perf(api): DB-level pagination + drop N+1 message-count + adapter logging (Batch B)

src/agentic_orchestrator/adapters/coingecko.py

@@ -9,6 +9,7 @@
 """
 
 import asyncio
+import logging
 import os
 import time
 from typing import Any, Dict, List, Optional
@@ -17,6 +18,8 @@
 
 from .base import AdapterConfig, AdapterResult, BaseAdapter, SignalData
 
+logger = logging.getLogger(__name__)
+
 
 class CoingeckoAdapter(BaseAdapter):
     """
@@ -206,7 +209,7 @@ async def _fetch_trending(self) -> List[SignalData]:
                         signals.append(signal)
 
         except Exception as e:
-            print(f"Error fetching trending: {e}")
+            logger.warning(f"Error fetching trending: {e}")
 
         return signals
 
@@ -327,7 +330,7 @@ async def _fetch_top_movers(self) -> List[SignalData]:
                             signals.append(signal)
 
         except Exception as e:
-            print(f"Error fetching top movers: {e}")
+            logger.warning(f"Error fetching top movers: {e}")
 
         return signals
 
@@ -392,7 +395,7 @@ async def _fetch_global_stats(self) -> List[SignalData]:
                     signals.append(signal)
 
         except Exception as e:
-            print(f"Error fetching global stats: {e}")
+            logger.warning(f"Error fetching global stats: {e}")
 
         return signals
 
@@ -451,7 +454,7 @@ async def _fetch_tracked_coins(self) -> List[SignalData]:
                         signals.append(signal)
 
         except Exception as e:
-            print(f"Error fetching tracked coins: {e}")
+            logger.warning(f"Error fetching tracked coins: {e}")
 
         return signals
 

src/agentic_orchestrator/adapters/discord.py

@@ -8,6 +8,7 @@
 """
 
 import asyncio
+import logging
 import os
 import time
 from datetime import datetime, timedelta
@@ -17,6 +18,8 @@
 
 from .base import AdapterConfig, AdapterResult, BaseAdapter, SignalData
 
+logger = logging.getLogger(__name__)
+
 
 class DiscordAdapter(BaseAdapter):
     """
@@ -226,7 +229,7 @@ async def _fetch_via_bot(self) -> List[SignalData]:
                         await asyncio.sleep(0.5)
 
                 except Exception as e:
-                    print(f"Error fetching from {server['name']}: {e}")
+                    logger.warning(f"Error fetching from {server['name']}: {e}")
 
         return signals
 
@@ -288,7 +291,7 @@ async def _fetch_public_announcements(self) -> List[SignalData]:
                     await asyncio.sleep(1)
 
         except Exception as e:
-            print(f"Error fetching public Discord data: {e}")
+            logger.warning(f"Error fetching public Discord data: {e}")
 
         return signals
 

src/agentic_orchestrator/adapters/farcaster.py

@@ -8,6 +8,7 @@
 """
 
 import asyncio
+import logging
 import os
 import time
 from typing import Any, Dict, List, Optional
@@ -16,6 +17,8 @@
 
 from .base import AdapterConfig, AdapterResult, BaseAdapter, SignalData
 
+logger = logging.getLogger(__name__)
+
 
 class FarcasterAdapter(BaseAdapter):
     """
