Function credentialSetHasProviderCredential

apps/sim/lib/webhooks/deploy.ts:102–135

(
  credentialSetId: string,
  providerId: string,
  executor: DbOrTx
)

}

async function credentialSetHasProviderCredential(
  credentialSetId: string,
  providerId: string,
  executor: DbOrTx
): Promise<boolean> {
  const members = await executor
    .select({ userId: credentialSetMember.userId })
    .from(credentialSetMember)
    .where(
      and(
        eq(credentialSetMember.credentialSetId, credentialSetId),
        eq(credentialSetMember.status, 'active')
      )
    )

  if (members.length === 0) return false

  const [credential] = await executor
    .select({ id: account.id })
    .from(account)
    .where(
      and(
        inArray(
          account.userId,
          members.map((member) => member.userId)
        ),
        eq(account.providerId, providerId),
        or(isNotNull(account.accessToken), isNotNull(account.refreshToken))
      )
    )
    .limit(1)

  return Boolean(credential)
}

interface CredentialSetSyncResult {
  error: TriggerSaveError | null