/* node:sqlite adapter matching the Workers `state.storage.sql` API surface
   used by the Accounting DO (exec with ? bindings; .one()/.toArray()/rowsWritten). */
import { DatabaseSync } from 'node:sqlite';

export function makeSqliteState() {
  const db = new DatabaseSync(':memory:');
  return {
    storage: {
      sql: {
        exec(sql, ...bindings) {
          const stmt = db.prepare(sql);
          if (/^\s*select/i.test(sql)) {
            const rows = stmt.all(...bindings);
            return { one: () => (rows[0] === undefined ? null : rows[0]), toArray: () => rows };
          }
          const info = stmt.run(...bindings);
          return { rowsWritten: Number(info.changes), rowsRead: 0 };
        },
      },
    },
  };
}