format python

Author: balogh.adam@icloud.com

onchain/portfolio/solana_portfolio.py

@@ -23,7 +23,7 @@ def __init__(self, token_metadata_repo: TokenMetadataRepo):
     async def close(self):
         await self.http_client.close()
 
-    @alru_cache(maxsize=1_000_000, ttl=60*60)
+    @alru_cache(maxsize=1_000_000, ttl=60 * 60)
     async def get_portfolio(self, wallet_address: str) -> Portfolio:
         if wallet_address == "":
             return Portfolio(holdings=[], total_value_usd=0)

onchain/tokens/metadata.py

@@ -55,7 +55,9 @@ async def session(self) -> aiohttp.ClientSession:
         if self._session is None:
             self._session = aiohttp.ClientSession(
                 timeout=aiohttp.ClientTimeout(total=10),  # Add timeout
-                connector=aiohttp.TCPConnector(limit=100, limit_per_host=30)  # Connection pooling
+                connector=aiohttp.TCPConnector(
+                    limit=100, limit_per_host=30
+                ),  # Connection pooling
             )
         return self._session
 

server/activity_tracker.py

@@ -37,9 +37,7 @@ def __init__(self, get_table: Callable[[], TableContext]):
         """
         self.get_table = get_table
 
-    async def increment_message_count(
-        self, user_address: str, miner_token: str = None
-    ) -> bool:
+    async def increment_message_count(self, user_address: str) -> bool:
         """
         Increment the message count for a user.
         Returns True if the message was counted, False if the daily limit was reached.

server/auth.py

@@ -23,8 +23,12 @@ async def _verify_firebase_id_token(token: str) -> FirebaseIDTokenData:
         FirebaseIDTokenData: Pydantic model containing the user's firebase `uid`.
     """
     try:
-        user_data = await asyncio.to_thread(auth.verify_id_token,
-            id_token=token, app=None, check_revoked=True, clock_skew_seconds=10
+        user_data = await asyncio.to_thread(
+            auth.verify_id_token,
+            id_token=token,
+            app=None,
+            check_revoked=True,
+            clock_skew_seconds=10,
         )
         return FirebaseIDTokenData(**user_data)
     except (

server/fastapi_server.py

@@ -211,7 +211,9 @@ async def verify_solana_signature(request: Request):
             request_data = await request.json()
             verify_request = SolanaVerifyRequest(**request_data)
 
-            token = await asyncio.to_thread(service.verify_solana_signature, verify_request)
+            token = await asyncio.to_thread(
+                service.verify_solana_signature, verify_request
+            )
             return {"token": token}
 
         except ValidationError as e:
@@ -242,7 +244,6 @@ async def get_portfolio(
         # TODO: Revert this once load is under control
         return Portfolio(holdings=[], total_value_usd=0).model_dump()
 
-
     @app.get("/api/tokenlist")
     async def get_tokenlist():
         file_path = os.path.join(STATIC_DIR, "tokenlist.json")
@@ -260,7 +261,7 @@ async def run_agent(
 
         # Increment message count, return 429 if limit reached
         if not await activity_tracker.increment_message_count(
-            agent_request.context.address, agent_request.context.miner_token
+            agent_request.context.address
         ):
             statsd.increment("agent.message.daily_limit_reached")
             raise HTTPException(status_code=429, detail="Daily message limit reached")