Function emitWorkflowLifecycleEvent

apps/sim/lib/workspace-events/emitter.ts:169–195

* Shared dispatch loop for workflow lifecycle events: matches subscriptions * on event type and workflow scope, never notifying the source workflow about * itself. Fire-and-forget: failures never affect the lifecycle operation.

(params: {
  eventType: 'workflow_deployed' | 'workflow_undeployed'
  workflowId: string
  workspaceId: string
  payload: SimEventPayload
})

 * itself. Fire-and-forget: failures never affect the lifecycle operation.
 */
async function emitWorkflowLifecycleEvent(params: {
  eventType: 'workflow_deployed' | 'workflow_undeployed'
  workflowId: string
  workspaceId: string
  payload: SimEventPayload
}): Promise<void> {
  try {
    const subscriptions = await fetchSimTriggerSubscriptions(params.workspaceId)
    if (subscriptions.length === 0) return

    for (const subscription of subscriptions) {
      const config = parseSubscriptionConfig(subscription.webhook.providerConfig)
      if (!config) continue
      if (config.eventType !== params.eventType) continue

      if (subscription.webhook.workflowId === params.workflowId) continue
      if (!matchesWorkflowScope(config, params.workflowId)) continue

      await dispatchSimEvent(subscription, params.payload)
    }
  } catch (error) {
    logger.error(`Failed to emit ${params.eventType} event`, {
      error,
      workflowId: params.workflowId,
    })
  }
}

/**
 * Emits a workflow_deployed event to subscribed side-effect workflows.