CDP telemetry fixes

server/cmd/api/api/api.go

@@ -12,14 +12,14 @@ import (
 
 	"github.com/kernel/kernel-images/server/lib/cdpmonitor"
 	"github.com/kernel/kernel-images/server/lib/devtoolsproxy"
-	"github.com/kernel/kernel-images/server/lib/telemetry"
 	"github.com/kernel/kernel-images/server/lib/events"
 	"github.com/kernel/kernel-images/server/lib/logger"
 	"github.com/kernel/kernel-images/server/lib/nekoclient"
 	oapi "github.com/kernel/kernel-images/server/lib/oapi"
 	"github.com/kernel/kernel-images/server/lib/policy"
 	"github.com/kernel/kernel-images/server/lib/recorder"
 	"github.com/kernel/kernel-images/server/lib/scaletozero"
+	"github.com/kernel/kernel-images/server/lib/telemetry"
 )
 
 type cdpMonitorController interface {
@@ -99,7 +99,7 @@ func New(
 	stz scaletozero.PinnedController,
 	nekoAuthClient *nekoclient.AuthClient,
 	telemetrySession *telemetry.TelemetrySession,
-	eventStream      *events.EventStream,
+	eventStream *events.EventStream,
 	displayNum int,
 ) (*ApiService, error) {
 	switch {

server/cmd/api/api/api_test.go

@@ -12,12 +12,12 @@ import (
 	"log/slog"
 
 	"github.com/kernel/kernel-images/server/lib/devtoolsproxy"
-	"github.com/kernel/kernel-images/server/lib/telemetry"
 	"github.com/kernel/kernel-images/server/lib/events"
 	"github.com/kernel/kernel-images/server/lib/nekoclient"
 	oapi "github.com/kernel/kernel-images/server/lib/oapi"
 	"github.com/kernel/kernel-images/server/lib/recorder"
 	"github.com/kernel/kernel-images/server/lib/scaletozero"
+	"github.com/kernel/kernel-images/server/lib/telemetry"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
 )

server/cmd/api/api/computer_test.go

@@ -262,7 +262,7 @@ func TestGaussianDelay_WelfordVelocityVariance(t *testing.T) {
 	for i := range distances {
 		t_norm := float64(i) / float64(steps)
 		base := 5.0 + 15.0*math.Sin(t_norm*math.Pi) // 5-20px, peaked in middle
-		distances[i] = base + rng.Float64()*3.0       // small random variation
+		distances[i] = base + rng.Float64()*3.0     // small random variation
 	}
 
 	// Gaussian delays → velocity variance
@@ -302,27 +302,27 @@ func TestClampPoints(t *testing.T) {
 		expected [][2]int
 	}{
 		{
-			name:     "no clamping needed",
-			points:   [][2]int{{10, 20}, {50, 50}, {100, 80}},
-			w:        200, h: 200,
+			name:   "no clamping needed",
+			points: [][2]int{{10, 20}, {50, 50}, {100, 80}},
+			w:      200, h: 200,
 			expected: [][2]int{{10, 20}, {50, 50}, {100, 80}},
 		},
 		{
-			name:     "clamp negative x and y",
-			points:   [][2]int{{-10, -20}, {50, 50}},
-			w:        200, h: 200,
+			name:   "clamp negative x and y",
+			points: [][2]int{{-10, -20}, {50, 50}},
+			w:      200, h: 200,
 			expected: [][2]int{{0, 0}, {50, 50}},
 		},
 		{
-			name:     "clamp exceeding screen bounds",
-			points:   [][2]int{{50, 50}, {250, 300}},
-			w:        200, h: 200,
+			name:   "clamp exceeding screen bounds",
+			points: [][2]int{{50, 50}, {250, 300}},
+			w:      200, h: 200,
 			expected: [][2]int{{50, 50}, {199, 199}},
 		},
 		{
-			name:     "clamp both directions",
-			points:   [][2]int{{-5, 250}, {300, -10}, {100, 100}},
-			w:        200, h: 200,
+			name:   "clamp both directions",
+			points: [][2]int{{-5, 250}, {300, -10}, {100, 100}},
+			w:      200, h: 200,
 			expected: [][2]int{{0, 199}, {199, 0}, {100, 100}},
 		},
 	}

server/cmd/api/api/display.go

@@ -12,11 +12,11 @@ import (
 	"strings"
 	"time"
 
-	nekooapi "github.com/m1k1o/neko/server/lib/oapi"
 	"github.com/kernel/kernel-images/server/lib/cdpclient"
 	"github.com/kernel/kernel-images/server/lib/logger"
 	oapi "github.com/kernel/kernel-images/server/lib/oapi"
 	"github.com/kernel/kernel-images/server/lib/recorder"
+	nekooapi "github.com/m1k1o/neko/server/lib/oapi"
 )
 
 // PatchDisplay updates the display configuration. When require_idle
@@ -655,4 +655,3 @@ func (s *ApiService) setResolutionViaNeko(ctx context.Context, width, height, re
 	log.Info("successfully changed resolution via Neko API", "width", width, "height", height, "refresh_rate", refreshRate)
 	return nil
 }
-

server/cmd/api/api/fs.go

@@ -16,11 +16,11 @@ import (
 	"os/user"
 
 	"github.com/fsnotify/fsnotify"
-	"github.com/nrednav/cuid2"
 	"github.com/kernel/kernel-images/server/lib/logger"
 	oapi "github.com/kernel/kernel-images/server/lib/oapi"
 	"github.com/kernel/kernel-images/server/lib/ziputil"
 	"github.com/kernel/kernel-images/server/lib/zstdutil"
+	"github.com/nrednav/cuid2"
 )
 
 // fsWatch represents an in-memory directory watch.

server/cmd/api/api/process.go

@@ -23,10 +23,10 @@ import (
 	"github.com/coder/websocket"
 	"github.com/creack/pty"
 	"github.com/google/uuid"
-	openapi_types "github.com/oapi-codegen/runtime/types"
 	"github.com/kernel/kernel-images/server/lib/logger"
 	oapi "github.com/kernel/kernel-images/server/lib/oapi"
 	"github.com/kernel/kernel-images/server/lib/ptyio"
+	openapi_types "github.com/oapi-codegen/runtime/types"
 )
 
 type processHandle struct {

server/cmd/api/api/process_test.go

@@ -13,9 +13,9 @@ import (
 	"time"
 
 	"github.com/google/uuid"
-	openapi_types "github.com/oapi-codegen/runtime/types"
 	oapi "github.com/kernel/kernel-images/server/lib/oapi"
 	"github.com/kernel/kernel-images/server/lib/scaletozero"
+	openapi_types "github.com/oapi-codegen/runtime/types"
 	"github.com/stretchr/testify/require"
 )
 

server/cmd/chromium-launcher/main.go

@@ -135,7 +135,6 @@ func main() {
 	}
 }
 
-
 // execLookPath helps satisfy syscall.Exec's requirement to pass an absolute path.
 func execLookPath(file string) (string, error) {
 	if strings.ContainsRune(file, os.PathSeparator) {

server/cmd/chromium-launcher/main_test.go

@@ -34,4 +34,3 @@ func TestExecLookPath(t *testing.T) {
 		t.Fatalf("execLookPath PATH search failed: p=%q err=%v", p, err)
 	}
 }
-

server/cmd/shell/main.go

@@ -17,8 +17,8 @@ import (
 	"time"
 
 	"github.com/google/uuid"
-	openapi_types "github.com/oapi-codegen/runtime/types"
 	oapi "github.com/kernel/kernel-images/server/lib/oapi"
+	openapi_types "github.com/oapi-codegen/runtime/types"
 	"golang.org/x/term"
 )
 

server/cmd/wrapper/chromium.go

@@ -61,4 +61,3 @@ func applyHeadlessDefaultFlags() {
 	}, " ")
 	_ = os.Setenv("CHROMIUM_FLAGS", flags)
 }
-

server/cmd/wrapper/main.go

@@ -243,9 +243,9 @@ func main() {
 
 // waitAllReady gates on all caller-visible ready signals concurrently:
 //   - cdp          : HTTP /json/version on the public CDP port (proves api proxy is
-//                    wired through to chromium's DevTools server)
+//     wired through to chromium's DevTools server)
 //   - chromedriver : TCP on chromedriver's internal port 9225 (api on 9224 is bound
-//                    when api itself is up, which CDP readiness already implies)
+//     when api itself is up, which CDP readiness already implies)
 //   - neko         : TCP on neko's HTTP port (8080), only when ENABLE_WEBRTC=true
 //   - envoy        : TCP on envoy's listener (3128), only when envoy is enabled
 func waitAllReady(t0 time.Time, webrtc bool) map[string]time.Duration {

server/e2e/container.go

@@ -178,7 +178,7 @@ func (c *TestContainer) ExitCh() <-chan error {
 // WaitDevTools waits for the CDP WebSocket endpoint to be ready.
 func (c *TestContainer) WaitDevTools(ctx context.Context) error {
 	return wait.ForListeningPort(nat.Port("9222/tcp")).
-		WithStartupTimeout(2 * time.Minute).
+		WithStartupTimeout(2*time.Minute).
 		WaitUntilReady(ctx, c.ctr)
 }
 

server/lib/cdpclient/cdpclient_test.go

@@ -16,20 +16,20 @@ import (
 // fakeCDP is a minimal CDP server that responds to the commands used by
 // SetDeviceMetricsOverride and GetBrowserVersion.
 type fakeCDP struct {
-	getTargetsCalled     bool
-	attachCalled         bool
-	setMetricsCalled     bool
-	setMetricsWidth      int
-	setMetricsHeight     int
-	detachCalled         bool
-	pageTargetID         string
-	sessionID            string
-	failGetTargets       bool
-	failSetMetrics       bool
-	returnNoPageTargets  bool
-	getVersionCalled     bool
-	failGetVersion       bool
-	productResponse      string
+	getTargetsCalled    bool
+	attachCalled        bool
+	setMetricsCalled    bool
+	setMetricsWidth     int
+	setMetricsHeight    int
+	detachCalled        bool
+	pageTargetID        string
+	sessionID           string
+	failGetTargets      bool
+	failSetMetrics      bool
+	returnNoPageTargets bool
+	getVersionCalled    bool
+	failGetVersion      bool
+	productResponse     string
 }
 
 func (f *fakeCDP) handler(w http.ResponseWriter, r *http.Request) {

server/lib/cdpmonitor/computed.go

@@ -100,7 +100,6 @@ func (s *computedState) navDataWith(extra map[string]any) json.RawMessage {
 	return out
 }
 
-
 // currentNavCtxFields returns the current nav context fields for constructing typed event payloads.
 // Returns zero values if s is nil (before first navigation).
 func (s *computedState) currentNavCtxFields() (sessionID, targetID, targetType, frameID, loaderID, url string, navSeq int64) {

server/lib/cdpmonitor/types.go

@@ -16,12 +16,12 @@ const mainSessionUnset = "\x00unset"
 // Each maps 1-to-1 with a specific CDP domain event (Runtime.*, Network.*,
 // Page.*, PerformanceTimeline.*) received from Chrome.
 const (
-	EventConsoleLog           = "console_log"            // Runtime.consoleAPICalled (non-error types)
-	EventConsoleError         = "console_error"          // Runtime.consoleAPICalled (type=error) or Runtime.exceptionThrown
-	EventNetworkRequest       = "network_request"        // Network.requestWillBeSent
-	EventNetworkResponse      = "network_response"       // Network.loadingFinished (with prior responseReceived)
-	EventNetworkLoadingFailed = "network_loading_failed" // Network.loadingFailed
-	EventNavigation           = "page_navigation"        // Page.frameNavigated
+	EventConsoleLog           = "console_log"             // Runtime.consoleAPICalled (non-error types)
+	EventConsoleError         = "console_error"           // Runtime.consoleAPICalled (type=error) or Runtime.exceptionThrown
+	EventNetworkRequest       = "network_request"         // Network.requestWillBeSent
+	EventNetworkResponse      = "network_response"        // Network.loadingFinished (with prior responseReceived)
+	EventNetworkLoadingFailed = "network_loading_failed"  // Network.loadingFailed
+	EventNavigation           = "page_navigation"         // Page.frameNavigated
 	EventDOMContentLoaded     = "page_dom_content_loaded" // Page.domContentEventFired
 	EventPageLoad             = "page_load"               // Page.loadEventFired
 	EventLayoutShift          = "page_layout_shift"       // PerformanceTimeline event of type "layout-shift"
@@ -33,27 +33,27 @@ const (
 // None of these correspond to a single CDP notification; they are inferred from
 // sequences of CDP events and debounce timers.
 const (
-	EventNetworkIdle       = "network_idle"           // 500 ms after all in-flight requests finish
-	EventLayoutSettled     = "page_layout_settled"    // 1 s after page_load with no intervening layout shifts
+	EventNetworkIdle       = "network_idle"            // 500 ms after all in-flight requests finish
+	EventLayoutSettled     = "page_layout_settled"     // 1 s after page_load with no intervening layout shifts
 	EventNavigationSettled = "page_navigation_settled" // fires once page_dom_content_loaded and page_layout_settled both hold
 )
 
 // Interaction events — fired by injected page-side JS (interaction.js) via the
 // Runtime.bindingCalled mechanism. They originate in the browser's renderer
 // process, not from Chrome's network or page domains.
 const (
-	EventInteractionClick = "interaction_click"         // document click (target selector, coords, text)
-	EventInteractionKey   = "interaction_key"           // keydown (key name, target selector)
+	EventInteractionClick = "interaction_click"          // document click (target selector, coords, text)
+	EventInteractionKey   = "interaction_key"            // keydown (key name, target selector)
 	EventScrollSettled    = "interaction_scroll_settled" // 300 ms after the last scroll event on a target
 )
 
 // Monitor lifecycle and internal events — emitted by the monitor itself, not by Chrome.
 const (
-	EventScreenshot             = "monitor_screenshot"    // ffmpeg frame capture on page load or JS exception
-	EventMonitorDisconnected    = "monitor_disconnected"    // WebSocket to Chrome closed unexpectedly
-	EventMonitorReconnected     = "monitor_reconnected"     // successfully reconnected after a disconnect
+	EventScreenshot             = "monitor_screenshot"       // ffmpeg frame capture on page load or JS exception
+	EventMonitorDisconnected    = "monitor_disconnected"     // WebSocket to Chrome closed unexpectedly
+	EventMonitorReconnected     = "monitor_reconnected"      // successfully reconnected after a disconnect
 	EventMonitorReconnectFailed = "monitor_reconnect_failed" // reconnect attempts exhausted
-	EventMonitorInitFailed      = "monitor_init_failed"     // could not initialise the CDP session
+	EventMonitorInitFailed      = "monitor_init_failed"      // could not initialise the CDP session
 )
 
 // Metadata keys written into events.Source.Metadata for CDP-sourced events.