Function validateTriggerWebhookConfigForDeploy

apps/sim/lib/webhooks/deploy.ts:45–100

(
  blocks: Record<string, BlockState>,
  executor: DbOrTx = db
)

}

export async function validateTriggerWebhookConfigForDeploy(
  blocks: Record<string, BlockState>,
  executor: DbOrTx = db
): Promise<TriggerSaveResult> {
  const triggerBlocks = Object.values(blocks || {}).filter((b) => b && b.enabled !== false)

  for (const block of triggerBlocks) {
    const triggerId = resolveTriggerId(block)
    if (!triggerId || !isTriggerValid(triggerId)) continue

    const triggerDef = getTrigger(triggerId)
    const provider = triggerDef.provider
    const { providerConfig, missingFields } = buildProviderConfig(block, triggerId, triggerDef)

    if (missingFields.length > 0) {
      return {
        success: false,
        error: {
          message: `Missing required fields for ${triggerDef.name || triggerId}: ${missingFields.join(', ')}`,
          status: 400,
        },
      }
    }

    if (providerConfig.requireAuth && !providerConfig.token) {
      return {
        success: false,
        error: {
          message:
            'Authentication is enabled but no token is configured. Please set an authentication token or disable authentication.',
          status: 400,
        },
      }
    }

    if (providerConfig.credentialSetId) {
      const oauthProviderId = getProviderIdFromServiceId(provider)
      const hasCredential = await credentialSetHasProviderCredential(
        providerConfig.credentialSetId as string,
        oauthProviderId,
        executor
      )
      if (!hasCredential) {
        return {
          success: false,
          error: {
            message: `No valid credentials found in credential set for ${provider}. Please connect accounts and try again.`,
            status: 400,
          },
        }
      }
    }
  }

  return { success: true }
}

async function credentialSetHasProviderCredential(