}, handler: async (args) => { let message = [...args.message, ...(args["--"] || [])] .map((arg) => (arg.includes(" ") ? `"${arg.replace(/"/g, '\\"')}"` : arg)) .join(" ") const directory = (() => { if (!args.dir) return undefined if (args.attach) return args.dir try { process.chdir(args.dir) return process.cwd() } catch { UI.error("Failed to change directory to " + args.dir) process.exit(1) } })() const files: { type: "file"; url: string; filename: string; mime: string }[] = [] if (args.file) { const list = Array.isArray(args.file) ? args.file : [args.file] for (const filePath of list) { const resolvedPath = path.resolve(process.cwd(), filePath) if (!(await Filesystem.exists(resolvedPath))) { UI.error(`File not found: ${filePath}`) process.exit(1) } const mime = (await Filesystem.isDir(resolvedPath)) ? "application/x-directory" : "text/plain" files.push({ type: "file", url: pathToFileURL(resolvedPath).href, filename: path.basename(resolvedPath), mime, }) } } if (!process.stdin.isTTY) message += "\n" + (await Bun.stdin.text()) if (message.trim().length === 0 && !args.command) { UI.error("You must provide a message or a command") process.exit(1) } if (args.fork && !args.continue && !args.session) { UI.error("--fork requires --continue or --session") process.exit(1) } const rules: PermissionNext.Ruleset = [ { permission: "question", action: "deny", pattern: "*", }, { permission: "plan_enter", action: "deny", pattern: "*", }, { permission: "plan_exit", action: "deny", pattern: "*", }, ] function title() { if (args.title === undefined) return if (args.title !== "") return args.title return message.slice(0, 50) + (message.length > 50 ? "..." : "") } async function session(sdk: OpencodeClient) { const baseID = args.continue ? (await sdk.session.list()).data?.find((s) => !s.parentID)?.id : args.session if (baseID && args.fork) { const forked = await sdk.session.fork({ sessionID: baseID }) return forked.data?.id } if (baseID) return baseID const name = title() const result = await sdk.session.create({ title: name, permission: rules }) return result.data?.id } async function share(sdk: OpencodeClient, sessionID: string) { const cfg = await sdk.config.get() if (!cfg.data) return if (cfg.data.share !== "auto" && !Flag.OPENCODE_AUTO_SHARE && !args.share) return const res = await sdk.session.share({ sessionID }).catch((error) => { if (error instanceof Error && error.message.includes("disabled")) { UI.println(UI.Style.TEXT_DANGER_BOLD + "! " + error.message) } return { error } }) if (!res.error && "data" in res && res.data?.share?.url) { UI.println(UI.Style.TEXT_INFO_BOLD + "~ " + res.data.share.url) } } async function execute(sdk: OpencodeClient) { function tool(part: ToolPart) { try { if (part.tool === "bash") return bash(props(part)) if (part.tool === "glob") return glob(props(part)) if (part.tool === "grep") return grep(props(part)) if (part.tool === "list") return list(props(part)) if (part.tool === "read") return read(props(part)) if (part.tool === "write") return write(props(part)) if (part.tool === "webfetch") return webfetch(props(part)) if (part.tool === "edit") return edit(props(part)) if (part.tool === "codesearch") return codesearch(props(part)) if (part.tool === "websearch") return websearch(props(part)) if (part.tool === "task") return task(props(part)) if (part.tool === "todowrite") return todo(props(part)) if (part.tool === "skill") return skill(props(part)) return fallback(part) } catch { return fallback(part) } } function emit(type: string, data: Record) { if (args.format === "json") { process.stdout.write(JSON.stringify({ type, timestamp: Date.now(), sessionID, ...data }) + EOL) return true } return false } const events = await sdk.event.subscribe() let error: string | undefined async function loop() { const toggles = new Map() for await (const event of events.stream) { if ( event.type === "message.updated" && event.properties.info.role === "assistant" && args.format !== "json" && toggles.get("start") !== true ) { UI.empty() UI.println(`> ${event.properties.info.agent} · ${event.properties.info.modelID}`)