From c3388f18d41434cf3cc5490a135b6a829188b1ef Mon Sep 17 00:00:00 2001
From: Zeljko Mihaljcic <7150613+zehiko@users.noreply.github.com>
Date: Mon, 21 Oct 2024 11:22:04 +0200
Subject: [PATCH] address feedback

---
 crates/store/re_remote_store_types/Cargo.toml   | 2 +-
 crates/store/re_remote_store_types/src/codec.rs | 8 ++++----
 2 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/crates/store/re_remote_store_types/Cargo.toml b/crates/store/re_remote_store_types/Cargo.toml
index d39ae70acb7a..b342fa235da9 100644
--- a/crates/store/re_remote_store_types/Cargo.toml
+++ b/crates/store/re_remote_store_types/Cargo.toml
@@ -14,10 +14,10 @@ re_log_types.workspace = true
 re_dataframe.workspace = true
 
 # External
+arrow2 = { workspace = true, features = ["io_ipc"] }
 prost.workspace = true
 thiserror.workspace = true
 tonic.workspace = true
-arrow2 = { workspace = true, features = ["io_ipc"] }
 
 [lints]
 workspace = true
diff --git a/crates/store/re_remote_store_types/src/codec.rs b/crates/store/re_remote_store_types/src/codec.rs
index 74cb664076c2..42acc31c9734 100644
--- a/crates/store/re_remote_store_types/src/codec.rs
+++ b/crates/store/re_remote_store_types/src/codec.rs
@@ -29,8 +29,8 @@ pub enum CodecError {
 pub struct MessageHader(pub u8);
 
 impl MessageHader {
-    pub const NO_DATA: Self = Self(0);
-    pub const RECORD_BATCH: Self = Self(1);
+    pub const NO_DATA: Self = Self(1);
+    pub const RECORD_BATCH: Self = Self(2);
 
     pub const SIZE_BYTES: usize = 1;
 }
@@ -215,7 +215,7 @@ mod tests {
 
     #[test]
     fn test_invalid_batch_data() {
-        let data = vec![1, 2, 3];
+        let data = vec![2, 3, 4]; // '1' is NO_DATA message header
         let decoded = TransportMessageV0::from_bytes(&data);
 
         assert!(matches!(
@@ -226,7 +226,7 @@ mod tests {
 
     #[test]
     fn test_unknown_header() {
-        let data = vec![2];
+        let data = vec![3];
         let decoded = TransportMessageV0::from_bytes(&data);
         assert!(decoded.is_err());