feat: add project.close()

package.json

@@ -127,7 +127,7 @@
     "hyperswarm": "4.4.1",
     "magic-bytes.js": "^1.0.14",
     "map-obj": "^5.0.2",
-    "multi-core-indexer": "1.0.0-alpha.7",
+    "multi-core-indexer": "1.0.0-alpha.8",
     "p-defer": "^4.0.0",
     "p-timeout": "^6.1.2",
     "patch-package": "^8.0.0",

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
   #iconApi
   #syncApi
@@ -99,8 +100,8 @@ export class MapeoProject {
     this.#projectId = projectKeyToId(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,
     })
@@ -123,7 +124,7 @@ export class MapeoProject {
       projectKey,
       keyManager,
       storage: coreManagerStorage,
-      sqlite,
+      sqlite: this.#sqlite,
       logger: this.#l,
     })
 
@@ -137,7 +138,7 @@ export class MapeoProject {
         deviceInfoTable,
         iconTable,
       ],
-      sqlite,
+      sqlite: this.#sqlite,
       getWinner,
       mapDoc: (doc, version) => {
         switch (doc.schemaName) {
@@ -353,6 +354,20 @@ export class MapeoProject {
     await Promise.all([this.#coreManager.ready(), this.#ownershipWriteDone])
   }
 
+  /**
+   */
+  async close() {
+    this.#l.log('closing project %h', this.#projectId)
+    await this.#coreManager.close()
+    let dataStorePromises = []
+    for (const dataStore of Object.values(this.#dataStores)) {
+      dataStorePromises.push(dataStore.close())
+    }
+    await Promise.all(dataStorePromises)
+
+    this.#sqlite.close()
+  }
+
   /**
    * @param {import('multi-core-indexer').Entry[]} entries
    * @param {{projectIndexWriter: IndexWriter, sharedIndexWriter: IndexWriter}} indexWriters

test-e2e/project-crud.js

@@ -124,6 +124,62 @@ test('CRUD operations', async (t) => {
         'expected values returns from getMany()'
       )
     })
+    t.test('create, close and then create, update', async (st) => {
+      const projectId = await manager.createProject()
+      const project = await manager.getProject(projectId)
+      const values = new Array(5).fill(null).map(() => {
+        return getUpdateFixture(value)
+      })
+      for (const value of values) {
+        // @ts-ignore
+        await project[schemaName].create(value)
+      }
+      // @ts-ignore
+      const written = await project[schemaName].create(value)
+      await project.close()
+
+      await st.exception(async () => {
+        const updateValue = getUpdateFixture(value)
+        // @ts-ignore
+        await project[schemaName].update(written.versionId, updateValue)
+      }, 'should fail updating since the project is already closed')
+
+      await st.exception(async () => {
+        for (const value of values) {
+          // @ts-ignore
+          await project[schemaName].create(value)
+        }
+      }, 'should fail creating since the project is already closed')
+
+      // @ts-ignore
+      await st.exception.all(async () => {
+        await project[schemaName].getMany()
+      }, 'should fail getting since the project is already closed')
+    })
+    t.test(
+      'create project, close, then re-create a project and create',
+      async (st) => {
+        // create project
+        const projectId = await manager.createProject()
+        const project = await manager.getProject(projectId)
+        // close it
+        await project.close()
+        // re create project
+        const newProjectId = await manager.createProject()
+        const newProject = await manager.getProject(newProjectId)
+        const newValues = new Array(5).fill(null).map(() => {
+          return getUpdateFixture(value)
+        })
+
+        for (const value of newValues) {
+          await st.execution(
+            // @ts-ignore
+            await newProject[schemaName].create(value),
+            'create after `project.close()` and creating new project'
+          )
+        }
+      }
+    )
   }
 })