Swapped order of handling event stream and event storage

event-driven-io · Jan 9, 2025 · e8e0b3c · e8e0b3c
1 parent c473f94
commit e8e0b3c
Showing 1 changed file with 18 additions and 18 deletions.
diff --git a/src/packages/emmett-sqlite/src/eventStore/schema/appendToStream.ts b/src/packages/emmett-sqlite/src/eventStore/schema/appendToStream.ts
@@ -115,24 +115,6 @@ const appendEventsRaw = async (
       );
     }
 
-    const { sqlString, values } = buildEventInsertQuery(
-      events,
-      expectedStreamVersion,
-      streamId,
-      streamType,
-      options?.partition?.toString() ?? defaultTag,
-    );
-
-    const returningId = await db.querySingle<{
-      global_position: string;
-    } | null>(sqlString, values);
-
-    if (returningId?.global_position == null) {
-      throw new Error('Could not find global position');
-    }
-
-    globalPosition = BigInt(returningId.global_position);
-
     let position: { stream_position: string } | null;
 
     if (expectedStreamVersion === 0n) {
@@ -192,6 +174,24 @@ const appendEventsRaw = async (
         };
       }
     }
+
+    const { sqlString, values } = buildEventInsertQuery(
+      events,
+      expectedStreamVersion,
+      streamId,
+      streamType,
+      options?.partition?.toString() ?? defaultTag,
+    );
+
+    const returningId = await db.querySingle<{
+      global_position: string;
+    } | null>(sqlString, values);
+
+    if (returningId?.global_position == null) {
+      throw new Error('Could not find global position');
+    }
+
+    globalPosition = BigInt(returningId.global_position);
   } catch (err: unknown) {
     if (isSQLiteError(err) && isOptimisticConcurrencyError(err)) {
       return {