Qi). UddlZddlZddlZddlZddlmZddlmZmZddlm Z ddl m Z ddl m Z mZmZmZmZddlZddlmZddlmZdd lmZdd lmZdd lmZdd lmZeeeeeee ffZ!d Z"d Z#dZ$e%ejLejNejPdfgzZ)e!e*d<de"fde#fde$ffD]4\Z+Z,e-ee+se)j]ej^e0ee+e,f6gdZ1de2de2fdZ3eGddZ4GddeZ5dDdee!dejlfdZ7 dDdee!dejlfdZ8e7a9e8a:da;ee!e*d<d adee!ddfd#Z?dEd$Z@dEd%ZAd&ZBd'ZCeBZDd(ezZEd)ee2de2fd*ZF dFd+e2d)ee2d,eGd-ed.eejldejf d/ZId d0d1ejd2e2d3eGdeeje ffd4ZJ dGd+e2d)ee2d,eGd-ede f d5ZK dGd+e2d)ee2d,eGd-ede f d6ZL dHd7e2d8e2d)ee2d9e2d-ede f d:ZM dGd+e2d)ee2d,eGd-edejf d;ZN dId+e2de2d)ee2d-eedd?ePZQGd@dAeQZRejjZUejjZWGdBdCejZYy)JN) dataclass)datedatetime)GzipFile)BytesIO)AnyListOptionalTupleUnion)tzutc) HTTPAdapter)HTTPConnection)Retry)remove_trailing_slash)VERSION<KEEP_ALIVE_SOCKET_OPTIONS TCP_KEEPIDLE TCP_KEEPINTVL TCP_KEEPCNT)iiiiiurlreturnc0tjdd|S)zKMask token values in URLs for safe logging, keeping first 10 chars visible.z(token=)([^&]{10})[^&]*z\1\2...)resub)rs K/mnt/e/genesis-system/.venv/lib/python3.12/site-packages/posthog/request.py_mask_tokens_in_urlr 0s 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!rr#r#5s"8 ID(3-L$r!r#c>eZdZdZdddeeffdZfdZxZS)HTTPAdapterWithSocketOptionsz-HTTPAdapter with configurable socket options.Nsocket_optionsr2c2||_t||i|yN)r2super__init__)selfr2argskwargs __class__s rr6z%HTTPAdapterWithSocketOptions.__init__As, $)&)r!cZ|j|j|d<t||i|y)Nr2)r2r5init_poolmanager)r7r8r9r:s rr<z-HTTPAdapterWithSocketOptions.init_poolmanagerEs2    *'+':':F# $  $1&1r!) r'r(r)r*r SocketOptionsr6r< __classcell__)r:s@rr0r0>s$7HL*h}.E*22r!r0r2cttddd|}tj}|j d||S)z;Build a session for general requests (batch, decide, etc.).)totalconnectread max_retriesr2https://)r0rrequestsSessionmountr2adaptersessions r_build_sessionrMKsE* & G G MM*g& Nr!c ttddddtdg|}tj}|j d||S)a8 Build a session for feature flag requests with POST retries. Feature flag requests are idempotent (read-only), so retrying POST requests is safe. This session retries on transient server errors (408, 5xx) and network failures with exponential backoff (0.5s, 1s delays between retries). r@g?POST)rArBrCbackoff_factorstatus_forcelistallowed_methodsrDrF)r0rRETRY_STATUS_FORCELISTrGrHrIrJs r_build_flags_sessionrTZsR+3#H  & G G MM*g& Nr!_socket_optionsTc8trtSttSr4)_pooling_enabled_sessionrMrUr.r!r _get_sessionrY{s / **r!c8trtSttSr4)rW_flags_sessionrTrUr.r!r_get_flags_sessionr\s  00r!cH|tk(ry|at|at|ay)z Configure socket options for all HTTP connections. Example: from posthog import set_socket_options set_socket_options([(socket.SOL_SOCKET, socket.SO_KEEPALIVE, 1)]) N)rUrMrXrTr[r1s rset_socket_optionsr^s(($On-H).9Nr!c"tty)zDEnable TCP keepalive to prevent idle connections from being dropped.N)r^rr.r!renable_keep_aliver`s 01r!cday)zGDisable connection reuse, creating a fresh connection for each request.FN)rWr.r!rdisable_connection_reuserbs r!zhttps://us.i.posthog.comzhttps://eu.i.posthog.comzposthog-python/hostcZ|xst}t|}|dvrtS|dk(rtS|S)z"Determines the server host to use.)zhttps://app.posthog.comzhttps://us.posthog.comzhttps://eu.posthog.com) DEFAULT_HOSTrUS_INGESTION_ENDPOINTEU_INGESTION_ENDPOINT)rchost_or_default trimmed_hosts rdetermine_server_hostrjs:*lO(9LLL$$ 1 1$$r!api_keygziptimeoutrLc ~tjd}|}tjt j |d<t |xst|z} ||d<tj|t} |jd| | dtd} |rUd | d <t} t| d 5} | j| j!d ddd| j#} |xs t%j'| | | |}|j(dk(r|jd|S#1swY\xYw)zPost the `kwargs` to the APIposthog)tzsentAtrk)clszmaking request: %s to url: %szapplication/json)z Content-Type User-AgentrlzContent-Encodingw)fileobjmodezutf-8N)r$headersrmdata uploaded successfully)logging getLoggerrnowr isoformatrrejsondumpsDatetimeSerializerdebug USER_AGENTrrwriteencodegetvaluerYpost status_code)rkrcpathrlrmrLr9logbodyrr$rwbufgzress rrrs   I &C D\\UW-779DN  4 5 t||d||fi|}t|ddS)z6Post the `kwargs` to the batch API endpoint for eventsz/batch/ryF)rrrrs r batch_postr)s0 wiw A& AC  9u r!r%ctjd}t|xst|z}d|ztd}|r||d<t j |||}t|} |jdk(rB|jd| d|jj d } td | xs|d St|d| d } |jj d } t| | d S)a Make a GET request with optional ETag support. If an etag is provided, sends If-None-Match header. Returns GetResponse with: - not_modified=True and data=None if server returns 304 - not_modified=False and data=response if server returns 200 roz Bearer %s) Authorizationrsz If-None-Match)rwrmi0zGET z returned 304 Not ModifiedETagNT)r$r%r&z completed successfullyrF) rzr{rrerrYrr rrrwr#r) rkrrcrmr%rfull_urlrwr masked_url response_etagr$s rrr7s   I &C$T%9\:S@H +g 5ZPG #' .  Xw  HC$X.J # D $>?@ / =+@DtTT  tJrs  !#44)-$/#U3U3:%6678 ,0)), ++Q/,= +,01)*YKD% vt!((&..'&$:OQV)WX Y3?S?S?    2; 2 8M#: hFVFV  /3]+ 6  %'+/-(/+h&&+ 1H,,1 :x '> :4 : 2  32$  (   #  *. " " 3-"  "  " h&& ' ""LJN2   2-02BF2 8  c !"2> X  X 3- X  X X  X   3-    2  3-     &    3-      "! $J $J $J 3-$Jc] $J 3- $J  $JN5y5 h %%--"--==3))3r!