Update services/aggregator.py

services/aggregator.py

@@ -5,7 +5,7 @@ from services.preprocessing import clean_text
 def collect_data(keyword, source="all"):
     all_comments = []
 
-    # YouTube
+    # ✅ YOUTUBE (WAJIB)
     if source in ["youtube", "all"]:
         try:
             video_ids = search_videos(keyword)
@@ -14,13 +14,19 @@ def collect_data(keyword, source="all"):
         except Exception as e:
             print("YouTube error:", e)
 
-    # Reddit
+    # ✅ REDDIT (OPSIONAL - JANGAN BIARKAN CRASH)
     if source in ["reddit", "all"]:
         try:
-            all_comments.extend(get_reddit_comments(keyword))
+            reddit_comments = get_reddit_comments(keyword)
+            if reddit_comments:
+                all_comments.extend(reddit_comments)
         except Exception as e:
-            print("Reddit error:", e)
+            print("Reddit error (skip):", e)
 
-    cleaned = [clean_text(c) for c in all_comments if len(c) > 5]
+    # 🔥 FALLBACK (BIAR GA KOSONG)
+    if len(all_comments) == 0:
+        all_comments = ["data tidak ditemukan"]
+
+    cleaned = [clean_text(c) for c in all_comments if len(c) > 3]
 
     return cleaned