flumeview-level
Advanced tools
+17
-3
@@ -101,7 +101,19 @@ 'use strict' | ||
| if(err && err.name === 'NotFoundError') return cb(err) | ||
| if(err) 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)) | ||
| } | ||
| cb(null,null) | ||
| }) | ||
| } | ||
| 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) | ||
| else cb(null, value, seq) | ||
| }) | ||
@@ -139,3 +151,5 @@ }) | ||
| Paramap(function (data, cb) { | ||
| if(data.sync) return cb(null, data) | ||
| if (data.sync) return cb(null, data) | ||
| if (data.type === 'del') return cb(null, null) | ||
| log.get(data.value, function (err, value) { | ||
@@ -142,0 +156,0 @@ if(err) { |
+1
-1
| { | ||
| "name": "flumeview-level", | ||
| "description": "a flumeview on level", | ||
| "version": "3.0.10", | ||
| "version": "3.0.11", | ||
| "homepage": "https://github.com/flumedb/flumeview-level", | ||
@@ -6,0 +6,0 @@ "repository": { |
New author
Supply chain riskA new npm collaborator published a version of the package for the first time. New collaborators are usually benign additions to a project, but do indicate a change to the security surface area of a package.
Found 1 instance in 1 package
14873
2.84%224
5.16%0
-100%