ExpoSqliteTupleStorageApi

ExpoSqliteTupleStorageApi.ts

class ExpoSqliteTupleStorageApi implements AsyncTupleStorageApi {
	private db = SQLite.openDatabase("app.db");

	constructor() {}

	async prepare() {
		await this.db.execAsync(
			[
				{
					sql: `
            CREATE TABLE IF NOT EXISTS tuples (
              key TEXT PRIMARY KEY,
              value TEXT
            );
          `,
					args: [],
				},
			],
			false,
		);
	}

	scan: AsyncTupleStorageApi["scan"] = () => {
		return new Promise((resolve, reject) => {
			this.db.transaction((tx) => {
				tx.executeSql(`SELECT key, value FROM tuples`, [], (_, result) => {
					result.rows._array.map(({ value }) => {
						return JSON.stringify(tap(value, "SELECTED VALUES"));
					}, resolve([]));
				});
			}, reject);
		});
	};

	transact(fn: (tx: SQLite.SQLTransaction) => void): Promise<void> {
		return new Promise<void>((resolve, reject) => {
			this.db.transaction(fn, reject, resolve);
		});
	}

	commit: AsyncTupleStorageApi["commit"] = async (writes) => {
		await this.transact((tx) => {
			for (const { key, value } of writes.set ?? []) {
				tx.executeSql(
					`INSERT OR REPLACE INTO tuples (key, value) VALUES (?, ?)`,
					[JSON.stringify(key), JSON.stringify(value)],
				);
			}
			for (const key of writes.remove ?? []) {
				tx.executeSql(`DELETE FROM tuples WHERE key = ?`, [
					JSON.stringify(key),
				]);
			}
		});
	};

	close: AsyncTupleStorageApi["close"] = async () => {
		await this.db.closeAsync();
	};
}