feat: .withIdPrefix(prefix)

helpers/add-many.js

@@ -1,11 +1,28 @@
 'use strict'
 
+var uuid = require('pouchdb-utils').uuid
+
 var toDoc = require('../utils/to-doc')
 var addTimestamps = require('../utils/add-timestamps')
 
-module.exports = function addMany (objects) {
+module.exports = function addMany (objects, prefix) {
   objects.forEach(addTimestamps)
-  return this.bulkDocs(objects.map(toDoc))
+
+  if (prefix) {
+    objects.forEach(function (object) {
+      if (!object.id) {
+        object.id = uuid()
+      }
+
+      if (prefix) {
+        object.id = prefix + object.id
+      }
+    })
+  }
+
+  var docs = objects.map(toDoc)
+
+  return this.bulkDocs(docs)
 
   .then(function (responses) {
     return responses.map(function (response, i) {

helpers/add-one.js

@@ -2,18 +2,25 @@
 
 var PouchDBErrors = require('pouchdb-errors')
 var Promise = require('lie')
+var uuid = require('pouchdb-utils').uuid
 
 var toDoc = require('../utils/to-doc')
 var addTimestamps = require('../utils/add-timestamps')
 
-module.exports = function addOne (object) {
+module.exports = function addOne (object, prefix) {
   if (typeof object !== 'object') {
     return Promise.reject(PouchDBErrors.NOT_AN_OBJECT)
   }
 
-  var method = object.id ? 'put' : 'post'
+  if (!object.id) {
+    object.id = uuid()
+  }
+
+  if (prefix) {
+    object.id = prefix + object.id
+  }
 
-  return this[method](toDoc(addTimestamps(object)))
+  return this.put(toDoc(addTimestamps(object)))
 
   .then(function (response) {
     object.id = response.id

helpers/find-many.js

@@ -3,9 +3,15 @@
 var toId = require('../utils/to-id')
 var toObject = require('../utils/to-object')
 
-module.exports = function findMany (idsOrObjects) {
+module.exports = function findMany (idsOrObjects, prefix) {
   var ids = idsOrObjects.map(toId)
 
+  if (prefix) {
+    ids = ids.map(function (id) {
+      return id.substr(0, prefix.length) === prefix ? id : prefix + id
+    })
+  }
+
   return this.allDocs({keys: ids, include_docs: true})
 
   .then(function (response) {

helpers/find-one.js

@@ -3,8 +3,13 @@
 var toId = require('../utils/to-id')
 var toObject = require('../utils/to-object')
 
-module.exports = function findOne (idOrObject) {
+module.exports = function findOne (idOrObject, prefix) {
   var id = toId(idOrObject)
+
+  if (prefix && id.substr(0, prefix.length) !== prefix) {
+    id = prefix + id
+  }
+
   return this.get(id)
 
   .then(toObject)

helpers/find-or-add-many.js

@@ -2,29 +2,35 @@ var toId = require('../utils/to-id')
 var findMany = require('./find-many')
 var addMany = require('./add-many')
 
-module.exports = function findOrAddMany (state, passedObjects) {
+module.exports = function findOrAddMany (state, passedObjects, prefix) {
   var self = this
   var foundObjects
   var passedObjectIds = passedObjects.map(toId)
 
-  return findMany.call(this, passedObjectIds)
+  if (prefix) {
+    passedObjectIds = passedObjectIds.map(function (id) {
+      return prefix + id
+    })
+  }
+
+  return findMany.call(this, passedObjectIds, prefix)
 
   .then(function (_foundObjects) {
     foundObjects = _foundObjects
 
     var foundObjectIds = foundObjects.map(toId)
     var notFoundObjects = passedObjects.reduce(function (notFoundObjects, passedObject) {
-      if (foundObjectIds.indexOf(passedObject.id) === -1) {
+      if (foundObjectIds.indexOf((prefix || '') + passedObject.id) === -1) {
         notFoundObjects.push(passedObject)
       }
       return notFoundObjects
     }, [])
 
     if (state) {
-      return addMany.call(self, notFoundObjects)
+      return addMany.call(self, notFoundObjects, prefix)
     }
 
-    return addMany.call(self, notFoundObjects)
+    return addMany.call(self, notFoundObjects, prefix)
   })
 
   .then(function (addedObjects) {

helpers/find-or-add-one.js

@@ -7,7 +7,7 @@ var toId = require('../utils/to-id')
 var findOne = require('./find-one')
 var addOne = require('./add-one')
 
-function findOrAddOne (state, idOrObject, newObject) {
+function findOrAddOne (state, idOrObject, newObject, prefix) {
   var self = this
   var id = toId(idOrObject)
 
@@ -19,7 +19,7 @@ function findOrAddOne (state, idOrObject, newObject) {
     return Promise.reject(PouchDBErrors.MISSING_ID)
   }
 
-  return findOne.call(this, id)
+  return findOne.call(this, id, prefix)
 
   .catch(function (/* error */) {
     if (typeof newObject === 'object') {
@@ -29,7 +29,7 @@ function findOrAddOne (state, idOrObject, newObject) {
     }
 
     if (state) {
-      return addOne.call(self, newObject)
+      return addOne.call(self, newObject, prefix)
     }
 
     return addOne.call(self, newObject)

helpers/update-many.js

@@ -10,12 +10,12 @@ var toId = require('../utils/to-id')
 
 var findMany = require('./find-many')
 
-module.exports = function updateMany (array, change) {
+module.exports = function updateMany (array, change, prefix) {
   var self = this
   var objects
   var ids = array.map(toId)
 
-  return findMany.call(this, array)
+  return findMany.call(this, array, prefix)
 
   .then(function (objects) {
     if (change) {

helpers/update-one.js

@@ -10,19 +10,19 @@ var addTimestamps = require('../utils/add-timestamps')
 
 var findOne = require('./find-one')
 
-module.exports = function updateOne (idOrObject, change) {
+module.exports = function updateOne (idOrObject, change, prefix) {
   var self = this
   var object
 
   if (typeof idOrObject === 'string' && !change) {
     return Promise.reject(PouchDBErrors.NOT_AN_OBJECT)
   }
 
-  return findOne.call(this, idOrObject)
+  return findOne.call(this, idOrObject, prefix)
 
   .then(function (object) {
     if (!change) {
-      return extend(object, idOrObject)
+      return extend(object, idOrObject, {id: object.id, _rev: object._rev})
     }
     return changeObject(change, object)
   })

helpers/update-or-add-many.js

@@ -2,15 +2,22 @@ var toId = require('../utils/to-id')
 var addMany = require('./add-many')
 var updateMany = require('./update-many')
 
-module.exports = function updateOrAddMany (passedObjects) {
+module.exports = function updateOrAddMany (passedObjects, prefix) {
   var self = this
   var addedObjects
   var passedObjectIds = passedObjects.map(toId)
 
-  return addMany.call(this, passedObjects)
+  if (prefix) {
+    passedObjectIds = passedObjectIds.map(function (id) {
+      return prefix + id
+    })
+  }
+
+  return addMany.call(this, passedObjects, prefix)
 
   .then(function (_addedObjectsAndErrors) {
     addedObjects = _addedObjectsAndErrors
+
     var conflicting = passedObjects.reduce(function (array, passedObject, i) {
       var objectOrError = _addedObjectsAndErrors[i]
       var isConflictError = objectOrError instanceof Error && objectOrError.status === 409
@@ -21,7 +28,7 @@ module.exports = function updateOrAddMany (passedObjects) {
       return array
     }, [])
 
-    return updateMany.call(self, conflicting)
+    return updateMany.call(self, conflicting, null, prefix)
   })
 
   .then(function (updatedObjects) {

helpers/update-or-add-one.js

@@ -2,9 +2,9 @@ var toId = require('../utils/to-id')
 var addOne = require('./add-one')
 var updateOne = require('./update-one')
 
-module.exports = function updateOrAddOne (idOrObject, newObject) {
+module.exports = function updateOrAddOne (idOrObject, newObject, prefix) {
   var self = this
-  return updateOne.call(this, idOrObject, newObject)
+  return updateOne.call(this, idOrObject, newObject, prefix)
 
   .catch(function (error) {
     if (error.status !== 404) {
@@ -13,9 +13,9 @@ module.exports = function updateOrAddOne (idOrObject, newObject) {
 
     if (newObject) {
       newObject.id = toId(idOrObject)
-      return addOne.call(self, newObject)
+      return addOne.call(self, newObject, prefix)
     }
 
-    return addOne.call(self, idOrObject)
+    return addOne.call(self, idOrObject, prefix)
   })
 }

index.js

@@ -23,6 +23,7 @@ function hoodieApi (options) {
     updateAll: require('./update-all').bind(this),
     remove: require('./remove').bind(this),
     removeAll: require('./remove-all').bind(this),
+    withIdPrefix: require('./with-id-prefix').bind(this, state),
     on: require('./lib/on').bind(this, state),
     one: require('./lib/one').bind(this, state),
     off: require('./lib/off').bind(this, state),