1 files changed, 9 insertions, 11 deletions
diff --git a/packages/meshbay-hub/src/meshbay_hub/api/revocation.py b/packages/meshbay-hub/src/meshbay_hub/api/revocation.py
index 1f1f5c5..f8cae8a 100644
--- a/packages/meshbay-hub/src/meshbay_hub/api/revocation.py
+++ b/packages/meshbay-hub/src/meshbay_hub/api/revocation.py
@@ -26,23 +26,21 @@ and close active connections for that user.
 """
 
 import asyncio
-import base64
 import json
 import logging
 import time
 import uuid
-from datetime import datetime, timezone
-from typing import Any
+from datetime import UTC, datetime
 
+import jwt
 from fastapi import APIRouter, Depends, HTTPException, Request, WebSocket, WebSocketDisconnect
+from meshbay_common.background import spawn
 from pydantic import BaseModel
 from sqlalchemy import select, update
 from sqlalchemy.ext.asyncio import AsyncSession
 
-import jwt
-from meshbay_common.background import spawn
-from meshbay_hub.auth import hub_public_key_pem, decode_access_token
 from meshbay_hub.api.deps import get_current_user, require_admin
+from meshbay_hub.auth import decode_access_token
 from meshbay_hub.db.engine import get_db
 from meshbay_hub.db.models import Group, GroupMember, IPLog, Node, User
 
@@ -143,7 +141,7 @@ async def _mark_hosted(group_ids: list[str]) -> None:
             await db.execute(
                 update(Group)
                 .where(Group.id.in_(group_ids), Group.hosted_at.is_(None))
-                .values(hosted_at=datetime.now(timezone.utc)))
+                .values(hosted_at=datetime.now(UTC)))
             await db.commit()
     except Exception as e:
         # A group that stays unhosted in the table is visible to its owner and
@@ -169,7 +167,7 @@ async def broadcast_revocation(token: str) -> int:
 
 def _sign_revocation(target: str, target_id: str, reason: str) -> str:
     """Issue a signed revocation token (JWT EdDSA)."""
-    from meshbay_hub.auth import _hub_sk_pem, _hub_id
+    from meshbay_hub.auth import _hub_id, _hub_sk_pem
     now = int(time.time())
     payload = {
         "type":       "revocation",
@@ -208,9 +206,9 @@ async def _handle_chat_notify(group_id: str, sender_name: str, sender_user_id: s
                     (node_id or "?")[:8])
         return
     try:
-        from meshbay_hub.db.engine import get_session_factory
-        from meshbay_hub.db.models import GroupMember, Group
         from meshbay_hub.api.notifications import create_notification
+        from meshbay_hub.db.engine import get_session_factory
+        from meshbay_hub.db.models import Group, GroupMember
 
         async with get_session_factory()() as db:
             group = await db.get(Group, group_id)
@@ -478,7 +476,7 @@ async def notify_incoming(
 
     try:
         await asyncio.wait_for(event.wait(), timeout=5.0)
-    except asyncio.TimeoutError:
+    except TimeoutError:
         raise HTTPException(status_code=504, detail="Node did not respond in time")
     finally:
         _punch_events.pop(node_id, None)