{"version":3,"sources":["../../src/client/index.ts","../../src/client/types.ts","../../src/client/utils.ts","../../src/client/trigger-client.ts"],"sourcesContent":["export * from './types';\nexport * from './trigger-client';\nexport * from './utils';\n","/* eslint-disable @typescript-eslint/no-explicit-any */\n\n/**\n * Action handler function type\n */\nexport interface ActionHandler {\n  (...args: any[]): any | Promise<any>;\n}\n\n/**\n * Action definition\n */\nexport interface Action extends ActionMetadata {\n  handler: ActionHandler;\n}\n\nexport enum ENUM_STATUS {\n  SUCCEEDED = 'succeed',\n  FAILED = 'failed',\n}\n\nexport enum ENUM_PHASE {\n  Trigger = 'trigger',\n  Action = 'action',\n}\n\nexport enum ENUM_ENV {\n  DEV = 'development',\n  PROD = 'production',\n}\n\nexport interface ActionContext {\n  attributes: {\n    trigger: string;\n    triggerID?: string;\n    triggerType?: string;\n    instanceID: string;\n    status?: ENUM_STATUS;\n    phase?: ENUM_PHASE;\n    startAt?: number;\n    endAt?: number;\n    duration_ms?: number;\n  };\n  content?: string; // '{ input: {}, output: {} }'\n}\n\n\nexport type TLogContent = string; // stringified { input, output }\nexport interface ILogAttributes {\n  trigger?: string;\n  trigger_id?: string;\n  trigger_type?: string;\n  instance_id?: string;\n  status?: ENUM_STATUS;\n  phase?: ENUM_PHASE;\n  start_at?: number;\n  end_at?: number;\n  duration_ms?: number;\n}\n\n/**\n * Action metadata (without handler)\n */\nexport interface ActionMetadata {\n  name?: string;\n  path?: string;\n  desc?: string;\n}\n\n/**\n * Logger interface for client SDK\n */\nexport interface Logger {\n  debug(message: string, extra?: any): void;\n  info(message: string, extra?: any): void;\n  warn(message: string, extra?: any): void;\n  error(message: string, extra?: any): void;\n}\n\n/**\n * TriggerClient configuration options\n */\nexport interface TriggerClientOptions {\n  /**\n   * Timeout for action execution (ms)\n   */\n  timeout?: number;\n  imports?: any[];\n}\n\nexport enum ENUM_ERROR {\n  NOT_EXIST = 'NOT_EXIST',\n  TIMEOUT = 'TIMEOUT',\n  PARAM_INVALID = 'PARAM_INVALID',\n  TRY_CATCH = 'TRY_CATCH',\n}\n\nexport interface ILogContentParsed {\n  /** 触发器名称 (例如 'cron-daily') */\n  trigger?: string;\n  /** 触发器定义 ID */\n  trigger_id?: string;\n  /** 触发器类型 (例如 定时任务、记录变更) */\n  trigger_type?: string;\n  /** 执行实例 ID */\n  instance_id?: string;\n  /** 阶段：触发阶段或动作执行阶段 */\n  phase?: ENUM_PHASE;\n  /** 状态：成功或失败 */\n  status?: ENUM_STATUS;\n  /** 执行耗时 (毫秒)。计算逻辑：(endAt - startAt) 或内部计时器 */\n  duration_ms?: number;\n  /** 核心内容 */\n  content?: {\n    /** 动作入参 */\n    input?: any;\n    /** 动作出参 */\n    output?: any;\n  };\n  /** 错误信息，仅在 status 为 failed 时填充，否则为空字符串 */\n  error_message?: string;\n}\n","import { ActionContext, ILogAttributes, TLogContent } from './types';\n\nexport const convertActionContextToReportData = (actionCtx: ActionContext): [TLogContent, ILogAttributes] => {\n  const { attributes, content } = actionCtx;\n  return [\n    content || '',\n    {\n      trigger: attributes?.trigger,\n      trigger_id: attributes?.triggerID,\n      trigger_type: attributes?.triggerType,\n      instance_id: attributes?.instanceID,\n      status: attributes?.status,\n      phase: attributes?.phase,\n      start_at: attributes?.startAt,\n      end_at: attributes?.endAt,\n      duration_ms: attributes?.duration_ms,\n    },\n  ];\n};","/* eslint-disable @typescript-eslint/no-explicit-any */\nimport { Logger } from '@nestjs/common';\nimport {\n  ENUM_STATUS,\n  ENUM_PHASE,\n  type Action,\n  type ActionHandler,\n  type ActionMetadata,\n  ENUM_ERROR,\n  ActionContext,\n  TLogContent,\n  ILogAttributes,\n  ILogContentParsed,\n} from './types';\nimport { convertActionContextToReportData } from './utils';\n\nconst INTERNAL = 'AUTOMATION_INTERNAL';\n\n/**\n * TriggerClient\n *\n * 自动化触发器管理客户端核心类\n *\n * 负责管理触发器注册、执行和生命周期事件\n * 提供中间件支持和与 trigger-server 的回调集成\n */\nexport class TriggerClient {\n  private _triggerActionMap: Map<string, Action> = new Map();\n  private _logger: Logger;\n\n  /**\n   * 创建 TriggerClient 实例\n   *\n   * @param logger - 日志记录器\n   */\n  public constructor(logger: Logger) {\n    this._logger = logger;\n  }\n\n  /**\n   * 为指定的 trigger 注册动作\n   *\n   * @param trigger - 触发器标识\n   * @param action - 动作配置\n   */\n  public registerAction(trigger: string, action: Action): void {\n    this._logger.debug(\n      `[${INTERNAL}] Registering action for trigger: ${trigger}`,\n      {\n        actionName: action.name,\n        path: action.path,\n        desc: action.desc,\n      }\n    );\n\n    if (this._triggerActionMap.has(trigger)) {\n      this._logger.debug(\n        `[${INTERNAL}] Trigger ${trigger} already registered, overwriting`\n      );\n    }\n\n    const wrappedHandler = this._wrapHandler(action.handler);\n    const wrappedAction: Action = {\n      ...action,\n      handler: wrappedHandler,\n    };\n\n    this._triggerActionMap.set(trigger, wrappedAction);\n    this._logger.debug(\n      `[${INTERNAL}] Action registered successfully for trigger: ${trigger}`\n    );\n  }\n\n  /**\n   * 执行指定的 trigger 动作\n   *\n   * @param trigger - 触发器标识\n   * @param instanceID - 实例ID\n   * @param context - 执行上下文\n   * @returns 执行报告数据\n   */\n  public executeAction(\n    trigger: string,\n    instanceID: string,\n    context: ActionContext\n  ): ActionContext {\n    let input;\n\n    // 解析输入参数\n    try {\n      const parsed = JSON.parse(context.content || '{}');\n      input = parsed?.input ?? null;\n    } catch (error) {\n      input = undefined;\n      const content = JSON.stringify({\n        input,\n        output: {\n          error: ENUM_ERROR.PARAM_INVALID,\n          message: `参数解析失败(trigger: ${trigger}, instanceID: ${instanceID})`,\n        },\n      });\n      const actionCtx: ActionContext = {\n        ...context,\n        attributes: {\n          ...context.attributes,\n          phase: ENUM_PHASE.Trigger,\n          status: ENUM_STATUS.FAILED,\n          endAt: Date.now(),\n          duration_ms: this._computeDuration(context.attributes.startAt),\n        },\n        content,\n      };\n      this.report(...convertActionContextToReportData(actionCtx));\n      return actionCtx;\n    }\n\n    try {\n      // 获取动作处理器\n      const action = this.getAction(trigger);\n\n      // 如果动作不存在，返回错误\n      if (!action) {\n        const actionCtx: ActionContext = {\n          ...context,\n          attributes: {\n            ...context.attributes,\n            phase: ENUM_PHASE.Trigger,\n            status: ENUM_STATUS.FAILED,\n            endAt: Date.now(),\n            duration_ms: this._computeDuration(context.attributes.startAt),\n          },\n          content: JSON.stringify({\n            input,\n            output: {\n              error: ENUM_ERROR.NOT_EXIST,\n              message: `执行动作不存在: ${trigger}`,\n            },\n          }),\n        };\n        // 上报 trigger 结果{成功/失败}\n        this.report(...convertActionContextToReportData(actionCtx));\n        return actionCtx;\n      }\n\n      // 直接执行 _wrapHandler(handler)，不会等待执行结束\n      action.handler(context);\n\n      const actionCtx: ActionContext = {\n        ...context,\n        attributes: {\n          ...context.attributes,\n          phase: ENUM_PHASE.Trigger,\n          status: ENUM_STATUS.SUCCEEDED,\n          endAt: Date.now(),\n          duration_ms: this._computeDuration(context.attributes.startAt),\n        },\n        content: JSON.stringify({ input, output: null }),\n      };\n      // 上报 trigger 结果{成功/失败}\n      this.report(...convertActionContextToReportData(actionCtx));\n\n      return actionCtx;\n    } catch (error) {\n      const errorMessage =\n        error instanceof Error ? error.message : String(error);\n\n      const actionCtx: ActionContext = {\n        ...context,\n        attributes: {\n          ...context.attributes,\n          phase: ENUM_PHASE.Trigger,\n          status: ENUM_STATUS.FAILED,\n          endAt: Date.now(),\n          duration_ms: this._computeDuration(context.attributes.startAt),\n        },\n        content: JSON.stringify({\n          input,\n          output: { error: ENUM_ERROR.TRY_CATCH, message: errorMessage },\n        }),\n      };\n      // 上报 trigger 结果{成功/失败}\n      this.report(...convertActionContextToReportData(actionCtx));\n\n      return actionCtx;\n    }\n  }\n\n  /**\n   * 根据 trigger 获取对应的动作\n   *\n   * @param trigger - 触发器标识\n   * @returns 动作实例，如果不存在返回 undefined\n   */\n  public getAction(trigger: string): Action | undefined {\n    const action = this._triggerActionMap.get(trigger);\n\n    if (!action) {\n      this._logger.debug(`No action found for trigger: ${trigger}`);\n      return undefined;\n    }\n\n    this._logger.debug(`Retrieved action for trigger: ${trigger}`, {\n      actionName: action.name,\n      path: action.path,\n    });\n\n    return action;\n  }\n\n  /**\n   * 获取所有已注册的动作\n   *\n   * @returns 动作映射表\n   */\n  public getAllActions(): Map<string, Action> {\n    return this._triggerActionMap;\n  }\n\n  /**\n   * 根据 trigger 获取动作的元数据\n   *\n   * @param trigger - 触发器标识\n   * @returns 动作元数据，如果不存在返回 undefined\n   */\n  public getActionMetadata(trigger: string): ActionMetadata | undefined {\n    const action = this.getAction(trigger);\n\n    if (!action) {\n      return undefined;\n    }\n\n    return {\n      name: action.name,\n      path: action.path,\n      desc: action.desc,\n    };\n  }\n\n  /**\n   * 获取所有已注册的 trigger 标识\n   *\n   * @returns trigger 标识数组\n   */\n  public getAllTriggers(): string[] {\n    const triggers = Array.from(this._triggerActionMap.keys());\n    this._logger.debug(`Retrieved all triggers`, {\n      count: triggers.length,\n    });\n    return triggers;\n  }\n\n  /**\n   * 根据 trigger 移除对应的动作\n   *\n   * @param trigger - 触发器标识\n   * @returns 如果成功移除返回 true，如果不存在返回 false\n   */\n  public removeAction(trigger: string): boolean {\n    const existed = this._triggerActionMap.has(trigger);\n\n    if (existed) {\n      this._triggerActionMap.delete(trigger);\n      this._logger.debug(`Removed action for trigger: ${trigger}`);\n    } else {\n      this._logger.debug(\n        `Attempted to remove non-existent trigger: ${trigger}`\n      );\n    }\n\n    return existed;\n  }\n\n  /**\n   * 清空所有已注册的动作\n   */\n  public clearAllActions(): void {\n    const count = this._triggerActionMap.size;\n    this._triggerActionMap.clear();\n    this._logger.debug(`Cleared all actions`, { count });\n  }\n\n  /**\n   * 上报执行数据，用于日志记录和调试\n   */\n  public report(msg: TLogContent, extra: ILogAttributes): void {\n    const {\n      status,\n      phase,\n      start_at,\n      end_at,\n      trigger,\n      trigger_id,\n      instance_id,\n      trigger_type,\n    } = extra;\n\n    let contentObj: { input: any; output: any } = { input: null, output: null };\n    try {\n      contentObj = JSON.parse(msg);\n    } catch (error) {\n      this._logger.debug(`Failed to parse log content as JSON: ${msg}`);\n    }\n\n    const duration_ms = end_at && start_at ? end_at - start_at : 0;\n\n    let error_message;\n    if (status === ENUM_STATUS.FAILED && contentObj?.output?.message) {\n      error_message = contentObj.output.message;\n    }\n\n    const logContent: ILogContentParsed = {\n      trigger,\n      trigger_id,\n      trigger_type,\n      instance_id,\n      phase,\n      status,\n      duration_ms,\n      content: contentObj,\n      error_message,\n    };\n\n    // for 观测\n    const signature = {\n      sourceType: 'platform',\n      paas_attributes_module: 'trigger',\n    };\n    const newMsg = JSON.stringify(logContent);\n\n    // msg\n    if (status === ENUM_STATUS.FAILED) {\n      this._logger.error(newMsg, { ...extra, ...signature });\n    } else {\n      this._logger.log(newMsg, { ...extra, ...signature });\n    }\n  }\n\n  /**\n   * 包装处理器，添加日志记录和计时功能\n   *\n   * @param handler - 原始处理器\n   * @returns 包装后的处理器\n   */\n  private _computeDuration(startAt?: number): number | undefined {\n    return startAt ? Date.now() - startAt : undefined;\n  }\n\n  private _wrapHandler(handler: Action['handler']): ActionHandler {\n    return async (context: ActionContext): Promise<ActionContext> => {\n      let input;\n\n      // 解析输入参数\n      try {\n        input = JSON.parse(context.content || '{}').input;\n      } catch (error) {\n        input = undefined;\n      }\n\n      try {\n        const actionStartAt = Date.now();\n        const output = await Promise.resolve(\n          handler({\n            attributes: {\n              ...context.attributes,\n              startAt: actionStartAt,\n            },\n            content: {\n              input,\n            },\n          })\n        );\n\n        const actionCtx: ActionContext = {\n          ...context,\n          attributes: {\n            ...context.attributes,\n            startAt: actionStartAt,\n            phase: ENUM_PHASE.Action,\n            status: ENUM_STATUS.SUCCEEDED,\n            endAt: Date.now(),\n            duration_ms: this._computeDuration(actionStartAt),\n          },\n          content: JSON.stringify({\n            input,\n            output,\n          }),\n        };\n        this.report(...convertActionContextToReportData(actionCtx));\n\n        return actionCtx;\n      } catch (error) {\n        const errorMessage =\n          error instanceof Error ? error.message : String(error);\n\n        const actionCtx: ActionContext = {\n          ...context,\n          attributes: {\n            ...context.attributes,\n            phase: ENUM_PHASE.Action,\n            status: ENUM_STATUS.FAILED,\n            endAt: Date.now(),\n            duration_ms: this._computeDuration(context.attributes.startAt),\n          },\n          content: JSON.stringify({\n            input,\n            output: { error: ENUM_ERROR.TRY_CATCH, message: errorMessage },\n          }),\n        };\n        this.report(...convertActionContextToReportData(actionCtx));\n        return actionCtx;\n      }\n    };\n  }\n}\n"],"mappings":";;;;;;;;;;;;;;;;;;;;;AAAA;;;;;;;;;;;;ACgBO,IAAKA,cAAAA,0BAAAA,cAAAA;;;SAAAA;;AAKL,IAAKC,aAAAA,0BAAAA,aAAAA;;;SAAAA;;AAKL,IAAKC,WAAAA,0BAAAA,WAAAA;;;SAAAA;;AAgEL,IAAKC,aAAAA,0BAAAA,aAAAA;;;;;SAAAA;;;;ACxFL,IAAMC,mCAAmC,wBAACC,cAAAA;AAC/C,QAAM,EAAEC,YAAYC,QAAO,IAAKF;AAChC,SAAO;IACLE,WAAW;IACX;MACEC,SAASF,YAAYE;MACrBC,YAAYH,YAAYI;MACxBC,cAAcL,YAAYM;MAC1BC,aAAaP,YAAYQ;MACzBC,QAAQT,YAAYS;MACpBC,OAAOV,YAAYU;MACnBC,UAAUX,YAAYY;MACtBC,QAAQb,YAAYc;MACpBC,aAAaf,YAAYe;IAC3B;;AAEJ,GAhBgD;;;ACchD,IAAMC,WAAW;AAUV,IAAMC,gBAAN,MAAMA;EA1Bb,OA0BaA;;;EACHC,oBAAyC,oBAAIC,IAAAA;EAC7CC;;;;;;EAOR,YAAmBC,QAAgB;AACjC,SAAKD,UAAUC;EACjB;;;;;;;EAQOC,eAAeC,SAAiBC,QAAsB;AAC3D,SAAKJ,QAAQK,MACX,IAAIT,QAAAA,qCAA6CO,OAAAA,IACjD;MACEG,YAAYF,OAAOG;MACnBC,MAAMJ,OAAOI;MACbC,MAAML,OAAOK;IACf,CAAA;AAGF,QAAI,KAAKX,kBAAkBY,IAAIP,OAAAA,GAAU;AACvC,WAAKH,QAAQK,MACX,IAAIT,QAAAA,aAAqBO,OAAAA,kCAAyC;IAEtE;AAEA,UAAMQ,iBAAiB,KAAKC,aAAaR,OAAOS,OAAO;AACvD,UAAMC,gBAAwB;MAC5B,GAAGV;MACHS,SAASF;IACX;AAEA,SAAKb,kBAAkBiB,IAAIZ,SAASW,aAAAA;AACpC,SAAKd,QAAQK,MACX,IAAIT,QAAAA,iDAAyDO,OAAAA,EAAS;EAE1E;;;;;;;;;EAUOa,cACLb,SACAc,YACAC,SACe;AACf,QAAIC;AAGJ,QAAI;AACF,YAAMC,SAASC,KAAKC,MAAMJ,QAAQK,WAAW,IAAA;AAC7CJ,cAAQC,QAAQD,SAAS;IAC3B,SAASK,OAAO;AACdL,cAAQM;AACR,YAAMF,UAAUF,KAAKK,UAAU;QAC7BP;QACAQ,QAAQ;UACNH,OAAOI,WAAWC;UAClBC,SAAS,iDAAmB3B,OAAAA,iBAAwBc,UAAAA;QACtD;MACF,CAAA;AACA,YAAMc,YAA2B;QAC/B,GAAGb;QACHc,YAAY;UACV,GAAGd,QAAQc;UACXC,OAAOC,WAAWC;UAClBC,QAAQC,YAAYC;UACpBC,OAAOC,KAAKC,IAAG;UACfC,aAAa,KAAKC,iBAAiBzB,QAAQc,WAAWY,OAAO;QAC/D;QACArB;MACF;AACA,WAAKsB,OAAM,GAAIC,iCAAiCf,SAAAA,CAAAA;AAChD,aAAOA;IACT;AAEA,QAAI;AAEF,YAAM3B,SAAS,KAAK2C,UAAU5C,OAAAA;AAG9B,UAAI,CAACC,QAAQ;AACX,cAAM2B,aAA2B;UAC/B,GAAGb;UACHc,YAAY;YACV,GAAGd,QAAQc;YACXC,OAAOC,WAAWC;YAClBC,QAAQC,YAAYC;YACpBC,OAAOC,KAAKC,IAAG;YACfC,aAAa,KAAKC,iBAAiBzB,QAAQc,WAAWY,OAAO;UAC/D;UACArB,SAASF,KAAKK,UAAU;YACtBP;YACAQ,QAAQ;cACNH,OAAOI,WAAWoB;cAClBlB,SAAS,+CAAY3B,OAAAA;YACvB;UACF,CAAA;QACF;AAEA,aAAK0C,OAAM,GAAIC,iCAAiCf,UAAAA,CAAAA;AAChD,eAAOA;MACT;AAGA3B,aAAOS,QAAQK,OAAAA;AAEf,YAAMa,YAA2B;QAC/B,GAAGb;QACHc,YAAY;UACV,GAAGd,QAAQc;UACXC,OAAOC,WAAWC;UAClBC,QAAQC,YAAYY;UACpBV,OAAOC,KAAKC,IAAG;UACfC,aAAa,KAAKC,iBAAiBzB,QAAQc,WAAWY,OAAO;QAC/D;QACArB,SAASF,KAAKK,UAAU;UAAEP;UAAOQ,QAAQ;QAAK,CAAA;MAChD;AAEA,WAAKkB,OAAM,GAAIC,iCAAiCf,SAAAA,CAAAA;AAEhD,aAAOA;IACT,SAASP,OAAO;AACd,YAAM0B,eACJ1B,iBAAiB2B,QAAQ3B,MAAMM,UAAUsB,OAAO5B,KAAAA;AAElD,YAAMO,YAA2B;QAC/B,GAAGb;QACHc,YAAY;UACV,GAAGd,QAAQc;UACXC,OAAOC,WAAWC;UAClBC,QAAQC,YAAYC;UACpBC,OAAOC,KAAKC,IAAG;UACfC,aAAa,KAAKC,iBAAiBzB,QAAQc,WAAWY,OAAO;QAC/D;QACArB,SAASF,KAAKK,UAAU;UACtBP;UACAQ,QAAQ;YAAEH,OAAOI,WAAWyB;YAAWvB,SAASoB;UAAa;QAC/D,CAAA;MACF;AAEA,WAAKL,OAAM,GAAIC,iCAAiCf,SAAAA,CAAAA;AAEhD,aAAOA;IACT;EACF;;;;;;;EAQOgB,UAAU5C,SAAqC;AACpD,UAAMC,SAAS,KAAKN,kBAAkBwD,IAAInD,OAAAA;AAE1C,QAAI,CAACC,QAAQ;AACX,WAAKJ,QAAQK,MAAM,gCAAgCF,OAAAA,EAAS;AAC5D,aAAOsB;IACT;AAEA,SAAKzB,QAAQK,MAAM,iCAAiCF,OAAAA,IAAW;MAC7DG,YAAYF,OAAOG;MACnBC,MAAMJ,OAAOI;IACf,CAAA;AAEA,WAAOJ;EACT;;;;;;EAOOmD,gBAAqC;AAC1C,WAAO,KAAKzD;EACd;;;;;;;EAQO0D,kBAAkBrD,SAA6C;AACpE,UAAMC,SAAS,KAAK2C,UAAU5C,OAAAA;AAE9B,QAAI,CAACC,QAAQ;AACX,aAAOqB;IACT;AAEA,WAAO;MACLlB,MAAMH,OAAOG;MACbC,MAAMJ,OAAOI;MACbC,MAAML,OAAOK;IACf;EACF;;;;;;EAOOgD,iBAA2B;AAChC,UAAMC,WAAWC,MAAMC,KAAK,KAAK9D,kBAAkB+D,KAAI,CAAA;AACvD,SAAK7D,QAAQK,MAAM,0BAA0B;MAC3CyD,OAAOJ,SAASK;IAClB,CAAA;AACA,WAAOL;EACT;;;;;;;EAQOM,aAAa7D,SAA0B;AAC5C,UAAM8D,UAAU,KAAKnE,kBAAkBY,IAAIP,OAAAA;AAE3C,QAAI8D,SAAS;AACX,WAAKnE,kBAAkBoE,OAAO/D,OAAAA;AAC9B,WAAKH,QAAQK,MAAM,+BAA+BF,OAAAA,EAAS;IAC7D,OAAO;AACL,WAAKH,QAAQK,MACX,6CAA6CF,OAAAA,EAAS;IAE1D;AAEA,WAAO8D;EACT;;;;EAKOE,kBAAwB;AAC7B,UAAML,QAAQ,KAAKhE,kBAAkBsE;AACrC,SAAKtE,kBAAkBuE,MAAK;AAC5B,SAAKrE,QAAQK,MAAM,uBAAuB;MAAEyD;IAAM,CAAA;EACpD;;;;EAKOjB,OAAOyB,KAAkBC,OAA6B;AAC3D,UAAM,EACJnC,QACAH,OACAuC,UACAC,QACAtE,SACAuE,YACAC,aACAC,aAAY,IACVL;AAEJ,QAAIM,aAA0C;MAAE1D,OAAO;MAAMQ,QAAQ;IAAK;AAC1E,QAAI;AACFkD,mBAAaxD,KAAKC,MAAMgD,GAAAA;IAC1B,SAAS9C,OAAO;AACd,WAAKxB,QAAQK,MAAM,wCAAwCiE,GAAAA,EAAK;IAClE;AAEA,UAAM5B,cAAc+B,UAAUD,WAAWC,SAASD,WAAW;AAE7D,QAAIM;AACJ,QAAI1C,WAAWC,YAAYC,UAAUuC,YAAYlD,QAAQG,SAAS;AAChEgD,sBAAgBD,WAAWlD,OAAOG;IACpC;AAEA,UAAMiD,aAAgC;MACpC5E;MACAuE;MACAE;MACAD;MACA1C;MACAG;MACAM;MACAnB,SAASsD;MACTC;IACF;AAGA,UAAME,YAAY;MAChBC,YAAY;MACZC,wBAAwB;IAC1B;AACA,UAAMC,SAAS9D,KAAKK,UAAUqD,UAAAA;AAG9B,QAAI3C,WAAWC,YAAYC,QAAQ;AACjC,WAAKtC,QAAQwB,MAAM2D,QAAQ;QAAE,GAAGZ;QAAO,GAAGS;MAAU,CAAA;IACtD,OAAO;AACL,WAAKhF,QAAQoF,IAAID,QAAQ;QAAE,GAAGZ;QAAO,GAAGS;MAAU,CAAA;IACpD;EACF;;;;;;;EAQQrC,iBAAiBC,SAAsC;AAC7D,WAAOA,UAAUJ,KAAKC,IAAG,IAAKG,UAAUnB;EAC1C;EAEQb,aAAaC,SAA2C;AAC9D,WAAO,OAAOK,YAAAA;AACZ,UAAIC;AAGJ,UAAI;AACFA,gBAAQE,KAAKC,MAAMJ,QAAQK,WAAW,IAAA,EAAMJ;MAC9C,SAASK,OAAO;AACdL,gBAAQM;MACV;AAEA,UAAI;AACF,cAAM4D,gBAAgB7C,KAAKC,IAAG;AAC9B,cAAMd,SAAS,MAAM2D,QAAQC,QAC3B1E,QAAQ;UACNmB,YAAY;YACV,GAAGd,QAAQc;YACXY,SAASyC;UACX;UACA9D,SAAS;YACPJ;UACF;QACF,CAAA,CAAA;AAGF,cAAMY,YAA2B;UAC/B,GAAGb;UACHc,YAAY;YACV,GAAGd,QAAQc;YACXY,SAASyC;YACTpD,OAAOC,WAAWsD;YAClBpD,QAAQC,YAAYY;YACpBV,OAAOC,KAAKC,IAAG;YACfC,aAAa,KAAKC,iBAAiB0C,aAAAA;UACrC;UACA9D,SAASF,KAAKK,UAAU;YACtBP;YACAQ;UACF,CAAA;QACF;AACA,aAAKkB,OAAM,GAAIC,iCAAiCf,SAAAA,CAAAA;AAEhD,eAAOA;MACT,SAASP,OAAO;AACd,cAAM0B,eACJ1B,iBAAiB2B,QAAQ3B,MAAMM,UAAUsB,OAAO5B,KAAAA;AAElD,cAAMO,YAA2B;UAC/B,GAAGb;UACHc,YAAY;YACV,GAAGd,QAAQc;YACXC,OAAOC,WAAWsD;YAClBpD,QAAQC,YAAYC;YACpBC,OAAOC,KAAKC,IAAG;YACfC,aAAa,KAAKC,iBAAiBzB,QAAQc,WAAWY,OAAO;UAC/D;UACArB,SAASF,KAAKK,UAAU;YACtBP;YACAQ,QAAQ;cAAEH,OAAOI,WAAWyB;cAAWvB,SAASoB;YAAa;UAC/D,CAAA;QACF;AACA,aAAKL,OAAM,GAAIC,iCAAiCf,SAAAA,CAAAA;AAChD,eAAOA;MACT;IACF;EACF;AACF;","names":["ENUM_STATUS","ENUM_PHASE","ENUM_ENV","ENUM_ERROR","convertActionContextToReportData","actionCtx","attributes","content","trigger","trigger_id","triggerID","trigger_type","triggerType","instance_id","instanceID","status","phase","start_at","startAt","end_at","endAt","duration_ms","INTERNAL","TriggerClient","_triggerActionMap","Map","_logger","logger","registerAction","trigger","action","debug","actionName","name","path","desc","has","wrappedHandler","_wrapHandler","handler","wrappedAction","set","executeAction","instanceID","context","input","parsed","JSON","parse","content","error","undefined","stringify","output","ENUM_ERROR","PARAM_INVALID","message","actionCtx","attributes","phase","ENUM_PHASE","Trigger","status","ENUM_STATUS","FAILED","endAt","Date","now","duration_ms","_computeDuration","startAt","report","convertActionContextToReportData","getAction","NOT_EXIST","SUCCEEDED","errorMessage","Error","String","TRY_CATCH","get","getAllActions","getActionMetadata","getAllTriggers","triggers","Array","from","keys","count","length","removeAction","existed","delete","clearAllActions","size","clear","msg","extra","start_at","end_at","trigger_id","instance_id","trigger_type","contentObj","error_message","logContent","signature","sourceType","paas_attributes_module","newMsg","log","actionStartAt","Promise","resolve","Action"]}