uIg\ddlZddlZddlZddlZddlZddlmZmZddlmZm Z ddl m Z ddl m Z ddlmZddlmZddlmZmZmZdd lmZmZdd lmZdd lmZmZmZmZm Z m!Z!dd l"m#Z#m$Z$m%Z%m&Z&dd l'm(Z( ddl)Z)ejXe efZ-dZ.Gdde/Z0dZ1dZ2y#e*$rddl+Z)Y.wxYw)N)datetime timedelta)UUIDuuid4)tzutc) string_types)Consumer)ExceptionCapture)exc_info_from_errorexceptions_from_error_tuple handle_in_app)InconclusiveMatchErrormatch_feature_flag_properties)Poller) DEFAULT_HOSTAPIError batch_postdecidedetermine_server_hostget)SizeLimitedDictcleanguess_timezoneremove_trailing_slash)VERSIONiPceZdZdZej dZ d'dZd(dZ d)dZ d)d Z d)d Z d)d Z d*d Z d(d Zd(dZ d+dZd(dZ d+dZ d+dZdZdZdZdZdZdZiiidddZiiidddddZiiidddddZdiiidddddZd Ziiiddd!d"Ziiiddd!d#Z iiiddd$Z!d%Z"d&Z#y),ClientzCreate a new PostHog client.posthogNFTc tj||_|xs||_td|jt||_||_||_| |_|xst|_ t||_ | |_ | |_d|_d|_d|_d|_||_||_d|_t-t.t0|_||_||_||_||_||_||_d|_ | tCjD}||_$||_%|r>tMjN|jPjStLjTn)|jPjStLjV|j<rtY||j>|_ | rd|_-y|rt]j^|j`tc| D]j}g|_-te|j|j|j|||| | | | }|jZjg||s[|jily#tF$rd}YQwxYw)Napi_key) integrations)hoston_errorflush_atflush_intervalgzipretriestimeouthistorical_migration)5queueQueuer requirerr#debugsend sync_moderraw_hostrr"r&r( feature_flagsfeature_flags_by_keygroup_type_mappingcohorts poll_interval%feature_flags_request_timeout_secondspollerr MAX_DICT_SIZEset#distinct_ids_feature_flags_reporteddisabled disable_geoipr)super_propertiesenable_exception_autocapture"exception_autocapture_integrationsexception_captureosgetcwd Exception project_rootpersonal_api_keylogging basicConfiglogsetLevelDEBUGWARNINGr consumersatexitregisterjoinranger appendstart)selfr r"r-max_queue_sizer.r#r$r%r& max_retriesr/r(threadr5rEproject_api_keyr;r<r)r6r=r>r?rDnconsumers K/var/www/html/answerous/venv/lib/python3.12/site-packages/posthog/client.py__init__zClient.__init__$s6[[0 '1'  4<<6    ",  )$/   !$(!"& *5Z2 3B=RU3V0  *$8! 0,H)2T/!%   $!yy{ )!1     ! HH  gmm , HH  goo .  , ,%5dIpIp%qD " !DN *6] %!##JJLL%%#1'#)= %%h/NN$% %; $#  $sI I.-I.c|xsi}|xsi}td|ttd|t||||d|d}|j||S)N distinct_id propertiesz $identify timestampcontextr]$seteventuuidr,ID_TYPESdict_enqueuerSr]r^rar`rdr<msgs rZidentifyzClient.identifys[%2 -R {H5 j$/#&   }}S-00c6|j|||||}|dS)N featureFlags get_deciderSr]groupsperson_propertiesgroup_propertiesr< resp_datas rZget_feature_variantszClient.get_feature_variantss(OOK9JL\^kl ((rlc6|j|||||}|dS)NfeatureFlagPayloadsrorqs rZget_feature_payloadszClient.get_feature_payloadss)OOK9JL\^kl .//rlcB|j|||||}|d|ddS)Nrnrxrnrxrorqs rZget_feature_flags_and_payloadsz%Client.get_feature_flags_and_payloadss8OOK9JL\^kl %n5#,-B#C  rlctd|t| |j}|rtd|tni}|||||d}t |j |j fd|ji|}|S)Nr]rr)r]rrrsrtr<r()r,rfr<rgrr r"r6)rSr]rrrsrtr< request_datarus rZrpzClient.get_decidesx {H5   ..M  Hfd +F'!2 0*  4<<wD GW6= y 2 3 >9I8N8N8Pg eTYafTfgg 8L 4 5  I#3 Is<7H IC }}S-00' [""%UVWUX#YZZ [ hs$+D E%E ED??Ec|xsi}|xsi}td|ttd|t||||d|d}|j||S)Nr]r^rbr_reris rZr9z Client.sets[%2 -R {H5 j$/#&  }}S-00rlc|xsi}|xsi}td|ttd|t||||d|d}|j||S)Nr]r^ $set_once)r`rar]rrcrdreris rZset_oncezClient.set_onces[%2 -R {H5 j$/#&#   }}S-00rlc|xsi}|xsi}td|ttd|ttd|td|||ddj|||||d}|j ||S)N group_type group_keyr^z$groupidentify)z $group_type $group_keyz $group_setz${}_{})rcr^r]r`rard)r,rfrgformatrh) rSrrr^rar`rdr<rjs rZgroup_identifyzClient.group_identify*s %2 -R j(3 Y1 j$/&)'( $??:yA"  }}S-00rlc|xsi}td|ttd|t||d||d|d}|j||S)N previous_idr])r]aliasz $create_alias)r^r`rarcr])r,rfrh)rSrr]rar`rdr<rjs rZrz Client.aliasIsX-R {H5 {H5 +$#$&  }}S-00rlc|xsi}|xsi}td|ttd|ttd|t||d<d|||||d}|j ||S)Nr]r^urlz $current_urlz $pageview)rcr^r`rar]rd)r,rfrgrrh) rSr]rr^rar`rdr<rjs rZpagez Client.page\ss %2 -R {H5 j$/sL)%( >"!$"&  }}S-00rlc  |xsi}|d|d<t}td|ttd|t| t |}nt j }||dk(r|jjdyt|} tdd| ii|j } | dd} | d jd | d jd | t|jd |jd|d|}|j!|d|||||S#t"$r(} |jj%d| Yd} ~ yd} ~ wwxYw)NFz$process_person_profiler]r^)NNNz"No exception information availablervalues)rDrtyperz /project/z/person/)z$exception_typez$exception_messagez$exception_listz$exception_personURLz $exceptionzFailed to capture exception: )rr,rfrgr sysexc_inforHwarningr r rDrrr0r rrCr) rSrr]r^rar`rdrrrall_exceptions_with_tracerc$all_exceptions_with_trace_and_in_apprs rZcapture_exceptionzClient.capture_exceptionss- D#)rJ"8= 45#g M; 9 L*d 3$.y9<<>8/A#A  !EF)DH(M %" ";" ".. E493Eh3O 0$H#J#N#Nv#V&J1&M&Q&QRY&Z#G+@+O*PPYZ^ZfZfYggop{o|(}   J<< \:wPY[_agh h D HH  !>qcB C C DsA=DBD E EEc|jry|d}|tjt}t d|tt d|dt t |}|j|d<d|vr!|jd}|rt||d<|jdsi|d<d|dd <t|dd <| |j}|rd |dd <|jri|d|j|d<t|jd d|d <t|}|jj!d||j"sd |fS|j$rg|jj!d|dt'|j(|j*|j,|j.|g|j0d |fS |j2j5|d|jj!d|dd |fS#t2j6$r"|jj9dd|fcYSwxYw)z8Push a new `msg` onto the queue, return `(success, msg)`)Fr;r`Ntzrardr^zposthog-pythonz$libz $lib_versionTz$geoip_disabler]z queueing: %szenqueued with blocking %s.rc)r&r(batchr)F)blockz enqueued %s.zanalytics-python queue is full)r;rnowrr,rgr isoformatpop stringify_idrrr<r=rrHr-r.r/rr r"r&r(r)r*putFullr)rSrjr<r`rds rZrhzClient._enqueues ==$ $   0I Y1 3y>40#9- $..0K S=776?D*40F ww|$ "C $4L&!,3L.)   ..M 26C . /  N3|#4 N8M8M NC )#''-*FGMCj ~s+yy9  >> HHNN7W F   YY e%)%>%>  9   JJNN3eN , HHNN>3w< 89 zz  HH  = >#:  s?H2H=<H=c|j}|j}|j|jj d|y)z4Forces a flush from the internal queue to the serverz$successfully flushed about %s items.N)r*qsizerOrHr-)rSr*sizes rZflushz Client.flushs6 u{{}  =tDrlc|jD]#}|j |j%|jr|jj yy#t$rYYwxYw)zbEnds the consumer thread once the queue is empty. Blocks execution until finished N)rLpauserO RuntimeErrorr7stop)rSrYs rZrOz Client.joinsa H NN     ;; KK        sA A'&A'c|j|j|jr|jjyy)z2Flush all messages and cleanly shutdown the clientN)rrOr@closerSs rZshutdownzClient.shutdowns4   ! !  " " ( ( * "rlc  t|jd|jd|jd}|dxsg|_|jDcic]}|jd|d|c}|_|dxsi|_|dxsi|_t!j"t%|_ycc}w#t$rk}|jd k(r4|jjd |jr+td d |jjd |Yd}~d}~wt$rM}|jjd|jz|jj|Yd}~d}~wwxYw)Nz*/api/feature_flag/local_evaluation/?token=z &send_cohorts )r(flagsrr3r4iz[FEATURE FLAGS] Error loading feature flags: To use feature flags, please set a valid personal_api_key. More information: https://posthog.com/docs/api/overviewzYou are using a write-only key with feature flags. To use feature flags, please set a personal_api_key More information: https://posthog.com/docs/api/overview)statusmessagez-[FEATURE FLAGS] Error loading feature flags: z`[FEATURE FLAGS] Fetching feature flags failed with following error. We will retry in %s seconds.r)rrEr r"r1r2r3r4rrrHerrorr-rCrr5rrr_last_feature_flag_poll)rSresponseflagrs rZ_load_feature_flagszClient._load_feature_flagssm" %%A B;B6&B6.$B;6B;; FA!D** F6AE>>Fcd|js#|jjdg|_y|j |j r|j j sKtt|j|j|_|j jyy)NzL[FEATURE FLAGS] You have to specify a personal_api_key to use feature flags.)seconds)intervalexecute) rErHrr1rr7is_aliverrr5rRrs rZload_feature_flagszClient.load_feature_flags7s$$ HH  k l!#D     "  4 4 6 )D zFailed to compute flag z locally: z7[FEATURE FLAGS] Error while computing variant locally: rrrsrtr<Fz&Successfully computed flag remotely: #z -> #z-[FEATURE FLAGS] Unable to get flag remotely: _$feature_flag_called $feature_flag$feature_flag_responselocally_evaluatedrrrr<)r,rrfrgr;&_add_local_person_and_group_propertiesr1rErrrHr-rrCrrvrrr:radd)rSrr]rrrsrtrrr<rrrflag_was_locally_evaluatedr1feature_flag_reported_keys rZrzClient.get_feature_flags sL) {H5&$' ==.2.Y.Y !24D/ ++    %$*?*?  # # %   ** !;#%!#'#=#= '#).?-= $>$)McURVW_V`'ab !$&.T%9")2G X $ 9 9!&7%5"/ !:! ),,S1#$H!GuERZQ[\](+e1S]O$<! %T-U-UVa-b b( LL&#S,h')Cu%x  +    4 4[ A E EF_ `U2!)@ZPQs'ST $!**-defdg+hi !$ X""%RSTRU#VWW Xs='7F)A H G>"!G  G>G99G> H2 H--H2) match_valuerrrsrtrrr<ct|jry||j|||||dd| }d} d} ||j||} | du} | sY|sW |j||||| } | dj |d} | dj t |j d} |dt | }||j|vrC|rA|j|dd |d | d | d | d || i|| |j|j|| S#t$r(}|jjd|Yd}~d}~wwxYw)NFT)rrrsrtrrr<rnrx:[FEATURE FLAGS] Unable to get feature flags and payloads: rrrrz$feature_flag_payloadrrr) r;r_compute_payload_locallyr|rrlowerrCrHrr:rr)rSrr]rrrrsrtrrr<rpayloadrresponses_and_payloadsrrs rZget_feature_flag_payloadzClient.get_feature_flag_payloads ==  //"3!1).'++0 K  "33CEG%,D%8")2G e)-)L)L):1(sw12 9DvAFE +%@N  #,mf#!%@#!%Rr#!%DL  #%0##L&(2PRkp$3L" ;rlrcXt||sdj|||}t|y)z8Require that the named `field` has the right `data_type`z{0} must have {1}, got: {2}N) isinstancerAssertionError)namefield data_typerjs rZr,r,s0 eY '+224EJS!! (rlcB|yt|tr|St|Sr)rrr)vals rZrrs" {#|$ s8Orl)3rMrFnumbersrArrrrdrr dateutil.tzrsixrposthog.consumerr posthog.exception_capturer posthog.exception_utilsr r r posthog.feature_flagsrrposthog.pollerrposthog.requestrrrrrr posthog.utilsrrrrposthog.versionrr* ImportErrorr+Numberrfr8objectrr,rrrlrZr+s  (%6ccW!bbWW# NNL$ /  ;V ;D"cs8B B+*B+