DrizzleAdapter

import { DrizzleAdapter } from '@gluonic/client-drizzle'

function DrizzleAdapter(config: DrizzleAdapterConfig): StorageAdapter

import { drizzle } from 'drizzle-orm/op-sqlite'
import { open } from '@op-rs/sqlite'
import { DrizzleAdapter } from '@gluonic/client-drizzle'
 
export const opDb = open('app.db')
export const db = drizzle(opDb)
 
const storage = DrizzleAdapter({ db, opDb })

import { drizzle } from 'drizzle-orm/better-sqlite3'
import Database from 'better-sqlite3'
import { DrizzleAdapter } from '@gluonic/client-drizzle'
 
const sqlite = new Database('app.db')
export const db = drizzle(sqlite)
 
const storage = DrizzleAdapter({ db })

import { relay, transcript } from './schema'
 
const storage = DrizzleAdapter({
  db,
  opDb,
  tables: {
    relay: { model: relay, idField: 'id' },
    transcript: { model: transcript, idField: 'id' }
  }
})

interface StorageAdapter {
  // Row operations
  getRow(t: string, id: string): Promise<WireRow | null>
  putRow(row: WireRow): Promise<void>
  deleteRow(t: string, id: string): Promise<void>
  
  // Bulk operations
  putRows(rows: WireRow[]): Promise<void>
  deleteRows(items: Array<{ t: string, id: string }>): Promise<void>
  
  // Query operations
  listByType(t: string): Promise<WireRow[]>
  listByIndex(t: string, indexKey: string, indexVal: string): Promise<WireRow[]>
  
  // Metadata
  getLastSyncId(): Promise<number>
  setLastSyncId(n: number): Promise<void>
  
  // Transaction queue
  enqueueTx(tx: Transaction): Promise<void>
  dequeueTx(id: string): Promise<void>
  listTx(): Promise<Transaction[]>
  
  // Utility
  clearAll(): Promise<void>
}

CREATE TABLE sync_rows_task (
  id TEXT PRIMARY KEY,
  data TEXT NOT NULL  -- JSON serialized WireRow
)

CREATE TABLE sync_tx_queue (
  id TEXT PRIMARY KEY,
  type TEXT NOT NULL,
  model_id TEXT NOT NULL,
  patch TEXT NOT NULL,
  prev TEXT,
  op TEXT,
  created_at INTEGER
)

CREATE TABLE sync_meta (
  key TEXT PRIMARY KEY,
  value TEXT NOT NULL
)