Moved ensure created inside try catch block

event-driven-io · Feb 10, 2025 · 4e79aeb · 4e79aeb
1 parent 20eb16c
commit 4e79aeb
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/src/packages/emmett-sqlite/src/eventStore/SQLiteEventStore.ts b/src/packages/emmett-sqlite/src/eventStore/SQLiteEventStore.ts
@@ -162,9 +162,9 @@ export const getSQLiteEventStore = (
         db = createConnection();
       }
 
-      await ensureSchemaExists();
       let stream;
       try {
+        await ensureSchemaExists();
         stream = await readStream<EventType>(db, streamName, options);
       } catch (err: Error) {
         closeConnection();
@@ -185,15 +185,17 @@ export const getSQLiteEventStore = (
         db = createConnection();
       }
 
-      await ensureSchemaExists();
       // TODO: This has to be smarter when we introduce urn-based resolution
       const [firstPart, ...rest] = streamName.split('-');
 
       const streamType =
         firstPart && rest.length > 0 ? firstPart : 'emt:unknown';
 
       let appendResult;
+
       try {
+        await ensureSchemaExists();
+
         appendResult = await appendToStream(
           db,
           streamName,