Function TestOutOfOrderWithDuplicates

pkg/streamclient/stream_test.go:331–379

(t *testing.T)

}

func TestOutOfOrderWithDuplicates(t *testing.T) {
	transport := newFakeTransport()
	reader := NewReader("test-dup", 1024, transport)

	packet0 := wshrpc.CommandStreamData{
		Id:     "test-dup",
		Seq:    0,
		Data64: base64.StdEncoding.EncodeToString([]byte("aaaaa")),
	}
	packet10 := wshrpc.CommandStreamData{
		Id:     "test-dup",
		Seq:    10,
		Data64: base64.StdEncoding.EncodeToString([]byte("ccccc")),
	}
	packet5First := wshrpc.CommandStreamData{
		Id:     "test-dup",
		Seq:    5,
		Data64: base64.StdEncoding.EncodeToString([]byte("xxxxx")),
	}
	packet5Second := wshrpc.CommandStreamData{
		Id:     "test-dup",
		Seq:    5,
		Data64: base64.StdEncoding.EncodeToString([]byte("bbbbb")),
	}

	reader.RecvData(packet0)
	reader.RecvData(packet10)      // OOO - buffered
	reader.RecvData(packet5First)  // OOO - buffered
	reader.RecvData(packet5First)  // Duplicate - should be ignored
	reader.RecvData(packet5Second) // Duplicate with different data - should be ignored

	// Read all data - should get all 3 packets in order
	buf := make([]byte, 20)
	n, err := reader.Read(buf)
	if err != nil {
		t.Fatalf("Read failed: %v", err)
	}
	
	// Should get all 15 bytes (3 packets * 5 bytes)
	if n != 15 {
		t.Fatalf("Expected to read 15 bytes, got %d", n)
	}
	
	// Should be "aaaaaxxxxxccccc" (first packet received for each seq wins)
	expected := "aaaaaxxxxxccccc"
	if string(buf[:n]) != expected {
		t.Fatalf("Expected %q, got %q", expected, string(buf[:n]))
	}
}

func TestOutOfOrderWithGaps(t *testing.T) {
	transport := newFakeTransport()