Update alisto_project/backend/ingest_reddit.py

alisto_project/backend/ingest_reddit.py

@@ -390,28 +390,27 @@ def is_credible_user(post):
 # orchestrates the entire scraping process (historical scan + real-time stream)
 async def scrape_reddit():
     print("Connecting to Reddit API...")
-
-    client_id = os.getenv("REDDIT_CLIENT_ID")
-    client_secret = os.getenv("REDDIT_CLIENT_SECRET")
     
     if not client_id or not client_secret:
         print("❌ Error: Client ID or Secret missing in .env")
         return
         
     reddit = asyncpraw.Reddit(
-        client_id=client_id,
-        client_secret=client_secret,
-        user_agent=os.getenv("REDDIT_USER_AGENT", "script:alisto_bot:v3.0")
-    )
+        client_id=os.getenv("REDDIT_CLIENT_ID"),
+        client_secret=os.getenv("REDDIT_CLIENT_SECRET"),
+        user_agent=os.getenv("REDDIT_USER_AGENT"),
+        username=os.getenv("REDDIT_USERNAME"),
+        password=os.getenv("REDDIT_PASSWORD")
+)
 
     try:
         subreddit = await reddit.subreddit(SUBREDDITS)
         print(f"👁️  ALISTO ACTIVE: Monitoring r/{SUBREDDITS}...")
         
         # --- PHASE 1: FETCH LATEST EXISTING POSTS (e.g., last 500) ---
-        print("🔍 Scanning last 500 posts for missed alerts...")
-        # iterates over the last 500 posts asynchronously
-        async for post in subreddit.new(limit=10):
+        print("🔍 Scanning last 5 posts for missed alerts...")
+        # iterates over the last 5 posts asynchronously
+        async for post in subreddit.new(limit=5):
             await process_post(post) 
         
         print("✅ Historical scan complete")