Expose batch input to users of queryDatabase

src/init-dependencies/event-store/commit-event.ts

@@ -26,11 +26,13 @@ export const commitEvent =
         event_type: type,
         payload: JSON.stringify(payload),
       }),
-      row =>
-        queryDatabase(
-          'INSERT INTO events (id, resource_id, resource_type, event_type, payload) VALUES ($id, $resource_id, $resource_type, $event_type, $payload); ',
-          row
-        ),
+      args =>
+        queryDatabase([
+          {
+            sql: 'INSERT INTO events (id, resource_id, resource_type, event_type, payload) VALUES ($id, $resource_id, $resource_type, $event_type, $payload); ',
+            args,
+          },
+        ]),
       TE.map(() => ({
         status: StatusCodes.CREATED,
         message: 'Persisted a new event',

src/init-dependencies/event-store/ensure-event-table-exists.ts

@@ -1,8 +1,9 @@
 import {QueryEventsDatabase} from './query-events-database';
 
 export const ensureEventTableExists = (queryDatabase: QueryEventsDatabase) =>
-  queryDatabase(
-    `
+  queryDatabase([
+    {
+      sql: `
     CREATE TABLE IF NOT EXISTS events (
       id TEXT,
       resource_version number,
@@ -12,5 +13,6 @@ export const ensureEventTableExists = (queryDatabase: QueryEventsDatabase) =>
       payload TEXT
     );
   `,
-    []
-  );
+      args: {},
+    },
+  ]);

src/init-dependencies/event-store/get-all-events.ts

@@ -39,7 +39,7 @@ export const getAllEvents =
   (queryDatabase: QueryEventsDatabase): Dependencies['getAllEvents'] =>
   () =>
     pipe(
-      queryDatabase('SELECT * FROM events;', []),
+      queryDatabase([{sql: 'SELECT * FROM events;', args: {}}]),
       TE.chainEitherK(
         flow(
           EventsFromDb.decode,

src/init-dependencies/event-store/init-query-events-database.ts

@@ -7,16 +7,10 @@ import {pipe} from 'fp-ts/lib/function';
 
 export const initQueryEventsDatabase = (): QueryEventsDatabase => {
   const client = libsqlClient.createClient({url: ':memory:'});
-  return (query: string, args: libsqlClient.InArgs) =>
+  return statements =>
     pipe(
       TE.tryCatch(
-        () =>
-          client.batch([
-            {
-              sql: query,
-              args: args,
-            },
-          ]),
+        () => client.batch(statements),
         failureWithStatus('DB query failed', StatusCodes.INTERNAL_SERVER_ERROR)
       ),
       TE.map(results => results[0])

src/init-dependencies/event-store/query-events-database.ts

@@ -1,8 +1,7 @@
 import * as TE from 'fp-ts/TaskEither';
 import {FailureWithStatus} from '../../types/failureWithStatus';
-import {InArgs} from '@libsql/client/.';
+import {InStatement} from '@libsql/client/.';
 
 export type QueryEventsDatabase = (
-  query: string,
-  args: InArgs
+  statements: InStatement[]
 ) => TE.TaskEither<FailureWithStatus, unknown>;