From cbf759cf2c2d240f0d052798952c98458e951c52 Mon Sep 17 00:00:00 2001
From: Oskar Dudycz <oskar.dudycz@gmail.com>
Date: Thu, 27 Feb 2025 20:40:39 +0100
Subject: [PATCH] Made message_kind column to be char(1) instead of Text

---
 .../emmett-postgresql/src/eventStore/schema/appendToStream.ts | 4 +++-
 .../emmett-postgresql/src/eventStore/schema/tables.ts         | 2 +-
 .../emmett-sqlite/src/eventStore/schema/appendToStream.ts     | 4 ++--
 src/packages/emmett-sqlite/src/eventStore/schema/tables.ts    | 2 +-
 4 files changed, 7 insertions(+), 5 deletions(-)

diff --git a/src/packages/emmett-postgresql/src/eventStore/schema/appendToStream.ts b/src/packages/emmett-postgresql/src/eventStore/schema/appendToStream.ts
index c75d8b9f..194b90c7 100644
--- 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
index 11c1932b..1ebe58b6 100644
--- 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
index c372f9a7..dae267e1 100644
--- 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
index 74fbf7f7..18d10afe 100644
--- 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,