Merge pull request #70 from helius-labs/json-parsed

Fix: Preserve internal slot tracker in write() calls

Author: hetdagli234

javascript/Cargo.lock

@@ -1,6 +1,6 @@
 [package]
 name = "laserstream-napi"
-version = "0.2.6"
+version = "0.2.7"
 edition = "2021"
 
 [lib]

javascript/Cargo.toml

@@ -22,7 +22,7 @@ const FORK_DEPTH_SAFETY_MARGIN: u64 = 31; // Max fork depth for processed commit
 
 // SDK metadata constants
 const SDK_NAME: &str = "laserstream-javascript";
-const SDK_VERSION: &str = "0.2.6";
+const SDK_VERSION: &str = "0.2.7";
 
 /// Custom interceptor that adds SDK metadata headers to all gRPC requests
 #[derive(Clone)]
@@ -478,6 +478,11 @@ impl StreamInner {
         current: &mut geyser::SubscribeRequest,
         modification: &geyser::SubscribeRequest,
     ) {
+        // Save the internal slot tracker before replacing slots
+        let internal_tracker = current.slots.iter()
+            .find(|(k, _)| k.starts_with("__internal_slot_tracker_"))
+            .map(|(k, v)| (k.clone(), v.clone()));
+
         // Replace all subscription types (Yellowstone gRPC replaces, not merges)
         current.accounts = modification.accounts.clone();
         current.slots = modification.slots.clone();
@@ -488,6 +493,11 @@ impl StreamInner {
         current.entry = modification.entry.clone();
         current.accounts_data_slice = modification.accounts_data_slice.clone();
 
+        // Restore the internal slot tracker if it existed
+        if let Some((key, value)) = internal_tracker {
+            current.slots.insert(key, value);
+        }
+
         // Update commitment if specified
         if modification.commitment.is_some() {
             current.commitment = modification.commitment;

javascript/napi-src/stream.rs

@@ -1,6 +1,6 @@
 {
   "name": "helius-laserstream",
-  "version": "0.2.6",
+  "version": "0.2.7",
   "description": "High-performance Laserstream gRPC client with automatic reconnection",
   "main": "client.js",
   "types": "client.d.ts",
@@ -83,12 +83,12 @@
     }
   },
   "optionalDependencies": {
-    "helius-laserstream-darwin-arm64": "0.2.6",
-    "helius-laserstream-darwin-x64": "0.2.6",
-    "helius-laserstream-linux-arm64-gnu": "0.2.6",
-    "helius-laserstream-linux-arm64-musl": "0.2.6",
-    "helius-laserstream-linux-x64-gnu": "0.2.6",
-    "helius-laserstream-linux-x64-musl": "0.2.6"
+    "helius-laserstream-darwin-arm64": "0.2.7",
+    "helius-laserstream-darwin-x64": "0.2.7",
+    "helius-laserstream-linux-arm64-gnu": "0.2.7",
+    "helius-laserstream-linux-arm64-musl": "0.2.7",
+    "helius-laserstream-linux-x64-gnu": "0.2.7",
+    "helius-laserstream-linux-x64-musl": "0.2.7"
   },
   "dependencies": {
     "@types/protobufjs": "^6.0.0",