Triplit op-sqlite storage

op-sqlite-storage.ts

import { OPSQLiteConnection, open } from '@op-engineering/op-sqlite';
import {
  AsyncSQLiteAdapter,
  AsyncSQLiteExecutor,
  AsyncAdapterSQLiteStorage
} from '@triplit/db/storage/adapter-sqlite';
import { AsyncTupleStorageApi } from '@triplit/tuple-database';

// Create DB instance
const db = open({ name: 'triplit.db' });

// Create adapter
const adapter = new OPSQLiteAdapter(db);

// Create storage provider
export const storage = new AsyncAdapterSQLiteStorage(adapter);

class OPSQLiteAdapter implements AsyncSQLiteAdapter {
  constructor(private db: OPSQLiteConnection) {}
  async execute(sql: string, args?: any[] | undefined) {
    return this.db.execute(sql, args);
  }
  normalizeResults(results: any): { key: string; value: string }[] {
    if (!results.rows) return [];
    return results.rows._array as { key: string; value: string }[];
  }
  async transact(fn: (adapter: AsyncSQLiteExecutor) => Promise<void>) {
    await this.db.transaction(async (tx) => {
      await fn({
        execute: (sql, args) => {
          return tx.execute(sql, args);
        },
      });
      tx.commit();
    });
  }
  async close() {
    this.db.close();
  }
}