1 files changed, 26 insertions, 2 deletions
diff --git a/packages/meshbay-hub/src/meshbay_hub/api/groups.py b/packages/meshbay-hub/src/meshbay_hub/api/groups.py
index 6819ff6..65307f1 100644
--- a/packages/meshbay-hub/src/meshbay_hub/api/groups.py
+++ b/packages/meshbay-hub/src/meshbay_hub/api/groups.py
@@ -2,7 +2,8 @@
 
 from fastapi import APIRouter, Depends, HTTPException, Request
 from pydantic import BaseModel
-from sqlalchemy import func, or_, select
+from datetime import datetime, timezone
+from sqlalchemy import func, or_, select, update
 from sqlalchemy.ext.asyncio import AsyncSession
 
 from meshbay_hub.api.deps import get_current_user, require_user_scope
@@ -36,7 +37,7 @@ async def my_groups(
                # added to it before a node exists would see a name they cannot
                # open and cannot be told why.
                or_(Group.hosted_at.is_not(None), Group.admin_id == current_user.id))
-        .order_by(Group.name)
+        .order_by(Group.last_activity_at.desc())
     )
     groups = result.scalars().all()
     muted_rows = await db.execute(
@@ -63,12 +64,35 @@ async def my_groups(
                 # which is the evidence that actually concerns the user.
                 "node_online": bool(get_online_nodes_for_group(g.id)),
                 "hosted": g.hosted_at is not None,
+                "last_activity_at": g.last_activity_at.isoformat(),
             }
             for g in groups
         ]
     }
 
 
+@router.post("/{group_id}/activity")
+async def touch_group_activity(
+    group_id: str,
+    current_user: User = Depends(get_current_user),
+    db: AsyncSession = Depends(get_db),
+):
+    """Bump a group's last_activity_at. Called by the client on chat/file events."""
+    result = await db.execute(
+        select(GroupMember.group_id).where(
+            GroupMember.group_id == group_id,
+            GroupMember.user_id == current_user.id,
+        ))
+    if not result.first():
+        raise HTTPException(status_code=403, detail="Not a member")
+    await db.execute(
+        update(Group)
+        .where(Group.id == group_id)
+        .values(last_activity_at=datetime.now(timezone.utc)))
+    await db.commit()
+    return {"ok": True}
+
+
 @router.get("/{group_id}/nodes")
 async def group_online_nodes(
     group_id: str,