Update main.py
Browse files
main.py
CHANGED
|
@@ -393,6 +393,8 @@ class FilterRequest(BaseModel):
|
|
| 393 |
image_url: Optional[str] = None
|
| 394 |
context: Optional[str] = None
|
| 395 |
discord_id: Optional[int] = 1
|
|
|
|
|
|
|
| 396 |
|
| 397 |
@app.post("/filter")
|
| 398 |
async def filter_endpoint(request: FilterRequest):
|
|
@@ -410,7 +412,11 @@ async def filter_endpoint(request: FilterRequest):
|
|
| 410 |
|
| 411 |
try:
|
| 412 |
import urllib.parse
|
| 413 |
-
|
|
|
|
|
|
|
|
|
|
|
|
|
| 414 |
sys_target_url = "https://discordmsg.arthurmribeiro51.workers.dev/?" + urllib.parse.urlencode({
|
| 415 |
"mensagem": sys_msg,
|
| 416 |
"id": 0
|
|
@@ -528,15 +534,34 @@ Reprovando (exemplo 2):
|
|
| 528 |
|
| 529 |
try:
|
| 530 |
import urllib.parse
|
|
|
|
| 531 |
target_url = "https://discordmsg.arthurmribeiro51.workers.dev/?" + urllib.parse.urlencode({
|
| 532 |
"mensagem": filter_data.get("filter_message", ""),
|
| 533 |
-
"id":
|
| 534 |
})
|
| 535 |
requests.get(
|
| 536 |
"https://proxy.onrecurve.com/",
|
| 537 |
params={"quest": target_url},
|
| 538 |
timeout=5
|
| 539 |
)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 540 |
except Exception as e:
|
| 541 |
print(f"⚠️ Erro ao enviar mensagem para o Discord: {e}")
|
| 542 |
|
|
|
|
| 393 |
image_url: Optional[str] = None
|
| 394 |
context: Optional[str] = None
|
| 395 |
discord_id: Optional[int] = 1
|
| 396 |
+
ig_username: Optional[str] = None
|
| 397 |
+
post_url: Optional[str] = None
|
| 398 |
|
| 399 |
@app.post("/filter")
|
| 400 |
async def filter_endpoint(request: FilterRequest):
|
|
|
|
| 412 |
|
| 413 |
try:
|
| 414 |
import urllib.parse
|
| 415 |
+
|
| 416 |
+
author_info = f"\n👤 **Autor:** @{request.ig_username}" if request.ig_username else ""
|
| 417 |
+
post_info = f"\n🔗 **URL Original:** {request.post_url}" if request.post_url else ""
|
| 418 |
+
|
| 419 |
+
sys_msg = f"🏃♀️ **{agent_name}** começou a filtrar uma postagem...{author_info}{post_info}\n\n📎 **Mídia:** {url_to_download}"
|
| 420 |
sys_target_url = "https://discordmsg.arthurmribeiro51.workers.dev/?" + urllib.parse.urlencode({
|
| 421 |
"mensagem": sys_msg,
|
| 422 |
"id": 0
|
|
|
|
| 534 |
|
| 535 |
try:
|
| 536 |
import urllib.parse
|
| 537 |
+
# 1) Mensagem normal do filtro para o bot específico (id 1, 2 ou 3)
|
| 538 |
target_url = "https://discordmsg.arthurmribeiro51.workers.dev/?" + urllib.parse.urlencode({
|
| 539 |
"mensagem": filter_data.get("filter_message", ""),
|
| 540 |
+
"id": discord_id
|
| 541 |
})
|
| 542 |
requests.get(
|
| 543 |
"https://proxy.onrecurve.com/",
|
| 544 |
params={"quest": target_url},
|
| 545 |
timeout=5
|
| 546 |
)
|
| 547 |
+
|
| 548 |
+
# 2) Aviso final pro Painel de Sistema (ID 0)
|
| 549 |
+
is_approved = filter_data.get("approved_filter", False)
|
| 550 |
+
status_emoji = "✅" if is_approved else "❌"
|
| 551 |
+
status_text = "APROVOU" if is_approved else "REPROVOU"
|
| 552 |
+
|
| 553 |
+
author_text = f" de **@{request.ig_username}**" if request.ig_username else ""
|
| 554 |
+
sys_end_msg = f"{status_emoji} **{agent_name}** {status_text} a postagem{author_text} para a próxima etapa."
|
| 555 |
+
|
| 556 |
+
sys_end_url = "https://discordmsg.arthurmribeiro51.workers.dev/?" + urllib.parse.urlencode({
|
| 557 |
+
"mensagem": sys_end_msg,
|
| 558 |
+
"id": 0
|
| 559 |
+
})
|
| 560 |
+
requests.get(
|
| 561 |
+
"https://proxy.onrecurve.com/",
|
| 562 |
+
params={"quest": sys_end_url},
|
| 563 |
+
timeout=5
|
| 564 |
+
)
|
| 565 |
except Exception as e:
|
| 566 |
print(f"⚠️ Erro ao enviar mensagem para o Discord: {e}")
|
| 567 |
|