SmartBrain

{
  ok: true,
  commit_id: "uuid",
  session_id: "...",
  turn_id: "uuid",
  memory_written: { count: 3, items: [...], conflicts: [...] },
  summary: { triggered: true, trigger_reason: "turn_threshold", text: "..." },
  explain: { retention: [...], conflicts: [...], summary: {...} }
}

scope_context = {
  read: [
    { type: 'global', id: 'default' },
    { type: 'project', id: 'project-001' },
    { type: 'task', id: 'task-030' }
  ],
  write: [
    { type: 'project', id: 'project-001' },
    { type: 'task', id: 'task-030' }
  ],
  default_write: { type: 'task', id: 'task-030' }
}

SmartBrain.commit_turn(
  domain_id: 'tenant-a', session_id: 'conversation-1', scope_context: scope_context,
  turn_events: { decisions: [{ key: 'decision:db', decision: 'use PostgreSQL' }] }
)

{
  version: '0.1',
  context_id: "uuid",               # 本次装配唯一 ID
  session_id: "...",
  working_summary: "...",           # 滚动摘要文本
  recent_turns: [...],              # 最近 N 轮对话
  evidence: [                       # 融合后的证据列表
    {
      id: "...",
      source: 'memory' | 'resource',
      source_uri: "...",
      title: "...",
      snippet: "...",
      mode: 'exact' | 'relational' | 'hybrid',
      score: 0.85,
      ref: { memory_item_id: "..." }
    }
  ],
  user_message: { role: 'user', content: "..." },
  constraints: {
    token_budget: { limit: 8000, used_estimate: 1200 },
    diversity: { by_document: 3, by_source: 2 },
    truncation: { snippets_max_chars: 800, recent_turns_max: 8 }
  },
  debug: {
    trace: { request_id: "uuid", plan_id: "uuid", context_id: "uuid" },
    planner: { purpose: "qa", queries: ["..."] },
    why_selected: ["item-1 score=0.85 source=memory"],
    ignored: [],
    dropped: [{ id: "...", reason: "diversity" }]
  }
}

{
  compose_logs: [...],
  commit_logs: [...],
  metrics: {
    compose_p95_ms: 45.2,
    memory_resource_ratio: "3/2",
    token_over_budget_rate: 0.0
  }
}

require_relative 'lib/smart_brain'

SmartBrain.configure

SmartBrain.commit_turn(
  session_id: 'demo',
  turn_events: {
    messages: [
      { role: 'user', content: '请记住：默认数据库是 Postgres。' },
      { role: 'assistant', content: '已记录。' }
    ],
    decisions: [
      { key: 'decision:smartbrain:storage', decision: 'Use Postgres by default' }
    ]
  }
)

context = SmartBrain.compose_context(
  session_id: 'demo',
  user_message: '继续并总结关键结论'
)

puts context[:context_id]
puts context.dig(:debug, :trace, :request_id)
puts context.dig(:debug, :trace, :plan_id)

require 'smart_brain'
require 'smart_agent'
require 'smart_rag'
require_relative 'lib/smart_brain/adapters/smart_rag/direct_client'

# 1. 初始化 SmartRAG
rag = SmartRAG::SmartRAG.new(database: {...}, llm: {...})
client = SmartBrain::Adapters::SmartRag::DirectClient.new(rag: rag)

# 2. 初始化 SmartBrain
SmartBrain.configure(smart_rag_client: client)

# 3. 初始化 SmartAgent
engine = SmartAgent::Engine.new('./config/example_agent.yml')
agent = engine.build_agent(:brain_assistant)

# 4. 多轮对话循环
session_id = "demo-session"
user_message = "Ruby 类名应该用什么命名风格？"

# 4a. 获取上下文（内部可能调用 SmartRAG 检索文档资源）
context = SmartBrain.compose_context(
  session_id: session_id,
  user_message: user_message,
  agent_state: { turn: 1 }
)

# 4b. 调用 Agent（LLM）生成回复
response = agent.please(context.to_json)

# 4c. 提交本轮（沉淀记忆）
commit = SmartBrain.commit_turn(
  session_id: session_id,
  turn_events: {
    messages: [
      { role: 'user', content: user_message },
      { role: 'assistant', content: response.to_s }
    ],
    decisions: [
      { key: 'decision:ruby:class_naming', decision: '使用 CamelCase' }
    ],
    entities: [
      { key: 'entity:lang:ruby', name: 'Ruby', canonical: 'ruby', kind: 'language', remember: true }
    ]
  }
)

# 5. 查看诊断信息
pp SmartBrain.diagnostics

SmartBrain.configure  # 无需额外配置

transport = lambda do |plan, timeout_seconds:|
  {
    plan_id: 'p1',
    supports_language_filter: true,
    evidences: []
  }
end

scope_mapper = lambda do |domain_id:, scopes:|
  { filters: { topic_ids: scopes.map { |scope| "#{domain_id}:#{scope[:type]}:#{scope[:id]}" } } }
end
client = SmartBrain::Adapters::SmartRag::HttpClient.new(
  transport: transport, timeout_seconds: 2, scope_mapper: scope_mapper
)
SmartBrain.configure(smart_rag_client: client)

require 'smart_rag'
require_relative 'lib/smart_brain/adapters/smart_rag/direct_client'

rag_config = SmartRAG::Config.load(ENV.fetch('SMARTRAG_CONFIG_PATH'))
rag = SmartRAG::SmartRAG.new(rag_config)
scope_mapper = lambda do |domain_id:, scopes:|
  { filters: { topic_ids: scopes.map { |scope| "#{domain_id}:#{scope[:type]}:#{scope[:id]}" } } }
end
client = SmartBrain::Adapters::SmartRag::DirectClient.new(rag: rag, scope_mapper: scope_mapper)

SmartBrain.configure(smart_rag_client: client)