h|EVddlZddlZddlZddlZddlZddlmZddlmZddl m Z m Z m Z ddl m Z mZddlmZddlmZddlmZmZmZdd lmZdd lmZdd lmZdd lmZdd lmZ m!Z!m"Z"ddlm#Z#m$Z$m%Z%ddl m&Z&ddl'm(Z(dZ)dZ*eZ+ejXejZcZ.Z/da0ejbZ2da3da4iZ5ejleejle dZ7dZ8d!dZ9Gdde:Zde dfdZ;ee"Gdde:ZGdde:Z?dZ@d ZAe?e+ZBeBjZCeBjZDeBjZEeBjZFeBjZGeBjZHeBjZIeBjZJeBjZKeBjZLeBjZMeBjZNeBjZOeBjZPeBjZQeBjZReBjZSeBjZTejZUejZVy)"N)partialFailure) maybeDeferredDeferred DeferredList)succeedfail) IReactorTime)provider) IFailedFutureILogger log_levels)guess_stream_needs_encoding)_Config _BatchedTimer)_util)Logger formatEvent ILogObserver)globalLogBeginner formatTimeLogLevel)ensureDeferred)iscoroutinefunctionTFinfocyN)argskwargss D/var/www/Befach/backend/env/lib/python3.12/site-packages/txaio/tx.py_no_opr$Lsc.tj|yr) _categoriesupdate) categoriess r#add_log_categoriesr*Psz"r%c~|-tjtj|ur tdttS)NzTwisted has only a single, global reactor. You passed in a reactor different from the one already configured in txaio.config.loop)configloop RuntimeError_TxApi)r-s r# with_configr0Ts;  ;; "v{{$'>'  &>r%cDeZdZd dZd dZdZdZd dZdZd dZ d Z y) rNc|sJd||||_d|_|r|j|n|jtt j |y)Nz$Should not be instantiated directly.)observer namespaceF)_logger_log_level_set_explicitly set_log_level_set_log_level _log_level_loggersadd)selflevelloggerr4r3s r#__init__zLogger.__init__fsQ===vx9E ).&    u %    + Tr%c|Srr )r<oselftypes r#__get__zLogger.__get__ts  r%cd|vr0|dtvr%t}tj|d|d<|jj|g|i|y)N log_categoryformat)r'tuplegetr5emitr<r=r!r"s r#_logz Logger._log|sU V #~(>+(M7D*vn/EFF8  %1$1&1r%ctj|jtj|kry|dk(r|j|i|St j |}|j |g|i|S)Ntrace)rindexr9_tracer lookupByNamerKrJs r#rIz Logger.emitsp   DOO ,z/?/?/F F  G 4;;// /%%e,tyy0000r%c4|j|||_y)zt Set the log level. If keep is True, then it will not change along with global log changes. N)r8r6)r<r=keeps r#r7zLogger.set_log_levels E")-&r%c  tj|}ttD]\}}|dk(r ||kDrAt||d}|tk(r|t ||t|dk(s@t |dtRt||dtdfvsh|dk(rt |d|j n4t ||t|jtj||dk(st |d|j||_ y)NnoneerrorfailurerM) rrN enumerategetattrr$setattrrOrrKrrP_failurer9)r<r= desired_indexidxnamecurrents r#r8zLogger._set_log_levels#((/ ":.ICv~]"!$d3&(GOD$/7?D)V44t,>wgt{{; $ 8;P;PQU;V(Wwi?-/0 r%cB|jj|g|i|Sr)r5rV)r<rFr!kws r#rZzLogger._failures##t||##F8T8R88r%c,|j|ddi|y)N txaio_traceT)debug)r<r!r`s r#rOz Logger._traces  D1d1b1r%)NNNNrT) __name__ __module__ __qualname__r?rCrKrIr7r8rZrOr r%r#rrds+ 2 1. @92r%rctjj}d|jvr@|jdj}dj |j |j}nD|jd}|jjdk7r|dz|jjz}t||||}|S)Nr<z{0}.{1}rez.)r=r4r>r3) inspect currentframef_backf_locals __class__rFrfre f_globalsf_codeco_namer)r=r>r3cfclsr4s r# make_loggerrts     & &B kk&!++$$S^^S\\B LL, 99   *"C"))*;*;;I %9Vh WF Mr%ceZdZdZej ej ejejejejdZ dZ dZ dZ y) _LogObserverzQ Internal helper. An observer which formats events to a given file. )criticalrUwarnrrcrMc@||_t||_d|_yr)_filer_encode_levels)r<outs r#r?z_LogObserver.__init__s 237  r%c|j\tjt}tDcgc].}tj||kr|dk7r|j|0c}|_||jvScc}w)NrT)r|rrNr9to_tx)r<r= target_levellvls r#_acceptable_levelz_LogObserver._acceptable_levelso << %++J7L&##C(L8SF] 3DL  $$ s3A7c|drdjt|dt|dtj}|j r|j d}|jj|yd|vr|j|drodjt|dt|tj}|j r|j d}|jj|yyy)N log_formatz {0} {1}{2}log_time log_failureutf8 log_level) rFrfailure_format_tracebackoslinesepr{encoderzwriterr)r<eventmsgs r#__call__z_LogObserver.__call__s   &%%5,-(})=> C ||jj( JJ  S !e#(>(>u[?Q(R"))uZ01&JJ <<**V,C   %)S#r%N)rerfrg__doc__rrwrUrxrrcrr?rrr r%r#rvrvsK%%    E %&r%rvc"|tvr.tdj|djttryda|at t |r t|ag}tr|jttj|y)z[ Start logging to the file-like object in ``out``. By default, this is stdout. z'Invalid log level '{0}'; valid are: {1}z, NT) rr.rFjoin_started_loggingr9set_global_log_levelrv _observerappendrbeginLoggingTo)r}r= _observerss r# start_loggingrs J 5 < <tyy,   J$  % J)$$$Z0r%ceZdZdZdZdZdZeedfdZdZ ddZ d Z d Z d Z dd Zd ZddZddZddZddZdZddZdZdZy)r/c||_yr)_config)r<r,s r#r?z_TxApi.__init__6s  r%c dj|jjj|jS#t $rdj|cYSwxYw)z_ :param fail: must be an IFailedFuture returns a unicode error-message z{0}: {1}z+Failed to produce failure message for "{0}")rFvaluernregetErrorMessage Exceptionr<r s r#failure_messagez_TxApi.failure_message9s`  N$$ $$--$$$&  N@GGM M Ns>AAAc|jS)z\ :param fail: must be an IFailedFuture returns a traceback instance )tbrs r#failure_tracebackz_TxApi.failure_tracebackFs wwr%c tj}|j||jS#t$rdj |cYSwxYw)zP :param fail: must be an IFailedFuture returns a string )filez,Failed to format failure traceback for '{0}')ioStringIOprintTracebackgetvaluerrF)r<r fs r#rz_TxApi.failure_format_tracebackMsQ  O A D  Q '::<  OAHHN N Os69AANc|tur|tur tdt|}|turt|||S|tur t |||S)Nz"Cannot have both result and error.) canceller) _unspecified ValueErrorrresolvereject)r<resultrUrrs r# create_futurez_TxApi.create_futureYsY  %%|*CAB B y )  % Av , & 1e r%ct|Sr)r )r<rs r#create_future_successz_TxApi.create_future_successds vr%c*tt|Sr)r create_failure)r<rUs r#create_future_errorz_TxApi.create_future_errorgsN5)**r%ct|r t||i|St |g|i|S#t$r}t|cYd}~Sd}~wwxYwr)rr TypeErrorrr)r<funr!r"es r# as_futurez_TxApi.as_futurejsX s # .%c4&:6&:;;S242622 .*1-- .s- A  AA A c"t|tSr) isinstancer)r<objs r# is_futurez_TxApi.is_futuress#x((r%c^t|jj||g|i|Sr)r _get_loop callLater)r<delayrr!r"s r# call_laterz_TxApi.call_latervs-7|DNN,-77sTTTVTTr%c<fd}fd}t|dz|||S)a& Creates and returns an object implementing :class:`txaio.IBatchedTimer`. :param bucket_seconds: the number of seconds in each bucket. That is, a value of 5 means that any timeout within a 5 second window will be in the same bucket, and get notified at the same time. This is only accurate to "milliseconds". :param chunk_size: when "doing" the callbacks in a particular bucket, this controls how many we do at once before yielding to the reactor. c@jjSr)rseconds)r<sr# get_secondsz._TxApi.make_batched_timer..get_secondss>>#++- -r%cNjj||g|i|Sr)rr)rrr!r"r<s r#create_delayed_callz6_TxApi.make_batched_timer..create_delayed_calls)-4>>#--eSJ4J6J Jr%g@@)seconds_providerdelayed_call_creatorr)r<bucket_seconds chunk_sizerrs` r#make_batched_timerz_TxApi.make_batched_timerys. . K V # (!4   r%c|jSr)called)r<futures r# is_calledz_TxApi.is_calleds }}r%c&|j|yr)callback)r<rrs r#rz_TxApi.resolvesr%c| t}n7t|tr t|}nt|ts t d|j |y)Nz&reject requires a Failure or Exception)rrrrr.errback)r<rrUs r#rz _TxApi.rejectsD ="$E y )ENEeW-"#KLLur%c$|jyr)cancel)r<rrs r#rz _TxApi.cancels  r%c0|r t|StS)z Create a Failure instance. if ``exception`` is None (the default), we MUST be inside an "except" block. This encapsulates the exception into an object that implements IFailedFuture r)r< exceptions r#rz_TxApi.create_failures 9% %yr%cd|J||J|j||S|j|||S)z] callback or errback may be None, but at least one must be non-None. ) addErrback addCallbacks)r<rrrs r# add_callbacksz_TxApi.add_callbackssN !!!  & &&   g &    ' 2 r%cXfd}tt|}t||d|S)Ncng}|D],\}}|j||rr|j.|Sr)rraiseException)resrtnokrconsume_exceptionss r# completedz _TxApi.gather..completeds;C E 5!"4((*!Jr%) consumeErrors)rlistr)r<futuresrrdls ` r#gatherz _TxApi.gathers. $w-7I J b)T* r%cpt}|jj||jd|S)z Inline sleep for use in co-routines. :param delay: Time to sleep in seconds. :type delay: float N)rrrr)r<rds r#sleepz _TxApi.sleeps- J ""5!**d;r%c|jjddlm}||j_|jjS)z! internal helper r)reactor)rr-twisted.internetr)r<rs r#rz_TxApi._get_loops3 <<   $ 0 'DLL ||   r%r)drd)rerfrgr?rrrrrrrrrrrrrrrrrrrrr r%r#r/r/4sr N O$0|t +3)U 8   *  !r%r/cZtD] }|jr|j|"|ay)zH Set the global log level on all loggers instantiated by txaio. N)r:r6r8r9)r=items r#rrs,--    &Jr%ctSr)r9r r%r#get_global_log_levelrs r%r)Wrrsysweakrefrj functoolsrtwisted.python.failurertwisted.internet.deferrrrr r twisted.internet.interfacesr zope.interfacer txaio.interfacesr rr txaio._iotypertxaior txaio._commonrrtwisted.loggerr_Loggerrrrrrrasyncior using_twisted using_asyncior,stderrstdout_stderr_stdoutrWeakSetr:r9rr'registerr$r*r0objectrtrvrrr/rr _default_apirrrrrrrrrrrrrrrrrrtime_nsperf_counter_nsr r%r#rs 6 *HH04#??5'GGBB1'  ::szz  7??     w # Z2VZ2z7T& ,:&6:&:&zV1>x y!Vy!xf~ .. 22'@@** $::"66  " "  " "  $ $ !44  " "         ,,**    --''r%