feat: guardian source from ethereum to pythnet (#894)

Author: Reisen

hermes/src/config.rs

@@ -1,5 +1,6 @@
 use {
     libp2p::Multiaddr,
+    solana_sdk::pubkey::Pubkey,
     std::net::SocketAddr,
     structopt::StructOpt,
 };
@@ -15,6 +16,9 @@ pub enum Options {
         #[structopt(long, env = "PYTHNET_WS_ENDPOINT")]
         pythnet_ws_endpoint: String,
 
+        #[structopt(long, env = "PYTHNET_HTTP_ENDPOINT")]
+        pythnet_http_endpoint: String,
+
         /// Network ID for Wormhole
         #[structopt(
             long,
@@ -45,20 +49,8 @@ pub enum Options {
         #[structopt(long, default_value = "127.0.0.1:33999")]
         api_addr: SocketAddr,
 
-        /// Ethereum RPC endpoint
-        #[structopt(long, env = "ETH_RPC_ENDPOINT")]
-        eth_rpc_endpoint: String,
-
-        /// Wormhole contract address on Ethereum
-        #[structopt(
-            long,
-            env = "WORMHOLE_CONTRACT_ADDRESS",
-            default_value = "0x98f3c9e6E3fAce36bAAd05FE09d375Ef1464288B"
-        )]
-        wormhole_eth_contract_address: String,
-
-        /// Ethereum RPC polling duration
-        #[structopt(long, env = "ETH_POLLING_INTERVAL", default_value = "10s")]
-        eth_polling_interval: humantime::Duration,
+        /// Address of the Wormhole contract on the target PythNet cluster.
+        #[structopt(long, default_value = "H3fxXJ86ADW2PNuDDmZJg6mzTtPxkYCpNuQUTgmJ7AjU")]
+        wh_contract_addr: Pubkey,
     },
 }

hermes/src/main.rs

@@ -22,13 +22,12 @@ async fn init() -> Result<()> {
     match config::Options::from_args() {
         config::Options::Run {
             pythnet_ws_endpoint,
+            pythnet_http_endpoint,
             wh_network_id,
             wh_bootstrap_addrs,
             wh_listen_addrs,
+            wh_contract_addr,
             api_addr,
-            eth_rpc_endpoint,
-            wormhole_eth_contract_address,
-            eth_polling_interval,
         } => {
             // A channel to emit state updates to api
             let (update_tx, update_rx) = tokio::sync::mpsc::channel(1000);
@@ -46,23 +45,16 @@ async fn init() -> Result<()> {
             )
             .await?;
 
-            // Spawn the Ethereum guardian set watcher
-            log::info!(
-                "Starting Ethereum guardian set watcher using {}",
-                eth_rpc_endpoint
-            );
-            network::ethereum::spawn(
+            // Spawn the Pythnet listener
+            log::info!("Starting Pythnet listener using {}", pythnet_ws_endpoint);
+            network::pythnet::spawn(
                 store.clone(),
-                eth_rpc_endpoint,
-                wormhole_eth_contract_address,
-                eth_polling_interval.into(),
+                pythnet_ws_endpoint,
+                pythnet_http_endpoint,
+                wh_contract_addr,
             )
             .await?;
 
-            // Spawn the Pythnet listener
-            log::info!("Starting Pythnet listener using {}", pythnet_ws_endpoint);
-            network::pythnet::spawn(store.clone(), pythnet_ws_endpoint).await?;
-
             // Run the RPC server and wait for it to shutdown gracefully.
             log::info!("Starting RPC server on {}", api_addr);
             api::run(store.clone(), update_rx, api_addr.to_string()).await?;

hermes/src/network.rs

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