From 9dcd4efca4706935314a741e5a7bcd0de701dbe8 Mon Sep 17 00:00:00 2001
From: Vladimir Aleksiev <vladimiraleksiev@gmail.com>
Date: Wed, 28 Aug 2024 17:24:29 +0300
Subject: [PATCH] rename env var to RABBITMQ_EVENT_BUS_EXCHANGE

---
 .env.default                | 2 +-
 src/event.bus/connection.ts | 2 +-
 src/index.ts                | 3 ---
 3 files changed, 2 insertions(+), 5 deletions(-)

diff --git a/.env.default b/.env.default
index b2cd995..dac4925 100644
--- a/.env.default
+++ b/.env.default
@@ -4,7 +4,7 @@ RABBITMQ_PASSWORD=alkemio!
 RABBITMQ_PORT=5672
 RABBITMQ_INGEST_SPACE_QUEUE=virtual-contributor-ingest-space
 RABBITMQ_INGEST_SPACE_RESULT_QUEUE=virtual-contributor-ingest-space-result
-RABBITMQ_EXCHANGE=event-bus
+RABBITMQ_EVENT_BUS_EXCHANGE=event-bus
 
 API_ENDPOINT_PRIVATE_GRAPHQL='http://localhost:3000/api/private/non-interactive/graphql'
 AUTH_ORY_KRATOS_PUBLIC_BASE_URL=http://localhost:3000/ory/kratos/public
diff --git a/src/event.bus/connection.ts b/src/event.bus/connection.ts
index e130618..ae01991 100644
--- a/src/event.bus/connection.ts
+++ b/src/event.bus/connection.ts
@@ -49,7 +49,7 @@ export class Connection {
       port: this.getEnvValue('RABBITMQ_PORT'),
       incomingQueue: this.getEnvValue('RABBITMQ_INGEST_SPACE_QUEUE'),
       outgoingQueue: this.getEnvValue('RABBITMQ_INGEST_SPACE_RESULT_QUEUE'),
-      exchange: this.getEnvValue('RABBITMQ_EXCHANGE'),
+      exchange: this.getEnvValue('RABBITMQ_EVENT_BUS_EXCHANGE'),
     };
   }
 
diff --git a/src/index.ts b/src/index.ts
index fe95560..abb1b43 100644
--- a/src/index.ts
+++ b/src/index.ts
@@ -9,9 +9,6 @@ import { embedSpace } from './space.embed/embed.space';
   const connection = await Connection.get();
 
   connection.consume(async (event: IngestSpace) => {
-    //TODO create event class matching the one from Server
-    //maybe share them in a package
-    //publish a confifrmation
     logger.info(`Ingest invoked for space: ${event.spaceId}`);
     const resultEvent = await embedSpace(event);
     // add rety mechanism as well