Function newV2Session

pkg/agent/proxy/integrations/generic/v2_test.go:19–32

newV2Session wires a supervisor.Session around two caller-supplied chunk channels. The caller pushes Chunks onto clientCh / destCh and closes them to drive the parser; the returned session's ClientStream and DestStream surface those channels as read-only FakeConns.

(t *testing.T, clientCh, destCh chan fakeconn.Chunk)

// closes them to drive the parser; the returned session's ClientStream
// and DestStream surface those channels as read-only FakeConns.
func newV2Session(t *testing.T, clientCh, destCh chan fakeconn.Chunk) (*supervisor.Session, chan *models.Mock) {
	t.Helper()
	mocks := make(chan *models.Mock, 16)
	sess := &supervisor.Session{
		ClientStream: fakeconn.New(clientCh, nil, nil),
		DestStream:   fakeconn.New(destCh, nil, nil),
		Mocks:        mocks,
		Logger:       zaptest.NewLogger(t),
		Ctx:          context.Background(),
		ClientConnID: "test-client-conn",
		DestConnID:   "test-dest-conn",
	}
	return sess, mocks
}

// dispatch calls the public RecordOutgoing boundary rather than the
// unexported V2 entry so the test exercises the same dispatch branch