g\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|_ ||_!| tEjF}||_%||_&|r>tOjP|jRjUtNjVn)|jRjUtNjX|j<rt[||j>|_ | rd|_.y|rt_j`|jbte| D]j}g|_.tg|j|j|j|||| | | | }|j\ji||s[|jkly#tH$rd}YQwxYw)Napi_key) integrations)hoston_errorflush_atflush_intervalgzipretriestimeouthistorical_migration)6queueQueuer 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_capture privacy_modeosgetcwd Exception project_rootpersonal_api_keylogging basicConfiglogsetLevelDEBUGWARNINGr consumersatexitregisterjoinranger appendstart)selfr r"r-max_queue_sizer.r#r$r%r& max_retriesr/r(threadr5rFproject_api_keyr;r<r)r6r=r>r?rErAnconsumers C/var/www/openai/venv/lib/python3.12/site-packages/posthog/client.py__init__zClient.__init__$s8[[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&& I54I5c|xsi}|xsi}td|ttd|t||||d|d}|j||S)N distinct_id propertiesz $identify timestampcontextr^$seteventuuidr,ID_TYPESdict_enqueuerTr^r_rbrarer<msgs r[identifyzClient.identifys[%2 -R {H5 j$/#&   }}S-00c6|j|||||}|dS)N featureFlags get_deciderTr^groupsperson_propertiesgroup_propertiesr< resp_datas r[get_feature_variantszClient.get_feature_variantss(OOK9JL\^kl ((rmc6|j|||||}|dS)NfeatureFlagPayloadsrprrs r[get_feature_payloadszClient.get_feature_payloadss)OOK9JL\^kl .//rmcB|j|||||}|d|ddS)Nroryroryrprrs r[get_feature_flags_and_payloadsz%Client.get_feature_flags_and_payloadss8OOK9JL\^kl %n5#,-B#C  rmctd|t| |j}|rtd|tni}|||||d}t |j |j fd|ji|}|S)Nr^rs)r^rsrtrur<r()r,rgr<rhrr r"r6)rTr^rsrtrur< request_datarvs r[rqzClient.get_decidesx {H5   ..M  Hfd +F'!2 0*  4<<wD"!$"&  }}S-00rmc  |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)rErtyperz /project/z/person/)z$exception_typez$exception_messagez$exception_listz$exception_personURLz $exceptionzFailed to capture exception: )rr,rgrhr sysexc_inforIwarningr r rErrr0r rrDr) rTrr^r_rbrarersrall_exceptions_with_tracerd$all_exceptions_with_trace_and_in_apprs r[capture_exceptionzClient.capture_exception{s- 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;raNtzrbrer_zposthog-pythonz$libz $lib_versionTz$geoip_disabler^z queueing: %szenqueued with blocking %s.rd)r&r(batchr)F)blockz enqueued %s.zanalytics-python queue is full)r;rnowrr,rhr isoformatpop stringify_idrrr<r=rrIr-r.r/rr r"r&r(r)r*putFullr)rTrkr<rares r[rizClient._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*qsizerPrIr-)rTr*sizes r[flushz Client.flushs6 u{{}  =tDrmc|jD]#}|j |j%|jr|jj yy#t$rYYwxYw)zbEnds the consumer thread once the queue is empty. Blocks execution until finished N)rMpauserP RuntimeErrorr7stop)rTrZs r[rPz Client.joins\H NN   ' ;; KK        sA A'&A'c|j|j|jr|jjyy)z2Flush all messages and cleanly shutdown the clientN)rrPr@closerTs r[shutdownzClient.shutdowns4   ! !  " " ( ( * "rmc  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)rrFr r"r1r2r3r4rrrIerrorr-rDrr5rrr_last_feature_flag_poll)rTresponseflagrs r[_load_feature_flagszClient._load_feature_flagssr" %%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) rFrIrr1rr7is_aliverrr5rSrs r[load_feature_flagszClient.load_feature_flags?s$$ HH  k l!#D     "  4 4 6 )D zFailed to compute flag z locally: z7[FEATURE FLAGS] Error while computing variant locally: rsrtrur<Fz&Successfully computed flag remotely: #z -> #z-[FEATURE FLAGS] Unable to get flag remotely: _$feature_flag_called $feature_flag$feature_flag_responselocally_evaluatedrrsr<)r,rrgrhr;&_add_local_person_and_group_propertiesr1rFrrrIr-rrDrrwrrr:radd)rTrr^rsrtrurrr<rrrflag_was_locally_evaluatedr1feature_flag_reported_keys r[rzClient.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_valuersrtrurrr<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)rsrtrurrr<rory:[FEATURE FLAGS] Unable to get feature flags and payloads: rrrrz$feature_flag_payloadrrr) r;r_compute_payload_locallyr}rrlowerrDrIrr:rr)rTrr^rrsrtrurrr<rpayloadrresponses_and_payloadsrrs r[get_feature_flag_payloadzClient.get_feature_flag_payloads ==  //"3!1).'++0 K  "33CEG%,D%8")2G e)-)L)L):r,s  (%6ccW!bbWW# NNL$ / G;VG;T"ss8B B+*B+