Function syncAllWebhooksForCredentialSet

apps/sim/lib/webhooks/utils.server.ts:315–408

(
  credentialSetId: string,
  requestId: string
)

 * Must run OUTSIDE any open transaction — see {@link syncWebhooksForCredentialSet}.
 */
export async function syncAllWebhooksForCredentialSet(
  credentialSetId: string,
  requestId: string
): Promise<{ workflowsUpdated: number; totalCreated: number; totalDeleted: number }> {
  const syncLogger = createLogger('CredentialSetMembershipSync')
  syncLogger.info(`[${requestId}] Syncing all webhooks for credential set ${credentialSetId}`)

  const webhooksForSet = await db
    .select({ webhook })
    .from(webhook)
    .leftJoin(
      workflowDeploymentVersion,
      and(
        eq(workflowDeploymentVersion.workflowId, webhook.workflowId),
        eq(workflowDeploymentVersion.isActive, true)
      )
    )
    .where(
      and(
        eq(webhook.credentialSetId, credentialSetId),
        isNull(webhook.archivedAt),
        or(
          eq(webhook.deploymentVersionId, workflowDeploymentVersion.id),
          and(isNull(workflowDeploymentVersion.id), isNull(webhook.deploymentVersionId))
        )
      )
    )

  if (webhooksForSet.length === 0) {
    syncLogger.info(`[${requestId}] No webhooks found using credential set ${credentialSetId}`)
    return { workflowsUpdated: 0, totalCreated: 0, totalDeleted: 0 }
  }

  const triggerGroups = new Map<string, (typeof webhooksForSet)[number]['webhook']>()
  for (const row of webhooksForSet) {
    const wh = row.webhook
    const key = `${wh.workflowId}:${wh.blockId}`
    if (!triggerGroups.has(key)) {
      triggerGroups.set(key, wh)
    }
  }

  syncLogger.info(
    `[${requestId}] Found ${triggerGroups.size} triggers using credential set ${credentialSetId}`
  )

  let workflowsUpdated = 0
  let totalCreated = 0
  let totalDeleted = 0

  for (const [key, representativeWebhook] of triggerGroups) {
    if (!representativeWebhook.provider) {
      syncLogger.warn(`[${requestId}] Skipping webhook without provider: ${key}`)
      continue
    }

    const config = representativeWebhook.providerConfig as Record<string, unknown>
    const oauthProviderId = getProviderIdFromServiceId(representativeWebhook.provider)