Create services/aggregator.py

services/aggregator.py

@@ -0,0 +1,19 @@
+from services.youtube import search_videos, get_comments
+from services.reddit import get_reddit_comments
+from services.preprocessing import clean_text
+
+def collect_data(keyword):
+    all_comments = []
+
+    # YouTube
+    video_ids = search_videos(keyword)
+    for vid in video_ids:
+        all_comments.extend(get_comments(vid))
+
+    # Reddit
+    all_comments.extend(get_reddit_comments(keyword))
+
+    # Clean
+    cleaned = [clean_text(c) for c in all_comments if len(c) > 5]
+
+    return cleaned