refactor: remove the public-content swarm

Nodes registered the hashes of their public groups on the hub and nothing
ever read them back. Routes, model and node registration removed; a
migration drops swarm_sources. No node sends the hub a content hash now.

Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>

1 files changed, 0 insertions, 28 deletions

diff --git a/packages/meshbay-node/src/meshbay_node/daemon.py b/packages/meshbay-node/src/meshbay_node/daemon.py
index 220a908..a29aa9f 100644
--- a/packages/meshbay-node/src/meshbay_node/daemon.py
+++ b/packages/meshbay-node/src/meshbay_node/daemon.py
@@ -667,12 +667,6 @@ class NodeDaemon(EnrichmentMixin):
                 await indexer.initial_scan()
                 log.info("Background scan complete for %s: %d files",
                          name, indexer.index.count)
-                # Swarm registration for public groups (after files are known).
-                if gctx.get("visibility") == "public":
-                    endpoint = f"webrtc:{self._config.node.quic_port}"
-                    hashes = [e.id for e in gctx["index"].entries]
-                    if hashes:
-                        await self._register_swarm(hashes, endpoint)
                 # initial_scan() itself never calls on_change (it predates
                 # the concept — every existing caller only cared about the
                 # scan finishing, not about notifying anyone) — but Videos
@@ -1468,21 +1462,6 @@ class NodeDaemon(EnrichmentMixin):
                     log.info("Index %s pushed to %d WebRTC peers",
                              "delta" if delta is not None else "sync", pushed)
 
-        # 11.9 — Register file hashes with hub swarm table (public groups only, H7)
-        group_cfg = next(
-            (g for g in self._config.groups if g.id == group_id), None)
-        if (self._hub and self._state.get("endpoint_hint")
-                and group_cfg and group_cfg.visibility == "public"):
-            # Only the newly added hashes once there is a delta to know them
-            # from — registering the whole library again on every change is
-            # the same O(changes x library size) cost the delta above exists
-            # to avoid.
-            hashes = ([e.id for e in delta.additions] if delta is not None
-                     else [e.id for e in idx.entries])
-            if hashes:
-                endpoint = f"webrtc:{self._config.node.quic_port}"
-                spawn(self._register_swarm(hashes, endpoint))
-
     def _drop_group_sessions(self, group_id: str) -> None:
         """Close live sessions for a revoked group (H4)."""
         if not self._webrtc or not group_id:
@@ -1492,13 +1471,6 @@ class NodeDaemon(EnrichmentMixin):
                 spawn(session.close())
                 log.info("Dropped session for revoked group %s", group_id[:8])
 
-    async def _register_swarm(self, hashes: list[str], endpoint: str) -> None:
-        try:
-            n = await self._hub.register_swarm(hashes, endpoint)
-            log.info("Swarm: registered %d/%d hashes", n, len(hashes))
-        except Exception as e:
-            log.warning("Swarm registration failed: %s", e)
-
     async def _shutdown(self) -> None:
         log.info("Shutting down...")
         self._state["status"] = "stopping"