| 1 | var pull = require('pull-stream')
|
| 2 | var pl = require('pull-level')
|
| 3 |
|
| 4 | module.exports = function (db) {
|
| 5 | var set = {}
|
| 6 |
|
| 7 | pull(
|
| 8 | pl.read(db, { live: true }),
|
| 9 | pull.drain(function (e) {
|
| 10 | if (!e.sync) {}
|
| 11 | if (e.type === 'del') delete set[e.key]
|
| 12 | else set[e.key] = e.value
|
| 13 | })
|
| 14 | )
|
| 15 |
|
| 16 | return {
|
| 17 | set: set,
|
| 18 | add: function (key, cb) {
|
| 19 | db.put(key, -1, cb)
|
| 20 | },
|
| 21 | remove: function (key, cb) {
|
| 22 | db.del(key, cb)
|
| 23 | }
|
| 24 | }
|
| 25 | }
|