@@ -141,7 +144,7 @@ async def _neynar_request(
                     return response.json()
 
         except Exception as e:
-            print(f"Neynar API error: {e}")
+            logger.warning(f"Neynar API error: {e}")
 
         return None
 
@@ -177,7 +180,7 @@ async def _fetch_trending_casts(self) -> List[SignalData]:
                                 signals.append(signal)
 
             except Exception as e:
-                print(f"Warpcast API error: {e}")
+                logger.warning(f"Warpcast API error: {e}")
 
         return signals
 

src/agentic_orchestrator/adapters/github_events.py

@@ -8,6 +8,7 @@
 """
 
 import asyncio
+import logging
 import os
 import time
 from datetime import datetime, timedelta
@@ -17,6 +18,8 @@
 
 from .base import AdapterConfig, AdapterResult, BaseAdapter, SignalData
 
+logger = logging.getLogger(__name__)
+
 
 class GitHubEventsAdapter(BaseAdapter):
     """
@@ -164,7 +167,7 @@ async def _fetch_trending_repos(self) -> List[SignalData]:
                     signals.append(signal)
 
         except Exception as e:
-            print(f"Error fetching trending repos: {e}")
+            logger.warning(f"Error fetching trending repos: {e}")
 
         return signals
 
@@ -229,7 +232,7 @@ async def _fetch_repo_releases(self, client: httpx.AsyncClient, repo: str) -> Li
                     signals.append(signal)
 
         except Exception as e:
-            print(f"Error fetching releases for {repo}: {e}")
+            logger.warning(f"Error fetching releases for {repo}: {e}")
 
         return signals
 
@@ -292,7 +295,7 @@ async def _fetch_topic_repos(self) -> List[SignalData]:
                     await asyncio.sleep(0.5)
 
                 except Exception as e:
-                    print(f"Error fetching topic {topic}: {e}")
+                    logger.warning(f"Error fetching topic {topic}: {e}")
 
         return signals
 

src/agentic_orchestrator/adapters/lens.py

@@ -5,13 +5,16 @@
 """
 
 import asyncio
+import logging
 import time
 from typing import Any, Dict, List, Optional
 
 import httpx
 
 from .base import AdapterConfig, AdapterResult, BaseAdapter, SignalData
 
+logger = logging.getLogger(__name__)
+
 
 class LensAdapter(BaseAdapter):
     """
@@ -112,7 +115,7 @@ async def _graphql_request(
                     return response.json()
 
         except Exception as e:
-            print(f"Lens GraphQL error: {e}")
+            logger.warning(f"Lens GraphQL error: {e}")
 
         return None
 

src/agentic_orchestrator/adapters/news.py

@@ -8,6 +8,7 @@
 """
 
 import asyncio
+import logging
 import os
 import time
 from datetime import datetime, timedelta
@@ -17,6 +18,8 @@
 
 from .base import AdapterConfig, AdapterResult, BaseAdapter, SignalData
 
+logger = logging.getLogger(__name__)
+
 
 class NewsAPIAdapter(BaseAdapter):
     """
@@ -156,7 +159,7 @@ async def _fetch_newsapi(self) -> List[SignalData]:
                     await asyncio.sleep(0.5)
 
                 except Exception as e:
-                    print(f"Error fetching NewsAPI for '{query_config['query']}': {e}")
+                    logger.warning(f"Error fetching NewsAPI for '{query_config['query']}': {e}")
 
         return signals
 
@@ -213,7 +216,7 @@ async def _fetch_cryptopanic(self) -> List[SignalData]:
                         signals.append(signal)
 
         except Exception as e:
-            print(f"Error fetching Cryptopanic: {e}")
+            logger.warning(f"Error fetching Cryptopanic: {e}")
 
         return signals
 
@@ -322,7 +325,7 @@ async def _fetch_hackernews(self) -> List[SignalData]:
                         signals.append(signal)
 
         except Exception as e:
-            print(f"Error fetching Hacker News: {e}")
+            logger.warning(f"Error fetching Hacker News: {e}")
 
         return signals
 

src/agentic_orchestrator/adapters/onchain.py

@@ -9,6 +9,7 @@
 """
 
 import asyncio
+import logging
 import os
 import time
 from typing import Any, Dict, List, Optional
@@ -17,6 +18,8 @@
 
 from .base import AdapterConfig, AdapterResult, BaseAdapter, SignalData
 
+logger = logging.getLogger(__name__)
+
 
 class OnChainAdapter(BaseAdapter):
     """
@@ -193,7 +196,7 @@ async def _fetch_defi_tvl(self) -> List[SignalData]:
                         signals.append(signal)
 
         except Exception as e:
-            print(f"Error fetching DeFi TVL: {e}")
+            logger.warning(f"Error fetching DeFi TVL: {e}")
 
         return signals
 
@@ -232,7 +235,7 @@ async def _fetch_chain_stats(self) -> List[SignalData]:
                     signals.append(signal)
 
         except Exception as e:
-            print(f"Error fetching chain stats: {e}")
+            logger.warning(f"Error fetching chain stats: {e}")
 
         return signals
 
@@ -274,7 +277,7 @@ async def _fetch_protocol_updates(self) -> List[SignalData]:
                     signals.append(signal)
 
         except Exception as e:
-            print(f"Error fetching protocol updates: {e}")
+            logger.warning(f"Error fetching protocol updates: {e}")
 
         return signals
 
@@ -328,7 +331,7 @@ async def _fetch_dex_volume(self) -> List[SignalData]:
                         signals.append(signal)
 
         except Exception as e:
-            print(f"Error fetching DEX volume: {e}")
+            logger.warning(f"Error fetching DEX volume: {e}")
 
         return signals
 
@@ -390,7 +393,7 @@ async def _fetch_whale_transactions(self) -> List[SignalData]:
                         signals.append(signal)
 
         except Exception as e:
-            print(f"Error fetching whale transactions: {e}")
+            logger.warning(f"Error fetching whale transactions: {e}")
 
         return signals
 
@@ -419,7 +422,7 @@ async def _fetch_whale_from_explorers(self) -> List[SignalData]:
                 # track specific whale addresses or use a service that aggregates this.
 
         except Exception as e:
-            print(f"Error fetching from explorers: {e}")
+            logger.warning(f"Error fetching from explorers: {e}")
 
         return signals
 
@@ -509,7 +512,7 @@ async def _fetch_stablecoin_flows(self) -> List[SignalData]:
                             signals.append(signal)
 
         except Exception as e:
-            print(f"Error fetching stablecoin data: {e}")
+            logger.warning(f"Error fetching stablecoin data: {e}")
 
         return signals
 
@@ -559,7 +562,7 @@ async def _fetch_gas_prices(self) -> List[SignalData]:
                         signals.append(signal)
 
         except Exception as e:
-            print(f"Error fetching gas prices: {e}")
+            logger.warning(f"Error fetching gas prices: {e}")
 
         return signals
 

src/agentic_orchestrator/adapters/rss.py

@@ -10,6 +10,7 @@
 """
 
 import asyncio
+import logging
 import time
 from dataclasses import dataclass
 from datetime import datetime
@@ -20,6 +21,8 @@
 
 from .base import AdapterConfig, AdapterResult, BaseAdapter, SignalData
 
+logger = logging.getLogger(__name__)
+
 
 @dataclass
 class FeedConfig:
@@ -194,7 +197,7 @@ async def _fetch_feed(self, feed: FeedConfig) -> List[SignalData]:
 
         except Exception as e:
             # Log error but don't fail the entire adapter
-            print(f"Error fetching feed {feed.name}: {e}")
+            logger.warning(f"Error fetching feed {feed.name}: {e}")
 
         return signals