Fix the test.

Author: rkistner

packages/driver/src/util/SingleConnectionPool.ts

@@ -29,7 +29,6 @@ export class SingleConnectionPool implements SqliteDriverConnectionPool {
   async reserveConnection(
     options?: ReserveConnectionOptions
   ): Promise<ReservedConnection> {
-    console.log('single reserveConnection', this.connection.lock);
     if (options?.signal?.aborted) {
       throw new Error('Aborted');
     }

packages/wa-sqlite-driver/src/OPFSCoopSyncVFS2.ts

@@ -62,10 +62,10 @@ export class OPFSCoopSyncVFS2 extends FacadeVFS {
   mapIdToFile = new Map<number, File>();
 
   lastError = null;
-  // log = null; //function(...args) { console.log(`[${contextName}]`, ...args) };
-  log = function (...args) {
-    console.log(`[OPFSCoopSyncVFS2]`, ...args);
-  };
+  log = null;
+  // log = function (...args) {
+  //   console.log(`[OPFSCoopSyncVFS2]`, ...args);
+  // };
 
   persistentFiles = new Map<string, PersistentFile>();
   boundAccessHandles = new Map<string, FileSystemSyncAccessHandle>();

packages/wa-sqlite-driver/src/pool.ts

@@ -38,7 +38,6 @@ export function waSqliteWorkerPool(path: string): SqliteDriverConnectionPool {
       async openConnection(
         options?: ReserveConnectionOptions & { connectionName?: string }
       ): Promise<SqliteDriverConnection> {
-        console.log('openConnection', options);
         const connection = new WorkerDriverConnection(
           new Worker(new URL('./wa-sqlite-worker.js', import.meta.url), {
             type: 'module'

packages/wa-sqlite-driver/src/wa-sqlite-worker.ts

@@ -9,7 +9,6 @@ setupDriverWorker({
     if (vfs != null) {
       throw new Error('Can only open one connection');
     }
-    console.log('open', options);
     vfs = await OPFSCoopSyncVFS2.create(
       'test.db',
       module,

packages/wa-sqlite-driver/src/worker_threads/setup.ts

@@ -27,8 +27,6 @@ export function setupDriverPort(config: WorkerDriverConfig) {
   const listener = async (value: any) => {
     const [message, id, args] = value.data;
 
-    console.log('received', message, id, args);
-
     if (message == 'open') {
       const open = new Deferred<void>();
       opened = open.promise;

packages/wa-sqlite-driver/src/worker_threads/worker-driver.ts

@@ -117,6 +117,10 @@ export class WorkerDriverConnection implements SqliteDriverConnection {
     this._maybeFlush();
   }
 
+  log(...args: any[]) {
+    console.log(this.options.path, this.options.connectionName, ...args);
+  }
+
   private registerCallback(callback: (value: any) => void) {
     const id = this.nextCallbackId++;
     this.callbacks.set(id, callback);

packages/wa-sqlite-driver/test/src/concurrency.test.ts

@@ -83,5 +83,6 @@ describe('concurrency tests', () => {
       })();
       promises.push(p);
     }
+    await Promise.all(promises);
   });
 });

packages/wa-sqlite-driver/test/src/driver.test.ts

@@ -5,7 +5,6 @@ describeDriverTests(
   'wa-sqlite',
   { getColumns: true, rawResults: true, allowsMissingParameters: false },
   async (path) => {
-    console.log('open', path);
     return waSqliteSingleWorker(path);
   }
 );