jKj"9UddlZddlZddlZddlZddlZddlZddlmZddlm Z mZm Z ddl m Z ddl mZddlmZmZmZmZmZmZddlZddlmZddlmZdd lmZdd lmZdd lm Z dd l!m"Z"eee#e#ee#e$ffZ%d Z&d Z'dZ(e)ejTejVejXdfgzZ-e%e.d<de&fde'fde(ffD]4\Z/Z0e1ee/se-jeejfe4ee/e0f6dZ5ddhZ6de7de7fdZ8eGddZ9GddeZ:dPdee%dejvfdZ< dPdee%dejvfd Z=e<a>e=a?da@ee%e.d!<d"aAdejvfd#ZBdejvfd$ZCdQd%ZDdee%ddfd&ZEdQd'ZFdQd(ZGd)ZHd*ZIeHZJd+e"zZKed,ee7de7fd-ZLd,ee7de7fd.ZM dRd1e7d,ee7d2ee7d3eNd4e#d5eejvdejfd6ZPd"d7d8ejd9e7d:eNdeejeffd;ZQde#def d?ZT dTd@e7dAe7d,ee7dBe7d4e#def dCZUdDZVdEZWdeNfdFZXdd/d0eVfd1e7d,ee7d3eNd4e#d2e7dejf dGZY dUd1e7de7d,ee7d4ee#dHee7de9f dIZZGdJdKe[Z\GdLdMe\Z]ejjZ`ejjZbGdNdOejZdy)VN) dataclass)datedatetimetimezone)GzipFile)BytesIO)AnyListOptionalTupleUnioncast) HTTPAdapter)HTTPConnection)Retry)_configure_posthog_logging)remove_trailing_slash)VERSION<KEEP_ALIVE_SOCKET_OPTIONS TCP_KEEPIDLE TCP_KEEPINTVL TCP_KEEPCNTg333333?iiurlreturnc0tjdd|S)zKMask token values in URLs for safe logging, keeping first 10 chars visible.z(token=)([^&]{10})[^&]*z\1\2...)resub)rs `/Users/ahmed/devFolder/Ultron/claude-voice/.venv/lib/python3.12/site-packages/posthog/request.py_mask_tokens_in_urlr"2s 66,j# >>c>eZdZUdZeed<dZeeed<dZ e ed<y) GetResponsez.Response from a GET request with ETag support.dataNetagF not_modified) __name__ __module__ __qualname____doc__r __annotations__r'r strr(boolr#r!r%r%7s"8 ID(3-L$r#r%c>eZdZdZdddeeffdZfdZxZS)HTTPAdapterWithSocketOptionsz-HTTPAdapter with configurable socket options.Nsocket_optionsr4c2||_t||i|yN)r4super__init__)selfr4argskwargs __class__s r!r8z%HTTPAdapterWithSocketOptions.__init__Cs, $)&)r#cZ|j|j|d<t||i|y)Nr4)r4r7init_poolmanager)r9r:r;r<s r!r>z-HTTPAdapterWithSocketOptions.init_poolmanagerGs2    *'+':':F# $  $1&1r#) r)r*r+r,r SocketOptionsr8r> __classcell__)r<s@r!r2r2@s$7HL*h}.E*22r#r2r4cttddd|}tj}|j d||S)zBBuild a session for general requests (batch, remote config, etc.).)totalconnectread max_retriesr4https://r2rrequestsSessionmountr4adaptersessions r!_build_sessionrPMsE* & G G MM*g& Nr#cttdddd|}tj}|j d||S)zBuild a session for feature flag requests. /flags retries are handled explicitly in ``flags()`` so that only transport failures and contract-defined transient HTTP responses are retried. r)rCrDrEstatusrFrHrIrMs r!_build_flags_sessionrS\sB+11Q?%G G MM*g& Nr#_socket_optionsTc8trtSttSr6)_pooling_enabled_sessionrPrTr0r#r! _get_sessionrXss / **r#c8trtSttSr6)rV_flags_sessionrSrTr0r#r!_get_flags_sessionr[ys  00r#ctrtjtrtjttat tay)z Reset the global sessions. This should be called after a fork to ensure that the child process does not use the parent's connection pool. N)rWcloserZrPrTrSr0r#r!reset_sessionsr^s4 o.H)/:Nr#cH|tk(ry|at|at|ay)a Configure socket options for all SDK HTTP connections. Call this during initialization, before making API requests. Pass ``None`` to reset to the default socket behavior. Args: socket_options: A list of ``(level, option, value)`` tuples accepted by urllib3/``socket.setsockopt()``, or ``None`` to reset defaults. Example: from posthog import set_socket_options set_socket_options([(socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1)]) N)rTrPrWrSrZr3s r!set_socket_optionsr`s( ($On-H).9Nr#c"tty)z Enable TCP keepalive for SDK HTTP connections. This helps prevent idle pooled connections from being dropped by network infrastructure. Call during initialization, before making API requests. N)r`rr0r#r!enable_keep_aliverbs 01r#cday)a Disable HTTP connection reuse for SDK requests. Each request will create a fresh connection. This can avoid issues with environments that terminate pooled connections, but adds per-request overhead. Call during initialization, before making API requests. FN)rVr0r#r!disable_connection_reuserds r#zhttps://us.i.posthog.comzhttps://eu.i.posthog.comzposthog-python/hostc>|xsdj}|stS|S)zENormalize a configured host, defaulting blank values to DEFAULT_HOST.)strip DEFAULT_HOST)renormalized_hosts r!normalize_hostrks#zr((*O  r#c\t|}t|}|dvrtS|dk(rtS|S)z"Determines the server host to use.)zhttps://app.posthog.comzhttps://us.posthog.comzhttps://eu.posthog.com)rkrUS_INGESTION_ENDPOINTEU_INGESTION_ENDPOINT)rehost_or_default trimmed_hosts r!determine_server_hostrqs:$T*O(9LLL$$ 1 1$$r#Fapi_keypathgziptimeoutrOc :tjd}|}tjtj j |d<tt|} | tt|z} ||d<tj|t} |jd| | dtd} |rd t!} t#| d 5}|j%tt| j'd d d d | j)} d | d<|xs t3j5| | | |}|j6dk(r|jd|S#1swYaxYw#t*t,j.f$r}|j1d|Yd }~d }~wwxYw)zPost the `kwargs` to the APIposthog)tzsent_atrs)clszmaking request: %s to url: %szapplication/json)z Content-Type User-Agentw)fileobjmodezutf-8NruzContent-Encodingz5failed to gzip request body, sending uncompressed: %s)r&headersrvdata uploaded successfully)logging getLoggerrnowrutc isoformatrrkrr.jsondumpsDatetimeSerializerdebug USER_AGENTrrwriteencodegetvalueOSErrorzliberrorwarningrXpost status_code)rsrertrurvrOr;logbodyrprr&rbufgzexcress r!rrsc   I &C Dllhll3==?DO()=>L c4 (CDO 4-?@DII-tS91LG  V)C#C0Bc4//891<<>D*0G& '  $ln * * $ + C # ./ J!10 $ V KKOQT U U Vs03E% /E9E%E"E%%F>FF) return_jsonrsuccess_messagercjtjd}|jdk(r||j||r|j n|}t |t rEd|vrAt |dtr.d|dvr'|jdt|jd|Sd}|jjd}|r t|} |j }|jd |t/|j|d | #ttf$rd dd lm}t#d ||t%j&t(j*z j-}n#ttf$rYnwxYwYwxYw#t0tf$r#t/|j|j2| wxYw)Nrxr quotaLimited feature_flagsz[FEATURE FLAGS] PostHog feature flags quota limited, resetting feature flag data. Learn more about billing limits at https://posthog.com/docs/billing/limits-alertszFeature flags quota limitedz Retry-Afterr)parsedate_to_datetimegzreceived response: %sdetail) retry_after)rrrrr isinstancedictlistrQuotaLimitErrorrgetfloat ValueError TypeError email.utilsrmaxrrrr total_secondsAPIErrorKeyErrortext) rrrrresponserretry_after_headerrpayloads r!_process_responsers   I &C # /"!,388:# x &(*8N3T:8N#;; KKw "#//3PQ QK7  23KK((* )73s(9{SS#I&  =!-.@A",,x||45#mo   *   $ j !KskJJKsC D =F E=A E%$E=%E74E=6E77E=<E=2F2failed_attemptctd|zzS)NrB)$_FEATURE_FLAGS_RETRY_BACKOFF_SECONDS)rs r!_feature_flags_retry_delayr0s /1n3D EEr#rGc td|}d} t||d||fdti|}t|dS#tj j tj jf$r ||k\rYn-t$r"} | jtvs||k\rYd} ~ nd} ~ wwxYwtjt||dz })zIPost the kwargs to the flags API endpoint with bounded transient retries.rz /flags/?v=2rOz$Feature flags evaluated successfullyrNr)rrr[rrJ exceptionsConnectionErrorTimeoutrrR"_FEATURE_FLAGS_RETRY_HTTP_STATUSEStimesleepr) rsrerurvrGr;retriesrrrs r!flagsr4s![!GN    +, C%%K ##33X5H5H5P5PQ ()  "DD!W,-  -n=>!1 s&8=B!7B!?BB!personal_api_keyproject_api_keykeycBt|d|d|||}|jS)zt|||||fi|}t|ddS)z6Post the `kwargs` to the batch API endpoint for eventsrF)rr)rr)rsrerurvrtr;rs r! batch_postrts0 wdD' Lc!H +g 5ZPG #' .  Xw  HC$X.J # D $>?@ / =+@DtTT  tJrs  !--::)-$7/#U3U3:%6678 ,0)), ++Q/,= +,01)*KD% vt!((&..'&$:OQV)WX (+$&)3Z"?S?S?    2; 2 8M#: hFVFV  /3]+ "  %'+/-(/+h&&+ 1H,,1 ;:x '>:4:.2 32$  ( #3  # *. & & 3-& 3-&  &  & h&& ' &&TJN-K   -K-0-KBF-K 8  c !"-K`FsFuF  $ $ 3-$ $ $  $ $T  3-     "&ItI     3-       $! %J %J %J 3-%Jc] %J 3- %J  %JP 5y 5 h %%--"--==3))3r#