o Rh:@sddlZddlZddlZddlZddlZddlZddlZddlmZmZddl m Z m Z m Z ddl mZmZddlZddlmZddlmZddlmZddlmZdd lmZmZmZdd lmZmZdd l m!Z!dd l"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)dd l*m+Z+ddl,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6ddl7m8Z8m9Z9m:Z:m;Z;ddlZ>Wn e?yddl@Z>YnwejAeefZBdZCddZDdeEeFe ffddZGGdddeHZIddZJddZKdS)N)datetime timedelta)AnyOptionalUnion)UUIDuuid4)tzutc) string_types)Consumer)ExceptionCapture)exc_info_from_errorexceptions_from_error_tuple handle_in_app)InconclusiveMatchErrormatch_feature_flag_properties)Poller) DEFAULT_HOSTAPIError batch_postdetermine_server_hostflagsget remote_config)get_tags) FeatureFlagFeatureFlagResult FlagMetadataFlagsAndPayloads FlagsResponse FlagValuenormalize_flags_responseto_flags_and_payloads to_payloads to_values)SizeLimitedDictcleanguess_timezoneremove_trailing_slash)VERSIONiPcCsd}d}tj}|dr!d}ttdrtd}|r|}||fS|dkr:d}ttdr6td}|r6|}||fS|d rQd }t}|d rM|d }||fS|d red }ttdrat}||fS|}ttdrpt}||fS)zr Returns standardized OS name and version information. Similar to how user agent parsing works in JS. winWindows win32_verrdarwinzMac OS Xmac_verlinuxLinuxversionfreebsdFreeBSDrelease) sysplatform startswithhasattrr-r/distroinfor5)os_name os_version platform_name win_version mac_version linux_inforBP/home/air/sanwanet/backup_V2/venv/lib/python3.10/site-packages/posthog/client.py get_os_info<s@         rDreturncCs*t\}}tdtjdd||dS)Nz%s.%s.%s)z$python_runtimez$python_versionz$osz $os_version)rDr7python_implementationr6 version_info)r<r=rBrBrCsystem_contextgs rIc@s eZdZdZedZ                      did dZeddZ e j ddZ      djddZ    dkde e eee fffddZ    dkde e e ffddZ    dkdefddZ    dkdefddZ         dlddZ      djdd Z      djd!d"Z        dmd#d$Z      djd%d&Z       dnd'd(Z       dnd)d*Zd+d,Zd-d.Zd/d0Zd1d2Z d3d4Z!d5d6Z"iiidd7de#fd8d9Z$iiidddd:d;d<Z%diiidddd=d>e&e#de&e'fd?d@Z(iiidddd:de&e'fdAdBZ)iiidddd:de&e#fdCdDZ*dEe dFe dGe e e fdHe e e fdIe e e fde&e#f dJdKZ+diiiddddLdMe&e#fdNdOZ,dEe dFe dGe e e fdHe e e fdIe e e fdPe&ede-e&e.e&e ffdQdRZ/dFe dEe dSe&e#dTe&e dUedGe e e fdPe&edVe&e dWe&e.fdXdYZ0dEe fdZd[Z1dEe dMe#de&e fd\d]Z2iiiddd^de&e e eee fffd_d`Z3iiiddd^defdadbZ4iiidd7de-eeffdcddZ5dedfZ6dgdhZ7dS)oClientzCreate a new PostHog client.posthogNF'Td?rFc Cst||_|p ||_td|jt||_||_||_| |_|p!t |_ t ||_ | |_ | |_d|_d|_d|_d|_||_||_d|_ttt|_||_||_||_||_||_||_||_ d|_!||_"|durzzt#$}Wn t%yyd}Ynw||_&||_'|rt()|j*+t(j,n|j*+t(j-|durt.|r||_/n |j*0dd|_/nd|_/|jrt1||j d|_!| rd|_2dS|rt34|j5t6| D]"}g|_2t7|j|j|j |||| | | |d }|j28||r|9qdS)Napi_keyz/before_send is not callable, it will be ignored) integrations)hoston_errorflush_atflush_intervalgzipretriestimeouthistorical_migration):queueQueuerRrequirer rUdebugsend sync_moderraw_hostrrTrXrZ_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_autocapturelog_captured_exceptions"exception_autocapture_integrationsexception_capture privacy_modeosgetcwd Exception project_rootpersonal_api_keylogging basicConfiglogsetLevelDEBUGWARNINGcallable before_sendwarningr consumersatexitregisterjoinranger appendstart)selfrRrTr_max_queue_sizer`rUrVrWrX max_retriesrarZthreadrgryproject_api_keyrmrnr[rhrorprqrrrxrtrnconsumerrBrBrC__init__ws            zClient.__init__cC|jS)z9 Get the local evaluation feature flags. )rcrrBrBrC feature_flagsszClient.feature_flagscCs2|pg|_dd|jD|_|jdusJddS)z9 Set the local evaluation feature flags. cSs$i|]}|ddur|d|qS)keyNr).0flagrBrBrC s z(Client.feature_flags..NDfeature_flags_by_key should be initialized when feature_flags is set)rcrd)rrrBrBrCrs  cCT|dur tjdtdd|pi}td|ttd|t|||d|d}|||S)NNThe 'context' parameter is deprecated and will be removed in a future version. stacklevel distinct_id propertiesz $identify timestampr$seteventuuidwarningswarnDeprecationWarningr^ID_TYPESdict_enqueuerrrcontextrrrnmsgrBrBrCidentify     zClient.identifyrEcC||||||}t|piS)zP Get feature flag variants for a distinct_id by calling decide. )get_flags_decisionr$rrgroupsperson_propertiesgroup_propertiesrn resp_datarBrBrCget_feature_variants,  zClient.get_feature_variantscCr)zP Get feature flag payloads for a distinct_id by calling decide. )rr#rrBrBrCget_feature_payloads<rzClient.get_feature_payloadscCs||||||}t|S)zU Get feature flags and payloads for a distinct_id by calling decide. )rr")rrrrrrnresprBrBrCget_feature_flags_and_payloadsLs z%Client.get_feature_flags_and_payloadscCsdtd|t|dur |j}|rtd|tni}|||||d}t|j|jfd|ji|}t|S)zd Get feature flags decision, using either flags() or decide() API based on rollout. rNr)rrrr geoip_disablerZ) r^rrnrrrRrTrhr!)rrrrrrn request_datarrBrBrCr\s* zClient.get_flags_decisionc  Cst|dur tjdtddi|pit}td|ttd|ttd|tt} | r1| | |||||d} |rGtd|t|| dd <i} i} |rsz |j ||| d } Wn-t yr}z|j d |WYd}~nd}~ww|jr|d kr|j||pi| d d} | piD] \}}|| d|<qdd| piD}|r|| d<| ri| | d| d<|| | S)Nrrrrrr)rrrrrrz$groups)rnz0[FEATURE FLAGS] Unable to get feature variants: $feature_flag_calledT)rrnonly_evaluate_locally $feature/cSsg|] \}}|dur|qS)FrB)rrvaluerBrBrC s z"Client.capture..z$active_feature_flags)rrrrIr^rrr rupdaterrwr| exceptionr get_all_flagsitemsr)rrrrrrrrsend_feature_flagsrn context_tagsrextra_propertiesfeature_variantsefeaturevariantactive_feature_flagsrBrBrCcapturesh          zClient.capturecCr)NrrrrrrrrrrBrBrCrkrz Client.setcCr)Nrrrrr $set_once)rrrrrrrrBrBrCset_oncerzClient.set_oncec Cs|dur tjdtdd|pi}td|ttd|ttd|t|r+td|tnd||}d |||d |||d } || |S) Nrrr group_type group_keyrrz${}_{}z$groupidentify)z $group_type $group_keyz $group_set)rrrrr)rrrr^rrformatr) rrrrrrrrnrrrBrBrCgroup_identify s.      zClient.group_identifycCsP|dur tjdtddtd|ttd|t||d|d|d}|||S) Nrrr previous_idr)raliasz $create_alias)rrrr)rrrr^rr)rrrrrrrnrrBrBrCr6s     z Client.aliasc Csh|dur tjdtdd|pi}td|ttd|ttd|t||d<d||||d }|||S) Nrrrrrurlz $current_urlz $pageview)rrrrr)rrrr^rrr r) rrrrrrrrnrrBrBrCpageUs$     z Client.pagec Ks|dur tjdtddz|pi}|dur#t|dr#|jdWdS|dur.d|d<t}td|ttd |t |durCt |} nt } | dusO| d krX|j d WdSt| } td d | ii|jd} | d d } | dd| dd| t|jd|jd|d|}|jr|jj||d||d|||||} |durt|trt|dd| WSty}z|jd|WYd}~dSd}~ww)Nrrr__posthog_exception_capturedz$Exception already captured, skippingFz$process_person_profilerr)NNNz"No exception information availablervalues)rxrtyperz /project/z/person/)z$exception_typez$exception_messagez$exception_listz$exception_personURL)extraz $exceptionTzFailed to capture exception: )rrrr9r|r_rr^rrr r6exc_inforrrrxrr(rbrRrqrr isinstance BaseExceptionsetattrrw)rrrrrrrrkwargsrall_exceptions_with_tracer$all_exceptions_with_trace_and_in_appresrrBrBrCcapture_exceptionwsl            zClient.capture_exceptionc Cs|jrdS|d}|durtjtd}td|tt|}||d<d|vr5|d}|r5t||d<| ds>i|d<d|dd<t |dd <|durQ|j }|rYd |dd <|j rgi|d|j |d<t| d d|d <t |}|jrz||}|dur|jd WdS|}Wnty}z|jd|WYd}~nd}~ww|jd||jsd |fS|jr|jd|dt|j|j|j|j|g|jdd |fSz|jj|dd|jd|dd |fWStjy|jdd|fYSw)z8Push a new `msg` onto the queue, return `(success, msg)`)FrmrNtzrrzposthog-pythonz$libz $lib_versionTz$geoip_disablerz%Event dropped by before_send callback)TNzError in before_send callback: z queueing: %szenqueued with blocking %s.r)rXrZbatchr[F)blockz enqueued %s.zanalytics-python queue is full)rmrnowr r^r' isoformatpop stringify_idrr)rnror&rr|r_rwrr`rarrRrTrXrZr[r\putFullr)rrrnrr modified_msgrrBrBrCrsr              zClient._enqueuecCs(|j}|}||jd|dS)z4Forces a flush from the internal queue to the serverz$successfully flushed about %s items.N)r\qsizerr|r_)rr\sizerBrBrCflushsz Client.flushc CsJ|jD]}|z|WqtyYqw|jr#|jdSdS)zbEnds the consumer thread once the queue is empty. Blocks execution until finished N)rpauser RuntimeErrorristop)rrrBrBrCr$s   z Client.joincCs(|||jr|jdSdS)z2Flush all messages and cleanly shutdown the clientN)rrrscloserrBrBrCshutdown3s zClient.shutdownc Cs>z&t|jd|jd|jdd}|dpg|_|dpi|_|dp#i|_Wnntyt}zB|jdkrC|j d |j rBtdd d n'|jd kra|j d g|_i|_i|_|j r`td dd n |j d|WYd}~n%d}~wt y}z|j d|j|j |WYd}~nd}~wwtjtd|_dS)Nz*/api/feature_flag/local_evaluation/?token=z &send_cohorts rZrrerfiz[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)statusmessageiz[FEATURE FLAGS] PostHog feature flags quota limited, resetting feature flag data. Learn more about billing limits at https://posthog.com/docs/billing/limits-alertsz#PostHog feature flags quota limitedz-[FEATURE FLAGS] Error loading feature flags: z`[FEATURE FLAGS] Fetching feature flags failed with following error. We will retry in %s seconds.r)rryrRrTrrerfrrr|errorr_rrwrgrrr _last_feature_flag_poll)rresponserrBrBrC_load_feature_flags;s\   zClient._load_feature_flagscCs^|js|jdg|_dS||jr|js-tt|j d|jd|_|j dSdS)NzL[FEATURE FLAGS] You have to specify a personal_api_key to use feature flags.)seconds)intervalexecute) ryr|rrrriis_aliverrrgrrrBrBrCload_feature_flagsms zClient.load_feature_flagsrrrwarn_on_unknown_groupsc Cs|ddr td|dsdS|dpi}|d}|durk|jt|} | s=|jd|d|d td | |vr_|rQ|jd |d d dS|jd |d d dS|| } t||| | St||||jS) Nensure_experience_continuityFz&Flag has experience continuity enabledactivefiltersaggregation_group_type_indexz)[FEATURE FLAGS] Unknown group type index z for feature flag rz!Flag has unknown group type indexz2[FEATURE FLAGS] Can't compute group feature flag: z without group names passed in) rrrestrr|rr_rrf) r feature_flagrrrrr  flag_filtersr group_namefocused_group_propertiesrBrBrC_compute_flag_locally}s<     zClient._compute_flag_locallyrrrrsend_feature_flag_eventsrnc Cs.|j||||||||d} | durdSt| S)Nr)get_feature_flagbool) rrrrrrrrrnrrBrBrCfeature_enableds  zClient.feature_enabledoverride_match_valuerrrrrrnrc CsLtd|ttd|ttd|t|jrdS|||||\}}d} d} d} ||||||} | du}|rL|p9| }|rB|||nd}t |||} n>|sz | |||||| \} } t | |} |j d|d| Wnty}z|j d|WYd}~nd}~ww|r|||| r| nd| r| jnd||| | | | S)Nrrrz&Successfully computed flag remotely: #z -> #z-[FEATURE FLAGS] Unable to get flag remotely: )r^r rrrm&_add_local_person_and_group_properties_locally_evaluate_flag_compute_payload_locallyrfrom_value_and_payload%_get_feature_flag_details_from_decidefrom_flag_detailsr|r_rwr_capture_feature_flag_called get_valuepayload)rrrrrrrrrrn flag_result flag_details request_id flag_valueflag_was_locally_evaluatedlookup_match_valuer&rrBrBrC_get_feature_flag_resultst     zClient._get_feature_flag_resultc Cs|j||||||||dS)aL Get a FeatureFlagResult object which contains the flag result and payload for a key by evaluating locally or remotely depending on whether local evaluation is enabled and the flag can be locally evaluated. This also captures the $feature_flag_called event unless send_feature_flag_events is False. r)r-) rrrrrrrrrnrBrBrCget_feature_flag_resultszClient.get_feature_flag_resultc Cs*|j||||||||d} | r| SdS)a# Get a feature flag value for a key by evaluating locally or remotely depending on whether local evaluation is enabled and the flag can be locally evaluated. This also captures the $feature_flag_called event unless send_feature_flag_events is False. rN)r.r%) rrrrrrrrrnfeature_flag_resultrBrBrCr6s zClient.get_feature_flagrrrrrc Cs|jdur |jr |d}|jrv|jdusJd|j|}|rvz|j|||||d}|jd|d|W|StyZ}z|jd|d|WYd}~|Sd}~wt yu}z|j d|WYd}~|Sd}~ww|S)Nrrrrz$Successfully computed flag locally: z -> zFailed to compute flag z locally: z7[FEATURE FLAGS] Error while computing variant locally: ) rryr rdrrr|r_rrwr) rrrrrrrrrrBrBrCrUsB   "zClient._locally_evaluate_flag) match_valuerrrrrrnr1c Cs*|j||||||||| d } | r| jSdS)Nr)r-r&) rrrr1rrrrrrnr/rBrBrCget_feature_flag_payload{s  zClient.get_feature_flag_payloadrnc Cs@||||||}|d}|d} | r| |nd} | |fS)zK Calls /decide and returns the flag details and request id requestIdrN)rr) rrrrrrrnrr)rr(rBrBrCr"s   z,Client._get_feature_flag_details_from_deciderr&r+r)r(c Cs|d|dur dnt|} | |j|vrod|d|d|d||i} |r)|| d<|r/|| d<t| tr[| jrA| jjrA| jj| d <t| jtr[| jjrQ| jj| d <| jj r[| jj | d <|j |d | ||d |j| | dSdS)N_z::null::z $feature_flagz$feature_flag_responselocally_evaluatedrz$feature_flag_payloadz$feature_flag_request_idz$feature_flag_reasonz$feature_flag_versionz$feature_flag_idr)rrn) rrlrrreason descriptionmetadatarr2idradd) rrrrr&r+rrnr)r(feature_flag_reported_keyrrBrBrCr$sD       z#Client._capture_feature_flag_calledc Csv|jrdS|jdur|jddSz t|j|j||jdWSty:}z|jd|WYd}~dSd}~ww)Nz`[FEATURE FLAGS] You have to specify a personal_api_key to fetch decrypted feature flag payloads.rz>[FEATURE FLAGS] Unable to get decrypted feature flag payload: ) rmryr|rrrTrhrwr)rrrrBrBrCget_remote_config_payloads( z Client.get_remote_config_payloadcCshd}|jdur |S|j|}|r2|dpi}|dpi}t|tr(|r(dnt|}||d}|S)Nrpayloadstrue)rdrrrr)rrr1r&flag_definitionr flag_payloads lookup_valuerBrBrCr s   zClient._compute_payload_locallyrrrrrncCs|j||||||d}|dS)NrB featureFlags)get_all_flags_and_payloads)rrrrrrrnrrBrBrCr s  zClient.get_all_flagsc Cs|jrdddS|||||\}}|j||||d\}}|rM|sMz|j|||||d} t| WStyL} z|jd| WYd} ~ |Sd} ~ ww|S)NrCfeatureFlagPayloadsr0)rrrrnz:[FEATURE FLAGS] Unable to get feature flags and payloads: )rmr#_get_all_flags_and_payloads_locallyrr"rwr|r) rrrrrrrnrfallback_to_decidedecide_responserrBrBrCrD!s<   z!Client.get_all_flags_and_payloadsc Cstd|ttd|t|jdur|jr|i}i}d}|jrt|jD]N} z%|j| |||||d|| d<|| d|| d} | rJ| || d<Wq$tyVd}Yq$t yr} z|j d| d}WYd} ~ q$d} ~ wwnd}||d|fS) NrrFr rTz;[FEATURE FLAGS] Error while computing variant and payload: rE) r^rrrryr rr rrwr|r) rrrrrr rr=rHrmatched_payloadrrBrBrCrGLsP    z*Client._get_all_flags_and_payloads_locallycCrN)rrrBrBrCfeature_flag_definitionsszClient.feature_flag_definitionscCsHd|i|pi}i}|r |D]}d||i||pi||<q||fS)Nrrr)rrrrrall_person_propertiesall_group_propertiesrrBrBrCrs  z-Client._add_local_person_and_group_properties)NNFrLTNrMrNFrFFrOrPrQNNFTFrFNFFNNFN)NNNNNN)NNNN) NNNNNNNFN)NNNNNNNN)NNNNNNN)8__name__ __module__ __qualname____doc__rz getLoggerr|rpropertyrsetterrrrrrrrrrrrrrkrrrrrrrrrrr r rrrrr-r.rrr2tuplerr"r$r<r rrDrGrLrrBrBrBrCrJrs     !     ( Q     + ! $ WN2 7   T "     +        7   /  3 rJcCs$t||sd|||}t|dS)z8Require that the named `field` has the right `data_type`z{0} must have {1}, got: {2}N)rrAssertionError)namefield data_typerrBrBrCr^s r^cCs"|durdSt|tr |St|SrK)rr r)valrBrBrCrs  r)Lrrznumbersrur7r6rrrtypingrrrrrrr: dateutil.tzr sixr posthog.consumerr posthog.exception_capturer posthog.exception_utilsr rrposthog.feature_flagsrrposthog.pollerrposthog.requestrrrrrrrposthog.scopesr posthog.typesrrrrrr r!r"r#r$ posthog.utilsr%r&r'r(posthog.versionr)r\ ImportErrorr]NumberrrjrDrrrIobjectrJr^rrBrBrBrCsZ     $ 0     + -