Rename Match Queue

services/match/README.md

@@ -225,10 +225,10 @@ docker compose down -v
 
 ## Producers
 
-### Match Request Updated Producer
+### Match Request Created Producer
 
 - This producer emits a message when a match request has been created or updated. 
-- **Queue**: `MATCH_REQUEST_UPDATED`
+- **Queue**: `MATCH_REQUEST_CREATED`
 - **Data Produced**
   - `user` - The user associated with the created or updated match request.
   - `topics` - The topics of the created or updated match request.
@@ -279,12 +279,12 @@ docker compose down -v
 
 ## Consumers
 
-### Match Request Updated Consumer
+### Match Request Created Consumer
 
 - This consumer attempts to find and assign a compatible match request based on their preferences (topics and difficulty) upon the update of a given match request.
 - Two match requests are said to be compatible if they share the same difficulty and have at least one topic in common.
 - Upon successfully finding a match, it produces a `MATCH_FOUND` event.
-- **Queue**: `MATCH_REQUEST_UPDATED` - This message is emitted when a match request is created or updated.
+- **Queue**: `MATCH_REQUEST_CREATED` - This message is emitted when a match request is created or updated.
 - **Data Consumed**
   - `user` - The user associated with the created or updated match request.
   - `topics` - The topics of the created or updated match request.

services/match/src/events/consumer.ts

@@ -55,7 +55,7 @@ async function consumeMatchFailed(msg: MatchFailedEvent) {
 }
 
 export async function initializeConsumers() {
-    messageBroker.consume(Queues.MATCH_REQUEST_UPDATED, consumeMatchUpdated);
+    messageBroker.consume(Queues.MATCH_REQUEST_CREATED, consumeMatchUpdated);
     messageBroker.consume(Queues.COLLAB_CREATED, consumeCollabCreated);
     messageBroker.consume(Queues.MATCH_FAILED, consumeMatchFailed);
 }

services/match/src/events/producer.ts

@@ -16,7 +16,7 @@ export async function produceMatchUpdatedRequest(
         topics,
         difficulty,
     };
-    await messageBroker.produce(Queues.MATCH_REQUEST_UPDATED, message);
+    await messageBroker.produce(Queues.MATCH_REQUEST_CREATED, message);
 }
 
 export async function produceMatchFound(user1: any, user2: any, topics: string[], difficulty: Difficulty) {

services/match/src/events/queues.ts

@@ -1,5 +1,5 @@
 export enum Queues {
-    MATCH_REQUEST_UPDATED = 'MATCH_REQUEST_UPDATED',
+    MATCH_REQUEST_CREATED = 'MATCH_REQUEST_CREATED',
     MATCH_FOUND = 'MATCH_FOUND',
     QUESTION_FOUND = 'QUESTION_FOUND',
     COLLAB_CREATED = 'COLLAB_CREATED',

services/question/src/events/queues.ts

@@ -1,5 +1,5 @@
 export enum Queues {
-    MATCH_REQUEST_UPDATED = 'MATCH_REQUEST_UPDATED',
+    MATCH_REQUEST_CREATED = 'MATCH_REQUEST_CREATED',
     MATCH_FOUND = 'MATCH_FOUND',
     QUESTION_FOUND = 'QUESTION_FOUND',
     COLLAB_CREATED = 'COLLAB_CREATED',