Agent SDK, Claude Code를 코드에서 부른다

node -v                        # 18 이상, 랩 EC2는 22
mkdir -p ~/agentlab && cd ~/agentlab
npm init -y > /dev/null
npm install @anthropic-ai/claude-agent-sdk zod
claude /status                 # CLI 인증이 살아 있으면 SDK도 그대로 동작

cat > hello.mjs << 'HELLOEOF'
// T1: 첫 query, CLI의 프로그래매틱 쌍둥이
import { query } from "@anthropic-ai/claude-agent-sdk";

const q = query({
  prompt: "이 디렉토리의 파일 목록을 보고 한 줄 소감을 말해줘",
  options: { allowedTools: ["Read", "Glob"], maxTurns: 3 },
});

for await (const m of q) {
  if (m.type === "assistant") {
    for (const b of m.message.content) if (b.type === "text") process.stdout.write(b.text);
  }
  if (m.type === "result") {
    console.log(`\n--- session=${m.session_id} turns=${m.num_turns} cost=$${m.total_cost_usd}`);
  }
}
HELLOEOF
node hello.mjs

cat > chat.mjs << 'CHATEOF'
// T2: 대화 메모리, session_id를 resume으로 잇는다
import readline from "node:readline/promises";
import { query } from "@anthropic-ai/claude-agent-sdk";

const rl = readline.createInterface({ input: process.stdin, output: process.stdout });
let sessionId;

while (true) {
  const line = (await rl.question("나> ")).trim();
  if (!line || line === "exit") break;

  const q = query({
    prompt: line,
    options: { resume: sessionId, allowedTools: [], maxTurns: 1 },
  });
  for await (const m of q) {
    if (m.type === "assistant") {
      for (const b of m.message.content) if (b.type === "text") process.stdout.write(b.text);
    }
    if (m.type === "result") { sessionId = m.session_id; process.stdout.write("\n"); }
  }
}
rl.close();
CHATEOF
node chat.mjs

cat > notes-agent.mjs << 'NOTESEOF'
// T3: 커스텀 도구, 내 함수가 에이전트의 손이 된다 (in-process MCP)
import { query, tool, createSdkMcpServer } from "@anthropic-ai/claude-agent-sdk";
import { z } from "zod";

const NOTES = [
  "7월 회식은 24일 목요일 19시, 장소는 을지로 골뱅이집",
  "배포 원칙: 금요일 오후에는 프로덕션 배포를 하지 않는다",
  "신규 입사자 온보딩: 버디가 2주간 매일 30분 페어링",
];

const searchNote = tool(
  "search_note",
  "사내 노트에서 키워드가 포함된 문장을 찾는다",
  { keyword: z.string().describe("찾을 키워드") },
  async ({ keyword }) => ({
    content: [{
      type: "text",
      text: NOTES.filter((n) => n.includes(keyword)).join("\n") || "일치하는 노트 없음",
    }],
  }),
);

const shelf = createSdkMcpServer({ name: "shelf", version: "1.0.0", tools: [searchNote] });

const q = query({
  prompt: process.argv[2] ?? "다음 회식이 언제 어디서인지 노트에서 찾아 알려줘",
  options: {
    mcpServers: { shelf },
    allowedTools: ["mcp__shelf__search_note"],
    maxTurns: 5,
    systemPrompt: "당신은 사내 노트 사서다. 반드시 search_note 도구로 찾은 내용만 근거로 답한다.",
  },
});

for await (const m of q) {
  if (m.type === "assistant") {
    for (const b of m.message.content) if (b.type === "text") process.stdout.write(b.text);
  }
  if (m.type === "result") console.log(`\n--- turns=${m.num_turns}`);
}
NOTESEOF
node notes-agent.mjs
node notes-agent.mjs "금요일에 배포해도 돼?"

echo "service: OK" > status.txt
cat > medic-lite.mjs << 'MEDLITEEOF'
// T4: 미니 상주 점검원, 프로세스를 넘어 기억하는 에이전트
import { query } from "@anthropic-ai/claude-agent-sdk";
import { readFileSync, writeFileSync, existsSync } from "node:fs";

const prev = existsSync(".medic-session")
  ? readFileSync(".medic-session", "utf8").trim()
  : undefined;

const q = query({
  prompt: "status.txt를 읽고 서비스 상태를 두 줄로 보고해. DOWN이면 원인 후보와 첫 조치를 제안해. 이전 점검 기록이 있으면 상태 변화를 먼저 언급해.",
  options: { resume: prev, allowedTools: ["Read"], maxTurns: 4 },
});

for await (const m of q) {
  if (m.type === "assistant") {
    for (const b of m.message.content) if (b.type === "text") process.stdout.write(b.text);
  }
  if (m.type === "result") {
    writeFileSync(".medic-session", m.session_id);
    console.log(`\n--- 점검 완료, turns=${m.num_turns} cost=$${m.total_cost_usd}`);
  }
}
MEDLITEEOF
node medic-lite.mjs

echo "service: DOWN (connection refused)" > status.txt
node medic-lite.mjs

cd ~/claude-lab/ch1 && claude