change log ids in data keys and current table

bin/blobs-put.js

@@ -20,9 +20,11 @@ module.exports = function(dat, opts, cb) {
       row = existing
     }
     var blobKey = opts.name || path.basename(blob)
-    var ws = dat.createBlobWriteStream(blobKey, row, function(err, updated) {
+    var options = { filename:blobKey, version:version }
+
+    var ws = dat.createBlobWriteStream(options, row, function(err, updated) {
       if (err) return cb(err)
-      console.log('Attached ' + blobKey + ' successfully to', updated.key)
+      console.log('Attached ' + options.filename + ' successfully to', updated.key)
       cb()
     })
 

bin/rows-put.js

@@ -30,4 +30,4 @@ module.exports = function (dat, opts, cb) {
       cb()
     })
   }
-}
+}

cli.js

@@ -102,4 +102,4 @@ function close() {
   } else {
     dat.close()
   }
-}
+}

lib/commands.js

@@ -428,12 +428,16 @@ dat.createBlobWriteStream = function(options, doc, cb) {
   if (!cb) cb = noop
 
   debug('createBlobWriteStream', options.filename)
+  var version = doc.version
+  if (!doc.version && options.version) {
+    version = options.version
+  }
 
   var blobWrite = this.blobs.createWriteStream(options, function(err, blob) {
     if (err) return cb(err)
     if (!doc.blobs) doc.blobs = {}
     doc.blobs[options.filename] = blob
-    self.put(doc, {version:doc.version}, cb)
+    self.put(doc, {version:options.version}, cb)
   })
 
   return blobWrite
@@ -783,10 +787,10 @@ dat.put = function(key, doc, opts, cb) {
 
     var ready = function(err, doc) {
       if (err) return cb(err)
-
-      self.storage.put(key, isBuffer ? doc : self.schema.encode(doc), {version:version, force:opts.force}, function(err, value, version) {
+      
+      self.storage.put(key, isBuffer ? doc : self.schema.encode(doc), {version:version, force:opts.force}, function(err, value, version, change) {
         if (err) return cb(err)
-        cb(null, self.schema.decode(value, {key:key, version:version}))
+        cb(null, self.schema.decode(value, {key:key, version:version, change:change}))
       })
     }
 
@@ -805,9 +809,9 @@ dat.get = function(key, opts, cb) {
 
   var self = this
 
-  this.storage.get(key, opts, function(err, value, version) {
+  this.storage.get(key, opts, function(err, value, version, change) {
     if (err) return cb(err)
-    var val = self.schema.decode(value, {key:key, version:version, blobsOnly:opts.blobsOnly})
+    var val = self.schema.decode(value, {key:key, version:version, change:change, blobsOnly:opts.blobsOnly})
     if (self.afterGet) self.afterGet(val, cb)
     else cb(null, val)
   })

lib/schema.js

@@ -168,6 +168,7 @@ Schema.prototype.decode = function(buf, opts) {
   var msg = this.messages.Row.decode(buf)
   msg.key = opts.key
   msg.version = opts.version
+  msg.change = opts.change
   return msg
 }
 
@@ -203,4 +204,4 @@ Schema.prototype._tag = function() {
   return 1 + this.fields.map(toTag).reduce(max, 0)
 }
 
-module.exports = Schema
+module.exports = Schema

package.json

@@ -1,6 +1,6 @@
 {
   "name": "dat",
-  "version": "6.8.1",
+  "version": "6.9.0",
   "description": "real-time replication and versioning for data sets (tabular and blobs)",
   "preferGlobal": true,
   "keywords": [
@@ -52,7 +52,7 @@
     "isnumber": "^1.0.0",
     "json-protobuf-encoding": "^1.0.1",
     "ldjson-stream": "~1.0.0",
-    "level-dat": "^4.4.1",
+    "level-dat": "^4.5.0",
     "level-events": "^1.0.2",
     "level-js": "^2.1.3",
     "level-manifest": "~1.2.0",