Function notifyWorkflowArchived

apps/sim/lib/workflows/lifecycle.ts:31–50

(workflowId: string, requestId: string)

}

async function notifyWorkflowArchived(workflowId: string, requestId: string): Promise<void> {
  try {
    const socketResponse = await fetch(`${getSocketServerUrl()}/api/workflow-deleted`, {
      method: 'POST',
      headers: {
        'Content-Type': 'application/json',
        'x-api-key': env.INTERNAL_API_SECRET,
      },
      body: JSON.stringify({ workflowId }),
    })

    if (!socketResponse.ok) {
      logger.warn(`[${requestId}] Failed to notify Socket.IO about archived workflow ${workflowId}`)
    }
  } catch (error) {
    logger.warn(`[${requestId}] Error notifying Socket.IO about archived workflow ${workflowId}`, {
      error,
    })
  }
}

async function cleanupExternalWebhooksForWorkflow(
  workflowId: string,