Function executeWebhookJob

apps/sim/background/webhook-execution.ts:254–285

(payload: WebhookExecutionPayload)

}

export async function executeWebhookJob(payload: WebhookExecutionPayload) {
  const correlation = buildWebhookCorrelation(payload)
  const executionId = correlation.executionId
  const requestId = correlation.requestId

  return runWithRequestContext({ requestId }, async () => {
    logger.info(`[${requestId}] Starting webhook execution`, {
      webhookId: payload.webhookId,
      workflowId: payload.workflowId,
      provider: payload.provider,
      userId: payload.userId,
      executionId,
    })

    const idempotencyKey = IdempotencyService.createWebhookIdempotencyKey(
      payload.webhookId,
      payload.headers,
      payload.body,
      payload.provider
    )

    const runOperation = async () => {
      return await executeWebhookJobInternal(payload, correlation)
    }

    return await webhookIdempotency.executeWithIdempotency(
      payload.provider,
      idempotencyKey,
      runOperation
    )
  })
}

export async function resolveWebhookExecutionProviderConfig<
  T extends { id: string; providerConfig?: unknown },