rename messageStore table to messageStoreMessages and eventLog …

…to `eventLogMessages`. Also renamed `eventLogWatermark` to `eventWatermark` field in the `eventLogRecordsTags` table.
decentralized-identity · Apr 23, 2024 · 7cd7848 · 7cd7848
1 parent d6a61d2
commit 7cd7848
Show file tree

Hide file tree

Showing 4 changed files with 25 additions and 25 deletions.
diff --git a/src/event-log-sql.ts b/src/event-log-sql.ts
@@ -14,7 +14,7 @@ export class EventLogSql implements EventLog {
 
   constructor(dialect: Dialect) {
     this.#dialect = dialect;
-    this.#tags = new TagTables(dialect, 'eventLog');
+    this.#tags = new TagTables(dialect, 'eventLogMessages');
   }
 
   async open(): Promise<void> {
@@ -24,7 +24,7 @@ export class EventLogSql implements EventLog {
 
     this.#db = new Kysely<DwnDatabaseType>({ dialect: this.#dialect });
     let createTable = this.#db.schema
-      .createTable('eventLog')
+      .createTable('eventLogMessages')
       .ifNotExists()
       .addColumn('tenant', 'text', (col) => col.notNull())
       .addColumn('messageCid', 'varchar(60)', (col) => col.notNull())
@@ -69,7 +69,7 @@ export class EventLogSql implements EventLog {
     // Add columns that have dialect-specific constraints
     createTable = this.#dialect.addAutoIncrementingColumn(createTable, 'watermark', (col) => col.primaryKey());
     createRecordsTagsTable = this.#dialect.addAutoIncrementingColumn(createRecordsTagsTable, 'id', (col) => col.primaryKey());
-    createRecordsTagsTable = this.#dialect.addReferencedColumn(createRecordsTagsTable, 'eventLogRecordsTags', 'eventLogWatermark', 'integer', 'eventLog', 'watermark', 'cascade');
+    createRecordsTagsTable = this.#dialect.addReferencedColumn(createRecordsTagsTable, 'eventLogRecordsTags', 'eventWatermark', 'integer', 'eventLogMessages', 'watermark', 'cascade');
 
     await createTable.execute();
     await createRecordsTagsTable.execute();
@@ -120,7 +120,7 @@ export class EventLogSql implements EventLog {
 
       // we use the dialect-specific `insertThenReturnId` in order to be able to extract the `insertId`
       const result = await this.#dialect
-        .insertThenReturnId(tx, 'eventLog', eventIndexValues, 'watermark as insertId')
+        .insertThenReturnId(tx, 'eventLogMessages', eventIndexValues, 'watermark as insertId')
         .executeTakeFirstOrThrow();
 
       // if tags exist, we execute those within the transaction associating them with the `insertId`.
@@ -151,8 +151,8 @@ export class EventLogSql implements EventLog {
     }
 
     let query = this.#db
-      .selectFrom('eventLog')
-      .leftJoin('eventLogRecordsTags', 'eventLogRecordsTags.eventLogWatermark', 'eventLog.watermark')
+      .selectFrom('eventLogMessages')
+      .leftJoin('eventLogRecordsTags', 'eventLogRecordsTags.eventWatermark', 'eventLogMessages.watermark')
       .select('messageCid')
       .distinct()
       .select('watermark')
@@ -164,7 +164,7 @@ export class EventLogSql implements EventLog {
     }
 
     if(cursor !== undefined) {
-      // eventLog in the sql store uses the watermark cursor value which is a number in SQL
+      // eventLogMessages in the sql store uses the watermark cursor value which is a number in SQL
       // if not we will return empty results
       const cursorValue = cursor.value as number;
       const cursorMessageCid = cursor.messageCid;
@@ -211,7 +211,7 @@ export class EventLogSql implements EventLog {
     }
 
     await this.#db
-      .deleteFrom('eventLog')
+      .deleteFrom('eventLogMessages')
       .where('tenant', '=', tenant)
       .where('messageCid', 'in', messageCids)
       .execute();
@@ -225,7 +225,7 @@ export class EventLogSql implements EventLog {
     }
 
     await this.#db
-      .deleteFrom('eventLog')
+      .deleteFrom('eventLogMessages')
       .execute();
   }
 }
diff --git a/src/message-store-sql.ts b/src/message-store-sql.ts
@@ -30,7 +30,7 @@ export class MessageStoreSql implements MessageStore {
 
   constructor(dialect: Dialect) {
     this.#dialect = dialect;
-    this.#tags = new TagTables(dialect, 'messageStore');
+    this.#tags = new TagTables(dialect, 'messageStoreMessages');
   }
 
   async open(): Promise<void> {
@@ -40,7 +40,7 @@ export class MessageStoreSql implements MessageStore {
 
     this.#db = new Kysely<DwnDatabaseType>({ dialect: this.#dialect });
     let createTable = this.#db.schema
-      .createTable('messageStore')
+      .createTable('messageStoreMessages')
       .ifNotExists()
       .addColumn('tenant', 'varchar(255)', (col) => col.notNull())
       .addColumn('messageCid', 'varchar(60)', (col) => col.notNull())
@@ -88,7 +88,7 @@ export class MessageStoreSql implements MessageStore {
     createTable = this.#dialect.addAutoIncrementingColumn(createTable, 'id', (col) => col.primaryKey());
     createTable = this.#dialect.addBlobColumn(createTable, 'encodedMessageBytes', (col) => col.notNull());
     createRecordsTagsTable = this.#dialect.addAutoIncrementingColumn(createRecordsTagsTable, 'id', (col) => col.primaryKey());
-    createRecordsTagsTable = this.#dialect.addReferencedColumn(createRecordsTagsTable, 'messageStoreRecordsTags', 'messageInsertId', 'integer', 'messageStore', 'id', 'cascade');
+    createRecordsTagsTable = this.#dialect.addReferencedColumn(createRecordsTagsTable, 'messageStoreRecordsTags', 'messageInsertId', 'integer', 'messageStoreMessages', 'id', 'cascade');
 
     await createTable.execute();
     await createRecordsTagsTable.execute();
@@ -171,7 +171,7 @@ export class MessageStoreSql implements MessageStore {
 
       // we use the dialect-specific `insertThenReturnId` in order to be able to extract the `insertId`
       const result = await this.#dialect
-        .insertThenReturnId(tx, 'messageStore', messageIndexValues, 'id as insertId')
+        .insertThenReturnId(tx, 'messageStoreMessages', messageIndexValues, 'id as insertId')
         .executeTakeFirstOrThrow();
 
       // if tags exist, we execute those within the transaction associating them with the `insertId`.
@@ -197,7 +197,7 @@ export class MessageStoreSql implements MessageStore {
 
     const result = await executeUnlessAborted(
       this.#db
-        .selectFrom('messageStore')
+        .selectFrom('messageStoreMessages')
         .selectAll()
         .where('tenant', '=', tenant)
         .where('messageCid', '=', cid)
@@ -231,8 +231,8 @@ export class MessageStoreSql implements MessageStore {
     const { property: sortProperty, direction: sortDirection } = this.extractSortProperties(messageSort);
 
     let query = this.#db
-      .selectFrom('messageStore')
-      .leftJoin('messageStoreRecordsTags', 'messageStoreRecordsTags.messageInsertId', 'messageStore.id')
+      .selectFrom('messageStoreMessages')
+      .leftJoin('messageStoreRecordsTags', 'messageStoreRecordsTags.messageInsertId', 'messageStoreMessages.id')
       .select('messageCid')
       .distinct()
       .select([
@@ -294,7 +294,7 @@ export class MessageStoreSql implements MessageStore {
 
     await executeUnlessAborted(
       this.#db
-        .deleteFrom('messageStore')
+        .deleteFrom('messageStoreMessages')
         .where('tenant', '=', tenant)
         .where('messageCid', '=', cid)
         .execute(),
@@ -310,7 +310,7 @@ export class MessageStoreSql implements MessageStore {
     }
 
     await this.#db
-      .deleteFrom('messageStore')
+      .deleteFrom('messageStoreMessages')
       .execute();
   }
 

diff --git a/src/types.ts b/src/types.ts
@@ -88,7 +88,7 @@ type MessageStoreRecordsTagsTable = {
 type EventLogRecordsTagsTable = {
   id: Generated<number>;
   tag: string;
-  eventLogWatermark: number;
+  eventWatermark: number;
   valueString: string | null;
   valueNumber: number | null;
 };
@@ -102,9 +102,9 @@ type DataStoreTable = {
 }
 
 export type DwnDatabaseType = {
-  eventLog: EventLogTable;
+  eventLogMessages: EventLogTable;
   eventLogRecordsTags: EventLogRecordsTagsTable;
-  messageStore: MessageStoreTable;
+  messageStoreMessages: MessageStoreTable;
   messageStoreRecordsTags: MessageStoreRecordsTagsTable;
   dataStore: DataStoreTable;
 }
diff --git a/src/utils/tags.ts b/src/utils/tags.ts
@@ -12,9 +12,9 @@ export class TagTables {
 
   /**
    * @param dialect the target dialect, necessary for returning the `insertId`
-   * @param table the DB Table in order to index the tags and values in the correct tables. Choice between `messageStore` and `eventLog`
+   * @param table the DB Table in order to index the tags and values in the correct tables. Choice between `messageStoreMessages` and `eventLogMessages`
    */
-  constructor(private dialect: Dialect, private table: 'messageStore' | 'eventLog'){}
+  constructor(private dialect: Dialect, private table: 'messageStoreMessages' | 'eventLogMessages'){}
 
   /**
    * Inserts the given tags associated with the given foreign `insertId`.
@@ -24,8 +24,8 @@ export class TagTables {
     tags: KeyValues,
     tx: Transaction<DwnDatabaseType>,
   ):Promise<void> {
-    const tagTable = this.table === 'messageStore' ? 'messageStoreRecordsTags' : 'eventLogRecordsTags';
-    const foreignKeyReference = tagTable === 'messageStoreRecordsTags' ? { messageInsertId: foreignInsertId } : { eventLogWatermark: foreignInsertId };
+    const tagTable = this.table === 'messageStoreMessages' ? 'messageStoreRecordsTags' : 'eventLogRecordsTags';
+    const foreignKeyReference = tagTable === 'messageStoreRecordsTags' ? { messageInsertId: foreignInsertId } : { eventWatermark: foreignInsertId };
 
     for (const tag in tags) {
       const tagValues = tags[tag];