Function getCredentialOwner

apps/sim/lib/webhooks/provider-subscription-utils.ts:27–48

(
  credentialId: string,
  requestId: string
)

 * registration and cleanup.
 */
export async function getCredentialOwner(
  credentialId: string,
  requestId: string
): Promise<{ userId: string; accountId: string } | null> {
  const resolved = await resolveOAuthAccountId(credentialId)
  if (!resolved) {
    logger.warn(`[${requestId}] Failed to resolve OAuth account for credentialId ${credentialId}`)
    return null
  }
  const [credentialRecord] = await db
    .select({ userId: account.userId })
    .from(account)
    .where(eq(account.id, resolved.accountId))
    .limit(1)

  if (!credentialRecord?.userId) {
    logger.warn(`[${requestId}] Credential owner not found for credentialId ${credentialId}`)
    return null
  }

  return { userId: credentialRecord.userId, accountId: resolved.accountId }
}