Upload folder using huggingface_hub

app.py

@@ -632,25 +632,41 @@ async def ws_stream(ws: WebSocket):
 
                 force = bool(msg.get("force", False))
                 if force or (qvd > state.qvd_threshold and novelty > 0.1):
-                    try:
-                        result = build(state, state.observer_state or {})
-                        state.current_artifact = result["patch_output"]
-                        state.last_patch_hash = result["patch_hash"]
-                        state.last_builder_ts = time.time()
-                        state.receipt_count += 1
-
-                        save_receipt(result["receipt"])
-                        print(f"[WS] Patch generated: session={state.session_id} hash={result['patch_hash'][:16]} qvd={round(qvd,3)}", flush=True)
-
+                    # ─── Evidence Gate: check if sufficient intent exists ───
+                    ev_result = evidence_gate(
+                        (state.observer_state or {}).get("observer_output", ""),
+                        compress_state(state),
+                    )
+                    log_gate_decision("evidence_gate", ev_result, patch_hash="")
+                    if not ev_result.passed:
+                        print(f"[WS] Evidence Gate blocked: session={state.session_id} reason={ev_result.reason[:60]}", flush=True)
                         await ws.send_json({
-                            "type": "patch",
-                            "output": result["patch_output"],
-                            "patch_hash": result["patch_hash"],
-                            "receipt": result["receipt"],
+                            "type": "gate_block",
+                            "gate": "evidence_gate",
+                            "reason": ev_result.reason,
+                            "evidence_type": ev_result.evidence_type,
                             "qvd": round(qvd, 4),
                         })
-                    except Exception as e:
-                        await ws.send_json({"type": "error", "stage": "builder", "message": str(e)})
+                    else:
+                        try:
+                            result = build(state, state.observer_state or {})
+                            state.current_artifact = result["patch_output"]
+                            state.last_patch_hash = result["patch_hash"]
+                            state.last_builder_ts = time.time()
+                            state.receipt_count += 1
+
+                            save_receipt(result["receipt"])
+                            print(f"[WS] Patch generated: session={state.session_id} hash={result['patch_hash'][:16]} qvd={round(qvd,3)}", flush=True)
+
+                            await ws.send_json({
+                                "type": "patch",
+                                "output": result["patch_output"],
+                                "patch_hash": result["patch_hash"],
+                                "receipt": result["receipt"],
+                                "qvd": round(qvd, 4),
+                            })
+                        except Exception as e:
+                            await ws.send_json({"type": "error", "stage": "builder", "message": str(e)})
 
                 # Send QVD update
                 await ws.send_json({
@@ -692,19 +708,32 @@ async def ws_stream(ws: WebSocket):
                 state.observer_state = observation
                 state.last_observer_ts = time.time()
 
-                result = build(state, observation)
-                state.current_artifact = result["patch_output"]
-                state.last_patch_hash = result["patch_hash"]
-                state.last_builder_ts = time.time()
-                state.receipt_count += 1
-                save_receipt(result["receipt"])
+                # ─── Evidence Gate: check if sufficient intent exists ───
+                ev_result = evidence_gate(observation.get("observer_output", ""), compact)
+                log_gate_decision("evidence_gate", ev_result, patch_hash="")
+                if not ev_result.passed:
+                    print(f"[WS] Evidence Gate blocked (synthesize): session={state.session_id} reason={ev_result.reason[:60]}", flush=True)
+                    await ws.send_json({
+                        "type": "gate_block",
+                        "gate": "evidence_gate",
+                        "reason": ev_result.reason,
+                        "evidence_type": ev_result.evidence_type,
+                    })
+                else:
+                    result = build(state, observation)
+                    state.current_artifact = result["patch_output"]
+                    state.last_patch_hash = result["patch_hash"]
+                    state.last_builder_ts = time.time()
+                    state.receipt_count += 1
+                    save_receipt(result["receipt"])
+                    print(f"[WS] Patch generated (synthesize): session={state.session_id} hash={result['patch_hash'][:16]}", flush=True)
 
-                await ws.send_json({
-                    "type": "patch",
-                    "output": result["patch_output"],
-                    "patch_hash": result["patch_hash"],
-                    "receipt": result["receipt"],
-                })
+                    await ws.send_json({
+                        "type": "patch",
+                        "output": result["patch_output"],
+                        "patch_hash": result["patch_hash"],
+                        "receipt": result["receipt"],
+                    })
 
             elif msg_type == "state":
                 await ws.send_json({

frontend/index.html

@@ -1464,6 +1464,19 @@
               patchStream.innerHTML = '<div class="empty-state" style="color:var(--red)">' + escapeHtml(msg.message) + '</div>';
             }
             break;
+          case "gate_block":
+            const gateDiv = document.createElement("div");
+            gateDiv.className = "patch-entry";
+            gateDiv.style.borderColor = "var(--amber)";
+            gateDiv.innerHTML = '<div class="patch-header" style="color:var(--amber)">\u26d4 Evidence Gate Blocked</div>' +
+              '<div style="padding:12px 16px;font-size:13px;color:var(--text2);line-height:1.6">' +
+              '<strong>Reason:</strong> ' + escapeHtml(msg.reason) + '<br>' +
+              '<strong>Evidence type:</strong> ' + escapeHtml(msg.evidence_type) + '<br>' +
+              '<em style="color:var(--gray);margin-top:8px;display:block">Speak to the camera or show a screen with code to trigger code generation.</em>' +
+              '</div>';
+            patchStream.prepend(gateDiv);
+            setStatus("Evidence Gate: " + msg.evidence_type, "dot-idle");
+            break;
           case "state":
             updateSpeakerLedger(msg.state);
             break;