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>

2 files changed, 0 insertions, 50 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"
diff --git a/packages/meshbay-node/src/meshbay_node/hub_client.py b/packages/meshbay-node/src/meshbay_node/hub_client.py
index 346a4cd..5f47090 100644
--- a/packages/meshbay-node/src/meshbay_node/hub_client.py
+++ b/packages/meshbay-node/src/meshbay_node/hub_client.py
@@ -6,7 +6,6 @@ Handles all communication from the node to a Mesh Hub:
   - JWT offline verification and auto-refresh
   - Node announcement (endpoint_hint)
   - User public key lookup (for GEK wrapping)
-  - Swarm hash registration
 
 The node authenticates via Ed25519 challenge-response (/v1/nodes/auth).
 No auth_key or password is ever stored on or transmitted from the node.
@@ -461,27 +460,6 @@ class HubClient:
             log.warning("Could not deliver WebRTC answer to %s: %s",
                         str(msg.get("peer_id"))[:8], e)
 
-    # ── Swarm registration ─────────────────────────────────────────────────
-
-    async def register_swarm(self, content_hashes: list[str], endpoint: str) -> int:
-        """Register file hashes in the hub swarm table. Returns count registered."""
-        if self._session is None:
-            raise RuntimeError("Not logged in")
-        await self.ensure_fresh_token()
-
-        registered = 0
-        for h in content_hashes:
-            try:
-                r = await self._http.post("/v1/swarm/register", json={
-                    "content_hash": h,
-                    "endpoint": endpoint,
-                }, headers=self._session.auth_headers)
-                if r.status_code in (201, 200):
-                    registered += 1
-            except Exception:
-                pass
-        return registered
-
     # ── Convenience: full startup sequence ───────────────────────────────────
 
     async def startup(self, endpoint_hint: str | None = None) -> HubSession: