o Nign @sddlmZddlmZmZddlmZmZddlm Z ddl m Z ddl m Z ddlmZdd lmZdd lmZmZmZmZdd lmZmZmZmZmZmZdd lmZdd l m!Z!ddl"m#Z#m$Z$ e!a0eZ1ddZ2ddZ3eddkZ4dZ5dZ6dZ7dZ8dZ9dZ:e;eeee?e@eAeefZBdZCdZDdZEddZFddZGe#dZHe#dd d!ZIGd"d#d#e$eHZJe ZKd$d%ZLeJjMZMeJjNZOeJjPZPd&d'ZQdS)() namedtuple)partialwraps) version_infoexc_info)RLock) TracebackType)WeakKeyDictionary)reraise)Async)Future ensure_future iscoroutineiterate_promise) deprecated integer_types string_types text_type binary_typewarn) PromiseList)ImmediateScheduler)TypeVarGenericF) TypeListAnyCallableDictIteratorOptionalTupleUnionrHashableMutableMappingcCstSNdefault_schedulerr)r)C/home/ubuntu/.local/lib/python3.10/site-packages/promise/promise.pyget_default_scheduler/sr+cCs|adSr&r') schedulerr)r)r*set_default_scheduler4r-NicCstdS)NzPromise is self) TypeErrorr)r)r)r*make_self_resolution_errorOr.r3c OsPz ||i|dfWSty'}ztd}d||ffWYd}~Sd}~wwNr/) Exceptionr)handlerargskwargsetbr)r)r* try_catchTs r;TST) contravariantc@seZdZdZeZdZdZdZdZ dZ dZ dZ dZ dZdZdZdZdZdpddZeddZed d Zd d ZeZed ddddZedddddZddZdqddZddZdrddZddZ dsd d!Z!d"d#Z"d$d%Z#d&d'Z$d(d)Z%d*d+Z&d,d-Z'd.d/Z(d0d1Z)d2d3Z*d4d5Z+d6d7Z,d8d9Z-d:d;Z.dd?Z0d@dAZ1dBdCZ2e3drdDdEZ4drdFdGZ5drdHdIZ6dqdJdKZ7e7Z8Z9ee7Z:Z;dLdMZedRdSZ?dTdUZ@  dpdVdWZAeZBeZCe!ZDdpdXdYZEdpdZd[ZFdrd\d]ZGdrd^d_ZHe3d`daZIe3dbdcZJeJZKe3dddeZLeLZMeMZNe3dfdgZOdZPe3dhdiZQe3djdkZRe3dldmZSe3dndoZTdS)tPromisezP This is the Promise class that complies Promises/A+ specification. FrNcCs ||_|dur||dSdS)z> Initialize the Promise into a pending state. N) _scheduler_resolve_from_executor)selfexecutorr,r)r)r*__init__|szPromise.__init__cCs |jptSr&)r@r(rBr)r)r*r,s zPromise.schedulercCs(|jst|_||jj|jj|jSr&)_futurer _then set_result set_exceptionrEr)r)r*futures  zPromise.futurecCs t|Sr&)r_targetrEr)r)r*__iter__s zPromise.__iter__zRejecting directly in a Promise instance is deprecated, as Promise.reject() is now a class method. Please use promise.do_reject() instead.reject)namecC||dSr&) do_reject)rBr9r)r)r*_deprecated_rejectzPromise._deprecated_rejectzResolving directly in a Promise instance is deprecated, as Promise.resolve() is now a class method. Please use promise.do_resolve() instead.resolvecCrOr&) do_resolve)rBvaluer)r)r*_deprecated_resolverRzPromise._deprecated_resolvecCs||ur |tdS||s||S||}||kr(|tdS|jtkrT|j }|dkr9| |t d|D]}| ||q>d|_ d|_ ||dS|jtkrb||dS|jtkrt|||jdSdS)NFrr T)_reject_callbackr3 is_thenable_fulfill_try_convert_to_promiserK_reject_state STATE_PENDING_length_migrate_callback0range_migrate_callback_at _is_following _set_followeeSTATE_FULFILLED_valueSTATE_REJECTED_reason _traceback)rBrUpromiselenir)r)r*_resolve_callbacks,       zPromise._resolve_callbackcCsJ|jrJ|jtkr |jS|jtkr#|r |j}tt|||j|jSdSr&) rbr\rd_rejection_handler0rf_fulfillment_handler0r typerh)rB_raise raise_valr)r)r*_settled_values   zPromise._settled_valuecCsR||ur t}||St|_||_|jdkr'|jr |dSt |dSdSNr) r3r[rdr\rmr^_is_async_guaranteed_settle_promisesasync_instancesettle_promises)rBrUerrr)r)r*rYs   zPromise._fulfillcCsvt|_||_||_|jr|jdksJt||jdS|jdkr't |n| |j r4| dSt |dSrs) rfr\rnrh _is_finalr^rv fatal_errorr,rw"_ensure_possible_rejection_handledrtru)rBreason tracebackr)r)r*r[s   zPromise._rejectcCsdSr&r)rEr)r)r*r{ sz*Promise._ensure_possible_rejection_handledcCs(t|ts Jd||||dS)Nz+A promise was rejected with a non-error: {}) isinstancer5formatr[)rBr| synchronousr}r)r)r*rWs zPromise._reject_callbackcCsP|jrJ|dks J|tt}d|j|t<d|j|t<d|j|t<dSrs)rb CALLBACK_SIZE _handlersCALLBACK_PROMISE_OFFSETCALLBACK_FULFILL_OFFSETCALLBACK_REJECT_OFFSET)rBindexbaser)r)r*_clear_callback_data_index_ats   z%Promise._clear_callback_data_index_atcCBtd|D]}||}||}||||||dqdSNr )r`_fulfillment_handler_at _promise_atr_settle_promise)rBlengthrUrkr6rir)r)r*_fulfill_promises"    zPromise._fulfill_promisescCrr)r`_rejection_handler_atrrr)rBrr|rkr6rir)r)r*_reject_promises*rzPromise._reject_promisescCs|jrJt||j}|j}t|r(|s||dS|rd|_||||dS|rD|r/d|_|jtkr;||dS| ||j dSdSNT) rbr~ __class__rtcallable_settle_promise_from_handlerr\rdrYr[rh)rBrir6rUr} is_promiseasync_guaranteedr)r)r*r2s$    zPromise._settle_promisecCs |j}d|_|||||dSr&) _promise0r)rBr6rUr}rir)r)r*_settle_promise0NszPromise._settle_promise0cCs:t||\}}|r|\}}||d|dS||dS)NF)r;rWrl)rBr6rUri error_with_tberrorr:r)r)r*rYs z$Promise._settle_promise_from_handlercCs.|dksJ|jr J|j|tttSrs)rbrgetrrrBrr)r)r*rcs  zPromise._promise_atcC.|jrJ|dks J|j|tttSrs)rbrrrrrr)r)r*rk  zPromise._fulfillment_handler_atcCrrs)rbrrrrrr)r)r*rsrzPromise._rejection_handler_atcCs||j|j|jdSr&)_add_callbacksrnrmr)rBfollowerr)r)r*r_{s zPromise._migrate_callback0cCs$|||||||dSr&)rrrr)rBrrr)r)r*ras zPromise._migrate_callback_atcCs |jrJ|jdur i|_|j}|ttkrd}d|_|dkr@|jr$J|jr)J|jr.J||_t|r8||_t|r?||_n>|tt}|t |jvsOJ|t |jvsXJ|t |jvsaJ||j|t <t|rs||j|t <t|r~||j|t <|d|_|S)Nrr ) rbrr^ MAX_LENGTHrrrnrmrrrr)rBfulfillrMrirrr)r)r*rs8        zPromise._add_callbackscCs|}|jr |}|js|Sr&)rb _followee)rBretr)r)r*rKs zPromise._targetcCs |jsJt|jts J|jSr&rbr~rmr?rEr)r)r*rs zPromise._followeecCs$|jsJt|jtr J||_dSr&r)rBrir)r)r*rcs  zPromise._set_followeecCsr|j}|dkr7|jtkr!|j}|j}||j|||||n|j}||j|d|||d|_dSdSrs) r^r\rfrnrhrrmrr)rBrr|r}rUr)r)r*rus   zPromise._settle_promisesc sdfdd}dfdd }d}d}z|||Wnty4}z td}|}WYd}~nd}~wwd|durD|d|dSdS) NTcs|dSr&)rl)rUrEr)r*rSz/Promise._resolve_from_executor..resolvecs||dSr&rW)r|r}rBrr)r*rMz.Promise._resolve_from_executor..rejectr/Fr&)r5rrW)rBrCrSrMrr}r9r)rr*rAs   zPromise._resolve_from_executorcCst||dSr&)rvwait)clsritimeoutr)r)r*rsz Promise.waitcCs|||dSr&)r)rBrr)r)r*_waitsz Promise._waitcCs"|}||p t|jddS)NT)rp)rKrDEFAULT_TIMEOUT_target_settled_value)rBrtargetr)r)r*rs z Promise.getcCs||Sr&)rKrr)rBrpr)r)r*rrzPromise._target_settled_valuecCsrtt|}|jrd||S|j}|tkrd|S|tkr*d|t|j S|t kr7d|t|j SdS)Nzzz!z z) hexidrbrrKr\r]rdreprrmrfrn)rBhex_idstater)r)r*__repr__ s    zPromise.__repr__cC|jtkS)z^Indicate whether the Promise is still pending. Could be wrong the moment the function returns.)rKr\r]rEr)r)r* is_pendingzPromise.is_pendingcCr)z`Indicate whether the Promise has been fulfilled. Could be wrong the moment the function returns.)rKr\rdrEr)r)r* is_fulfilled"rzPromise.is_fulfilledcCr)z_Indicate whether the Promise has been rejected. Could be wrong the moment the function returns.)rKr\rfrEr)r)r* is_rejected(rzPromise.is_rejectedcCs |d|S)z This method returns a Promise and deals with rejected cases only. It behaves the same as calling Promise.then(None, on_rejection). N)then)rB on_rejectionr)r)r*catch.s z Promise.catchc Cs|}|}|j}|tkr|||||Sd}|tkr$|j}|}n |tkr0|j}|j }|}t t |j |||||j|Sr&)rrKr\r]rrdrmrfrnrhrvinvokerrr,) rB did_fulfill did_rejectrirrr}rUr6r)r)r*rG6s&z Promise._thencCs |||S)a This method takes two optional arguments. The first argument is used if the "self promise" is fulfilled and the other is used if the "self promise" is rejected. In either case, this method returns another promise that effectively represents the result of either the first of the second argument (in the case that the "self promise" is fulfilled or rejected, respectively). Each argument can be either: * None - Meaning no action is taken * A function - which will be called with either the value of the "self promise" or the reason for rejection of the "self promise". The function may return: * A value - which will be used to fulfill the promise returned by this method. * A promise - which, when fulfilled or rejected, will cascade its value or reason to the promise returned by this method. * A value - which will be assigned as either the value or the reason for the promise returned by this method when the "self promise" is either fulfilled or rejected, respectively. :type success: (Any) -> object :type failure: (Any) -> object :rtype : Promise )rG)rBrrr)r)r*rZs z Promise.thencCs|||}d|_dSr)rGry)rBrrrir)r)r*donexs  z Promise.donecCsl|sdS|D]-}t|tr|\}}|||qt|tr.|d}|d}|||q||qdS)zb :type handlers: list[(Any) -> object] | list[((Any) -> object, (Any) -> object)] Nsuccessfailure)r~tuplerdictr)rBhandlersr6sfr)r)r*done_all}s     zPromise.done_allcCs|sgSg}|D]6}t|tr|\}}||||qt|tr6|d}|d}||||q|||q|S)a Utility function which calls 'then' for each handler provided. Handler can either be a function in which case it is used as success handler, or a tuple containing the success and the failure handler, where each of them could be None. :type handlers: list[(Any) -> object] | list[((Any) -> object, (Any) -> object)] :param handlers :rtype : list[Promise] rr)r~rappendrrr)rBrpromisesr6rrr)r)r*then_alls     zPromise.then_allcsjj}t|tr|tur|jjSStr tj}t|r3fdd}||}|_|SS)Ncs.r t||dSt||dSr&)r_process_future_resultadd_done_callbackrSrMobjr)r*rCsz1Promise._try_convert_to_promise..executor) r issubclassr?rr@rris_future_likerF)rr_typerCrir)rr*rZs  zPromise._try_convert_to_promisecCs|}||d|Srr)rr|rr)r)r*rMs zPromise.rejectcCs*||s|}t|_||_|S||Sr&)rXrdr\rmrZ)rrrr)r)r*rSs  zPromise.resolvecs4ts tdStfdd}|S)NzRPromise.promisify is now a function decorator, please use Promise.resolve instead.csfdd}|S)Ncs|iSr&r)r)r7rr8r)r*rCrz4Promise.promisify..wrapper..executorr))r7r8rCrrr7r8r*wrappersz"Promise.promisify..wrapper)rrrSr)rrrr)rr* promisifys zPromise.promisifycs8ddlm}jstd_|fdd}|S)Nr)rcsjfddS)NcsiSr&r))v)r7fnr8r)r*sz/Promise.safe..wrapper..)_safe_resolved_promiserrrrrr*rszPromise.safe..wrapper) functoolsrrr?rS)rrrrr)rr*safes  z Promise.safecCst||djS)N) promise_class)rri)rrr)r)r*all sz Promise.allcs:ts |Sfdd}||S)a A special function that takes a dictionary of promises and turns them into a promise for a dictionary of values. In other words, this turns an dictionary of promises for values into a promise for a dictionary of values. cst|Sr&)zipkeys)resolved_values dict_typemr)r*handle_successrz(Promise.for_dict..handle_success)rorSrvaluesr)rrrr)rr*for_dicts   zPromise.for_dictcCs4|j}|dus |tvr dSt|tpt|pt|S)zs A utility function to determine if the specified object is a promise using "duck typing". NF)r BASE_TYPESrr?rr)rrrr)r)r*rX$s zPromise.is_thenable)NN)Fr&)FN)U__name__ __module__ __qualname____doc__r]r\ry _is_boundrbrtr^rrnrmrrFrh _is_waitingr@rDpropertyr,rJrL __await__rrQrVrlrrrYr[r{rWrrrrrrrrrr_rarrKrrcrurA classmethodrrrrrergrUr|rrrrrrGrrTrPrrrrrZrMrejectedrScast fulfilledrrrrrrXr)r)r)r*r?as              ,                       r?cCs$|tvrtt|ddt|<t|S)Nr)_type_done_callbacksrgetattr)rr)r)r*r9s  rcsfdd}|S)Nc sNz |WdSty&}ztd}||WYd}~dSd}~wwr4)resultr5r)rJr9r:rMrSr)r*handle_future_resultIs z4_process_future_result..handle_future_resultr))rSrMrr)rr*rGsr)R collectionsrrrrsysrr threadingrtypesrweakrefr sixr async_r compatr rrrutilsrrrrrr promise_listrschedulers.immediatertypingrrrrrrrr r!r"r#r$r%r(rvr+r- IS_PYTHON2rrrrrrsetboolfloatcomplexrlistrrr]rfrdr3r;r<r=r?rrrrpromise_for_dictrXrr)r)r)r*sf           Z