Cumfiesta.24.06.16.ryan.reid.the.rise.of.the.cu... -
# Apply recency bonus if hours_since_publish < 2: score *= 1.5 return round(score, 6) // GET /api/trending/feed router.get('/feed', async (req, res) => { const limit = 20, offset = 0, contentType, category = req.query; const whereClause = {}; if (contentType) whereClause.contentType = contentType; if (category) whereClause.category = category;
# backend/services/trending_algorithm.py from datetime import datetime, timezone import math def calculate_trend_score(content, current_time): hours_since_publish = (current_time - content.published_at).total_seconds() / 3600 hours_since_decay_start = (current_time - content.decay_started_at).total_seconds() / 3600
The Trending Score is calculated every 15 minutes via a background job (Celery/Bull). CumFiesta.24.06.16.Ryan.Reid.The.Rise.Of.The.Cu...
def fetch_youtube_trending(): youtube_api_key = os.getenv("YOUTUBE_API_KEY") url = f"https://www.googleapis.com/youtube/v3/videos?part=snippet,statistics&chart=mostPopular®ionCode=US&videoCategoryId=10&key=youtube_api_key" # Category 10 = Music, 24 = Entertainment return videos
useEffect(() => const observer = new IntersectionObserver( entries => if (entries[0].isIntersecting && !loading) setPage(p => p + 1); , threshold: 1 ); if (observerTarget.current) observer.observe(observerTarget.current); return () => observer.disconnect(); , [loading]); # Apply recency bonus if hours_since_publish < 2:
const handleLike = async (itemId: string) => // Optimistic update setItems(items.map(item => item.id === itemId ? ...item, likes: item.likes + (item.userLiked ? -1 : 1), userLiked: !item.userLiked : item )); await fetch( /api/trending/$itemId/interact , method: 'POST', body: JSON.stringify( type: 'like' ), headers: 'Content-Type': 'application/json' ); ;
# scraper/entertainment_aggregator.py import feedparser from selenium import webdriver def fetch_reddit_trending(): # r/all trending in entertainment reddit_url = "https://www.reddit.com/r/entertainment/top.json?t=day&limit=25" # Use praw library or requests with auth return posts -1 : 1), userLiked:
// Trigger async recalc of trendScore queue.add('recalc-trending', contentId );