Function run

packages/actionsflow/src/trigger.ts:29–342

({
  trigger,
  event,
  workflow,
  cwd,
  dest,
}: ITriggerInternalOptions)

const allTriggers = Triggers as Record<string, ITriggerClassTypeConstructable>;

export const run = async ({
  trigger,
  event,
  workflow,
  cwd,
  dest,
}: ITriggerInternalOptions): Promise<ITriggerInternalResult> => {
  log.debug("Trigger event: ", event);
  const originLogLevel = log.getLevel();
  const finalResult: ITriggerInternalResult = {
    items: [],
    outcome: "success",
    conclusion: "success",
  };

  const Trigger = trigger.class;

  if (Trigger) {
    const triggerCacheManager = getTriggerManageCache({
      name: trigger.name,
      workflowRelativePath: workflow.relativePath,
    });
    const triggerConstructorParams = await getTriggerConstructorParams({
      name: trigger.name,
      workflow: workflow,
      options: trigger.options,
    });
    finalResult.helpers = triggerConstructorParams.helpers;
    const triggerInstance = new Trigger(triggerConstructorParams);

    let triggerResult: ITriggerResult | undefined;

    if (triggerInstance) {
      const triggerGeneralOptions = getGeneralTriggerFinalOptions(
        triggerInstance,
        trigger.options,
        event,
        {
          cwd,
          dest,
        }
      );
      const {
        shouldDeduplicate,
        limit,
        filter,
        filterOutputs,
        format,
        sort,
        skip,
        skipFirst,
        force,
        logLevel,
        filterScript,
        sortScript,
      } = triggerGeneralOptions;
      if (logLevel) {
        log.setLevel(logLevel);