Yi<dZddlZddlZddlmZmZddlZddlmZeje Z Gdde Z Gdd Zd ed efd Zy) zWrapper na API CRM dgred.com.N)AnyIterable)configceZdZdZy)CRMErroruBłąd komunikacji z CRM.N)__name__ __module__ __qualname____doc__4/var/www/html/scraper-prawny.klono.ai/scraper/crm.pyrrs#rrceZdZejej ej fdededefdZ dedefdZ dedede fd Z de fd Zd e de fd Zdd edee fdZdedzdedzde fdZdedede fdZded e de fdZy) CRMClientbase_urlapi_keytimeoutc|jd|_||_||_t j |_|j jjddiy)N/Acceptzapplication/json) rstriprrrrequestsSessionsessionheadersupdate)selfrrrs r__init__zCRMClient.__init__sP !,   '')  ##X/A$BCrpathreturnc"|j|SN)r)rr s r_urlzCRMClient._url s--''rmethodc |jdixsi}|j|d< |jj||j |f||j d|}|jdk\r-t|d|d|jd|jdd  |jS#t j$r}td||d}~wwxYw#t$r}td |d||d}~wwxYw) NparamsapiKey)r'rzNetwork error: i u → HTTP z: i,zInvalid JSON from ) poprrrequestr$rrRequestExceptionr status_codetextjson ValueError)rr%r kwargsr'res r_requestzCRMClient._request#s Hb)/R<<x 9$ $$ $06 PVA ==C fXQtfJq}}oRtPS ~VW W D668O(( 9_QC01q 8 9 D/vRs;c*|jdd|S)u'POST /clients — dodanie nowego leada.POSTr7r/r4r=s radd_leadzCRMClient.add_lead;s}}VZd};;r page_sizecg}d} |jdd||d}|jdgxsg}|j||jdd}||k\s|s |S|dz }tjdu) u8GET /clients — paginowane pobranie wszystkich leadów.rr6r7)pager8r9r>pagesg?)r4r<extendtimesleep)rrE all_leadsrGrespr>rHs r get_all_leadszCRMClient.get_all_leads?s " ==z4)*L!D88FB'-2D   T "HHWa(Eu}D AID JJsOremailNphonec|s|sy|j}|D]l}|r7|jdr&|dj|jk(ry|s?|jdsQt|dt|k(slyy)uSprawdzenie czy lead z danym emailem lub telefonem już istnieje. Uwaga: do masowej deduplikacji używaj klasy Deduplicator (cache w pamięci). Ta metoda wykonuje pełen pull każdorazowo i jest tylko do testów ad-hoc. FrOTrP)rNr<lower _norm_phone)rrOrPleadsleads r lead_existszCRMClient.lead_existsPs U""$ D'*tG}/B/B/D /U'*{4=/I[Y^M_/_   r client_idnotec6|jdd|dd|iS)zPOST /clients/{id}/notes.rAz /clients/z/notescontentrBrC)rrWrXs radd_notezCRMClient.add_note`s-}} i {&1D8I  rc0|jdd||S)zPUT /client/{id}.PUTz/client/rBrC)rrWr>s r update_leadzCRMClient.update_leadfs}}Uhyk$:}FFr)d)r r r r CRM_BASE_URL CRM_API_KEYREQUEST_TIMEOUTstrintrr$dictr4boolr?rDlistrNrVr[r^r rrrrs++))-- D D D D(((DsD#DDD&*d* z_norm_phone..ls;qyy{1;s)join)rPs rrSrSks 77;u{; ;;r)r loggingrJtypingrrrrir getLoggerr log ExceptionrrrcrSr rrrusW# g!$y$VGVGr