borogove

created pr with borogove/sqlite-injectable-driver.1 on 2026-11-09T19:46:34Z · by 3c31bc8c

commented on 2026-11-09T19:46:34Z · by 3c31bc8c

Changes are available at https://tangled.org/mrry.band/borogove on branch sqlite-injectable-driver.

added borogove/sqlite-injectable-driver.2 on 2026-11-09T20:05:07Z · by 3c31bc8c


                      1:  981fe7d = 1:  981fe7d Use arrays


                      2:  ef9e639 = 2:  ef9e639 Make prepare public, remove formatParam and first


                      3:  f949361 ! 3:  a97c836 Allow injectable drivers for Sqlite

commented on 2026-11-09T20:49:02Z · by 9e834e0d

browser tests dont pass

added borogove/sqlite-injectable-driver.3 on 2026-11-09T21:28:45Z · by 3c31bc8c


                      1:  981fe7d = 1:  981fe7d Use arrays


                      2:  ef9e639 ! 2:  11eb826 Make prepare public, remove formatParam and first


                      3:  a97c836 ! 3:  34cee7d Allow injectable drivers for Sqlite

cmds

checkout latest patchset:

ssh pr.pico.sh pull borogove:sqlite-injectable-driver | git am -3

checkout specific patchset revision:

ssh pr.pico.sh pull borogove:sqlite-injectable-driver [rev] | git am -3

add changes to patch request:

git format-patch main --stdout | ssh pr.pico.sh borogove:sqlite-injectable-driver

add comment to patch request:

ssh pr.pico.sh comment borogove:sqlite-injectable-driver "lgtm!"

Patchset `borogove/sqlite-injectable-driver.2` on 2026-11-09T20:05:07Z · commit a97c836

Use arrays

Eric Roberts 2026-11-09T19:27:25Z

Make prepare public, remove formatParam and first

Eric Roberts 2026-11-09T19:29:48Z

→ Allow injectable drivers for Sqlite

Eric Roberts 2026-11-09T19:41:16Z

Allow injectable drivers for Sqlite

Eric Roberts 2026-11-09T19:41:16Z

In Tauri I want to use https://v2.tauri.app/plugin/sql/ so we can put
the db on the filesystem. To do that I need to be able to pass in a
custom driver in borogove. This does that.

Semantic diff summary

0 added, 0 modified, 0 signature changed, 0 removed across 0 analyzed files (2 files skipped: unsupported file type)

+14 -3 borogove/persistence/Sqlite.hx #

......@@ -34,6 +34,8 @@ typedef InsertColumn = {
	value:(ChatMessage)->Dynamic
}

typedef SqliteDriverFactory = (String, (Array<String>->Promise<Array<Dynamic>>)->Promise<Any>)->SqliteDriver;

@:expose
#if cpp
@:build(HaxeCBridge.expose())

