feat: add DeleteTopic

Author: Frando

src/client.rs

@@ -213,6 +213,16 @@ impl Client {
         let res = r.await??;
         Ok(res)
     }
+
+    /// Delete a gossip topic.
+    pub async fn delete_gossip_topic(&mut self, topic: TopicId) -> Result<()> {
+        let (s, r) = oneshot::channel();
+        self.sender
+            .send(ActorMessage::DeleteTopic { topic, s })
+            .await?;
+        let res = r.await??;
+        Ok(res)
+    }
 }
 
 struct Actor {
@@ -264,6 +274,10 @@ enum ActorMessage {
         bootstrap: Vec<NodeId>,
         s: oneshot::Sender<anyhow::Result<()>>,
     },
+    DeleteTopic {
+        topic: iroh_gossip::proto::TopicId,
+        s: oneshot::Sender<anyhow::Result<()>>,
+    },
 }
 
 impl Actor {
@@ -436,6 +450,30 @@ impl Actor {
                 };
                 s.send(response).ok();
             }
+            ActorMessage::DeleteTopic { topic, s } => {
+                if let Err(err) = self
+                    .writer
+                    .send(ServerMessage::DeleteTopic {
+                        topic: *topic.as_bytes(),
+                    })
+                    .await
+                {
+                    s.send(Err(err.into())).ok();
+                    return;
+                }
+                let response = match self.reader.next().await {
+                    Some(Ok(msg)) => match msg {
+                        ClientMessage::DeleteTopicResponse(None) => Ok(()),
+                        ClientMessage::DeleteTopicResponse(Some(err)) => {
+                            Err(anyhow!("delete topic failed: {}", err))
+                        }
+                        _ => Err(anyhow!("unexpected message from server: {:?}", msg)),
+                    },
+                    Some(Err(err)) => Err(anyhow!("failed to receive response: {:?}", err)),
+                    None => Err(anyhow!("connection closed")),
+                };
+                s.send(response).ok();
+            }
         }
     }
 

src/protocol.rs

@@ -24,6 +24,8 @@ pub enum ServerMessage {
         label: String,
         bootstrap: Vec<NodeId>,
     },
+    /// Request that the node joins the given tossip topic
+    DeleteTopic { topic: ProtoTopicId },
     /// Request the name of a blob held by the node
     GetTag { name: String },
     /// Request to store the given metrics data
@@ -44,6 +46,8 @@ pub enum ClientMessage {
     PutBlobResponse(Option<String>),
     /// If set, this means it was an error.
     PutTopicResponse(Option<String>),
+    /// If set, this means it was an error.
+    DeleteTopicResponse(Option<String>),
     /// Simple pong response
     Pong {
         req: [u8; 32],