1// Package replaytest owns the protocol-neutral transport replay fixture and
2// assertions shared by transport adapter tests.
3package replaytest
4
5import (
6 "bytes"
7 "reflect"
8 "testing"
9
10 "github.com/bnema/vev/internal/ports"
11)
12
13var transcript = []ports.Frame{
14 {Type: ports.MsgOutput, Payload: ports.MarshalOutput(ports.Output{BaseStateNum: 0, NewStateNum: 1, Data: []byte("\x1b[2J\x1b[Hone\r\ntwo")})},
15 {Type: ports.MsgOutput, Payload: ports.MarshalOutput(ports.Output{BaseStateNum: 1, NewStateNum: 2, EchoAck: 7, Data: []byte("\x1b[2;1HTWO")})},
16}
17
18// Transcript returns a deep copy of the canonical replay transcript so an
19// adapter cannot mutate the fixture observed by another adapter.
20func Transcript() []ports.Frame {
21 return cloneFrames(transcript)
22}
23
24// Exchange carries already-composed frames through one transport adapter.
25type Exchange func(t *testing.T, frames []ports.Frame) []ports.Frame
26
27// Run verifies that an adapter preserves the canonical transcript exactly.
28func Run(t *testing.T, exchange Exchange) {
29 t.Helper()
30 want := Transcript()
31 got := exchange(t, cloneFrames(want))
32 if len(got) != len(want) {
33 t.Fatalf("replayed frame count = %d, want %d", len(got), len(want))
34 }
35 for i := range want {
36 if got[i].Type != want[i].Type {
37 t.Errorf("frame %d type = %d, want %d", i, got[i].Type, want[i].Type)
38 }
39 if !bytes.Equal(got[i].Payload, want[i].Payload) {
40 t.Errorf("frame %d payload = %x, want byte-for-byte %x", i, got[i].Payload, want[i].Payload)
41 continue
42 }
43 gotOutput, err := ports.UnmarshalOutput(got[i].Payload)
44 if err != nil {
45 t.Errorf("frame %d output decode: %v", i, err)
46 continue
47 }
48 wantOutput, err := ports.UnmarshalOutput(want[i].Payload)
49 if err != nil {
50 t.Fatalf("canonical frame %d output decode: %v", i, err)
51 }
52 if !reflect.DeepEqual(gotOutput, wantOutput) {
53 t.Errorf("frame %d output = %#v, want %#v", i, gotOutput, wantOutput)
54 }
55 }
56}
57
58func cloneFrames(frames []ports.Frame) []ports.Frame {
59 cloned := make([]ports.Frame, len(frames))
60 for i, frame := range frames {
61 cloned[i] = ports.Frame{Type: frame.Type, Payload: append([]byte(nil), frame.Payload...)}
62 }
63 return cloned
64}