Exported the missing SQLite package code

src/packages/emmett-sqlite/src/connection/index.ts

@@ -0,0 +1 @@
+export * from './sqliteConnection';

src/packages/emmett-sqlite/src/eventStore/SQLiteEventStore.e2e.spec.ts

@@ -10,7 +10,7 @@ import { afterEach, beforeEach, describe, it } from 'node:test';
 import path from 'path';
 import { fileURLToPath } from 'url';
 import { v4 as uuid } from 'uuid';
-import { InMemorySQLiteDatabase, sqliteConnection } from '../sqliteConnection';
+import { InMemorySQLiteDatabase, sqliteConnection } from '../connection';
 import {
   type DiscountApplied,
   type PricedProductItem,

src/packages/emmett-sqlite/src/eventStore/SQLiteEventStore.ts

@@ -21,7 +21,7 @@ import {
   InMemorySQLiteDatabase,
   sqliteConnection,
   type SQLiteConnection,
-} from '../sqliteConnection';
+} from '../connection';
 import { createEventStoreSchema } from './schema';
 import { appendToStream } from './schema/appendToStream';
 import { readStream } from './schema/readStream';

src/packages/emmett-sqlite/src/eventStore/index.ts

@@ -0,0 +1,2 @@
+export * from './schema';
+export * from './SQLiteEventStore';

src/packages/emmett-sqlite/src/eventStore/schema/appendToStream.int.spec.ts

@@ -13,7 +13,7 @@ import {
   InMemorySQLiteDatabase,
   sqliteConnection,
   type SQLiteConnection,
-} from '../../sqliteConnection';
+} from '../../connection';
 import { appendToStream } from './appendToStream';
 
 export type PricedProductItem = {

src/packages/emmett-sqlite/src/eventStore/schema/appendToStream.ts

@@ -14,7 +14,7 @@ import {
   type Parameters,
   type SQLiteConnection,
   type SQLiteError,
-} from '../../sqliteConnection';
+} from '../../connection';
 import { defaultTag, messagesTable, streamsTable } from './typing';
 
 export type AppendEventResult =

src/packages/emmett-sqlite/src/eventStore/schema/createEventStoreSchema.int.spec.ts

@@ -4,7 +4,7 @@ import {
   InMemorySQLiteDatabase,
   sqliteConnection,
   type SQLiteConnection,
-} from '../../sqliteConnection';
+} from '../../connection';
 import { createEventStoreSchema } from '../schema';
 
 type TableExists = {

src/packages/emmett-sqlite/src/eventStore/schema/index.ts

@@ -1,14 +1,4 @@
-import { type SQLiteConnection } from '../../sqliteConnection';
-import { messagesTableSQL, streamsTableSQL } from './tables';
-
+export * from './appendToStream';
+export * from './readStream';
 export * from './tables';
-
-export const schemaSQL: string[] = [streamsTableSQL, messagesTableSQL];
-
-export const createEventStoreSchema = async (
-  db: SQLiteConnection,
-): Promise<void> => {
-  for (const sql of schemaSQL) {
-    await db.command(sql);
-  }
-};
+export * from './typing';

src/packages/emmett-sqlite/src/eventStore/schema/readStream.int.spec.ts

@@ -12,7 +12,7 @@ import {
   InMemorySQLiteDatabase,
   sqliteConnection,
   type SQLiteConnection,
-} from '../../sqliteConnection';
+} from '../../connection';
 import { appendToStream } from './appendToStream';
 import { readStream } from './readStream';
 

src/packages/emmett-sqlite/src/eventStore/schema/readStream.ts

@@ -7,7 +7,7 @@ import {
   type ReadStreamOptions,
   type ReadStreamResult,
 } from '@event-driven-io/emmett';
-import { type SQLiteConnection } from '../../sqliteConnection';
+import { type SQLiteConnection } from '../../connection';
 import { SQLiteEventStoreDefaultStreamVersion } from '../SQLiteEventStore';
 import { defaultTag, messagesTable } from './typing';
 

src/packages/emmett-sqlite/src/eventStore/schema/tables.ts

@@ -1,3 +1,4 @@
+import type { SQLiteConnection } from '../../connection';
 import { globalTag, messagesTable, streamsTable } from './typing';
 
 export const sql = (sql: string) => sql;
@@ -33,3 +34,13 @@ export const messagesTableSQL = sql(
   ); 
 `,
 );
+
+export const schemaSQL: string[] = [streamsTableSQL, messagesTableSQL];
+
+export const createEventStoreSchema = async (
+  db: SQLiteConnection,
+): Promise<void> => {
+  for (const sql of schemaSQL) {
+    await db.command(sql);
+  }
+};

src/packages/emmett-sqlite/src/index.ts

@@ -0,0 +1,2 @@
+export * from './connection';
+export * from './eventStore';