add chat id

Author: cyri113

src/controllers/hivemind.controller.ts

@@ -6,10 +6,10 @@ import HivemindTemporalService from '../services/temporal/hivemind.service';
 import { catchAsync } from '../utils';
 
 const askQuestion = catchAsync(async function (req: IAuthRequest, res: Response) {
-  console.debug('Body', req.body.communityId, req.body.question);
+  console.debug('Body', req.body.communityId, req.body.question, req.body.chatId);
   req.setTimeout(6 * 60 * 1000);
   res.setTimeout(6 * 60 * 1000);
-  const answer = await HivemindTemporalService.triggerWorkflow(req.body.communityId, req.body.question, false);
+  const answer = await HivemindTemporalService.triggerWorkflow(req.body.communityId, req.body.question, false, req.body.chatId);
   res.status(httpStatus.OK).send({ answer });
 });
 

src/services/temporal/hivemind.service.ts

@@ -9,6 +9,7 @@ interface HivemindPayload {
   community_id: string;
   query: string;
   enable_answer_skipping: boolean;
+  chat_id: string;
 }
 
 class HivemindTemporalService extends TemporalCoreService {
@@ -24,14 +25,15 @@ class HivemindTemporalService extends TemporalCoreService {
    * @param enableAnswerSkipping - Flag indicating if answer skipping is enabled.
    * @returns The workflow ID of the started workflow.
    */
-  public async triggerWorkflow(communityId: string, query: string, enableAnswerSkipping: boolean) {
+  public async triggerWorkflow(communityId: string, query: string, enableAnswerSkipping: boolean, chatId: string = '') {
     const client: Client = await this.getClient();
 
     // // Construct the payload as specified
     const payload: HivemindPayload = {
       community_id: communityId,
       query: query,
       enable_answer_skipping: enableAnswerSkipping,
+      chat_id: chatId,
     };
     try {
       const hivemindTaskQueue = 'HIVEMIND_AGENT_QUEUE';