Create trend_monitor.py

services/trend_monitor.py

@@ -0,0 +1,34 @@
+import os
+from typing import List
+import random
+import asyncio
+
+# 実運用では official API を使う。ここでは疑似データ or トークンがあれば差し替え。
+# X/Instagramの本API接続は social_adapters を参照。
+
+async def fetch_trend_samples(platforms: List[str], keywords: List[str], limit: int = 20):
+    have_real_api = bool(os.getenv("X_BEARER_TOKEN") or os.getenv("IG_ACCESS_TOKEN"))
+    if not have_real_api:
+        # 疑似データ生成（MVPデモ用）
+        samples = []
+        for _ in range(limit):
+            plat = random.choice(platforms or ["x", "instagram"])
+            kw = random.choice(keywords or ["ブランド", "競合"])
+            samples.append({
+                "platform": plat,
+                "text": f"話題の投稿（疑似）: {kw} がトレンド。短評とリンク例。",
+                "author": f"user_{random.randint(1000,9999)}",
+                "url": "https://example.com/post"
+            })
+        await asyncio.sleep(0.1)
+        return samples
+
+    # ↓ ここに本番アダプタ呼び出し（例）
+    from .social_adapters.x_adapter import search_recent_x
+    from .social_adapters.instagram_adapter import search_recent_instagram
+    results = []
+    if "x" in platforms:
+        results += await search_recent_x(keywords, limit=limit)
+    if "instagram" in platforms:
+        results += await search_recent_instagram(keywords, limit=limit)
+    return results[:limit]