${j"dZddlZddlZddlZejdZdZdZejddjZ dZ d e d e e e ffd Z dd e d e d e de dzd eeee ff dZ dde de dzd e de dzde dzd eeee ff dZy)u GoHighLevel (Linkia) API client — Sweet Angels SDR Medio Porte. Clone do ghl_client.py do sdr_fesqua. Unica diferenca: DEFAULT_PIPELINE_ID vem de env (LINKIA_PIPELINE_ID_MEDIO_PORTE) porque o pipeline dessa campanha ainda vai ser criado pelo Renato no Linkia. Gotchas GHL serverless (ver ghl_integration_gotchas.md): - sempre consumir body do fetch (a gente ja consome via r.text). - dedupe 400: usar contactId do erro (nao implementado aqui — cabe adicionar se comecar a bater 400 duplicate). - delay de indexacao de 30-90s: enviar mensagem logo apos criar contato pode falhar. Contatos ja existem na lista antes do webhook. Nghl_client_medio_portez$https://services.leadconnectorhq.comz 2021-07-28LINKIA_PIPELINE_ID_MEDIO_PORTEzoMozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36tokenreturnc(d|ddttdS)NzBearer zapplication/json) Authorizationz Content-TypeAcceptVersionz User-Agent)GHL_API_VERSION USER_AGENT)rs F/opt/mia/workspace/clientes/sweet_angels/sdr_medio_porte/ghl_client.py _base_headersr%s""5'**$"   contact_idmessageconversation_idctd}t|}d||d}|r||d< tj|||d}|j}|s0t j d||j|jdd n!t jd ||j||j|jfS#tj$r.} t jd | d d t| fcYd} ~ Sd} ~ wwxYw)zl Envia mensagem WhatsApp para o contato via API do GHL/Linkia. Retorna (ok, status_code, body). z/conversations/messagesWhatsApp)type contactIdrconversationIdjsonheaderstimeoutz,GHL send failed contact=%s status=%s body=%sNz GHL send ok contact=%s status=%szGHL send exception: %sFr) GHL_API_BASErrequestspostoklogwarning status_codetextinfoRequestException exceptionstr) rrrrurlrpayloadrr"es rsend_whatsapp_messager//sN1 2CE"GG $3 !  MM#GWb I TT KK>AMM166$3<  HH7Q]] S1==!&&((  $ $  .2aQ sBB44C5#C0*C50C5opportunity_idstage_idstatus pipeline_idc 6|sy|syi}|r|xst}|sy||d<||d<|r||d<|sytd|}t|} tj|||d } | j } | s1t jd ||| j| jd d n"t jd||| j| | j| jfS#tj$r/} t jd|| ddt| fcYd } ~ Sd } ~ wwxYw)a Move card de oportunidade para uma etapa e/ou atualiza status via API v2 do GHL. - Se `stage_id` for informado, envia `pipelineStageId` no body (a API exige tambem `pipelineId`; usa `pipeline_id` recebido ou o DEFAULT_PIPELINE_ID). - Se `status` for informado (ex.: 'lost', 'won'), envia `status` no body. - Se ambos forem informados, envia num unico PUT. - Se nenhum for informado, nao chama a API e retorna (False, 0, 'noop'). Retorna (ok, status_code, body). )Frmissing_opportunity_id)Fr missing_token)Frmissing_pipeline_idpipelineStageId pipelineIdr2)Frnoopz/opportunities/rrz?GHL move opportunity failed opp=%s payload=%s status=%s body=%sNrz3GHL move opportunity ok opp=%s payload=%s status=%sz)GHL move opportunity exception opp=%s: %sFr)DEFAULT_PIPELINE_IDrrr putr"r#r$r%r&r'r(r)r*) r0r1rr2r3r,effective_pipeliner+rr-r"r.s rmove_opportunity_stager>Ss$$ 1 ( G(?,?!2%-!" 2  "  N/.)9 :CE"G LL7GR H TT KKQt   HHE 1==!&&((  $ $  A>STUaQ sBCD)$D DD)N)NN)__doc__loggingosr getLoggerr#rr getenvstripr;r r*dictrtupleboolintr/r>rrrJs  g015   bii @"EKKM9 c3h#' ! ! !  ! 4Z !  4c> ! P" 7 7 Dj7  7  $J 7 t 7  4c> 7 r