We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 88f399e commit cd8f1cfCopy full SHA for cd8f1cf
matching-service/src/services/webSocketService.ts
@@ -117,14 +117,10 @@ class WebSocketService {
117
this.clients.delete(userId);
118
// Remove any pending notifications for this user
119
this.pendingNotifications.delete(userId);
120
- // TODO: Implement logic to remove the user from Redis queues
121
this.removeUserFromQueues(userId);
122
}
123
124
private async removeUserFromQueues(userId: string) {
125
- // This method should remove the user from all Redis queues
126
- // You'll need to implement this logic based on your Redis structure
127
- // For example:
128
const allTopics = await redisClient.keys("topic:*");
129
const allDifficulties = await redisClient.keys("difficulty:*");
130
0 commit comments