Implement accumulator updates for cosmwasm (#880)

* Implement accumulator updates for cosmwasm

* Update fee calculation logic for accumulator messages

The fee for accumulator messages is base fee times the number of messages
but the logic remains the same for the batch method

Author: m30m

pythnet/pythnet_sdk/src/error.rs

@@ -7,6 +7,9 @@ pub enum Error {
 
     #[error("Invalid Version")]
     InvalidVersion,
+
+    #[error("Deserialization error")]
+    DeserializationError,
 }
 
 #[macro_export]

pythnet/pythnet_sdk/src/wire.rs

@@ -57,7 +57,7 @@ pub mod v1 {
         major_version: u8,
         minor_version: u8,
         trailing:      Vec<u8>,
-        proof:         Proof,
+        pub proof:     Proof,
     }
 
     impl AccumulatorUpdateData {
@@ -72,7 +72,8 @@ pub mod v1 {
         }
 
         pub fn try_from_slice(bytes: &[u8]) -> Result<Self, Error> {
-            let message = from_slice::<byteorder::BE, Self>(bytes).unwrap();
+            let message = from_slice::<byteorder::BE, Self>(bytes)
+                .map_err(|_| Error::DeserializationError)?;
             require!(
                 &message.magic[..] == PYTHNET_ACCUMULATOR_UPDATE_MAGIC,
                 Error::InvalidMagic
@@ -109,8 +110,16 @@ pub mod v1 {
     pub const ACCUMULATOR_UPDATE_WORMHOLE_VERIFICATION_MAGIC: &[u8; 4] = b"AUWV";
 
     impl WormholeMessage {
+        pub fn new(payload: WormholePayload) -> Self {
+            Self {
+                magic: *ACCUMULATOR_UPDATE_WORMHOLE_VERIFICATION_MAGIC,
+                payload,
+            }
+        }
+
         pub fn try_from_bytes(bytes: impl AsRef<[u8]>) -> Result<Self, Error> {
-            let message = from_slice::<byteorder::BE, Self>(bytes.as_ref()).unwrap();
+            let message = from_slice::<byteorder::BE, Self>(bytes.as_ref())
+                .map_err(|_| Error::DeserializationError)?;
             require!(
                 &message.magic[..] == ACCUMULATOR_UPDATE_WORMHOLE_VERIFICATION_MAGIC,
                 Error::InvalidMagic

target_chains/cosmwasm/Cargo.lock

@@ -39,6 +39,7 @@ byteorder = "1.4.3"
 cosmwasm-schema = "1.1.9"
 osmosis-std = "0.15.2"
 pyth-sdk-cw = { path = "../../sdk/rust" }
+pythnet-sdk = { path = "../../../../pythnet/pythnet_sdk" }
 
 [dev-dependencies]
 cosmwasm-vm = { version = "1.0.0", default-features = false }