fix: remove no longer needed endpoint callback

Author: Septias

Cargo.lock

@@ -13,23 +13,18 @@ use iroh_gossip::proto::{Event as IrohEvent, TopicId};
 use iroh_net::magic_endpoint::accept_conn;
 use iroh_net::NodeId;
 use iroh_net::{derp::DerpMode, key::SecretKey, MagicEndpoint};
-use once_cell::sync::OnceCell;
-use std::sync::Arc;
-use tokio::sync::Notify;
 
 impl Context {
     /// Create magic endpoint and gossip for the context.
     pub async fn create_gossip(&self) -> Result<()> {
         let secret_key: SecretKey = self.get_or_create_iroh_keypair().await?;
 
         if self.endpoint.lock().await.is_some() {
+            warn!(self, "Tried to create gossip even tough there still exists an instance");
             return Ok(());
         }
 
-        // setup a notification to emit once the initial endpoints of our local node are discovered
-        let notify = Arc::new(Notify::new());
-
-        // build our magic endpoint
+        // build magic endpoint
         let endpoint = MagicEndpoint::builder()
             .secret_key(secret_key)
             .alpns(vec![GOSSIP_ALPN.to_vec()])
@@ -40,32 +35,15 @@ impl Context {
                     .context("Can't get parent of blob dir")?
                     .to_path_buf(),
             )
-            .on_endpoints({
-                let gossip_cell: OnceCell<Gossip> = todo!();
-                let notify = notify.clone();
-                Box::new(move |endpoints| {
-                    if endpoints.is_empty() {
-                        return;
-                    }
-                    // send our updated endpoints to the gossip protocol to be sent as NodeAddr to peers
-                    if let Some(gossip) = gossip_cell.get() {
-                        gossip.update_endpoints(endpoints).ok();
-                    }
-                    // notify the outer task of the initial endpoint update (later updates are not interesting)
-                    notify.notify_one();
-                })
-            })
             .bind(0)
             .await?;
 
-        // wait for a first endpoint update so that we know about our endpoint addresses
-        notify.notified().await;
 
         // create gossip
         let my_addr = endpoint.my_addr().await?;
         let gossip = Gossip::from_endpoint(endpoint.clone(), Default::default(), &my_addr.info);
 
-        // spawn our endpoint loop that forwards incoming connections to the gossiper
+        // spawn endpoint loop that forwards incoming connections to the gossiper
         let context = self.clone();
         tokio::spawn(endpoint_loop(context, endpoint.clone(), gossip.clone()));