Update alisto_project/backend/ingest_reddit.py

alisto_project/backend/ingest_reddit.py

@@ -143,15 +143,12 @@ async def process_post(post):
 
 # 5. Main Loop (POLLING MODE)
 async def scrape_reddit():
-    log("🔌 Connecting to Reddit API (Polling Mode)...")
+    log("🔌 Connecting to Reddit API (Debug Mode)...")
     
     client_id = os.getenv("REDDIT_CLIENT_ID")
     client_secret = os.getenv("REDDIT_CLIENT_SECRET")
     
-    if not client_id or not client_secret:
-        log("❌ CRITICAL ERROR: Client ID or Secret missing in .env")
-        return
-
+    # 1. Initialize Reddit
     reddit = asyncpraw.Reddit(
         client_id=client_id,
         client_secret=client_secret,
@@ -160,28 +157,32 @@ async def scrape_reddit():
         password=os.getenv("REDDIT_PASSWORD")
     )
 
-    log(f"👁️  ALISTO ACTIVE: Polling r/{SUBREDDITS} every 60s...")
+    # --- THE TRUTH CHECK ---
+    # This tells us if the password actually worked
+    log(f"🧐 DEBUG CHECK: Am I logged in as {os.getenv('REDDIT_USERNAME')}?")
+    is_read_only = await reddit.read_only
+    log(f"👉 IS READ ONLY MODE? {is_read_only}") 
+    # True = Password Failed (You are Anonymous -> BLOCKED)
+    # False = Password Worked (You are Logged In)
+    # -----------------------
+
+    log(f"👁️  ALISTO ACTIVE: Polling r/{SUBREDDITS}...")
+    
     last_id = None
 
     while True:
         try:
             subreddit = await reddit.subreddit(SUBREDDITS)
-            
-            # Fetch ONLY 1 post to minimize bandwidth
             async for post in subreddit.new(limit=1):
                 if post.id != last_id:
-                    log(f"📥 New Post Detected: {post.title}")
+                    log(f"📥 New Post: {post.title}")
                     await process_post(post)
                     last_id = post.id
-                else:
-                    # Silence "no new post" messages to keep logs clean
-                    pass 
-            
-            # Wait 60 seconds (The Fix)
             await asyncio.sleep(60)
 
         except Exception as e:
-            log(f"⚠️ Connection glitch (Retrying in 2m): {e}")
+            log(f"⚠️ Connection glitch: {e}")
+            # If 403 happens, we know exactly why now based on the Read Only check
             await asyncio.sleep(120)
 
     await reddit.close()