diff options
Diffstat (limited to 'packages/meshbay-hub/src/meshbay_hub/db/models.py')
| -rw-r--r-- | packages/meshbay-hub/src/meshbay_hub/db/models.py | 36 |
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. |