Ajusta callback

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,
+            "url": url if 'url' in locals() else None,
-            "videoId": video_id,
+            "videoId": video_id if 'video_id' in locals() else None,
             "error": str(e),
         }
 
         print(f"Erro no processamento: {e}")
 
-        try:
+    try:
-            publish_to_queue(payload)
+        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)
+        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:
+            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: