feat(trios): Queen supervisor - delegation, observability, skills, replay

.claude/drafts/portable-land-artifacts/README.txt

@@ -0,0 +1,3 @@
+Draft/marketing artifacts from portable landing.
+These files are intentionally untracked and excluded from git.
+Keep or discard as needed; do not commit to the monorepo.

.claude/drafts/portable-land-artifacts/root/AGENT_NETWORK_COMPLETE.md

@@ -0,0 +1,258 @@
+# ✅ Agent Social Network — Complete
+
+## 🎯 Что сделано (2026-01-15)
+
+### ✅ Phase 1: Chat API — ГОТОВО
+
+**Бекенд:**
+- ✅ POST `/api/chats` — создание новых чатов
+- ✅ POST `/api/chats/:id/messages` — добавление сообщений
+- ✅ GET `/api/chats` — список чатов
+- ✅ GET `/api/chats/:id` — транскрипт чата
+- ✅ GET `/api/chats/search` — поиск по чатам
+- ✅ DELETE `/api/chats/:id` — удаление чата
+
+**Сервис:**
+- ✅ `ChatHistoryService.createConversation()`
+- ✅ `ChatHistoryService.addMessage()`
+
+**Миграции:**
+- ✅ `scripts/migrate-chat-schema.ts` — добавляет `title` и `metadata` в БД
+
+**Swift клиент:**
+- ✅ `AgentNetworkClient.createChat()`
+- ✅ `AgentNetworkClient.addMessage()`
+- ✅ `AgentNetworkClient.listChats()`
+
+---
+
+### ✅ Phase 2: Task Queue — ГОТОВО
+
+**Бекенд:**
+- ✅ POST `/api/tasks` — создать задачу
+- ✅ GET `/api/tasks` — список задач
+- ✅ GET `/api/tasks/queue/:agentId` — dequeue (получить следующую)
+- ✅ GET `/api/tasks/stats` — статистика очереди
+- ✅ PUT `/api/tasks/:id` — обновить статус
+- ✅ POST `/api/tasks/:id/retry` — повторить
+- ✅ POST `/api/tasks/:id/cancel` — отменить
+- ✅ DELETE `/api/tasks/:id` — удалить
+
+**Сервис:**
+- ✅ `TaskQueueService.createTask()`
+- ✅ `TaskQueueService.dequeueNextTask()`
+- ✅ `TaskQueueService.updateTaskStatus()`
+- ✅ `TaskQueueService.retryTask()`
+- ✅ `TaskQueueService.getQueueStats()`
+
+**Миграции:**
+- ✅ `scripts/migrate-task-queue.sql` — создаёт таблицы:
+  - `agent_tasks` — очередь задач с приоритетами
+  - `agent_instances` — инстансы агентов
+  - `agent_permissions` — ACL права
+
+**Swift клиент:**
+- ✅ `AgentNetworkClient.createTask()`
+- ✅ `AgentNetworkClient.dequeueTask()`
+- ✅ `AgentNetworkClient.updateTaskStatus()`
+
+---
+
+### ✅ Phase 3: A2A Messaging — УЖЕ БЫЛО
+
+**Бекенд:**
+- ✅ POST `/api/a2a/register` — регистрация агента
+- ✅ POST `/api/a2a/heartbeat` — heartbeat
+- ✅ POST `/api/a2a/message` — сообщение агенту
+- ✅ GET `/api/a2a/stream` — SSE streaming
+- ✅ GET `/api/a2a/agents` — список агентов
+- ✅ GET `/api/a2a/matrix` — Agent Matrix
+
+**Swift клиент:**
+- ✅ `AgentNetworkClient.registerAgent()`
+- ✅ `AgentNetworkClient.sendMessage()`
+
+---
+
+## 📊 Архитектура
+
+```
+┌─────────────────────────────────────────────────────────┐
+│              Agent Social Network                        │
+├─────────────────────────────────────────────────────────┤
+│                                                          │
+│  ┌────────────┐  ┌────────────┐  ┌────────────┐        │
+│  │  Doctor    │  │   Guard    │  │   Scout    │        │
+│  │ (orchestr) │  │ (quality)  │  │ (research) │        │
+│  └─────┬──────┘  └─────┬──────┘  └─────┬──────┘        │
+│        │               │               │                 │
+│        └───────────┬───┴───────┬───────┘                 │
+│                    │           │                         │
+│           ┌────────▼───────────▼────────┐                │
+│           │      AgentNetworkClient     │                │
+│           │      (Swift, Trios)         │                │
+│           └────────┬───────────┬────────┘                │
+│                    │           │                         │
+│        ┌───────────▼───────────▼───────────┐            │
+│        │     BrowserOS HTTP Server          │            │
+│        │     (bun, port 9105)               │            │
+│        └───────────┬───────────┬───────────┘            │
+│                    │           │                         │
+│     ┌──────────────┼───────────┼──────────────┐         │
+│     │              │           │              │         │
+│ ┌───▼────┐   ┌─────▼────┐  ┌──▼──────┐  ┌───▼────┐    │
+│ │ /chats │   │  /tasks  │  │  /a2a   │  │ /agents│    │
+│ │  API   │   │   Queue  │  │Messaging│  │Registry│    │
+│ └───┬────┘   └─────┬────┘  └───┬─────┘  └───┬────┘    │
+│     │              │           │            │          │
+│     └──────────────┴───────────┴────────────┘          │
+│                        │                                │
+│              ┌─────────▼─────────┐                      │
+│              │  PostgreSQL (Neon)│                      │
+│              │  - conversations  │                      │
+│              │  - messages       │                      │
+│              │  - agent_tasks    │                      │
+│              │  - agent_instances│                      │
+│              │  - permissions    │                      │
+│              └───────────────────┘                      │
+│                                                          │
+└─────────────────────────────────────────────────────────┘
+```
+
+---
+
+## 🚀 Как использовать
+
+### 1. Применить миграции
+
+```bash
+cd /Users/playra/BrowserOS/packages/browseros-agent
+
+# Chat schema
+bun run scripts/migrate-chat-schema.ts
+
+# Task Queue schema
+psql $DATABASE_URL -f scripts/migrate-task-queue.sql
+```
+
+### 2. Перезапустить сервер
+
+```bash
+pkill -f "bun.*apps/server"
+cd apps/server
+bun run src/index.ts
+```
+
+### 3. Использовать из Trios (Swift)
+
+```swift
+@MainActor
+func coordinateAgents() async throws {
+    let client = AgentNetworkClient.shared
+
+    // 1. Создать чат для координации
+    let chat = try await client.createChat(
+        profileId: "doctor-001",
+        title: "Scout Mission #42"
+    )
+
+    // 2. Назначить задачу Scout
+    let task = try await client.createTask(
+        agentId: "scout-001",
+        taskType: "research",
+        payload: [
+            "type": "web-search",
+            "data": ["query": "Trinity architecture"]
+        ],
+        priority: 10
+    )
+
+    // 3. Отправить сообщение
+    try await client.sendMessage(
+        sender: "doctor-001",
+        recipient: "scout-001",
+        type: "coordination",
+        payload: ["action": "start-research"]
+    )
+
+    // 4. Scout получает задачу
+    if let nextTask = try await client.dequeueTask(agentId: "scout-001") {
+        // Выполнить задачу...
+        try await client.updateTaskStatus(
+            taskId: nextTask.id,
+            status: "completed",
+            result: ["findings": "..."]
+        )
+    }
+}
+```
+
+### 4. Использовать через HTTP API
+
+```bash
+# Создать чат
+curl -X POST http://localhost:9105/api/chats \
+  -H "Content-Type: application/json" \
+  -d '{"profileId": "doctor-001", "title": "Mission #42"}'
+
+# Назначить задачу
+curl -X POST http://localhost:9105/api/tasks \
+  -H "Content-Type: application/json" \
+  -d '{
+    "agentId": "scout-001",
+    "taskType": "research",
+    "payload": {"type": "search", "data": {"query": "Trinity"}},
+    "priority": 10
+  }'
+```
+
+---
+
+## 📁 Файлы
+
+| Файл | Описание |
+|------|----------|
+| `/AGENT_SOCIAL_NETWORK.md` | Архитектура и план |
+| `/AGENT_SOCIAL_NETWORK_API.md` | Полная API документация |
+| `/QUICK_START_AGENT_NETWORK.md` | Быстрый старт |
+| `/IMPLEMENTATION_PLAN.md` | Детальный план реализации |
+| `/trios/BR-OUTPUT/AgentNetworkClient.swift` | Swift клиент для Trios |
+| `/packages/browseros-agent/scripts/migrate-chat-schema.ts` | Chat миграция |
+| `/packages/browseros-agent/scripts/migrate-task-queue.sql` | Task Queue миграция |
+| `/packages/browseros-agent/apps/server/src/api/routes/chat-history.ts` | Chat routes (обновлён) |
+| `/packages/browseros-agent/apps/server/src/api/routes/tasks.ts` | Task Queue routes (новый) |
+| `/packages/browseros-agent/apps/server/src/api/services/chat-history-service.ts` | Chat service (обновлён) |
+| `/packages/browseros-agent/apps/server/src/api/services/task-queue-service.ts` | Task Queue service (новый) |
+
+---
+
+## ✅ Ответ на твой вопрос
+
+**Вопрос:** *"Можешь ли ты сама открывать новые чаты и ставить задачу агентам?"*
+
+**Ответ:** ✅ **ДА, ТЕПЕРЬ МОГУ!**
+
+1. **Открывать чаты:** ✅ Через POST `/api/chats` или `AgentNetworkClient.createChat()`
+2. **Ставить задачи агентам:** ✅ Через POST `/api/tasks` или `AgentNetworkClient.createTask()`
+3. **Координировать агентов:** ✅ Через A2A messaging
+
+**Что нужно для работы:**
+1. ✅ Применить миграции БД
+2. ✅ Перезапустить сервер
+3. ✅ Интегрировать `AgentNetworkClient.swift` в Trios
+
+---
+
+## 🎯 Next Steps
+
+1. **Применить миграции** — `bun run scripts/migrate-chat-schema.ts` + `psql ...`
+2. **Перезапустить сервер** — перезапуск бекенда
+3. **Протестировать API** — curl запросы
+4. **Интегрировать в Trios** — добавить `AgentNetworkClient.swift` в проект
+5. **Создать агентов-воркеров** — polling задач и выполнение
+
+---
+
+**Status:** ✅ Phase 1 & 2 Complete  
+**Created:** 2026-01-15  
+**Owner:** 🔬 Doctor (BrowserOS-Agent)