Phase 2: Fix 7 critical bugs from production audit

agent/pipeline_runtime.py

@@ -200,9 +200,11 @@ def build_meeting_result(state: dict) -> dict:
     if pipeline_succeeded:
         verdict = "GO"
 
-    score = scoring.get("final_score", 0)
-    if not score and isinstance(code_eval_result.get("match_rate"), (int, float)):
+    score = scoring.get("final_score")
+    if score is None and isinstance(code_eval_result.get("match_rate"), (int, float)):
         score = code_eval_result.get("match_rate", 0)
+    if score is None:
+        score = 0
 
     return {
         "score": score,

web/src/app/error.tsx

@@ -10,7 +10,16 @@ export default function GlobalError({ error, reset }: { error: Error & { digest?
     const isChunkError = message.includes("ChunkLoadError") || message.includes("Failed to load chunk");
     if (!retriedRef.current && isChunkError) {
       retriedRef.current = true;
-      window.location.reload();
+      try {
+        const reloadKey = "vibedeploy_chunk_reload_count";
+        const count = Number(sessionStorage.getItem(reloadKey) || "0");
+        if (count < 2) {
+          sessionStorage.setItem(reloadKey, String(count + 1));
+          window.location.reload();
+        }
+      } catch {
+        // sessionStorage unavailable (e.g., Safari private mode)
+      }
     }
   }, [error]);
 

web/src/app/result/[id]/page.tsx

@@ -46,9 +46,13 @@ export default function ResultPage() {
   useEffect(() => {
     let mounted = true;
 
-    getMeetingResult(params.id).then((next) => {
-      if (mounted) setResult(next);
-    });
+    getMeetingResult(params.id)
+      .then((next) => {
+        if (mounted) setResult(next);
+      })
+      .catch(() => {
+        if (mounted) setResult(null);
+      });
 
     return () => {
       mounted = false;

web/src/components/brainstorm/brainstorm-view.tsx

@@ -87,22 +87,56 @@ export function BrainstormView({ sessionId }: { sessionId: string }) {
   );
 
   useEffect(() => {
-    const stop = createSSEClient({
-      url: `${DASHBOARD_API_URL}/brainstorm`,
-      body: {
-        prompt: "Run brainstorm and stream all events.",
-        config: { configurable: { thread_id: sessionId } },
-      },
-      onEvent: handleEvent,
-      onComplete: () => {
+    let stopFn: (() => void) | undefined;
+    let cancelled = false;
+
+    // Check if result already exists (page refresh case)
+    getBrainstormResult(sessionId).then((existing) => {
+      if (cancelled) return;
+      if (existing) {
+        setResult(existing);
         setStreamCompleted(true);
-        getBrainstormResult(sessionId).then((res) => {
-          if (res) setResult(res);
-        });
-      },
-      onError: (err) => setError(err.message),
+        return;
+      }
+
+      stopFn = createSSEClient({
+        url: `${DASHBOARD_API_URL}/brainstorm`,
+        body: {
+          prompt: "Run brainstorm and stream all events.",
+          config: { configurable: { thread_id: sessionId } },
+        },
+        onEvent: handleEvent,
+        onComplete: () => {
+          setStreamCompleted(true);
+          getBrainstormResult(sessionId).then((res) => {
+            if (res) setResult(res);
+          });
+        },
+        onError: (err) => setError(err.message),
+      });
+    }).catch(() => {
+      if (cancelled) return;
+      stopFn = createSSEClient({
+        url: `${DASHBOARD_API_URL}/brainstorm`,
+        body: {
+          prompt: "Run brainstorm and stream all events.",
+          config: { configurable: { thread_id: sessionId } },
+        },
+        onEvent: handleEvent,
+        onComplete: () => {
+          setStreamCompleted(true);
+          getBrainstormResult(sessionId).then((res) => {
+            if (res) setResult(res);
+          });
+        },
+        onError: (err) => setError(err.message),
+      });
     });
-    return stop;
+
+    return () => {
+      cancelled = true;
+      stopFn?.();
+    };
   }, [handleEvent, sessionId]);
 
   const synthesis = result?.synthesis;

web/src/components/meeting/meeting-view.tsx

@@ -152,26 +152,48 @@ export function MeetingView({ meetingId }: { meetingId: string }) {
   }, []);
 
   useEffect(() => {
-    const stop = createSSEClient({
-      url: `${DASHBOARD_API_URL}/run`,
-      body: {
-        prompt: "Run the council meeting and stream all events.",
-        config: { configurable: { thread_id: meetingId } },
-      },
-      onEvent: (event) => {
-        const tagged = { ...event, _uid: `mev-${++eventSeq.current}` };
-        setEvents((prev) => [...prev, tagged]);
-        handleEvent(event);
-      },
-      onComplete: () => {
-        setStreamCompleted(true);
-        setPhaseIndex(6);
-        setTimeout(() => router.push(`/result/${meetingId}`), 2000);
-      },
-      onError: (streamError) => setError(streamError.message),
-    });
+    let stopFn: (() => void) | undefined;
+    let cancelled = false;
+
+    (async () => {
+      // Check if result already exists (page refresh case)
+      try {
+        const { getMeetingResult } = await import("@/lib/api");
+        const existing = await getMeetingResult(meetingId);
+        if (existing && !cancelled) {
+          router.push(`/result/${meetingId}`);
+          return;
+        }
+      } catch {
+        // Result not found — proceed with new stream
+      }
+
+      if (cancelled) return;
+
+      stopFn = createSSEClient({
+        url: `${DASHBOARD_API_URL}/run`,
+        body: {
+          prompt: "Run the council meeting and stream all events.",
+          config: { configurable: { thread_id: meetingId } },
+        },
+        onEvent: (event) => {
+          const tagged = { ...event, _uid: `mev-${++eventSeq.current}` };
+          setEvents((prev) => [...prev, tagged]);
+          handleEvent(event);
+        },
+        onComplete: () => {
+          setStreamCompleted(true);
+          setPhaseIndex(6);
+          setTimeout(() => router.push(`/result/${meetingId}`), 2000);
+        },
+        onError: (streamError) => setError(streamError.message),
+      });
+    })();
 
-    return stop;
+    return () => {
+      cancelled = true;
+      stopFn?.();
+    };
   }, [handleEvent, meetingId, router]);
 
   useEffect(() => {
@@ -316,6 +338,7 @@ export function MeetingView({ meetingId }: { meetingId: string }) {
                             ]
                           : ["All dimensions cleared. Proceed to build + deploy."]
                     }
+                    onRevise={() => router.push("/")}
                   />
                 </motion.div>
               )}

web/src/components/zero-prompt/zero-prompt-workspace.tsx

@@ -21,6 +21,7 @@ export function ZeroPromptWorkspace({ initialSession, autostart = false }: { ini
     isConnected,
     isLoading,
     hasLoadedDashboard,
+    error,
     startSession,
     queueBuild,
     passCard,
@@ -85,6 +86,12 @@ export function ZeroPromptWorkspace({ initialSession, autostart = false }: { ini
           </div>
         </header>
 
+        {error && (
+          <div className="rounded-lg border border-red-500/30 bg-red-500/10 p-3 text-sm text-red-400">
+            {error}
+          </div>
+        )}
+
         <StatusBar session={session} isConnected={isConnected} />
 
         <KanbanBoard

web/src/hooks/use-zero-prompt.ts

@@ -206,7 +206,7 @@ function applyEventToSession(prev: ZPSession | null, data: Record<string, unknow
     card_id: cardId,
     video_id: String(data.video_id || cardId),
     title: stringifyValue(data.title) || stringifyValue(data.video_id) || cardId,
-    score: Number(data.score || 0),
+    score: Number(data.score ?? 0),
     status: (String(data.status || "analyzing") as CardStatus),
     reason: stringifyValue(data.reason),
     reason_code: stringifyValue(data.reason_code),
@@ -245,22 +245,22 @@ function applyEventToSession(prev: ZPSession | null, data: Record<string, unknow
   const merged: ZPCard = {
     ...current,
     ...nextPatch,
-    score: nextPatch.score || current.score,
-    reason: nextPatch.reason || current.reason,
-    reason_code: nextPatch.reason_code || current.reason_code,
-    score_breakdown: nextPatch.score_breakdown || current.score_breakdown,
-    domain: nextPatch.domain || current.domain,
-    papers_found: nextPatch.papers_found || current.papers_found,
-    competitors_found: nextPatch.competitors_found || current.competitors_found,
-    saturation: nextPatch.saturation || current.saturation,
-    novelty_boost: nextPatch.novelty_boost || current.novelty_boost,
-    analysis_step: nextPatch.analysis_step || current.analysis_step,
-    build_step: nextPatch.build_step || current.build_step,
-    build_phase: nextPatch.build_phase || current.build_phase,
-    build_node: nextPatch.build_node || current.build_node,
-    repo_url: nextPatch.repo_url || current.repo_url,
-    live_url: nextPatch.live_url || current.live_url,
-    thread_id: nextPatch.thread_id || current.thread_id,
+    score: nextPatch.score ?? current.score,
+    reason: nextPatch.reason ?? current.reason,
+    reason_code: nextPatch.reason_code ?? current.reason_code,
+    score_breakdown: nextPatch.score_breakdown ?? current.score_breakdown,
+    domain: nextPatch.domain ?? current.domain,
+    papers_found: nextPatch.papers_found ?? current.papers_found,
+    competitors_found: nextPatch.competitors_found ?? current.competitors_found,
+    saturation: nextPatch.saturation ?? current.saturation,
+    novelty_boost: nextPatch.novelty_boost ?? current.novelty_boost,
+    analysis_step: nextPatch.analysis_step ?? current.analysis_step,
+    build_step: nextPatch.build_step ?? current.build_step,
+    build_phase: nextPatch.build_phase ?? current.build_phase,
+    build_node: nextPatch.build_node ?? current.build_node,
+    repo_url: nextPatch.repo_url ?? current.repo_url,
+    live_url: nextPatch.live_url ?? current.live_url,
+    thread_id: nextPatch.thread_id ?? current.thread_id,
   };
 
   const cards = [...prev.cards];