fix(dialect-wasm): fix official wasm database type

Author: subframe7536

README.md

@@ -1,5 +1,6 @@
 # Kysely Sqlite Tools
 
+- [dialect](packages/dialect-generic-sqlite) for generic SQLite, support run in current or worker thread
 - [dialect](packages/dialect-wasm) for `wasm`, run SQLite in browser
 - [dialect](packages/dialect-sqlite-worker) for [`better-sqlite3`](https://github.com/WiseLibs/better-sqlite3), running sql in worker_thread
 - [dialect](packages/dialect-wasqlite-worker) for [`wa-sqlite`](https://github.com/rhashimoto/wa-sqlite), running sql in web worker, store data in OPFS or IndexedDB

packages/dialect-bun-worker/src/worker/utils.ts

@@ -10,7 +10,7 @@ async function* iterateData(
   parameters?: readonly unknown[],
 ): AsyncIterableIterator<Record<string, any>> {
   if (!('iterate' in stmt)) {
-    throw new Error('Streaming not supported, please upgrade to Bun@^1.1.31')
+    throw new Error('Streaming not supported, please upgrade to Bun@1.1.31 or later')
   }
   for (const row of stmt.iterate(...parameters || [] as any)) {
     yield row as any

packages/dialect-wasm/official-wasm.d.ts

@@ -64,7 +64,7 @@ export class OfficialWasmDialect extends GenericSqliteDialect {
               return db.selectObjects(sql, parameters as any)
             },
             run: () => ({
-              insertId: BigInt(db.selectArray('SELECT last_insert_rowid()')[0]),
+              insertId: BigInt((db.selectArray('SELECT last_insert_rowid()')?.[0] || 0) as number),
               numAffectedRows: BigInt(db.changes(false, true)),
             }),
           }),

packages/dialect-wasm/src/official-wasm-dialect/index.ts

@@ -1,18 +1,60 @@
-import type { BaseDB } from '../types'
+export interface OfficialWasmDB {
 
-export type Option = {
-  sql: string | string[]
-  bind?: any[] | Record<string, any>
-  returnValue?: 'resultRows' | 'saveSql' | 'this'
-  resultRows?: any[]
-  saveSql?: any[]
-  columnNames?: string[]
-  callback?: (row: any[], stmt: any) => void | false
-  rowMode?: 'array' | 'object' | 'stmt'
-}
+  /** Returns true if the database handle is open, else false. */
+  isOpen: () => boolean
+
+  /** Throws if the given DB has been closed. */
+  affirmOpen: () => this
+
+  /**
+   * Finalizes all still-open statements which were opened by this object and
+   * closes this database connection. This is a no-op if the db has already been
+   * closed. After calling `close()`, {@link pointer} will resolve to
+   * `undefined`, so that can be used to check whether the db instance is still
+   * opened.
+   *
+   * If {@link onclose.before} is a function then it is called before any
+   * close-related cleanup. If {@link onclose.after} is a function then it is
+   * called after the db is closed but before auxiliary state like this.filename
+   * is cleared.
+   *
+   * Both onclose handlers are passed this object as their only argument. If
+   * this db is not opened, neither of the handlers are called. Any exceptions
+   * the handlers throw are ignored because "destructors must not throw."
+   *
+   * Note that garbage collection of a db handle, if it happens at all, will
+   * never trigger `close()`, so {@link onclose} handlers are not a reliable way
+   * to implement close-time cleanup or maintenance of a db.
+   */
+  close: () => void // ✓
+
+  /**
+   * Returns the number of changes, as per `sqlite3_changes()` (if the first
+   * argument is `false`) or `sqlite3_total_changes()` (if it's `true`). If the
+   * 2nd argument is `true`, it uses `sqlite3_changes64()` or
+   * `sqlite3_total_changes64()`, which will trigger an exception if this build
+   * does not have `BigInt` support enabled.
+   */
+  changes: (total?: boolean, sixtyFour?: boolean) => number
+
+  /**
+   * Prepares the given SQL, `step()`s it one time, and returns an array
+   * containing the values of the first result row. If it has no results,
+   * `undefined` is returned. If passed a second argument other than
+   * `undefined`, it is treated like an argument to
+   * {@link PreparedStatement#bind}, so may be any type supported by that
+   * function. Throws on error.
+   */
+  selectArray: (sql: string, bind?: any[]) => any[] | undefined
+
+  /**
+   * Works identically to {@link Database#selectArrays} except that each value in
+   * the returned array is an object, as per the `"object"` rowMode option to
+   * {@link Database#exec}.
+   */
+  selectObjects: (
+    sql: string,
+    bind?: any[],
+  ) => { [columnName: string]: any }[]
 
-export interface OfficialWasmDB extends BaseDB {
-  changes: (isTotal: boolean, isBigint: boolean) => number | bigint
-  selectArray: (sql: string, bind?: any[]) => any[]
-  selectObjects: (sql: string, bind?: any[]) => any[]
 }