feat(swarm): host a swarm rendezvous on every node

Cargo.toml

@@ -242,3 +242,10 @@ cognitive_complexity = "allow"
 # Allow non-const functions during initial development (may need runtime features later)
 missing_const_for_fn = "allow"
 
+# The swarm's wire types (ant-protocol #50), the send on one named channel
+# (saorsa-core #183) and the plain STUN answers (saorsa-transport #231) are on
+# these branches until they merge.
+[patch.crates-io]
+ant-protocol = { git = "https://github.com/grumbach/ant-protocol", branch = "feat/peer-swarm" }
+saorsa-core = { git = "https://github.com/grumbach/saorsa-core", branch = "feat/peer-swarm" }
+saorsa-transport = { git = "https://github.com/grumbach/saorsa-transport", branch = "feat/peer-swarm" }

docs/adr/README.md

@@ -41,3 +41,4 @@ See [`TOOLING.md`](./TOOLING.md) for `adrs`, `adr-kit`, and AI harness setup.
 - [ADR-0019: Pointer audits serve the record round 1 bound](./ADR-0019-pointer-audits-serve-the-record-round-one-bound.md)
 - [ADR-0022: Remove the LMDB Chunk Store](./ADR-0022-remove-the-lmdb-chunk-store.md)
 - [ADR-0023: Spread hot-record reads across the close group, and refuse full browser sessions explicitly](./ADR-0023-spread-hot-reads-and-refuse-full-browser-sessions.md)
+- [ADR-0026: Clients reading the same file share its records; nodes introduce them and stay the last seed](./ADR-0026-clients-share-records-nodes-introduce-them.md)

scripts/third_party_notices/config.toml

@@ -108,7 +108,7 @@ text_sha256 = "b05785f9f18e6716bab63424b11454513b9943a222595b70411009202fc592b5"
 note = "its COPYING, reproduced with its copyright lines, refers to LICENSE-MIT and LICENSE-APACHE files that neither the crate nor its repository contain; the MIT text is reproduced from the SPDX licence list."
 
 [missing.granit-parser]
-version = "1.3.0"
+version = "2.0.0"
 text_url = "https://raw.githubusercontent.com/spdx/license-list-data/v3.29.0/text/MIT.txt"
 text_sha256 = "b05785f9f18e6716bab63424b11454513b9943a222595b70411009202fc592b5"
 note = "its root LICENSE, reproduced with its notices for Chen Yuheng, Ethiraric and Bourumir Wyngs, refers to licence texts the crate ships under a hidden .licenses directory, which is not searched for licence files; the MIT text is reproduced from the SPDX licence list."

scripts/third_party_notices/generate.py

@@ -38,6 +38,7 @@
 import time
 import tomllib
 import urllib.error
+import urllib.parse
 import urllib.request
 
 LICENCE_FILE = re.compile(
@@ -152,7 +153,11 @@ def resolve_package(name, version, annotation, by_name_version):
     elif annotation.startswith("registry "):
         raise Gap(f"{name} {version} comes from {annotation}; only crates.io is supported")
     elif "://" in annotation:
-        matches = [p for p in candidates if (p["source"] or "").startswith("git+" + annotation)]
+        # cargo tree percent-encodes a git branch's slashes, cargo metadata
+        # does not: compare both decoded.
+        wanted = "git+" + urllib.parse.unquote(annotation)
+        matches = [p for p in candidates
+                   if urllib.parse.unquote(p["source"] or "").startswith(wanted)]
     else:
         wanted = os.path.realpath(annotation)
         matches = [p for p in candidates if p["source"] is None

src/devnet.rs

@@ -27,6 +27,11 @@ use tokio::sync::RwLock;
 use tokio::task::JoinHandle;
 use tokio::time::Instant;
 use tokio_util::sync::CancellationToken;
+use tokio_util::task::TaskTracker;
+
+use crate::node::NativeSwarmRouter;
+#[cfg(feature = "webrtc-direct")]
+use crate::swarm::SwarmService;
 
 #[cfg(all(feature = "webrtc-direct", feature = "test-utils"))]
 use crate::ant_protocol::{ChunkMessage, ChunkMessageBody, ChunkPutRequest, ChunkPutResponse};
@@ -1059,11 +1064,17 @@ impl Devnet {
                     node.index
                 ))
             })?;
+            let swarm = node
+                .ant_protocol
+                .as_ref()
+                .map_or_else(SwarmService::new, |protocol| Arc::clone(protocol.swarm()));
+            swarm.set_node_id(*p2p.peer_id().to_bytes());
             let server = crate::web_rtc::spawn(
                 &webrtc_direct_config,
                 &node.data_dir,
                 p2p,
                 node.ant_protocol.clone(),
+                swarm,
                 self.config
                     .evm_network
                     .as_ref()
@@ -1091,8 +1102,18 @@ impl Devnet {
             let p2p_clone = Arc::clone(p2p);
             let protocol_clone = Arc::clone(protocol);
             let node_index = node.index;
+            // Native clients' swarm requests, as a node routes them.
+            let swarm = NativeSwarmRouter::start(
+                Arc::clone(protocol.swarm()),
+                Arc::clone(p2p),
+                TaskTracker::new(),
+                self.shutdown.clone(),
+            );
             node.protocol_task = Some(tokio::spawn(async move {
                 while let Ok(event) = events.recv().await {
+                    if swarm.route(&event) {
+                        continue;
+                    }
                     if let P2PEvent::Message {
                         topic,
                         source: Some(source),

src/lib.rs

@@ -58,6 +58,7 @@ pub mod payment;
 pub mod pointer;
 pub mod replication;
 pub mod storage;
+pub mod swarm;
 pub mod upgrade;
 #[cfg(feature = "webrtc-direct")]
 mod web_rtc;