lyric.tngl.sh / mistermorph
Unified Agent + reusable Go agent core.
0
fork

Configure Feed

Select the types of activity you want to include in your feed.

feat: add Cursor CLI ACP stdio proxy and client compatibility

Add a transparent JSON-RPC proxy to `agent acp`, handle Cursor auth and
permission option formats, respond to blocking cursor/* extensions, and
document configuration across zh/en/ja and config.example.yaml.

authored by

yiplee and committed by
Lyric Wai 7799c222 941d2205

+549 -6
+1
AGENTS.md
··· 9 9 - `tools/` and `tools/builtin/`: tool registry and built-ins (`web_search`, `url_fetch`, `bash`, `read_file`). 10 10 - `skills/`: skill discovery and selection logic for `SKILL.md`. 11 11 - `demo/`: embedding examples (`demo/embed-go/`, `demo/embed-cli/`). 12 + - `wrappers/acp/`: optional stdio bridges for external ACP agents (Codex app-server, Claude Code print mode, Cursor CLI `agent acp` proxy). 12 13 - Root configs: `assets/config/config.example.yaml` (template) and `config.yaml` (local). `mistermorph` in repo root is a build artifact. 13 14 14 15 ## Build, Test, and Development Commands
+12
assets/config/config.example.yaml
··· 310 310 # max_turns: 8 311 311 # # Set bare: true only when you authenticate with API keys or explicit settings. 312 312 # # Claude Code bare mode skips OAuth and keychain reads. 313 + # - name: "cursor" 314 + # enable: true 315 + # type: "stdio" 316 + # # Transparent proxy to Cursor CLI `agent acp` (see wrappers/acp/cursor/README.md). 317 + # command: "node" 318 + # args: ["./wrappers/acp/cursor/src/index.mjs"] 319 + # env: 320 + # # Optional: pass flags before the final `acp` subcommand, e.g. API key: 321 + # MISTERMORPH_CURSOR_ARGS: "--api-key ${CURSOR_API_KEY}" 322 + # cwd: "." 323 + # read_roots: ["."] 324 + # write_roots: ["."] 313 325 314 326 # Markdown-based memory 315 327 memory:
+32 -1
docs/acp.md
··· 29 29 - `authenticate` when the agent advertises auth methods 30 30 - `session/set_config_option` when `session/new` advertises config option ids 31 31 - client callbacks for: 32 - - `session/request_permission` 32 + - `session/request_permission` (underscore and hyphenated option kinds, e.g. Cursor’s `allow-once`) 33 33 - `fs/read_text_file` 34 34 - `fs/write_text_file` 35 35 - `terminal/create` ··· 37 37 - `terminal/wait_for_exit` 38 38 - `terminal/kill` 39 39 - `terminal/release` 40 + - conservative responses for Cursor blocking extensions (`cursor/ask_question`, `cursor/create_plan`) so the subprocess does not hang 40 41 41 42 Not supported yet: 42 43 ··· 227 228 ```bash 228 229 MISTERMORPH_ACP_CLAUDE_INTEGRATION=1 \ 229 230 go test ./internal/acpclient -run TestRunPrompt_ClaudeNativeWrapperIntegration -v 231 + ``` 232 + 233 + ## Cursor CLI (`agent acp`) 234 + 235 + The Cursor CLI exposes ACP via `agent acp` over stdio. This repository includes a **transparent stdio proxy** at `wrappers/acp/cursor/` that forwards JSON-RPC to the Cursor CLI (unlike the Codex/Claude bridges, which adapt another protocol). 236 + 237 + Prerequisites: Cursor CLI installed, `agent` on `PATH`, and authentication (`agent login` or API key / token as in the [Cursor ACP docs](https://cursor.com/docs/cli/acp)). 238 + 239 + Example: 240 + 241 + ```yaml 242 + acp: 243 + agents: 244 + - name: "cursor" 245 + enable: true 246 + type: "stdio" 247 + command: "node" 248 + args: ["./wrappers/acp/cursor/src/index.mjs"] 249 + env: 250 + MISTERMORPH_CURSOR_ARGS: "--api-key ${CURSOR_API_KEY}" 251 + cwd: "." 252 + read_roots: ["."] 253 + write_roots: ["."] 254 + ``` 255 + 256 + Opt-in live test (requires Cursor CLI and auth): 257 + 258 + ```bash 259 + MISTERMORPH_ACP_CURSOR_INTEGRATION=1 \ 260 + go test ./internal/acpclient -run TestRunPrompt_CursorACPProxyIntegration -v 230 261 ``` 231 262 232 263 ## See Also
+45 -2
internal/acpclient/client.go
··· 27 27 methodSessionSetConfig = "session/set_config_option" 28 28 methodSessionUpdate = "session/update" 29 29 methodRequestPerm = "session/request_permission" 30 + methodCursorAskQuestion = "cursor/ask_question" 31 + methodCursorCreatePlan = "cursor/create_plan" 30 32 methodReadTextFile = "fs/read_text_file" 31 33 methodWriteTextFile = "fs/write_text_file" 32 34 jsonRPCVersion = "2.0" ··· 430 432 } 431 433 byID[id] = method 432 434 } 435 + // Cursor CLI ACP advertises authenticate with methodId "cursor_login" (see Cursor docs). 436 + // Prefer it whenever the server offers it: auth may already be satisfied via `agent login` 437 + // or keys in the child process env without duplicating secrets in the parent. 438 + if _, ok := byID["cursor_login"]; ok { 439 + return "cursor_login" 440 + } 433 441 if _, ok := byID["codex-api-key"]; ok && hasEffectiveEnv(cfg, "CODEX_API_KEY") { 434 442 return "codex-api-key" 435 443 } ··· 755 763 return terminals.kill(msg.Params) 756 764 case methodTerminalRelease: 757 765 return terminals.release(msg.Params) 766 + case methodCursorAskQuestion: 767 + return handleCursorAskQuestion(msg.Params) 768 + case methodCursorCreatePlan: 769 + return handleCursorCreatePlan(msg.Params) 758 770 default: 759 771 return nil, &rpcError{Code: rpcCodeMethodNotFound, Message: "method not found"} 760 772 } 761 773 } 762 774 775 + func handleCursorAskQuestion(_ json.RawMessage) (any, *rpcError) { 776 + // Cursor blocks until the client answers; MisterMorph has no interactive UI here. 777 + return map[string]any{ 778 + "outcome": map[string]any{ 779 + "outcome": "skipped", 780 + "reason": "MisterMorph ACP client does not implement cursor/ask_question", 781 + }, 782 + }, nil 783 + } 784 + 785 + func handleCursorCreatePlan(_ json.RawMessage) (any, *rpcError) { 786 + return map[string]any{ 787 + "outcome": map[string]any{ 788 + "outcome": "rejected", 789 + "reason": "MisterMorph ACP client does not implement cursor/create_plan", 790 + }, 791 + }, nil 792 + } 793 + 763 794 func handleNotification(ctx context.Context, sessionID string, msg rpcMessage, state *runState) { 764 795 if strings.TrimSpace(msg.Method) != methodSessionUpdate { 765 796 return ··· 878 909 if len(options) == 0 { 879 910 return "", false 880 911 } 881 - for _, wanted := range []string{permissionAllowOnce, permissionAllowAlways, permissionRejectOnce} { 912 + // Codex-style uses underscores; Cursor ACP docs use hyphenated kinds (allow-once, etc.). 913 + wantedKinds := []string{ 914 + normalizePermissionKind(permissionAllowOnce), 915 + normalizePermissionKind(permissionAllowAlways), 916 + normalizePermissionKind(permissionRejectOnce), 917 + } 918 + for _, wanted := range wantedKinds { 882 919 for _, option := range options { 883 - if strings.TrimSpace(option.Kind) != wanted || strings.TrimSpace(option.OptionID) == "" { 920 + if normalizePermissionKind(option.Kind) != wanted || strings.TrimSpace(option.OptionID) == "" { 884 921 continue 885 922 } 886 923 return strings.TrimSpace(option.OptionID), true 887 924 } 888 925 } 889 926 return "", false 927 + } 928 + 929 + func normalizePermissionKind(kind string) string { 930 + k := strings.TrimSpace(strings.ToLower(kind)) 931 + k = strings.ReplaceAll(k, "_", "-") 932 + return k 890 933 } 891 934 892 935 func handleReadTextFile(sessionID string, cfg PreparedAgentConfig, raw json.RawMessage) (any, *rpcError) {
+15
internal/acpclient/client_test.go
··· 422 422 } 423 423 } 424 424 425 + func TestChoosePermissionOption_AcceptsHyphenatedKinds(t *testing.T) { 426 + optionID, ok := choosePermissionOption("tool", "edit", []struct { 427 + OptionID string `json:"optionId"` 428 + Kind string `json:"kind"` 429 + }{ 430 + {OptionID: "once", Kind: "allow-once"}, 431 + }) 432 + if !ok { 433 + t.Fatal("choosePermissionOption() returned ok=false, want true") 434 + } 435 + if optionID != "once" { 436 + t.Fatalf("optionID = %q, want %q", optionID, "once") 437 + } 438 + } 439 + 425 440 func TestRunPrompt_AuthenticatesWithConfiguredEnvVarMethod(t *testing.T) { 426 441 t.Parallel() 427 442
+80
internal/acpclient/cursor_integration_test.go
··· 1 + package acpclient 2 + 3 + import ( 4 + "context" 5 + "os" 6 + "os/exec" 7 + "path/filepath" 8 + "strings" 9 + "testing" 10 + "time" 11 + ) 12 + 13 + const cursorACPIntegrationEnv = "MISTERMORPH_ACP_CURSOR_INTEGRATION" 14 + 15 + func TestRunPrompt_CursorACPProxyIntegration(t *testing.T) { 16 + if testing.Short() { 17 + t.Skip("skipping live Cursor ACP integration test in short mode") 18 + } 19 + if strings.TrimSpace(os.Getenv(cursorACPIntegrationEnv)) != "1" { 20 + t.Skipf("set %s=1 to run the live Cursor ACP integration test", cursorACPIntegrationEnv) 21 + } 22 + if _, err := exec.LookPath("node"); err != nil { 23 + t.Skip("node is required for the live Cursor ACP integration test") 24 + } 25 + if _, err := exec.LookPath("agent"); err != nil { 26 + t.Skip("Cursor CLI `agent` is required for the live Cursor ACP integration test") 27 + } 28 + 29 + repoRoot := repoRootFromTestFile(t) 30 + wrapperPath := filepath.Join(repoRoot, "wrappers", "acp", "cursor", "src", "index.mjs") 31 + node, err := exec.LookPath("node") 32 + if err != nil { 33 + t.Skip("node is required for the live Cursor ACP integration test") 34 + } 35 + 36 + dir := t.TempDir() 37 + probePath := filepath.Join(dir, "acp_probe.txt") 38 + if err := os.WriteFile(probePath, []byte("ACP_CURSOR_SMOKE_TOKEN_20260413\n"), 0o644); err != nil { 39 + t.Fatalf("WriteFile(probePath) error = %v", err) 40 + } 41 + 42 + prepared, err := PrepareAgentConfig(AgentConfig{ 43 + Name: "cursor", 44 + Enable: true, 45 + Type: "stdio", 46 + Command: node, 47 + Args: []string{wrapperPath}, 48 + CWD: dir, 49 + ReadRoots: []string{dir}, 50 + WriteRoots: []string{dir}, 51 + }, "") 52 + if err != nil { 53 + t.Fatalf("PrepareAgentConfig() error = %v", err) 54 + } 55 + 56 + ctx, cancel := context.WithTimeout(context.Background(), 3*time.Minute) 57 + defer cancel() 58 + 59 + var events []Event 60 + result, err := RunPrompt(ctx, prepared, RunRequest{ 61 + Prompt: "Read ./acp_probe.txt and reply with exactly its full contents. " + 62 + "Do not add quotes, labels, explanations, or any extra text.", 63 + Observer: ObserverFunc(func(_ context.Context, event Event) { 64 + events = append(events, event) 65 + }), 66 + }) 67 + if err != nil { 68 + t.Fatalf("RunPrompt() error = %v", err) 69 + } 70 + if result.StopReason != "end_turn" { 71 + t.Fatalf("StopReason = %q, want %q", result.StopReason, "end_turn") 72 + } 73 + output := strings.ReplaceAll(result.Output, "\r\n", "\n") 74 + if strings.TrimSpace(output) != "ACP_CURSOR_SMOKE_TOKEN_20260413" { 75 + t.Fatalf("Output = %q, want probe token", result.Output) 76 + } 77 + if len(events) == 0 { 78 + t.Fatal("expected at least one ACP event from the Cursor proxy") 79 + } 80 + }
+38 -1
web/vitepress/docs/guide/acp.md
··· 34 34 - `session/new` 35 35 - `session/set_config_option` for option ids advertised by `session/new` 36 36 - `session/prompt` 37 - - `session/request_permission` 37 + - `session/request_permission` (including hyphenated kinds such as `allow-once` used by Cursor ACP) 38 38 - `fs/read_text_file` 39 39 - `fs/write_text_file` 40 40 - minimal `terminal/*` 41 + - conservative defaults for Cursor blocking extension methods (`cursor/ask_question` skipped, `cursor/create_plan` rejected) so the subprocess does not hang 41 42 42 43 Not supported yet: 43 44 ··· 212 213 ```bash 213 214 MISTERMORPH_ACP_CLAUDE_INTEGRATION=1 \ 214 215 go test ./internal/acpclient -run TestRunPrompt_ClaudeNativeWrapperIntegration -v 216 + ``` 217 + 218 + ## Cursor CLI (`agent acp`) 219 + 220 + The Cursor CLI runs an ACP server via `agent acp` over stdio. Unlike the Codex/Claude bridges, this repository ships a **transparent stdio proxy** that forwards JSON-RPC lines to the Cursor CLI. 221 + 222 + Install the Cursor CLI, ensure `agent` is on `PATH`, and authenticate (`agent login`, or pass keys/flags as documented in [Cursor ACP](https://cursor.com/docs/cli/acp)). 223 + 224 + Example profile: 225 + 226 + ```yaml 227 + acp: 228 + agents: 229 + - name: "cursor" 230 + enable: true 231 + type: "stdio" 232 + command: "node" 233 + args: ["./wrappers/acp/cursor/src/index.mjs"] 234 + env: 235 + MISTERMORPH_CURSOR_ARGS: "--api-key ${CURSOR_API_KEY}" 236 + cwd: "." 237 + read_roots: ["."] 238 + write_roots: ["."] 239 + ``` 240 + 241 + Notes: 242 + 243 + - `MISTERMORPH_CURSOR_COMMAND` overrides the `agent` binary path 244 + - `MISTERMORPH_CURSOR_ARGS` are extra argv tokens inserted before the final `acp` subcommand 245 + - Team MCP servers from the Cursor dashboard are not supported in ACP mode (per Cursor docs) 246 + 247 + Optional live check (requires Cursor CLI installed and authenticated): 248 + 249 + ```bash 250 + MISTERMORPH_ACP_CURSOR_INTEGRATION=1 \ 251 + go test ./internal/acpclient -run TestRunPrompt_CursorACPProxyIntegration -v 215 252 ``` 216 253 217 254 See also:
+38 -1
web/vitepress/docs/ja/guide/acp.md
··· 32 32 - `session/new` 33 33 - `session/new` が宣言した option id に対する `session/set_config_option` 34 34 - `session/prompt` 35 - - `session/request_permission` 35 + - `session/request_permission`（Cursor 側の `allow-once` のようなハイフン区切りも含む） 36 36 - `fs/read_text_file` 37 37 - `fs/write_text_file` 38 38 - 最小の `terminal/*` 39 + - Cursor ACP のブロッキング拡張は保守的なデフォルトで応答（`cursor/ask_question` はスキップ、`cursor/create_plan` は拒否） 39 40 40 41 まだ未対応: 41 42 ··· 210 211 ```bash 211 212 MISTERMORPH_ACP_CLAUDE_INTEGRATION=1 \ 212 213 go test ./internal/acpclient -run TestRunPrompt_ClaudeNativeWrapperIntegration -v 214 + ``` 215 + 216 + ## Cursor CLI（`agent acp`） 217 + 218 + Cursor CLI の `agent acp` はそのまま ACP server（stdio）です。Codex/Claude のブリッジとは異なり、本リポジトリでは **stdio の透明プロキシ** で JSON-RPC を転送します。 219 + 220 + Cursor CLI を入れ、`agent` が `PATH` にあり、認証済みであること（`agent login` や API key など、[Cursor ACP ドキュメント](https://cursor.com/docs/cli/acp) 参照）。 221 + 222 + 設定例: 223 + 224 + ```yaml 225 + acp: 226 + agents: 227 + - name: "cursor" 228 + enable: true 229 + type: "stdio" 230 + command: "node" 231 + args: ["./wrappers/acp/cursor/src/index.mjs"] 232 + env: 233 + MISTERMORPH_CURSOR_ARGS: "--api-key ${CURSOR_API_KEY}" 234 + cwd: "." 235 + read_roots: ["."] 236 + write_roots: ["."] 237 + ``` 238 + 239 + 補足: 240 + 241 + - `MISTERMORPH_CURSOR_COMMAND` で `agent` のパスを上書き可能 242 + - `MISTERMORPH_CURSOR_ARGS` は最後の `acp` の前に挿入する追加引数（空白区切り） 243 + - ダッシュボードのチーム MCP は ACP モードでは使えない（Cursor ドキュメントの通り） 244 + 245 + 任意の live 検証（Cursor CLI が入っていて認証済みの場合）: 246 + 247 + ```bash 248 + MISTERMORPH_ACP_CURSOR_INTEGRATION=1 \ 249 + go test ./internal/acpclient -run TestRunPrompt_CursorACPProxyIntegration -v 213 250 ``` 214 251 215 252 関連ページ:
+38 -1
web/vitepress/docs/zh/guide/acp.md
··· 34 34 - `session/new` 35 35 - 对 `session/new` 已声明 option id 的 `session/set_config_option` 36 36 - `session/prompt` 37 - - `session/request_permission` 37 + - `session/request_permission`（含 Cursor 文档中的 `allow-once` 等连字符形式） 38 38 - `fs/read_text_file` 39 39 - `fs/write_text_file` 40 40 - 最小 `terminal/*` 41 + - Cursor ACP 的阻塞扩展方法会返回保守默认结果（`cursor/ask_question` 跳过、`cursor/create_plan` 拒绝），避免子进程无限等待 41 42 42 43 暂时还不支持： 43 44 ··· 212 213 ```bash 213 214 MISTERMORPH_ACP_CLAUDE_INTEGRATION=1 \ 214 215 go test ./internal/acpclient -run TestRunPrompt_ClaudeNativeWrapperIntegration -v 216 + ``` 217 + 218 + ## Cursor CLI（`agent acp`） 219 + 220 + Cursor 命令行自带的 `agent acp` 本身就是 ACP server（stdio），与 Codex/Claude 的「桥接 wrapper」不同：仓库里提供的是 **透明 stdio 代理**，把 MisterMorph 的 JSON-RPC 原样转发给 Cursor CLI。 221 + 222 + 先在本机安装 Cursor CLI，保证 `agent` 在 `PATH` 中，并完成认证（`agent login`，或通过环境变量/参数传入 API key，见 [Cursor ACP 文档](https://cursor.com/cn/docs/cli/acp)）。 223 + 224 + 配置示例： 225 + 226 + ```yaml 227 + acp: 228 + agents: 229 + - name: "cursor" 230 + enable: true 231 + type: "stdio" 232 + command: "node" 233 + args: ["./wrappers/acp/cursor/src/index.mjs"] 234 + env: 235 + MISTERMORPH_CURSOR_ARGS: "--api-key ${CURSOR_API_KEY}" 236 + cwd: "." 237 + read_roots: ["."] 238 + write_roots: ["."] 239 + ``` 240 + 241 + 说明： 242 + 243 + - `MISTERMORPH_CURSOR_COMMAND` 可覆盖 `agent` 可执行文件路径 244 + - `MISTERMORPH_CURSOR_ARGS` 为 `acp` 之前的额外参数（空格分隔） 245 + - 仪表盘级团队 MCP 在 ACP 模式下不可用（以 Cursor 文档为准） 246 + 247 + 可选联调（需本机已安装并登录 Cursor CLI）： 248 + 249 + ```bash 250 + MISTERMORPH_ACP_CURSOR_INTEGRATION=1 \ 251 + go test ./internal/acpclient -run TestRunPrompt_CursorACPProxyIntegration -v 215 252 ``` 216 253 217 254 另见：
+49
wrappers/acp/cursor/README.md
··· 1 + # MisterMorph ACP Cursor proxy 2 + 3 + This wrapper is a **transparent stdio proxy** between MisterMorph (ACP client) and the Cursor CLI’s ACP server (`agent acp`). It does not translate protocols; it forwards newline-delimited JSON-RPC lines. 4 + 5 + ## Requirements 6 + 7 + - Cursor CLI `agent` on `PATH`, or set `MISTERMORPH_CURSOR_COMMAND` to the executable path. 8 + - Authentication: run `agent login`, or pass API key / token via Cursor-supported flags or env (see [Cursor ACP documentation](https://cursor.com/cn/docs/cli/acp)). 9 + 10 + ## Usage 11 + 12 + ```bash 13 + node ./wrappers/acp/cursor/src/index.mjs 14 + ``` 15 + 16 + Example ACP profile: 17 + 18 + ```yaml 19 + acp: 20 + agents: 21 + - name: "cursor" 22 + enable: true 23 + type: "stdio" 24 + command: "node" 25 + args: ["./wrappers/acp/cursor/src/index.mjs"] 26 + env: 27 + MISTERMORPH_CURSOR_ARGS: "--api-key ${CURSOR_API_KEY}" 28 + cwd: "." 29 + read_roots: ["."] 30 + write_roots: ["."] 31 + ``` 32 + 33 + ## Environment 34 + 35 + - `MISTERMORPH_CURSOR_COMMAND` — backend executable (default: `agent`) 36 + - `MISTERMORPH_CURSOR_ARGS` — extra arguments inserted **before** the final `acp` subcommand (space-separated) 37 + 38 + ## Notes 39 + 40 + - Team MCP servers from the Cursor dashboard are not supported in ACP mode (per Cursor docs); project/user `.cursor/mcp.json` may apply when the CLI runs in your project directory. 41 + 42 + ## Opt-in integration test 43 + 44 + From the repository root (Go 1.25+), with `agent` and `node` on `PATH` and Cursor CLI authenticated: 45 + 46 + ```bash 47 + MISTERMORPH_ACP_CURSOR_INTEGRATION=1 \ 48 + go test ./internal/acpclient -run TestRunPrompt_CursorACPProxyIntegration -v 49 + ```
+16
wrappers/acp/cursor/package.json
··· 1 + { 2 + "name": "@mistermorph/acp-cursor", 3 + "version": "0.1.0", 4 + "private": true, 5 + "type": "module", 6 + "description": "MisterMorph stdio proxy for Cursor CLI agent acp", 7 + "bin": { 8 + "mistermorph-acp-cursor": "./src/index.mjs" 9 + }, 10 + "scripts": { 11 + "test": "node --test" 12 + }, 13 + "engines": { 14 + "node": ">=20" 15 + } 16 + }
+5
wrappers/acp/cursor/src/index.mjs
··· 1 + #!/usr/bin/env node 2 + 3 + import { main } from "./lib.mjs"; 4 + 5 + main();
+151
wrappers/acp/cursor/src/lib.mjs
··· 1 + import { spawn } from "node:child_process"; 2 + import process from "node:process"; 3 + import readline from "node:readline"; 4 + 5 + export const WRAPPER_VERSION = "0.1.0"; 6 + 7 + export function buildBackendArgs() { 8 + const extra = normalizeString(process.env.MISTERMORPH_CURSOR_ARGS) 9 + .split(/\s+/) 10 + .filter(Boolean); 11 + return [...extra, "acp"]; 12 + } 13 + 14 + export function resolveAgentCommand(options = {}) { 15 + return ( 16 + normalizeString(options.command) || 17 + normalizeString(process.env.MISTERMORPH_CURSOR_COMMAND) || 18 + "agent" 19 + ); 20 + } 21 + 22 + /** 23 + * Transparent stdio proxy: MisterMorph ACP client <-> Cursor CLI `agent acp`. 24 + * JSON-RPC lines pass through unchanged; stderr is forwarded for CLI logs. 25 + */ 26 + export class CursorACPProxy { 27 + constructor(options = {}) { 28 + this.command = resolveAgentCommand(options); 29 + this.args = Array.isArray(options.args) ? options.args : buildBackendArgs(); 30 + this.cwd = normalizeString(options.cwd) || process.cwd(); 31 + this.env = { ...process.env, ...(isRecord(options.env) ? options.env : {}) }; 32 + this.stdin = options.stdin ?? process.stdin; 33 + this.stdout = options.stdout ?? process.stdout; 34 + this.stderr = options.stderr ?? process.stderr; 35 + this.proc = null; 36 + this.stdinRl = null; 37 + this.stdoutRl = null; 38 + this.closed = false; 39 + } 40 + 41 + start() { 42 + this.proc = spawn(this.command, this.args, { 43 + cwd: this.cwd, 44 + env: this.env, 45 + stdio: ["pipe", "pipe", "pipe"], 46 + }); 47 + 48 + this.proc.stderr.on("data", (chunk) => { 49 + this.stderr.write(chunk); 50 + }); 51 + 52 + this.proc.on("exit", (code, signal) => { 53 + if (this.closed) { 54 + return; 55 + } 56 + this.closed = true; 57 + const suffix = signal ? `signal ${signal}` : `code ${code ?? "unknown"}`; 58 + this.stderr.write(`\n[cursor-acp-proxy] backend exited (${suffix})\n`); 59 + process.exit(code ?? 1); 60 + }); 61 + 62 + this.stdinRl = readline.createInterface({ input: this.stdin }); 63 + this.stdinRl.on("line", (line) => { 64 + if (this.closed || !this.proc?.stdin || this.proc.stdin.destroyed) { 65 + return; 66 + } 67 + this.proc.stdin.write(`${line}\n`); 68 + }); 69 + this.stdinRl.on("close", () => { 70 + void this.close(); 71 + }); 72 + 73 + this.stdoutRl = readline.createInterface({ input: this.proc.stdout }); 74 + this.stdoutRl.on("line", (line) => { 75 + if (this.closed) { 76 + return; 77 + } 78 + if (line.trim() === "") { 79 + return; 80 + } 81 + this.stdout.write(`${line}\n`); 82 + }); 83 + this.stdoutRl.on("close", () => { 84 + if (!this.closed) { 85 + void this.close(); 86 + } 87 + }); 88 + } 89 + 90 + async close() { 91 + if (this.closed) { 92 + return; 93 + } 94 + this.closed = true; 95 + if (this.stdinRl) { 96 + this.stdinRl.close(); 97 + } 98 + if (this.stdoutRl) { 99 + this.stdoutRl.close(); 100 + } 101 + if (this.proc?.stdin && !this.proc.stdin.destroyed) { 102 + this.proc.stdin.end(); 103 + } 104 + if (this.proc && !this.proc.killed) { 105 + this.proc.kill(); 106 + } 107 + } 108 + } 109 + 110 + export function printHelp(stream = process.stdout) { 111 + stream.write( 112 + [ 113 + "MisterMorph ACP Cursor proxy", 114 + "", 115 + "Transparently forwards stdio JSON-RPC between MisterMorph and Cursor CLI:", 116 + " <your-command> ... <args> acp", 117 + "", 118 + "Default command is `agent` (Cursor CLI). Ensure `agent` is on PATH or set", 119 + "MISTERMORPH_CURSOR_COMMAND to the full path.", 120 + "", 121 + "Usage:", 122 + " node ./wrappers/acp/cursor/src/index.mjs", 123 + "", 124 + "Environment:", 125 + " MISTERMORPH_CURSOR_COMMAND backend executable, default: agent", 126 + " MISTERMORPH_CURSOR_ARGS extra args inserted before the final `acp`", 127 + " (space-separated, e.g. \"--api-key $CURSOR_API_KEY\")", 128 + "", 129 + "Authenticate before use: `agent login`, or pass API key / auth token via", 130 + "MISTERMORPH_CURSOR_ARGS / Cursor CLI env vars (see Cursor ACP docs).", 131 + "", 132 + ].join("\n"), 133 + ); 134 + } 135 + 136 + export function main(argv = process.argv.slice(2)) { 137 + if (argv.includes("--help") || argv.includes("-h")) { 138 + printHelp(); 139 + return; 140 + } 141 + const proxy = new CursorACPProxy(); 142 + proxy.start(); 143 + } 144 + 145 + function normalizeString(value) { 146 + return typeof value === "string" ? value.trim() : ""; 147 + } 148 + 149 + function isRecord(value) { 150 + return value !== null && typeof value === "object" && !Array.isArray(value); 151 + }
+29
wrappers/acp/cursor/test/lib.test.mjs
··· 1 + import test from "node:test"; 2 + import assert from "node:assert/strict"; 3 + 4 + import { buildBackendArgs, resolveAgentCommand } from "../src/lib.mjs"; 5 + 6 + test("buildBackendArgs appends acp and respects MISTERMORPH_CURSOR_ARGS", async (t) => { 7 + t.afterEach(() => { 8 + delete process.env.MISTERMORPH_CURSOR_ARGS; 9 + }); 10 + 11 + process.env.MISTERMORPH_CURSOR_ARGS = ""; 12 + assert.deepEqual(buildBackendArgs(), ["acp"]); 13 + 14 + process.env.MISTERMORPH_CURSOR_ARGS = "-e https://api.example.test"; 15 + assert.deepEqual(buildBackendArgs(), ["-e", "https://api.example.test", "acp"]); 16 + }); 17 + 18 + test("resolveAgentCommand respects env and options", async (t) => { 19 + t.afterEach(() => { 20 + delete process.env.MISTERMORPH_CURSOR_COMMAND; 21 + }); 22 + 23 + delete process.env.MISTERMORPH_CURSOR_COMMAND; 24 + assert.equal(resolveAgentCommand(), "agent"); 25 + assert.equal(resolveAgentCommand({ command: "/opt/cursor/bin/agent" }), "/opt/cursor/bin/agent"); 26 + 27 + process.env.MISTERMORPH_CURSOR_COMMAND = "my-agent"; 28 + assert.equal(resolveAgentCommand(), "my-agent"); 29 + });