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/domain"
11 "github.com/bnema/vev/internal/ports"
12)
13
14func mustMarshalOutput(m ports.Output) []byte {
15 payload, err := ports.MarshalOutput(m)
16 if err != nil {
17 panic(err)
18 }
19 return payload
20}
21
22var transcript = []ports.Frame{
23 {Type: ports.MsgOutput, Payload: mustMarshalOutput(ports.Output{Epoch: 1, Base: 0, New: 1, Size: domain.Size{Cols: 80, Rows: 24}, Full: true, Data: []byte("\x1b[2J\x1b[Hone\r\ntwo")})},
24 {Type: ports.MsgOutput, Payload: mustMarshalOutput(ports.Output{Epoch: 1, Base: 1, New: 2, Echo: 7, Size: domain.Size{Cols: 80, Rows: 24}, Data: []byte("\x1b[2;1HTWO")})},
25}
26
27// Transcript returns a deep copy of the canonical replay transcript so an
28// adapter cannot mutate the fixture observed by another adapter.
29func Transcript() []ports.Frame {
30 return cloneFrames(transcript)
31}
32
33// Exchange carries already-composed frames through one transport adapter.
34type Exchange func(t *testing.T, frames []ports.Frame) []ports.Frame
35
36// Run verifies that an adapter preserves the canonical transcript exactly.
37func Run(t *testing.T, exchange Exchange) {
38 t.Helper()
39 want := Transcript()
40 got := exchange(t, cloneFrames(want))
41 if len(got) != len(want) {
42 t.Fatalf("replayed frame count = %d, want %d", len(got), len(want))
43 }
44 for i := range want {
45 if got[i].Type != want[i].Type {
46 t.Errorf("frame %d type = %d, want %d", i, got[i].Type, want[i].Type)
47 }
48 if !bytes.Equal(got[i].Payload, want[i].Payload) {
49 t.Errorf("frame %d payload = %x, want byte-for-byte %x", i, got[i].Payload, want[i].Payload)
50 continue
51 }
52 gotOutput, err := ports.UnmarshalOutput(got[i].Payload)
53 if err != nil {
54 t.Errorf("frame %d output decode: %v", i, err)
55 continue
56 }
57 wantOutput, err := ports.UnmarshalOutput(want[i].Payload)
58 if err != nil {
59 t.Fatalf("canonical frame %d output decode: %v", i, err)
60 }
61 if !reflect.DeepEqual(gotOutput, wantOutput) {
62 t.Errorf("frame %d output = %#v, want %#v", i, gotOutput, wantOutput)
63 }
64 }
65}
66
67func cloneFrames(frames []ports.Frame) []ports.Frame {
68 cloned := make([]ports.Frame, len(frames))
69 for i, frame := range frames {
70 cloned[i] = ports.Frame{Type: frame.Type, Payload: append([]byte(nil), frame.Payload...)}
71 }
72 return cloned
73}