Function syncCredentialSetWebhooks

apps/sim/lib/webhooks/deploy.ts:398–481

(params: {
  workflowId: string
  blockId: string
  provider: string
  triggerPath: string
  providerConfig: Record<string, unknown>
  requestId: string
  deploymentVersionId?: string
})

}

async function syncCredentialSetWebhooks(params: {
  workflowId: string
  blockId: string
  provider: string
  triggerPath: string
  providerConfig: Record<string, unknown>
  requestId: string
  deploymentVersionId?: string
}): Promise<CredentialSetSyncResult> {
  const {
    workflowId,
    blockId,
    provider,
    triggerPath,
    providerConfig,
    requestId,
    deploymentVersionId,
  } = params

  const credentialSetId = providerConfig.credentialSetId as string | undefined
  if (!credentialSetId) {
    return { error: null, warnings: [] }
  }

  const oauthProviderId = getProviderIdFromServiceId(provider)

  const { credentialId: _cId, credentialSetId: _csId, userId: _uId, ...baseConfig } = providerConfig

  const syncResult = await syncWebhooksForCredentialSet({
    workflowId,
    blockId,
    provider,
    basePath: triggerPath,
    credentialSetId,
    oauthProviderId,
    providerConfig: baseConfig as Record<string, unknown>,
    requestId,
    deploymentVersionId,
  })

  const warnings: string[] = []

  if (syncResult.failed.length > 0) {
    const failedCount = syncResult.failed.length
    const totalCount = syncResult.webhooks.length + failedCount
    warnings.push(
      `${failedCount} of ${totalCount} credentials in the set failed to sync for ${provider}. Some team members may not receive triggers.`
    )
  }

  if (syncResult.webhooks.length === 0) {
    return {
      error: {
        message: `No valid credentials found in credential set for ${provider}. Please connect accounts and try again.`,
        status: 400,
      },
      warnings,
    }