Merge pull request #24 from AgrI-Mitra/fix/repeated-responses

Author: kh4l1d64

src/app.controller.ts

@@ -194,13 +194,15 @@ export class AppController {
       configid
     )
 
+    console.log("fetched conversation: ", conversation)
     //handle text and audio
     if(promptDto.text){
       type = "Text"
       let detectLanguageStartTime = Date.now();
       if(/^\d+$/.test(userInput)){
         prompt.inputLanguage = Language.en
       } else {
+        console.log("IN ELSE....")
         try {
           let response = await this.aiToolsService.detectLanguage(userInput)
           prompt.inputLanguage = response["language"] as Language 
@@ -239,12 +241,14 @@ export class AppController {
             tags: ['bot','detect_language','error']     
           })
         }
+        console.log("LANGUAGE DETECTED...")
         //@ts-ignore
         if(prompt.inputLanguage == 'unk'){
           prompt.inputLanguage = prompt.input.inputLanguage as Language
         }
         // verboseLogger("Detected Language =", prompt.inputLanguage)
       }
+      console.log("TELEMETRYYYYY")
       await this.telemetryService.capture({
         eventName: "Detect language",
         eventType: "DETECT_LANGUAGE",
@@ -375,7 +379,7 @@ export class AppController {
     }
 
     conversation.inputType = type;
-
+    console.log("CP 1...")
     //get flow
     let botFlowMachine;
     switch(configid){
@@ -411,6 +415,7 @@ export class AppController {
         }
       })
     }else {
+      console.log("creating a new message in Message table...")
       await this.prismaService.message.create({
         data:{
           text: type=="Text"?promptDto.text:null,
@@ -505,6 +510,7 @@ export class AppController {
       return res
     } else {
       //translate to english
+      console.log("Translating to English...")
       let translateStartTime = Date.now();
       if(userInput == 'resend OTP'){
         this.monitoringService.incrementResentOTPCount()
@@ -1101,7 +1107,7 @@ export class AppController {
         result['audio'] = {text: "",error: error.message}
       }
     }
-
+    console.log("Saving conversation..")
     conversation = await this.conversationService.saveConversation(
       sessionId,
       userId,

src/modules/aiTools/ai-tools.service.ts

@@ -19,6 +19,7 @@ export class AiToolsService {
     @Inject(CACHE_MANAGER) private readonly cacheManager: Cache,
   ) {}
   async detectLanguage(text: string): Promise<any> {
+    console.log("DETECTING LANGUAGE....")
     var myHeaders = new Headers();
     myHeaders.append("Content-Type", "application/json");
 

src/modules/conversation/conversation.service.ts

@@ -58,6 +58,24 @@ export class ConversationService {
         } 
       })
     }
+
+    if(conversation.state == "Done") {
+      conversation = await this.prisma.conversation.update({
+        where: {
+          id: sessionId
+        },
+        data: {
+          context: defaultContext,
+          state: "onGoing"
+        }
+      })
+
+      conversation = await this.prisma.conversation.findFirst({
+        where: {
+          id: sessionId
+        }
+      })
+    }
 
     return conversation?.context ? {...conversation.context, id:conversation.id} : null;
   }

src/xstate/prompt/prompt.service.ts

@@ -33,6 +33,7 @@ export class PromptServices {
     }
 
     async questionClassifier (context) {
+        console.log("IN questionclassifier")
         try{
             let response: any = await this.aiToolsService.getResponseViaWadhwani(context.sessionId, context.userId, context.query)
             if (response.error) throw new Error(`${response.error}, please try again.`)
@@ -68,6 +69,7 @@ export class PromptServices {
     }
 
     async validateAadhaarNumber (context, event) {
+        console.log("validate aadhar")
         try{
             const userIdentifier = `${context.userAadhaarNumber}${context.lastAadhaarDigits}`;
             let res;
@@ -101,6 +103,7 @@ export class PromptServices {
     }
 
     async validateOTP (context, event) {
+        console.log("Validate OTP")
         const userIdentifier = `${context.userAadhaarNumber}${context.lastAadhaarDigits}`;
         const otp = context.otp;
         let res;
@@ -124,6 +127,7 @@ export class PromptServices {
     }
 
     async fetchUserData (context, event) {
+        console.log("Fetch user data");
         const userIdentifier = `${context.userAadhaarNumber}${context.lastAadhaarDigits}`;
         let res;
         let type='Mobile'
@@ -210,6 +214,7 @@ export class PromptServices {
     }
 
     async wadhwaniClassifier (context) {
+        console.log("Wadhwani Classifierrr")
         try{
             let response: any = await this.aiToolsService.getResponseViaWadhwani(context.sessionId, context.userId,context.query)
             if (response.error) throw new Error(`${response.error}, please try again.`)