Ensuring dedicated worker is closed on client close call.

Author: Chriztiaan

packages/web/src/db/adapters/WorkerWrappedAsyncDatabaseConnection.ts

@@ -19,6 +19,7 @@ export type WrappedWorkerConnectionOptions<Config extends ResolvedWebSQLOpenOpti
    * Need a remote in order to keep a reference to the Proxied worker
    */
   remote: Comlink.Remote<OpenAsyncDatabaseConnection<Config>>;
+  onClose?: () => void;
 };
 
 /**
@@ -59,6 +60,7 @@ export class WorkerWrappedAsyncDatabaseConnection<Config extends ResolvedWebSQLO
   async close(): Promise<void> {
     await this.baseConnection.close();
     this.options.remote[Comlink.releaseProxy]();
+    this.options.onClose?.();
   }
 
   execute(sql: string, params?: any[]): Promise<ProxiedQueryResult> {

packages/web/src/db/adapters/wa-sqlite/WASQLiteOpenFactory.ts

@@ -77,7 +77,14 @@ export class WASQLiteOpenFactory extends AbstractWebSQLOpenFactory {
           flags: this.resolvedFlags,
           encryptionKey: encryptionKey
         }),
-        identifier: this.options.dbFilename
+        identifier: this.options.dbFilename,
+        onClose: () => {
+          if (workerPort instanceof Worker) {
+            workerPort.terminate();
+          } else {
+            workerPort.close();
+          }
+        }
       });
     } else {
       // Don't use a web worker