habulaj commited on
Commit
066582a
·
verified ·
1 Parent(s): 30dde3f

Update main.py

Browse files
Files changed (1) hide show
  1. main.py +7 -19
main.py CHANGED
@@ -821,13 +821,9 @@ LEGENDA ORIGINAL:
821
  print(f"⚠️ Erro ao enviar Discord de falha: {dc_e}")
822
 
823
  if record_id:
824
- try:
825
- # Update Supabase to avoid endless retry loop
826
- update_url = f"{supabase_url}/rest/v1/posts?id=eq.{record_id}"
827
- patch_payload = {"result": [{"error": err_msg, "failed": True}]}
828
- requests.patch(update_url, headers=headers, json=patch_payload, timeout=10)
829
- except Exception as sup_e:
830
- print(f"⚠️ Erro ao atualizar falha no Supabase: {sup_e}")
831
 
832
  publish_res = await safe_call_publish()
833
  return JSONResponse(status_code=500, content={"error": f"Erro interno: {err_msg}", "publish_result": publish_res})
@@ -1129,17 +1125,9 @@ Reprovando (exemplo 2):
1129
  print(f"⚠️ Erro ao enviar Discord de falha: {dc_e}")
1130
 
1131
  if record_id:
1132
- try:
1133
- update_url = f"{supabase_url}/rest/v1/posts?id=eq.{record_id}"
1134
- patch_payload = {
1135
- "filter_message": f"Erro interno: {err_msg}",
1136
- "approved_filter": False,
1137
- "image_needs_correction": False,
1138
- "contains_image": False
1139
- }
1140
- requests.patch(update_url, headers=headers, json=patch_payload, timeout=10)
1141
- except Exception as sup_e:
1142
- print(f"⚠️ Erro ao atualizar falha no Supabase: {sup_e}")
1143
 
1144
  process_res = await safe_call_process()
1145
  return JSONResponse(status_code=500, content={"error": f"Erro interno: {err_msg}", "next_steps": {"process": process_res}})
@@ -1168,7 +1156,7 @@ async def publish_girlsmoodaily_endpoint():
1168
  }
1169
 
1170
  # Buscar 1 post pronto para publicação: tem result, tem final_content_url, published=false, superior_needs_verification IS NULL
1171
- select_url = f"{supabase_url}/rest/v1/posts?select=*&result=not.is.null&final_content_url=not.is.null&published=eq.false&superior_needs_verification=is.null&limit=1"
1172
  res_get = requests.get(select_url, headers=headers, timeout=10)
1173
  if not res_get.ok:
1174
  raise HTTPException(status_code=500, detail=f"Erro ao ler posts: {res_get.text}")
 
821
  print(f"⚠️ Erro ao enviar Discord de falha: {dc_e}")
822
 
823
  if record_id:
824
+ # A pedido do usuário, não vamos salvar falso result de falha no Supabase
825
+ # salvará quando de fato gerar com sucesso o final_content_url e result.
826
+ pass
 
 
 
 
827
 
828
  publish_res = await safe_call_publish()
829
  return JSONResponse(status_code=500, content={"error": f"Erro interno: {err_msg}", "publish_result": publish_res})
 
1125
  print(f"⚠️ Erro ao enviar Discord de falha: {dc_e}")
1126
 
1127
  if record_id:
1128
+ # A pedido do usuário, não vamos salvar falso result de falha no Supabase
1129
+ # salvará quando de fato o filtro não aprovar.
1130
+ pass
 
 
 
 
 
 
 
 
1131
 
1132
  process_res = await safe_call_process()
1133
  return JSONResponse(status_code=500, content={"error": f"Erro interno: {err_msg}", "next_steps": {"process": process_res}})
 
1156
  }
1157
 
1158
  # Buscar 1 post pronto para publicação: tem result, tem final_content_url, published=false, superior_needs_verification IS NULL
1159
+ select_url = f"{supabase_url}/rest/v1/posts?select=*&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"
1160
  res_get = requests.get(select_url, headers=headers, timeout=10)
1161
  if not res_get.ok:
1162
  raise HTTPException(status_code=500, detail=f"Erro ao ler posts: {res_get.text}")