Jito Bell: Fix deserializing (#142)

* fix: update

* fix: log

Author: aoikurokawa

jito-bell/src/event_parser/jito_steward.rs

@@ -150,3 +150,56 @@ impl JitoStewardEvent {
         None
     }
 }
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+
+    #[test]
+    fn test_parse_rebalance_event_log() {
+        let log = "Program data: eBt162gqhEtMsYgkyyouvKpCwIQK+PQ/fXApJFO4g1PcCGJg3zGq0YMDAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA==";
+
+        let event = JitoStewardEvent::parse_log(log);
+        assert!(event.is_some());
+
+        let event = event.unwrap();
+        match event {
+            JitoStewardEvent::Rebalance(_) => {
+                println!("Successfully parsed RebalanceEvent");
+            }
+            _ => panic!("Expected RebalanceEvent, got {event:?}"),
+        }
+    }
+
+    #[test]
+    fn test_parse_state_transition_log() {
+        let log = "Program data: agl496lqzumDAwAAAAAAAFUiLBcAAAAACQAAAFJlYmFsYW5jZQQAAABJZGxl";
+
+        let event = JitoStewardEvent::parse_log(log);
+        assert!(event.is_some());
+
+        let event = event.unwrap();
+        match event {
+            JitoStewardEvent::StateTransition(st) => {
+                println!("Successfully parsed StateTransition: {st:?}");
+            }
+            _ => panic!("Expected StateTransition, got {event:?}"),
+        }
+    }
+
+    #[test]
+    fn test_parse_directed_rebalance_log() {
+        let log = "Program data: uz87SL9AcR380T2ote3ZsSVQXwXdXsmLELwWrxqrmm7aHBZ2nE7pQoMDAAAAAAAAAAAAAAAAAAAAAAA=";
+
+        let event = JitoStewardEvent::parse_log(log);
+        assert!(event.is_some());
+
+        let event = event.unwrap();
+        match event {
+            JitoStewardEvent::DirectedRebalance(st) => {
+                println!("Successfully parsed DirectedRebalance: {st:?}");
+            }
+            _ => panic!("Expected DirectedRebalance, got {event:?}"),
+        }
+    }
+}

jito-bell/src/events/jito_steward.rs

@@ -56,6 +56,7 @@ pub struct DecreaseComponents {
     pub instant_unstake_lamports: u64,
     pub stake_deposit_unstake_lamports: u64,
     pub total_unstake_lamports: u64,
+    pub directed_unstake_lamports: u64,
 }
 
 impl DecreaseComponents {