Function verifyCredentialSetBilling

apps/sim/lib/webhooks/processor.ts:55–82

(credentialSetId: string)

}

async function verifyCredentialSetBilling(credentialSetId: string): Promise<{
  valid: boolean
  error?: string
}> {
  if (!isProd) {
    return { valid: true }
  }

  const [set] = await db
    .select({ organizationId: credentialSet.organizationId })
    .from(credentialSet)
    .where(eq(credentialSet.id, credentialSetId))
    .limit(1)

  if (!set) {
    return { valid: false, error: 'Credential set not found' }
  }

  const hasTeamPlan = await isOrganizationOnTeamOrEnterprisePlan(set.organizationId)
  if (!hasTeamPlan) {
    return {
      valid: false,
      error: 'Credential sets require a Team or Enterprise plan. Please upgrade to continue.',
    }
  }

  return { valid: true }
}

const WEBHOOK_BODY_LABEL = 'Webhook request body'