ZThfUdZddlmZddlZddlZddlZddlmZddlm Z m Z m Z ddl m Z e rddlmZGdd e ZgZd ed <e d Zdd Zy)zNUtility for generating synchronous API wrappers from asynchronous API classes.) annotationsN)wraps) TYPE_CHECKINGAnyTypeVar) TypedDict) ResourceBasec"eZdZUded<ded<y)SyncAPIRegistrationz type[Any] async_clssync_clsN)__name__ __module__ __qualname____annotations__g/home/www/backend.miabetepe.com/venv/lib/python3.12/site-packages/sift_client/_internal/sync_wrapper.pyr r srr zlist[SyncAPIRegistration] _registeredScj}j}j}t|fd}d}|d|djxsd|||d}dfd }dfd } j j D]\}} |jd rt| tru| jri| j} tj| } |} | r"tt| | fd }|||<n!tt| | fd }|||<t| tr td t| tr td tj| r ||||<| |||<t!|t"f|}|t$j&vr"t$j&|j }|||<t(j+t-||S)aVGenerate a synchronous wrapper class for the given async API class. It creates a new class whose name is derived from the async class by stripping a trailing 'Async' (e.g. PingAPIAsync -> PingAPI). For each public coroutine method on the async class, it defines a sync method that invokes the async one on the default loop using run_coroutine_threadsafe. Usage: from sift_client._internal.sync_wrapper import generate_sync_api PingAPI = generate_sync_api(PingAPIAsync) Returns: A new class that wraps the async class with synchronous methods. c |i||_yN) _async_impl)selfargskwargsclss r__init__z#generate_sync_api..__init__2s//rc|jjj}tj||j Sr)rclientget_asyncio_loopasynciorun_coroutine_threadsaferesult)rcoroloops r_runzgenerate_sync_api.._run6s8&&779//d;BBDDrzSync counterpart to `z`. )r__doc__rr(rcHt}t|fd}|S)NcZ|jt|j|i|Sr)r(getattrrrakw func_names r sync_funcz8generate_sync_api.._make_sync..sync_funcFs,99AWT%5%5yA1KKL Lrr-r)r1 async_funcr2rs` r _make_syncz%generate_sync_api.._make_syncCs0S), z  M  MrcHt}t|fd}|S)Nc<t|j|i|Srr-rr.s r wrapped_funcz;generate_sync_api.._wrap_sync..wrapped_funcOs"774++Y7AbA Arr3)r1funcr9rs` r _wrap_syncz%generate_sync_api.._wrap_syncLs/sI& t B  Br_cPt|j|}|j|Sr)r-rr()r _prop_namer&s rsync_prop_wrapperz,generate_sync_api..sync_prop_wrappercs$#4#3#3Z@D99T?*rc.t|j|Srr8)rr>s r sync_propz$generate_sync_api..sync_propns#4#3#3Z@@rz*staticmethod is not supported sync_wrapperz-classmethod is not supported for sync_wrapper)r r )r1str)rrrrr*__dict__items startswith isinstancepropertyfgetinspectiscoroutinefunction staticmethodNotImplementedError classmethodtypeobjectsysmodulesrappendr )r sync_namenamemodule orig_initrr( namespacer5r;attrr: is_async_prop prop_namer?rA sync_classmodule_globalss` rgenerate_sync_apir]s <rdsNT" ..'8) *, &+ CLxr