{"version":3,"sources":["../src/server/handlers/agent-builder.ts"],"names":["__export","WorkflowRegistry","createRoute","listWorkflowsResponseSchema","LIST_WORKFLOWS_ROUTE","handleError","actionIdPathParams","workflowInfoSchema","HTTPException","GET_WORKFLOW_BY_ID_ROUTE","listWorkflowRunsQuerySchema","workflowRunsResponseSchema","LIST_WORKFLOW_RUNS_ROUTE","actionRunPathParams","workflowRunResultQuerySchema","workflowRunResultSchema","GET_WORKFLOW_RUN_BY_ID_ROUTE","optionalRunIdSchema","createWorkflowRunResponseSchema","CREATE_WORKFLOW_RUN_ROUTE","runIdSchema","streamAgentBuilderBodySchema","streamResponseSchema","STREAM_WORKFLOW_ROUTE","startAsyncAgentBuilderBodySchema","workflowExecutionResultSchema","START_ASYNC_WORKFLOW_ROUTE","workflowControlResponseSchema","START_WORKFLOW_RUN_ROUTE","OBSERVE_STREAM_WORKFLOW_ROUTE","resumeAgentBuilderBodySchema","RESUME_ASYNC_WORKFLOW_ROUTE","RESUME_NO_WAIT_WORKFLOW_ROUTE","RESUME_WORKFLOW_ROUTE","RESUME_STREAM_WORKFLOW_ROUTE","CANCEL_WORKFLOW_RUN_ROUTE","streamLegacyAgentBuilderBodySchema","STREAM_LEGACY_WORKFLOW_ROUTE","OBSERVE_STREAM_LEGACY_WORKFLOW_ROUTE"],"mappings":";;;;;;;;;;;;;;AAAA,IAAA,qBAAA,GAAA;AAAAA,0BAAA,CAAA,qBAAA,EAAA;AAAA,EAAA,qCAAA,EAAA,MAAA,qCAAA;AAAA,EAAA,qCAAA,EAAA,MAAA,qCAAA;AAAA,EAAA,oCAAA,EAAA,MAAA,oCAAA;AAAA,EAAA,wCAAA,EAAA,MAAA,wCAAA;AAAA,EAAA,gCAAA,EAAA,MAAA,gCAAA;AAAA,EAAA,oCAAA,EAAA,MAAA,oCAAA;AAAA,EAAA,yCAAA,EAAA,MAAA,yCAAA;AAAA,EAAA,gDAAA,EAAA,MAAA,gDAAA;AAAA,EAAA,iCAAA,EAAA,MAAA,iCAAA;AAAA,EAAA,uCAAA,EAAA,MAAA,uCAAA;AAAA,EAAA,yCAAA,EAAA,MAAA,yCAAA;AAAA,EAAA,wCAAA,EAAA,MAAA,wCAAA;AAAA,EAAA,oCAAA,EAAA,MAAA,oCAAA;AAAA,EAAA,sCAAA,EAAA,MAAA,sCAAA;AAAA,EAAA,iCAAA,EAAA,MAAA,iCAAA;AAAA,EAAA,wCAAA,EAAA,MAAA;AAAA,CAAA,CAAA;AA4BA,IAAI,4BAAA;AAEJ,eAAe,yBAAA,GAA4D;AACzE,EAAA,4BAAA,KAAiC,OAAO,qBAAuB,CAAA,CAAE,IAAA,CAAK,CAAA,GAAA,KAAO,IAAI,qBAAqB,CAAA;AACtG,EAAA,OAAO,4BAAA;AACT;AAEA,eAAe,8BACb,MAAA,EACA;AACA,EAAA,MAAM,qBAAA,GAAwB,MAAM,yBAAA,EAA0B;AAC9D,EAAAC,kCAAA,CAAiB,0BAAA,CAA2B,uBAAuB,MAAM,CAAA;AACzE,EAAA,OAAO,qBAAA;AACT;AAMO,IAAM,mCAAmCC,6BAAA,CAAY;AAAA,EAC1D,MAAA,EAAQ,KAAA;AAAA,EACR,IAAA,EAAM,gBAAA;AAAA,EACN,YAAA,EAAc,MAAA;AAAA,EACd,cAAA,EAAgBC,6CAAA;AAAA,EAChB,OAAA,EAAS,4BAAA;AAAA,EACT,WAAA,EAAa,uDAAA;AAAA,EACb,IAAA,EAAM,CAAC,eAAe,CAAA;AAAA,EACtB,YAAA,EAAc,IAAA;AAAA,EACd,OAAA,EAAS,OAAM,GAAA,KAAO;AACpB,IAAA,MAAM,EAAE,QAAO,GAAI,GAAA;AACnB,IAAA,MAAM,MAAA,GAAS,OAAO,SAAA,EAAU;AAChC,IAAA,IAAI;AACF,MAAA,MAAM,8BAA8B,MAAM,CAAA;AAC1C,MAAA,MAAA,CAAO,KAAK,+BAA+B,CAAA;AAG3C,MAAA,OAAO,MAAgBC,sCAAA,CAAqB,OAAA,CAAQ,GAAG,CAAA;AAAA,IACzD,SAAS,KAAA,EAAO;AACd,MAAA,MAAA,CAAO,KAAA,CAAM,qCAAA,EAAuC,EAAE,KAAA,EAAO,CAAA;AAC7D,MAAA,OAAOC,6BAAA,CAAY,OAAO,uCAAuC,CAAA;AAAA,IACnE,CAAA,SAAE;AACA,MAAAJ,kCAAA,CAAiB,OAAA,EAAQ;AAAA,IAC3B;AAAA,EACF;AACF,CAAC;AAEM,IAAM,uCAAuCC,6BAAA,CAAY;AAAA,EAC9D,MAAA,EAAQ,KAAA;AAAA,EACR,IAAA,EAAM,0BAAA;AAAA,EACN,YAAA,EAAc,MAAA;AAAA,EACd,eAAA,EAAiBI,oCAAA;AAAA,EACjB,cAAA,EAAgBC,oCAAA;AAAA,EAChB,OAAA,EAAS,kBAAA;AAAA,EACT,WAAA,EAAa,qDAAA;AAAA,EACb,IAAA,EAAM,CAAC,eAAe,CAAA;AAAA,EACtB,YAAA,EAAc,IAAA;AAAA,EACd,OAAA,EAAS,OAAM,GAAA,KAAO;AACpB,IAAA,MAAM,EAAE,MAAA,EAAQ,QAAA,EAAS,GAAI,GAAA;AAC7B,IAAA,MAAM,MAAA,GAAS,OAAO,SAAA,EAAU;AAChC,IAAA,IAAI;AACF,MAAA,MAAM,qBAAA,GAAwB,MAAM,6BAAA,CAA8B,MAAM,CAAA;AAExE,MAAA,IAAI,QAAA,IAAY,CAACN,kCAAA,CAAiB,sBAAA,CAAuB,QAAQ,CAAA,EAAG;AAClE,QAAA,MAAM,IAAIO,gCAAc,GAAA,EAAK;AAAA,UAC3B,OAAA,EAAS,CAAA,8BAAA,EAAiC,QAAQ,CAAA,qBAAA,EAAwB,MAAA,CAAO,KAAK,qBAAqB,CAAA,CAAE,IAAA,CAAK,IAAI,CAAC,CAAA;AAAA,SACxH,CAAA;AAAA,MACH;AAEA,MAAA,MAAA,CAAO,IAAA,CAAK,oCAAA,EAAsC,EAAE,QAAA,EAAU,CAAA;AAE9D,MAAA,OAAO,MAAgBC,2CAAyB,OAAA,CAAQ,EAAE,GAAG,GAAA,EAAK,UAAA,EAAY,UAAU,CAAA;AAAA,IAC1F,SAAS,KAAA,EAAO;AACd,MAAA,MAAA,CAAO,KAAA,CAAM,0CAAA,EAA4C,EAAE,KAAA,EAAO,UAAU,CAAA;AAC5E,MAAA,OAAOJ,6BAAA,CAAY,OAAO,oCAAoC,CAAA;AAAA,IAChE,CAAA,SAAE;AACA,MAAAJ,kCAAA,CAAiB,OAAA,EAAQ;AAAA,IAC3B;AAAA,EACF;AACF,CAAC;AAEM,IAAM,uCAAuCC,6BAAA,CAAY;AAAA,EAC9D,MAAA,EAAQ,KAAA;AAAA,EACR,IAAA,EAAM,+BAAA;AAAA,EACN,YAAA,EAAc,MAAA;AAAA,EACd,eAAA,EAAiBI,oCAAA;AAAA,EACjB,gBAAA,EAAkBI,6CAAA;AAAA,EAClB,cAAA,EAAgBC,4CAAA;AAAA,EAChB,OAAA,EAAS,kBAAA;AAAA,EACT,WAAA,EAAa,qEAAA;AAAA,EACb,IAAA,EAAM,CAAC,eAAe,CAAA;AAAA,EACtB,YAAA,EAAc,IAAA;AAAA,EACd,OAAA,EAAS,OAAM,GAAA,KAAO;AACpB,IAAA,MAAM,EAAE,MAAA,EAAQ,QAAA,EAAS,GAAI,GAAA;AAC7B,IAAA,MAAM,MAAA,GAAS,OAAO,SAAA,EAAU;AAChC,IAAA,IAAI;AACF,MAAA,MAAM,8BAA8B,MAAM,CAAA;AAE1C,MAAA,IAAI,QAAA,IAAY,CAACV,kCAAA,CAAiB,sBAAA,CAAuB,QAAQ,CAAA,EAAG;AAClE,QAAA,MAAM,IAAIO,gCAAc,GAAA,EAAK,EAAE,SAAS,CAAA,8BAAA,EAAiC,QAAQ,IAAI,CAAA;AAAA,MACvF;AAEA,MAAA,MAAA,CAAO,IAAA,CAAK,mCAAA,EAAqC,EAAE,QAAA,EAAU,CAAA;AAE7D,MAAA,OAAO,MAAgBI,2CAAyB,OAAA,CAAQ;AAAA,QACtD,GAAG,GAAA;AAAA,QACH,UAAA,EAAY;AAAA,OACb,CAAA;AAAA,IACH,SAAS,KAAA,EAAO;AACd,MAAA,MAAA,CAAO,KAAA,CAAM,yCAAA,EAA2C,EAAE,KAAA,EAAO,UAAU,CAAA;AAC3E,MAAA,OAAOP,6BAAA,CAAY,OAAO,yCAAyC,CAAA;AAAA,IACrE,CAAA,SAAE;AACA,MAAAJ,kCAAA,CAAiB,OAAA,EAAQ;AAAA,IAC3B;AAAA,EACF;AACF,CAAC;AAEM,IAAM,2CAA2CC,6BAAA,CAAY;AAAA,EAClE,MAAA,EAAQ,KAAA;AAAA,EACR,IAAA,EAAM,sCAAA;AAAA,EACN,YAAA,EAAc,MAAA;AAAA,EACd,eAAA,EAAiBW,qCAAA;AAAA,EACjB,gBAAA,EAAkBC,8CAAA;AAAA,EAClB,cAAA,EAAgBC,yCAAA;AAAA,EAChB,OAAA,EAAS,sBAAA;AAAA,EACT,WAAA,EACE,+IAAA;AAAA,EACF,IAAA,EAAM,CAAC,eAAe,CAAA;AAAA,EACtB,YAAA,EAAc,IAAA;AAAA,EACd,OAAA,EAAS,OAAM,GAAA,KAAO;AACpB,IAAA,MAAM,EAAE,MAAA,EAAQ,QAAA,EAAU,KAAA,EAAM,GAAI,GAAA;AACpC,IAAA,MAAM,MAAA,GAAS,OAAO,SAAA,EAAU;AAChC,IAAA,IAAI;AACF,MAAA,MAAM,8BAA8B,MAAM,CAAA;AAE1C,MAAA,IAAI,QAAA,IAAY,CAACd,kCAAA,CAAiB,sBAAA,CAAuB,QAAQ,CAAA,EAAG;AAClE,QAAA,MAAM,IAAIO,gCAAc,GAAA,EAAK,EAAE,SAAS,CAAA,8BAAA,EAAiC,QAAQ,IAAI,CAAA;AAAA,MACvF;AAEA,MAAA,MAAA,CAAO,IAAA,CAAK,wCAAA,EAA0C,EAAE,QAAA,EAAU,OAAO,CAAA;AAEzE,MAAA,OAAO,MAAgBQ,+CAA6B,OAAA,CAAQ;AAAA,QAC1D,GAAG,GAAA;AAAA,QACH,UAAA,EAAY;AAAA,OACb,CAAA;AAAA,IACH,SAAS,KAAA,EAAO;AACd,MAAA,MAAA,CAAO,MAAM,wCAAA,EAA0C,EAAE,KAAA,EAAO,QAAA,EAAU,OAAO,CAAA;AACjF,MAAA,OAAOX,6BAAA,CAAY,OAAO,wCAAwC,CAAA;AAAA,IACpE,CAAA,SAAE;AACA,MAAAJ,kCAAA,CAAiB,OAAA,EAAQ;AAAA,IAC3B;AAAA,EACF;AACF,CAAC;AAEM,IAAM,wCAAwCC,6BAAA,CAAY;AAAA,EAC/D,MAAA,EAAQ,MAAA;AAAA,EACR,IAAA,EAAM,qCAAA;AAAA,EACN,YAAA,EAAc,MAAA;AAAA,EACd,eAAA,EAAiBI,oCAAA;AAAA,EACjB,gBAAA,EAAkBW,qCAAA;AAAA,EAClB,cAAA,EAAgBC,iDAAA;AAAA,EAChB,OAAA,EAAS,mBAAA;AAAA,EACT,WAAA,EAAa,wEAAA;AAAA,EACb,IAAA,EAAM,CAAC,eAAe,CAAA;AAAA,EACtB,YAAA,EAAc,IAAA;AAAA,EACd,OAAA,EAAS,OAAM,GAAA,KAAO;AACpB,IAAA,MAAM,EAAE,MAAA,EAAQ,QAAA,EAAU,KAAA,EAAM,GAAI,GAAA;AACpC,IAAA,MAAM,MAAA,GAAS,OAAO,SAAA,EAAU;AAChC,IAAA,IAAI;AACF,MAAA,MAAM,8BAA8B,MAAM,CAAA;AAE1C,MAAA,IAAI,QAAA,IAAY,CAACjB,kCAAA,CAAiB,sBAAA,CAAuB,QAAQ,CAAA,EAAG;AAClE,QAAA,MAAM,IAAIO,gCAAc,GAAA,EAAK,EAAE,SAAS,CAAA,8BAAA,EAAiC,QAAQ,IAAI,CAAA;AAAA,MACvF;AAEA,MAAA,MAAA,CAAO,IAAA,CAAK,mCAAA,EAAqC,EAAE,QAAA,EAAU,OAAO,CAAA;AAEpE,MAAA,OAAO,MAAgBW,4CAA0B,OAAA,CAAQ;AAAA,QACvD,GAAG,GAAA;AAAA,QACH,UAAA,EAAY;AAAA,OACb,CAAA;AAAA,IACH,SAAS,KAAA,EAAO;AACd,MAAA,MAAA,CAAO,KAAA,CAAM,yCAAA,EAA2C,EAAE,KAAA,EAAO,UAAU,CAAA;AAC3E,MAAA,OAAOd,6BAAA,CAAY,OAAO,yCAAyC,CAAA;AAAA,IACrE,CAAA,SAAE;AACA,MAAAJ,kCAAA,CAAiB,OAAA,EAAQ;AAAA,IAC3B;AAAA,EACF;AACF,CAAC;AAEM,IAAM,oCAAoCC,6BAAA,CAAY;AAAA,EAC3D,MAAA,EAAQ,MAAA;AAAA,EACR,IAAA,EAAM,iCAAA;AAAA,EACN,YAAA,EAAc,QAAA;AAAA,EACd,eAAA,EAAiBI,oCAAA;AAAA,EACjB,gBAAA,EAAkBc,6BAAA;AAAA,EAClB,UAAA,EAAYC,8CAAA;AAAA,EACZ,cAAA,EAAgBC,sCAAA;AAAA,EAChB,OAAA,EAAS,yBAAA;AAAA,EACT,WAAA,EAAa,yDAAA;AAAA,EACb,IAAA,EAAM,CAAC,eAAe,CAAA;AAAA,EACtB,YAAA,EAAc,IAAA;AAAA,EACd,OAAA,EAAS,OAAM,GAAA,KAAO;AACpB,IAAA,MAAM,EAAE,MAAA,EAAQ,QAAA,EAAU,KAAA,EAAO,gBAAe,GAAI,GAAA;AACpD,IAAA,MAAM,MAAA,GAAS,OAAO,SAAA,EAAU;AAChC,IAAA,IAAI;AACF,MAAA,MAAM,8BAA8B,MAAM,CAAA;AAE1C,MAAA,IAAI,QAAA,IAAY,CAACrB,kCAAA,CAAiB,sBAAA,CAAuB,QAAQ,CAAA,EAAG;AAClE,QAAA,MAAM,IAAIO,gCAAc,GAAA,EAAK,EAAE,SAAS,CAAA,8BAAA,EAAiC,QAAQ,IAAI,CAAA;AAAA,MACvF;AAEA,MAAA,MAAA,CAAO,IAAA,CAAK,gCAAA,EAAkC,EAAE,QAAA,EAAU,OAAO,CAAA;AAEjE,MAAA,OAAO,MAAgBe,wCAAsB,OAAA,CAAQ;AAAA,QACnD,GAAG,GAAA;AAAA,QACH,UAAA,EAAY,QAAA;AAAA,QACZ;AAAA,OACD,CAAA;AAAA,IACH,SAAS,KAAA,EAAO;AACd,MAAA,MAAA,CAAO,KAAA,CAAM,sCAAA,EAAwC,EAAE,KAAA,EAAO,UAAU,CAAA;AACxE,MAAA,OAAOlB,6BAAA,CAAY,OAAO,sCAAsC,CAAA;AAAA,IAClE,CAAA,SAAE;AACA,MAAAJ,kCAAA,CAAiB,OAAA,EAAQ;AAAA,IAC3B;AAAA,EACF;AACF,CAAC;AAEM,IAAM,yCAAyCC,6BAAA,CAAY;AAAA,EAChE,MAAA,EAAQ,MAAA;AAAA,EACR,IAAA,EAAM,sCAAA;AAAA,EACN,YAAA,EAAc,MAAA;AAAA,EACd,eAAA,EAAiBI,oCAAA;AAAA,EACjB,gBAAA,EAAkBW,qCAAA;AAAA,EAClB,UAAA,EAAYO,kDAAA;AAAA,EACZ,cAAA,EAAgBC,+CAAA;AAAA,EAChB,OAAA,EAAS,6BAAA;AAAA,EACT,WAAA,EAAa,qEAAA;AAAA,EACb,IAAA,EAAM,CAAC,eAAe,CAAA;AAAA,EACtB,YAAA,EAAc,IAAA;AAAA,EACd,OAAA,EAAS,OAAM,GAAA,KAAO;AACpB,IAAA,MAAM,EAAE,MAAA,EAAQ,QAAA,EAAU,KAAA,EAAO,gBAAe,GAAI,GAAA;AACpD,IAAA,MAAM,MAAA,GAAS,OAAO,SAAA,EAAU;AAChC,IAAA,IAAI;AACF,MAAA,MAAM,8BAA8B,MAAM,CAAA;AAE1C,MAAA,IAAI,QAAA,IAAY,CAACxB,kCAAA,CAAiB,sBAAA,CAAuB,QAAQ,CAAA,EAAG;AAClE,QAAA,MAAM,IAAIO,gCAAc,GAAA,EAAK,EAAE,SAAS,CAAA,8BAAA,EAAiC,QAAQ,IAAI,CAAA;AAAA,MACvF;AAEA,MAAA,MAAA,CAAO,IAAA,CAAK,8CAAA,EAAgD,EAAE,QAAA,EAAU,OAAO,CAAA;AAE/E,MAAA,OAAO,MAAgBkB,6CAA2B,OAAA,CAAQ;AAAA,QACxD,GAAG,GAAA;AAAA,QACH,UAAA,EAAY,QAAA;AAAA,QACZ;AAAA,OACD,CAAA;AAAA,IACH,SAAS,KAAA,EAAO;AACd,MAAA,MAAA,CAAO,KAAA,CAAM,oDAAA,EAAsD,EAAE,KAAA,EAAO,UAAU,CAAA;AACtF,MAAA,OAAOrB,6BAAA,CAAY,OAAO,qCAAqC,CAAA;AAAA,IACjE,CAAA,SAAE;AACA,MAAAJ,kCAAA,CAAiB,OAAA,EAAQ;AAAA,IAC3B;AAAA,EACF;AACF,CAAC;AAEM,IAAM,uCAAuCC,6BAAA,CAAY;AAAA,EAC9D,MAAA,EAAQ,MAAA;AAAA,EACR,IAAA,EAAM,gCAAA;AAAA,EACN,YAAA,EAAc,MAAA;AAAA,EACd,eAAA,EAAiBI,oCAAA;AAAA,EACjB,gBAAA,EAAkBc,6BAAA;AAAA,EAClB,UAAA,EAAYI,kDAAA;AAAA,EACZ,cAAA,EAAgBG,+CAAA;AAAA,EAChB,OAAA,EAAS,2BAAA;AAAA,EACT,WAAA,EAAa,iDAAA;AAAA,EACb,IAAA,EAAM,CAAC,eAAe,CAAA;AAAA,EACtB,YAAA,EAAc,IAAA;AAAA,EACd,OAAA,EAAS,OAAM,GAAA,KAAO;AACpB,IAAA,MAAM,EAAE,MAAA,EAAQ,QAAA,EAAU,KAAA,EAAO,gBAAe,GAAI,GAAA;AACpD,IAAA,MAAM,MAAA,GAAS,OAAO,SAAA,EAAU;AAChC,IAAA,IAAI;AACF,MAAA,MAAM,8BAA8B,MAAM,CAAA;AAE1C,MAAA,IAAI,QAAA,IAAY,CAAC1B,kCAAA,CAAiB,sBAAA,CAAuB,QAAQ,CAAA,EAAG;AAClE,QAAA,MAAM,IAAIO,gCAAc,GAAA,EAAK,EAAE,SAAS,CAAA,8BAAA,EAAiC,QAAQ,IAAI,CAAA;AAAA,MACvF;AAEA,MAAA,MAAA,CAAO,IAAA,CAAK,4CAAA,EAA8C,EAAE,QAAA,EAAU,OAAO,CAAA;AAE7E,MAAA,OAAO,MAAgBoB,2CAAyB,OAAA,CAAQ;AAAA,QACtD,GAAG,GAAA;AAAA,QACH,UAAA,EAAY,QAAA;AAAA,QACZ;AAAA,OACD,CAAA;AAAA,IACH,SAAS,KAAA,EAAO;AACd,MAAA,MAAA,CAAO,KAAA,CAAM,yCAAA,EAA2C,EAAE,KAAA,EAAO,UAAU,CAAA;AAC3E,MAAA,OAAOvB,6BAAA,CAAY,OAAO,yCAAyC,CAAA;AAAA,IACrE,CAAA,SAAE;AACA,MAAAJ,kCAAA,CAAiB,OAAA,EAAQ;AAAA,IAC3B;AAAA,EACF;AACF,CAAC;AAEM,IAAM,4CAA4CC,6BAAA,CAAY;AAAA,EACnE,MAAA,EAAQ,MAAA;AAAA,EACR,IAAA,EAAM,kCAAA;AAAA,EACN,YAAA,EAAc,QAAA;AAAA,EACd,eAAA,EAAiBI,oCAAA;AAAA,EACjB,gBAAA,EAAkBc,6BAAA;AAAA,EAClB,cAAA,EAAgBE,sCAAA;AAAA,EAChB,OAAA,EAAS,uBAAA;AAAA,EACT,WAAA,EAAa,uEAAA;AAAA,EACb,IAAA,EAAM,CAAC,eAAe,CAAA;AAAA,EACtB,YAAA,EAAc,IAAA;AAAA,EACd,OAAA,EAAS,OAAM,GAAA,KAAO;AACpB,IAAA,MAAM,EAAE,MAAA,EAAQ,QAAA,EAAU,KAAA,EAAM,GAAI,GAAA;AACpC,IAAA,MAAM,MAAA,GAAS,OAAO,SAAA,EAAU;AAChC,IAAA,IAAI;AACF,MAAA,MAAM,8BAA8B,MAAM,CAAA;AAE1C,MAAA,IAAI,QAAA,IAAY,CAACrB,kCAAA,CAAiB,sBAAA,CAAuB,QAAQ,CAAA,EAAG;AAClE,QAAA,MAAM,IAAIO,gCAAc,GAAA,EAAK,EAAE,SAAS,CAAA,8BAAA,EAAiC,QAAQ,IAAI,CAAA;AAAA,MACvF;AAEA,MAAA,MAAA,CAAO,IAAA,CAAK,uCAAA,EAAyC,EAAE,QAAA,EAAU,OAAO,CAAA;AAExE,MAAA,OAAO,MAAgBqB,gDAA8B,OAAA,CAAQ;AAAA,QAC3D,GAAG,GAAA;AAAA,QACH,UAAA,EAAY;AAAA,OACb,CAAA;AAAA,IACH,SAAS,KAAA,EAAO;AACd,MAAA,MAAA,CAAO,KAAA,CAAM,6CAAA,EAA+C,EAAE,KAAA,EAAO,UAAU,CAAA;AAC/E,MAAA,OAAOxB,6BAAA,CAAY,OAAO,6CAA6C,CAAA;AAAA,IACzE,CAAA,SAAE;AACA,MAAAJ,kCAAA,CAAiB,OAAA,EAAQ;AAAA,IAC3B;AAAA,EACF;AACF,CAAC;AAEM,IAAM,0CAA0CC,6BAAA,CAAY;AAAA,EACjE,MAAA,EAAQ,MAAA;AAAA,EACR,IAAA,EAAM,uCAAA;AAAA,EACN,YAAA,EAAc,MAAA;AAAA,EACd,eAAA,EAAiBI,oCAAA;AAAA,EACjB,gBAAA,EAAkBc,6BAAA;AAAA,EAClB,UAAA,EAAYU,8CAAA;AAAA,EACZ,cAAA,EAAgBL,+CAAA;AAAA,EAChB,OAAA,EAAS,8BAAA;AAAA,EACT,WAAA,EAAa,uEAAA;AAAA,EACb,IAAA,EAAM,CAAC,eAAe,CAAA;AAAA,EACtB,YAAA,EAAc,IAAA;AAAA,EACd,OAAA,EAAS,OAAM,GAAA,KAAO;AACpB,IAAA,MAAM,EAAE,MAAA,EAAQ,QAAA,EAAU,KAAA,EAAO,IAAA,EAAM,gBAAe,GAAI,GAAA;AAC1D,IAAA,MAAM,MAAA,GAAS,OAAO,SAAA,EAAU;AAChC,IAAA,IAAI;AACF,MAAA,MAAM,8BAA8B,MAAM,CAAA;AAE1C,MAAA,IAAI,QAAA,IAAY,CAACxB,kCAAA,CAAiB,sBAAA,CAAuB,QAAQ,CAAA,EAAG;AAClE,QAAA,MAAM,IAAIO,gCAAc,GAAA,EAAK,EAAE,SAAS,CAAA,8BAAA,EAAiC,QAAQ,IAAI,CAAA;AAAA,MACvF;AAEA,MAAA,MAAA,CAAO,KAAK,8CAAA,EAAgD,EAAE,QAAA,EAAU,KAAA,EAAO,MAAM,CAAA;AAErF,MAAA,OAAO,MAAgBuB,8CAA4B,OAAA,CAAQ;AAAA,QACzD,GAAG,GAAA;AAAA,QACH,UAAA,EAAY,QAAA;AAAA,QACZ;AAAA,OACD,CAAA;AAAA,IACH,SAAS,KAAA,EAAO;AACd,MAAA,MAAA,CAAO,KAAA,CAAM,oDAAA,EAAsD,EAAE,KAAA,EAAO,UAAU,CAAA;AACtF,MAAA,OAAO1B,6BAAA,CAAY,OAAO,qCAAqC,CAAA;AAAA,IACjE,CAAA,SAAE;AACA,MAAAJ,kCAAA,CAAiB,OAAA,EAAQ;AAAA,IAC3B;AAAA,EACF;AACF,CAAC;AASM,IAAM,4CAA4CC,6BAAA,CAAY;AAAA,EACnE,MAAA,EAAQ,MAAA;AAAA,EACR,IAAA,EAAM,yCAAA;AAAA,EACN,YAAA,EAAc,MAAA;AAAA,EACd,eAAA,EAAiBI,oCAAA;AAAA,EACjB,gBAAA,EAAkBc,6BAAA;AAAA,EAClB,UAAA,EAAYU,8CAAA;AAAA,EACZ,cAAA,EAAgBZ,iDAAA;AAAA,EAChB,OAAA,EAAS,+BAAA;AAAA,EACT,WAAA,EACE,kKAAA;AAAA,EACF,IAAA,EAAM,CAAC,eAAe,CAAA;AAAA,EACtB,YAAA,EAAc,IAAA;AAAA,EACd,OAAA,EAAS,OAAM,GAAA,KAAO;AACpB,IAAA,MAAM,EAAE,MAAA,EAAQ,QAAA,EAAU,KAAA,EAAO,IAAA,EAAM,gBAAe,GAAI,GAAA;AAC1D,IAAA,MAAM,MAAA,GAAS,OAAO,SAAA,EAAU;AAChC,IAAA,IAAI;AACF,MAAA,MAAM,8BAA8B,MAAM,CAAA;AAE1C,MAAA,IAAI,QAAA,IAAY,CAACjB,kCAAA,CAAiB,sBAAA,CAAuB,QAAQ,CAAA,EAAG;AAClE,QAAA,MAAM,IAAIO,gCAAc,GAAA,EAAK,EAAE,SAAS,CAAA,8BAAA,EAAiC,QAAQ,IAAI,CAAA;AAAA,MACvF;AAEA,MAAA,MAAA,CAAO,KAAK,+CAAA,EAAiD,EAAE,QAAA,EAAU,KAAA,EAAO,MAAM,CAAA;AAEtF,MAAA,OAAO,MAAgBwB,gDAA8B,OAAA,CAAQ;AAAA,QAC3D,GAAG,GAAA;AAAA,QACH,UAAA,EAAY,QAAA;AAAA,QACZ;AAAA,OACD,CAAA;AAAA,IACH,SAAS,KAAA,EAAO;AACd,MAAA,MAAA,CAAO,KAAA,CAAM,qDAAA,EAAuD,EAAE,KAAA,EAAO,UAAU,CAAA;AACvF,MAAA,OAAO3B,6BAAA,CAAY,OAAO,qCAAqC,CAAA;AAAA,IACjE,CAAA,SAAE;AACA,MAAAJ,kCAAA,CAAiB,OAAA,EAAQ;AAAA,IAC3B;AAAA,EACF;AACF,CAAC;AAEM,IAAM,oCAAoCC,6BAAA,CAAY;AAAA,EAC3D,MAAA,EAAQ,MAAA;AAAA,EACR,IAAA,EAAM,iCAAA;AAAA,EACN,YAAA,EAAc,MAAA;AAAA,EACd,eAAA,EAAiBI,oCAAA;AAAA,EACjB,gBAAA,EAAkBc,6BAAA;AAAA,EAClB,UAAA,EAAYU,8CAAA;AAAA,EACZ,cAAA,EAAgBH,+CAAA;AAAA,EAChB,OAAA,EAAS,eAAA;AAAA,EACT,WAAA,EAAa,2DAAA;AAAA,EACb,IAAA,EAAM,CAAC,eAAe,CAAA;AAAA,EACtB,YAAA,EAAc,IAAA;AAAA,EACd,OAAA,EAAS,OAAM,GAAA,KAAO;AACpB,IAAA,MAAM,EAAE,MAAA,EAAQ,QAAA,EAAU,KAAA,EAAO,IAAA,EAAM,gBAAe,GAAI,GAAA;AAC1D,IAAA,MAAM,MAAA,GAAS,OAAO,SAAA,EAAU;AAChC,IAAA,IAAI;AACF,MAAA,MAAM,8BAA8B,MAAM,CAAA;AAE1C,MAAA,IAAI,QAAA,IAAY,CAAC1B,kCAAA,CAAiB,sBAAA,CAAuB,QAAQ,CAAA,EAAG;AAClE,QAAA,MAAM,IAAIO,gCAAc,GAAA,EAAK,EAAE,SAAS,CAAA,8BAAA,EAAiC,QAAQ,IAAI,CAAA;AAAA,MACvF;AAEA,MAAA,MAAA,CAAO,KAAK,+BAAA,EAAiC,EAAE,QAAA,EAAU,KAAA,EAAO,MAAM,CAAA;AAEtE,MAAA,OAAO,MAAgByB,wCAAsB,OAAA,CAAQ;AAAA,QACnD,GAAG,GAAA;AAAA,QACH,UAAA,EAAY,QAAA;AAAA,QACZ;AAAA,OACD,CAAA;AAAA,IACH,SAAS,KAAA,EAAO;AACd,MAAA,MAAA,CAAO,KAAA,CAAM,qCAAA,EAAuC,EAAE,KAAA,EAAO,UAAU,CAAA;AACvE,MAAA,OAAO5B,6BAAA,CAAY,OAAO,qCAAqC,CAAA;AAAA,IACjE,CAAA,SAAE;AACA,MAAAJ,kCAAA,CAAiB,OAAA,EAAQ;AAAA,IAC3B;AAAA,EACF;AACF,CAAC;AAEM,IAAM,2CAA2CC,6BAAA,CAAY;AAAA,EAClE,MAAA,EAAQ,MAAA;AAAA,EACR,IAAA,EAAM,wCAAA;AAAA,EACN,YAAA,EAAc,QAAA;AAAA,EACd,eAAA,EAAiBI,oCAAA;AAAA,EACjB,gBAAA,EAAkBc,6BAAA;AAAA,EAClB,UAAA,EAAYU,8CAAA;AAAA,EACZ,cAAA,EAAgBR,sCAAA;AAAA,EAChB,OAAA,EAAS,sBAAA;AAAA,EACT,WAAA,EAAa,sEAAA;AAAA,EACb,IAAA,EAAM,CAAC,eAAe,CAAA;AAAA,EACtB,YAAA,EAAc,IAAA;AAAA,EACd,OAAA,EAAS,OAAM,GAAA,KAAO;AACpB,IAAA,MAAM,EAAE,MAAA,EAAQ,QAAA,EAAU,KAAA,EAAO,IAAA,EAAM,gBAAe,GAAI,GAAA;AAC1D,IAAA,MAAM,MAAA,GAAS,OAAO,SAAA,EAAU;AAChC,IAAA,IAAI;AACF,MAAA,MAAM,8BAA8B,MAAM,CAAA;AAE1C,MAAA,IAAI,QAAA,IAAY,CAACrB,kCAAA,CAAiB,sBAAA,CAAuB,QAAQ,CAAA,EAAG;AAClE,QAAA,MAAM,IAAIO,gCAAc,GAAA,EAAK,EAAE,SAAS,CAAA,8BAAA,EAAiC,QAAQ,IAAI,CAAA;AAAA,MACvF;AAEA,MAAA,MAAA,CAAO,KAAK,sCAAA,EAAwC,EAAE,QAAA,EAAU,KAAA,EAAO,MAAM,CAAA;AAE7E,MAAA,OAAO,MAAgB0B,+CAA6B,OAAA,CAAQ;AAAA,QAC1D,GAAG,GAAA;AAAA,QACH,UAAA,EAAY,QAAA;AAAA,QACZ;AAAA,OACD,CAAA;AAAA,IACH,SAAS,KAAA,EAAO;AACd,MAAA,MAAA,CAAO,KAAA,CAAM,4CAAA,EAA8C,EAAE,KAAA,EAAO,UAAU,CAAA;AAC9E,MAAA,OAAO7B,6BAAA,CAAY,OAAO,4CAA4C,CAAA;AAAA,IACxE,CAAA,SAAE;AACA,MAAAJ,kCAAA,CAAiB,OAAA,EAAQ;AAAA,IAC3B;AAAA,EACF;AACF,CAAC;AAEM,IAAM,wCAAwCC,6BAAA,CAAY;AAAA,EAC/D,MAAA,EAAQ,MAAA;AAAA,EACR,IAAA,EAAM,6CAAA;AAAA,EACN,YAAA,EAAc,MAAA;AAAA,EACd,eAAA,EAAiBW,qCAAA;AAAA,EACjB,cAAA,EAAgBc,+CAAA;AAAA,EAChB,OAAA,EAAS,mBAAA;AAAA,EACT,WAAA,EAAa,yCAAA;AAAA,EACb,IAAA,EAAM,CAAC,eAAe,CAAA;AAAA,EACtB,YAAA,EAAc,IAAA;AAAA,EACd,OAAA,EAAS,OAAM,GAAA,KAAO;AACpB,IAAA,MAAM,EAAE,MAAA,EAAQ,QAAA,EAAU,KAAA,EAAM,GAAI,GAAA;AACpC,IAAA,MAAM,MAAA,GAAS,OAAO,SAAA,EAAU;AAChC,IAAA,IAAI;AACF,MAAA,MAAM,8BAA8B,MAAM,CAAA;AAE1C,MAAA,IAAI,QAAA,IAAY,CAAC1B,kCAAA,CAAiB,sBAAA,CAAuB,QAAQ,CAAA,EAAG;AAClE,QAAA,MAAM,IAAIO,gCAAc,GAAA,EAAK,EAAE,SAAS,CAAA,8BAAA,EAAiC,QAAQ,IAAI,CAAA;AAAA,MACvF;AAEA,MAAA,MAAA,CAAO,IAAA,CAAK,qCAAA,EAAuC,EAAE,QAAA,EAAU,OAAO,CAAA;AAEtE,MAAA,OAAO,MAAgB2B,4CAA0B,OAAA,CAAQ;AAAA,QACvD,GAAG,GAAA;AAAA,QACH,UAAA,EAAY;AAAA,OACb,CAAA;AAAA,IACH,SAAS,KAAA,EAAO;AACd,MAAA,MAAA,CAAO,KAAA,CAAM,2CAAA,EAA6C,EAAE,KAAA,EAAO,UAAU,CAAA;AAC7E,MAAA,OAAO9B,6BAAA,CAAY,OAAO,2CAA2C,CAAA;AAAA,IACvE,CAAA,SAAE;AACA,MAAAJ,kCAAA,CAAiB,OAAA,EAAQ;AAAA,IAC3B;AAAA,EACF;AACF,CAAC;AAGM,IAAM,2CAA2CC,6BAAA,CAAY;AAAA,EAClE,MAAA,EAAQ,MAAA;AAAA,EACR,IAAA,EAAM,wCAAA;AAAA,EACN,YAAA,EAAc,QAAA;AAAA,EACd,eAAA,EAAiBI,oCAAA;AAAA,EACjB,gBAAA,EAAkBc,6BAAA;AAAA,EAClB,UAAA,EAAYgB,oDAAA;AAAA,EACZ,cAAA,EAAgBd,sCAAA;AAAA,EAChB,OAAA,EAAS,6DAAA;AAAA,EACT,WAAA,EACE,4GAAA;AAAA,EACF,IAAA,EAAM,CAAC,eAAA,EAAiB,QAAQ,CAAA;AAAA,EAChC,YAAA,EAAc,IAAA;AAAA,EACd,OAAA,EAAS,OAAM,GAAA,KAAO;AACpB,IAAA,MAAM,EAAE,MAAA,EAAQ,QAAA,EAAU,KAAA,EAAO,gBAAe,GAAI,GAAA;AACpD,IAAA,MAAM,MAAA,GAAS,OAAO,SAAA,EAAU;AAChC,IAAA,IAAI;AACF,MAAA,MAAM,8BAA8B,MAAM,CAAA;AAE1C,MAAA,IAAI,QAAA,IAAY,CAACrB,kCAAA,CAAiB,sBAAA,CAAuB,QAAQ,CAAA,EAAG;AAClE,QAAA,MAAM,IAAIO,gCAAc,GAAA,EAAK,EAAE,SAAS,CAAA,8BAAA,EAAiC,QAAQ,IAAI,CAAA;AAAA,MACvF;AAEA,MAAA,MAAA,CAAO,IAAA,CAAK,yCAAA,EAA2C,EAAE,QAAA,EAAU,OAAO,CAAA;AAE1E,MAAA,OAAO,MAAgB6B,+CAA6B,OAAA,CAAQ;AAAA,QAC1D,GAAG,GAAA;AAAA,QACH,UAAA,EAAY,QAAA;AAAA,QACZ;AAAA,OACD,CAAA;AAAA,IACH,SAAS,KAAA,EAAO;AACd,MAAA,MAAA,CAAO,KAAA,CAAM,+CAAA,EAAiD,EAAE,KAAA,EAAO,UAAU,CAAA;AACjF,MAAA,OAAOhC,6BAAA,CAAY,OAAO,sCAAsC,CAAA;AAAA,IAClE,CAAA,SAAE;AACA,MAAAJ,kCAAA,CAAiB,OAAA,EAAQ;AAAA,IAC3B;AAAA,EACF;AACF,CAAC;AAEM,IAAM,mDAAmDC,6BAAA,CAAY;AAAA,EAC1E,MAAA,EAAQ,MAAA;AAAA,EACR,IAAA,EAAM,gDAAA;AAAA,EACN,YAAA,EAAc,QAAA;AAAA,EACd,eAAA,EAAiBI,oCAAA;AAAA,EACjB,gBAAA,EAAkBc,6BAAA;AAAA,EAClB,cAAA,EAAgBE,sCAAA;AAAA,EAChB,OAAA,EAAS,qEAAA;AAAA,EACT,WAAA,EACE,0GAAA;AAAA,EACF,IAAA,EAAM,CAAC,eAAA,EAAiB,QAAQ,CAAA;AAAA,EAChC,YAAA,EAAc,IAAA;AAAA,EACd,OAAA,EAAS,OAAM,GAAA,KAAO;AACpB,IAAA,MAAM,EAAE,MAAA,EAAQ,QAAA,EAAU,KAAA,EAAM,GAAI,GAAA;AACpC,IAAA,MAAM,MAAA,GAAS,OAAO,SAAA,EAAU;AAChC,IAAA,IAAI;AACF,MAAA,MAAM,8BAA8B,MAAM,CAAA;AAE1C,MAAA,IAAI,QAAA,IAAY,CAACrB,kCAAA,CAAiB,sBAAA,CAAuB,QAAQ,CAAA,EAAG;AAClE,QAAA,MAAM,IAAIO,gCAAc,GAAA,EAAK,EAAE,SAAS,CAAA,8BAAA,EAAiC,QAAQ,IAAI,CAAA;AAAA,MACvF;AAEA,MAAA,MAAA,CAAO,IAAA,CAAK,gDAAA,EAAkD,EAAE,QAAA,EAAU,OAAO,CAAA;AAEjF,MAAA,OAAO,MAAgB8B,uDAAqC,OAAA,CAAQ;AAAA,QAClE,GAAG,GAAA;AAAA,QACH,UAAA,EAAY;AAAA,OACb,CAAA;AAAA,IACH,SAAS,KAAA,EAAO;AACd,MAAA,MAAA,CAAO,KAAA,CAAM,sDAAA,EAAwD,EAAE,KAAA,EAAO,UAAU,CAAA;AACxF,MAAA,OAAOjC,6BAAA,CAAY,OAAO,6CAA6C,CAAA;AAAA,IACzE,CAAA,SAAE;AACA,MAAAJ,kCAAA,CAAiB,OAAA,EAAQ;AAAA,IAC3B;AAAA,EACF;AACF,CAAC","file":"chunk-JGWDTZ4A.cjs","sourcesContent":["import type { agentBuilderWorkflows as agentBuilderWorkflowsType } from '@mastra/agent-builder';\nimport { HTTPException } from '../http-exception';\nimport {\n  actionIdPathParams,\n  actionRunPathParams,\n  createWorkflowRunResponseSchema,\n  listWorkflowRunsQuerySchema,\n  resumeAgentBuilderBodySchema,\n  streamAgentBuilderBodySchema,\n  startAsyncAgentBuilderBodySchema,\n  workflowExecutionResultSchema,\n  workflowControlResponseSchema,\n  workflowRunsResponseSchema,\n  workflowInfoSchema,\n  listWorkflowsResponseSchema,\n  streamLegacyAgentBuilderBodySchema,\n  workflowRunResultSchema,\n  workflowRunResultQuerySchema,\n} from '../schemas/agent-builder';\nimport { streamResponseSchema } from '../schemas/agents';\nimport { optionalRunIdSchema, runIdSchema } from '../schemas/common';\nimport { createRoute } from '../server-adapter/routes/route-builder';\nimport { WorkflowRegistry } from '../utils';\nimport { handleError } from './error';\nimport * as workflows from './workflows';\n\ntype AgentBuilderWorkflows = typeof agentBuilderWorkflowsType;\n\nlet agentBuilderWorkflowsPromise: Promise<AgentBuilderWorkflows> | undefined;\n\nasync function loadAgentBuilderWorkflows(): Promise<AgentBuilderWorkflows> {\n  agentBuilderWorkflowsPromise ??= import('@mastra/agent-builder').then(mod => mod.agentBuilderWorkflows);\n  return agentBuilderWorkflowsPromise;\n}\n\nasync function registerAgentBuilderWorkflows(\n  mastra: Parameters<typeof WorkflowRegistry.registerTemporaryWorkflows>[1],\n) {\n  const agentBuilderWorkflows = await loadAgentBuilderWorkflows();\n  WorkflowRegistry.registerTemporaryWorkflows(agentBuilderWorkflows, mastra);\n  return agentBuilderWorkflows;\n}\n\n// ============================================================================\n// Route Definitions (handlers call workflow route handlers with transformed parameters)\n// ============================================================================\n\nexport const LIST_AGENT_BUILDER_ACTIONS_ROUTE = createRoute({\n  method: 'GET',\n  path: '/agent-builder',\n  responseType: 'json',\n  responseSchema: listWorkflowsResponseSchema,\n  summary: 'List agent-builder actions',\n  description: 'Returns a list of all available agent-builder actions',\n  tags: ['Agent Builder'],\n  requiresAuth: true,\n  handler: async ctx => {\n    const { mastra } = ctx;\n    const logger = mastra.getLogger();\n    try {\n      await registerAgentBuilderWorkflows(mastra);\n      logger.info('Listing agent builder actions');\n\n      // Call workflow list handler\n      return await workflows.LIST_WORKFLOWS_ROUTE.handler(ctx);\n    } catch (error) {\n      logger.error('Error listing agent builder actions', { error });\n      return handleError(error, 'Error getting agent builder workflows');\n    } finally {\n      WorkflowRegistry.cleanup();\n    }\n  },\n});\n\nexport const GET_AGENT_BUILDER_ACTION_BY_ID_ROUTE = createRoute({\n  method: 'GET',\n  path: '/agent-builder/:actionId',\n  responseType: 'json',\n  pathParamSchema: actionIdPathParams,\n  responseSchema: workflowInfoSchema,\n  summary: 'Get action by ID',\n  description: 'Returns details for a specific agent-builder action',\n  tags: ['Agent Builder'],\n  requiresAuth: true,\n  handler: async ctx => {\n    const { mastra, actionId } = ctx;\n    const logger = mastra.getLogger();\n    try {\n      const agentBuilderWorkflows = await registerAgentBuilderWorkflows(mastra);\n\n      if (actionId && !WorkflowRegistry.isAgentBuilderWorkflow(actionId)) {\n        throw new HTTPException(400, {\n          message: `Invalid agent-builder action: ${actionId}. Valid actions are: ${Object.keys(agentBuilderWorkflows).join(', ')}`,\n        });\n      }\n\n      logger.info('Getting agent builder action by ID', { actionId });\n\n      return await workflows.GET_WORKFLOW_BY_ID_ROUTE.handler({ ...ctx, workflowId: actionId });\n    } catch (error) {\n      logger.error('Error getting agent builder action by ID', { error, actionId });\n      return handleError(error, 'Error getting agent builder action');\n    } finally {\n      WorkflowRegistry.cleanup();\n    }\n  },\n});\n\nexport const LIST_AGENT_BUILDER_ACTION_RUNS_ROUTE = createRoute({\n  method: 'GET',\n  path: '/agent-builder/:actionId/runs',\n  responseType: 'json',\n  pathParamSchema: actionIdPathParams,\n  queryParamSchema: listWorkflowRunsQuerySchema,\n  responseSchema: workflowRunsResponseSchema,\n  summary: 'List action runs',\n  description: 'Returns a paginated list of execution runs for the specified action',\n  tags: ['Agent Builder'],\n  requiresAuth: true,\n  handler: async ctx => {\n    const { mastra, actionId } = ctx;\n    const logger = mastra.getLogger();\n    try {\n      await registerAgentBuilderWorkflows(mastra);\n\n      if (actionId && !WorkflowRegistry.isAgentBuilderWorkflow(actionId)) {\n        throw new HTTPException(400, { message: `Invalid agent-builder action: ${actionId}` });\n      }\n\n      logger.info('Listing agent builder action runs', { actionId });\n\n      return await workflows.LIST_WORKFLOW_RUNS_ROUTE.handler({\n        ...ctx,\n        workflowId: actionId,\n      });\n    } catch (error) {\n      logger.error('Error listing agent builder action runs', { error, actionId });\n      return handleError(error, 'Error getting agent builder action runs');\n    } finally {\n      WorkflowRegistry.cleanup();\n    }\n  },\n});\n\nexport const GET_AGENT_BUILDER_ACTION_RUN_BY_ID_ROUTE = createRoute({\n  method: 'GET',\n  path: '/agent-builder/:actionId/runs/:runId',\n  responseType: 'json',\n  pathParamSchema: actionRunPathParams,\n  queryParamSchema: workflowRunResultQuerySchema,\n  responseSchema: workflowRunResultSchema,\n  summary: 'Get action run by ID',\n  description:\n    'Returns details for a specific action run with metadata and processed execution state. Use the fields query parameter to reduce payload size.',\n  tags: ['Agent Builder'],\n  requiresAuth: true,\n  handler: async ctx => {\n    const { mastra, actionId, runId } = ctx;\n    const logger = mastra.getLogger();\n    try {\n      await registerAgentBuilderWorkflows(mastra);\n\n      if (actionId && !WorkflowRegistry.isAgentBuilderWorkflow(actionId)) {\n        throw new HTTPException(400, { message: `Invalid agent-builder action: ${actionId}` });\n      }\n\n      logger.info('Getting agent builder action run by ID', { actionId, runId });\n\n      return await workflows.GET_WORKFLOW_RUN_BY_ID_ROUTE.handler({\n        ...ctx,\n        workflowId: actionId,\n      });\n    } catch (error) {\n      logger.error('Error getting agent builder action run', { error, actionId, runId });\n      return handleError(error, 'Error getting agent builder action run');\n    } finally {\n      WorkflowRegistry.cleanup();\n    }\n  },\n});\n\nexport const CREATE_AGENT_BUILDER_ACTION_RUN_ROUTE = createRoute({\n  method: 'POST',\n  path: '/agent-builder/:actionId/create-run',\n  responseType: 'json',\n  pathParamSchema: actionIdPathParams,\n  queryParamSchema: optionalRunIdSchema,\n  responseSchema: createWorkflowRunResponseSchema,\n  summary: 'Create action run',\n  description: 'Creates a new action execution instance with an optional custom run ID',\n  tags: ['Agent Builder'],\n  requiresAuth: true,\n  handler: async ctx => {\n    const { mastra, actionId, runId } = ctx;\n    const logger = mastra.getLogger();\n    try {\n      await registerAgentBuilderWorkflows(mastra);\n\n      if (actionId && !WorkflowRegistry.isAgentBuilderWorkflow(actionId)) {\n        throw new HTTPException(400, { message: `Invalid agent-builder action: ${actionId}` });\n      }\n\n      logger.info('Creating agent builder action run', { actionId, runId });\n\n      return await workflows.CREATE_WORKFLOW_RUN_ROUTE.handler({\n        ...ctx,\n        workflowId: actionId,\n      });\n    } catch (error) {\n      logger.error('Error creating agent builder action run', { error, actionId });\n      return handleError(error, 'Error creating agent builder action run');\n    } finally {\n      WorkflowRegistry.cleanup();\n    }\n  },\n});\n\nexport const STREAM_AGENT_BUILDER_ACTION_ROUTE = createRoute({\n  method: 'POST',\n  path: '/agent-builder/:actionId/stream',\n  responseType: 'stream',\n  pathParamSchema: actionIdPathParams,\n  queryParamSchema: runIdSchema,\n  bodySchema: streamAgentBuilderBodySchema,\n  responseSchema: streamResponseSchema,\n  summary: 'Stream action execution',\n  description: 'Executes an action and streams the results in real-time',\n  tags: ['Agent Builder'],\n  requiresAuth: true,\n  handler: async ctx => {\n    const { mastra, actionId, runId, requestContext } = ctx;\n    const logger = mastra.getLogger();\n    try {\n      await registerAgentBuilderWorkflows(mastra);\n\n      if (actionId && !WorkflowRegistry.isAgentBuilderWorkflow(actionId)) {\n        throw new HTTPException(400, { message: `Invalid agent-builder action: ${actionId}` });\n      }\n\n      logger.info('Streaming agent builder action', { actionId, runId });\n\n      return await workflows.STREAM_WORKFLOW_ROUTE.handler({\n        ...ctx,\n        workflowId: actionId,\n        requestContext,\n      });\n    } catch (error) {\n      logger.error('Error streaming agent builder action', { error, actionId });\n      return handleError(error, 'Error streaming agent builder action');\n    } finally {\n      WorkflowRegistry.cleanup();\n    }\n  },\n});\n\nexport const START_ASYNC_AGENT_BUILDER_ACTION_ROUTE = createRoute({\n  method: 'POST',\n  path: '/agent-builder/:actionId/start-async',\n  responseType: 'json',\n  pathParamSchema: actionIdPathParams,\n  queryParamSchema: optionalRunIdSchema,\n  bodySchema: startAsyncAgentBuilderBodySchema,\n  responseSchema: workflowExecutionResultSchema,\n  summary: 'Start action asynchronously',\n  description: 'Starts an action execution asynchronously without streaming results',\n  tags: ['Agent Builder'],\n  requiresAuth: true,\n  handler: async ctx => {\n    const { mastra, actionId, runId, requestContext } = ctx;\n    const logger = mastra.getLogger();\n    try {\n      await registerAgentBuilderWorkflows(mastra);\n\n      if (actionId && !WorkflowRegistry.isAgentBuilderWorkflow(actionId)) {\n        throw new HTTPException(400, { message: `Invalid agent-builder action: ${actionId}` });\n      }\n\n      logger.info('Starting agent builder action asynchronously', { actionId, runId });\n\n      return await workflows.START_ASYNC_WORKFLOW_ROUTE.handler({\n        ...ctx,\n        workflowId: actionId,\n        requestContext,\n      });\n    } catch (error) {\n      logger.error('Error starting agent builder action asynchronously', { error, actionId });\n      return handleError(error, 'Error starting agent builder action');\n    } finally {\n      WorkflowRegistry.cleanup();\n    }\n  },\n});\n\nexport const START_AGENT_BUILDER_ACTION_RUN_ROUTE = createRoute({\n  method: 'POST',\n  path: '/agent-builder/:actionId/start',\n  responseType: 'json',\n  pathParamSchema: actionIdPathParams,\n  queryParamSchema: runIdSchema,\n  bodySchema: startAsyncAgentBuilderBodySchema,\n  responseSchema: workflowControlResponseSchema,\n  summary: 'Start specific action run',\n  description: 'Starts execution of a specific action run by ID',\n  tags: ['Agent Builder'],\n  requiresAuth: true,\n  handler: async ctx => {\n    const { mastra, actionId, runId, requestContext } = ctx;\n    const logger = mastra.getLogger();\n    try {\n      await registerAgentBuilderWorkflows(mastra);\n\n      if (actionId && !WorkflowRegistry.isAgentBuilderWorkflow(actionId)) {\n        throw new HTTPException(400, { message: `Invalid agent-builder action: ${actionId}` });\n      }\n\n      logger.info('Starting specific agent builder action run', { actionId, runId });\n\n      return await workflows.START_WORKFLOW_RUN_ROUTE.handler({\n        ...ctx,\n        workflowId: actionId,\n        requestContext,\n      });\n    } catch (error) {\n      logger.error('Error starting agent builder action run', { error, actionId });\n      return handleError(error, 'Error starting agent builder action run');\n    } finally {\n      WorkflowRegistry.cleanup();\n    }\n  },\n});\n\nexport const OBSERVE_STREAM_AGENT_BUILDER_ACTION_ROUTE = createRoute({\n  method: 'POST',\n  path: '/agent-builder/:actionId/observe',\n  responseType: 'stream',\n  pathParamSchema: actionIdPathParams,\n  queryParamSchema: runIdSchema,\n  responseSchema: streamResponseSchema,\n  summary: 'Observe action stream',\n  description: 'Observes and streams updates from an already running action execution',\n  tags: ['Agent Builder'],\n  requiresAuth: true,\n  handler: async ctx => {\n    const { mastra, actionId, runId } = ctx;\n    const logger = mastra.getLogger();\n    try {\n      await registerAgentBuilderWorkflows(mastra);\n\n      if (actionId && !WorkflowRegistry.isAgentBuilderWorkflow(actionId)) {\n        throw new HTTPException(400, { message: `Invalid agent-builder action: ${actionId}` });\n      }\n\n      logger.info('Observing agent builder action stream', { actionId, runId });\n\n      return await workflows.OBSERVE_STREAM_WORKFLOW_ROUTE.handler({\n        ...ctx,\n        workflowId: actionId,\n      });\n    } catch (error) {\n      logger.error('Error observing agent builder action stream', { error, actionId });\n      return handleError(error, 'Error observing agent builder action stream');\n    } finally {\n      WorkflowRegistry.cleanup();\n    }\n  },\n});\n\nexport const RESUME_ASYNC_AGENT_BUILDER_ACTION_ROUTE = createRoute({\n  method: 'POST',\n  path: '/agent-builder/:actionId/resume-async',\n  responseType: 'json',\n  pathParamSchema: actionIdPathParams,\n  queryParamSchema: runIdSchema,\n  bodySchema: resumeAgentBuilderBodySchema,\n  responseSchema: workflowExecutionResultSchema,\n  summary: 'Resume action asynchronously',\n  description: 'Resumes a suspended action execution asynchronously without streaming',\n  tags: ['Agent Builder'],\n  requiresAuth: true,\n  handler: async ctx => {\n    const { mastra, actionId, runId, step, requestContext } = ctx;\n    const logger = mastra.getLogger();\n    try {\n      await registerAgentBuilderWorkflows(mastra);\n\n      if (actionId && !WorkflowRegistry.isAgentBuilderWorkflow(actionId)) {\n        throw new HTTPException(400, { message: `Invalid agent-builder action: ${actionId}` });\n      }\n\n      logger.info('Resuming agent builder action asynchronously', { actionId, runId, step });\n\n      return await workflows.RESUME_ASYNC_WORKFLOW_ROUTE.handler({\n        ...ctx,\n        workflowId: actionId,\n        requestContext,\n      });\n    } catch (error) {\n      logger.error('Error resuming agent builder action asynchronously', { error, actionId });\n      return handleError(error, 'Error resuming agent builder action');\n    } finally {\n      WorkflowRegistry.cleanup();\n    }\n  },\n});\n\n/**\n * Fire-and-forget resume for agent-builder actions: returns immediately with the runId without\n * waiting for completion. Delegates to the workflows `resume-no-wait` route.\n *\n * TODO(v2): fold this behavior into the `resume-async` route in Mastra v2 and remove this route.\n * Kept separate in v1 to avoid breaking the existing `resume-async` response contract.\n */\nexport const RESUME_NO_WAIT_AGENT_BUILDER_ACTION_ROUTE = createRoute({\n  method: 'POST',\n  path: '/agent-builder/:actionId/resume-no-wait',\n  responseType: 'json',\n  pathParamSchema: actionIdPathParams,\n  queryParamSchema: runIdSchema,\n  bodySchema: resumeAgentBuilderBodySchema,\n  responseSchema: createWorkflowRunResponseSchema,\n  summary: 'Resume action without waiting',\n  description:\n    'Resumes a suspended action execution without waiting (fire-and-forget) and returns immediately with the runId. The action continues executing in the background.',\n  tags: ['Agent Builder'],\n  requiresAuth: true,\n  handler: async ctx => {\n    const { mastra, actionId, runId, step, requestContext } = ctx;\n    const logger = mastra.getLogger();\n    try {\n      await registerAgentBuilderWorkflows(mastra);\n\n      if (actionId && !WorkflowRegistry.isAgentBuilderWorkflow(actionId)) {\n        throw new HTTPException(400, { message: `Invalid agent-builder action: ${actionId}` });\n      }\n\n      logger.info('Resuming agent builder action without waiting', { actionId, runId, step });\n\n      return await workflows.RESUME_NO_WAIT_WORKFLOW_ROUTE.handler({\n        ...ctx,\n        workflowId: actionId,\n        requestContext,\n      });\n    } catch (error) {\n      logger.error('Error resuming agent builder action without waiting', { error, actionId });\n      return handleError(error, 'Error resuming agent builder action');\n    } finally {\n      WorkflowRegistry.cleanup();\n    }\n  },\n});\n\nexport const RESUME_AGENT_BUILDER_ACTION_ROUTE = createRoute({\n  method: 'POST',\n  path: '/agent-builder/:actionId/resume',\n  responseType: 'json',\n  pathParamSchema: actionIdPathParams,\n  queryParamSchema: runIdSchema,\n  bodySchema: resumeAgentBuilderBodySchema,\n  responseSchema: workflowControlResponseSchema,\n  summary: 'Resume action',\n  description: 'Resumes a suspended action execution from a specific step',\n  tags: ['Agent Builder'],\n  requiresAuth: true,\n  handler: async ctx => {\n    const { mastra, actionId, runId, step, requestContext } = ctx;\n    const logger = mastra.getLogger();\n    try {\n      await registerAgentBuilderWorkflows(mastra);\n\n      if (actionId && !WorkflowRegistry.isAgentBuilderWorkflow(actionId)) {\n        throw new HTTPException(400, { message: `Invalid agent-builder action: ${actionId}` });\n      }\n\n      logger.info('Resuming agent builder action', { actionId, runId, step });\n\n      return await workflows.RESUME_WORKFLOW_ROUTE.handler({\n        ...ctx,\n        workflowId: actionId,\n        requestContext,\n      });\n    } catch (error) {\n      logger.error('Error resuming agent builder action', { error, actionId });\n      return handleError(error, 'Error resuming agent builder action');\n    } finally {\n      WorkflowRegistry.cleanup();\n    }\n  },\n});\n\nexport const RESUME_STREAM_AGENT_BUILDER_ACTION_ROUTE = createRoute({\n  method: 'POST',\n  path: '/agent-builder/:actionId/resume-stream',\n  responseType: 'stream',\n  pathParamSchema: actionIdPathParams,\n  queryParamSchema: runIdSchema,\n  bodySchema: resumeAgentBuilderBodySchema,\n  responseSchema: streamResponseSchema,\n  summary: 'Resume action stream',\n  description: 'Resumes a suspended action execution and continues streaming results',\n  tags: ['Agent Builder'],\n  requiresAuth: true,\n  handler: async ctx => {\n    const { mastra, actionId, runId, step, requestContext } = ctx;\n    const logger = mastra.getLogger();\n    try {\n      await registerAgentBuilderWorkflows(mastra);\n\n      if (actionId && !WorkflowRegistry.isAgentBuilderWorkflow(actionId)) {\n        throw new HTTPException(400, { message: `Invalid agent-builder action: ${actionId}` });\n      }\n\n      logger.info('Resuming agent builder action stream', { actionId, runId, step });\n\n      return await workflows.RESUME_STREAM_WORKFLOW_ROUTE.handler({\n        ...ctx,\n        workflowId: actionId,\n        requestContext,\n      });\n    } catch (error) {\n      logger.error('Error resuming agent builder action stream', { error, actionId });\n      return handleError(error, 'Error resuming agent builder action stream');\n    } finally {\n      WorkflowRegistry.cleanup();\n    }\n  },\n});\n\nexport const CANCEL_AGENT_BUILDER_ACTION_RUN_ROUTE = createRoute({\n  method: 'POST',\n  path: '/agent-builder/:actionId/runs/:runId/cancel',\n  responseType: 'json',\n  pathParamSchema: actionRunPathParams,\n  responseSchema: workflowControlResponseSchema,\n  summary: 'Cancel action run',\n  description: 'Cancels an in-progress action execution',\n  tags: ['Agent Builder'],\n  requiresAuth: true,\n  handler: async ctx => {\n    const { mastra, actionId, runId } = ctx;\n    const logger = mastra.getLogger();\n    try {\n      await registerAgentBuilderWorkflows(mastra);\n\n      if (actionId && !WorkflowRegistry.isAgentBuilderWorkflow(actionId)) {\n        throw new HTTPException(400, { message: `Invalid agent-builder action: ${actionId}` });\n      }\n\n      logger.info('Cancelling agent builder action run', { actionId, runId });\n\n      return await workflows.CANCEL_WORKFLOW_RUN_ROUTE.handler({\n        ...ctx,\n        workflowId: actionId,\n      });\n    } catch (error) {\n      logger.error('Error cancelling agent builder action run', { error, actionId });\n      return handleError(error, 'Error cancelling agent builder action run');\n    } finally {\n      WorkflowRegistry.cleanup();\n    }\n  },\n});\n\n// Legacy routes (deprecated)\nexport const STREAM_LEGACY_AGENT_BUILDER_ACTION_ROUTE = createRoute({\n  method: 'POST',\n  path: '/agent-builder/:actionId/stream-legacy',\n  responseType: 'stream',\n  pathParamSchema: actionIdPathParams,\n  queryParamSchema: runIdSchema,\n  bodySchema: streamLegacyAgentBuilderBodySchema,\n  responseSchema: streamResponseSchema,\n  summary: '[DEPRECATED] Stream agent-builder action with legacy format',\n  description:\n    'Legacy endpoint for streaming agent-builder action execution. Use /agent-builder/:actionId/stream instead.',\n  tags: ['Agent Builder', 'Legacy'],\n  requiresAuth: true,\n  handler: async ctx => {\n    const { mastra, actionId, runId, requestContext } = ctx;\n    const logger = mastra.getLogger();\n    try {\n      await registerAgentBuilderWorkflows(mastra);\n\n      if (actionId && !WorkflowRegistry.isAgentBuilderWorkflow(actionId)) {\n        throw new HTTPException(400, { message: `Invalid agent-builder action: ${actionId}` });\n      }\n\n      logger.info('Streaming agent builder action (legacy)', { actionId, runId });\n\n      return await workflows.STREAM_LEGACY_WORKFLOW_ROUTE.handler({\n        ...ctx,\n        workflowId: actionId,\n        requestContext,\n      });\n    } catch (error) {\n      logger.error('Error streaming agent builder action (legacy)', { error, actionId });\n      return handleError(error, 'Error streaming agent builder action');\n    } finally {\n      WorkflowRegistry.cleanup();\n    }\n  },\n});\n\nexport const OBSERVE_STREAM_LEGACY_AGENT_BUILDER_ACTION_ROUTE = createRoute({\n  method: 'POST',\n  path: '/agent-builder/:actionId/observe-stream-legacy',\n  responseType: 'stream',\n  pathParamSchema: actionIdPathParams,\n  queryParamSchema: runIdSchema,\n  responseSchema: streamResponseSchema,\n  summary: '[DEPRECATED] Observe agent-builder action stream with legacy format',\n  description:\n    'Legacy endpoint for observing agent-builder action stream. Use /agent-builder/:actionId/observe instead.',\n  tags: ['Agent Builder', 'Legacy'],\n  requiresAuth: true,\n  handler: async ctx => {\n    const { mastra, actionId, runId } = ctx;\n    const logger = mastra.getLogger();\n    try {\n      await registerAgentBuilderWorkflows(mastra);\n\n      if (actionId && !WorkflowRegistry.isAgentBuilderWorkflow(actionId)) {\n        throw new HTTPException(400, { message: `Invalid agent-builder action: ${actionId}` });\n      }\n\n      logger.info('Observing agent builder action stream (legacy)', { actionId, runId });\n\n      return await workflows.OBSERVE_STREAM_LEGACY_WORKFLOW_ROUTE.handler({\n        ...ctx,\n        workflowId: actionId,\n      });\n    } catch (error) {\n      logger.error('Error observing agent builder action stream (legacy)', { error, actionId });\n      return handleError(error, 'Error observing agent builder action stream');\n    } finally {\n      WorkflowRegistry.cleanup();\n    }\n  },\n});\n"]}