fix: autofix unused imports (F401)

app/auth.py

@@ -862,6 +862,7 @@ async def x_callback(request: Request):
         return RedirectResponse(f"{FRONTEND_URL}/auth/callback?error=missing_code")
 
     import httpx
+
     from app.core.redis import get_redis
 
     client_id = os.getenv("X_CLIENT_ID")

app/databus/x402_mcp_server.py

@@ -178,7 +178,7 @@ def get_wallet_labels(
     address: str, wallet: str | None = None, fingerprint: str | None = None
 ) -> dict:
     """Resolve crypto address to entity label (82K+ labeled addresses)."""
-    auth = check_x402_payment(wallet, fingerprint)
+    check_x402_payment(wallet, fingerprint)
     r = get_redis()
     result = r.get(f"rmi:label:ethereum:{address.lower()}")
     if not result:
@@ -333,7 +333,7 @@ def get_news_sentiment() -> dict:
     """Aggregated market sentiment across all news sources."""
     r = get_redis()
     stats = json.loads(r.get("rmi:news:stats") or "{}")
-    s500 = json.loads(r.get("rmi:news:stats_500") or "{}")
+    json.loads(r.get("rmi:news:stats_500") or "{}")
     total = sum(
         r.zcard(k)
         for k in [

app/domain/news/clusterer.py

@@ -24,7 +24,7 @@ import logging
 import re
 import time
 from dataclasses import dataclass, field
-from datetime import UTC, datetime, timedelta
+from datetime import UTC, datetime
 
 logger = logging.getLogger(__name__)
 
@@ -73,7 +73,7 @@ def _jaccard_minhash(a: list[int], b: list[int]) -> float:
     """Estimate Jaccard similarity from two MinHash signatures."""
     if not a or not b or len(a) != len(b):
         return 0.0
-    return sum(1 for x, y in zip(a, b) if x == y) / len(a)
+    return sum(1 for x, y in zip(a, b, strict=False) if x == y) / len(a)
 
 
 # ── DBSCAN (pure-python, no sklearn dep) ────────────────────────────
@@ -372,9 +372,10 @@ async def persist_clusters(stories: list[StoryCluster]) -> int:
 async def load_recent_clusters(limit: int = 50) -> list[dict]:
     """Load recent clusters from Postgres."""
     try:
-        import asyncpg
         import json
 
+        import asyncpg
+
         from app.core.db_pool import PG_URL
 
         conn = await asyncpg.connect(PG_URL)
@@ -409,6 +410,6 @@ __all__ = [
     "StoryCluster",
     "cluster_items",
     "ensure_schema",
-    "persist_clusters",
     "load_recent_clusters",
+    "persist_clusters",
 ]

app/domain/threat/brand_patterns.json

@@ -0,0 +1,65 @@
+{
+  "_comment": "T12 — CertStream brand patterns. Update as new phishing patterns emerge.",
+  "brands": [
+    "rugmunch",
+    "metamask",
+    "ledger",
+    "coinbase",
+    "trezor",
+    "phantom",
+    "solflare",
+    "trustwallet",
+    "exodus",
+    "ronin",
+    "binance",
+    "kraken",
+    "okx",
+    "bybit",
+    "gitcoin",
+    "uniswap",
+    "sushiswap",
+    "aave",
+    "compound",
+    "wormhole",
+    "optimism",
+    "arbitrum",
+    "polygon",
+    "stargate",
+    "curve",
+    "balancer",
+    "makerdao",
+    "dydx",
+    "bitfinex",
+    "crypto.com",
+    "kucoin",
+    "huobi",
+    "gate.io",
+    "bitstamp",
+    "gemini",
+    "etoro",
+    "robinhood",
+    "swissborg",
+    "blockfi",
+    "celcius",
+    "voyager",
+    "ftx",
+    "anchor",
+    "lido",
+    "rocketpool",
+    "frax",
+    "convex",
+    "yearn",
+    "synthetix",
+    "ens",
+    "opensea",
+    "blur",
+    "magic-eden",
+    "pancakeswap",
+    "1inch",
+    "0x",
+    "kyber",
+    "paraswap",
+    "rango",
+    "lifi"
+  ]
+}

app/domain/threat/certstream_listener.py

@@ -132,6 +132,7 @@ CREATE INDEX IF NOT EXISTS threat_domains_brand_idx
 async def _ensure_schema() -> bool:
     try:
         import asyncpg
+
         from app.core.db_pool import PG_URL
 
         conn = await asyncpg.connect(PG_URL)
@@ -148,6 +149,7 @@ async def _ensure_schema() -> bool:
 async def _persist_domain(domain: str, brand: str, issued_at: datetime | None, issuer: str) -> bool:
     try:
         import asyncpg
+
         from app.core.db_pool import PG_URL
 
         conn = await asyncpg.connect(PG_URL)
@@ -241,7 +243,7 @@ async def _run_listener(stop_event: asyncio.Event) -> None:
                 while not stop_event.is_set():
                     try:
                         raw = await asyncio.wait_for(ws.recv(), timeout=60)
-                    except asyncio.TimeoutError:
+                    except TimeoutError:
                         # send a ping to keep the connection alive
                         with suppress(Exception):
                             await ws.send("ping")
@@ -255,10 +257,8 @@ async def _run_listener(stop_event: asyncio.Event) -> None:
             raise
         except Exception as exc:
             logger.warning("certstream_disconnected err=%s reconnecting_in=%.1fs", exc, backoff)
-            try:
+            with suppress(asyncio.TimeoutError):
                 await asyncio.wait_for(stop_event.wait(), timeout=backoff)
-            except asyncio.TimeoutError:
-                pass
             backoff = min(backoff * 2, 60.0)
 
 
@@ -336,9 +336,9 @@ if __name__ == "__main__":
 
 
 __all__ = [
+    "CERTSTREAM_URL",
+    "load_brand_patterns",
+    "match_brand",
     "start_listener",
     "stop_listener",
-    "match_brand",
-    "load_brand_patterns",
-    "CERTSTREAM_URL",
 ]

app/routers/admin_users_api.py

@@ -16,7 +16,6 @@ All endpoints require ADMIN or SUPERADMIN role.
 
 import json
 import logging
-import os
 from datetime import datetime, timedelta
 from enum import StrEnum
 from typing import Any
@@ -552,7 +551,6 @@ async def bulk_action(req: BulkActionRequest, request: Request):
             elif req.action == "update_tier":
                 tier = req.params.get("tier", "FREE") if req.params else "FREE"
                 from app.auth import _get_user, _save_user
-                from app.core.redis import get_redis
 
                 user = _get_user(user_id)
                 if user:

app/routers/developer_tier.py

@@ -14,11 +14,9 @@ Author: RMI Development
 Date: 2026-06-05
 """
 
-import hashlib
 import json
 import logging
 import time
-import uuid
 from datetime import UTC, datetime, timedelta
 from typing import Any
 
@@ -59,6 +57,7 @@ def verify_solana_signature(address: str, message: str, signature: str) -> bool:
         import base64
 
         from nacl.signing import VerifyKey
+
         from app.core.redis import get_redis
 
         pubkey = VerifyKey(base64.b58decode(address))

app/routers/persistent_state.py

@@ -34,11 +34,9 @@ import logging
 import time
 import uuid
 from datetime import UTC, datetime
-from typing import Any
 
 from fastapi import APIRouter, Request
 from fastapi.responses import JSONResponse
-from pydantic import BaseModel
 
 logger = logging.getLogger("persistent_state")
 

app/routers/subscription_pricing_api.py

@@ -16,7 +16,6 @@ import logging
 import os
 import secrets
 from datetime import datetime, timedelta
-from enum import StrEnum
 from typing import Any
 
 from fastapi import APIRouter, HTTPException, Request

app/routers/webhook_pipeline.py

@@ -19,7 +19,6 @@ Date: 2026-06-05
 """
 
 import hashlib
-import hmac
 import json
 import logging
 import time

app/routers/x402_alpha_revenue_tools.py

@@ -621,7 +621,6 @@ def register_alpha_tool_prices():
     """Register alpha tool prices with the enforcement system."""
     try:
         from app.routers.x402_enforcement import TOOL_PRICES
-        from app.core.redis import get_redis
 
         TOOL_PRICES.update(
             {

app/routers/x402_enforcement.py

@@ -21,7 +21,6 @@ Date: 2026-05-23
 
 from __future__ import annotations
 
-import hashlib
 import json
 import logging
 import os
@@ -2327,7 +2326,7 @@ async def get_revenue():
         # Daily breakdown (last 30 days)
         daily = {}
         from datetime import datetime, timedelta
-        from app.core.redis import get_redis
+
 
         for i in range(30):
             day = (datetime.utcnow() - timedelta(days=i)).strftime("%Y-%m-%d")

app/routers/x402_tools.py

@@ -17,7 +17,6 @@ import asyncio
 import json
 import logging
 import os
-import time
 from datetime import datetime
 from typing import Any
 
@@ -5772,7 +5771,6 @@ async def tool_alias_dispatcher(tool_id: str, request: Request):
     try:
         opt_out = request.query_params.get("enrich", "").lower() == "false"
         from app.routers.x402_enrichment import enrich_tool_response
-        from app.core.redis import get_redis
 
         result = enrich_tool_response(tool_id, result, request_params=body, opt_out=opt_out)
     except Exception: