Indexeddb faster alldocs updated 2023 09 13

packages/node_modules/pouchdb-adapter-indexeddb/src/setup.js

@@ -1,14 +1,15 @@
 'use strict';
 
 import { uuid } from 'pouchdb-utils';
+import { isLocalId } from 'pouchdb-adapter-utils';
 
 import { META_STORE, DOC_STORE, rawIndexFields, naturalIndexName, correctIndexFields } from './util';
 
 //
 // Core PouchDB schema version. Increment this if we, as a library, want to make
 // schema changes in indexeddb. See upgradePouchDbSchema()
 //
-var POUCHDB_IDB_VERSION = 1;
+var POUCHDB_IDB_VERSION = 2;
 
 //
 // Functions that manage a combinate indexeddb version, by combining the current
@@ -91,17 +92,21 @@ function maintainNativeIndexes(openReq, reject) {
   };
 }
 
-function upgradePouchDbSchema(db, pouchdbVersion) {
+function upgradePouchDbSchema(db, tx, pouchdbVersion) {
   if (pouchdbVersion < 1) {
     var docStore = db.createObjectStore(DOC_STORE, {keyPath : 'id'});
     docStore.createIndex('seq', 'seq', {unique: true});
-    docStore.createIndex('_isDeleted_id', [ 'deleted', 'id' ], {unique: true});
 
     db.createObjectStore(META_STORE, {keyPath: 'id'});
   }
 
+  if (pouchdbVersion < 2) {
+    const docStore = tx.objectStore(DOC_STORE);
+    docStore.createIndex('_isDeleted_id', [ 'deleted', 'id' ], {unique: true});
+  }
+
   // Declare more PouchDB schema changes here
-  // if (pouchdbVersion < 2) { .. }
+  // if (pouchdbVersion < 3) { .. }
 }
 
 function openDatabase(openDatabases, api, opts, resolve, reject) {
@@ -123,11 +128,38 @@ function openDatabase(openDatabases, api, opts, resolve, reject) {
       throw new Error('Database was deleted while open');
     }
 
+    const tx = e.target.transaction;
     var db = e.target.result;
 
     var pouchdbVersion = getPouchDbVersion(e.oldVersion);
-    upgradePouchDbSchema(db, pouchdbVersion);
+    upgradePouchDbSchema(db, tx, pouchdbVersion);
     maintainNativeIndexes(openReq, reject);
+
+    if (pouchdbVersion < 2) {
+      const docStore = openReq.transaction.objectStore(DOC_STORE);
+      const metaStore = openReq.transaction.objectStore(META_STORE);
+
+      const allDocsReq = docStore.openCursor();
+      allDocsReq.onsuccess = event => {
+        const cursor = event.target.result;
+        if (!cursor) {
+          return;
+        }
+
+        const doc = cursor.value;
+
+        if (!isLocalId(doc.id)) {
+          return cursor.continue();
+        }
+
+        // Move _local/ docs to the META_STORE
+        metaStore.put(doc).onsuccess = () => {
+          cursor.delete(doc).onsuccess = () => {
+            cursor.continue();
+          };
+        };
+      };
+    }
   };
 
   openReq.onblocked = function (e) {