0j>|dZddlZddlZddlZddlmZmZddlmZm Z m Z m Z m Z m Z ddlZddlmZmZddlmZmZmZmZddlmZmZdd lmZmZmZejeZ d e e!e!fd e e!e!fd e e!e!ffd Z"dejd dfdZ#edGddZ$GddZ%dS)z[ Copyright (c) Microsoft Corporation. All rights reserved. Licensed under the MIT License. N) dataclassfield)Any AwaitableCallableDictListOptional)RequestResponse)QueryParamTypesRequestContent RequestData RequestFiles)Token resolve_token) InterceptorInterceptorRequestContextInterceptorResponseContextbase overridesreturnc(t|}|D]m\}}|dkrKtd|Dd}|)||}||vr |d|||<b||d<h|||<n|S)a Merge two header dicts, concatenating User-Agent values when both sides define it. For User-Agent headers (case-insensitive key match), the values are merged by concatenating with a space, skipping tokens that are already present. All other headers from overrides take precedence over base headers. Args: base: The base headers dict. overrides: Headers to merge in (may override base headers). Returns: Merged headers dict. user-agentc3JK|]}|dk|VdS)rN)lower).0ks j/home/rurouni/.hermes/hermes-agent/venv/lib/python3.11/site-packages/microsoft_teams/common/http/client.py z!_merge_headers..(s4OOaQWWYY,5N5N5N5N5N5NOON z User-Agent)dictitemsrnextsplit)rrresultkeyvalue base_ua_keyexistings r _merge_headersr-s$ZZFoo''   U 99;;, & &OO6OOOQUVVK&!+. 0 000-5*?*?*?*?F;'',|$$F3KK Mr"responsecPjdtdtffd }|_dS)z Wrap the response.json method to handle JSONDecodeError gracefully. Args: response: The httpx.Response object to wrap. logger: Logger instance for warning messages. kwargsrc di|S#tj$r;}|jdkr*tdjdicYd}~Sd}~wwxYw)Nrz$Failed to decode JSON response from z. Returning empty dict.)jsonJSONDecodeErrorposloggerdebugurl)r0e original_jsonr.s r safe_jsonz&_wrap_response_json..safe_json>s}  =**6** *#   uzz iHLiiijjj   s  A/A AAAN)r3r)r.r;r:s` @r _wrap_response_jsonr<4sKMMCCHMMMr"T)frozenceZdZUdZdZeeed<ee eefZ e eefed<dZ ee ed<dZeeed<eeeZeeeed<dS) ClientOptionsa Configuration options for the HTTP Client. Attributes: base_url: The base URL for all requests. headers: Default headers to include with every request. timeout: Default request timeout in seconds. token: Default authorization token (string, string-like, or callable). interceptors: List of interceptors for request/response middleware. Nbase_url)default_factoryheaderstimeouttoken interceptors)__name__ __module__ __qualname____doc__r@r str__annotations__rr$rBrrCfloatrDrlistrrEr r2r"r r?r?Ks  #Hhsm"""#eDcNCCCGT#s(^CCC#GXe_###!E8E?!!!05d;FW0X0X0XL(4 ,-XXXXXr"r?cjeZdZdZd deefdZdeeeefdee deeeffdZ dddd d edeeeefdee d ee d e de jf d Zddddddddd edeedeedeedee d ee deeeefdee d e de jfdZddddddddd edeedeedeedee d ee deeeefdee d e de jfdZddddddddd edeedeedeedee d ee deeeefdee d e de jfdZdddd d edeeeefdee d ee d e de jf dZddddddddded ed ee deeeefdee deedeedeedee d e de jfdZdee deefdZdeddfdZd!dZd deeddfdZdS)"Clientz HTTP Client abstraction for making requests with configurable options. Args: options: ClientOptions dataclass with configuration for the client. Noptionsc|t}||_|j|_t jd}|tjt|j pg|_ tj |jrtj|jnd|j|j|_|dS)z Initialize the HTTP Client. Args: options: Optional ClientOptions dataclass with configuration for the client. Nhttpx)r@rBrC)r?_optionsrD_tokenlogging getLoggersetLevelr6levelrMrE _interceptorsrR AsyncClientr@URLrBrChttp_update_event_hooks)selfrP httpx_loggers r __init__zClient.__init__gs ?#ooG m (11 fl+++"'"6"<"==%4;4DLUYw/000"OO      """""r"rBrDrcxKi|jj|pi}||d{V}|rd||d<|S)a% Merge default and per-request headers, resolve token, and inject Authorization header if needed. Args: headers: Optional per-request headers. token: Optional per-request token. Returns: Final headers dict for the request. NzBearer Authorization)rTrB_resolve_token)r_rBrD req_headersresolved_tokens r _prepare_headerszClient._prepare_headerssgC.B7=bB #22599999999  F+E^+E+EK (r")rBrDparamsr8rhr0cK|||d{V}|jj|f||d|d{V}|t ||S)as Send a GET request. Args: url: The URL path or full URL. headers: Optional per-request headers. params: Optional query parameters. token: Optional per-request token (overrides default). **kwargs: Additional httpx.AsyncClient.get arguments. Returns: httpx.Response NrBrh)rgr]getraise_for_statusr<r_r8rBrDrhr0rer.s r rkz Client.gets,!11'5AAAAAAAA &sYKYYRXYYYYYYYY!!###H%%%r")contentdatafilesr3rhrBrDrnrorpr3c K|||d{V} |jj|f|||||| d| d{V} | t | | S)a Send a POST request. Args: url: The URL path or full URL. data: The request body. headers: Optional per-request headers. params: Optional query parameters. content: The request body. files: The request files. json: The request JSON body. token: Optional per-request token (overrides default). **kwargs: Additional httpx.AsyncClient.post arguments. Returns: httpx.Response Nrorpr3rnrhrB)rgr]postrlr< r_r8rnrorpr3rhrBrDr0rer.s r rsz Client.posts<!11'5AAAAAAAA '                !!###H%%%r"c K|||d{V} |jj|f|||||| d| d{V} | t | | S)a  Send a PUT request. Args: url: The URL path or full URL. data: The request body. headers: Optional per-request headers. params: Optional query parameters. content: The request body. files: The request files. json: The request JSON body. token: Optional per-request token (overrides default). **kwargs: Additional httpx.AsyncClient.put arguments. Returns: httpx.Response Nrr)rgr]putrlr<rts r rvz Client.puts<!11'5AAAAAAAA &                !!###H%%%r"c K|||d{V} |jj|f|||||| d| d{V} | t | | S)a Send a PATCH request. Args: url: The URL path or full URL. data: The request body. headers: Optional per-request headers. params: Optional query parameters. content: The request body. files: The request files. json: The request JSON body. token: Optional per-request token (overrides default). **kwargs: Additional httpx.AsyncClient.patch arguments. Returns: httpx.Response Nrr)rgr]patchrlr<rts r rxz Client.patchs<!11'5AAAAAAAA (                !!###H%%%r"cK|||d{V}|jj|f||d|d{V}|t ||S)ay Send a DELETE request. Args: url: The URL path or full URL. headers: Optional per-request headers. params: Optional query parameters. token: Optional per-request token (overrides default). **kwargs: Additional httpx.AsyncClient.delete arguments. Returns: httpx.Response Nrj)rgr]deleterlr<rms r rzz Client.delete4s,!11'5AAAAAAAA ))#\{6\\U[\\\\\\\\!!###H%%%r")rhrBrDrnrorpr3methodc K|||d{V} |jj||f| ||||| d| d{V} | t | | S)aK Send a custom HTTP request. Args: method: HTTP method (GET, POST, etc). url: The URL path or full URL. headers: Optional per-request headers. params: Optional query parameters. content: The request body. data: The request body. files: The request files. json: The request JSON body. token: Optional per-request token (overrides default). **kwargs: Additional httpx.AsyncClient.request arguments. Returns: httpx.Response N)rBrhrnrorpr3)rgr]requestrlr<) r_r{r8rhrBrDrnrorpr3r0rer.s r r}zClient.requestPs@!11'5AAAAAAAA **                  !!###H%%%r"cNK||n|j}|dSt|d{VS)z Resolve the token to a string, using per-request or default token. Args: token: Per-request token or None. Returns: The resolved token string or None. N)rUr)r_rD use_tokens r rdzClient._resolve_tokensC#.EEDK  4"9---------r" interceptorcb|j||dS)z Register an interceptor for request/response middleware. Args: interceptor: An object with optional request/response methods. N)rZappendr^)r_rs r use_interceptorzClient.use_interceptors3 !!+...   """""r"ci}|jD]}t|dr]dtdttgt dffd}|dg||t|dr]dtdttgt dffd}|dg||||j _ dS)zc Internal: Update the httpx.AsyncClient event_hooks to match current interceptors. r}hrNc&dtddffd }|S)Nr}rcKt|}|}tj|r |d{VdSdSN)rr}inspect isawaitable)r}ctxr(rs r wrapperzJClient._update_event_hooks.._make_request_wrapper..wrappersU7@@!"3".v66)"(LLLLLLLLL))r")r rrs` r _make_request_wrapperz9Client._update_event_hooks.._make_request_wrappers6)w)4)))))) #Nr"r.c&dtddffd }|S)Nr.rcKt|}|}tj|r |d{VdSdSr)rr.rr)r.rr(rs r rzKClient._update_event_hooks.._make_response_wrapper..wrappersU8BB!"C".v66)"(LLLLLLLLL))r")r rs` r _make_response_wrapperz:Client._update_event_hooks.._make_response_wrappers6))T)))))) #Nr") rZhasattrrrr r setdefaultrr r] event_hooks)r_event_hooks_dicthookrrs r r^zClient._update_event_hookss'CE& a aDtY'' _#[#XwiQZ[_Q`F`=a####!++Ir::AABWBWX\B]B]^^^tZ(( a#k#hzS\]aSbGb>c####!++J;;BBCYCYZ^C_C_``` 0 r"rc |p t}t|j|jn |jjt|jj|jpi|j|jn |jj|j|jn |jj|jt|jnt|j }t|S)a Create a new Client instance with merged configuration. Args: overrides: Optional ClientOptions object to override fields. Returns: A new Client instance with merged options and a cloned interceptor list. N)r@rBrCrDrE) r?r@rTr-rBrCrDrErMrZrO)r_rmerged_optionss r clonez Client.clones0 &+4+=+IY''t}Oe"4=#8):K:QrRR)2):)FI%%DMLa%._%@)//dmFY%1i4555d())   n%%%r"r)rN)rFrGrHrIr r?rarrJrrgr rrRr rkrrrrsrvrxrzr}rdrrr^rr2r"r rOrO_s&## 7####2htCH~.FxX]cghkmphpcq*-1!%,0  $sCx.)    )  @-1&*(,",0,0!%+++ +.) + {# +  % +sm+)+$sCx.)+++ ++++b-1&*(,",0,0!%+++ +.) + {# +  % +sm+)+$sCx.)+++ ++++b-1&*(,",0,0!%+++ +.) + {# +  % +sm+)+$sCx.)+++ ++++b-1!%,0  $sCx.)    )  B-1,0!%,0&*(,"..... ) . $sCx.) ...).{#. %.sm.. ....` .(5/ .hsm . . . .#;#4####1111@&&x 6&(&&&&&&r"rO)&rIrr3rV dataclassesrrtypingrrrrr r rR httpx._modelsr r httpx._typesr rrr client_tokenrrrrrrrWrFr6rJr-r<r?rOr2r"r rs  ((((((((AAAAAAAAAAAAAAAA ++++++++SSSSSSSSSSSS........[[[[[[[[[[  8 $ $c3hDcNtCQTH~<%.T. $YYYYYYYY&n&n&n&n&n&n&n&n&n&n&r"