Update routers/cronjob.py

routers/cronjob.py

@@ -23,11 +23,11 @@ async def fetch_news():
                 response = await client.get("/news")
                 if response.status_code == 200:
                     data = response.json()
-                    print("News fetched:", data)
+                    print("[NEWS] Fetched:", data)
                 else:
-                    print("Erro ao buscar notícias:", response.status_code)
+                    print("[NEWS] Erro ao buscar notícias:", response.status_code)
             except Exception as e:
-                print("Erro fetch_news:", e)
+                print("[NEWS] Erro:", e)
 
             await asyncio.sleep(180)  # 3 minutos
 
@@ -35,7 +35,7 @@ async def fetch_filter():
     async with httpx.AsyncClient(timeout=10.0, base_url=BASE_URL) as client:
         while not stop_flags.get("filter"):
             try:
-                response = await client.get("/filter")
+                response = await client.post("/filter")
                 if response.status_code == 200:
                     data = response.json()
                     f = data.get("filter", {})
@@ -43,15 +43,16 @@ async def fetch_filter():
                     relevance = f.get("relevance", "low").lower()
                     brazil_interest = f.get("brazil_interest", False)
 
-                    print("Filter fetched:", data)
+                    print("[FILTER] Fetched:", data)
 
+                    # Repetir imediatamente se critérios não atendidos
                     if not is_news_content or relevance not in ["medium", "high", "viral"] or not brazil_interest:
-                        print("Condição não satisfeita, refazendo chamada imediatamente...")
-                        continue  # Repetir sem esperar
+                        print("[FILTER] Critérios não atendidos, refazendo...")
+                        continue
                 else:
-                    print("Erro ao buscar filter:", response.status_code)
+                    print("[FILTER] Erro ao buscar filter:", response.status_code)
             except Exception as e:
-                print("Erro fetch_filter:", e)
+                print("[FILTER] Erro:", e)
 
             await asyncio.sleep(120)  # 2 minutos
 
@@ -59,21 +60,22 @@ async def fetch_analyze():
     async with httpx.AsyncClient(timeout=10.0, base_url=BASE_URL) as client:
         while not stop_flags.get("analyze"):
             try:
-                response = await client.get("/analyze")
+                response = await client.post("/analyze")
                 if response.status_code == 200:
                     data = response.json()
                     success = data.get("rewrite_result", {}).get("success", False)
-                    print("Analyze fetched:", data)
+                    print("[ANALYZE] Fetched:", data)
+
                     if not success:
-                        print("Analyze não teve sucesso, tentando novamente em 1 minuto...")
+                        print("[ANALYZE] Success=false, tentando novamente em 1 minuto...")
                         await asyncio.sleep(60)
                         continue
                 else:
-                    print("Erro ao buscar analyze:", response.status_code)
+                    print("[ANALYZE] Erro ao buscar analyze:", response.status_code)
                     await asyncio.sleep(60)
                     continue
             except Exception as e:
-                print("Erro fetch_analyze:", e)
+                print("[ANALYZE] Erro:", e)
                 await asyncio.sleep(60)
                 continue
 
@@ -92,7 +94,6 @@ async def start_cronjob():
 
     stop_flags = {"news": False, "filter": False, "analyze": False}
 
-    # Cria tarefas assíncronas
     tasks["news"] = asyncio.create_task(fetch_news())
     tasks["filter"] = asyncio.create_task(fetch_filter())
     tasks["analyze"] = asyncio.create_task(fetch_analyze())