Function cleanupExternalWebhooksForWorkflow

apps/sim/lib/workflows/lifecycle.ts:52–86

(
  workflowId: string,
  requestId: string
)

}

async function cleanupExternalWebhooksForWorkflow(
  workflowId: string,
  requestId: string
): Promise<void> {
  try {
    const { cleanupExternalWebhook } = await import('@/lib/webhooks/provider-subscriptions')
    const webhooksToCleanup = await db
      .select({
        webhook: webhook,
        workflow: {
          id: workflow.id,
          userId: workflow.userId,
          workspaceId: workflow.workspaceId,
        },
      })
      .from(webhook)
      .innerJoin(workflow, eq(webhook.workflowId, workflow.id))
      .where(eq(webhook.workflowId, workflowId))

    for (const webhookData of webhooksToCleanup) {
      try {
        await cleanupExternalWebhook(webhookData.webhook, webhookData.workflow, requestId)
      } catch (error) {
        logger.warn(
          `[${requestId}] Failed to cleanup external webhook ${webhookData.webhook.id} for workflow ${workflowId}`,
          { error }
        )
      }
    }
  } catch (error) {
    logger.warn(`[${requestId}] Error during external webhook cleanup for workflow ${workflowId}`, {
      error,
    })
  }
}

export async function archiveWorkflow(
  workflowId: string,