Skip to content

Commit e15396c

Browse files
committed
fix index cleaning bug
1 parent d7af904 commit e15396c

File tree

1 file changed

+6
-5
lines changed

1 file changed

+6
-5
lines changed

index.js

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -100,15 +100,16 @@ function AutoIndex (db, idb, reduce) {
100100
var tr = Transform({ objectMode: true })
101101

102102
tr._transform = function (chunk, enc, done) {
103-
var key = chunk.value
103+
var dbKey = chunk.value
104+
var idbKey = chunk.key
104105
if (opts.values === false) {
105-
done(null, key)
106+
done(null, dbKey)
106107
return
107108
}
108109

109-
db.get(key, function (err, value) {
110+
db.get(dbKey, function (err, value) {
110111
if (err && err.type === 'NotFoundError') {
111-
idb.del(key, done)
112+
idb.del(idbKey, done)
112113
} else if (err) {
113114
done(err)
114115
} else {
@@ -120,7 +121,7 @@ function AutoIndex (db, idb, reduce) {
120121
done(null, value)
121122
} else {
122123
done(null, {
123-
key: key,
124+
key: dbKey,
124125
value: value
125126
})
126127
}

0 commit comments

Comments
 (0)