Add vaa verification

Author: ali-behjati

hermes/Cargo.lock

@@ -68,6 +68,13 @@ wormhole-sdk = { git = "https://github.com/wormhole-foundation/wormhole", tag =
 pyth-oracle = { git = "https://github.com/pyth-network/pyth-client", rev = "7d593d87e07a1e2486e7ca21597d664ee72be1ec", features = ["library"] }
 
 strum = { version = "0.24", features = ["derive"] }
+ethabi = { version = "18.0.0", features = ["serde"] }
 
 [patch.crates-io]
 serde_wormhole = { git = "https://github.com/wormhole-foundation/wormhole", tag = "v2.17.1" }
+
+[profile.release]
+panic = 'abort'
+
+[profile.dev]
+panic = 'abort'

hermes/Cargo.toml

@@ -32,7 +32,7 @@ impl State {
 ///
 /// Currently this is based on Axum due to the simplicity and strong ecosystem support for the
 /// packages they are based on (tokio & hyper).
-pub async fn spawn(rpc_addr: String, store: Store) -> Result<()> {
+pub async fn spawn(store: Store, rpc_addr: String) -> Result<()> {
     let state = State::new(store);
 
     // Initialize Axum Router. Note the type here is a `Router<State>` due to the use of the

hermes/src/api.rs

@@ -36,23 +36,31 @@ async fn init() -> Result<()> {
             // Spawn the P2P layer.
             log::info!("Starting P2P server on {:?}", wh_listen_addrs);
             network::p2p::spawn(
+                store.clone(),
                 wh_network_id.to_string(),
                 wh_bootstrap_addrs,
                 wh_listen_addrs,
-                store.clone(),
             )
             .await?;
 
+            // Spawn the Ethereum guardian set watcher
+            network::ethereum::spawn(
+                store.clone(),
+                "https://rpc.ankr.com/eth".to_owned(),
+                "0x98f3c9e6E3fAce36bAAd05FE09d375Ef1464288B".to_owned(),
+            )
+            .await;
+
             // Spawn the RPC server.
             log::info!("Starting RPC server on {}", api_addr);
 
             // TODO: Add max size to the config
-            api::spawn(api_addr.to_string(), store.clone()).await?;
+            api::spawn(store.clone(), api_addr.to_string()).await?;
 
             // Spawn the Pythnet listener
             // TODO: Exit the thread when it gets spawned
             log::info!("Starting Pythnet listener using {}", pythnet_ws_endpoint);
-            network::pythnet::spawn(pythnet_ws_endpoint, store.clone()).await?;
+            network::pythnet::spawn(store.clone(), pythnet_ws_endpoint).await?;
 
             // Wait on Ctrl+C similar to main.
             tokio::signal::ctrl_c().await?;

hermes/src/main.rs

@@ -1,2 +1,3 @@
+pub mod ethereum;
 pub mod p2p;
 pub mod pythnet;