From 0fd0cda460b1cb3cff712feab295759def1c8258 Mon Sep 17 00:00:00 2001
From: admin <admin@admin.com>
Date: Tue, 5 Aug 2025 04:39:03 +0200
Subject: [PATCH] Ajusta rabbit

---
 main.py | 26 +++++++++++++++++---------
 1 file changed, 17 insertions(+), 9 deletions(-)

diff --git a/main.py b/main.py
index 6eabff8..52e8ebd 100644
--- a/main.py
+++ b/main.py
@@ -37,6 +37,8 @@ def publish_to_queue(payload):
     connection.close()
 
 def callback(ch, method, properties, body):
+    filename = url = video_id = None
+
     try:
         data = json.loads(body)
         filename = data.get("filename")
@@ -56,23 +58,29 @@ def callback(ch, method, properties, body):
             "videoId": video_id,
             "error": False,
         }
+
+        publish_to_queue(payload)
+
+        print(f"Mensagem publicada na fila '{RABBITMQ_UPLOAD_QUEUE}'.")
+
     except Exception as e:
         payload = {
             "videosProcessedQuantity": 0,
-            "filename": filename if 'filename' in locals() else None,
+            "filename": filename,
             "processedFiles": [],
-            "url": url if 'url' in locals() else None,
-            "videoId": video_id if 'video_id' in locals() else None,
+            "url": url,
+            "videoId": video_id,
             "error": str(e),
         }
+
         print(f"Erro no processamento: {e}")
 
-    try:
-        publish_to_queue(payload)
-        print(f"Mensagem publicada na fila '{RABBITMQ_UPLOAD_QUEUE}'.")
-    except Exception as publish_err:
-        print(f"Erro ao publicar na fila '{RABBITMQ_UPLOAD_QUEUE}': {publish_err}")
-
+        try:
+            publish_to_queue(payload)
+            print(f"Mensagem publicada na fila '{RABBITMQ_UPLOAD_QUEUE}'.")
+        except Exception as publish_err:
+            print(f"Erro ao publicar na fila '{RABBITMQ_UPLOAD_QUEUE}': {publish_err}")
+            
     ch.basic_ack(delivery_tag=method.delivery_tag)
 
 def main():