Function getCredentialOwner

apps/sim/app/api/cron/renew-subscriptions/route.ts:19–36

(
  credentialId: string
)

const LOCK_TTL_SECONDS = 300

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

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

/**
 * Renews Microsoft Teams chat subscriptions that are close to expiring.