Function executeWorkflows

apps/web/lib/api/workflows/execute-workflows.ts:43–214

({
  trigger,
  reason,
  identity,
  metrics,
}: WorkflowContext)

};

export async function executeWorkflows({
  trigger,
  reason,
  identity,
  metrics,
}: WorkflowContext) {
  const { programId, partnerId } = identity;

  let workflows = await prisma.workflow.findMany({
    where: {
      programId,
      disabledAt: null,
      trigger,
    },
  });

  if (workflows.length === 0) {
    console.log(
      `No workflows found to execute for trigger ${trigger} and reason ${reason}.`,
    );
    return;
  }

  // Parse all workflow configs once upfront, filtering out any that fail to parse
  const parsedWorkflows = workflows
    .map((workflow) => {
      try {
        return {
          workflow,
          config: parseWorkflowConfig(workflow),
        };
      } catch (error) {
        console.error(
          `Failed to parse workflow config for workflow ${workflow.id}, skipping:`,
          error,
        );
        return null;
      }
    })
    .filter(
      (
        item,
      ): item is {
        workflow: Workflow;
        config: ReturnType<typeof parseWorkflowConfig>;
      } => item !== null,
    );

  if (parsedWorkflows.length === 0) {
    console.log(
      `No valid workflows found to execute for trigger ${trigger} and reason ${reason}.`,
    );
    return;
  }

  // Filter by reason if provided
  let filteredWorkflows = parsedWorkflows;
  if (reason) {