Update main.py

main.py

@@ -237,6 +237,7 @@ async def process_account_endpoint(account: str):
         agent_conf = AGENTS[account]["process"]
         agent_name = agent_conf["name"]
         discord_id = agent_conf["discord_id"]
+        system_discord_id = agent_conf.get("system_discord_id", 0)
 
         # Buscar 1 post aprovado pelo filtro mas ainda não processado
         select_url = f"{supabase_url}/rest/v1/posts?select=*&account_target=eq.{account}&approved_filter=eq.true&result=is.null&limit=1"
@@ -263,7 +264,7 @@ async def process_account_endpoint(account: str):
         try:
             import urllib.parse as _up
             _sys_msg = f"🎨 **{agent_name}** começou a processar uma postagem...\n\n📎 **Mídia:** {video_url}"
-            _sys_url = "https://discordmsg.arthurmribeiro51.workers.dev/?" + _up.urlencode({"mensagem": _sys_msg, "id": 0})
+            _sys_url = "https://discordmsg.arthurmribeiro51.workers.dev/?" + _up.urlencode({"mensagem": _sys_msg, "id": system_discord_id})
             requests.get("https://proxy.onrecurve.com/", params={"quest": _sys_url}, timeout=5)
         except Exception as _e:
             print(f"⚠️ Erro ao enviar notificação de início para o Discord: {_e}")
@@ -657,7 +658,7 @@ LEGENDA ORIGINAL:
 
             # ID 0 (sistema): marcou como finalizada + legenda completa
             _sys_end_msg = f"✅ **{agent_name}** marcou a postagem #{record_id} como finalizada.\n\n💬 **Legenda:** {legenda_done}"
-            _sys_end_url = "https://discordmsg.arthurmribeiro51.workers.dev/?" + _up.urlencode({"mensagem": _sys_end_msg, "id": 0})
+            _sys_end_url = "https://discordmsg.arthurmribeiro51.workers.dev/?" + _up.urlencode({"mensagem": _sys_end_msg, "id": system_discord_id})
             requests.get("https://proxy.onrecurve.com/", params={"quest": _sys_end_url}, timeout=5)
         except Exception as _e:
             print(f"⚠️ Erro ao enviar notificação de conclusão para o Discord: {_e}")
@@ -673,7 +674,7 @@ LEGENDA ORIGINAL:
         try:
             import urllib.parse as _up
             sys_err_msg = f"<@1331348103806189675> 🚨 **ERRO CRÍTICO** ao processar post #{record_id if record_id else 'desconhecido'}:\n\n`{err_msg}`\n\nNão foi possível concluir a solicitação."
-            sys_err_url = "https://discordmsg.arthurmribeiro51.workers.dev/?" + _up.urlencode({"mensagem": sys_err_msg, "id": 0})
+            sys_err_url = "https://discordmsg.arthurmribeiro51.workers.dev/?" + _up.urlencode({"mensagem": sys_err_msg, "id": system_discord_id})
             requests.get("https://proxy.onrecurve.com/", params={"quest": sys_err_url}, timeout=5)
         except Exception as dc_e:
             print(f"⚠️ Erro ao enviar Discord de falha: {dc_e}")
@@ -744,6 +745,7 @@ async def run_filter_account(account: str):
         agent_conf = AGENTS[account]["filter"]
         agent_name = agent_conf["name"]
         discord_id = agent_conf["discord_id"]
+        system_discord_id = agent_conf.get("system_discord_id", 0)
 
         # Buscar 1 post pendente para filtro para essa conta
         select_url = f"{supabase_url}/rest/v1/posts?select=*&account_target=eq.{account}&filter_message=is.null&limit=1"
