final tests, removed redundant id check within specs

Author: erhant

compute/src/node/reqres.rs

@@ -51,16 +51,6 @@ impl DriaComputeNode {
             spec_request.request_id
         );
 
-        // ensure peer is authorized
-        if !self.dria_nodes.rpc_peerids.contains(&peer_id) {
-            log::warn!(
-                "Received spec request from unauthorized source: {}",
-                peer_id
-            );
-            log::debug!("Allowed sources: {:#?}", self.dria_nodes.rpc_peerids);
-            return Err(eyre!("Received unauthorized spec request from {}", peer_id));
-        }
-
         let response = SpecResponder::respond(spec_request, self.spec_collector.collect().await);
         let response_data = serde_json::to_vec(&response)?;
 
@@ -145,7 +135,12 @@ impl DriaComputeNode {
             Some(channel) => {
                 TaskResponder::handle_respond(self, task_response, channel).await?;
             }
-            None => log::error!("Channel not found for task id: {}", task_response.task_id),
+            None => {
+                return Err(eyre!(
+                    "Channel not found for task id: {}",
+                    task_response.task_id
+                ))
+            }
         };
 
         Ok(())

compute/src/utils/message.rs

@@ -86,7 +86,7 @@ impl DriaMessage {
         let recovery_id =
             RecoveryId::parse(self.recovery_id).wrap_err("could not decode recovery id")?;
 
-        // verify signature w.r.t the body and the given public key
+        // verify signature w.r.t the payload and the given public key
         let message = Message::parse(&sha256hash(&self.payload));
 
         let recovered_public_key = recover(&message, &signature, &recovery_id)?;

p2p/src/network.rs

@@ -45,11 +45,11 @@ impl DriaNetworkType {
     pub fn get_static_bootstrap_nodes(&self) -> Vec<Multiaddr> {
         match self {
              DriaNetworkType::Community => [
-              // "/ip4/18.205.158.27/tcp/4001/p2p/16Uiu2HAmB2GFG8oYa7DuivXYEsMUPiiKQ6yq9haQHRHHjJrn7FHo",
-                 "/ip4/44.206.245.139/tcp/4001/p2p/16Uiu2HAm4q3LZU2T9kgjKK4ysy6KZYKLq8KiXQyae4RHdF7uqSt4",
-                 "/ip4/18.234.39.91/tcp/4001/p2p/16Uiu2HAmJqegPzwuGKWzmb5m3RdSUJ7NhEGWB5jNCd3ca9zdQ9dU",
-                 "/ip4/54.242.44.217/tcp/4001/p2p/16Uiu2HAmR2sAoh9F8jT9AZup9y79Mi6NEFVUbwRvahqtWamfabkz",
-                 "/ip4/52.201.242.227/tcp/4001/p2p/16Uiu2HAmFEUCy1s1gjyHfc8jey4Wd9i5bSDnyFDbWTnbrF2J3KFb",
+              "/ip4/18.205.158.27/tcp/4001/p2p/16Uiu2HAmB2GFG8oYa7DuivXYEsMUPiiKQ6yq9haQHRHHjJrn7FHo",
+                //  "/ip4/44.206.245.139/tcp/4001/p2p/16Uiu2HAm4q3LZU2T9kgjKK4ysy6KZYKLq8KiXQyae4RHdF7uqSt4",
+                //  "/ip4/18.234.39.91/tcp/4001/p2p/16Uiu2HAmJqegPzwuGKWzmb5m3RdSUJ7NhEGWB5jNCd3ca9zdQ9dU",
+                //  "/ip4/54.242.44.217/tcp/4001/p2p/16Uiu2HAmR2sAoh9F8jT9AZup9y79Mi6NEFVUbwRvahqtWamfabkz",
+                //  "/ip4/52.201.242.227/tcp/4001/p2p/16Uiu2HAmFEUCy1s1gjyHfc8jey4Wd9i5bSDnyFDbWTnbrF2J3KFb",
              ].iter(),
              DriaNetworkType::Pro => [].iter(),
              DriaNetworkType::Test => [].iter(),
@@ -63,11 +63,11 @@ impl DriaNetworkType {
     pub fn get_static_relay_nodes(&self) -> Vec<Multiaddr> {
         match self {
              DriaNetworkType::Community => [
-              // "/ip4/3.88.84.50/tcp/4001/p2p/16Uiu2HAmN35mw5MMf3SCUt3TpEU6WnBvjYJQ4ZZeKHRHEkSc4RPq",
-                 "/ip4/34.201.33.141/tcp/4001/p2p/16Uiu2HAkuXiV2CQkC9eJgU6cMnJ9SMARa85FZ6miTkvn5fuHNufa",
-                 "/ip4/18.232.93.227/tcp/4001/p2p/16Uiu2HAmHeGKhWkXTweHJTA97qwP81ww1W2ntGaebeZ25ikDhd4z",
-                 "/ip4/54.157.219.194/tcp/4001/p2p/16Uiu2HAm7A5QVSy5FwrXAJdNNsdfNAcaYahEavyjnFouaEi22dcq",
-                 "/ip4/54.88.171.104/tcp/4001/p2p/16Uiu2HAm5WP1J6bZC3aHxd7XCUumMt9txAystmbZSaMS2omHepXa",
+              "/ip4/3.88.84.50/tcp/4001/p2p/16Uiu2HAmN35mw5MMf3SCUt3TpEU6WnBvjYJQ4ZZeKHRHEkSc4RPq",
+                //  "/ip4/34.201.33.141/tcp/4001/p2p/16Uiu2HAkuXiV2CQkC9eJgU6cMnJ9SMARa85FZ6miTkvn5fuHNufa",
+                //  "/ip4/18.232.93.227/tcp/4001/p2p/16Uiu2HAmHeGKhWkXTweHJTA97qwP81ww1W2ntGaebeZ25ikDhd4z",
+                //  "/ip4/54.157.219.194/tcp/4001/p2p/16Uiu2HAm7A5QVSy5FwrXAJdNNsdfNAcaYahEavyjnFouaEi22dcq",
+                //  "/ip4/54.88.171.104/tcp/4001/p2p/16Uiu2HAm5WP1J6bZC3aHxd7XCUumMt9txAystmbZSaMS2omHepXa",
              ].iter(),
              DriaNetworkType::Pro => [].iter(),
              DriaNetworkType::Test => [].iter(),
@@ -81,8 +81,8 @@ impl DriaNetworkType {
     pub fn get_static_rpc_nodes(&self) -> Vec<Multiaddr> {
         match self {
             DriaNetworkType::Community => [
-                // "/ip4/104.28.54.97/tcp/4001/p2p/16Uiu2HAmEcBQRQy4CVCnQ144rnvagKa1fS5uAguwq9S2DRiRmAWE",
-            ]
+              "/ip4/3.238.173.11/tcp/4001/p2p/16Uiu2HAmEcBQRQy4CVCnQ144rnvagKa1fS5uAguwq9S2DRiRmAWE"
+              ]
             .iter(),
             DriaNetworkType::Pro => [].iter(),
             DriaNetworkType::Test => [].iter(),
@@ -95,7 +95,9 @@ impl DriaNetworkType {
     #[inline(always)]
     pub fn get_static_rpc_peer_ids(&self) -> Vec<PeerId> {
         match self {
-            DriaNetworkType::Community => [].iter(),
+            DriaNetworkType::Community => {
+                ["16Uiu2HAmEcBQRQy4CVCnQ144rnvagKa1fS5uAguwq9S2DRiRmAWE"].iter()
+            }
             DriaNetworkType::Pro => [].iter(),
             DriaNetworkType::Test => [].iter(),
         }