o Dg@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+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3ddl4m5Z5m6Z6m7Z7m8Z8ddl9m:Z:zddl;Z;Wn eeefZ?dZ@ddZAdeBeCe ffddZDGdddeEZFddZGddZHdS)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_postdecidedetermine_server_hostget remote_config) DecideResponse FeatureFlag FlagMetadataFlagsAndPayloads FlagValuenormalize_decide_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-distroinfor3)os_name os_version platform_name win_version mac_version linux_infor@h/var/www/eduai.edurigo.com/doc_train/edurigo_ai/Puru/venv/lib/python3.10/site-packages/posthog/client.py get_os_info.s@         rBreturncCs*t\}}tdtjdd||dS)Nz%s.%s.%s)z$python_runtimez$python_versionz$osz $os_version)rBr5python_implementationr4 version_info)r:r;r@r@rAsystem_contextYs rGc@sneZdZdZedZ                     dcd dZeddZ e j ddZ ddddZ dede e eee fffddZ dede e e ffddZ dedefddZ dedefddZ         dfddZdddd Zddd!d"Z        dgd#d$Zddd%d&Z dhd'd(Z       dhd)d*Zd+d,Zd-d.Zd/d0Zd1d2Z d3d4Z!d5d6Z"iiidd7de#fd8d9Z$iiidddd:d;d<Z%iiidddd:de&e#fd=d>Z'd?e d@e dAe e e fdBe e e fdCe e e fde&e#f dDdEZ(diiiddddFdGdHZ)d?e d@e dAe e e fdBe e e fdCe e e fdIe&ede*e&e+e&e ffdJdKZ,d@e d?e dLe#dMe&e dNedAe e e fdIe&edOe&e dPe&e+fdQdRZ-d?e fdSdTZ.d?e dUe#de&e fdVdWZ/iiidddXde&e e eee fffdYdZZ0iiidddXdefd[d\Z1iiidd7de*eeffd]d^Z2d_d`Z3dadbZ4dS)iClientzCreate a new PostHog client.posthogNF'Td?rDc 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-|jrt.||j d|_!| rd|_/dS|rt01|j2t3| D]"}g|_/t4|j|j|j |||| | | |d }|j/5||r|6qdS)Napi_key) integrations)hoston_errorflush_atflush_intervalgzipretriestimeouthistorical_migration)7queueQueuerPrequirer rSdebugsend sync_moderraw_hostrrRrVrX_feature_flagsfeature_flags_by_keygroup_type_mappingcohorts poll_interval%feature_flags_request_timeout_secondspollerr# MAX_DICT_SIZEset#distinct_ids_feature_flags_reporteddisabled disable_geoiprYsuper_propertiesenable_exception_autocapturelog_captured_exceptions"exception_autocapture_integrationsexception_capture privacy_modeosgetcwd Exception project_rootpersonal_api_keylogging basicConfiglogsetLevelDEBUGWARNINGr consumersatexitregisterjoinranger appendstart)selfrPrRr]max_queue_sizer^rSrTrUrV max_retriesr_rXthreadrerwproject_api_keyrkrlrYrfrmrnrorprvrrnconsumerr@r@rA__init__is           zClient.__init__cC|jS)z9 Get the local evaluation feature flags. )rarr@r@rA feature_flagsszClient.feature_flagscCs2|pg|_dd|jD|_|jdusJddS)z9 Set the local evaluation feature flags. cSs$i|]}|ddur|d|qS)keyNr).0flagr@r@rA s$z(Client.feature_flags..NDfeature_flags_by_key should be initialized when feature_flags is set)rarb)rflagsr@r@rArs  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_enqueuerrrcontextrrrlmsgr@r@rAidentify    zClient.identifyrCcC||||||}t|piS)zP Get feature flag variants for a distinct_id by calling decide. ) get_decider"rrgroupsperson_propertiesgroup_propertiesrl resp_datar@r@rAget_feature_variants zClient.get_feature_variantscCr)zP Get feature flag payloads for a distinct_id by calling decide. )rr!rr@r@rAget_feature_payloads rzClient.get_feature_payloadscCs||||||}t|S)zU Get feature flags and payloads for a distinct_id by calling decide. )rr )rrrrrrlrespr@r@rAget_feature_flags_and_payloadssz%Client.get_feature_flags_and_payloadscCsdtd|t|dur |j}|rtd|tni}|||||d}t|j|jfd|ji|}t|S)Nrr)rrrrrlrX) r\rrlrrrPrRrfr)rrrrrrl request_datarr@r@rArs zClient.get_decidec  Cs`|dur tjdtddi|pit}td|ttd|ttd|t|||||d} |r=td|t|| dd <i} i} |riz |j||| d } Wn-t yh} z|j d | WYd} ~ nd} ~ ww|j r{|d kr{|j ||pvi| d d} | p~iD] \}}|| d|<qdd| piD}|r|| d<| ri| | d| d<|| | S)Nrrrrrr)rrrrrrz$groups)rlz0[FEATURE FLAGS] Unable to get feature variants: $feature_flag_calledT)rrlonly_evaluate_locally $feature/cSsg|] \}}|dur|qS)Fr@)rrvaluer@r@rA msz"Client.capture..z$active_feature_flags)rrrrGr\rrr rrurz exceptionr get_all_flagsitemsr)rrrrrrrrsend_feature_flagsrlrextra_propertiesfeature_variantsefeaturevariantactive_feature_flagsr@r@rAcapture7sP        zClient.capturecCr)Nrrrrrrrrrr@r@rArivrz Client.setcCr)Nrrrrr $set_once)rrrrrrrr@r@rAset_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) rrrrrrrrlrrr@r@rAgroup_identifys.      zClient.group_identifycCsP|dur tjdtddtd|ttd|t||d|d|d}|||S) Nrrr previous_idr)raliasz $create_alias)rrrr)rrrr\rr)rrrrrrrlrr@r@rArs    z Client.aliasc Csh|dur tjdtdd|pi}td|ttd|ttd|t||d<d||||d }|||S) Nrrrrrurlz $current_urlz $pageview)rrrrr)rrrr\rrr r) rrrrrrrrlrr@r@rApages$    z Client.pagec KsZ|dur tjdtddz|pi}|durd|d<t}td|ttd|t|dur1t|} nt } | dus=| dkrF|j d WdSt | } t d d | ii|jd } | d d } | d d| d d| t|jd|jd|d|}|jr|j j||d||d|||||WSty} z|j d| WYd} ~ dSd} ~ ww)NrrrFz$process_person_profilerr)NNNz"No exception information availablervalues)rvrtyperz /project/z/person/)z$exception_typez$exception_messagez$exception_listz$exception_personURL)extraz $exceptionzFailed to capture exception: )rrrrr\rrr r4exc_inforzwarningrrrvrr&r`rProrrru)rrrrrrrrkwargsrall_exceptions_with_tracer$all_exceptions_with_trace_and_in_apprr@r@rAcapture_exceptionsT         zClient.capture_exceptioncCs|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 |}|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)`)FrkrNtzrrzposthog-pythonz$libz $lib_versionTz$geoip_disablerz queueing: %szenqueued with blocking %s.r)rVrXbatchrYF)blockz enqueued %s.zanalytics-python queue is full)rkrnowr r\r% isoformatpop stringify_idrr'rlrmr$rzr]r^r_rrPrRrVrXrYrZputFullr)rrrlrrr@r@rArCs\            zClient._enqueuecCs(|j}|}||jd|dS)z4Forces a flush from the internal queue to the serverz$successfully flushed about %s items.N)rZqsizerrzr])rrZsizer@r@rAflushsz Client.flushc CsJ|jD]}|z|WqtyYqw|jr#|jdSdS)zbEnds the consumer thread once the queue is empty. Blocks execution until finished N)r~pauser RuntimeErrorrgstop)rrr@r@rArs   z Client.joincCs(|||jr|jdSdS)z2Flush all messages and cleanly shutdown the clientN)rrrqcloserr@r@rAshutdowns 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 rXrrcrdiz[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)rrwrPrRrrcrdrrrzerrorr]rrurerrr _last_feature_flag_poll)rresponserr@r@rA_load_feature_flagss\   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) rwrzrrrrgis_aliverrrerrr@r@rAload_feature_flagss 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) rrrcstrrzrr]rrd) r feature_flagrrrrr flag_filtersr group_namefocused_group_propertiesr@r@rA_compute_flag_locallys4   zClient._compute_flag_locallyrrrrsend_feature_flag_eventsrlc Cs.|j||||||||d} | durdSt| S)Nr )get_feature_flagbool) rrrrrrrr rlrr@r@rAfeature_enableds  zClient.feature_enabledc Cstd|ttd|ttd|t|jrdS|||||\}}||||||} d} d} | du} | st|stz"|||||||\} } | rI| nd} |j d|d| Wnt ys} z|j d| WYd} ~ nd} ~ ww|r| ||| p}dd| ||| | | S) 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. rrrNFz&Successfully computed flag remotely: #z -> #z-[FEATURE FLAGS] Unable to get flag remotely: )r\r rrrk&_add_local_person_and_group_properties_locally_evaluate_flag%_get_feature_flag_details_from_decide get_valuerzr]rur_capture_feature_flag_called)rrrrrrrr rlr flag_details request_idflag_was_locally_evaluatedrr@r@rAr *sH     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: ) rrwrrbrr rzr]rrur) rrrrrrrrrr@r@rArgs:  "zClient._locally_evaluate_flag) match_valuerrrrr rlc Cs|jrdS|dur|||||\}}||||||}d} d} d} d} |dur.|||} | du}|sp|spz||||||| \} } | rI| jjnd} | rQ| nd} Wntyo}z|j d|WYd}~nd}~ww|r| ||| pyd| ||| | | | S)NF:[FEATURE FLAGS] Unable to get feature flags and payloads: ) rkrr_compute_payload_locallyrmetadatapayloadrrurzrr)rrrrrrrrr rlrrrrrrr@r@rAget_feature_flag_payloadsL    zClient.get_feature_flag_payloadrlc Cs@||||||}|d}|d} | r| |nd} | |fS)zK Calls /decide and returns the flag details and request id requestIdrN)rr) rrrrrrrlrrrrr@r@rArs   z,Client._get_feature_flag_details_from_deciderrrrrc Cs|dt|} | |j|vrid|d|d|d||i} |r#|| d<|r)|| d<t| trU| jr;| jjr;| jj| d<t| jtrU| jjrK| jj| d <| jj rU| jj | d <|j |d | ||d |j| | dSdS) N_z $feature_flagz$feature_flag_responselocally_evaluatedrz$feature_flag_payloadz$feature_flag_request_idz$feature_flag_reasonz$feature_flag_versionz$feature_flag_idr)rrl) rrj isinstancerreason descriptionrrr0idradd) rrrrrrrrlrrfeature_flag_reported_keyrr@r@rArs8       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: ) rkrwrzrrrRrfrur)rrrr@r@rAget_remote_config_payloads$  z Client.get_remote_config_payloadrcCshd}|jdur |S|j|}|r2|dpi}|dpi}t|tr(|r(dnt|}||d}|S)Nrpayloadstrue)rbrr"rr)rrrrflag_definitionr flag_payloads lookup_valuer@r@rArs   zClient._compute_payload_locallyrrrrrlcCs|j||||||d}|dS)Nr. featureFlags)get_all_flags_and_payloads)rrrrrrrlrr@r@rAr$s  zClient.get_all_flagsc Cs|jrdddS|||||\}}|j||||d\}}|rM|sMz|j|||||d} t| WStyL} z|jd| WYd} ~ |Sd} ~ ww|S)Nr/featureFlagPayloadsr)rrrrlr)rkr#_get_all_flags_and_payloads_locallyrr rurzr) rrrrrrrlrfallback_to_decidedecide_responserr@r@rAr09s0   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) NrrFrrTz;[FEATURE FLAGS] Error while computing variant and payload: r1) r\rrrrwrr rrrurzr) rrrrrrrr)r4rmatched_payloadrr@r@rAr3]s@     z*Client._get_all_flags_and_payloads_locallycCrN)rrr@r@rAfeature_flag_definitionsszClient.feature_flag_definitionscCsHd|i|pi}i}|r |D]}d||i||pi||<q||fS)Nrrr)rrrrrall_person_propertiesall_group_propertiesrr@r@rArs  z-Client._add_local_person_and_group_properties)NNFrJTNrKrLFrDFrMrNrONNFTFrDNFFNNF)NNNNNN)NNNN) NNNNNNNFN)NNNNNNNN)NNNNNNN)5__name__ __module__ __qualname____doc__rx getLoggerrzrpropertyrsetterrrrrrrrrrrrrrirrrrrrrrrrrrr rrr rrtuplerrrr(rrr0r3r8rr@r@r@rArHds~  s            ?  )  FB2 3   =    ' 8       -  %  & rHcCs$t||sd|||}t|dS)z8Require that the named `field` has the right `data_type`z{0} must have {1}, got: {2}N)r"rAssertionError)namefield data_typerr@r@rAr\s r\cCs"|durdSt|tr |St|Sr7)r"r r)valr@r@rArs  r)Irrxnumbersrsr5r4rrrtypingrrrrrrr8 dateutil.tzr sixr posthog.consumerr posthog.exception_capturer posthog.exception_utilsr rrposthog.feature_flagsrrposthog.pollerrposthog.requestrrrrrrr posthog.typesrrrrrrr r!r" posthog.utilsr#r$r%r&posthog.versionr'rZ ImportErrorr[NumberrrhrBrrrGobjectrHr\rr@r@r@rAsT     $,     + 8