added serde deserialization

Author: ayushboss

target_chains/stylus/Cargo.lock

@@ -1,22 +1,21 @@
 [package]
-name = "stylus-hello-world"
+name = "pyth-receiver-stylus"
 version = "0.1.11"
 edition = "2021"
-license = "MIT OR Apache-2.0"
-homepage = "https://github.com/OffchainLabs/stylus-hello-world"
-repository = "https://github.com/OffchainLabs/stylus-hello-world"
-keywords = ["arbitrum", "ethereum", "stylus", "alloy"]
-description = "Stylus hello world example"
+homepage = "https://github.com/pyth-network/pyth-crosschain"
+repository = "https://github.com/pyth-network/pyth-crosschain"
+keywords = ["arbitrum", "ethereum", "stylus", "alloy", "pyth"]
+description = "Pyth receiver contract for the Arbitrum networks, built on Arbitrum Stylus"
 
 [dependencies]
 alloy-primitives = "=0.8.20"
 alloy-sol-types = "=0.8.20"
 stylus-sdk = "0.9.0"
 byteorder = { version = "1.4.3" }
 hex = { version = "0.4", default-features = false }
-serde = { version = "1.0", features = ["derive"] }
 pythnet-sdk = { path = "../../../../pythnet/pythnet_sdk" }
 pyth-types = { path = "../pyth-types" }
+serde = { version = "1.0", features = ["derive"] }
 wormhole-vaas = "0.1.1"
 wormhole-contract = { path = "../../contracts/wormhole" }
 

target_chains/stylus/contracts/pyth-receiver/Cargo.toml

@@ -176,7 +176,6 @@ impl PythReceiver {
                         return Err(PythReceiverError::InvalidMerkleProof);
                     }
 
-                    // UPDATE STORED PRICE INFO BASED ON THE UPDATES IN THE VAA
                     let msg = from_slice::<byteorder::BE, Message>(&message_vec)
                         .map_err(|_| PythReceiverError::InvalidAccumulatorMessage)?;
 
@@ -263,15 +262,6 @@ impl PythReceiver {
 
         current_u64.saturating_sub(publish_time_u64) <= max_age
     }
-
-    // Updates the Price Feed only if it is newer than the current one. This function never fails
-    // and will either update in-place or not update at all. The return value indicates whether
-    // the update was performed or not.
-    // fn update_price_feed_if_new(&self, price_id: [u8; 32], price_feed: PriceInfo) -> bool {
-
-    // }
-
-
 }
 
 fn parse_wormhole_proof(vaa: Vaa) -> Result<MerkleRoot<Keccak160>, PythReceiverError> {
@@ -282,5 +272,3 @@ fn parse_wormhole_proof(vaa: Vaa) -> Result<MerkleRoot<Keccak160>, PythReceiverE
     });
     Ok(root)
 }
-
-

target_chains/stylus/contracts/pyth-receiver/src/lib.rs

@@ -22,12 +22,12 @@ fn serialize_data_source_to_bytes(chain_id: u16, emitter_address: &[u8; 32]) ->
         chain_id,
         emitter_address: *emitter_address,
     };
-    
+
     let bytes = to_vec::<_, byteorder::BE>(&data_source)?;
     if bytes.len() != 34 {
         return Err(format!("Expected 34 bytes, got {}", bytes.len()).into());
     }
-    
+
     let mut result = [0u8; 34];
     result.copy_from_slice(&bytes);
     Ok(result)
@@ -50,10 +50,10 @@ impl StorageKey for DataSourceStorage {
     fn to_slot(&self, root: B256) -> U256 {
         let chain_id: u16 = self.chain_id.get().to::<u16>();
         let emitter_address = self.emitter_address.get();
-        
+
         let bytes = serialize_data_source_to_bytes(chain_id, emitter_address.as_slice().try_into().unwrap())
             .expect("Failed to serialize DataSource");
-        
+
         keccak256(bytes).to_slot(root)
     }
 }
@@ -62,10 +62,10 @@ impl StorageKey for DataSource {
     fn to_slot(&self, root: B256) -> U256 {
         let chain_id: u16 = self.chain_id.to::<u16>();
         let emitter_address: [u8; 32] = self.emitter_address.as_slice().try_into().unwrap();
-        
+
         let bytes = serialize_data_source_to_bytes(chain_id, &emitter_address)
             .expect("Failed to serialize DataSource");
-        
+
         keccak256(bytes).to_slot(root)
     }
 }
@@ -143,7 +143,7 @@ mod tests {
 
         let actual_bytes = serialize_data_source_to_bytes(chain_id, &emitter_address)
             .expect("Serialization should succeed");
-        
+
         assert_eq!(actual_bytes, expected_bytes, "Serialization should produce identical bytes");
     }
 }