aboutsummaryrefslogtreecommitdiffstats
path: root/packages/meshbay-hub/src/meshbay_hub/db/models.py
diff options
context:
space:
mode:
Diffstat (limited to 'packages/meshbay-hub/src/meshbay_hub/db/models.py')
-rw-r--r--packages/meshbay-hub/src/meshbay_hub/db/models.py36
1 files changed, 36 insertions, 0 deletions
diff --git a/packages/meshbay-hub/src/meshbay_hub/db/models.py b/packages/meshbay-hub/src/meshbay_hub/db/models.py
index 63cc8c3..b76870d 100644
--- a/packages/meshbay-hub/src/meshbay_hub/db/models.py
+++ b/packages/meshbay-hub/src/meshbay_hub/db/models.py
@@ -142,6 +142,42 @@ class RefreshToken(Base):
# ── IP logs (legal compliance) ────────────────────────────────────────────────
+class FederatedGroup(Base):
+ """
+ Groups received from peer hubs via MHP federation.
+ Included in public /v1/groups search results with hub_id attribution.
+ """
+ __tablename__ = "federated_groups"
+
+ id: Mapped[str] = mapped_column(String(36), primary_key=True)
+ name: Mapped[str] = mapped_column(String(128), nullable=False)
+ source_hub: Mapped[str] = mapped_column(String(128), nullable=False)
+ join_policy: Mapped[str] = mapped_column(String(16), default="invite")
+ received_at: Mapped[datetime] = mapped_column(DateTime(timezone=True), default=_now)
+ updated_at: Mapped[datetime] = mapped_column(DateTime(timezone=True), default=_now)
+
+ __table_args__ = (
+ Index("ix_federated_groups_source", "source_hub"),
+ Index("ix_federated_groups_name", "name"),
+ )
+
+
+class SwarmSource(Base):
+ """
+ Tracks which nodes can serve a given content hash (public swarm).
+ Hub maintains this for load-balanced public content delivery.
+ """
+ __tablename__ = "swarm_sources"
+
+ content_hash: Mapped[str] = mapped_column(String(64), primary_key=True)
+ node_id: Mapped[str] = mapped_column(String(36), primary_key=True)
+ endpoint: Mapped[str] = mapped_column(String(128), nullable=False)
+ registered_at: Mapped[datetime] = mapped_column(DateTime(timezone=True), default=_now)
+ last_seen: Mapped[datetime] = mapped_column(DateTime(timezone=True), default=_now)
+
+ __table_args__ = (Index("ix_swarm_hash", "content_hash"),)
+
+
class ContentReport(Base):
"""
Report of a public content hash for moderation.