flumeview-level
Advanced tools
+19
-16
@@ -100,21 +100,24 @@ 'use strict' | ||
| db.get(key, function (err, seq) { | ||
| if(err && err.name === 'NotFoundError') return cb(err) | ||
| if (err && err.name === 'NotFoundError') | ||
| return cb(err) | ||
| if (err) | ||
| return cb(explain(err, 'flumeview-level.get: key not found:'+key)) | ||
| if (err) { | ||
| if (err.code === 'flumelog:deleted') { | ||
| return db.del(key, (delErr) => { | ||
| if (delErr) { | ||
| return cb(explain(err, 'when trying to delete:'+key+'at since:'+log.since.value)) | ||
| } | ||
| log.get(seq, function (err, value) { | ||
| if (err) { | ||
| if (err.code === 'flumelog:deleted') { | ||
| return db.del(key, (delErr) => { | ||
| if (delErr) { | ||
| return cb(explain(err, 'when trying to delete:'+key+'at since:'+log.since.value)) | ||
| } | ||
| cb(null,null) | ||
| }) | ||
| cb(null, null, seq) | ||
| }) | ||
| } | ||
| return cb(explain(err, 'flumeview-level.get: index for: ' +key+'pointed at:'+seq+'but log error')) | ||
| } else { | ||
| cb(null, value, seq) | ||
| } | ||
| return cb(explain(err, 'flumeview-level.get: key not found:'+key)) | ||
| } | ||
| else | ||
| log.get(seq, function (err, value) { | ||
| if(err) cb(explain(err, 'flumeview-level.get: index for:'+key+'pointed at:'+seq+'but log error')) | ||
| else cb(null, value, seq) | ||
| }) | ||
| }) | ||
| }) | ||
@@ -121,0 +124,0 @@ }, |
+1
-1
| { | ||
| "name": "flumeview-level", | ||
| "description": "a flumeview on level", | ||
| "version": "3.0.11", | ||
| "version": "3.0.12", | ||
| "homepage": "https://github.com/flumedb/flumeview-level", | ||
@@ -6,0 +6,0 @@ "repository": { |
14930
0.38%226
0.89%