4.0.0 - use abstract-blob-store 2.x API

Author: max-mapper

index.js

@@ -82,10 +82,10 @@ Blobs.prototype.createWriteStream = function(options, cb) {
     function handleUploadResponse() {
       return concat(function(body) {
         var response = JSON.parse(body)
-        self.addProperty(response.id, 'hash', response.md5Checksum, function(err, resp, props) {
+        self.addProperty(response.id, 'key', response.md5Checksum, function(err, resp, props) {
           if (err) return cb(err)
           if (resp.statusCode > 299) return cb(new Error(JSON.stringify(props)))
-          response.hash = response.md5Checksum
+          response.key = response.md5Checksum
           response.size = +response.fileSize
           if (process.env['DEBUG']) debug('createWriteStream done', JSON.stringify(response))
           cb(null, response)
@@ -115,7 +115,7 @@ Blobs.prototype.createReadStream = function(opts) {
   var self = this
   var duplex = duplexify()
   debug('createReadStream', JSON.stringify(opts))
-  self.get(opts.hash, function(err, file) {
+  self.get(opts.key, function(err, file) {
     if (err) return duplex.destroy(err)
     if (!file) return duplex.destroy(new Error('Blob not found'))
     var req = self.request({
@@ -130,7 +130,7 @@ Blobs.prototype.createReadStream = function(opts) {
 
 Blobs.prototype.exists = function(opts, cb) {
   var self = this
-  self.get(opts.hash, function(err, file) {
+  self.get(opts.key, function(err, file) {
     if (err) return cb(err)
     cb(null, !!file)
   })
@@ -184,7 +184,7 @@ Blobs.prototype.request = function(opts, cb) {
 
 Blobs.prototype.get = function(hash, cb) {
   var self = this
-  var query = "properties has { key='hash' and value='" + hash + "' and visibility='PRIVATE' } and trashed = false"
+  var query = "properties has { key='key' and value='" + hash + "' and visibility='PRIVATE' } and trashed = false"
   var reqOpts = {
     contentType: 'application/json',
     query: '?' + formEncoder.encode({q: query}),
@@ -202,7 +202,7 @@ Blobs.prototype.get = function(hash, cb) {
 Blobs.prototype.remove = function(opts, cb) {
   var self = this
 
-  self.get(opts.hash, function(err, file) {
+  self.get(opts.key, function(err, file) {
     if (err) return cb(err)
     var reqOpts = {
       method: 'DELETE',

package.json

@@ -1,6 +1,6 @@
 {
   "name": "google-drive-blobs",
-  "version": "3.1.0",
+  "version": "4.0.0",
   "description": "a simple content-addressable streaming blob store API on top of google drive",
   "main": "index.js",
   "scripts": {
@@ -18,7 +18,7 @@
     "through2": "^0.5.1"
   },
   "devDependencies": {
-    "abstract-blob-store": "^1.1.1"
+    "abstract-blob-store": "^2.0.1"
   },
   "repository": {
     "type": "git",

readme.md

@@ -26,7 +26,7 @@ returns a writable stream that you can pipe data to.
 
 ### blobs.createReadStream(opts)
 
-opts should be `{hash: md5}`
+opts should be `{key: md5}`
 
 returns a readable stream of data for the first file in your drive whose md5 checksum matches the `md5` argument
 
@@ -36,7 +36,7 @@ gets google drive metadata for the first file in your drive whose md5 checksum m
 
 ### blobs.remove(opts, cb)
 
-opts should be `{hash: md5}`
+opts should be `{key: md5}`
 
 deletes file by md5
 

test.js

@@ -38,7 +38,7 @@ test('uploads a blob', function(t) {
   var ws = blobs.createWriteStream({filename: 'test.js'}, function(err, resp) {
     t.false(err, 'should not error')
     if (err) console.error(err)
-    t.equal(resp.hash, testmd5)
+    t.equal(resp.key, testmd5)
     t.end()
   })
 
@@ -58,7 +58,7 @@ test('gets blob metadata by md5', function(t) {
 test('gets a blob', function(t) {
   var blobs = gdb(tokens)
 
-  var ws = blobs.createReadStream({hash: testmd5})
+  var ws = blobs.createReadStream({key: testmd5})
 
   ws.on('error', function(e) {
     t.error(e)
@@ -74,7 +74,7 @@ test('gets a blob', function(t) {
 test('deletes a blob', function(t) {
   var blobs = gdb(tokens)
 
-  var ws = blobs.remove({hash: testmd5}, function(err) {
+  var ws = blobs.remove({key: testmd5}, function(err) {
     t.false(err, 'snould not err')
     blobs.get(testmd5, function(err, file) {
       t.false(err, 'should not err')