1. Браузер → Core

POST https://chat-agent.gis-master.ru/core/message

Content-Type: application/json

{
  "text": "Покажи маршрут до SVO для TEST123. Сколько времени остаётся, если до вылета 120 минут, дорога 70, запас 30?",
  "session_id": "11111111-1111-4111-8111-111111111111",
  "request_id": "22222222-2222-4222-8222-222222222222",
  "turn_id": "22222222-2222-4222-8222-222222222222"
}

2. Core → API gateway → PostgreSQL

POST http://chat-agent_src_api_gateway:8100/api/domain/{S}/snapshots/{R}

{
  "snapshot_id": "33333333-3333-4333-8333-333333333333"
}

Снимок включает position, data_revision, demo и plans. Agent получает его идентификатор, затем читает снимок из БД.

S - сессия, R - запрос. В примерах используются вымышленные UUID и исходные демоданные.

Core → Agent: nats.agent.user123

{
  "trace_id": "UUID трассы сообщения",
  "request_id": "22222222-2222-4222-8222-222222222222",
  "correlation_id": "UUID трассы сообщения",
  "session_id": "11111111-1111-4111-8111-111111111111",
  "ts_ms": 1791320000000,
  "text": "Покажи маршрут до SVO для TEST123…",
  "turn_id": "22222222-2222-4222-8222-222222222222",
  "user_id": "user123",
  "snapshot_id": "33333333-3333-4333-8333-333333333333"
}

Agent → LLM: nats.llm.user123

{
  "mode": "agent_step",
  "input": {
    "messages": [{"role": "user",
      "content": "Покажи маршрут до SVO…"}],
    "tools": [{"type": "function", "function": {
      "name": "run_code",
      "parameters": {"type": "object",
        "properties": {"code": {"type": "string"}},
        "required": ["code"]}
    }}]
  },
  "constraints": {}
}

Справа показана часть LlmRequest: он также содержит TraceEnvelope. Реально передаются system prompt, нужная история и все 4 объявленных инструмента с полными схемами.

LLM gateway → существующий requester

POST https://nats-proxy-vllm.gis-master.ru/v1/chat/completions

{
  "model": "Qwen3.8-27B-FP8",
  "messages": [{"role": "user",
    "content": "Покажи маршрут до SVO…"}],
  "tools": [{"type": "function", "function": {
    "name": "run_code",
    "parameters": {"type": "object",
      "properties": {"code": {"type": "string"}},
      "required": ["code"]}
  }}],
  "stream": true, "temperature": 0,
  "max_tokens": 2048, "parallel_tool_calls": false,
  "stream_options": {"include_usage": true},
  "tool_choice": "auto",
  "chat_template_kwargs": {"enable_thinking": false}
}

Requester → gateway: SSE

Content-Type: text/event-stream

data: {"choices":[{"delta":{"content":"Для деморейса "},"finish_reason":null}]}

data: {"choices":[{"delta":{},"finish_reason":"stop"}]}

data: [DONE]

Tool call приходит как delta.tool_calls; аргументы могут идти частями. Gateway собирает вызов, проверяет имя и JSON Schema и только затем возвращает его Agent.

Показан один инструмент; реально передаются все 4 и полный контекст. Перед генерацией: POST /tokenize. Бюджет входа 6144 токена; ответ до 2048. Внутренний NATS subject requester → H100 в этой проверке не установлен.

Шаг A: run_code → Monty

f = flight_get(flight_number="TEST123")
r = route_preview(code="SVO")
left = (f["departure_in_minutes"]
        - f["travel_minutes"]
        - f["buffer_minutes"])
{"minutes_left": left,
 "destination": f["to"],
 "distance_km": r["distance_km"]}

120 - 70 - 30 = 20 минут

Расстояние зависит от положения самолёта в снимке. Время дороги берётся из деморейса, а не выводится из расстояния.

Шаг B: отдельный map_show_route

