From 501c45cad7a88cfa4193925c31dd7a09e177dbc7 Mon Sep 17 00:00:00 2001
From: admin <admin@admin.com>
Date: Tue, 5 Aug 2025 14:43:12 +0200
Subject: [PATCH] Ajusta callback

---
 main.py | 29 +++++++++++++----------------
 1 file changed, 13 insertions(+), 16 deletions(-)

diff --git a/main.py b/main.py
index 52e8ebd..2dbd5d5 100644
--- a/main.py
+++ b/main.py
@@ -37,8 +37,6 @@ 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")
@@ -58,30 +56,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,
+            "filename": filename if 'filename' in locals() else None,
             "processedFiles": [],
-            "url": url,
-            "videoId": video_id,
+            "url": url if 'url' in locals() else None,
+            "videoId": video_id if 'video_id' in locals() else None,
             "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}")
+    finally:
         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)
+            ch.basic_ack(delivery_tag=method.delivery_tag)
+        except Exception as ack_err:
+            print(f"Erro ao dar ack: {ack_err}")
 
 def main():
     while True: