auth.ts 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339
  1. import { AuthAnthropic } from "../../auth/anthropic"
  2. import { AuthCopilot } from "../../auth/copilot"
  3. import { Auth } from "../../auth"
  4. import { cmd } from "./cmd"
  5. import * as prompts from "@clack/prompts"
  6. import open from "open"
  7. import { UI } from "../ui"
  8. import { ModelsDev } from "../../provider/models"
  9. import { map, pipe, sortBy, values } from "remeda"
  10. import path from "path"
  11. import os from "os"
  12. import { Global } from "../../global"
  13. export const AuthCommand = cmd({
  14. command: "auth",
  15. describe: "manage credentials",
  16. builder: (yargs) =>
  17. yargs.command(AuthLoginCommand).command(AuthLogoutCommand).command(AuthListCommand).demandCommand(),
  18. async handler() {},
  19. })
  20. export const AuthListCommand = cmd({
  21. command: "list",
  22. aliases: ["ls"],
  23. describe: "list providers",
  24. async handler() {
  25. UI.empty()
  26. const authPath = path.join(Global.Path.data, "auth.json")
  27. const homedir = os.homedir()
  28. const displayPath = authPath.startsWith(homedir) ? authPath.replace(homedir, "~") : authPath
  29. prompts.intro(`Credentials ${UI.Style.TEXT_DIM}${displayPath}`)
  30. const results = await Auth.all().then((x) => Object.entries(x))
  31. const database = await ModelsDev.get()
  32. for (const [providerID, result] of results) {
  33. const name = database[providerID]?.name || providerID
  34. prompts.log.info(`${name} ${UI.Style.TEXT_DIM}${result.type}`)
  35. }
  36. prompts.outro(`${results.length} credentials`)
  37. // Environment variables section
  38. const activeEnvVars: Array<{ provider: string; envVar: string }> = []
  39. for (const [providerID, provider] of Object.entries(database)) {
  40. for (const envVar of provider.env) {
  41. if (process.env[envVar]) {
  42. activeEnvVars.push({
  43. provider: provider.name || providerID,
  44. envVar,
  45. })
  46. }
  47. }
  48. }
  49. if (activeEnvVars.length > 0) {
  50. UI.empty()
  51. prompts.intro("Environment")
  52. for (const { provider, envVar } of activeEnvVars) {
  53. prompts.log.info(`${provider} ${UI.Style.TEXT_DIM}${envVar}`)
  54. }
  55. prompts.outro(`${activeEnvVars.length} environment variable` + (activeEnvVars.length === 1 ? "" : "s"))
  56. }
  57. },
  58. })
  59. export const AuthLoginCommand = cmd({
  60. command: "login [url]",
  61. describe: "log in to a provider",
  62. builder: (yargs) =>
  63. yargs.positional("url", {
  64. describe: "opencode auth provider",
  65. type: "string",
  66. }),
  67. async handler(args) {
  68. UI.empty()
  69. prompts.intro("Add credential")
  70. if (args.url) {
  71. const wellknown = await fetch(`${args.url}/.well-known/opencode`).then((x) => x.json())
  72. prompts.log.info(`Running \`${wellknown.auth.command.join(" ")}\``)
  73. const proc = Bun.spawn({
  74. cmd: wellknown.auth.command,
  75. stdout: "pipe",
  76. })
  77. const exit = await proc.exited
  78. if (exit !== 0) {
  79. prompts.log.error("Failed")
  80. prompts.outro("Done")
  81. return
  82. }
  83. const token = await new Response(proc.stdout).text()
  84. await Auth.set(args.url, {
  85. type: "wellknown",
  86. key: wellknown.auth.env,
  87. token: token.trim(),
  88. })
  89. prompts.log.success("Logged into " + args.url)
  90. prompts.outro("Done")
  91. return
  92. }
  93. const providers = await ModelsDev.get()
  94. const priority: Record<string, number> = {
  95. anthropic: 0,
  96. "github-copilot": 1,
  97. openai: 2,
  98. google: 3,
  99. openrouter: 4,
  100. vercel: 5,
  101. }
  102. let provider = await prompts.autocomplete({
  103. message: "Select provider",
  104. maxItems: 8,
  105. options: [
  106. ...pipe(
  107. providers,
  108. values(),
  109. sortBy(
  110. (x) => priority[x.id] ?? 99,
  111. (x) => x.name ?? x.id,
  112. ),
  113. map((x) => ({
  114. label: x.name,
  115. value: x.id,
  116. hint: priority[x.id] === 0 ? "recommended" : undefined,
  117. })),
  118. ),
  119. {
  120. value: "other",
  121. label: "Other",
  122. },
  123. ],
  124. })
  125. if (prompts.isCancel(provider)) throw new UI.CancelledError()
  126. if (provider === "other") {
  127. provider = await prompts.text({
  128. message: "Enter provider id",
  129. validate: (x) => x && (x.match(/^[0-9a-z-]+$/) ? undefined : "a-z, 0-9 and hyphens only"),
  130. })
  131. if (prompts.isCancel(provider)) throw new UI.CancelledError()
  132. provider = provider.replace(/^@ai-sdk\//, "")
  133. if (prompts.isCancel(provider)) throw new UI.CancelledError()
  134. prompts.log.warn(
  135. `This only stores a credential for ${provider} - you will need configure it in opencode.json, check the docs for examples.`,
  136. )
  137. }
  138. if (provider === "amazon-bedrock") {
  139. prompts.log.info(
  140. "Amazon bedrock can be configured with standard AWS environment variables like AWS_BEARER_TOKEN_BEDROCK, AWS_PROFILE or AWS_ACCESS_KEY_ID",
  141. )
  142. prompts.outro("Done")
  143. return
  144. }
  145. if (provider === "anthropic") {
  146. const method = await prompts.select({
  147. message: "Login method",
  148. options: [
  149. {
  150. label: "Claude Pro/Max",
  151. value: "max",
  152. },
  153. {
  154. label: "Create API Key",
  155. value: "console",
  156. },
  157. {
  158. label: "Manually enter API Key",
  159. value: "api",
  160. },
  161. ],
  162. })
  163. if (prompts.isCancel(method)) throw new UI.CancelledError()
  164. if (method === "max") {
  165. // some weird bug where program exits without this
  166. await new Promise((resolve) => setTimeout(resolve, 10))
  167. const { url, verifier } = await AuthAnthropic.authorize("max")
  168. prompts.note("Trying to open browser...")
  169. try {
  170. await open(url)
  171. } catch (e) {
  172. prompts.log.error(
  173. "Failed to open browser perhaps you are running without a display or X server, please open the following URL in your browser:",
  174. )
  175. }
  176. prompts.log.info(url)
  177. const code = await prompts.text({
  178. message: "Paste the authorization code here: ",
  179. validate: (x) => x && (x.length > 0 ? undefined : "Required"),
  180. })
  181. if (prompts.isCancel(code)) throw new UI.CancelledError()
  182. try {
  183. const credentials = await AuthAnthropic.exchange(code, verifier)
  184. await Auth.set("anthropic", {
  185. type: "oauth",
  186. refresh: credentials.refresh,
  187. access: credentials.access,
  188. expires: credentials.expires,
  189. })
  190. prompts.log.success("Login successful")
  191. } catch {
  192. prompts.log.error("Invalid code")
  193. }
  194. prompts.outro("Done")
  195. return
  196. }
  197. if (method === "console") {
  198. // some weird bug where program exits without this
  199. await new Promise((resolve) => setTimeout(resolve, 10))
  200. const { url, verifier } = await AuthAnthropic.authorize("console")
  201. prompts.note("Trying to open browser...")
  202. try {
  203. await open(url)
  204. } catch (e) {
  205. prompts.log.error(
  206. "Failed to open browser perhaps you are running without a display or X server, please open the following URL in your browser:",
  207. )
  208. }
  209. prompts.log.info(url)
  210. const code = await prompts.text({
  211. message: "Paste the authorization code here: ",
  212. validate: (x) => x && (x.length > 0 ? undefined : "Required"),
  213. })
  214. if (prompts.isCancel(code)) throw new UI.CancelledError()
  215. try {
  216. const credentials = await AuthAnthropic.exchange(code, verifier)
  217. const accessToken = credentials.access
  218. const response = await fetch("https://api.anthropic.com/api/oauth/claude_cli/create_api_key", {
  219. method: "POST",
  220. headers: {
  221. Authorization: `Bearer ${accessToken}`,
  222. "Content-Type": "application/x-www-form-urlencoded",
  223. Accept: "application/json, text/plain, */*",
  224. },
  225. })
  226. if (!response.ok) {
  227. throw new Error("Failed to create API key")
  228. }
  229. const json = await response.json()
  230. await Auth.set("anthropic", {
  231. type: "api",
  232. key: json.raw_key,
  233. })
  234. prompts.log.success("Login successful - API key created and saved")
  235. } catch (error) {
  236. prompts.log.error("Invalid code or failed to create API key")
  237. }
  238. prompts.outro("Done")
  239. return
  240. }
  241. }
  242. const copilot = await AuthCopilot()
  243. if (provider === "github-copilot" && copilot) {
  244. await new Promise((resolve) => setTimeout(resolve, 10))
  245. const deviceInfo = await copilot.authorize()
  246. prompts.note(`Please visit: ${deviceInfo.verification}\nEnter code: ${deviceInfo.user}`)
  247. const spinner = prompts.spinner()
  248. spinner.start("Waiting for authorization...")
  249. while (true) {
  250. await new Promise((resolve) => setTimeout(resolve, deviceInfo.interval * 1000))
  251. const response = await copilot.poll(deviceInfo.device)
  252. if (response.status === "pending") continue
  253. if (response.status === "success") {
  254. await Auth.set("github-copilot", {
  255. type: "oauth",
  256. refresh: response.refresh,
  257. access: response.access,
  258. expires: response.expires,
  259. })
  260. spinner.stop("Login successful")
  261. break
  262. }
  263. if (response.status === "failed") {
  264. spinner.stop("Failed to authorize", 1)
  265. break
  266. }
  267. }
  268. prompts.outro("Done")
  269. return
  270. }
  271. if (provider === "vercel") {
  272. prompts.log.info("You can create an api key in the dashboard")
  273. }
  274. const key = await prompts.password({
  275. message: "Enter your API key",
  276. validate: (x) => x && (x.length > 0 ? undefined : "Required"),
  277. })
  278. if (prompts.isCancel(key)) throw new UI.CancelledError()
  279. await Auth.set(provider, {
  280. type: "api",
  281. key,
  282. })
  283. prompts.outro("Done")
  284. },
  285. })
  286. export const AuthLogoutCommand = cmd({
  287. command: "logout",
  288. describe: "log out from a configured provider",
  289. async handler() {
  290. UI.empty()
  291. const credentials = await Auth.all().then((x) => Object.entries(x))
  292. prompts.intro("Remove credential")
  293. if (credentials.length === 0) {
  294. prompts.log.error("No credentials found")
  295. return
  296. }
  297. const database = await ModelsDev.get()
  298. const providerID = await prompts.select({
  299. message: "Select provider",
  300. options: credentials.map(([key, value]) => ({
  301. label: (database[key]?.name || key) + UI.Style.TEXT_DIM + " (" + value.type + ")",
  302. value: key,
  303. })),
  304. })
  305. if (prompts.isCancel(providerID)) throw new UI.CancelledError()
  306. await Auth.remove(providerID)
  307. prompts.outro("Logout successful")
  308. },
  309. })