better change handling

seigel · Sep 7, 2016 · 0fd4765 · 0fd4765
1 parent 352717b
commit 0fd4765
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 4 deletions.
diff --git a/packages/pouchdb-adapter-asyncstorage/src/bulk_docs.js b/packages/pouchdb-adapter-asyncstorage/src/bulk_docs.js
@@ -113,7 +113,7 @@ export default function (db, req, opts, callback) {
         result: {
           ok: true,
           id: newDoc.id,
-          rev: newDoc.deleted ? '0-0' : newDoc.rev
+          rev: newDoc.rev
         }
       }
     }
@@ -137,7 +137,7 @@ export default function (db, req, opts, callback) {
         result: {
           ok: true,
           id: newDoc.id,
-          rev: newDoc.deleted ? '0-0' : newDoc.rev
+          rev: newDoc.rev
         }
       }
     }

diff --git a/packages/pouchdb-adapter-asyncstorage/src/changes.js b/packages/pouchdb-adapter-asyncstorage/src/changes.js
@@ -31,6 +31,7 @@ export default function (db, api, opts) {
   const filter = filterChange(opts)
   const complete = opts.complete
   const onChange = opts.onChange
+  const processChange = opts.processChange
 
   db.storage.getKeys((error, keys) => {
     if (error) return complete(error)
@@ -62,10 +63,12 @@ export default function (db, api, opts) {
 
         const results = []
         let lastChangeSeq
-        for (let index = 0; index < docs.length && results.length <= limit; index++) {
+        for (let index = 0; index < docs.length; index++) {
+          if (limit && results.length > limit) break
+
           const doc = docs[index]
           const data = dataObj[doc.id]
-          const change = opts.processChange(data, doc, opts)
+          const change = processChange(data, doc, opts)
           change.seq = doc.seq
 
           const filtered = filter(change)