⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.144
Server IP:
157.245.143.252
Server:
Linux www 6.11.0-9-generic #9-Ubuntu SMP PREEMPT_DYNAMIC Mon Oct 14 13:19:59 UTC 2024 x86_64
Server Software:
nginx/1.26.0
PHP Version:
8.3.11
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
lib
/
python3
/
dist-packages
/
botocore
/
__pycache__
/
View File Name :
hooks.cpython-312.pyc
Pea d dl Z d dlZd dlmZmZ d dlmZ d dlmZ ej e Z edg d Z d Z dZdZ G d de Zdd Z G d d Z G d de Z G d de Z G d d Zy) N)deque namedtuple)accepts_kwargs) EVENT_ALIASESNodeList)firstmiddlelast c e Zd Zd Zy)r c t j | j }t j | j }t j | j }t ||| }|S N)copyr r r r )self first_copy middle_copy last_copycopieds 0/usr/lib/python3/dist-packages/botocore/hooks.py__copy__zNodeList.__copy__ sK YYtzz* ii , IIdii( *k9= N)__name__ __module__ __qualname__r r r r r s r c , | D ] }|d |d c S |S )a Find first non None response in a list of tuples. This function can be used to find the first non None response from handlers connected to an event. This is useful if you are interested in the returned responses from event handlers. Example usage:: print(first_non_none_response([(func1, None), (func2, 'foo'), (func3, 'bar')])) # This will print 'foo' :type responses: list of tuples :param responses: The responses from the ``EventHooks.emit`` method. This is a list of tuples, and each tuple is (handler, handler_response). :param default: If no non-None responses are found, then this default value will be returned. :return: The first non-None response in the list of tuples. r r ) responsesdefaultresponses r first_non_none_responser! & s) , A; "A; Nr c P e Zd Zd Z d dZ d dZ d dZd Z d dZd Z d Z y) BaseEventHooksc g S )a Call all handlers subscribed to an event. :type event_name: str :param event_name: The name of the event to emit. :type **kwargs: dict :param **kwargs: Arbitrary kwargs to pass through to the subscribed handlers. The ``event_name`` will be injected into the kwargs so it's not necessary to add this to **kwargs. :rtype: list of tuples :return: A list of ``(handler_func, handler_func_return_value)`` r r event_namekwargss r emitzBaseEventHooks.emitC s r Nc D | j |||| j | y)a@ Register an event handler for a given event. If a ``unique_id`` is given, the handler will not be registered if a handler with the ``unique_id`` has already been registered. Handlers are called in the order they have been registered. Note handlers can also be registered with ``register_first()`` and ``register_last()``. All handlers registered with ``register_first()`` are called before handlers registered with ``register()`` which are called before handlers registered with ``register_last()``. register_methodunique_id_uses_countN)_verify_and_register _registerr r& handler unique_idr, s r registerzBaseEventHooks.registerT s* !! NN!5 " r c D | j |||| j | y)zRegister an event handler to be called first for an event. All event handlers registered with ``register_first()`` will be called before handlers registered with ``register()`` and ``register_last()``. r* N)r- _register_firstr/ s r register_firstz BaseEventHooks.register_firstl s, !! 0 0!5 " r c D | j |||| j | y)zRegister an event handler to be called last for an event. All event handlers registered with ``register_last()`` will be called after handlers registered with ``register_first()`` and ``register()``. r* N)r- _register_lastr/ s r register_lastz BaseEventHooks.register_last~ s, !! / /!5 " r c ^ | j | | j | ||||| y r )_verify_is_callable_verify_accept_kwargs)r r& r0 r1 r+ r, s r r- z#BaseEventHooks._verify_and_register s/ ) ""7+ GY8LMr c y)zUnregister an event handler for a given event. If no ``unique_id`` was given during registration, then the first instance of the event handler is removed (if the event handler has been registered multiple times). Nr r/ s r unregisterzBaseEventHooks.unregister s r c 6 t | st d|z y )Nz"Event handler %s must be callable.)callable ValueErrorr funcs r r: z"BaseEventHooks._verify_is_callable s ~ AD HI I r c X t | st d| d y# t $ r Y yw xY w)zVerifies a callable accepts kwargs :type func: callable :param func: A callable object. :returns: True, if ``func`` accepts kwargs, otherwise False. zEvent handler z) must accept keyword arguments (**kwargs)FN)r r@ TypeErrorrA s r r; z$BaseEventHooks._verify_accept_kwargs sF !$' $TF ++ , ( s ))NFNNF) r r r r( r2 r5 r8 r- r= r: r; r r r r# r# B sL $ IN 2 IN & IN " N " Jr r# c ^ e Zd Zd Zd dZd Zd Z d dZ d dZ d dZ d Z dd Z d Z y)HierarchicalEmitterc > i | _ t | _ i | _ y r ) _lookup_cache _PrefixTrie _handlers_unique_id_handlersr s r __init__z HierarchicalEmitter.__init__ s $ $& r c 4 g }| j j | }|+| j j | }|| j |< n|sg S ||d< g }|D ]= }t j d|| |di |}|j ||f |s8|;|c S |S )a Emit an event with optional keyword arguments. :type event_name: string :param event_name: Name of the event :type kwargs: dict :param kwargs: Arguments to be passed to the handler functions. :type stop_on_response: boolean :param stop_on_response: Whether to stop on the first non-None response. If False, then all handlers will be called. This is especially useful to handlers which mutate data and then want to stop propagation of the event. :rtype: list :return: List of (handler, response) tuples from all processed handlers. r& z Event %s: calling handler %sr )rJ getrL prefix_searchloggerdebugappend)r r& r' stop_on_responser handlers_to_callr0 r s r _emitzHierarchicalEmitter._emit s $ --11*= # #~~ ; ;J G -=D z *! I )| 'G LL7W M ((H gx 0 1 H$8 ( r c & | j || S )a; Emit an event by name with arguments passed as keyword args. >>> responses = emitter.emit( ... 'my-event.service.operation', arg1='one', arg2='two') :rtype: list :return: List of (handler, response) tuples from all processed handlers. rX r% s r r( zHierarchicalEmitter.emit s zz*f--r c : | j ||d }|r|d S y)a Emit an event by name with arguments passed as keyword args, until the first non-``None`` response is received. This method prevents subsequent handlers from being invoked. >>> handler, response = emitter.emit_until_response( 'my-event.service.operation', arg1='one', arg2='two') :rtype: tuple :return: The first (handler, response) tuple where the response is not ``None``, otherwise (``None``, ``None``). T)rV )NNrZ )r r& r' r s r emit_until_responsez'HierarchicalEmitter.emit_until_response s( JJz6DJI R= r Nc 8 | j ||||t y Nsection)_register_section_MIDDLEr/ s r r. z HierarchicalEmitter._register s& r c 8 | j ||||t y r_ )rb _FIRSTr/ s r r4 z#HierarchicalEmitter._register_first s& r c 8 | j ||||t y r_ )rb _LASTr/ s r r7 z"HierarchicalEmitter._register_last+ s# ,@% r c ||| j v r]| j | j dd }|r+|st d|z | j | dxx dz cc< y |rt d|z y | j j ||| d|i}|rd|d< || j |< i | _ y | j j ||| i | _ y )NcountzInitial registration of unique id %s was specified to use a counter. Subsequent register calls to unique id must specify use of a counter as well.r zInitial registration of unique id %s was specified to not use a counter. Subsequent register calls to unique id must specify not to use a counter as well.r` r0 )rM rQ r@ rL append_itemrJ )r r& r0 r1 r, ra ri unique_id_handler_items r rb z%HierarchicalEmitter._register_section2 s D 4 44 00;??N' ( ' *3 3 00;GDID ( 5 8A A ** + +4W)=&'67*736L((3 NN & &z7G & L r c | | j | j dd }|rO|t d|z |dk( r | j j | d }nI| j | dxx dz cc< y |rt d|z | j j | d } | j j || i | _ y # t $ r Y y w xY w# t $ r Y y w xY w)Nri zInitial registration of unique id %s was specified to use a counter. Subsequent unregister calls to unique id must specify use of a counter as well.r r0 zInitial registration of unique id %s was specified to not use a counter. Subsequent unregister calls to unique id must specify not to use a counter as well.)rM rQ KeyErrorr@ poprL remove_itemrJ )r r& r0 r1 r, ri s r r= z HierarchicalEmitter.unregister^ s 00;??N $=$DFOP aZ " 6 6 : :9 E! G ,,Y7@AE@$ #,, 2266yA)L NN & &z7 ;!#D ; < s# C ##C CC C"!C"c | j }| j j }t j | j |d< t j | j |d< ||_ |S )NrL rM ) __class____dict__r rL rM )r new_instance new_states r r z HierarchicalEmitter.__copy__ s_ ~~' MM&&( !%4>>!: + +/99T5M5M+N '( ) r )FrE rF ) r r r rO rX r( r] r. r4 r7 rb r= r r r r rH rH sW &&P . ( IN IN DI * ^ " )V r rH c ^ e Zd Zd dZd Zd Z d dZ d dZ d dZ ddZ d Z d Z d Z y) EventAliaserNc H || _ | t | _ i | _ || _ y r )_event_aliasesr _alias_name_cache_emitter)r event_emitter event_aliasess r rO zEventAliaser.__init__ s' + "/D !# % r c ^ | j | } | j j |fi |S r )_alias_event_namerz r( r r& r' aliased_event_names r r( zEventAliaser.emit s0 ! 3 3J ?!t}}!!"4???r c ^ | j | } | j j |fi |S r )r~ rz r] r s r r] z EventAliaser.emit_until_response s0 ! 3 3J ?0t}}001CNvNNr c ` | j | }| j j |||| S r )r~ rz r2 r r& r0 r1 r, r s r r2 zEventAliaser.register s6 " 3 3J ?}}%% 4H r c ` | j | }| j j |||| S r )r~ rz r5 r s r r5 zEventAliaser.register_first s6 " 3 3J ?}}++ 4H r c ` | j | }| j j |||| S r )r~ rz r8 r s r r8 zEventAliaser.register_last s6 " 3 3J ?}}** 4H r c ` | j | }| j j |||| S r )r~ rz r= r s r r= zEventAliaser.unregister s6 " 3 3J ?}}'' 4H r c || j v r| j | S | j j D ] \ }}|j d }d|vr |||j | < n*||v r%|j d }| j ||| n[dj | }t j d| d| || j |< |c S || j |< |S # t $ r Y w xY w)N.zChanging event name from z to ) ry rx itemssplitindexr@ _replace_subsectionjoinrS rT )r r& old_partnew_part event_parts old_partsnew_names r r~ z EventAliaser._alias_event_name s // /))*5 5"&"5"5";";"= Hh %**3/K(" @HK 1 1( ;< Z' $NN3 / ((iJxx ,H LL+J<tH:F 2:D " ": .O9 #>< .8 z*' " s C$$ C0/C0c t t | D ]6 }|| |d k( s|||t | z |k( s$|g|||t | z y y )Nr )rangelen)r sectionsr r is r r z EventAliaser._replace_subsection sW s8}%A y|+ QS^!34 A4<:QY /0 &r c | j t j | j t j | j S r )rq r rz rx rN s r r zEventAliaser.__copy__ s4 ~~ IIdmm $dii0C0C&D r r rE rF ) r r r rO r( r] r2 r5 r8 r= r~ r r r r r rv rv sW &@O IN IN IN " #J r rv c D e Zd ZdZd ZefdZd Zd Zd Z d Z d Z d Z y ) rK aj Specialized prefix trie that handles wildcards. The prefixes in this case are based on dot separated names so 'foo.bar.baz' is:: foo -> bar -> baz Wildcard support just means that having a key such as 'foo.bar.*.baz' will be matched with a call to ``get_items(key='foo.bar.ANYTHING.baz')``. You can think of this prefix trie as the equivalent as defaultdict(list), except that it can do prefix searches: foo.bar.baz -> A foo.bar -> B foo -> C Calling ``get_items('foo.bar.baz')`` will return [A + B + C], from most specific to least specific. c d i d d| _ y )N)chunkchildrenvalues)_rootrN s r rO z_PrefixTrie.__init__ s $tD r c |j d }| j }|D ]" }||d vr|di d}||d |< |}|d | }$ |d t g g g |d< |d | j | y)zAdd an item to a key. If a value is already associated with that key, the new value is appended to the list for the key. r r N)r r r r )r r r rU )r keyvaluera key_partscurrentpart new_childs r rj z_PrefixTrie.append_item s IIcN ** D7:..&*d K ,5 #D)#!*-d3 8 $ (R 4GH '"))%0r c | t }|j d }| j }| j |||d |S )zCollect all items that are prefixes of key. Prefix in this case are delineated by '.' characters so 'foo.bar.baz' is a 3 chunk sequence of 3 "prefixes" ( "foo", "bar", and "baz"). r r )r r r _get_items)r r collectedr r s r rR z_PrefixTrie.prefix_search, s9 G IIcN ** Iq9r c ||fg}t | }|r|j \ }}|d rE|d } | j | j z | j z } |j t | ||k( sY|d } | j || } | j d } |dz }| |j | |f | |j | |f |ry y )Nr r *r ) r rn r r r extendleftreversedrQ rU )r starting_noder r starting_indexstack key_parts_len current_noder node_listcomplete_orderr directswildcard next_indexs r r z_PrefixTrie._get_items: s 01I "'))+ L%H% ) 2 OOi&6&66 G $$Xn%=>M)' 3",,y'78#<<, "QY 'LL(J!78&LL':!67/ r c h |j d }| j }| j |||d y)zRemove an item associated with a key. If the value is not associated with the key a ``ValueError`` will be raised. If the key does not exist in the trie, a ``ValueError`` will be raised. r r )r N)r r _remove_item)r r r r r s r ro z_PrefixTrie.remove_itemZ s1 IIcN ** '9e1=r c |y |t | k r|d j || }|| j ||||dz |t | dz k( r|d }||j v r |j j | nS||j v r |j j | n)||j v r|j j | |d s|d s |d || = y y y t ddj | y )Nr r r zkey is not in trie: r ) r rQ r r remover r r@ r )r r r r r next_noder s r r z_PrefixTrie._remove_itemf s S^ #$Z044Yu5EFI$!!)YuqyIC NQ .. )( 3I /!..u5 )"2"22!((//6 )..0!--e4 ,Yx5H %Z051AB 6I, !#78K7L!MNN' $r c j | j }| j | j }||_ |S r )rq _recursive_copyrr )r new_copy copied_attrss r r z_PrefixTrie.__copy__~ s1 >>#++DMM: (r c i }|j D ]X \ }}t |t rt j | ||< /t |t r| j | ||< T|||< Z |S r )r isinstancer r dictr )r node copied_noder r s r r z_PrefixTrie._recursive_copy sk **,JC%*#'99U#3 C E4(#'#7#7#> C #( C ' r N) r r r __doc__rO rc rj rR r ro r r r r r r rK rK s7 ,E /6 1& 8@ >O0 r rK r )r logging collectionsr r botocore.compatr botocore.utilsr getLoggerr rS _NodeListre rc rg r r! r# rH rv rK r r r <module>r s ) * ( 8 $ z#> ? y 8} }@M . M `e > e PZ Zr