Class SqliteDriver

apps/web/src/common/sqlite/index.desktop.ts:34–82

import { DialectOptions } from ".";

class SqliteDriver implements Driver {
  connection?: DatabaseConnection;
  private connectionMutex = new Mutex();
  private handle?: string;
  constructor(private readonly config: { name: string }) {}

  async init(): Promise<void> {
    this.handle = await desktop!.sqlite.open.mutate({
      filePath: this.config.name
    });
    this.connection = new SqliteWorkerConnection(this.handle);
  }

  async acquireConnection(): Promise<DatabaseConnection> {
    if (!this.connection) throw new Error("Driver not initialized.");

    // SQLite only has one single connection. We use a mutex here to wait
    // until the single connection has been released.
    await this.connectionMutex.waitForUnlock();
    await this.connectionMutex.acquire();
    return this.connection;
  }

  async beginTransaction(connection: DatabaseConnection): Promise<void> {
    await connection.executeQuery(CompiledQuery.raw("begin"));
  }

  async commitTransaction(connection: DatabaseConnection): Promise<void> {
    await connection.executeQuery(CompiledQuery.raw("commit"));
  }

  async rollbackTransaction(connection: DatabaseConnection): Promise<void> {
    await connection.executeQuery(CompiledQuery.raw("rollback"));
  }

  async releaseConnection(): Promise<void> {
    this.connectionMutex.release();
  }

  async destroy(): Promise<void> {
    if (!this.handle) return;
    await desktop!.sqlite.close.mutate({ id: this.handle });
  }

  async delete() {
    if (!this.handle) return;
    await desktop!.sqlite.delete.mutate({ id: this.handle });
  }
}

class SqliteWorkerConnection implements DatabaseConnection {
  constructor(private readonly handle: string) {}