dedup relay endpoints in boost and builder configs

mev-boost-rs/src/service.rs

@@ -11,6 +11,7 @@ use serde::Deserialize;
 use std::{future::Future, net::Ipv4Addr, pin::Pin, task::Poll};
 use tokio::task::{JoinError, JoinHandle};
 use tracing::{info, warn};
+use std::collections::HashSet;
 
 #[derive(Debug, Deserialize)]
 pub struct Config {
@@ -37,8 +38,12 @@ pub struct Service {
 impl Service {
     pub fn from(network: Network, config: Config) -> Self {
         let relays = parse_relay_endpoints(&config.relays);
+        let mut relayset: HashSet<RelayEndpoint> = HashSet::new();
+        for relay in relays.into_iter(){
+          relayset.insert(relay);
+        }
 
-        Self { host: config.host, port: config.port, relays, network, config }
+        Self { host: config.host, port: config.port, relays: Vec::from_iter(relayset), network, config }
     }
 
     /// Spawns a new [`RelayMux`] and [`BlindedBlockProviderServer`] task

mev-build-rs/src/auctioneer/service.rs

@@ -17,7 +17,7 @@ use mev_rs::{
     relay::parse_relay_endpoints,
     signing::sign_builder_message,
     types::{block_submission, BidTrace, SignedBidSubmission},
-    BlindedBlockRelayer, Relay,
+    BlindedBlockRelayer, Relay, RelayEndpoint,
 };
 use reth::{
     api::{EngineTypes, PayloadBuilderAttributes},
@@ -155,8 +155,13 @@ impl<
         context: Arc<Context>,
         genesis_time: u64,
     ) -> Self {
-        let relays =
-            parse_relay_endpoints(&config.relays).into_iter().map(Relay::from).collect::<Vec<_>>();
+        let relays = parse_relay_endpoints(&config.relays);
+        let mut relayset: HashSet<RelayEndpoint> = HashSet::new();
+        for relay in relays.into_iter(){
+          relayset.insert(relay);
+        }
+
+        let relays = relayset.into_iter().map(Relay::from).collect::<Vec<_>>();
 
         config.public_key = config.secret_key.public_key();
 

mev-rs/src/relay.rs

@@ -29,6 +29,21 @@ impl TryFrom<Url> for RelayEndpoint {
     }
 }
 
+impl hash::Hash for RelayEndpoint {
+  fn hash<H: hash::Hasher>(&self, state: &mut H) {
+      self.public_key.hash(state);
+  }
+}
+
+impl cmp::PartialEq for RelayEndpoint {
+  fn eq(&self, other: &Self) -> bool {
+      self.public_key == other.public_key
+  }
+}
+
+impl cmp::Eq for RelayEndpoint {}
+
+
 impl fmt::Debug for RelayEndpoint {
     fn fmt(&self, f: &mut fmt::Formatter<'_>) -> Result<(), fmt::Error> {
         f.write_str(self.url.as_str())