Function dispatchSimEvent

apps/sim/lib/workspace-events/emitter.ts:45–72

(
  subscription: SimSubscription,
  payload: SimEventPayload
)

 * module stays cheap for the execution logger to import.
 */
export async function dispatchSimEvent(
  subscription: SimSubscription,
  payload: SimEventPayload
): Promise<void> {
  const requestId = generateShortId()
  try {
    const { processPolledWebhookEvent } = await import('@/lib/webhooks/processor')
    const result = await processPolledWebhookEvent(
      subscription.webhook,
      subscription.workflow,
      payload,
      requestId
    )

    if (!result.success) {
      logger.error(
        `[${requestId}] Failed to fire sim trigger for workflow ${subscription.workflow.id}:`,
        result.statusCode,
        result.error
      )
    }
  } catch (error) {
    logger.error(
      `[${requestId}] Error firing sim trigger for workflow ${subscription.workflow.id}:`,
      error
    )
  }
}

/** Workflow-scope filter shared by all event kinds. Empty selection watches every workflow. */
function matchesWorkflowScope(config: SimSubscriptionConfig, sourceWorkflowId: string): boolean {