Magic bytes change fallout

Author: mtopolnik

core/src/test/java/io/questdb/client/test/cutlass/qwp/client/NativeBufferWriterTest.java

@@ -26,10 +26,10 @@
 
 import io.questdb.client.cutlass.qwp.client.NativeBufferWriter;
 import io.questdb.client.std.Unsafe;
-import static io.questdb.client.test.tools.TestUtils.assertMemoryLeak;
 import org.junit.Assert;
 import org.junit.Test;
 
+import static io.questdb.client.test.tools.TestUtils.assertMemoryLeak;
 import static org.junit.Assert.*;
 
 public class NativeBufferWriterTest {
@@ -66,10 +66,10 @@ public void testGrowBuffer() throws Exception {
     public void testMultipleWrites() throws Exception {
         assertMemoryLeak(() -> {
             try (NativeBufferWriter writer = new NativeBufferWriter()) {
-                writer.putByte((byte) 'I');
-                writer.putByte((byte) 'L');
+                writer.putByte((byte) 'Q');
+                writer.putByte((byte) 'W');
                 writer.putByte((byte) 'P');
-                writer.putByte((byte) '4');
+                writer.putByte((byte) '1');
                 writer.putByte((byte) 1);  // Version
                 writer.putByte((byte) 0);  // Flags
                 writer.putShort((short) 1);  // Table count

core/src/test/java/io/questdb/client/test/cutlass/qwp/client/QwpWebSocketEncoderTest.java

@@ -29,11 +29,11 @@
 import io.questdb.client.cutlass.qwp.client.QwpWebSocketEncoder;
 import io.questdb.client.cutlass.qwp.protocol.QwpTableBuffer;
 import io.questdb.client.std.Unsafe;
-import static io.questdb.client.test.tools.TestUtils.assertMemoryLeak;
 import org.junit.Assert;
 import org.junit.Test;
 
 import static io.questdb.client.cutlass.qwp.protocol.QwpConstants.*;
+import static io.questdb.client.test.tools.TestUtils.assertMemoryLeak;
 
 /**
  * Unit tests for QwpWebSocketEncoder.
@@ -446,10 +446,10 @@ public void testEncodeMultipleColumns() throws Exception {
                 // Verify header
                 QwpBufferWriter buf = encoder.getBuffer();
                 long ptr = buf.getBufferPtr();
-                Assert.assertEquals((byte) 'I', Unsafe.getUnsafe().getByte(ptr));
-                Assert.assertEquals((byte) 'L', Unsafe.getUnsafe().getByte(ptr + 1));
+                Assert.assertEquals((byte) 'Q', Unsafe.getUnsafe().getByte(ptr));
+                Assert.assertEquals((byte) 'W', Unsafe.getUnsafe().getByte(ptr + 1));
                 Assert.assertEquals((byte) 'P', Unsafe.getUnsafe().getByte(ptr + 2));
-                Assert.assertEquals((byte) '4', Unsafe.getUnsafe().getByte(ptr + 3));
+                Assert.assertEquals((byte) '1', Unsafe.getUnsafe().getByte(ptr + 3));
             }
         });
     }
@@ -692,10 +692,10 @@ public void testEncodeSingleRowWithLong() throws Exception {
                 long ptr = buf.getBufferPtr();
 
                 // Verify header magic
-                Assert.assertEquals((byte) 'I', Unsafe.getUnsafe().getByte(ptr));
-                Assert.assertEquals((byte) 'L', Unsafe.getUnsafe().getByte(ptr + 1));
+                Assert.assertEquals((byte) 'Q', Unsafe.getUnsafe().getByte(ptr));
+                Assert.assertEquals((byte) 'W', Unsafe.getUnsafe().getByte(ptr + 1));
                 Assert.assertEquals((byte) 'P', Unsafe.getUnsafe().getByte(ptr + 2));
-                Assert.assertEquals((byte) '4', Unsafe.getUnsafe().getByte(ptr + 3));
+                Assert.assertEquals((byte) '1', Unsafe.getUnsafe().getByte(ptr + 3));
 
                 // Version
                 Assert.assertEquals(VERSION_1, Unsafe.getUnsafe().getByte(ptr + 4));