From 34e31f7e0463154eefd42202e13cc8c14eac12a4 Mon Sep 17 00:00:00 2001
From: Jimmy
 <1fe240cd1a8cf775f6f3060f115e5a303181f3abf28ad4cb0c2515f4a02b36a8@meshllm.communities.buzz.xyz>
Date: Thu, 27 Aug 2026 13:08:03 +1000
Subject: [PATCH] test(mesh): prove relay mode probes are refreshed

Exercise the real NIP-11 HTTP probe three times at one URL as its response changes from open to closed to malformed. This guards against restoring the permanent mode cache and proves malformed evidence cannot be interpreted as open.

Co-authored-by: Jimmy <1fe240cd1a8cf775f6f3060f115e5a303181f3abf28ad4cb0c2515f4a02b36a8@meshllm.communities.buzz.xyz>
Signed-off-by: Jimmy <1fe240cd1a8cf775f6f3060f115e5a303181f3abf28ad4cb0c2515f4a02b36a8@meshllm.communities.buzz.xyz>
---
 .../src-tauri/src/commands/mesh_llm_tests.rs  | 46 +++++++++++++++++++
 1 file changed, 46 insertions(+)

diff --git a/desktop/src-tauri/src/commands/mesh_llm_tests.rs b/desktop/src-tauri/src/commands/mesh_llm_tests.rs
index c4e1ae2e42..ad6a8d44d1 100644
--- a/desktop/src-tauri/src/commands/mesh_llm_tests.rs
+++ b/desktop/src-tauri/src/commands/mesh_llm_tests.rs
@@ -1,5 +1,6 @@
 use super::*;
 use crate::app_state::build_app_state;
+use tokio::io::{AsyncReadExt, AsyncWriteExt};
 
 fn target(model_id: &str, endpoint_addr: &str) -> mesh_llm::MeshServeTarget {
     mesh_llm::MeshServeTarget {
@@ -27,6 +28,51 @@ fn reported_target(
     target
 }
 
+#[tokio::test]
+async fn relay_mode_probe_rechecks_the_same_url_without_caching() {
+    let listener = tokio::net::TcpListener::bind("127.0.0.1:0")
+        .await
+        .expect("bind test NIP-11 server");
+    let addr = listener.local_addr().expect("test server address");
+    let server = tokio::spawn(async move {
+        for body in [
+            r#"{"supported_nips":[1,11,42]}"#,
+            r#"{"supported_nips":[1,11,42,43]}"#,
+            r#"{"supported_nips":[1,"43"]}"#,
+        ] {
+            let (mut stream, _) = listener.accept().await.expect("accept NIP-11 request");
+            let mut request = vec![0; 2048];
+            let bytes_read = stream.read(&mut request).await.expect("read request");
+            let request = String::from_utf8_lossy(&request[..bytes_read]);
+            assert!(request.starts_with("GET / HTTP/1.1"));
+            assert!(request
+                .to_ascii_lowercase()
+                .contains("accept: application/nostr+json"));
+
+            let response = format!(
+                "HTTP/1.1 200 OK\r\nContent-Type: application/nostr+json\r\nContent-Length: {}\r\nConnection: close\r\n\r\n{body}",
+                body.len()
+            );
+            stream
+                .write_all(response.as_bytes())
+                .await
+                .expect("write response");
+        }
+    });
+    let relay_url = format!("ws://{addr}");
+
+    assert_eq!(
+        probe_relay_mesh_mode(&relay_url).await,
+        Ok(mesh_llm::MeshRelayMode::OpenNoMembership)
+    );
+    assert_eq!(
+        probe_relay_mesh_mode(&relay_url).await,
+        Ok(mesh_llm::MeshRelayMode::ClosedMembershipEnforced)
+    );
+    assert!(probe_relay_mesh_mode(&relay_url).await.is_err());
+    server.await.expect("NIP-11 server task");
+}
+
 #[test]
 fn buzz_mesh_join_uses_the_same_live_member_from_every_other_node() {
     let targets = vec![