diff --git a/packages/node_modules/pouchdb-adapter-indexeddb/src/bulkDocs.js b/packages/node_modules/pouchdb-adapter-indexeddb/src/bulkDocs.js index 2f45d70a84..c5ace65993 100644 --- a/packages/node_modules/pouchdb-adapter-indexeddb/src/bulkDocs.js +++ b/packages/node_modules/pouchdb-adapter-indexeddb/src/bulkDocs.js @@ -38,6 +38,8 @@ export default function (api, req, opts, metadata, dbOpts, idbChanges, callback) const rewriteEnabled = dbOpts.name.indexOf("-mrview-") === -1; const autoCompaction = dbOpts.auto_compaction; + let maxSeqThisTxn = metadata.seq; + // We only need to track 1 revision for local documents function docsRevsLimit(doc) { return isLocalId(doc.id) ? 1 : revsLimit; @@ -211,7 +213,9 @@ export default function (api, req, opts, metadata, dbOpts, idbChanges, callback) // Bump the seq for every new (non local) revision written if (!isLocal) { doc.seq = ++metadata.seq; - + if (doc.seq > maxSeqThisTxn) { + maxSeqThisTxn = doc.seq; + } let delta = 0; // If its a new document, we wont decrement if deleted if (doc.isNewDoc) { @@ -304,6 +308,7 @@ export default function (api, req, opts, metadata, dbOpts, idbChanges, callback) function updateSeq(i) { if (i === lastWriteIndex) { + metadata.seq = Math.max(metadata.seq, maxSeqThisTxn); txn.objectStore(META_LOCAL_STORE).put(metadata); } }