Skip to content

Commit ef8c201

Browse files
committed
[electric-sql] Correct missing getElectricClient method
1 parent 0bfc97d commit ef8c201

File tree

5 files changed

+8
-3
lines changed

5 files changed

+8
-3
lines changed

src/persisters/persister-electric-sql.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -33,4 +33,5 @@ export const createElectricSqlPersister = ((
3333
onSqlCommand,
3434
onIgnoredError,
3535
electricClient,
36+
'getElectricClient',
3637
) as ElectricSqlPersister) as typeof createElectricSqlPersisterDecl;

src/persisters/sqlite/create.ts

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,7 @@ export const createSqlitePersister = <UpdateListeningHandle>(
2929
onSqlCommand: ((sql: string, args?: any[]) => void) | undefined,
3030
onIgnoredError: ((error: any) => void) | undefined,
3131
db: any,
32+
getThing = 'getDb',
3233
): Persister => {
3334
let dataVersion: number | null;
3435
let schemaVersion: number | null;
@@ -100,5 +101,6 @@ export const createSqlitePersister = <UpdateListeningHandle>(
100101
defaultedConfig as any,
101102
collValues(managedTableNamesSet),
102103
db,
104+
getThing,
103105
);
104106
};

src/persisters/sqlite/json.ts

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,7 @@ export const createJsonSqlitePersister = <ListeningHandle>(
1717
[storeTableName]: DefaultedJsonConfig,
1818
managedTableNames: string[],
1919
db: any,
20+
getThing: string,
2021
): Persister => {
2122
const [refreshSchema, loadTable, saveTable, transaction] =
2223
getCommandFunctions(cmd, managedTableNames, onIgnoredError);
@@ -54,7 +55,7 @@ export const createJsonSqlitePersister = <ListeningHandle>(
5455
addPersisterListener,
5556
delPersisterListener,
5657
onIgnoredError,
57-
['getDb', db],
58+
[getThing, db],
5859
db,
5960
);
6061

src/persisters/sqlite/tabular.ts

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,7 @@ export const createTabularSqlitePersister = <ListeningHandle>(
3030
]: DefaultedTabularConfig,
3131
managedTableNames: string[],
3232
db: any,
33+
getThing: string,
3334
): Persister => {
3435
const [refreshSchema, loadTable, saveTable, transaction] =
3536
getCommandFunctions(cmd, managedTableNames, onIgnoredError);
@@ -142,7 +143,7 @@ export const createTabularSqlitePersister = <ListeningHandle>(
142143
addPersisterListener,
143144
delPersisterListener,
144145
onIgnoredError,
145-
['getDb', db],
146+
[getThing, db],
146147
db,
147148
);
148149

test/unit/persisters/sqlite.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,7 @@ export const VARIANTS: {[name: string]: SqliteVariant<any>} = {
4848
const conn = await ElectricDatabase.init(':memory:', '');
4949
return await electrify(conn, electricSchema, config);
5050
}),
51-
['getDb', (electric: Electric) => electric],
51+
['getElectricClient', (electric: Electric) => electric],
5252
(
5353
store: Store,
5454
electric: Electric,

0 commit comments

Comments
 (0)