Made message_kind column to be char(1) instead of Text

event-driven-io · Feb 27, 2025 · cbf759c · cbf759c
1 parent 0f17e3a
commit cbf759c
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 5 deletions.
diff --git a/src/packages/emmett-postgresql/src/eventStore/schema/appendToStream.ts b/src/packages/emmett-postgresql/src/eventStore/schema/appendToStream.ts
@@ -263,7 +263,9 @@ const appendEventsRaw = (
           .join(','),
         messages.map(() => `'1'`).join(','),
         messages.map((e) => sql('%L', e.type)).join(','),
-        messages.map((e) => sql('%L', e.kind)).join(','),
+        messages
+          .map((e) => sql('%L', e.kind === 'Event' ? 'E' : 'C'))
+          .join(','),
         streamId,
         streamType,
         options?.expectedStreamVersion ?? 'NULL',

diff --git a/src/packages/emmett-postgresql/src/eventStore/schema/tables.ts b/src/packages/emmett-postgresql/src/eventStore/schema/tables.ts
@@ -28,7 +28,7 @@ export const messagesTableSQL = rawSql(
       stream_id              TEXT                      NOT NULL,
       stream_position        BIGINT                    NOT NULL,
       partition              TEXT                      NOT NULL DEFAULT '${globalTag}',
-      message_kind           TEXT                      NOT NULL DEFAULT 'Event',
+      message_kind           CHAR(1)                   NOT NULL DEFAULT 'E',
       message_data           JSONB                     NOT NULL,
       message_metadata       JSONB                     NOT NULL,
       message_schema_version TEXT                      NOT NULL,

diff --git a/src/packages/emmett-sqlite/src/eventStore/schema/appendToStream.ts b/src/packages/emmett-sqlite/src/eventStore/schema/appendToStream.ts
@@ -183,7 +183,6 @@ const appendEventsRaw = async (
       events,
       expectedStreamVersion,
       streamId,
-      streamType,
       options?.partition?.toString() ?? defaultTag,
     );
 
@@ -239,7 +238,6 @@ const buildEventInsertQuery = (
   events: ReadEvent[],
   expectedStreamVersion: bigint,
   streamId: string,
-  streamType: string,
   partition: string | null | undefined,
 ): {
   sqlString: string;
@@ -265,6 +263,7 @@ const buildEventInsertQuery = (
         streamId,
         streamPosition.toString() ?? 0,
         partition ?? defaultTag,
+        event.kind === 'Event' ? 'E' : 'C',
         JSONParser.stringify(event.data),
         JSONParser.stringify(event.metadata),
         expectedStreamVersion?.toString() ?? 0,
@@ -286,6 +285,7 @@ const buildEventInsertQuery = (
           stream_id, 
           stream_position, 
           partition, 
+          message_kind,
           message_data, 
           message_metadata, 
           message_schema_version, 

diff --git a/src/packages/emmett-sqlite/src/eventStore/schema/tables.ts b/src/packages/emmett-sqlite/src/eventStore/schema/tables.ts
@@ -20,7 +20,7 @@ export const messagesTableSQL = sql(
       stream_id              TEXT                      NOT NULL,
       stream_position        BIGINT                    NOT NULL,
       partition              TEXT                      NOT NULL DEFAULT '${globalTag}',
-      message_kind           TEXT                      NOT NULL DEFAULT 'Event',
+      message_kind           CHAR(1)                   NOT NULL DEFAULT 'E',
       message_data           JSONB                     NOT NULL,
       message_metadata       JSONB                     NOT NULL,
       message_schema_version TEXT                      NOT NULL,