{
  "id": "call_route_1",
  "name": "map_show_route",
  "arguments": {
    "code": "SVO"
  }
}

Инструмент вычисляет тот же маршрут и добавляет BUILD_ROUTE в client_events. route_preview возвращает данные и сам ничего не рисует.

Чтение работает по снимку внутри Agent. Monty не имеет сети, файлов, environment или credentials: 64 МиБ и 10 секунд вычислений.

Это допустимая последовательность для примера. Модель может выбрать другой порядок; фиксированный граф TEST123 отсутствует.

LLM → Agent: chat.agent.stream

{
  "request_id": "22222222-2222-4222-8222-222222222222",
  "session_id": "11111111-1111-4111-8111-111111111111",
  "attempt_id": "22222222-2222-4222-8222-222222222222",
  "generation_id": "33333333-3333-4333-8333-333333333333",
  "generation_index": 3,
  "sequence": 1,
  "delta": "Для деморейса TEST123 осталось 20 минут. "
}

Публикуется только текст. Tool calls возвращаются в окончательном LlmResponse.data.tool_calls после проверки.

Agent → браузер: nats.events.user123

{
  "time": "2026-10-07T10:00:00.000+00:00",
  "service": "src_agent", "type": "command",
  "kind": "response_fragment",
  "data": {
    "request_id": "R", "session_id": "S",
    "attempt_id": "A", "generation_id": "G",
    "attempt_index": 0, "generation_index": 3,
    "sequence": 7, "state": "generating",
    "deadline_ms": 1791320120000,
    "delta": "Для TEST123 осталось 20 минут. "
  },
  "name": "", "uid": "UUID события"
}

S/R/A/G - сокращения UUID. UI sequence и sequence gateway различаются: Agent нумерует собственные события.

Команда карты через /ws

{
  "type": "command", "kind": "client",
  "data": {
    "command": "BUILD_ROUTE",
    "trace": {"session_id": "S", "request_id": "R",
      "attempt_id": "A", "generation_id": "G"},
    "artifacts": {"all": ["ui"], "last": "ui",
      "payload": {"ui": {"data": {"route": {
        "geometry": [[37.6, 55.7], [37.386677, 55.977486]],
        "distance_km": 33.607, "demo": true
      }}}}
    }
  }
}

Показана часть события и route. GeoJSON-совместимый порядок точек: [lon, lat]. Координаты в примере иллюстративные.

Итог на POST /core/message

{
  "ok": true, "status": "DONE",
  "session_id": "11111111-1111-4111-8111-111111111111",
  "request_id": "22222222-2222-4222-8222-222222222222",
  "result": "Для деморейса TEST123 остаётся 20 минут: 120 - 70 - 30. Маршрут до SVO показан на карте.",
  "errors": []
}

Сокращённый AgentInboundResponse: также есть trace_id, correlation_id, ts_ms, client_handler и client_events. Команда BUILD_ROUTE в client_events содержит тот же route.

WSS: /audio/ws и пакет ingress

{"type": "start", "session_id": "S",
 "format": "pcm16le", "channels": 1,
 "sample_rate": 48000}

Затем binary frames ≤ 8192 байт. Частота - фактическая частота браузера; сервер пересчитывает в 16 kHz.

{"type": "frame", "seq": 1, "sample_rate": 16000,
 "channels": 1, "sample_width": 2,
 "session_id": "S", "stream_id": "T"}

ASR → Core: JSON

webrtc.komaroff.asr.text.{S}

{
  "version": 1, "result_type": "final",
  "session_id": "S", "stream_id": "T",
  "phrase_id": "P", "revision": 2,
  "text": "Покажи маршрут до SVO для TEST123."
}

partial обновляет транскрипцию, final запускает Agent. Проверяются stream, phrase и revision, чтобы старый или повторный final не запустил запрос ещё раз.

PCM не превращается в base64 и не передаётся модели LLM. end/abort имеют тот же бинарный конверт без PCM.