Function TestOutOfOrderPackets

pkg/streamclient/stream_test.go:270–329

(t *testing.T)

}

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

	packet0 := wshrpc.CommandStreamData{
		Id:     "test-ooo",
		Seq:    0,
		Data64: base64.StdEncoding.EncodeToString([]byte("AAAAA")),
	}
	packet5 := wshrpc.CommandStreamData{
		Id:     "test-ooo",
		Seq:    5,
		Data64: base64.StdEncoding.EncodeToString([]byte("BBBBB")),
	}
	packet10 := wshrpc.CommandStreamData{
		Id:     "test-ooo",
		Seq:    10,
		Data64: base64.StdEncoding.EncodeToString([]byte("CCCCC")),
	}
	packet15 := wshrpc.CommandStreamData{
		Id:     "test-ooo",
		Seq:    15,
		Data64: base64.StdEncoding.EncodeToString([]byte("DDDDD")),
	}

	// Send packets out of order: 0, 10, 15, 5
	reader.RecvData(packet0)
	reader.RecvData(packet10) // OOO - should be buffered
	reader.RecvData(packet15) // OOO - should be buffered
	reader.RecvData(packet5)  // fills the gap - should trigger processing

	// Read all data
	buf := make([]byte, 1024)
	totalRead := 0
	expectedLen := 20 // 4 packets * 5 bytes each

	readDone := make(chan struct{})
	go func() {
		for totalRead < expectedLen {
			n, err := reader.Read(buf[totalRead:])
			if err != nil {
				t.Errorf("Read failed: %v", err)
				return
			}
			totalRead += n
		}
		close(readDone)
	}()

	select {
	case <-readDone:
		// Success
	case <-time.After(2 * time.Second):
		t.Fatalf("Read didn't complete in time. Read %d bytes, expected %d", totalRead, expectedLen)
	}

	if totalRead != expectedLen {
		t.Fatalf("Expected to read %d bytes, got %d", expectedLen, totalRead)