Add wa-sqlite implementation.

Author: rkistner

package.json

@@ -18,7 +18,7 @@
     "ts-node": "^10.9.2",
     "tsx": "^4.16.2",
     "typescript": "^5.4.5",
-    "vitest": "^1.5.0"
+    "vitest": "^2.0.5"
   },
   "packageManager": "[email protected]+sha512.38dc6fba8dba35b39340b9700112c2fe1e12f10b17134715a4aa98ccf7bb035e76fd981cf0bb384dfa98f8d6af5481c2bef2f4266a24bfa20c34eb7147ce0b5e"
 }

packages/api/src/impl.ts

@@ -303,12 +303,12 @@ export class ConnectionImpl implements SqliteConnection {
   }
 
   async begin(options?: TransactionOptions): Promise<SqliteBeginTransaction> {
-    await this.init();
+    this.init();
 
     if ((options?.type ?? 'exclusive') == 'exclusive') {
-      await this._beginExclusive!.select();
+      await this._beginExclusive!.run();
     } else {
-      await this._begin!.select();
+      await this._begin!.run();
     }
 
     return new BeginTransactionImpl(this);
@@ -321,18 +321,18 @@ export class ConnectionImpl implements SqliteConnection {
     this.init();
 
     if ((options?.type ?? 'exclusive') == 'exclusive') {
-      await this._beginExclusive!.select();
+      await this._beginExclusive!.run();
     } else {
-      await this._begin!.select();
+      await this._begin!.run();
     }
     try {
       const tx = new TransactionImpl(this);
       const result = await callback(tx);
 
-      await this.commit!.select();
+      await this.commit!.run();
       return result;
     } catch (e) {
-      await this.rollback!.select();
+      await this.rollback!.run();
       throw e;
     }
   }

packages/api/test/src/impl-tests.ts

@@ -12,13 +12,13 @@ export function describeImplTests(
     let dbPath: string;
 
     const open = async () => {
-      const dir = path.dirname(dbPath);
-      try {
-        await fs.mkdir(dir);
-      } catch (e) {}
-      try {
-        await fs.rm(dbPath);
-      } catch (e) {}
+      // const dir = path.dirname(dbPath);
+      // try {
+      //   await fs.mkdir(dir);
+      // } catch (e) {}
+      // try {
+      //   await fs.rm(dbPath);
+      // } catch (e) {}
       return factory(dbPath);
     };
 

packages/driver-tests/src/driver-tests.ts

@@ -19,13 +19,13 @@ export function describeDriverTests(
     let dbPath: string;
 
     const open = async () => {
-      const dir = path.dirname(dbPath);
-      try {
-        await fs.mkdir(dir);
-      } catch (e) {}
-      try {
-        await fs.rm(dbPath);
-      } catch (e) {}
+      // const dir = path.dirname(dbPath);
+      // try {
+      //   await fs.mkdir(dir);
+      // } catch (e) {}
+      // try {
+      //   await fs.rm(dbPath);
+      // } catch (e) {}
       const db = factory(dbPath);
       return db;
     };

packages/driver-tests/src/test.ts

@@ -5,7 +5,7 @@ export interface TestContext {
   fullName: string;
 }
 
-export const isVitest = process.env.VITEST == 'true';
+export const isVitest = true || process.env.VITEST == 'true';
 export const isMocha = !isVitest;
 
 let testImpl, describeImpl, beforeEachImpl;

packages/wa-sqlite-driver/package.json

@@ -0,0 +1,33 @@
+{
+  "name": "@sqlite-js/wa-sqlite-driver",
+  "version": "0.0.1",
+  "description": "",
+  "type": "module",
+  "scripts": {
+    "build": "tsc -b",
+    "test": "pnpm build && vitest",
+    "clean": "tsc -b --clean && tsc -b ./test/tsconfig.json --clean && rm -rf lib test/lib"
+  },
+  "exports": {
+    ".": "./lib/index.js"
+  },
+  "keywords": [],
+  "author": "",
+  "license": "MIT",
+  "dependencies": {
+    "@journeyapps/wa-sqlite": "^0.3.0",
+    "@sqlite-js/driver": "workspace:^",
+    "async-mutex": "^0.5.0"
+  },
+  "devDependencies": {
+    "vite-plugin-top-level-await": "^1.4.2",
+    "vite-plugin-wasm": "^3.3.0",
+    "@sqlite-js/driver-tests": "workspace:^",
+    "@types/node": "^22.3.0",
+    "typescript": "^5.5.4",
+    "@vitest/browser": "^2.0.5",
+    "vitest": "^2.0.5",
+    "playwright": "^1.45.3",
+    "webdriverio": "^8.39.1"
+  }
+}

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

@@ -0,0 +1 @@
+export * from './wa-sqlite-driver.js';