Y\c d Z ddlZddlZddlmZ ddlmZ ddlmZ ddl m
Z
ddl m Z dd l m
Z
dd
l mZ d Zd Zd
Zd Zd Zd Zd Ze
d Zd Zd dZd Zd Zd Zd Z d Z d Z G d d e
Z d d Z e dS )!zWThe code for async support. Importing this patches Jinja on supported
Python versions.
Nupdate_wrapper)Markup )TemplateModule) LoopContextconcat internalcode)missingc X K g fd} | d {V t S )Nc L K 2 3 d {V } | 6 d S N)append)event async_genrvs s/builddir/build/BUILD/imunify360-venv-2.6.2/opt/imunify360/venv/lib/python3.11/site-packages/jinja2/asyncsupport.pycollectz concat_async..collect sM $ % IIe %99s #r )r r r s ` @r concat_asyncr sP B '))OOOOOOO ":: c K t |i |} | | | 2 3 d {V }|W V
6 d S # t $ r | j W V Y d S w xY wr )dictroot_render_func new_context Exception environmenthandle_exception)selfargskwargsvarsr s r generate_asyncr$ s D2 001A1A$1G1GHH %KKKKK IHH 2 2 2 //1111111112s (A AA &A21A2c 8 d fd}t | S )Nc 3 K | j |i |} | | V *# t $ r Y d S w xY wr )r$ run_until_complete __anext__StopAsyncIteration)r loopr! r" r s r _convert_generatorz.wrap_generate_func.._convert_generator' sv 'D'888
E--i.A.A.C.CDDDDD
E! DD s +<
A
A
c r | j j s | g|R i |S | t j || S r )r is_asyncasyncioget_event_loop)r r! r" r+ original_generates r generatez$wrap_generate_func..generate/ sR ( <$$T;D;;;F;; ;!!$(>(@(@$OOOr r )r0 r1 r+ s ` @r wrap_generate_funcr2 & sJ P P P P P P
($5 6 66r c " K | j j st d t |i |}| | } t | | d {V S # t $ r | j cY S w xY w)Nz8The environment was not created with async mode enabled.) r r- RuntimeErrorr r r r r r )r r! r" r# ctxs r render_asyncr6 7 s $ WUVVV D
4
C3!$"7"7"<"<========= 3 3 3 00222223s 'A( (#B
Bc . fd}t | S )Nc | j j s | g|R i |S t j }| | j |i | S r )r r- r. r/ r' r6 )r r! r" r* original_renders r renderz wrap_render_func..renderE sf ( :"?49$999&99 9%''&&'8t'8$'I&'I'IJJJr r )r9 r: s ` r wrap_render_funcr; D s3 K K K K K &/ 2 22r c l t d t fd }t | S )Nc K t | j | j | j d {V }| j j j rt
| }|S r )r _stack_depth_contexteval_ctx
autoescaper r r s r
async_callz-wrap_block_reference_call..async_callO s[ 8 DK 8 G GHH
H
H
H
H
H
H = ! , B r c R | j j j s | S | S r )r@ r r- )r rD
original_calls r __call__z+wrap_block_reference_call..__call__V s3 }(1 ' =&& &z$ r r r )rF rG rD s ` @r wrap_block_reference_callrI N sY \ \
(M 2 22r c l t d t fd }t | S )Nc L K | j | d {V }|rt | }|S r )_funcr )r argumentsrB r s r async_invokez'wrap_macro_invoke..async_invoke` s> 4:y)
)
)
)
)
)
) B r c P | j j s
| || S | || S r ) _environmentr- )r rM rB rN original_invokes r _invokez"wrap_macro_invoke.._invokeg s: ) @"?4J?? ?|D)Z888r rH )rQ rR rN s ` @r wrap_macro_invokerS _ sY \ 9 9 9 9 9 \9
'? 3 33r c h K | j | j S | d {V x| _ }|S r )_modulemake_module_asyncrC s r get_default_module_asyncrW p sE | | " 4 4 6 66666666DL2
Ir c , t fd }|S )Nc P | j j rt d | S )Nz6Template module attribute is unavailable in async mode)r r- r4 )r original_default_modules r _get_default_modulez0wrap_default_module.._get_default_moduley s2 $ Y WXX X&&t,,,r r )rZ r[ s ` r wrap_default_moduler\ x s. - - - - \-
r Fc K | ||| }g }| | 2 3 d {V }| | 6 t | || S r )r r r r )r r# sharedlocalscontext body_streamitems r rV rV s tVV44GK++G44 ! ! ! ! ! ! !d4 5 $ 5 55s Ac z ddl m} t | j | _ t t
| j | _ t t | j | _ t | j | _ t | j
| _
t | _ t t | j
| _
d S )Nr Template) re r2 r1 r r$ r6 r; r: r\ r[ rW _get_default_module_asyncrV rd s r patch_templaterh s *8+<==H ,^X=T U UH *<9N O OH&x77HO#6x7S#T#TH )AH&!/85" "H r c z ddl m} m} t | j | _ t |j |_ d S )Nr BlockReferenceMacro)runtimerk rl rI rG rS rR rj s r
patch_runtimern sB ........ 78O P PN%em44EMMMr c H ddl m} ddlm} | | d S )Nr )FILTERS)
ASYNC_FILTERS)filtersrp asyncfiltersrq update)rp rq s r
patch_filtersru s> ++++++ NN=!!!!!r c Z t t t d S r )rh rn ru r r patch_allrx s$ OOOOOOOOr c B K t j | r| d {V S | S r )inspect isawaitable)values r
auto_awaitr} s0 5!! {{{{{{ Lr c b K t | d r| 2 3 d {V }|W V
6 d S | D ]}|W V d S )N __aiter__)hasattr)iterablerb s r
auto_aiterr s} x%% " $JJJJJ #
s "c e Zd Z ee Zed Zed Zed Z d Z
ed Z ed Z d Z
d Zd S )
AsyncLoopContextc > K | j | j S t | j | _ nl# t $ r_ d | j 2 d {V }| | | _ t | | j z | j t uz | _ Y nw xY w| j S )Nc " K g | 3 d {V }|
6 S r rw ).0xs r
z+AsyncLoopContext.length.. s. 88888888A8888s ) _lengthlen _iterable TypeError _iterator _to_iteratorindex_afterr
)r r s r lengthzAsyncLoopContext.length s < #< U t~..DLL U U U88 888888888H ! . .x 8 8DN x==4:5G9STDLLL U
|s , A&BBc 0 K | j d {V | j z
S r )r r r s r revindex0zAsyncLoopContext.revindex0 s' [ 4:--r c 0 K | j d {V | j z
S r )r index0r s r revindexzAsyncLoopContext.revindex s' [ 4;..r c K | j t ur| j S | j d {V | _ n # t $ r t | _ Y nw xY w| j S r )r r
r r( r) r s r
_peek_nextzAsyncLoopContext._peek_next sy ;g % %; " $ 8 8 : :::::::DKK! " " "!DKKK " {s $> AAc H K | d {V t u S r )r r
r s r lastzAsyncLoopContext.last s- __&&&&&&&&'11r c z K | d {V }|t u r| d S |S )Nzthere is no next item)r r
_undefinedrC s r nextitemzAsyncLoopContext.nextitem sH ??$$
$
$
$
$
$
$
==??#:;; ; r c | S r rw r s r r zAsyncLoopContext.__aiter__ s r c K | j t ur| j }t | _ n | j d {V }| xj dz
c_ | j | _ || _ || fS )Nr )r r
r r( r _current_beforerC s r r( zAsyncLoopContext.__anext__ sq ;g % %B!DKK~//11111111B q }
4xr N)__name__
__module__ __qualname__ staticmethodr r propertyr r r r r r r r( rw r r r r s <
++L
X . . X. / / X/ 2 2 X2 X
r r c l K dd l }| dt d t | ||| S )Nr zRThis template must be recompiled with at least Jinja 2.11, or it will fail in 3.0. )
stacklevel)warningswarnDeprecationWarningr )r undefinedrecursedepth0r s r make_async_loop_contextr sK OOO MM Hi& A AAr )NFN)Nr )!__doc__r. rz functoolsr
markupsafer r r rm r utilsr
r r
r r$ r2 r6 r; rI rS rW r\ rV rh rn ru rx r} r r r rw r r r s $ $ $ $ $ $ ' ' ' ' ' ' 2 2 27 7 7"
3
3
33 3 33 3 3"4 4 4" 6 6 6 6 5 5 5" " " > > > > >{ > > >B B B B B
r