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  # 无需额外配置

client = SmartBrain::Adapters::SmartRag::HttpClient.for_url(
  base_url: 'http://127.0.0.1:9393',
  timeout_seconds: 30,
  headers: { 'Authorization' => "Bearer #{ENV.fetch('SMARTRAG_TOKEN')}" }
)
SmartBrain.configure(smart_rag_client: client)

SmartBrain.add_video(source: '/data/demo.mp4', options: { tags: ['demo'] })

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)

SmartBrain.add_image(
  source: '/data/whiteboard.jpg',
  options: {
    title: 'Q3 路线图白板',
    tags: ['roadmap'],
    image_describer: ->(path) { vision_client.describe(path) },
    ocr_extractor: ->(path) { ocr_client.extract(path) }
  }
)

SmartBrain.add_audio(
  source: '/data/weekly-meeting.wav',
  options: {
    tags: ['meeting'],
    audio_transcriber: ->(path) { whisper_client.transcribe(path) }
  }
)

SmartBrain.add_video(
  source: '/data/product-demo.mp4',
  options: {
    tags: ['demo'],
    # start/end 使用秒；也可以返回 start_ms/end_ms。
    video_transcriber: ->(audio_path) {
      whisper_client.transcribe(audio_path, timestamps: true)
      # => { segments: [{ text: '打开设置', start: 5.0, end: 9.0 }] }
    },
    frame_describer: ->(frame_path, timestamp_ms) {
      vision_client.describe(frame_path, timestamp_ms: timestamp_ms)
    },
    frame_interval_seconds: 30,
    max_frames: 12
  }
)

SmartBrain.compose_context(
  session_id: 'demo',
  user_message: '查资料：路线图白板上写了什么？',
  resource_filters: { media_type: ['image'] }
)

job = SmartBrain.enqueue_media(
  source: '/data/long-demo.mp4',
  options: { media_type: 'video', tags: ['demo'] }
)
status = SmartBrain.media_job(job_id: job[:job_id])

failed = SmartBrain.media_jobs(status: 'failed', limit: 20)
SmartBrain.retry_media_job(job_id: failed[:jobs].first[:id])
SmartBrain.cancel_media_job(job_id: job[:job_id]) # 仅 queued 状态可取消
queue = SmartBrain.media_job_statistics

job = SmartBrain.enqueue_media(
  source: '/data/long-demo.mp4',
  options: { media_type: 'video', idempotency_key: 'demo-video-v1' }
)