{"version":3,"sources":["/Users/shyun/comcom/ain-enterprise/ain-adk/dist/cjs/chunk-WWR5XE2T.cjs","../../src/services/user-workflow.service.ts"],"names":[],"mappings":"AAAA;ACAA,gCAA2B;AAYpB,IAAM,oBAAA,EAAN,MAA0B;AAAA,EACxB;AAAA,EACA;AAAA,EAER,WAAA,CACC,YAAA,EACA,wBAAA,EACC;AACD,IAAA,IAAA,CAAK,aAAA,EAAe,YAAA;AACpB,IAAA,IAAA,CAAK,yBAAA,EAA2B,wBAAA;AAAA,EACjC;AAAA,EAEA,MAAM,cAAA,CAAe,QAAA,EAA+C;AACnE,IAAA,MAAM,OAAA,EAAS,IAAA,CAAK,YAAA,CAAa,qBAAA,CAAsB,CAAA;AACvD,IAAA,MAAM,mBAAA,EAAmC;AAAA,MACxC,GAAG,QAAA;AAAA,MACH,OAAA,EAAS,QAAA,CAAS,QAAA,GAAW,QAAA,CAAS,KAAA;AAAA,MACtC,SAAA,EAAW,IAAA,CAAK,wBAAA,CAAyB,kBAAA;AAAA,QACxC,QAAA,CAAS;AAAA,MACV;AAAA,IACD,CAAA;AACA,IAAA,MAAM,EAAE,OAAA,EAAS,KAAA,EAAO,WAAW,EAAA,EAClC,IAAA,CAAK,wBAAA,CAAyB,kBAAA,CAAmB,kBAAkB,CAAA;AACpE,IAAA,GAAA,CAAI,CAAC,UAAA,EAAY;AAChB,MAAA,MAAM,IAAI,KAAA;AAAA,QACT;AAAA,MACD,CAAA;AAAA,IACD;AAEA,IAAA,MAAM,YAAA,EAA4B;AAAA,MACjC,GAAG,kBAAA;AAAA,MACH,UAAA,EAAY,QAAA,CAAS,WAAA,GAAc,gCAAA,CAAW;AAAA,MAC9C,MAAA,mBAAQ,QAAA,CAAS,MAAA,UAAU,MAAA;AAAA,MAC3B,OAAA;AAAA,MACA,KAAA;AAAA,MACA;AAAA,IACD,CAAA;AACA,IAAA,OAAO,MAAA,CAAO,kBAAA,CAAmB,WAAW,CAAA;AAAA,EAC7C;AAAA,EAEA,MAAM,cAAA,CACL,UAAA,EACA,OAAA,EACgB;AAChB,IAAA,MAAM,OAAA,EAAS,IAAA,CAAK,YAAA,CAAa,qBAAA,CAAsB,CAAA;AACvD,IAAA,MAAM,MAAA,CAAO,kBAAA,CAAmB,UAAA,EAAY;AAAA,MAC3C,GAAG,OAAA;AAAA,MACH,SAAA,EAAW,IAAA,CAAK,wBAAA,CAAyB,kBAAA;AAAA,QACxC,OAAA,CAAQ;AAAA,MACT,CAAA;AAAA,MACA,UAAA,EAAY,IAAA,CAAK,wBAAA,CAAyB,mBAAA;AAAA,QACzC,OAAA,CAAQ;AAAA,MACT;AAAA,IACD,CAAC,CAAA;AAAA,EACF;AAAA,EAEA,MAAM,cAAA,CAAe,UAAA,EAAoB,MAAA,EAA+B;AACvE,IAAA,MAAM,OAAA,EAAS,IAAA,CAAK,YAAA,CAAa,qBAAA,CAAsB,CAAA;AACvD,IAAA,MAAM,MAAA,CAAO,kBAAA,CAAmB,UAAA,EAAY,MAAM,CAAA;AAAA,EACnD;AAAA,EAEA,MAAM,WAAA,CAAY,UAAA,EAAuD;AACxE,IAAA,MAAM,OAAA,EAAS,IAAA,CAAK,YAAA,CAAa,qBAAA,CAAsB,CAAA;AACvD,IAAA,OAAO,MAAA,CAAO,eAAA,CAAgB,UAAU,CAAA;AAAA,EACzC;AAAA,EAEA,MAAM,aAAA,CACL,MAAA,EACA,OAAA,EAC0B;AAC1B,IAAA,MAAM,OAAA,EAAS,IAAA,CAAK,YAAA,CAAa,qBAAA,CAAsB,CAAA;AACvD,IAAA,OAAO,MAAA,CAAO,iBAAA,CAAkB,MAAA,EAAQ,OAAO,CAAA;AAAA,EAChD;AAAA;AAAA,EAGA,MAAM,cAAA,CAAe,MAAA,EAA8C;AAClE,IAAA,MAAM,OAAA,EAAS,IAAA,CAAK,YAAA,CAAa,qBAAA,CAAsB,CAAA;AACvD,IAAA,uBAAO,MAAA,mBAAO,kBAAA,0BAAA,CAAqB,MAAM,GAAA;AAAA,EAC1C;AAAA,EAEA,MAAM,4BAAA,CAAA,EAAwD;AAC7D,IAAA,MAAM,OAAA,EAAS,IAAA,CAAK,YAAA,CAAa,qBAAA,CAAsB,CAAA;AACvD,IAAA,OAAO,MAAA,CAAO,4BAAA,CAA6B,CAAA;AAAA,EAC5C;AACD,CAAA;AD5BA;AACA;AACE;AACF,kDAAC","file":"/Users/shyun/comcom/ain-enterprise/ain-adk/dist/cjs/chunk-WWR5XE2T.cjs","sourcesContent":[null,"import { randomUUID } from \"node:crypto\";\nimport type { MemoryModule } from \"@/modules/index.js\";\nimport type { ListOptions } from \"@/types/list.js\";\nimport type { UserWorkflow } from \"@/types/memory.js\";\nimport type { WorkflowVariableResolver } from \"./workflow-variable-resolver.service.js\";\n\n/**\n * Service for persisting user workflows.\n *\n * Keeps storage-focused operations in one place while delegating variable resolution\n * and execution orchestration to dedicated collaborators.\n */\nexport class UserWorkflowService {\n\tprivate memoryModule: MemoryModule;\n\tprivate workflowVariableResolver: WorkflowVariableResolver;\n\n\tconstructor(\n\t\tmemoryModule: MemoryModule,\n\t\tworkflowVariableResolver: WorkflowVariableResolver,\n\t) {\n\t\tthis.memoryModule = memoryModule;\n\t\tthis.workflowVariableResolver = workflowVariableResolver;\n\t}\n\n\tasync createWorkflow(workflow: UserWorkflow): Promise<UserWorkflow> {\n\t\tconst memory = this.memoryModule.getUserWorkflowMemory();\n\t\tconst normalizedWorkflow: UserWorkflow = {\n\t\t\t...workflow,\n\t\t\tcontent: workflow.content || workflow.title,\n\t\t\tvariables: this.workflowVariableResolver.normalizeVariables(\n\t\t\t\tworkflow.variables,\n\t\t\t),\n\t\t};\n\t\tconst { content, title, definition } =\n\t\t\tthis.workflowVariableResolver.resolveForCreation(normalizedWorkflow);\n\t\tif (!definition) {\n\t\t\tthrow new Error(\n\t\t\t\t\"Workflow definition is required: structured definition missing or invalid\",\n\t\t\t);\n\t\t}\n\n\t\tconst newWorkflow: UserWorkflow = {\n\t\t\t...normalizedWorkflow,\n\t\t\tworkflowId: workflow.workflowId || randomUUID(),\n\t\t\tactive: workflow.active ?? true,\n\t\t\tcontent,\n\t\t\ttitle,\n\t\t\tdefinition,\n\t\t};\n\t\treturn memory.createUserWorkflow(newWorkflow);\n\t}\n\n\tasync updateWorkflow(\n\t\tworkflowId: string,\n\t\tupdates: Partial<UserWorkflow>,\n\t): Promise<void> {\n\t\tconst memory = this.memoryModule.getUserWorkflowMemory();\n\t\tawait memory.updateUserWorkflow(workflowId, {\n\t\t\t...updates,\n\t\t\tvariables: this.workflowVariableResolver.normalizeVariables(\n\t\t\t\tupdates.variables,\n\t\t\t),\n\t\t\tdefinition: this.workflowVariableResolver.normalizeDefinition(\n\t\t\t\tupdates.definition,\n\t\t\t),\n\t\t});\n\t}\n\n\tasync deleteWorkflow(workflowId: string, userId: string): Promise<void> {\n\t\tconst memory = this.memoryModule.getUserWorkflowMemory();\n\t\tawait memory.deleteUserWorkflow(workflowId, userId);\n\t}\n\n\tasync getWorkflow(workflowId: string): Promise<UserWorkflow | undefined> {\n\t\tconst memory = this.memoryModule.getUserWorkflowMemory();\n\t\treturn memory.getUserWorkflow(workflowId);\n\t}\n\n\tasync listWorkflows(\n\t\tuserId?: string,\n\t\toptions?: ListOptions,\n\t): Promise<UserWorkflow[]> {\n\t\tconst memory = this.memoryModule.getUserWorkflowMemory();\n\t\treturn memory.listUserWorkflows(userId, options);\n\t}\n\n\t/** undefined = provider has no count support (legacy). */\n\tasync countWorkflows(userId?: string): Promise<number | undefined> {\n\t\tconst memory = this.memoryModule.getUserWorkflowMemory();\n\t\treturn memory.countUserWorkflows?.(userId);\n\t}\n\n\tasync listActiveScheduledWorkflows(): Promise<UserWorkflow[]> {\n\t\tconst memory = this.memoryModule.getUserWorkflowMemory();\n\t\treturn memory.listActiveScheduledWorkflows();\n\t}\n}\n"]}