ef3473db21
Complete snapshot of /opt/microdao-daarion/ from NODE1 (144.76.224.179).
This represents the actual running production code that has diverged
significantly from the previous main branch.
Key changes from old main:
- Gateway (http_api.py): expanded from ~40KB to 164KB with full agent support
- Router: new /v1/agents/{id}/infer endpoint with vision + DeepSeek routing
- Behavior Policy: SOWA v2.2 (3-level: FULL/ACK/SILENT)
- Agent Registry: config/agent_registry.yml as single source of truth
- 13 agents configured (was 3)
- Memory service integration
- CrewAI teams and roles
Excluded from snapshot: venv/, .env, data/, backups, .tgz archives
Co-authored-by: Cursor <cursoragent@cursor.com>
4.7 KiB
4.7 KiB
NATS Subjects Standards
Версія: 1.0
Статус: Canonical
Subject Naming Convention
Формат: {domain}.{event}.{qualifier}
1. Messages
message.created.{channel_id} # Нове повідомлення
message.edited.{channel_id} # Редагування
message.deleted.{channel_id} # Видалення
message.reaction.{channel_id} # Реакція
2. Attachments
attachment.created.image # Завантажено зображення
attachment.created.video # Завантажено відео
attachment.created.audio # Завантажено аудіо
attachment.created.document # Завантажено документ
attachment.parsed.image # Оброблено (vision)
attachment.parsed.audio # Оброблено (STT)
attachment.parsed.document # Оброблено (parser)
attachment.indexed.{type} # Проіндексовано в Qdrant
3. Agent Operations
agent.run.requested.{agent_id} # Запит на виконання
agent.run.started.{agent_id} # Почато виконання
agent.run.progress.{agent_id} # Прогрес (для довгих задач)
agent.run.completed.{agent_id} # Завершено успішно
agent.run.failed.{agent_id} # Помилка
# Handoff (orchestration)
agent.handoff.requested.{from}.{to} # Запит на передачу
agent.handoff.accepted.{from}.{to} # Прийнято
agent.handoff.completed.{from}.{to} # Завершено
agent.handoff.rejected.{from}.{to} # Відхилено
4. Memory Operations
memory.fact.created.{scope} # scope: user|team|public
memory.fact.updated.{scope}
memory.fact.deleted.{scope}
memory.vector.indexed.{scope} # Проіндексовано в Qdrant
memory.graph.updated.{scope} # Оновлено в Neo4j
5. Quota & Billing
quota.consumed.{user_id} # Використано ресурс
quota.blocked.{user_id} # Заблоковано (ліміт)
quota.reset.{user_id} # Скинуто (новий період)
quota.warning.{user_id} # Попередження (80%+)
6. Audit (append-only)
audit.gateway.request # Вхідний запит
audit.router.decision # Рішення маршрутизації
audit.agent.invocation # Виклик агента
audit.tool.execution # Виконання інструменту
audit.memory.access # Доступ до пам'яті
audit.auth.event # Auth події
7. Ops & Health
ops.health.{service} # Health check result
ops.alert.critical.{service} # Критична помилка
ops.alert.warning.{service} # Попередження
ops.metric.{service} # Метрика
8. Workflows (CrewAI)
workflow.started.{workflow_id} # Почато workflow
workflow.step.{workflow_id} # Крок workflow
workflow.completed.{workflow_id} # Завершено
workflow.failed.{workflow_id} # Помилка
JetStream Streams Configuration
streams:
- name: MESSAGES
subjects: ["message.>"]
retention: limits
max_msgs: 1000000
max_bytes: 10GB
max_age: 7d
- name: ATTACHMENTS
subjects: ["attachment.>"]
retention: limits
max_msgs: 100000
max_bytes: 1GB
max_age: 30d
- name: AGENT_OPS
subjects: ["agent.>"]
retention: limits
max_msgs: 500000
max_bytes: 5GB
max_age: 7d
- name: AUDIT
subjects: ["audit.>"]
retention: limits
max_msgs: -1 # unlimited
max_bytes: 100GB
max_age: 365d # 1 рік
- name: OPS
subjects: ["ops.>"]
retention: limits
max_msgs: 100000
max_bytes: 1GB
max_age: 7d
Consumer Groups
consumers:
# Parser pipeline
- name: parser-pipeline
stream: ATTACHMENTS
filter: "attachment.created.>"
deliver_policy: all
ack_policy: explicit
max_deliver: 3
# RAG indexer
- name: rag-indexer
stream: ATTACHMENTS
filter: "attachment.parsed.>"
deliver_policy: all
ack_policy: explicit
max_deliver: 3
# CrewAI workers
- name: crewai-workers
stream: AGENT_OPS
filter: "agent.run.requested.>"
deliver_policy: all
ack_policy: explicit
max_deliver: 5
Dead Letter Queue (DLQ)
dlq:
stream: DLQ
subjects: ["dlq.>"]
retention: limits
max_age: 30d
# Routing rule: після 3 retries → DLQ
# Format: dlq.{original_subject}.{error_type}
Останнє оновлення: 2026-01-19