{"version":3,"sources":["/Users/shyun/comcom/ain-enterprise/ain-adk/dist/cjs/chunk-FLPLVYXQ.cjs","../../src/services/thread.service.ts"],"names":[],"mappings":"AAAA;ACQO,IAAM,cAAA,EAAN,MAAoB;AAAA,EAClB;AAAA,EAER,WAAA,CAAY,YAAA,EAA4B;AACvC,IAAA,IAAA,CAAK,aAAA,EAAe,YAAA;AAAA,EACrB;AAAA,EAEA,MAAa,SAAA,CACZ,MAAA,EACA,QAAA,EACoC;AACpC,IAAA,MAAM,aAAA,EAAe,IAAA,CAAK,YAAA,CAAa,eAAA,CAAgB,CAAA;AACvD,IAAA,GAAA,CAAI,CAAC,YAAA,EAAc;AAClB,MAAA,MAAA;AAAA,IACD;AAEA,IAAA,OAAO,MAAM,YAAA,CAAa,SAAA,CAAU,MAAA,EAAQ,QAAQ,CAAA;AAAA,EACrD;AAAA,EAEA,MAAa,YAAA,CACZ,IAAA,EACA,MAAA,EACA,QAAA,EACA,KAAA,EACwB;AACxB,IAAA,MAAM,aAAA,EAAe,IAAA,CAAK,YAAA,CAAa,eAAA,CAAgB,CAAA;AACvD,IAAA,GAAA,CAAI,CAAC,YAAA,EAAc;AAClB,MAAA,OAAO;AAAA,QACN,IAAA;AAAA,QACA,MAAA;AAAA,QACA,QAAA;AAAA,QACA,KAAA;AAAA,QACA,QAAA,EAAU,CAAC;AAAA,MACZ,CAAA;AAAA,IACD;AAEA,IAAA,MAAM,SAAA,EAA2B,MAAM,YAAA,CAAa,YAAA;AAAA,MACnD,IAAA;AAAA,MACA,MAAA;AAAA,MACA,QAAA;AAAA,MACA;AAAA,IACD,CAAA;AACA,IAAA,OAAO,EAAE,GAAG,QAAA,EAAU,QAAA,EAAU,CAAC,EAAE,CAAA;AAAA,EACpC;AAAA,EAEA,MAAa,mBAAA,CACZ,MAAA,EACA,QAAA,EACA,QAAA,EACgB;AAChB,IAAA,MAAM,aAAA,EAAe,IAAA,CAAK,YAAA,CAAa,eAAA,CAAgB,CAAA;AACvD,IAAA,GAAA,CAAI,CAAC,YAAA,EAAc;AAClB,MAAA,MAAA;AAAA,IACD;AAEA,IAAA,MAAM,YAAA,CAAa,mBAAA,CAAoB,MAAA,EAAQ,QAAA,EAAU,QAAQ,CAAA;AAAA,EAClE;AACD,CAAA;ADzBA;AACA;AACE;AACF,sCAAC","file":"/Users/shyun/comcom/ain-enterprise/ain-adk/dist/cjs/chunk-FLPLVYXQ.cjs","sourcesContent":[null,"import type { MemoryModule } from \"@/modules\";\nimport type {\n\tMessageObject,\n\tThreadMetadata,\n\tThreadObject,\n\tThreadType,\n} from \"@/types/memory\";\n\nexport class ThreadService {\n\tprivate memoryModule: MemoryModule;\n\n\tconstructor(memoryModule: MemoryModule) {\n\t\tthis.memoryModule = memoryModule;\n\t}\n\n\tpublic async getThread(\n\t\tuserId: string,\n\t\tthreadId: string,\n\t): Promise<ThreadObject | undefined> {\n\t\tconst threadMemory = this.memoryModule.getThreadMemory();\n\t\tif (!threadMemory) {\n\t\t\treturn;\n\t\t}\n\n\t\treturn await threadMemory.getThread(userId, threadId);\n\t}\n\n\tpublic async createThread(\n\t\ttype: ThreadType,\n\t\tuserId: string,\n\t\tthreadId: string,\n\t\ttitle: string,\n\t): Promise<ThreadObject> {\n\t\tconst threadMemory = this.memoryModule.getThreadMemory();\n\t\tif (!threadMemory) {\n\t\t\treturn {\n\t\t\t\ttype,\n\t\t\t\tuserId,\n\t\t\t\tthreadId,\n\t\t\t\ttitle,\n\t\t\t\tmessages: [],\n\t\t\t};\n\t\t}\n\n\t\tconst metadata: ThreadMetadata = await threadMemory.createThread(\n\t\t\ttype,\n\t\t\tuserId,\n\t\t\tthreadId,\n\t\t\ttitle,\n\t\t);\n\t\treturn { ...metadata, messages: [] };\n\t}\n\n\tpublic async addMessagesToThread(\n\t\tuserId: string,\n\t\tthreadId: string,\n\t\tmessages: Array<MessageObject>,\n\t): Promise<void> {\n\t\tconst threadMemory = this.memoryModule.getThreadMemory();\n\t\tif (!threadMemory) {\n\t\t\treturn;\n\t\t}\n\n\t\tawait threadMemory.addMessagesToThread(userId, threadId, messages);\n\t}\n}\n"]}