Function createMockMessageGenerator

frontend/src/mock.ts:96–183

(onMessage: (msg: WSMessage) => void)

}

export function createMockMessageGenerator(onMessage: (msg: WSMessage) => void): () => void {
  const intervals: number[] = [];
  const agents = [...INITIAL_AGENTS];
  const agentMap = new Map(agents.map((a) => [a.id, { ...a }]));

  const emitAgentActivity = () => {
    const agent = pick(agents);
    const state = agentMap.get(agent.id)!;
    const layerStages = LAYER_META[agent.layer].stages;
    const roll = Math.random();

    if (roll < 0.5 && state.status !== 'working') {
      const stage = pick(layerStages);
      state.status = 'working';
      state.currentStage = stage;
      state.currentTask = pick(TASK_DETAILS[stage] || ['处理中...']);
      state.stageProgress[stage] = 'running';
    } else if (roll < 0.75 && state.currentStage) {
      state.stageProgress[state.currentStage] = 'completed';
      state.status = 'done';
      state.currentTask = '';

      const repo = stageToRepo(state.currentStage);
      if (repo) {
        const outputs = STAGE_META[state.currentStage].outputs;
        const file = pick(outputs);
        const artifact: Artifact = {
          id: uid(),
          repoId: repo,
          projectId: agent.runId,
          filename: file,
          producedBy: agent.name,
          timestamp: Date.now(),
          size: `${(Math.random() * 100 + 1).toFixed(1)} KB`,
          status: 'fresh',
        };
        onMessage({ type: 'artifact_produced', payload: artifact });
      }

      const nextStage = state.currentStage;
      state.currentStage = null;
      onMessage({
        type: 'stage_update',
        payload: { agentId: agent.id, stage: nextStage, status: 'completed' },
      });
    } else if (roll < 0.85 && state.currentStage) {
      state.stageProgress[state.currentStage] = 'failed';
      state.status = 'error';
      state.currentTask = '执行失败，等待重试...';
    } else {
      state.status = 'idle';
      state.currentStage = null;
      state.currentTask = '';
    }

    agentMap.set(agent.id, { ...state });
    onMessage({ type: 'agent_update', payload: { ...state } });