Краткое руководство по DaemonClient (TypeScript)

qwen serve --port 4170 \
  --workspace /path/to/project-a \
  --workspace /path/to/project-b
# → qwen serve listening on http://127.0.0.1:4170 (mode=http-bridge, workspace=/path/to/project-a)

npm install @qwen-code/sdk

import { DaemonClient, type DaemonEvent } from '@qwen-code/sdk';
 
const client = new DaemonClient({
  baseUrl: 'http://127.0.0.1:4170',
  // PR 27 (v0.16-alpha): когда `token` опущен, DaemonClient автоматически
  // использует `process.env.QWEN_SERVER_TOKEN` — та же переменная
  // окружения, к которой обращается флаг `--token` демона. То есть:
  //   export QWEN_SERVER_TOKEN="$(openssl rand -hex 32)"   # одноразовый
  //   export QWEN_SERVER_TOKEN="$(cat ./my-token-file)"    # файл, управляемый пользователем
  //   const client = new DaemonClient({ baseUrl: '...' });
  // ИЛИ передайте его явно, если у вас другое имя переменной:
  //   token: process.env.MY_TOKEN,
});
 
// 1. Убедимся, что можем связаться с демоном, узнаем его возможности и
//    выберем доверенное рабочее пространство из анонсированного каталога.
const caps = await client.capabilities();
console.log('Daemon features:', caps.features);
const selectedWorkspace =
  caps.workspaces?.find(
    (workspace) => workspace.trusted && !workspace.primary,
  ) ?? caps.workspaces?.find((workspace) => workspace.trusted);
if (!selectedWorkspace) throw new Error('No trusted workspace is available');
console.log('Selected workspace:', selectedWorkspace.id, selectedWorkspace.cwd);
 
// 2. Создать или подключиться к сессии в этой среде выполнения.
//    SDK сопоставляет `workspaceCwd` с полем `cwd` в POST /session.
//    Пропуск допустим только когда вызывающий код намеренно
//    хочет устаревшее основное значение по умолчанию.
const session = await client.createOrAttachSession({
  workspaceCwd: selectedWorkspace.cwd,
});
console.log(`session=${session.sessionId} attached=${session.attached}`);
 
// 3. Подписаться на поток событий. Передайте `lastEventId: 0`, чтобы демон
//    воспроизвёл все события с начала сессии — без этого существует
//    окно TOCTOU между моментом возврата итератора из `subscribeEvents()`
//    и фактическим открытием SSE-соединения (один круг запроса-ответа),
//    во время которого быстрый агент может испустить события, которые
//    попадут в кольцевой буфер сессии, но не будут переданы новому подписчику
//    без курсора. `lastEventId: 0` перекрывает этот пробел (и любое
//    переподключение — см. ниже).
const abort = new AbortController();
const subscription = (async () => {
  for await (const event of client.subscribeEvents(session.sessionId, {
    signal: abort.signal,
    lastEventId: 0,
  })) {
    handleEvent(event);
  }
})();
 
// 4. Отправить запрос и дождаться завершения. (Замечание о порядке операций:
//    даже если `prompt()` выполнится до завершения рукопожатия SSE,
//    `lastEventId: 0` на шаге 3 гарантирует, что все события попадут
//    в итератор.)
const result = await client.prompt(session.sessionId, {
  prompt: [{ type: 'text', text: 'Опиши src/main.ts одной строкой.' }],
});
console.log('stop reason:', result.stopReason);
 
// 5. Завершить подписку, чтобы скрипт мог выйти.
abort.abort();
await subscription;
 
function handleEvent(event: DaemonEvent): void {
  switch (event.type) {
    case 'session_update': {
      const data = event.data as {
        sessionUpdate: string;
        content?: { text?: string };
      };
      if (data.sessionUpdate === 'agent_message_chunk' && data.content?.text) {
        process.stdout.write(data.content.text);
      }
      break;
    }
    case 'permission_request':
      // См. "Голосование по разрешениям" ниже о семантике первого ответившего.
      console.log('\n[требуется разрешение]', event.data);
      break;
    case 'permission_resolved':
      console.log('\n[разрешение получено]', event.data);
      break;
    case 'session_died':
      console.error('\n[агент упал]', event.data);
      break;
    default:
      console.log(`\n[${event.type}]`, event.data);
  }
}

const selected = client.workspaceById(selectedWorkspace.id);
const file = await selected.readWorkspaceFile('src/main.ts');
 
const updated = await selected.editWorkspaceFile({
  path: 'src/main.ts',
  oldText: 'timeout: 30000',
  newText: 'timeout: 60000',
  expectedHash: file.hash!,
});
 
console.log(updated.hash);

let cursor: number | undefined;
 
for await (const event of client.subscribeEvents(session.sessionId, {
  signal: abort.signal,
  lastEventId: cursor, // возобновить после этого id; undefined = только новые
})) {
  if (typeof event.id === 'number') cursor = event.id;
  handleEvent(event);
}

case 'permission_request': {
  const req = event.data as {
    requestId: string;
    options: Array<{ optionId: string; name: string; kind: string }>;
  };
  // Выберите любой вариант — `proceed_once`, `allow` и т.д.
  const choice = req.options.find((o) => o.kind === 'allow_once') ?? req.options[0];
  const accepted = await client.respondToPermission(req.requestId, {
    outcome: { outcome: 'selected', optionId: choice.optionId },
  });
  if (!accepted) {
    console.log('Другой клиент проголосовал первым; ничего не делать.');
  }
  break;
}

// Демон запущен как `qwen serve --workspace /work/repo`, поэтому
// `caps.workspaceCwd === '/work/repo'` для обоих клиентов.
 
// Клиент A (например, плагин для IDE)
const a = await clientA.createOrAttachSession({ workspaceCwd: '/work/repo' });
console.log(a.attached); // false — A запустил агента
 
// Клиент B (например, веб-интерфейс на той же машине)
const b = await clientB.createOrAttachSession({ workspaceCwd: '/work/repo' });
console.log(b.attached); // true — B присоединился к сессии A
console.log(a.sessionId === b.sessionId); // true

import { DaemonHttpError } from '@qwen-code/sdk';
 
try {
  await client.createOrAttachSession({ workspaceCwd: '/some/other/project' });
} catch (err) {
  if (err instanceof DaemonHttpError && err.status === 400) {
    const body = err.body as {
      code?: string;
      boundWorkspace?: string;
      requestedWorkspace?: string;
    };
    if (body.code === 'workspace_mismatch') {
      console.error(
        `Рабочее пространство ${body.requestedWorkspace} не зарегистрировано. ` +
          `Обновите возможности и выберите зарегистрированное рабочее пространство ` +
          `или зарегистрируйте его перед повторной попыткой.`,
      );
    }
  }
}

const client = new DaemonClient({
  baseUrl: 'https://your-host:4170',
  token: process.env.QWEN_SERVER_TOKEN,
});

// То же самое, что token: process.env.QWEN_SERVER_TOKEN, но без шаблонного кода.
const client = new DaemonClient({ baseUrl: 'https://your-host:4170' });

import { DaemonHttpError } from '@qwen-code/sdk';
 
try {
  await client.health();
} catch (err) {
  if (err instanceof DaemonHttpError) {
    console.error(`Ошибка демона ${err.status}:`, err.body);
  } else {
    throw err;
  }
}

await client.cancel(session.sessionId);
// В потоке событий запрос завершится с stopReason: "cancelled"