ej&hUdZddlZddlZddlmZmZmZiZeeefed<ddefdZ dZ dZ e Z d ZGd d e ZGd d eZGddeZGddeZGddeZGddeZGddeZGddeZdZdS)z!Dynamic class-creation for Motor.N)AnyCallableDict _class_cache sync_methodctjfd}|||}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/fd|D}fd|D}n*d|D}d|D}|}j||jg|Ri|S)Ncdg|],}|jjdfr|jn|-SMotorClientSession __class____name__endswithdelegate).0obj unwrap_classs Y/var/www/app.qaans.com/backend/venv/lib/python3.11/site-packages/motor/metaprogramming.py z0asynchronize..method...sR=)22LBV3WXX cli|]0\}}||jjdfr|jn|1Sr r )rkeyrrs r z0asynchronize..method..4sY    C }-66 FZ7[\\CLL    rc^g|]*}|jjdr|jn|+Sr r rrs rrz0asynchronize..method..>sH!$ 6 ? ?@T U U^ [^rcfi|].\}}||jjdr|jn|/Sr r rrrs rrz0asynchronize..method..BsQ   C$'M$:$C$CDX$Y$YbCLL_b   r)items get_io_looprun_on_executorr) selfargskwargsunwrapped_argsunwrapped_kwargsloop frameworkrrs rmethodzasynchronize..method*s  # N      !'       N  !'      !!(y( +t} /=   AQ   rNT) functoolswrapspymongo_class_wrapperis_wrap_methodis_async_methodrpymongo_method_name__doc__)r(rdoc wrap_classrr)names`` ` r asynchronizer4s$_[!!! ! ! ! ! ! "!! F00DD $"F  D!%F  Mrcd|DS)Nc3fK|],}|jjdr|jn|V-dS)r Nr rs r z&unwrap_args_session.._sV    .778LMMV SV      r)r#s runwrap_args_sessionr9^s#     rc>d|DS)Ncfi|].\}}||jjdr|jn|/Sr r rs rrz)unwrap_kwargs_session..fsN    C cm4==>RSS\cllY\   r)r)r$s runwrap_kwargs_sessionr<es+      rcd|_|S)zlIn docs, annotate a function that returns a Future with 'coroutine'. This doesn't affect behavior. T)coroutine_annotation)fs rr>r>os"A Hrc eZdZdZddZdZdS)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||_dSN)r1r"r1s r__init__zMotorAttributeFactory.__init__s rctrC)NotImplementedError)r"cls attr_names rcreate_attributez&MotorAttributeFactory.create_attributes!!rrC)r __module__ __qualname__r0rErJr8rrrArA|sA """""rrAc2eZdZdfd ZdZdZdZxZS)AsyncNctt|||_d|_d|_dS)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)superrErIr2r)r"rIr1rs rrEzAsync.__init__s9 " rc|jp|}t|j|}t|j||j|j|jS)N)r(rr1r2r)rIgetattr__delegate_class__r4 _frameworkr1r2r)r"rHrIr3r)s rrJzAsync.create_attributesO~*/66n*     rc||_|SrCr2r"original_classs rwrapz Async.wrap( rc||_|SrC)r)r" class_names runwrapz Async.unwraps& rrC)rrKrLrErJrYr] __classcell__)rs@rrNrNsj ! ! ! ! ! !    rrNceZdZddZdS) AsyncReadNc@t|||dS)zeA descriptor that wraps a PyMongo read method like find_one() that returns a Future. rIr1NrNrEr"rIr1s rrEzAsyncRead.__init__" tyc:::::rNNrrKrLrEr8rrr`r`(;;;;;;rr`ceZdZddZdS) AsyncWriteNc@t|||dS)zA descriptor that wraps a PyMongo write method like update_one() that accepts getLastError options and returns a Future. rbNrcrds rrEzAsyncWrite.__init__rerrfrgr8rrrjrjrhrrjceZdZddZdS) AsyncCommandNc@t|||dS)zA descriptor that wraps a PyMongo command like copy_database() that returns a Future and does not accept getLastError options. rbNrcrds rrEzAsyncCommand.__init__rerrfrgr8rrrmrmrhrrmceZdZdZdZdS)ReadOnlyPropertyz;Creates a readonly attribute on the wrapped PyMongo object.cfd}|jr|j}nt|jj}|rt ||St |S)Nc.t|jSrC)rRr)rrIs rfgetz/ReadOnlyProperty.create_attribute..fgets3<33 3r)rsr1)rs)r1rRrSr0property)r"rHrIrsr1s ` rrJz!ReadOnlyProperty.create_attributess 4 4 4 4 4 8 E(CC#0)<<DC  '3/// /&&& &rN)rrKrLr0rJr8rrrprps)EE ' ' ' ' 'rrpc&eZdZdZddZdZdZdS)DelegateMethodz[A method on the wrapped PyMongo object that does no I/O and can be called synchronouslyNcJt||d|_dSrC)rprEr2rDs rrEzDelegateMethod.__init__s#!!$,,,rc||_|SrCrVrWs rrYzDelegateMethod.wraprZrc|jt|||St|j||jt jfd}|jr |j|_d|_ |S)Ncj|jg|Ri|}|jkr||S|SrC)rrrY)self_r#r$resultr)rXs rwrapperz0DelegateMethod.create_attribute..wrappersKVEN11zz&))) rT) r2rprJrRrSr*r+r1r0r-)r"rHrIr}r)rXs @@rrJzDelegateMethod.create_attributes ? "#44T3 JJ J/;;        !   8 '"hGO!%rrC)rrKrLr0rErYrJr8rrrvrvsPrrvceZdZdZdS)MotorCursorChainingMethodct|j|tjfd}d|_||_|jr |j|_|S)Nc*|jg|Ri||SrC)r)r"r#r$ cursor_methods r return_clonez@MotorCursorChainingMethod.create_attribute..return_clones* M$- 9$ 9 9 9& 9 9 9KrT)rRrSr*r+is_motorcursor_chaining_methodr/r1r0)r"rHrIrrs @rrJz*MotorCursorChainingMethod.create_attributeso 6 BB  ' '     ( '  7; 3+4 ( 8 ,#'8L rN)rrKrLrJr8rrrrs#rrc|j|jz}|||f}t|}|r|St t ||fi}||_||_t|dsJttj |D]]}|j D]A\}} t| tr'| ||} t#||| B^|t|<|S)NrS) CLASS_PREFIX__motor_class_name__rgettypestrrKrThasattrreversedinspectgetmro__dict__r isinstancerArJsetattr) rHr( module_namemotor_class_name cache_key cached_class new_classbaser3attrnew_class_attrs rcreate_class_with_frameworkr s -0HH& 2I##I..LS)**SFB77I&I$I 92 3 3333 ,,--99---// 9 9JD$$ 566 9!%!6!6y$!G!G 4888 9 (L r)NNN)r0r*rtypingrrrr__annotations__r4r9r<object _coro_tokenr>rArNr`rjrmrprvrrr8rrrs+(''&&&&&&&&&&! d38n!!!CCCCCCLfhh      " " " " "F " " " !D;;;;;;;;;;;;;;;;;;;;;5;;;''''','''$"""""%"""J 5$r