feat: add recently_analyzed and trending_tickers GraphQL queries utilizing prediction logs

backend/app/database/crud.py

@@ -444,4 +444,35 @@ async def get_all_strategy_logs(db: AsyncSession, limit: int = 1000) -> List[mod
         .order_by(models.StrategyLog.timestamp.desc())
         .limit(limit)
     )
-    return list(result.scalars().all())
+    return list(result.scalars().all())
+
+
+async def get_recently_analyzed_tickers(db: AsyncSession, user_id: uuid.UUID, limit: int = 5) -> List[str]:
+    """
+    Retrieves the unique tickers that the specified user has analyzed recently.
+    """
+    from sqlalchemy import func
+    result = await db.execute(
+        select(models.PredictionLog.ticker, func.max(models.PredictionLog.timestamp).label("latest"))
+        .where(models.PredictionLog.user_id == user_id)
+        .group_by(models.PredictionLog.ticker)
+        .order_by(func.max(models.PredictionLog.timestamp).desc())
+        .limit(limit)
+    )
+    return [row.ticker for row in result]
+
+
+async def get_trending_tickers(db: AsyncSession, limit: int = 5) -> List[dict]:
+    """
+    Retrieves the globally trending tickers based on analysis query count in the last 7 days.
+    """
+    from sqlalchemy import func
+    cutoff = datetime.datetime.now(datetime.timezone.utc) - datetime.timedelta(days=7)
+    result = await db.execute(
+        select(models.PredictionLog.ticker, func.count(models.PredictionLog.id).label("count"))
+        .where(models.PredictionLog.timestamp >= cutoff)
+        .group_by(models.PredictionLog.ticker)
+        .order_by(func.count(models.PredictionLog.id).desc())
+        .limit(limit)
+    )
+    return [{"ticker": row.ticker, "count": row.count} for row in result]

backend/app/graphql/schema.py

@@ -98,6 +98,11 @@ class SavedStrategyType:
     reason: str
     created_at: datetime.datetime
 
+@strawberry.type
+class TrendingTickerType:
+    ticker: str
+    count: int
+
 @strawberry.type
 class AuthTokenType:
     access_token: str
@@ -347,6 +352,20 @@ class Query:
                 ) for h in local_data
             ]
 
+    @strawberry.field
+    async def recently_analyzed(self, info: Info, limit: Optional[int] = 5) -> List[str]:
+        """Fetch the unique tickers the authenticated user has recently analyzed."""
+        user = get_authenticated_user(info)
+        db = info.context["db"]
+        return await crud.get_recently_analyzed_tickers(db, user_id=user.id, limit=limit or 5)
+
+    @strawberry.field
+    async def trending_tickers(self, info: Info, limit: Optional[int] = 5) -> List[TrendingTickerType]:
+        """Fetch the globally trending tickers based on analysis query count in the last 7 days."""
+        db = info.context["db"]
+        results = await crud.get_trending_tickers(db, limit=limit or 5)
+        return [TrendingTickerType(ticker=r["ticker"], count=r["count"]) for r in results]
+
 
 
 # ==========================================