Function ensureProjectContext

packages/arctic/src/provider/provider.ts:640–708

(accessToken: string)

              }

              async function ensureProjectContext(accessToken: string): Promise<string> {
                if (!accessToken) {
                  throw new Error("Missing Google OAuth access token")
                }
                const configuredProjectId =
                  Env.get("GOOGLE_CLOUD_PROJECT") ?? Env.get("GCP_PROJECT") ?? Env.get("GCLOUD_PROJECT")
                const cacheKey = configuredProjectId?.trim() || "default"
                const cached = projectContextCache.get(cacheKey)
                if (cached) return cached
                const pending = projectContextPending.get(cacheKey)
                if (pending) return pending

                const promise = (async () => {
                  const projectId = configuredProjectId?.trim() || undefined
                  if (projectId) {
                    projectContextCache.set(cacheKey, projectId)
                    return projectId
                  }

                  const loadPayload = await loadManagedProject(accessToken, projectId)
                  if (loadPayload?.cloudaicompanionProject) {
                    const managedProjectId = loadPayload.cloudaicompanionProject
                    projectContextCache.set(cacheKey, managedProjectId)
                    return managedProjectId
                  }

                  if (!loadPayload) {
                    throw new Error(
                      "Gemini requires a Google Cloud project. Enable the Gemini for Google Cloud API on a project you control.",
                    )
                  }

                  const currentTierId = loadPayload?.currentTier?.id ?? undefined
                  if (currentTierId && currentTierId !== "FREE") {
                    throw new Error(
                      "Gemini requires a Google Cloud project for non-free tiers. Set GOOGLE_CLOUD_PROJECT.",
                    )
                  }

                  const allowedTiers = Array.isArray(loadPayload?.allowedTiers) ? loadPayload.allowedTiers : []
                  let defaultTierId: string | undefined
                  for (const tier of allowedTiers) {
                    if (tier?.isDefault) {
                      defaultTierId = tier.id
                      break
                    }
                  }
                  const tierId = defaultTierId ?? allowedTiers[0]?.id ?? "FREE"

                  if (tierId !== "FREE") {
                    throw new Error(
                      "Gemini requires a Google Cloud project for non-free tiers. Set GOOGLE_CLOUD_PROJECT.",
                    )
                  }

                  const managedProjectId = await onboardManagedProject(accessToken, tierId, projectId)
                  if (!managedProjectId) {
                    throw new Error("Failed to resolve a managed Gemini project.")