@@ -769,7 +771,7 @@ async def run_filter_account(account: str):
             sys_msg = f"🏃‍♀️ **{agent_name}** começou a filtrar uma postagem...\n\n📎 **Mídia:** {url_to_download}"
             sys_target_url = "https://discordmsg.arthurmribeiro51.workers.dev/?" + urllib.parse.urlencode({
                 "mensagem": sys_msg,
-                "id": 0
+                "id": system_discord_id
             })
             requests.get(
                 "https://proxy.onrecurve.com/",
@@ -848,7 +850,7 @@ async def run_filter_account(account: str):
             
             sys_end_url = "https://discordmsg.arthurmribeiro51.workers.dev/?" + urllib.parse.urlencode({
                 "mensagem": sys_end_msg,
-                "id": 0
+                "id": system_discord_id
             })
             requests.get(
                 "https://proxy.onrecurve.com/",
@@ -885,7 +887,7 @@ async def run_filter_account(account: str):
         try:
             import urllib.parse as _up
             sys_err_msg = f"<@1331348103806189675> 🚨 **ERRO CRÍTICO** ao filtrar post #{record_id if record_id else 'desconhecido'}:\n\n`{err_msg}`\n\nNão foi possível concluir a solicitação."
-            sys_err_url = "https://discordmsg.arthurmribeiro51.workers.dev/?" + _up.urlencode({"mensagem": sys_err_msg, "id": 0})
+            sys_err_url = "https://discordmsg.arthurmribeiro51.workers.dev/?" + _up.urlencode({"mensagem": sys_err_msg, "id": system_discord_id})
             requests.get("https://proxy.onrecurve.com/", params={"quest": sys_err_url}, timeout=5)
         except Exception as dc_e:
             print(f"⚠️ Erro ao enviar Discord de falha: {dc_e}")
@@ -927,6 +929,7 @@ async def publish_account_endpoint(account: str):
         agent_conf = AGENTS[account]["publish"]
         agent_name = agent_conf["name"]
         discord_id = agent_conf["discord_id"]
+        system_discord_id = agent_conf.get("system_discord_id", 0)
 
         # Buscar 1 post pronto para publicação
         select_url = f"{supabase_url}/rest/v1/posts?select=*&account_target=eq.{account}&result=not.is.null&final_content_url=not.is.null&published=eq.false&or=(superior_needs_verification.is.null,superior_needs_verification.eq.false)&limit=1"
@@ -1005,7 +1008,7 @@ async def publish_account_endpoint(account: str):
                     import urllib.parse
                     sys_end_url = "https://discordmsg.arthurmribeiro51.workers.dev/?" + urllib.parse.urlencode({
                         "mensagem": sys_end_msg,
-                        "id": 0
+                        "id": system_discord_id
                     })
                     requests.get("https://proxy.onrecurve.com/", params={"quest": sys_end_url}, timeout=5)
                 
@@ -1031,7 +1034,7 @@ async def publish_account_endpoint(account: str):
             sys_msg = f"📦 **{agent_name}** começou a revisar uma postagem para publicação...\n\n📎 **Conteúdo:** {final_content_url}"
             sys_target_url = "https://discordmsg.arthurmribeiro51.workers.dev/?" + urllib.parse.urlencode({
                 "mensagem": sys_msg,
-                "id": 0
+                "id": system_discord_id
             })
             requests.get(
                 "https://proxy.onrecurve.com/",
@@ -1162,7 +1165,7 @@ RESULTADO GERADO PARA A POSTAGEM (o texto que vai pro ar com o post):
 
             sys_end_url = "https://discordmsg.arthurmribeiro51.workers.dev/?" + urllib.parse.urlencode({
                 "mensagem": sys_end_msg,
-                "id": 0
+                "id": system_discord_id
             })
             requests.get(
                 "https://proxy.onrecurve.com/",
@@ -1196,7 +1199,7 @@ RESULTADO GERADO PARA A POSTAGEM (o texto que vai pro ar com o post):
         try:
             import urllib.parse as _up
             sys_err_msg = f"<@1331348103806189675> 🚨 **ERRO CRÍTICO** na publicação do post #{record_id if record_id else 'desconhecido'}:\n\n`{err_msg}`\n\nNão foi possível concluir a solicitação."
-            sys_err_url = "https://discordmsg.arthurmribeiro51.workers.dev/?" + _up.urlencode({"mensagem": sys_err_msg, "id": 0})
+            sys_err_url = "https://discordmsg.arthurmribeiro51.workers.dev/?" + _up.urlencode({"mensagem": sys_err_msg, "id": system_discord_id})
             requests.get("https://proxy.onrecurve.com/", params={"quest": sys_err_url}, timeout=5)
         except Exception as dc_e:
             print(f"⚠️ Erro ao enviar Discord de falha: {dc_e}")