diff --git a/src/index.ts b/src/index.ts index bafe38b..16db530 100644 --- a/src/index.ts +++ b/src/index.ts @@ -6,6 +6,7 @@ import rDramaSession from './rdrama/session/SessionManager'; import { DatabaseInitializer } from './db/initializeDatabase'; import RedisSessionManager from './redis/session/SessionManager'; import { Comment } from './rdrama/models/Comment'; +import { CommentParser } from './rdrama/services/CommentParser'; // Import other necessary services or configurations @@ -34,6 +35,8 @@ async function startApplication() { const workflowOrchestrator = new WorkflowOrchestrator(); + + redisManager.client.on('message', async (channel, message) => { if (channel === 'newCommentsChannel') { const comment: Comment = JSON.parse(message)