Extended SQLite event store driver

This will make better DX for event store options, strong typing and
prepare for future improvements, like different strategies for drivers

Author: oskardudycz

src/package-lock.json

@@ -110,7 +110,7 @@
     "vitest": "^4.0.18"
   },
   "peerDependencies": {
-    "@event-driven-io/pongo": "0.17.0-beta.18",
+    "@event-driven-io/pongo": "0.17.0-beta.19",
     "@types/express": "4.17.21",
     "@types/node": "^25.0.10",
     "@types/supertest": "^6.0.2",

src/package.json

@@ -74,7 +74,7 @@
   },
   "dependencies": {
     "@event-driven-io/emmett": "0.43.0-alpha.3",
-    "@event-driven-io/pongo": "0.17.0-beta.18"
+    "@event-driven-io/pongo": "0.17.0-beta.19"
   },
   "peerDependencies": {
     "@types/pg": "^8.16.0",

src/packages/emmett-postgresql/package.json

@@ -1,4 +1,5 @@
 import { dumbo, single, SQL, type Dumbo } from '@event-driven-io/dumbo';
+import { pgDumboDriver } from '@event-driven-io/dumbo/pg';
 import {
   assertDeepEqual,
   asyncAwaiter,
@@ -16,7 +17,6 @@ import {
 } from '../postgreSQLEventStore';
 import { postgreSQLRawSQLProjection } from '../projections';
 import { rebuildPostgreSQLProjections } from './rebuildPostgreSQLProjections';
-import { pgDatabaseDriver } from '@event-driven-io/dumbo/pg';
 
 const withDeadline = { timeout: 10000 };
 
@@ -33,7 +33,7 @@ void describe('PostgreSQL projection rebuild with advisory locking', () => {
     eventStore = getPostgreSQLEventStore(connectionString, {
       projections: projections.inline([]),
     });
-    pool = dumbo({ connectionString, driver: pgDatabaseDriver });
+    pool = dumbo({ connectionString, driver: pgDumboDriver });
   });
 
   beforeEach(async () => {

src/packages/emmett-postgresql/src/eventStore/consumers/rebuildPostgreSQLProjections.e2e.spec.ts

@@ -1,5 +1,5 @@
 import { dumbo, single, SQL, type Dumbo } from '@event-driven-io/dumbo';
-import { pgDatabaseDriver } from '@event-driven-io/dumbo/pg';
+import { pgDumboDriver } from '@event-driven-io/dumbo/pg';
 import {
   assertDeepEqual,
   asyncAwaiter,
@@ -66,7 +66,7 @@ void describe('Rebuilding PostgreSQL Projections', () => {
     otherSummariesV2 = db.collection(
       `${otherShoppingCartsSummaryCollectionName}_v2`,
     );
-    pool = dumbo({ connectionString, driver: pgDatabaseDriver });
+    pool = dumbo({ connectionString, driver: pgDumboDriver });
   });
 
   beforeEach(async () => {

src/packages/emmett-postgresql/src/eventStore/consumers/rebuildPostgreSQLProjections.int.spec.ts

@@ -1,5 +1,5 @@
 import { dumbo, SQL, type SQLExecutor } from '@event-driven-io/dumbo';
-import { pgDatabaseDriver, type PgPool } from '@event-driven-io/dumbo/pg';
+import { pgDumboDriver, type PgPool } from '@event-driven-io/dumbo/pg';
 import {
   assertDeepEqual,
   assertFalse,
@@ -26,7 +26,7 @@ void describe('tryAcquireProcessorLock', () => {
   before(async () => {
     postgres = await getPostgreSQLStartedContainer();
     connectionString = postgres.getConnectionUri();
-    pool = dumbo({ connectionString, driver: pgDatabaseDriver });
+    pool = dumbo({ connectionString, driver: pgDumboDriver });
     await createEventStoreSchema(connectionString, pool);
   });
 

src/packages/emmett-postgresql/src/eventStore/projections/locks/postgreSQLProcessorLock.int.spec.ts

@@ -1,5 +1,5 @@
 import { dumbo, SQL, type SQLExecutor } from '@event-driven-io/dumbo';
-import { pgDatabaseDriver, type PgPool } from '@event-driven-io/dumbo/pg';
+import { pgDumboDriver, type PgPool } from '@event-driven-io/dumbo/pg';
 import {
   assertFalse,
   assertThrowsAsync,
@@ -25,7 +25,7 @@ void describe('tryAcquireProjectionLock', () => {
   before(async () => {
     postgres = await getPostgreSQLStartedContainer();
     connectionString = postgres.getConnectionUri();
-    pool = dumbo({ connectionString, driver: pgDatabaseDriver });
+    pool = dumbo({ connectionString, driver: pgDumboDriver });
     await createEventStoreSchema(connectionString, pool);
   });
 

src/packages/emmett-postgresql/src/eventStore/projections/locks/postgreSQLProjectionLock.int.spec.ts

@@ -1,5 +1,5 @@
 import { dumbo, SQL, type SQLExecutor } from '@event-driven-io/dumbo';
-import { pgDatabaseDriver, type PgPool } from '@event-driven-io/dumbo/pg';
+import { pgDumboDriver, type PgPool } from '@event-driven-io/dumbo/pg';
 import {
   assertEqual,
   assertFalse,
@@ -30,7 +30,7 @@ void describe('projectionRegistration', () => {
   before(async () => {
     postgres = await getPostgreSQLStartedContainer();
     const connectionString = postgres.getConnectionUri();
-    pool = dumbo({ connectionString, driver: pgDatabaseDriver });
+    pool = dumbo({ connectionString, driver: pgDumboDriver });
     await createEventStoreSchema(connectionString, pool);
   });
 

src/packages/emmett-postgresql/src/eventStore/projections/management/projectionRegistration.int.spec.ts

@@ -88,7 +88,7 @@ void describe('PostgreSQL Projections', () => {
         },
       ])
       .then(async ({ pool }) => {
-        const result = await tableExists(pool, projection);
+        const result = await tableExists(pool.execute, projection);
 
         assertTrue(result);
       });

src/packages/emmett-postgresql/src/eventStore/projections/postgreSQLRawSQLProjection.single.int.spec.ts

@@ -1,5 +1,5 @@
 import { dumbo, SQL } from '@event-driven-io/dumbo';
-import { pgDatabaseDriver, type PgPool } from '@event-driven-io/dumbo/pg';
+import { pgDumboDriver, type PgPool } from '@event-driven-io/dumbo/pg';
 import {
   assertEqual,
   assertFalse,
@@ -54,7 +54,7 @@ void describe('appendEvent', () => {
     const connectionString = postgres.getConnectionUri();
     pool = dumbo({
       connectionString,
-      driver: pgDatabaseDriver,
+      driver: pgDumboDriver,
     });
 
     await createEventStoreSchema(connectionString, pool);