<*,j,tdZddlmZddlZddlmZddlZddlmZeje Z GddZ y)z,dgred CRM REST API client with dry-run mode.) annotationsN)Any)SettingscpeZdZdZddZddZddZddZddZddZ ddZ dd Z dd Z dd Z dd Zdd Zy) DgredClientzCWrapper around dgred API v1. All calls append ?apiKey=... for auth.c|jjd|_|j|_|j |_t jd|_i|_ y)N/)timeout) dgred_base_urlrstripbase_url dgred_api_keyapi_keydry_runhttpxClient_http _status_cache)selfsettingss E/var/www/html/agent.samochodowy/src/agent_samochodowy/dgred/client.py__init__zDgredClient.__init__sL //66s; -- '' \\"- -/cPd|vrdnd}|j||d|jS)N?&zapiKey=)rr)rpathseps r_urlzDgredClient._urls0D[cc--se74<<.AArc|jj|j|}|j|j SN)rgetr raise_for_statusjson)rrresps r_getzDgredClient._get!s4zz~~diio. yy{rc|jrtjd||ddiS|jj |j ||}|j |j}t|tr d|vr|dS|S)Nu[DRY-RUN] POST %s — %sidz dry-run-idr%data) rloggerinforpostr r$r% isinstancedictrrpayloadr&bodys r_postzDgredClient._post&sy << KK2D' B,' 'zztyyW= yy{ dD !fn<  rc|jrtjd||iS|jj |j ||}|j |j}t|tr d|vr|dS|S)Nu[DRY-RUN] PUT %s — %sr*r+) rr,r-rputr r$r%r/r0r1s r_putzDgredClient._put2ss << KK14 AIzz~~diioG~< yy{ dD !fn<  rc:|jr |jS|jrQt|dDcic]\}}|| c}}|_tj d|j|jS|j d}t |tr|n|jdg}i}|D] }|d||d<|D]J}||vs|jdd|i}|jdd||<tj d |||L||_|Scc}}w) u<Ensure required client statuses exist; return name→id map.z[DRY-RUN] Status map: %sz/client-statusesr+r)namez/client-statuses/addrz Created dgred status: %s (id=%s)) rr enumerater,r-r'r/listr#r4) rnamesir:rawexisting name_to_idsresults rensure_statuseszDgredClient.ensure_statusesAs#   %% % <<9B5!9L!Mga$'!MD  KK2D4F4F G%% %ii*+$S$/3SWWVR5H%'  ,A$%dGJqy ! , XD:%$:VTNK#)::dA#6 4  >jQUFVW  X (#"Ns Dc&|jd|S)z5Create a new client. Returns the created client dict.z/clientsr4)rr+s r create_clientzDgredClient.create_client_szz*d++rc,|jd||S)zUpdate client fields./client/r7)r client_idr+s r update_clientzDgredClient.update_clientcsyy8I;/66rc0|jd|d|iS)zSet externalId on a client.rI externalIdrJ)rrK external_ids rset_external_idzDgredClient.set_external_idgsyy8I;/, 1LMMrc4|jd|d|ddS)zAdd a note to a client.z /clients/z/notesF)contentshowClientPanelrF)rrKrRs radd_notezDgredClient.add_noteos)zzIi[7$:   rcD|jrtjd|y |jd|}t |t r|n|j dg}|D]}|j d|k(s|cS y#tjttf$rYywxYw)z?Search for a client by externalId. Returns client dict or None.z([DRY-RUN] Search client by externalId=%sNz/clients?externalId=r+rN) rr,r-r'r/r<r#rHTTPStatusError IndexErrorKeyError)rrOresultsitemsitems rfind_client_by_external_idz&DgredClient.find_client_by_external_idzs << KKBK P ii"6{m DEG)'48Ggkk&RT>UE 88L)[8K %%z8<   sAA>7A>;A>>BBc8|jjyr")rclose)rs rr^zDgredClient.closes rN)rrreturnNone)rstrr_ra)rrar_r)rrar2r0r_r)r=z list[str]r_zdict[str, int])r+r0r_r0)rK int | strr+r0r_r0)rKrbrOrar_r0)rKrbrRrar_r0)rOrar_z dict | None)r_r`)__name__ __module__ __qualname____doc__rr r'r4r7rDrGrLrPrTr\r^rrrrsCM0B  <,7N  rr) rf __future__rloggingtypingrragent_samochodowy.configr getLoggerrcr,rrgrrrms52" -   8 ${{r