o j1@s@ddlZddlmZmZmZddlZeeZGdddZ dS)N)AnyDictOptionalc@s@eZdZdZ  d@dededeedefdd Zd eeeffd d Z  dAd ededeeee fdeeee fd eee ff ddZ d eee ffddZ deee fd eee ffddZ ded eee ffddZded eee ffddZdeee fd eee ffdd Zdedeee fd eee ffd!d"Zded eee ffd#d$Z % & 'dBd(ed)ed*ed+ed,ed eee ff d-d.Zed/e d efd0d1Zd2eee fd3ed efd4d5Zded eee ffd6d7Zd8ed eee ffd9d:Zd;eee fd eee ffdd?ZdS)CLeadSquaredServicezNPython port of LeadSquared integration service used in tatsat2dev/leadsquared.N access_key secret_keyapi_hosttimeoutcCs:|pd|_|p d|_|pdd|_t||_dS)Nz$https://api-in21.leadsquared.com/v2//)striprrrstripr intr )selfrrr r rleadsquared_service.py__init__ szLeadSquaredService.__init__returncCs|j|jdS)N) accessKey secretKey)rr)rrrr _auth_paramsszLeadSquaredService._auth_paramsmethodendpoint query_paramspayloadc Cs|jr|js ddddS|jd|d}|}|r"||zxtj|||||j d}|j rz| }Wnt yGd|j i}Ynwt|trzt|dpTdd krz|d pf|d pf|j } td |||j dd | |dWSdd|dWStd|||j|j dd|jd|j ddWSt y} ztjd| ddddt| ddWYd} ~ Sd} ~ ww)NFz#LeadSquared credentials are missingsuccessmessagedatar )rurlparamsjsonr rawStatusr errorExceptionMessageMessagez5LeadSquared API returned error payload: %s %s body=%szLeadSquared API error: TzRequest successfulz7LeadSquared API request failed: %s %s status=%s body=%szLeadSquared API error (z): z!LeadSquared request exception: %s)exc_infoz Exception: )rrr lstriprupdaterequestsrequestupperr okr" Exceptiontext isinstancedictstrgetlowerloggerr% status_code) rrrrrr r!responseparsedrexcrrr_requestst    $ zLeadSquaredService._requestcCsb|ddddi}|dr&dd|jr|jddd nd |jd d Sd d|ddS)NPagingrOffsetRowCountrTz!LeadSquared connection successful z...r )rr )rr credentialsFzLeadSquared connection failed: r)rr) search_leadsr4rr )rresultrrrtest_connectionhs"  z"LeadSquaredService.test_connection search_paramscC|jdd|pidS)NPOSTLeadManagement.svc/Leads.Getrrrr;)rrFrrrrC zLeadSquaredService.search_leadslead_idcCs|jdddt|idS)NGETz LeadManagement.svc/Leads.GetByIdidrrrr;r3rrMrrrget_leads  zLeadSquaredService.get_leadphonecCs|jddd|idS)NrNz,LeadManagement.svc/RetrieveLeadByPhoneNumberrTrPrK)rrTrrrget_lead_by_phone_numberrLz+LeadSquaredService.get_lead_by_phone_number lead_datacCrG)NrHzLeadManagement.svc/Lead.CreaterJrK)rrVrrr create_leadrLzLeadSquaredService.create_leadcCs|jdddt|i|p idS)NrHzLeadManagement.svc/Lead.UpdateleadIdrrrrrQ)rrMrVrrr update_leads  zLeadSquaredService.update_leadcCs|jdddt|iidS)NrHzLeadManagement.svc/Lead.DeleterXrYrQrRrrr delete_leads  zLeadSquaredService.delete_leadr ModifiedOn from_date_str to_date_stroffset row_count date_fieldcCs:|d|d|d|dgdd||dd}|jdd |d S) aFetch leads whose `date_field` falls within [from_date_str, to_date_str]. Uses Leads.Get with AdvancedSearch so it works on all LSQ account tiers. Pagination is offset-based (Offset / RowCount) matching Leads.Get convention. `date_field` can be 'ModifiedOn' (default) or 'CreatedOn'. On a fresh / first-run call, pass a very old from_date to retrieve all historical leads. GreaterOrEqualToField ConditionValue LessOrEqualToAND ConditionsOperatorr>AdvancedSearchr<rHrIrJrK)rr^r_r`rarbrrrrget_leads_in_date_ranges( z*LeadSquaredService.get_leads_in_date_rangevaluecCsdddt|p dDS)z1Return only digit characters from a phone string.r css|] }|r|VqdS)N)isdigit).0chrrr sz3LeadSquaredService._phone_digits..)joinr3)rprrr _phone_digitssz LeadSquaredService._phone_digitslead query_digitscCsvt|dkr |ddn|}dD](}||}|sq||}t|dkr+|ddn|}||ks5||kr8dSqdS)aSReturn True if any phone field on the lead contains `query_digits` as a suffix. LSQ stores phones with country-code prefixes (+91-XXXXXXXXXX). We normalise both sides to digits and check that either the query is a suffix of the stored number or vice-versa (handles 10-digit vs 12-digit variants). rAN)PhoneMobile PhoneNumberTF)lenr4rv)rrwrxcorefield stored_rawstored stored_corerrr_lead_matches_phones  z&LeadSquaredService._lead_matches_phonec Cs||}|s ddddSt|dkr|ddn|}tt||g}|D]>}||}|ds3q&|d}t|tr?|n t|trG|gng}|D]} t| trc|| |rcdd | gdSqKq&g} |D]"}| d d d |d giddddd dd |d giddddg7} qi| d |dddddd|dddddg7} | D]R} | | }|dsq|d}g}t|tr|}nt|tr|dp|dp|dp|dpg}|D]} t| tr|| |rdd | gdSqqddddS)NFzPhone is requiredrrAryrrT Lead foundrkrzEqualrdrr>rmr{)SearchByrg) Parameterr<ListDatalistz#No LeadSquared lead found for phone) rvr}rr2fromkeysrUr4r1rrC) rrT normalizedr~ search_valuesvalrDrrowsrwpayloadsrrrrsearch_lead_by_phonesl     "      z'LeadSquaredService.search_lead_by_phoneemailcCs|sddddSdd|dgddd d d d }||}|d s&|S|d}g}t|tr5|}nt|trP|dpO|dpO|dpO|dpOg}|rXdd|dSddddS)NFzEmail is requiredr EmailAddressrrdrirjrrr>rmrrrrrTrz#No LeadSquared lead found for email)r rCr4r1rr2)rrrrDrrrrrsearch_lead_by_email0s(     ,  z'LeadSquaredService.search_lead_by_email activity_datacCrG)NrHzProspectActivity.svc/CreaterJrK)rrrrrcreate_activityLrLz"LeadSquaredService.create_activitycCs(|r||S|r||SddddS)NFz3Phone or email is required to search for a prospectr)rr)rrTrrrrsearch_prospectSs    z"LeadSquaredService.search_prospect)Nr)NN)rr\r])__name__ __module__ __qualname____doc__r3rrrrrrr;rErCrSrUrWrZr[ro staticmethodrvboolrrrrrrrrrr sr     I""&   ,@",r) loggingtypingrrrr+ getLoggerrr6rrrrrs