From ccce221fe7ce3e9943cdcd928838e4f8f18a9789 Mon Sep 17 00:00:00 2001
From: "pulse-triage[bot]"
 <249995291+pulse-triage[bot]@users.noreply.github.com>
Date: Tue, 6 Oct 2026 12:14:07 +0100
Subject: [PATCH] Keep connected cost fixtures compiling and reject missing
 live frames

Remove an unused test import exposed by source-fciz7jhb and require the quiet-aware cost probe to retain all clients and actually queue changed readings.

Change-source: pulse-maintainer
---
 internal/websocket/broadcast_projection_export_test.go | 3 +++
 internal/websocket/connected_cost_test.go              | 3 +++
 internal/websocket/delta_dispatch_test.go              | 2 --
 3 files changed, 6 insertions(+), 2 deletions(-)

diff --git a/internal/websocket/broadcast_projection_export_test.go b/internal/websocket/broadcast_projection_export_test.go
index 9869b296d6..f3be2ce1da 100644
--- a/internal/websocket/broadcast_projection_export_test.go
+++ b/internal/websocket/broadcast_projection_export_test.go
@@ -50,6 +50,9 @@ func NewQuietBroadcastProjectionProbeForTest(getState func(string) interface{},
 		hub.dispatchStateBroadcast(&Message{Type: "rawData", Data: stateBroadcastRequest{}}, "")
 		bytes := 0
 		for _, client := range clients {
+			if !hub.clients[client] {
+				return 0, fmt.Errorf("cost probe lost a client")
+			}
 			select {
 			case data := <-client.send:
 				bytes += len(data)
diff --git a/internal/websocket/connected_cost_test.go b/internal/websocket/connected_cost_test.go
index f024a4d676..35eacede49 100644
--- a/internal/websocket/connected_cost_test.go
+++ b/internal/websocket/connected_cost_test.go
@@ -85,6 +85,9 @@ func BenchmarkConnectedDashboardCost(b *testing.B) {
 					if err != nil {
 						b.Fatal(err)
 					}
+					if viewers > 0 && mode != "quiet" && mode != "cold" && wire == 0 {
+						b.Fatal("live workload queued no frame")
+					}
 				}
 				b.ReportMetric(float64(wire), "wire-B/op")
 			})
diff --git a/internal/websocket/delta_dispatch_test.go b/internal/websocket/delta_dispatch_test.go
index bab482c409..706df5b5b1 100644
--- a/internal/websocket/delta_dispatch_test.go
+++ b/internal/websocket/delta_dispatch_test.go
@@ -4,8 +4,6 @@ import (
 	"bytes"
 	"encoding/json"
 	"testing"
-
-	"github.com/rcourtman/pulse-go-rewrite/internal/models"
 )
 
 func TestStateDeltaDispatchSharesOnlyAcceptedBaseline(t *testing.T) {