......@@ -85,10 +87,14 @@ class Sqlite implements Persistence implements KeyValueStore {
		@param media a MediaStore to use for media
		@returns new persistence layer
	**/
	public function new(dbfile: String, media: MediaStore) {
	public function new(
		dbfile: String,
		media: MediaStore,
		#if js ?driver: SqliteDriverFactory, #end
	) {
		this.media = media;
		media.setKV(this);
		db = new SqliteDriver(dbfile, (exec) -> {
		final migrate = (exec: Array<String>->Promise<Array<Dynamic>>) -> {
			exec(["PRAGMA user_version"]).then(rows -> {
				final version = Std.parseInt(rows[0]?.user_version) ?? 0;
				return Promise.resolve(null).then(_ -> {

......@@ -387,7 +393,12 @@ class Sqlite implements Persistence implements KeyValueStore {
					return Promise.resolve(null);
				});
			});
		});
		};
		#if js
		db = driver == null ? new SqliteDriver(dbfile, migrate) : driver(dbfile, migrate);
		#else
		db = new SqliteDriver(dbfile, migrate);
		#end
	}

	@HaxeCBridge.noemit

+29 -0 test/TestSqlite.hx #

......@@ -104,6 +104,35 @@ class TestSqlite extends utest.Test {
		mediaStore = new MockMediaStore();
		persistence = new Sqlite("file:" + ID.unique() + "?mode=memory&cache=shared", mediaStore);
	}
	#if js
	public function testInjectedDriver(async: Async) {
		var migrated = Promise.resolve(null);
		var migrationQueries: Array<String> = [];
		final injected = new Sqlite("injected.sqlite3", mediaStore, (file, migrate) -> {
			Assert.equals("injected.sqlite3", file);
			migrated = migrate(sql -> {
				migrationQueries = migrationQueries.concat(sql);
				return Promise.resolve([{ user_version: 24 }]);
			});
			return {
				exec: (sql: String, ?params: Array<Dynamic>) -> {
					Assert.equals("SELECT v FROM keyvaluepairs WHERE k=? LIMIT 1", sql);
					Assert.equals("key", params[0]);
					return Promise.resolve([{ v: "injected value" }]);
				},
				execMany: qs -> Promise.resolve([])
			};
		});
		migrated.then(_ -> injected.get("key")).then(value -> {
			Assert.same(["PRAGMA user_version"], migrationQueries);
			Assert.equals("injected value", value);
			async.done();
		}).catchError(e -> {
			Assert.fail(Std.string(e));
			async.done();
		});
	}
	#end

	public function testOrder(async: Async) {
		final account = "alice@example.com";

...	...		@@ -104,6 +104,35 @@ class TestSqlite extends utest.Test {
104	104		mediaStore = new MockMediaStore();
105	105		persistence = new Sqlite("file:" + ID.unique() + "?mode=memory&cache=shared", mediaStore);
106	106		}
	107	+	#if js
	108	+	public function testInjectedDriver(async: Async) {
	109	+	var migrated = Promise.resolve(null);
	110	+	var migrationQueries: Array<String> = [];
	111	+	final injected = new Sqlite("injected.sqlite3", mediaStore, (file, migrate) -> {
	112	+	Assert.equals("injected.sqlite3", file);
	113	+	migrated = migrate(sql -> {
	114	+	migrationQueries = migrationQueries.concat(sql);
	115	+	return Promise.resolve([{ user_version: 24 }]);
	116	+	});
	117	+	return {
	118	+	exec: (sql: String, ?params: Array<Dynamic>) -> {
	119	+	Assert.equals("SELECT v FROM keyvaluepairs WHERE k=? LIMIT 1", sql);
	120	+	Assert.equals("key", params[0]);
	121	+	return Promise.resolve([{ v: "injected value" }]);
	122	+	},
	123	+	execMany: qs -> Promise.resolve([])
	124	+	};
	125	+	});
	126	+	migrated.then(_ -> injected.get("key")).then(value -> {
	127	+	Assert.same(["PRAGMA user_version"], migrationQueries);
	128	+	Assert.equals("injected value", value);
	129	+	async.done();
	130	+	}).catchError(e -> {
	131	+	Assert.fail(Std.string(e));
	132	+	async.done();
	133	+	});
	134	+	}
	135	+	#end
107	136
108	137		public function testOrder(async: Async) {
109	138		final account = "alice@example.com";

...	...		@@ -34,6 +34,8 @@ typedef InsertColumn = {
34	34		value:(ChatMessage)->Dynamic
35	35		}
36	36
	37	+	typedef SqliteDriverFactory = (String, (Array<String>->Promise<Array<Dynamic>>)->Promise<Any>)->SqliteDriver;
	38	+
37	39		@:expose
38	40		#if cpp
39	41		@:build(HaxeCBridge.expose())

...	...		@@ -85,10 +87,14 @@ class Sqlite implements Persistence implements KeyValueStore {
85	87		@param media a MediaStore to use for media
86	88		@returns new persistence layer
87	89		**/
88		-	public function new(dbfile: String, media: MediaStore) {
	90	+	public function new(
	91	+	dbfile: String,
	92	+	media: MediaStore,
	93	+	#if js ?driver: SqliteDriverFactory, #end
	94	+	) {
89	95		this.media = media;
90	96		media.setKV(this);
91		-	db = new SqliteDriver(dbfile, (exec) -> {
	97	+	final migrate = (exec: Array<String>->Promise<Array<Dynamic>>) -> {
92	98		exec(["PRAGMA user_version"]).then(rows -> {
93	99		final version = Std.parseInt(rows[0]?.user_version) ?? 0;
94	100		return Promise.resolve(null).then(_ -> {

...	...		@@ -387,7 +393,12 @@ class Sqlite implements Persistence implements KeyValueStore {
387	393		return Promise.resolve(null);
388	394		});
389	395		});
390		-	});
	396	+	};
	397	+	#if js
	398	+	db = driver == null ? new SqliteDriver(dbfile, migrate) : driver(dbfile, migrate);
	399	+	#else
	400	+	db = new SqliteDriver(dbfile, migrate);
	401	+	#end
391	402		}
392	403
393	404		@HaxeCBridge.noemit

borogove

Patchset borogove/sqlite-injectable-driver.2 on 2026-11-09T20:05:07Z · commit a97c836

Patchset `borogove/sqlite-injectable-driver.2` on 2026-11-09T20:05:07Z · commit a97c836