transport_replay_test.go RawHistoryFolder

1package ipc
2
3import (
4	"net"
5	"sync"
6	"testing"
7
8	"github.com/bnema/vev/internal/protocol/wire"
9	"github.com/bnema/vev/internal/testutil/replaytest"
10)
11
12func TestTransportReplay(t *testing.T) {
13	replaytest.Run(t, func(t *testing.T, envelopes []wire.Envelope) []wire.Envelope {
14		left, right := net.Pipe()
15		t.Cleanup(func() { _ = left.Close(); _ = right.Close() })
16		sender, receiver := NewTransport(left), NewTransport(right)
17
18		var wg sync.WaitGroup
19		wg.Go(func() {
20			for _, frame := range envelopes {
21				if err := sender.Send(frame); err != nil {
22					t.Errorf("Send: %v", err)
23					return
24				}
25			}
26		})
27		got := make([]wire.Envelope, 0, len(envelopes))
28		for range envelopes {
29			frame, err := receiver.Recv()
30			if err != nil {
31				t.Errorf("Recv: %v", err)
32				_ = receiver.Close()
33				break
34			}
35			got = append(got, frame)
36		}
37		wg.Wait()
38		return got
39	})
40}