fix: use RecordMonitor instead of RecordVirtual to capture virtual monitor at correct resolution

Root cause: RecordVirtual creates its OWN virtual monitor using PipeWire format
negotiation, which defaults to 1280x720 (hardcoded in Mutter's
meta-screen-cast-stream-src.c:67). This ignored the virtual monitor
created by gnome-shell --virtual-monitor WxH.

Solution: Use RecordMonitor with connector "Meta-0" to capture the EXISTING
virtual monitor created by --virtual-monitor at the correct resolution.
Virtual monitor connector naming in Mutter: "Meta-{id}" (meta-output-virtual.c:44).

Also includes various improvements to immediate lobby attachment feature.

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude Opus 4.5 <[email protected]>

Author: lukemarsden

.github/workflows/pipewire-streaming-tests.yml

@@ -0,0 +1,39 @@
+name: PipeWire Streaming Tests
+
+on:
+  push:
+    paths:
+      - 'wolf/ubuntu-config/remotedesktop-session.py'
+      - 'tests/pipewire-streaming/**'
+      - '.github/workflows/pipewire-streaming-tests.yml'
+  pull_request:
+    paths:
+      - 'wolf/ubuntu-config/remotedesktop-session.py'
+      - 'tests/pipewire-streaming/**'
+      - '.github/workflows/pipewire-streaming-tests.yml'
+
+jobs:
+  python-tests:
+    name: Python Unit Tests
+    runs-on: ubuntu-24.04
+    steps:
+      - uses: actions/checkout@v4
+
+      - name: Setup Python
+        uses: actions/setup-python@v5
+        with:
+          python-version: '3.12'
+
+      - name: Install dependencies
+        working-directory: tests/pipewire-streaming
+        run: |
+          pip install -r requirements.txt
+
+      - name: Run Python tests
+        working-directory: tests/pipewire-streaming
+        run: |
+          python -m pytest test_remotedesktop_session.py -v --tb=short
+
+  # Note: Rust tests for gst-pipewire-zerocopy run during Wolf builds.
+  # See wolf/docker/wolf.Dockerfile line 72: `cargo test --lib`
+  # The tests require GStreamer CUDA libraries from the GOW base image.

api/pkg/external-agent/executor.go

@@ -31,6 +31,12 @@ type Executor interface {
 
 	// Reconciliation support
 	HasRunningContainer(ctx context.Context, sessionID string) bool
+
+	// Streaming session support
+	// ConfigurePendingSession pre-configures Wolf to attach a client to a lobby when it connects.
+	// The frontend calls this BEFORE connecting to moonlight-web with the same clientUniqueID.
+	// This enables immediate lobby attachment without auto-join polling.
+	ConfigurePendingSession(ctx context.Context, sessionID string, clientUniqueID string) error
 }
 
 // Shared types used by all executor implementations

api/pkg/external-agent/wolf_client_interface.go

@@ -29,6 +29,9 @@ type WolfClientInterface interface {
 	ResetKeyboardState(ctx context.Context, sessionID string) (*wolf.KeyboardResetResponse, error)
 	// Raw HTTP access (used for SSE streaming)
 	Get(ctx context.Context, path string) (*http.Response, error)
+	// Session pre-configuration for immediate lobby attachment
+	// Allows configuring immediate_lobby_id before Moonlight client connects
+	ConfigurePendingSession(ctx context.Context, clientUniqueID string, immediateLobbyID string) error
 }
 
 // Ensure *wolf.Client implements WolfClientInterface at compile time

api/pkg/external-agent/wolf_client_interface_mocks.go

@@ -887,6 +887,7 @@ func (w *WolfExecutor) StartDesktop(ctx context.Context, agent *types.ZedAgent)
 	extraEnv = append(extraEnv,
 		fmt.Sprintf("GAMESCOPE_WIDTH=%d", displayWidth),
 		fmt.Sprintf("GAMESCOPE_HEIGHT=%d", displayHeight),
+		fmt.Sprintf("GAMESCOPE_REFRESH=%d", displayRefreshRate),
 		fmt.Sprintf("HELIX_ZOOM_LEVEL=%d", zoomLevel),
 		fmt.Sprintf("HELIX_DESKTOP_TYPE=%s", string(desktopType)), // For container hostname reconstruction
 	)
@@ -1212,6 +1213,11 @@ func (w *WolfExecutor) StartDesktop(ctx context.Context, agent *types.ZedAgent)
 		Str("lobby_pin", lobbyPINString).
 		Msg("Wolf lobby created successfully - container starting immediately")
 
+	// NOTE: Session pre-configuration for immediate lobby attachment is now done by the frontend.
+	// The frontend generates a random client_unique_id and calls ConfigurePendingSession API
+	// BEFORE connecting to moonlight-web. This ensures Wolf is ready to attach the client
+	// directly to the lobby's interpipe when the Moonlight connection arrives.
+
 	// Step 3: Bridge desktop to Hydra network (if Hydra is enabled)
 	// This injects a veth pair connecting the desktop container to the Hydra network
 	// enabling Firefox/Zed in the desktop to access dev containers started via docker compose
@@ -2481,6 +2487,44 @@ func (w *WolfExecutor) FindExistingLobbyForSession(ctx context.Context, sessionI
 	return foundLobbyID, nil
 }
 
+// ConfigurePendingSession pre-configures Wolf to attach a client to a lobby when it connects.
+// The frontend calls this BEFORE connecting to moonlight-web with the same clientUniqueID.
+// This enables immediate lobby attachment without auto-join polling.
+func (w *WolfExecutor) ConfigurePendingSession(ctx context.Context, sessionID string, clientUniqueID string) error {
+	// Find the existing lobby for this session
+	lobbyID, err := w.FindExistingLobbyForSession(ctx, sessionID)
+	if err != nil {
+		return fmt.Errorf("failed to find lobby for session: %w", err)
+	}
+	if lobbyID == "" {
+		return fmt.Errorf("no lobby found for session %s", sessionID)
+	}
+
+	// Look up session to get Wolf instance ID
+	session, err := w.store.GetSession(ctx, sessionID)
+	if err != nil {
+		return fmt.Errorf("failed to get session: %w", err)
+	}
+
+	wolfInstanceID := session.WolfInstanceID
+	if wolfInstanceID == "" {
+		return fmt.Errorf("session %s has no Wolf instance ID", sessionID)
+	}
+
+	// Configure Wolf's pending session
+	if err := w.getWolfClient(wolfInstanceID).ConfigurePendingSession(ctx, clientUniqueID, lobbyID); err != nil {
+		return fmt.Errorf("failed to configure pending session: %w", err)
+	}
+
+	log.Info().
+		Str("session_id", sessionID).
+		Str("client_unique_id", clientUniqueID).
+		Str("lobby_id", lobbyID).
+		Msg("Session pre-configured for immediate lobby attachment via frontend API")
+
+	return nil
+}
+
 // cleanupOrphanedWolfUISessions removes Wolf-UI streaming sessions without active Zed containers
 func (w *WolfExecutor) cleanupOrphanedWolfUISessions(ctx context.Context) {
 	// Get all Wolf instances