Deployment

// kira-be/src/ai/agents/index.ts

async function runAgent(userId: string, threadId: string, message: string, groupId?: string) {
  // ① 一次调用拿到所有记忆上下文
  const memory = await fetch('http://kira-memory.internal:8080/inject', {
    method: 'POST',
    body: JSON.stringify({
      entity_id: userId,
      entity_type: 'user',
      group_id: groupId,
      query: message,
    }),
  }).then(r => r.json());

  // ② 组装 system prompt
  const systemPrompt = buildSystemPrompt({
    baseInstructions,
    userProfile: memory.profile,          // 新皮层：永远在
    groupProfile: memory.group_profile,   // 群上下文
    relevantMemories: memory.memories,    // 海马体：proactive 检索
  });

  // ③ Agent 执行（还有 memory tools 可以主动调用）
  const tools = [...existingTools, memoryAddTool, memorySearchTool];
  const result = await callLLM({ systemPrompt, tools, message });

  // ④ 异步触发记忆提取（不阻塞响应）
  await nats.publish('tasks.memory.extract', {
    entity_id: userId,
    entity_type: 'user',
    group_id: groupId,              // 群上下文单独传递
    thread_id: threadId,
    messages: result.messages,
    tool_calls: result.toolCalls,
  });

  return result;
}

// Stream
const stream = 'TASKS';          // 复用现有 stream
const subject = 'tasks.memory.extract';

// Consumer
const consumer = 'memory-worker';
const ackPolicy = AckPolicy.Explicit;
const maxDeliver = 3;
const ackWait = 60_000;          // 1 分钟（提取比视频快）

# LanceDB
LANCEDB_URI=                     # LanceDB Cloud URI
LANCEDB_API_KEY=                 # LanceDB Cloud API Key

# Supabase (复用现有)
SUPABASE_URL=                    # Supabase project URL
SUPABASE_KEY=                    # Supabase service role key

# Dragonfly (复用现有)
REDIS_URL=                       # Dragonfly URL

# NATS (复用现有)
NATS_URL=                        # NATS server URL
NATS_AUTH_TOKEN=                 # NATS auth token

# AI
VOYAGE_API_KEY=                  # Voyage embedding API
MISTRAL_API_KEY=                 # Mistral (mistral-small-latest)

# Monitoring
POSTHOG_API_KEY=                 # PostHog analytics
SENTRY_DSN=                      # Error tracking