Remove sequence state clearing on block rewind

Author: sergeytimoshin

src/ingester/fetchers/poller.rs

@@ -72,13 +72,11 @@ pub fn get_block_poller_stream(
                                 log::error!("Rewinding block stream to {}: {}", to_slot, reason);
                                 // Clear cached blocks
                                 block_cache.clear();
-                                // Clear sequence state to re-learn from rewound point
-                                crate::ingester::gap::clear_sequence_state();
                                 // Reset positions
                                 last_indexed_slot = to_slot - 1;
                                 current_start_slot = to_slot;
                                 rewind_occurred = true;
-                                log::info!("Cleared cache and sequence state, restarting from slot {}", current_start_slot);
+                                log::info!("Cleared cache, restarting from slot {}", current_start_slot);
                                 break;
                             }
                         }

src/ingester/gap/sequences.rs

@@ -119,18 +119,19 @@ impl StateUpdateSequences {
             }
         }
 
-        // Extract out_account leaf indexes
+        // Extract out_account sequences
         for account_with_context in &state_update.out_accounts {
             let tree_pubkey = account_with_context.account.tree.0;
-            let leaf_index = account_with_context.account.leaf_index.0;
-            self.out_account_leaf_indexes
-                .entry(tree_pubkey)
-                .or_insert_with(Vec::new)
-                .push(SequenceEntry {
-                    sequence: leaf_index,
-                    slot,
-                    signature: signature.to_string(),
-                });
+            if let Some(seq_value) = account_with_context.account.seq {
+                self.out_account_leaf_indexes
+                    .entry(tree_pubkey)
+                    .or_insert_with(Vec::new)
+                    .push(SequenceEntry {
+                        sequence: seq_value.0,
+                        slot,
+                        signature: signature.to_string(),
+                    });
+            }
         }
     }