ߎjjUddlmZddlZddlmZmZmZmZmZm Z ddl m Z ddl m Z erddlmZmZgdZee gd fZd ed < ee ge d fZd ed < GddZee egd fZd ed<ee ege d fZd ed<eeeefZd ed<ddZd dZd!dZd!dZdS)") annotationsN) TYPE_CHECKINGAnyUnionCallableIterable Awaitable) TypeAlias) APIRequest) APIResponseAsyncAPIResponse) MiddlewareCallNext AsyncCallNextMiddlewareCallableAsyncMiddlewareCallableMiddlewareInputAPIResponse[Any]r rAsyncAPIResponse[Any]rc"eZdZdZd dZdd Zd S)rzBase class for client-level middleware. Subclass and override `handle` (used by the sync client) and/or `handle_async` (used by the async client). The default implementations delegate straight to the rest of the chain. requestr call_nextrreturnrc||SNselfrrs CC:\Projects\DSCons\.venv\Lib\site-packages\anthropic\_middleware.pyhandlezMiddleware.handle6sy!!!rrc(K||d{VSrrrs r handle_asynczMiddleware.handle_async9s(Yw'''''''''r"N)rr rrrr)rr rrrr)__name__ __module__ __qualname____doc__r!r$rr"r rr.sF""""((((((r"rrrr middlewareobjectrstrct|trt|jSt |dd}t|t r|nt |S)Nr%) isinstancertyper%getattrr+repr)r)names r _middleware_namer2BsW*j)))J(( :z4 0 0DdC(( >44d:.>.>>r"objboolctj|rdSt|dd}|duotj|S)zWhether calling the given object returns a coroutine. Unlike `inspect.iscoroutinefunction(obj)` this also handles class instances that define an async `__call__` method. T__call__N)inspectiscoroutinefunctionr/)r3calls r _is_async_callabler:IsH "3''t 3 D ) )D t  A ;D A AAr"Iterable[MiddlewareInput]Nonec|D]}t|trt|jtjur t dt |dt jt|jr t dt |dt|s t dt |dt|r t dt |ddS)N middleware zW does not implement `handle()`; the synchronous client requires sync-capable middlewarezj defines `handle()` as an async function; the synchronous client requires `handle()` to be a sync function is not callablezP is an async function; the synchronous client requires sync middleware functions) r-rr.r! TypeErrorr2r7r8callabler:r)entrys r validate_sync_middlewarerDUsN eZ ( ( E{{!Z%666N"25"9"9NNN*4;;+=>> W"25"9"9WWW  % S*:5*A*ASSSTT T  & & L.u55LLL  r"c|D]}t|trt|jtjur t dt |dt jt|js t dt |dt|s t dt |dt|s t dt |ddS)Nr>z_ does not implement `handle_async()`; the asynchronous client requires async-capable middlewarezw defines `handle_async()` as a sync function; the asynchronous client requires `handle_async()` to be an async functionr?zV is not an async function; the asynchronous client requires async middleware functions) r-rr.r$r@r2r7r8rAr:rBs r validate_async_middlewarerFksN eZ ( ( E{{':+BBBP"25"9"9PPP.tE{{/GHH `"25"9"9```  % S*:5*A*ASSSTT T#E** N.u55NNN  r")r)r*rr+)r3r*rr4)r)r;rr<) __future__rr7typingrrrrrr typing_extensionsr _requestr _responser r__all__r__annotations__rrrrrr2r:rDrFrr"r rNs"""""""KKKKKKKKKKKKKKKK'''''' 988888888    |-??@@@@@ $ZL)