ACP 사용 가이드¶

backends:
  - url: http://localhost:11434
    name: ollama
    models: ["llama3.2"]

acp:
  enabled: true

  transport:
    stdio:
      enabled: true

  capabilities:
    load_session: true
    mcp: true

  # session/prompt 요청이 "model"을 생략했을 때 사용됩니다. 위 백엔드가 실제로
  # 제공하는 모델이어야 하며, 기본 모델을 설정하지 않으면 "model"이 없는
  # 프롬프트는 -32602로 거부됩니다.
  default_model: "llama3.2"

  permissions:
    default_policy: ask_always
    auto_allow:
      - read
      - search
      - think
    always_ask:
      - edit
      - delete
      - execute

  sessions:
    max_concurrent: 10
    idle_timeout: "1h"
    storage: memory

continuum-router --config config.yaml --mode stdio

echo '{"jsonrpc":"2.0","method":"initialize","params":{"protocolVersion":1,"clientCapabilities":{"readTextFile":true,"writeTextFile":true,"terminal":false},"clientInfo":{"name":"manual-test","version":"1.0.0"}},"id":1}' \
  | continuum-router --config config.yaml --mode stdio 2>/dev/null

{"jsonrpc":"2.0","result":{"protocolVersion":1,"agentCapabilities":{"loadSession":true,"image":false,"audio":false,"embeddedContext":false,"mcp":true,"mcpCapabilities":{"acp":true}},"agentInfo":{"name":"Continuum Router","version":"2.0.0"},"authMethods":[]},"id":1}

# 라우터를 백그라운드로 시작하고 stdin/stdout을 캡처
continuum-router --config config.yaml --mode stdio 2>/dev/null &
ROUTER_PID=$!

# /proc 또는 명명된 파이프로 메시지 전송
# (실용적인 접근 방법은 아래 스크립트 예제 참조)

#!/bin/bash
# acp-test.sh: ACP 메시지 시퀀스를 라우터로 전송

CONFIG="config.yaml"

{
  # 1. 초기화
  echo '{"jsonrpc":"2.0","method":"initialize","params":{"protocolVersion":1,"clientCapabilities":{"readTextFile":true},"clientInfo":{"name":"test","version":"1.0"}},"id":1}'

  # 응답이 처리될 때까지 대기
  sleep 0.5

  # 2. 새 세션 생성
  echo '{"jsonrpc":"2.0","method":"session/new","params":{"mode":"code"},"id":2}'
  sleep 0.5

  # 3. 프롬프트 전송 (SESSION_ID를 2단계에서 받은 실제 세션 ID로 교체)
  # echo '{"jsonrpc":"2.0","method":"session/prompt","params":{"sessionId":"SESSION_ID","content":[{"type":"text","text":"Hello, what can you do?"}],"stream":false},"id":3}'
  # sleep 2

} | continuum-router --config "$CONFIG" --mode stdio 2>/dev/null

#!/usr/bin/env python3
"""ACP 클라이언트 테스트 스크립트."""

import json
import subprocess
import sys
import threading

def read_responses(proc):
    """라우터의 응답을 읽어 출력합니다."""
    for line in proc.stdout:
        resp = json.loads(line)
        print(json.dumps(resp, indent=2))

def send(proc, method, params=None, msg_id=None):
    """JSON-RPC 메시지를 전송합니다."""
    msg = {"jsonrpc": "2.0", "method": method}
    if params:
        msg["params"] = params
    if msg_id is not None:
        msg["id"] = msg_id
    proc.stdin.write(json.dumps(msg) + "\n")
    proc.stdin.flush()

proc = subprocess.Popen(
    ["continuum-router", "--config", "config.yaml", "--mode", "stdio"],
    stdin=subprocess.PIPE,
    stdout=subprocess.PIPE,
    stderr=subprocess.DEVNULL,
    text=True,
)

# 백그라운드 스레드에서 응답 읽기
reader = threading.Thread(target=read_responses, args=(proc,), daemon=True)
reader.start()

# 1. 초기화
send(proc, "initialize", {
    "protocolVersion": 1,
    "clientCapabilities": {"readTextFile": True, "writeTextFile": True},
    "clientInfo": {"name": "python-test", "version": "1.0.0"},
}, msg_id=1)

import time; time.sleep(1)

# 2. 세션 생성
send(proc, "session/new", {"mode": "code"}, msg_id=2)
time.sleep(1)

# 3. stdin을 닫아 정상 종료 유도
proc.stdin.close()
proc.wait()

IDE 프로세스
    │
    ├── 스폰: continuum-router --config config.yaml --mode stdio
    │           stdin  ← IDE가 보내는 JSON-RPC 요청
    │           stdout → IDE로 전달되는 JSON-RPC 응답
    │           stderr → 로그 (디버깅용으로 캡처 가능)
    │
    └── NDJSON으로 통신 (한 줄에 JSON 객체 하나)

const { spawn } = require("child_process");
const readline = require("readline");

const router = spawn("continuum-router", [
  "--config", "config.yaml",
  "--mode", "stdio",
]);

// NDJSON 응답 파싱
const rl = readline.createInterface({ input: router.stdout });
rl.on("line", (line) => {
  const msg = JSON.parse(line);
  console.log("Received:", JSON.stringify(msg, null, 2));
});

// 디버깅을 위해 stderr 로그 출력
router.stderr.on("data", (data) => {
  console.error("[router log]", data.toString());
});

function send(method, params, id) {
  const msg = JSON.stringify({ jsonrpc: "2.0", method, params, id });
  router.stdin.write(msg + "\n");
}

// 초기화
send("initialize", {
  protocolVersion: 1,
  clientCapabilities: { readTextFile: true, writeTextFile: true },
  clientInfo: { name: "my-ide", version: "1.0.0" },
}, 1);

// initialize 응답을 받은 후 세션 생성...
setTimeout(() => {
  send("session/new", { mode: "code" }, 2);
}, 1000);

acp:
  enabled: true
  capabilities:
    mcp: true
  mcp:
    max_connections_per_session: 5
    allowed_servers: []  # 비어 있으면 모두 허용

mcp_servers:
  - id: filesystem
    command: npx
    args: ["-y", "@modelcontextprotocol/server-filesystem", "/workspace"]
  - id: github
    command: npx
    args: ["-y", "@modelcontextprotocol/server-github"]
    env:
      GITHUB_TOKEN: "${GITHUB_TOKEN}"

// 연결
{"jsonrpc":"2.0","method":"mcp/connect","params":{"id":"filesystem"},"id":10}

// 도구 목록 조회
{"jsonrpc":"2.0","method":"mcp/message","params":{"connectionId":"<returned-uuid>","message":{"jsonrpc":"2.0","method":"tools/list","id":1}},"id":11}

// 연결 해제
{"jsonrpc":"2.0","method":"mcp/disconnect","params":{"connectionId":"<returned-uuid>"},"id":12}

{"code":-32603,"message":"Backend stream timed out","data":{"timeout":"chunk_interval","timeout_ms":30000}}

{"code":-32603,"message":"Backend stream ended before the reply finished"}

# ACP 상태 확인
curl http://localhost:8080/admin/acp/status

# 활성 세션 보기
curl http://localhost:8080/admin/acp/sessions

# 에이전트 메타데이터 가져오기
curl http://localhost:8080/admin/acp/agent.json

continuum-router --config config.yaml --mode stdio 2>router.log
# 그런 다음 router.log에서 오류 확인

acp:
  permissions:
    default_policy: ask_always  # 프로덕션에서는 "allow_all"을 사용하지 마세요
    auto_allow:
      - read
      - search
      - think