| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264 |
- import { AuthAnthropic } from "../../auth/anthropic"
- import { AuthCopilot } from "../../auth/copilot"
- import { Auth } from "../../auth"
- import { cmd } from "./cmd"
- import * as prompts from "@clack/prompts"
- import open from "open"
- import { UI } from "../ui"
- import { ModelsDev } from "../../provider/models"
- import { map, pipe, sortBy, values } from "remeda"
- import path from "path"
- import os from "os"
- import { Global } from "../../global"
- export const AuthCommand = cmd({
- command: "auth",
- describe: "manage credentials",
- builder: (yargs) =>
- yargs
- .command(AuthLoginCommand)
- .command(AuthLogoutCommand)
- .command(AuthListCommand)
- .demandCommand(),
- async handler() {},
- })
- export const AuthListCommand = cmd({
- command: "list",
- aliases: ["ls"],
- describe: "list providers",
- async handler() {
- UI.empty()
- const authPath = path.join(Global.Path.data, "auth.json")
- const homedir = os.homedir()
- const displayPath = authPath.startsWith(homedir)
- ? authPath.replace(homedir, "~")
- : authPath
- prompts.intro(`Credentials ${UI.Style.TEXT_DIM}${displayPath}`)
- const results = await Auth.all().then((x) => Object.entries(x))
- const database = await ModelsDev.get()
- for (const [providerID, result] of results) {
- const name = database[providerID]?.name || providerID
- prompts.log.info(`${name} ${UI.Style.TEXT_DIM}${result.type}`)
- }
- prompts.outro(`${results.length} credentials`)
- // Environment variables section
- const activeEnvVars: Array<{ provider: string; envVar: string }> = []
- for (const [providerID, provider] of Object.entries(database)) {
- for (const envVar of provider.env) {
- if (process.env[envVar]) {
- activeEnvVars.push({
- provider: provider.name || providerID,
- envVar,
- })
- }
- }
- }
- if (activeEnvVars.length > 0) {
- UI.empty()
- prompts.intro("Environment")
- for (const { provider, envVar } of activeEnvVars) {
- prompts.log.info(`${provider} ${UI.Style.TEXT_DIM}${envVar}`)
- }
- prompts.outro(`${activeEnvVars.length} environment variables`)
- }
- },
- })
- export const AuthLoginCommand = cmd({
- command: "login",
- describe: "log in to a provider",
- async handler() {
- UI.empty()
- prompts.intro("Add credential")
- const providers = await ModelsDev.get()
- const priority: Record<string, number> = {
- anthropic: 0,
- "github-copilot": 1,
- openai: 2,
- google: 3,
- }
- let provider = await prompts.select({
- message: "Select provider",
- maxItems: 8,
- options: [
- ...pipe(
- providers,
- values(),
- sortBy(
- (x) => priority[x.id] ?? 99,
- (x) => x.name ?? x.id,
- ),
- map((x) => ({
- label: x.name,
- value: x.id,
- hint: priority[x.id] === 0 ? "recommended" : undefined,
- })),
- ),
- {
- value: "other",
- label: "Other",
- },
- ],
- })
- if (prompts.isCancel(provider)) throw new UI.CancelledError()
- if (provider === "other") {
- provider = await prompts.text({
- message: "Enter provider id",
- validate: (x) =>
- x.match(/^[a-z-]+$/) ? undefined : "a-z and hyphens only",
- })
- if (prompts.isCancel(provider)) throw new UI.CancelledError()
- provider = provider.replace(/^@ai-sdk\//, "")
- if (prompts.isCancel(provider)) throw new UI.CancelledError()
- prompts.log.warn(
- `This only stores a credential for ${provider} - you will need configure it in opencode.json, check the docs for examples.`,
- )
- }
- if (provider === "amazon-bedrock") {
- prompts.log.info(
- "Amazon bedrock can be configured with standard AWS environment variables like AWS_PROFILE or AWS_ACCESS_KEY_ID",
- )
- prompts.outro("Done")
- return
- }
- if (provider === "anthropic") {
- const method = await prompts.select({
- message: "Login method",
- options: [
- {
- label: "Claude Pro/Max",
- value: "oauth",
- },
- {
- label: "API Key",
- value: "api",
- },
- ],
- })
- if (prompts.isCancel(method)) throw new UI.CancelledError()
- if (method === "oauth") {
- // some weird bug where program exits without this
- await new Promise((resolve) => setTimeout(resolve, 10))
- const { url, verifier } = await AuthAnthropic.authorize()
- prompts.note("Trying to open browser...")
- try {
- await open(url)
- } catch (e) {
- prompts.log.error(
- "Failed to open browser perhaps you are running without a display or X server, please open the following URL in your browser:",
- )
- }
- prompts.log.info(url)
- const code = await prompts.text({
- message: "Paste the authorization code here: ",
- validate: (x) => (x.length > 0 ? undefined : "Required"),
- })
- if (prompts.isCancel(code)) throw new UI.CancelledError()
- await AuthAnthropic.exchange(code, verifier)
- .then(() => {
- prompts.log.success("Login successful")
- })
- .catch(() => {
- prompts.log.error("Invalid code")
- })
- prompts.outro("Done")
- return
- }
- }
- const copilot = await AuthCopilot()
- if (provider === "github-copilot" && copilot) {
- await new Promise((resolve) => setTimeout(resolve, 10))
- const deviceInfo = await copilot.authorize()
- prompts.note(
- `Please visit: ${deviceInfo.verification}\nEnter code: ${deviceInfo.user}`,
- )
- const spinner = prompts.spinner()
- spinner.start("Waiting for authorization...")
- while (true) {
- await new Promise((resolve) =>
- setTimeout(resolve, deviceInfo.interval * 1000),
- )
- const response = await copilot.poll(deviceInfo.device)
- if (response.status === "pending") continue
- if (response.status === "success") {
- await Auth.set("github-copilot", {
- type: "oauth",
- refresh: response.refresh,
- access: response.access,
- expires: response.expires,
- })
- spinner.stop("Login successful")
- break
- }
- if (response.status === "failed") {
- spinner.stop("Failed to authorize", 1)
- break
- }
- }
- prompts.outro("Done")
- return
- }
- const key = await prompts.password({
- message: "Enter your API key",
- validate: (x) => (x.length > 0 ? undefined : "Required"),
- })
- if (prompts.isCancel(key)) throw new UI.CancelledError()
- await Auth.set(provider, {
- type: "api",
- key,
- })
- prompts.outro("Done")
- },
- })
- export const AuthLogoutCommand = cmd({
- command: "logout",
- describe: "log out from a configured provider",
- async handler() {
- UI.empty()
- const credentials = await Auth.all().then((x) => Object.entries(x))
- prompts.intro("Remove credential")
- if (credentials.length === 0) {
- prompts.log.error("No credentials found")
- return
- }
- const database = await ModelsDev.get()
- const providerID = await prompts.select({
- message: "Select provider",
- options: credentials.map(([key, value]) => ({
- label:
- (database[key]?.name || key) +
- UI.Style.TEXT_DIM +
- " (" +
- value.type +
- ")",
- value: key,
- })),
- })
- if (prompts.isCancel(providerID)) throw new UI.CancelledError()
- await Auth.remove(providerID)
- prompts.outro("Logout successful")
- },
- })
|