feat: add project.close()

src/datastore/index.js

@@ -192,4 +192,9 @@ export class DataStore extends TypedEmitter {
     if (!block) throw new Error('Not Found')
     return block
   }
+
+  async close() {
+    this.#coreIndexer.removeAllListeners()
+    await this.#coreIndexer.close()
+  }
 }

src/mapeo-project.js

@@ -61,6 +61,7 @@ export class MapeoProject {
   #coreOwnership
   #capabilities
   #ownershipWriteDone
+  #sqlite
   #memberApi
   #projectPublicId
   #iconApi
@@ -101,8 +102,8 @@ export class MapeoProject {
     this.#projectPublicId = projectKeyToPublicId(projectKey)
 
     ///////// 1. Setup database
-    const sqlite = new Database(dbPath)
-    const db = drizzle(sqlite)
+    this.#sqlite = new Database(dbPath)
+    const db = drizzle(this.#sqlite)
     migrate(db, {
       migrationsFolder: new URL('../drizzle/project', import.meta.url).pathname,
     })
@@ -125,7 +126,7 @@ export class MapeoProject {
       projectKey,
       keyManager,
       storage: coreManagerStorage,
-      sqlite,
+      sqlite: this.#sqlite,
       logger: this.#l,
     })
 
@@ -138,7 +139,7 @@ export class MapeoProject {
         roleTable,
         deviceInfoTable,
       ],
-      sqlite,
+      sqlite: this.#sqlite,
       getWinner,
       mapDoc: (doc, version) => {
         switch (doc.schemaName) {
@@ -345,6 +346,20 @@ export class MapeoProject {
     await Promise.all([this.#coreManager.ready(), this.#ownershipWriteDone])
   }
 
+  /**
+   */
+  async close() {
+    this.#l.log('closing project %h', this.#projectId)
+    this.#coreManager.close()
+
+    // eslint-disable-next-line no-unused-vars
+    for await (let [_, dataStore] of Object.entries(this.#dataStores)) {
+      await dataStore.close()
+    }
+
+    this.#sqlite.close()
+  }
+
   /**
    * @param {import('multi-core-indexer').Entry[]} entries
    * @param {{projectIndexWriter: IndexWriter, sharedIndexWriter: IndexWriter}} indexWriters