df&NUdZddlZddlZddlmZmZmZmZiZeeefe d<d defdZ dZ dZ e Zd ZGd d ZGd d eZGddeZGddeZGddeZGddeZGddeZGddeZedZdedededefdZy)!z!Dynamic class-creation for Motor.N)AnyCallableDictTypeVar _class_cache sync_methodctjfd}|j||}d|_d|_j }||_|||_|S)a6Decorate `sync_method` so it returns a Future. The method runs on a thread and resolves the Future when it completes. :Parameters: - `motor_class`: Motor class being created, e.g. MotorClient. - `framework`: An asynchronous framework - `sync_method`: Unbound method of pymongo Collection, Database, MongoClient, etc. - `doc`: Optionally override sync_method's docstring - `wrap_class`: Optional PyMongo class, wrap a returned object of this PyMongo class in the equivalent Motor class - `unwrap_class` Optional Motor class name, unwrap an argument with this Motor class name and pass the wrapped PyMongo object instead c  |Dcgc]7}|jjj dfr |jn|9}}|j Dcic];\}}||jjj dfr |jn|=}}}n|Dcgc]5}|jjjdr |jn|7}}|j Dcic]9\}}||jjjdr |jn|;}}}|j }j | |jg|i|Scc}wcc}}wcc}wcc}}wNMotorClientSession) __class____name__endswithdelegateitems get_io_looprun_on_executor) selfargskwargsobjunwrapped_argskeyunwrapped_kwargsloop frameworkr unwrap_classs N/home/api-vastappli/venv/lib/python3.12/site-packages/motor/metaprogramming.pymethodzasynchronize..method+s  #  ==))22LBV3WX N!'    C }}--66 FZ7[\LL    !$ 6 6 ? ?@T U [^^N!'   C$'MM$:$:$C$CDX$YCLL_bc   !(y(( +t}} /= AQ  9   sE3T) functoolswrapspymongo_class_wrapperis_wrap_methodis_async_methodrpymongo_method_name__doc__)rrdoc wrap_classrrnames`` ` r asynchronizer*sq$__[!! "! F00D $"F   D!%F  Mcd|DS)Nc3K|]7}|jjjdr |jn|9yw)r N)r rrr).0rs r z&unwrap_args_session..`s:   ..778LM SVV s=?)rs runwrap_args_sessionr1_s  r+c|jDcic]9\}}||jjjdr |jn|;c}}Scc}}wr )rr rrr)rrrs runwrap_kwargs_sessionr3fsR   C cmm44==>RScllY\\  s>Acd|_|S)zlIn docs, annotate a function that returns a Future with 'coroutine'. This doesn't affect behavior. T)coroutine_annotation)fs rr5r5ps"A Hr+ceZdZdZddZdZy)MotorAttributeFactoryzUsed by Motor classes to mark attributes that delegate in some way to PyMongo. At module import time, create_class_with_framework calls create_attribute() for each attr to create the final class attribute. Nc||_yN)r'rr's r__init__zMotorAttributeFactory.__init__s r+ctr:)NotImplementedError)rcls attr_names rcreate_attributez&MotorAttributeFactory.create_attributes!!r+r:)r __module__ __qualname__r&r<rAr0r+rr8r8}s "r+r8c2eZdZdfd ZdZdZdZxZS)AsynccNt||||_d|_d|_y)a/A descriptor that wraps a PyMongo method, such as insert_one, and returns an asynchronous version of the method that returns a Future. :Parameters: - `attr_name`: The name of the attribute on the PyMongo class, if different from attribute on the Motor class N)superr<r@r(r)rr@r'r s rr<zAsync.__init__s( " r+c|jxs|}t|j|}t|j||j |j |jS)N)rrr'r(r)r@getattr__delegate_class__r* _frameworkr'r(r)rr?r@r)rs rrAzAsync.create_attributesP~~*//6nn**   r+c||_|Sr:r(roriginal_classs rwrapz Async.wrap( r+c||_|Sr:)r)r class_names runwrapz Async.unwraps& r+r:)rrBrCr<rArPrT __classcell__)r s@rrErEs !  r+rEceZdZddZy) AsyncReadNc4tj|||y)zeA descriptor that wraps a PyMongo read method like find_one() that returns a Future. r@r'NrEr<rr@r's rr<zAsyncRead.__init__ tyc:r+NNrrBrCr<r0r+rrWrW;r+rWceZdZddZy) AsyncWriteNc4tj|||y)zA descriptor that wraps a PyMongo write method like update_one() that accepts getLastError options and returns a Future. rYNrZr[s rr<zAsyncWrite.__init__r\r+r]r^r0r+rrarar_r+raceZdZddZy) AsyncCommandNc4tj|||y)zA descriptor that wraps a PyMongo command like copy_database() that returns a Future and does not accept getLastError options. rYNrZr[s rr<zAsyncCommand.__init__r\r+r]r^r0r+rrdrdr_r+rdceZdZdZdZy)ReadOnlyPropertyz;Creates a readonly attribute on the wrapped PyMongo object.cfd}|jr |j}n t|jj}|r t ||St |S)Nc0t|jSr:)rIr)rr@s rfgetz/ReadOnlyProperty.create_attribute..fgets3<<3 3r+)rjr')rj)r'rIrJr&property)rr?r@rjr's ` rrAz!ReadOnlyProperty.create_attributesM 4 88((C#00)<DDC 3/ /& &r+N)rrBrCr&rAr0r+rrgrgs E 'r+rgc$eZdZdZddZdZdZy)DelegateMethodz[A method on the wrapped PyMongo object that does no I/O and can be called synchronouslyNc>tj||d|_yr:)rgr<r(r;s rr<zDelegateMethod.__init__s!!$,r+c||_|Sr:rMrNs rrPzDelegateMethod.wraprQr+c|jtj|||St|j||jt j fd}|jr|j|_d|_ |S)Nct|jg|i|}|jk(r|j|S|Sr:)rr rP)self_rrresultrrOs rwrapperz0DelegateMethod.create_attribute..wrappers?ENN1zz&)) r+T) r(rgrArIrJr r!r'r&r#)rr?r@rtrrOs @@rrAzDelegateMethod.create_attributesy ?? "#44T3 J J//;    !  88"hhGO!%r+r:)rrBrCr&r<rPrAr0r+rrmrmsr+rmceZdZdZy)MotorCursorChainingMethodct|j|tjfd}d|_||_|j r|j |_|S)Nc4|jg|i||Sr:)r)rrr cursor_methods r return_clonez@MotorCursorChainingMethod.create_attribute..return_clones $-- 9$ 9& 9Kr+T)rIrJr r!is_motorcursor_chaining_methodr%r'r&)rr?r@rzrys @rrAz*MotorCursorChainingMethod.create_attributes[ 6 6 B  '  (  7; 3+4 ( 88#'88L r+N)rrBrCrAr0r+rrvrvsr+rvTr?r module_namereturnc|j|jz}|||f}tj|}|r|St t ||fi}||_||_t|dsJttj|D]T}|jjD]5\}} t| ts| j!||} t#||| 7V|t|<|S)NrJ) CLASS_PREFIX__motor_class_name__rgettypestrrBrKhasattrreversedinspectgetmro__dict__r isinstancer8rAsetattr) r?rr}motor_class_name cache_key cached_class new_classbaser)attrnew_class_attrs rcreate_class_with_frameworkrs --0H0HH& 2I##I.LS)*SFB7I&I$I 92 33 ,-9----/ 9JD$$ 56!%!6!6y$!G 48 99(L r+)NNN)r&r rtypingrrrrr__annotations__r*r1r3object _coro_tokenr5r8rErWrardrgrmrvr|rrr0r+rrs(//! d38n! CCLh    " " !D;;;;;5;','$"%"J 5$ CLQ3SQr+