transport_replay_test.go RawHistoryFolder

1package dgram
2
3import (
4	"testing"
5
6	"github.com/bnema/vev/internal/ports"
7	"github.com/bnema/vev/internal/testutil/replaytest"
8	"github.com/stretchr/testify/require"
9)
10
11func TestTransportReplay(t *testing.T) {
12	replaytest.Run(t, func(t *testing.T, frames []ports.Frame) []ports.Frame {
13		link := newSimulatedLink(fixedClock{}, packetPolicy{})
14		leftPC, rightPC := newPairWithCapacity(link, 32)
15		left, err := NewTransport(leftPC, testAddr("b"), key(), 1, 2)
16		require.NoError(t, err)
17		right, err := NewTransport(rightPC, testAddr("a"), key(), 2, 1)
18		require.NoError(t, err)
19		t.Cleanup(func() { _ = left.Close(); _ = right.Close() })
20
21		got := make([]ports.Frame, 0, len(frames))
22		for _, frame := range frames {
23			require.NoError(t, left.Send(frame))
24			link.flush(rightPC)
25			received, recvErr := right.Recv()
26			require.NoError(t, recvErr)
27			got = append(got, received)
28		}
29		return got
30	})
31}