events-backend: made some names in EventBusStore more explicit

Signed-off-by: Patrik Oldsberg <poldsberg@gmail.com>

plugins/events-backend/src/service/hub/DatabaseEventBusStore.ts

@@ -350,7 +350,7 @@ export class DatabaseEventBusStore implements EventBusStore {
   async publish(options: {
     params: EventParams;
     consumedBy?: string[];
-  }): Promise<{ id: string } | undefined> {
+  }): Promise<{ eventId: string } | undefined> {
     const topic = options.params.topic;
     const consumedBy = options.consumedBy ?? [];
     // This query inserts a new event into the database, but only if there are
@@ -410,7 +410,7 @@ export class DatabaseEventBusStore implements EventBusStore {
       );
     }
 
-    return { id };
+    return { eventId: id };
   }
 
   async upsertSubscription(id: string, topics: string[]): Promise<void> {

plugins/events-backend/src/service/hub/MemoryEventBusStore.ts

@@ -33,7 +33,7 @@ export class MemoryEventBusStore implements EventBusStore {
   async publish(options: {
     params: EventParams;
     consumedBy: string[];
-  }): Promise<{ id: string } | undefined> {
+  }): Promise<{ eventId: string } | undefined> {
     const topic = options.params.topic;
     const consumedBy = new Set(options.consumedBy);
 
@@ -57,7 +57,7 @@ export class MemoryEventBusStore implements EventBusStore {
         this.#listeners.delete(listener);
       }
     }
-    return { id: String(nextSeq) };
+    return { eventId: String(nextSeq) };
   }
 
   #getMaxSeq() {

plugins/events-backend/src/service/hub/createEventBusRouter.ts

@@ -167,7 +167,7 @@ export async function createEventBusRouter(options: {
       consumedBy: req.body.consumedBy,
     });
     if (result) {
-      logger.info(`Published event to '${topic}' with ID '${result.id}'`, {
+      logger.info(`Published event to '${topic}' with ID '${result.eventId}'`, {
         subject: credentials.principal.subject,
       });
       res.status(201).end();

plugins/events-backend/src/service/hub/types.ts

@@ -20,11 +20,11 @@ export type EventBusStore = {
   publish(options: {
     params: EventParams;
     consumedBy?: string[];
-  }): Promise<{ id: string } | undefined>;
+  }): Promise<{ eventId: string } | undefined>;
 
-  upsertSubscription(id: string, topics: string[]): Promise<void>;
+  upsertSubscription(subscriptionId: string, topics: string[]): Promise<void>;
 
-  readSubscription(id: string): Promise<{ events: EventParams[] }>;
+  readSubscription(subscriptionId: string): Promise<{ events: EventParams[] }>;
 
   setupListener(
     subscriptionId: string,