Comparing version 2.2.0 to 2.2.1
var path = require('path') | ||
var meta = require(path.join(__dirname, 'lib', 'meta.js')) | ||
var commands = require(path.join(__dirname, 'lib', 'commands')) | ||
@@ -44,6 +45,9 @@ module.exports = Dat | ||
if (err) return onReady() | ||
self._storage(opts, onReady) | ||
commands._ensureExists({path: self.dir}, function (err) { | ||
if (err) return onReady() | ||
self._storage(opts, onReady) | ||
}) | ||
}) | ||
} | ||
Dat.prototype = require(path.join(__dirname, 'lib', 'commands')) | ||
Dat.prototype = commands |
@@ -122,2 +122,2 @@ var http = require('http') | ||
if (req.method === "DELETE") return this.delete(req, res) | ||
} | ||
} |
@@ -241,4 +241,6 @@ var path = require('path') | ||
if (!columns) columns = this.meta.json.columns | ||
var primary = this.primary | ||
var primaryIndex | ||
if (Array.isArray(primary)) { | ||
@@ -252,2 +254,3 @@ primaryIndex = [] | ||
} | ||
this.primaryIndex = primaryIndex | ||
@@ -287,2 +290,3 @@ } | ||
var doc = {} | ||
if (row._rev) { | ||
@@ -292,2 +296,3 @@ doc._rev = row._rev | ||
} | ||
if (this.primary) { | ||
@@ -297,3 +302,5 @@ doc._id = this.primaryKeyAt(0) | ||
} | ||
var meta = store.updateRevision(doc, row) | ||
if (!meta) { | ||
@@ -305,8 +312,13 @@ rows[i] = {success: true, row: doc, existed: true} | ||
} | ||
var seq = store.seq = store.seq + 1 | ||
var keys = store.rowKeys(meta._id, meta._rev, seq) | ||
if (row.length === 0) row = whiteSpace | ||
batch.put(keys.seq, JSON.stringify([seq, meta._id, meta._rev])) | ||
batch.put(keys.row, row) | ||
rows[i] = {success: true, row: meta} | ||
pending-- | ||
@@ -375,2 +387,2 @@ if (pending === 0) commit() | ||
return data[0] | ||
} | ||
} |
{ | ||
"name": "dat", | ||
"version": "2.2.0", | ||
"version": "2.2.1", | ||
"description": "real-time replication and versioning for large tabular data sets", | ||
@@ -10,3 +10,3 @@ "main": "index.js", | ||
"scripts": { | ||
"test": "node test/test.js" | ||
"test": "node test/run.js" | ||
}, | ||
@@ -49,3 +49,4 @@ "repository": { | ||
"json-multibuffer-stream": "~0.0.1", | ||
"connections": "~0.0.1" | ||
"connections": "~0.0.1", | ||
"ldjson-stream": "~0.0.1" | ||
}, | ||
@@ -52,0 +53,0 @@ "directories": { |
@@ -14,3 +14,3 @@ ## Example usage | ||
cat some_csv.csv | dat --csv | ||
cat some_csv.csv | cat --csv -d $'\r\n' # custom line delimiter, --delimiter= works too | ||
cat some_csv.csv | dat --csv -d $'\r\n' # custom line delimiter, --delimiter= works too | ||
@@ -17,0 +17,0 @@ # specify a primary key to use |
Dynamic require
Supply chain riskDynamic require can indicate the package is performing dangerous or unsafe dynamic code execution.
Found 1 instance in 1 package
14227149
31
2210
31
14
+ Addedldjson-stream@~0.0.1
+ Addedldjson-stream@0.0.1(transitive)