| index.jsView |
|---|
| 57 | 57 … | module.exports = function (db, opts, keys, path) { |
| 58 | 58 … | |
| 59 | 59 … | var sysDB = db.sublevel('sys') |
| 60 | 60 … | var logDB = db.sublevel('log') |
| 61 | | - var feedDB = db.sublevel('fd') |
| 62 | | - var clockDB = require('./indexes/clock')(db, {path: db.location}) |
| 63 | | - |
| 61 … | + var feedDB = require('./indexes/feed')(db) |
| 62 … | + var clockDB = require('./indexes/clock')(db) |
| 64 | 63 … | var lastDB = db.sublevel('lst') |
| 65 | 64 … | var indexDB = db.sublevel('idx') |
| 66 | 65 … | var appsDB = db.sublevel('app') |
| 67 | 66 … | |
| 92 | 91 … | kv._value = op.value |
| 93 | 92 … | realtime(kv) |
| 94 | 93 … | } |
| 95 | 94 … | |
| 96 | | - |
| 97 | | - |
| 98 | | - |
| 99 | | - |
| 100 | | - |
| 101 | | - |
| 102 | | - add({ |
| 103 | | - key: [msg.timestamp, msg.author], value: id, |
| 104 | | - type: 'put', prefix: feedDB |
| 105 | | - }) |
| 106 | | - |
| 107 | 95 … | var localtime = op.timestamp = timestamp() |
| 108 | 96 … | |
| 109 | 97 … | |
| 110 | 98 … | add({ |
| 157 | 145 … | }) |
| 158 | 146 … | }) |
| 159 | 147 … | } |
| 160 | 148 … | |
| 161 | | - db.createFeed = function (keys, opts) { |
| 162 | | - return createFeed(db, keys, opts) |
| 163 | | - } |
| 164 | | - |
| 165 | 149 … | db.needsRebuild = function (cb) { |
| 166 | 150 … | sysDB.get('vmajor', function (err, dbvmajor) { |
| 167 | 151 … | dbvmajor = (dbvmajor|0) || 0 |
| 168 | 152 … | cb(null, dbvmajor < getVMajor()) |
| 202 | 186 … | } |
| 203 | 187 … | } |
| 204 | 188 … | |
| 205 | 189 … | |
| 206 | | - db.createFeedStream = function (opts) { |
| 207 | | - opts = stdopts(opts) |
| 208 | | - |
| 209 | | - ltgt.toLtgt(opts, opts, function (value) { |
| 210 | | - return [value, LO] |
| 211 | | - }, LO, HI) |
| 212 | | - |
| 213 | | - var _keys = opts.keys |
| 214 | | - var _values = opts.values |
| 215 | | - opts.keys = false |
| 216 | | - opts.values = true |
| 217 | | - |
| 218 | | - return pull( |
| 219 | | - pl.read(feedDB, opts), |
| 220 | | - lookup(_keys, _values) |
| 221 | | - ) |
| 222 | | - } |
| 223 | | - |
| 190 … | + db.createFeedStream = feedDB.createFeedStream |
| 224 | 191 … | |
| 225 | 192 … | |
| 226 | 193 … | |
| 227 | 194 … | |
| 255 | 222 … | } |
| 256 | 223 … | |
| 257 | 224 … | db.lookup = lookup |
| 258 | 225 … | |
| 259 | | - db.createHistoryStream = function (opts) { |
| 260 | | - return clockDB.createHistoryStream(opts) |
| 261 | | - } |
| 226 … | + db.createHistoryStream = clockDB.createHistoryStream |
| 262 | 227 … | |
| 263 | | - db.createUserStream = function (opts) { |
| 264 | | - opts = stdopts(opts) |
| 265 | | - |
| 266 | | - ltgt.toLtgt(opts, opts, function (value) { |
| 267 | | - return [opts.id, value] |
| 268 | | - }, LO, HI) |
| 269 | | - var _keys = opts.keys |
| 270 | | - var _values = opts.values |
| 228 … | + db.createUserStream = clockDB.createUserStream |
| 271 | 229 … | |
| 272 | | - opts.keys = false |
| 273 | | - opts.values = true |
| 274 | | - return pull( |
| 275 | | - clockDB.read(opts), |
| 276 | | - |
| 277 | | - lookup(_keys, _values) |
| 278 | | - ) |
| 279 | | - } |
| 280 | 230 … | |
| 281 | | - |
| 282 | 231 … | |
| 283 | 232 … | db.createWriteStream = function (cb) { |
| 284 | 233 … | return pull( |
| 285 | 234 … | paramap(function (data, cb) { |
| 540 | 489 … | |
| 541 | 490 … | var _close = db.close |
| 542 | 491 … | |
| 543 | 492 … | db.close = function (cb) { |
| 544 | | - var n = 2 |
| 493 … | + var n = 3 |
| 545 | 494 … | clockDB.close(next) |
| 495 … | + feedDB.close(next) |
| 546 | 496 … | _close.call(db, next) |
| 547 | 497 … | function next (err) { |
| 548 | 498 … | if(n < 0) return |
| 549 | 499 … | if(err) return n = -1, cb(err) |
| 556 | 506 … | } |
| 557 | 507 … | |
| 558 | 508 … | |
| 559 | 509 … | |
| 560 | | - |
| 561 | | - |
| 562 | | - |
| 563 | | - |
| 564 | | - |
| 565 | | - |
| 566 | | - |
| 567 | | - |
| 568 | | - |