Function setupTestBridge

internal/bridge/transfer_e2e_test.go:96–115

--------------------------------------------------------------------------- Test helper: create a Bridge with mock stream and local Manager ---------------------------------------------------------------------------

(t *testing.T, mgr *sessions.Manager, userAgent string, tools []observedtools.ObservedTool)

// ---------------------------------------------------------------------------

func setupTestBridge(t *testing.T, mgr *sessions.Manager, userAgent string, tools []observedtools.ObservedTool) (*Bridge, *mockSpiteStream, *sessions.Session) {
	t.Helper()
	stream := newMockSpiteStream()
	ctx, cancel := context.WithCancel(context.Background())
	t.Cleanup(cancel)
	b := &Bridge{
		listenerID:  "test-listener",
		pipelineID:  "test-pipeline",
		spiteStream: stream,
		registry:    buildDefaultRegistry(),
		taskManager: NewTaskManager(),
		ctx:         ctx,
		cancel:      cancel,
	}

	sess := mgr.Touch("test-key", userAgent, "claude", "")
	sess.RecordToolsDirect(tools)

	return b, stream, sess
}

// simulateToolResult publishes a CommandResult to the manager after a short delay.
func simulateToolResult(mgr *sessions.Manager, sessionID string, taskID uint32, output string, delay time.Duration) {