509318396 آگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآ 3 sف¨\ئم@sdZddlZddlZddlZddlmZddlmZmZm Z ddl mZddlm Z mZdd„Zd d „Zdd„Zd d„Zdd„Zdd„Zdd„Zedd„ƒZdd„Zd.dd„Zdd„Zdd„Zd d!„Zd"d#„Zd$d%„Zd&d'„ZGd(d)„d)e ƒZGd*d+„d+e ƒZ!d/d,d-„Z"dS)0zْ jinja2.asyncsupport ~~~~~~~~~~~~~~~~~~~ Has all the code for async support which is implemented as a patch for supported Python versions. :copyright: (c) 2017 by the Jinja Team. :license: BSD, see LICENSE for more details. éN)عupdate_wrapper)عconcatعinternalcodeعMarkup)عTemplateModule)عLoopContextBaseع_last_iterationcƒs&g‰‡‡fdd„}|ƒIdHtˆƒS)Nc“s>x8ˆ2dHy3dH}Wn tk s.Xˆj|ƒq YWdS)N)عStopAsyncIterationعappend)عevent)ع async_genعrv©ْ"/usr/lib/python3.6/asyncsupport.pyعcollects"zconcat_async..collect)r)rrr)rr rعconcat_asyncsrcOs†t||ژ}yFx@|j|j|ƒƒ2dHy3dH}Wn tk sBX|Vq"YWWntk rltjƒ}YnXdS|jj|dƒVdS)NT) عdictعroot_render_funcعnew_contextr ع Exceptionعsysعexc_infoعenvironmentعhandle_exception)عselfعargsعkwargsعvarsrrrrrعgenerate_asyncs .rcs dd„‰‡‡fdd„}t|ˆƒS)Ncss@|j||ژ}yx|j|jƒƒVqWWntk r:YnXdS)N)rعrun_until_completeع __anext__r )rعlooprrrrrrع_convert_generator,sz.wrap_generate_func.._convert_generatorcs*|jjsˆ|f|‍|ژSˆ|tjƒ||ƒS)N)rعis_asyncعasyncioعget_event_loop)rrr)r"عoriginal_generaterrعgenerate3sz$wrap_generate_func..generate)r)r&r'r)r"r&rعwrap_generate_func+sr(cدsd|jjstdƒ‚t||ژ}|j|ƒ}yt|j|ƒƒIdHStk rTtj ƒ}YnX|jj |dƒS)Nz8The environment was not created with async mode enabled.T)rr#عRuntimeErrorrrrrrrrr)rrrrعctxrrrrعrender_async:s r+cs‡fdd„}t|ˆƒS)Ncs2|jjsˆ|f|‍|ژStjƒ}|j|j||ژƒS)N)rr#r$r%rr+)rrrr!)عoriginal_renderrrعrenderJsz wrap_render_func..render)r)r,r-r)r,rعwrap_render_funcIsr.cs(tdd„ƒ‰t‡‡fdd„ƒ}t|ˆƒS)Ncسs2t|j|j|jƒƒIdH}|jjjr.t|ƒ}|S)N)rZ_stackZ_depthع_contextZeval_ctxع autoescaper)rr rrrع async_callSs z-wrap_block_reference_call..async_callcs|jjjsˆ|ƒSˆ|ƒS)N)r/rr#)r)r1ع original_callrrع__call__Zs z+wrap_block_reference_call..__call__)rr)r2r3r)r1r2rعwrap_block_reference_callRsr4cs(tdd„ƒ‰t‡‡fdd„ƒ}t|ˆƒS)Ncسs |j|ژIdH}|rt|ƒ}|S)N)Z_funcr)rع argumentsr0r rrrعasync_invokedsz'wrap_macro_invoke..async_invokecs |jjsˆ|||ƒSˆ|||ƒS)N)Z_environmentr#)rr5r0)r6عoriginal_invokerrع_invokeksz"wrap_macro_invoke.._invoke)rr)r7r8r)r6r7rعwrap_macro_invokecsr9cأs(|jdk r|jS|jƒIdH|_}|S)N)ع_moduleعmake_module_async)rr rrrعget_default_module_asyncss r<cst‡fdd„ƒ}|S)Ncs|jjrtdƒ‚ˆ|ƒS)Nz6Template module attribute is unavailable in async mode)rr#r))r)عoriginal_default_modulerrع_get_default_module|sz0wrap_default_module.._get_default_module)r)r=r>r)r=rعwrap_default_module{sr?Fcأs^|j|||ƒ}g}x>|j|ƒ2dHy3dH}Wn tk sFX|j|ƒq"YWt|||ƒS)N)rrr r r)rrZsharedعlocalsعcontextZbody_streamعitemrrrr;…s (r;cCsdddlm}t|jƒ|_tt|jƒ|_tt|jƒ|_t|jƒ|_t |j ƒ|_ t|_tt |j ƒ|_ dS)Nr)عTemplate)Zjinja2rCr(r'rrr+r.r-r?r>r<Z_get_default_module_asyncr;)rCrrrعpatch_templateچs rDcCs,ddlm}m}t|jƒ|_t|jƒ|_dS)Nr)عBlockReferenceعMacro)عjinja2.runtimerErFr4r3r9r8)rErFrrrع patch_runtimeœs rHcCs&ddlm}ddlm}|j|ƒdS)Nr)عFILTERS)ع ASYNC_FILTERS)Zjinja2.filtersrIZjinja2.asyncfiltersrJعupdate)rIrJrrrع patch_filters£srLcCstƒtƒtƒdS)N)rDrHrLrrrrع patch_all©srMcأstj|ƒr|IdHS|S)N)عinspectZisawaitable)عvaluerrrع auto_await¯s rPcCs\t|dƒrDx4|2dHy3dH}Wn tk s4X|VqYWdSx|D] }|VqJWdS)Nع __aiter__)عhasattrr )عiterablerBrrrع auto_aiterµs " rTc@s*eZdZd dd„Zedd„ƒZdd„ZdS) عAsyncLoopContextNrcCs&tj||||ƒ||_||_||_dS)N)rع__init__ع_async_iteratorع_afterع_length)rعasync_iteratorع undefinedعafterعlengthعrecurseعdepth0rrrrVہszAsyncLoopContext.__init__cCs|jdkrtdƒ‚|jS)NzHLoop length for some iterators cannot be lazily calculated in async mode)rYع TypeError)rrrrr]اs zAsyncLoopContext.lengthcCst|ƒS)N)عAsyncLoopContextIterator)rrrrrQخszAsyncLoopContext.__aiter__)Nr)ع__name__ع __module__ع__qualname__rVعpropertyr]rQrrrrrU¾s rUc@s(eZdZd Zdd„Zdd„Zdd„ZdS) rarAcCs ||_dS)N)rA)rrArrrrVصsz!AsyncLoopContextIterator.__init__cCs|S)Nr)rrrrrQطsz"AsyncLoopContextIterator.__aiter__cأsp|j}|jd7_|jtkr$tƒ‚|j|_|j|_y|jjƒIdH|_Wntk rdt|_YnX|j|fS)Né) rAZindex0rXrr Z_currentZ_beforerWr )rr*rrrr غs z"AsyncLoopContextIterator.__anext__N)rA)rbrcrdع __slots__rVrQr rrrrraزsracأsŒyt|ƒ}Wn8ttfk rDt|dƒss4