WIP: subman API

Cargo.toml

@@ -24,6 +24,7 @@ egui_virtual_list = "0.5.0"
 ehttp = "0.2.0"
 enostr = { path = "crates/enostr" } 
 ewebsock = { version = "0.2.0", features = ["tls"] }
+futures = "0.3.31"
 hex = "0.4.3"
 image = { version = "0.25", features = ["jpeg", "png", "webp"] }
 indexmap = "2.6.0"

crates/enostr/src/relay/pool.rs

@@ -96,6 +96,15 @@ impl PoolRelay {
     }
 
     pub fn subscribe(&mut self, subid: String, filter: Vec<Filter>) -> Result<()> {
+        debug!(
+            "PoolRelay subscribe: sending sub {} {}: {:?}",
+            subid,
+            self.url(),
+            filter
+                .iter()
+                .map(|f| f.json().unwrap_or_default())
+                .collect::<Vec<_>>(),
+        );
         self.send(&ClientMessage::req(subid, filter))
     }
 
@@ -197,6 +206,7 @@ impl RelayPool {
             if let Some(debug) = &mut self.debug {
                 debug.send_cmd(relay.url().to_owned(), &cmd);
             }
+            debug!("RelayPool unsubscribe close {} {}", subid, relay.url());
             if let Err(err) = relay.send(&cmd) {
                 error!(
                     "error unsubscribing from {} on {}: {err}",
@@ -215,10 +225,57 @@ impl RelayPool {
                     &ClientMessage::req(subid.clone(), filter.clone()),
                 );
             }
+            debug!(
+                "RelayPool subscribe: sending sub {} {}: {:?}",
+                subid,
+                relay.url(),
+                filter
+                    .iter()
+                    .map(|f| f.json().unwrap_or_default())
+                    .collect::<Vec<_>>(),
+            );
+            if let Err(err) = relay.send(&ClientMessage::req(subid.clone(), filter.clone())) {
+                error!("error subscribing to {}: {err}", relay.url());
+            }
+        }
+    }
 
+    // if the relay is in the pool already send the subscription, otherwise add the
+    // relay to the pool and we'll send it on open.
+    pub fn subscribe_relay(
+        &mut self,
+        subid: String,
+        filter: Vec<Filter>,
+        relaystr: String,
+    ) -> bool {
+        if let Some(&mut ref mut relay) = self.relays.iter_mut().find(|r| r.url() == relaystr) {
+            if let Some(debug) = &mut self.debug {
+                debug.send_cmd(
+                    relay.url().to_owned(),
+                    &ClientMessage::req(subid.clone(), filter.clone()),
+                );
+            }
+            debug!(
+                "RelayPool subscribe_relay: sending sub {} {}: {:?}",
+                subid,
+                relay.url(),
+                filter
+                    .iter()
+                    .map(|f| f.json().unwrap_or_default())
+                    .collect::<Vec<_>>(),
+            );
             if let Err(err) = relay.send(&ClientMessage::req(subid.clone(), filter.clone())) {
                 error!("error subscribing to {}: {err}", relay.url());
             }
+            true
+        } else {
+            let wakeup = move || {
+                // ignore
+            };
+            if let Err(err) = self.add_url(relaystr.clone(), wakeup) {
+                error!("trouble adding url {}: {:?}", relaystr, err);
+            }
+            false
         }
     }
 
@@ -340,7 +397,7 @@ impl RelayPool {
     }
 
     // standardize the format (ie, trailing slashes)
-    fn canonicalize_url(url: String) -> String {
+    pub fn canonicalize_url(url: String) -> String {
         match Url::parse(&url) {
             Ok(parsed_url) => parsed_url.to_string(),
             Err(_) => url, // If parsing fails, return the original URL.

crates/notedeck/Cargo.toml

@@ -13,6 +13,7 @@ dirs = { workspace = true }
 enostr = { workspace = true }
 egui = { workspace = true }
 eframe = { workspace = true }
+futures = { workspace = true }
 image = { workspace = true }
 base32 = { workspace = true }
 poll-promise = { workspace = true }
@@ -25,9 +26,11 @@ thiserror = { workspace = true }
 puffin = { workspace = true, optional = true }
 puffin_egui = { workspace = true, optional = true }
 sha2 = { workspace = true }
+tokio = { workspace = true, features = ["macros", "rt-multi-thread", "fs"] }
 
 [dev-dependencies]
 tempfile = { workspace = true }
+nostr = { workspace = true }
 
 [target.'cfg(target_os = "macos")'.dependencies]
 security-framework = { workspace = true }