/Jf%ddlZddlmZddlmZddlmZddlmZddl m Z ddl m Z m Z ejeZGd d ZGd d eZGd dZGddZdS)N) xform_name)ActionDocstring)inject_attribute)Action)create_request_parameters) RawHandlerResourceHandlerc eZdZdZddZdZdS) ServiceActiona A class representing a callable action on a resource, for example ``sqs.get_queue_by_name(...)`` or ``s3.Bucket('foo').delete()``. The action may construct parameters from existing resource identifiers and may return either a raw response or a new resource instance. :type action_model: :py:class`~boto3.resources.model.Action` :param action_model: The action model. :type factory: ResourceFactory :param factory: The factory that created the resource class to which this action is attached. :type service_context: :py:class:`~boto3.utils.ServiceContext` :param service_context: Context about the AWS service Nc||_|j}|r*t|j||||jj|_dSt|j|_dS)N) search_pathfactoryresource_modelservice_contextoperation_name) _action_modelresourcer pathrequest operation_response_handlerr )self action_modelrrresource_response_models Y/home/alex/cs2snipeproduction/venv/lib/python3.11/site-packages/boto3/resources/action.py__init__zServiceAction.__init__.sn)#/"7 " C%4386 /+3= &&&D " " "&0 0A%B%BD " " "ct|jjj}t ||jj}||t d|jj ||t|jj ||i|}t d|| |||S)a Perform the action's request operation after building operation parameters and build any defined resources from the response. :type parent: :py:class:`~boto3.resources.base.ServiceResource` :param parent: The resource instance to which this action is attached. :rtype: dict or ServiceResource or list(ServiceResource) :return: The response, either as a raw dict or resource instance(s). Calling %s:%s with %r Response: %r) rrrrrupdateloggerdebugmeta service_namegetattrclientr)rparentargskwargsrparamsresponses r__call__zServiceAction.__call__?s$D$6$>$HII +643E3MNN f # K $      ?76;-~>>OOO ^X...%%ffh???r)NN__name__ __module__ __qualname____doc__rr.rrr r sJ"CCCC"@@@@@rr ceZdZdZdZdS) BatchActiona An action which operates on a batch of items in a collection, typically a single page of results from the collection's underlying service operation call. For example, this allows you to delete up to 999 S3 objects in a single operation rather than calling ``.delete()`` on each one individually. :type action_model: :py:class`~boto3.resources.model.Action` :param action_model: The action model. :type factory: ResourceFactory :param factory: The factory that created the resource class to which this action is attached. :type service_context: :py:class:`~boto3.utils.ServiceContext` :param service_context: Context about the AWS service c>d}d}g}t|jjj}|D]}i} t |D]>\} } | | jj}| | jj}t| |jj| | ?| sn| |t d||| t|||i| } t d| |||| | |S)a Perform the batch action's operation on every page of results from the collection. :type parent: :py:class:`~boto3.resources.collection.ResourceCollection` :param parent: The collection iterator to which this action is attached. :rtype: list(dict) :return: A list of low-level response dicts from each call. N)r,indexr r!)rrrrpages enumerater%r&r(rr"r#r$r'appendr) rr)r*r+r&r( responsesrpager,r8rr-s rr.zBatchAction.__call__rsT  #D$6$>$HII LLNN O ODF#,T??  x '#+=#=L>%]1F)&.!   MM& ! ! ! LL'~v   7wv~66GGGH LL 2 2 2   T33FFHMM N N N NrN)r0r1r2r3r.r4rrr6r6_s-$66666rr6ceZdZdZdZdZdS) WaiterActiona/ A class representing a callable waiter action on a resource, for example ``s3.Bucket('foo').wait_until_bucket_exists()``. The waiter action may construct parameters from existing resource identifiers. :type waiter_model: :py:class`~boto3.resources.model.Waiter` :param waiter_model: The action waiter. :type waiter_resource_name: string :param waiter_resource_name: The name of the waiter action for the resource. It usually begins with a ``wait_until_`` c"||_||_dS)N) _waiter_model_waiter_resource_name)r waiter_modelwaiter_resource_names rrzWaiterAction.__init__s)%9"""rcvt|jj}t||j}||t d|jj|j ||jj }| |}|j di|}t d|dS)z Perform the wait operation after building operation parameters. :type parent: :py:class:`~boto3.resources.base.ServiceResource` :param parent: The resource instance to which this action is attached. r r!Nr4) rrA waiter_namerr"r#r$r%r&rBr( get_waiterwait) rr)r*r+client_waiter_namer,r(waiterr-s rr.zWaiterAction.__call__s((:(FGG +643EFF f # K $  &     #""#5666;(((( ^X.....rNr/r4rrr?r?s<  ::://///rr?ceZdZdZdZdZdS)CustomModeledActionz3A custom, modeled action to inject into a resource.c>||_||_||_||_dS)a :type action_name: str :param action_name: The name of the action to inject, e.g. 'delete_tags' :type action_model: dict :param action_model: A JSON definition of the action, as if it were part of the resource model. :type function: function :param function: The function to perform when the action is called. The first argument should be 'self', which will be the resource the function is to be called on. :type event_emitter: :py:class:`botocore.hooks.BaseEventHooks` :param event_emitter: The session event emitter. N)namemodelfunctionemitter)r action_namerrP event_emitters rrzCustomModeledAction.__init__s$$  !   $ rc |dd}t|j|ji}|j|j_t ||j||jd|j_ t||j|jdS)N.F) resource_namerSr service_modelinclude_signature) rsplitrrNrOrPr0rrQrXr3r)rclass_attributesr event_namer+rWactions rinjectzCustomModeledAction.injects"))#..r2  4:r22!%  /',)7# ! ! !   )49dmDDDDDrN)r0r1r2r3rr^r4rrrLrLs===%%%. E E E E ErrL)loggingbotocorerboto3.docs.docstringr boto3.utilsrrOrr,rr-r r getLoggerr0r#r r6r?rLr4rrrdse000000((((((------11111111  8 $ $@@@@@@@@@@@@@@@@FIIIII-IIIX././././././././b%E%E%E%E%E%E%E%E%E%Er