From 4e79aeb192c10932208c06cd88b0d70edc925bd0 Mon Sep 17 00:00:00 2001
From: dave <dave.devs.stuff@gmail.com>
Date: Mon, 10 Feb 2025 07:59:25 +0000
Subject: [PATCH] Moved ensure created inside try catch block

---
 .../emmett-sqlite/src/eventStore/SQLiteEventStore.ts        | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/src/packages/emmett-sqlite/src/eventStore/SQLiteEventStore.ts b/src/packages/emmett-sqlite/src/eventStore/SQLiteEventStore.ts
index 0548cd23..da4f70d6 100644
--- 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,7 +185,6 @@ export const getSQLiteEventStore = (
         db = createConnection();
       }
 
-      await ensureSchemaExists();
       // TODO: This has to be smarter when we introduce urn-based resolution
       const [firstPart, ...rest] = streamName.split('-');
 
@@ -193,7 +192,10 @@ export const getSQLiteEventStore = (
         firstPart && rest.length > 0 ? firstPart : 'emt:unknown';
 
       let appendResult;
+
       try {
+        await ensureSchemaExists();
+
         appendResult = await appendToStream(
           db,
           streamName,