AXj48UddlmZddlZddlmZmZmZmZmZm 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<ddZddZddZddZy)) annotationsN) TYPE_CHECKINGAnyUnionCallableIterable Awaitable) TypeAlias) APIRequest) APIResponseAsyncAPIResponse) MiddlewareCallNext AsyncCallNextMiddlewareCallableAsyncMiddlewareCallableMiddlewareInputAPIResponse[Any]r rAsyncAPIResponse[Any]rc eZdZdZddZddZy)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. c||SNselfrequest call_nexts [/var/www/html/content_generation/venv/lib/python3.12/site-packages/anthropic/_middleware.pyhandlezMiddleware.handle6s !!c.K||d{S7wrrrs r handle_asynczMiddleware.handle_async9sw''''s N)rr rrreturnr)rr rrr$r)__name__ __module__ __qualname____doc__r r#rr!rrr.s"(r!rrrrct|trt|jSt |dd}t|t r|St |S)Nr%) isinstancertyper%getattrstrrepr) middlewarenames r_middleware_namer1BsD*j)J((( :z4 0DdC(4>d:.>>r!c~tj|ryt|dd}|duxrtj|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,)objcalls r_is_async_callabler8Is> ""3' 3 D )D t  A ; ;D AAr!c|D]}t|tr~t|jtjurt dt |dt jt|jsyt dt |dt|st dt |dt|st dt |dy)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 TypeErrorr1r4r5callabler8r/entrys rvalidate_sync_middlewarer@Us eZ (E{!!Z%6%66!"25"9!:;NN**4;+=+=>!"25"9!:;WW%k*:5*A)BBRST T  &.u567LL r!c|D]}t|tr~t|jtjurt dt |dt jt|jryt dt |dt|st dt |dt|rt dt |dy)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<r1r4r5r=r8r>s rvalidate_async_middlewarerBks eZ (E{'':+B+BB!"25"9!:;PP..tE{/G/GH!"25"9!:;``%k*:5*A)BBRST T#E*.u567NN r!)r/objectr$r-)r6rCr$bool)r/zIterable[MiddlewareInput]r$None) __future__rr4typingrrrrrr typing_extensionsr _requestr _responser r__all__r__annotations__rrrrrr1r8r@rBrr!rrMs"KK' 8  |-??@)@ $ZL)