把编程 Agent 变成真实队友

export const agentTaskSnapshotKeys = {
  all: (wsId: string) => ["workspaces", wsId, "agent-task-snapshot"] as const,
  list: (wsId: string) => [...agentTaskSnapshotKeys.all(wsId), "list"] as const,
};

export function agentTaskSnapshotOptions(wsId: string) {
  return queryOptions({
    queryKey: agentTaskSnapshotKeys.list(wsId),
    queryFn: () => api.getAgentTaskSnapshot(),
    staleTime: 30 * 1000,        // 仅作 fallback；主刷新信号是 WS 任务事件
    refetchOnWindowFocus: true,
  });
}

task: () => {
  const wsId = getCurrentWsId();
  if (!wsId) return;
  qc.invalidateQueries({ queryKey: agentTaskSnapshotKeys.list(wsId) });
  qc.invalidateQueries({ queryKey: agentActivityKeys.last30d(wsId) });
  qc.invalidateQueries({ queryKey: agentRunCountsKeys.last30d(wsId) });
  qc.invalidateQueries({ queryKey: agentTasksKeys.all(wsId) });
  qc.invalidateQueries({ queryKey: ["issues", "tasks"] });  // 前缀匹配所有 issue
}
// task:message 故意不走该前缀——长任务每条流式消息都来一次会引发失效风暴。

"import-x/no-extraneous-dependencies": ["error", {
  devDependencies: [ "**/*.test.{ts,tsx}", "**/test/**",
    "**/electron.vite.config.*", "**/src/main/**", "**/src/preload/**", /* … */ ],
  peerDependencies: true,
}];

func (s *TaskService) enqueueIssueTask(ctx, issue, triggerCommentID, forceFreshSession) (db.AgentTaskQueue, error) {
    if !issue.AssigneeID.Valid { return ..., fmt.Errorf("issue has no assignee") }
    agent, _ := s.Queries.GetAgent(ctx, issue.AssigneeID)
    if agent.ArchivedAt.Valid { return ..., fmt.Errorf("agent is archived") }
    if !agent.RuntimeID.Valid { return ..., fmt.Errorf("agent has no runtime") }

    task, _ := s.Queries.CreateAgentTask(ctx, db.CreateAgentTaskParams{
        AgentID: issue.AssigneeID, RuntimeID: agent.RuntimeID, IssueID: issue.ID,
        Priority: priorityToInt(issue.Priority),
        TriggerCommentID: triggerCommentID,
        TriggerSummary:   s.buildCommentTriggerSummary(ctx, triggerCommentID), // 200 rune 摘要
        ForceFreshSession: ...,
    })
    // 先广播 queued，再通知 daemon——保证客户端按 queued→dispatch 顺序观测
    s.broadcastTaskEvent(ctx, protocol.EventTaskQueued, task)
    s.NotifyTaskEnqueued(ctx, task)
}

func (s *TaskService) ClaimTask(ctx, agentID) (*db.AgentTaskQueue, error) {
    agent, _ := s.Queries.GetAgent(ctx, agentID)
    running, _ := s.Queries.CountRunningTasks(ctx, agentID)
    if running >= int64(agent.MaxConcurrentTasks) { return nil, nil }  // 无容量
    task, err := s.Queries.ClaimAgentTask(ctx, agentID)                  // 原子取下一条 queued
    if errors.Is(err, pgx.ErrNoRows) { return nil, nil }
    s.ReconcileAgentStatus(ctx, agentID)
    s.broadcastTaskDispatch(ctx, task)
}

-- name: AddAgentSkill :exec
INSERT INTO agent_skill (agent_id, skill_id) VALUES ($1, $2) ON CONFLICT DO NOTHING;

-- name: ListAgentSkills :many
SELECT s.* FROM skill s JOIN agent_skill ask ON ask.skill_id = s.id
WHERE ask.agent_id = $1 ORDER BY s.name ASC;

export interface NavigationAdapter {
  push(path: string): void; replace(path: string): void; back(): void;
  pathname: string; searchParams: URLSearchParams;
  getShareableUrl: (path: string) => string;
  openInNewTab?: (path, title?, opts?) => void;   // 仅 desktop
  prefetch?: (path: string) => void;               // 仅 web → router.prefetch
}

push: (path) => {
  if (path === "/login") { useAuthStore().getState().logout(); return; }
  if (tryRouteToOverlay(path, active?.router)) return;        // /workspaces/new 等 → WindowOverlay
  if (tryRouteToOtherWorkspace(path)) return;                 // 跨工作区 → switchWorkspace(slug,path)
  if (tryRouteToPinnedNewTab(path)) return;                   // 钉住 tab 的 push → 开新 tab
  active?.router.navigate(path);
}

packages:
  - "apps/*"
  - "packages/*"
catalog:
  react: "19.2.3"
  zustand: "^5.0.0"
  "@tanstack/react-query": "^5.96.2"
  zod: "^4.1.5"          # 防御 API 漂移
  tailwindcss: "^4"
  vitest: "^4.1.0"

{
  "tasks": {
    "build":     { "dependsOn": ["^build"], "outputs": [".next/**","dist/**","out/**"] },
    "dev":       { "cache": false, "persistent": true },
    "typecheck": { "dependsOn": ["^typecheck"] },
    "test":      { "dependsOn": ["^typecheck"] },
    "lint":      { "dependsOn": ["^typecheck"] }
  }
}