Update src/reddit_client.py

src/reddit_client.py

@@ -6,52 +6,44 @@ from dotenv import load_dotenv
 
 load_dotenv(dotenv_path=os.path.join(os.path.dirname(__file__), '..', '.env'))
 
-MAX_CLIENTS = 5
+# Load multiple clients
 clients = []
-
-for i in range(1, MAX_CLIENTS + 1):
+for i in range(1, 4):  # Only up to 3 clients
     cid = os.getenv(f"REDDIT_CLIENT_ID_{i}")
-    secret = os.getenv(f"REDDIT_CLIENT_SECRET_{i}")
+    csecret = os.getenv(f"REDDIT_CLIENT_SECRET_{i}")
     agent = os.getenv(f"REDDIT_USER_AGENT_{i}")
     username = os.getenv(f"REDDIT_USERNAME_{i}")
     password = os.getenv(f"REDDIT_PASSWORD_{i}")
-    if cid and secret:
-        clients.append(
-            praw.Reddit(
-                client_id=cid,
-                client_secret=secret,
-                user_agent=agent,
-                username=username,
-                password=password,
-            )
+    
+    if cid and csecret and agent and username and password:
+        reddit = praw.Reddit(
+            client_id=cid,
+            client_secret=csecret,
+            user_agent=agent,
+            username=username,
+            password=password,
         )
+        reddit.read_only = False
+        clients.append(reddit)
 
-_search_cache = {}
-CACHE_TTL_SECONDS = 300
+if not clients:
+    raise ValueError("No valid Reddit clients loaded from environment variables.")
 
 def get_reddit_client():
     return clients[int(time.time()) % len(clients)]
 
 def search_reddit(brand, limit=10, retries=3):
-    now = time.time()
-    if brand in _search_cache:
-        ts, cached_posts = _search_cache[brand]
-        if now - ts < CACHE_TTL_SECONDS:
-            logging.info(f"Cache hit for '{brand}'")
-            return cached_posts
-
     delay = 1
     for attempt in range(retries):
         try:
-            reddit = get_reddit_client()
             posts = []
+            reddit = get_reddit_client()
             for post in reddit.subreddit("all").search(brand, sort="new", limit=limit):
                 posts.append(post)
                 time.sleep(1)
-            _search_cache[brand] = (time.time(), posts)
             return posts
         except Exception as e:
-            logging.warning(f"Attempt {attempt+1}: Reddit search failed: {e}")
+            logging.warning(f"[Retry {attempt+1}] Reddit search failed: {e}")
             time.sleep(delay)
             delay *= 2
     return []