HEX
Server: LiteSpeed
System: Linux php-prod-1.spaceapp.ru 5.15.0-157-generic #167-Ubuntu SMP Wed Sep 17 21:35:53 UTC 2025 x86_64
User: sport3497 (1034)
PHP: 8.1.33
Disabled: NONE
$ pwd: /usr/local/CyberCP/lib64/python3.10/site-packages/botocore/__pycache__/
Upload Files
File: //usr/local/CyberCP/lib64/python3.10/site-packages/botocore/__pycache__/monitoring.cpython-310.pyc
o

�huP�@s�ddlZddlZddlZddlZddlmZmZmZddlm	Z
e�e�Z
Gdd�d�ZGdd�d�ZGdd	�d	�ZGd
d�de�ZGdd
�d
e�ZGdd�d�ZGdd�d�ZdS)�N)�ensure_bytes�ensure_unicode�urlparse)�
EXCEPTION_MAPc@s,eZdZgd�Zdd�Zdd�Zdd�ZdS)	�Monitor)zbefore-parameter-buildzrequest-createdzresponse-receivedz
after-callzafter-call-errorcCs||_||_dS)z�Abstraction for monitoring clients API calls

        :param adapter: An adapter that takes event emitter events
            and produces monitor events

        :param publisher: A publisher for generated monitor events
        N)�_adapter�
_publisher)�self�adapter�	publisher�r�F/usr/local/CyberCP/lib/python3.10/site-packages/botocore/monitoring.py�__init__!s
zMonitor.__init__cCs|jD]	}|�||j�qdS)z(Register an event emitter to the monitorN)�_EVENTS_TO_REGISTER�
register_last�capture)r	�
event_emitter�event_to_registerrrr
�register,s
�zMonitor.registerc
Ksdz|j�||�}|r|j�|�WdSWdSty1}ztjd||dd�WYd}~dSd}~ww)z�Captures an incoming event from the event emitter

        It will feed an event emitter event to the monitor's adaptor to create
        a monitor event and then publish that event to the monitor's publisher.
        z:Exception %s raised by client monitor in handling event %sT)�exc_infoN)r�feedr�publish�	Exception�logger�debug)r	�
event_name�payload�
monitor_event�errr
r1s����zMonitor.captureN)�__name__�
__module__�__qualname__rrrrrrrr
rs
rc@sreZdZejfdd�Zdd�Zdd�Zdd�Zd	d
�Zdd�Z	d
d�Z
dd�Zdd�Zdd�Z
dd�Zdd�ZdS)�MonitorEventAdaptercCs
||_dS)z�Adapts event emitter events to produce monitor events

        :type time: callable
        :param time: A callable that produces the current time
        N)�_time)r	�timerrr
rEs
zMonitorEventAdapter.__init__cCs|�|�di|��S)a�Feed an event emitter event to generate a monitor event

        :type emitter_event_name: str
        :param emitter_event_name: The name of the event emitted

        :type emitter_payload: dict
        :param emitter_payload: The payload to associated to the event
            emitted

        :rtype: BaseMonitorEvent
        :returns: A monitor event based on the event emitter events
            fired
        Nr)�_get_handler)r	�emitter_event_name�emitter_payloadrrr
rMszMonitorEventAdapter.feedcCs t|d|�d�d�dd��S)N�_handle_�.r�-�_)�getattr�split�replace)r	rrrr
r%]s�z MonitorEventAdapter._get_handlercKs t|jj|j|��d�|d<dS)N��service�	operation�	timestamp�current_api_call_event)�APICallEvent�
service_model�
service_id�	wire_name�_get_current_time)r	�model�context�kwargsrrr
�_handle_before_parameter_buildbs
�z2MonitorEventAdapter._handle_before_parameter_buildcKs6|j}|dj|��d�}|j|_|j|_||d<dS)Nr3)r2�current_api_call_attempt_event)r:�new_api_call_attemptr8�headers�request_headers�url)r	�requestr;r:�new_attempt_eventrrr
�_handle_request_createdis��z+MonitorEventAdapter._handle_request_createdcKsT|�d�}|�|�|_|dur%|dd|_|dd|_|�d�|_|S||_|S)Nr=�ResponseMetadata�HTTPStatusCode�HTTPHeaders�Error)�pop�_get_latency�latency�http_status_code�response_headers�get�parsed_error�wire_exception)r	�parsed_responser:�	exceptionr;�
attempt_eventrrr
�_handle_response_receivedrs"
�����z-MonitorEventAdapter._handle_response_receivedcKs |d�dd�|d_|�|�S)NrE�MaxAttemptsReachedFr3)rN�retries_exceeded�_complete_api_call)r	r:�parsedr;rrr
�_handle_after_call�s��
z&MonitorEventAdapter._handle_after_callcKs|�|�|d_|�|�S�Nr3)�_is_retryable_exceptionrVrW)r	r:rRr;rrr
�_handle_after_call_error�s��
z,MonitorEventAdapter._handle_after_call_errorcCst|ttd��S)N�GENERAL_CONNECTION_ERROR)�
isinstance�tuple�RETRYABLE_EXCEPTIONS)r	rRrrr
r[�s�z+MonitorEventAdapter._is_retryable_exceptioncCs|�d�}|�|�|_|SrZ)rIrJrK)r	r:�
call_eventrrr
rW�s
z&MonitorEventAdapter._complete_api_callcCs|��|jS�N)r8r2�r	�eventrrr
rJ�sz MonitorEventAdapter._get_latencycCst|��d�S)Ni�)�intr#�r	rrr
r8�sz%MonitorEventAdapter._get_current_timeN)rr r!r$rrr%r<rDrTrYr\r[rWrJr8rrrr
r"Ds	
r"c@s$eZdZdd�Zdd�Zdd�ZdS)�BaseMonitorEventcCs||_||_||_dS)a�Base monitor event

        :type service: str
        :param service: A string identifying the service associated to
            the event

        :type operation: str
        :param operation: A string identifying the operation of service
            associated to the event

        :type timestamp: int
        :param timestamp: Epoch time in milliseconds from when the event began
        Nr/)r	r0r1r2rrr
r�s
zBaseMonitorEvent.__init__cCs|jj�d|j�d�S)N�(�))�	__class__r�__dict__rfrrr
�__repr__�szBaseMonitorEvent.__repr__cCst||j�r|j|jkSdS)NF)r^rjrk)r	�otherrrr
�__eq__�szBaseMonitorEvent.__eq__N)rr r!rrlrnrrrr
rg�srgcs,eZdZ			d�fdd�	Zdd�Z�ZS)r4NFcs6t�j|||d�||_||_|durg|_||_dS)a�Monitor event for a single API call

        This event corresponds to a single client method call, which includes
        every HTTP requests attempt made in order to complete the client call

        :type service: str
        :param service: A string identifying the service associated to
            the event

        :type operation: str
        :param operation: A string identifying the operation of service
            associated to the event

        :type timestamp: int
        :param timestamp: Epoch time in milliseconds from when the event began

        :type latency: int
        :param latency: The time in milliseconds to complete the client call

        :type attempts: list
        :param attempts: The list of APICallAttempts associated to the
            APICall

        :type retries_exceeded: bool
        :param retries_exceeded: True if API call exceeded retries. False
            otherwise
        r/N)�superrrK�attemptsrV)r	r0r1r2rKrprV�rjrr
r�s$�
zAPICallEvent.__init__cCs"t|j|j|d�}|j�|�|S)z�Instantiates APICallAttemptEvent associated to the APICallEvent

        :type timestamp: int
        :param timestamp: Epoch time in milliseconds to associate to the
            APICallAttemptEvent
        r/)�APICallAttemptEventr0r1rp�append)r	r2rSrrr
r>�s

�z!APICallEvent.new_api_call_attempt)NNF)rr r!rr>�
__classcell__rrrqr
r4�s�-r4cs,eZdZ							d�fdd�	Z�ZS)rrNcs@t�j|||d�||_||_||_||_||_|	|_|
|_dS)a�Monitor event for a single API call attempt

        This event corresponds to a single HTTP request attempt in completing
        the entire client method call.

        :type service: str
        :param service: A string identifying the service associated to
            the event

        :type operation: str
        :param operation: A string identifying the operation of service
            associated to the event

        :type timestamp: int
        :param timestamp: Epoch time in milliseconds from when the HTTP request
            started

        :type latency: int
        :param latency: The time in milliseconds to complete the HTTP request
            whether it succeeded or failed

        :type url: str
        :param url: The URL the attempt was sent to

        :type http_status_code: int
        :param http_status_code: The HTTP status code of the HTTP response
            if there was a response

        :type request_headers: dict
        :param request_headers: The HTTP headers sent in making the HTTP
            request

        :type response_headers: dict
        :param response_headers: The HTTP headers returned in the HTTP response
            if there was a response

        :type parsed_error: dict
        :param parsed_error: The error parsed if the service returned an
            error back

        :type wire_exception: Exception
        :param wire_exception: The exception raised in sending the HTTP
            request (i.e. ConnectionError)
        r/N)	rorrKrArLr@rMrOrP)r	r0r1r2rKrArLr@rMrOrPrqrr
r�s9�
zAPICallAttemptEvent.__init__)NNNNNNN)rr r!rrtrrrqr
rr�s�rrc@seZdZdZdZdZdZdZdddd�Ze	�
d	�e	�
d
�d�Zgd�Zd
d�Z
dd�Zdd�Zdd�Zdd�Zdd�Zdd�Zdd�Zdd�Zdd �Zd!d"�Zd#d$�Zd%d&�Zd'd(�Zd)d*�Zd+d,�Zd-d.�Zd/d0�Zd1d2�Zd3d4�Z d5d6�Z!d7d8�Z"d9d:�Z#d;d<�Z$d=d>�Z%d?S)@�
CSMSerializer���i�XAmznRequestId�
XAmzRequestId�XAmzId2)zx-amzn-requestidzx-amz-request-idz
x-amz-id-2zSAWS4-HMAC-SHA256 Credential=(?P<access_key>\w+)/\d+/(?P<signing_region>[a-z0-9-]+)/zAWS (?P<access_key>\w+):)�v4�s3)r0r1r2rprKrVrAr@rLrMrOrPcCs|�|�||_dS)z�Serializes monitor events to CSM (Client Side Monitoring) format

        :type csm_client_id: str
        :param csm_client_id: The application identifier to associate
            to the serialized events
        N)�_validate_client_id�
csm_client_id�r	rrrr
rds

zCSMSerializer.__init__cCs*t|�|jkrtd|�d|j�d���dS)Nz&The value provided for csm_client_id: z exceeds the maximum length of z characters)�len�_MAX_CLIENT_ID_LENGTH�
ValueErrorr�rrr
r~ns���z!CSMSerializer._validate_client_idcCsf|�|�}|�|�}||d<|jD]}t||d�}|dur)t|d|�|||d�qttj|dd��S)z�Serializes a monitor event to the CSM format

        :type event: BaseMonitorEvent
        :param event: The event to serialize to bytes

        :rtype: bytes
        :returns: The CSM serialized form of the event
        �TypeN�_serialize_)�
event_type)�,�:)�
separators)�_get_base_event_dict�_get_event_type�_SERIALIZEABLE_EVENT_PROPERTIESr,r�json�dumps)r	rd�
event_dictr��attr�valuerrr
�	serializeus
	

��zCSMSerializer.serializecCsd|jd�S)N�)�Version�ClientId)rrcrrr
r��s�z"CSMSerializer._get_base_event_dictcK�||d<dS)N�Servicer)r	r0r�r;rrr
�_serialize_service��z CSMSerializer._serialize_servicecKr�)N�Apir)r	r1r�r;rrr
�_serialize_operation�r�z"CSMSerializer._serialize_operationcKr�)N�	Timestampr)r	r2r�r;rrr
�_serialize_timestamp�r�z"CSMSerializer._serialize_timestampcKs(t|�|d<|r|�||d�dSdS)N�AttemptCount���)r��_add_fields_from_last_attempt)r	rpr�r;rrr
�_serialize_attempts�s�z!CSMSerializer._serialize_attemptscCs�|jr|�|j�}|dur||d<|�|j�|d<|jdur#|j|d<|jdur0|�|j|d�|jdur?|�|j|d�dSdS)N�Region�	UserAgent�FinalHttpStatusCode�ApiCall)r@�_get_region�_get_user_agentrLrO�_serialize_parsed_errorrP�_serialize_wire_exception)r	r��last_attempt�regionrrr
r��s$�


�
��z+CSMSerializer._add_fields_from_last_attemptcCs,|dkr
||d<dS|dkr||d<dSdS)Nr��Latency�ApiCallAttempt�AttemptLatencyr)r	rKr�r�rrr
�_serialize_latency�s
�z CSMSerializer._serialize_latencycKs|rdnd|d<dS)Nr�r�MaxRetriesExceededr)r	rVr�r;rrr
�_serialize_retries_exceeded�sz)CSMSerializer._serialize_retries_exceededcKst|�j|d<dS)N�Fqdn)r�netloc)r	rAr�r;rrr
�_serialize_url�szCSMSerializer._serialize_urlcKs\|�|�|d<|�|�r|�|�|d<|�|�}|dur ||d<d|vr,|d|d<dSdS)Nr��	AccessKeyr�zX-Amz-Security-Token�SessionToken)r��
_is_signed�_get_access_keyr�)r	r@r�r;r�rrr
�_serialize_request_headers�s

��z(CSMSerializer._serialize_request_headerscKr�)N�HttpStatusCoder)r	rLr�r;rrr
�_serialize_http_status_code�sz)CSMSerializer._serialize_http_status_codecKs,|j��D]\}}||vr||||<qdSrb)�"_RESPONSE_HEADERS_TO_EVENT_ENTRIES�items)r	rMr�r;�header�entryrrr
�_serialize_response_headers�s
��z)CSMSerializer._serialize_response_headerscKsH|dkrdnd}|�|d|j�||d<|�|d|j�||d<dS)Nr��Final��Code�AwsException�Message�AwsExceptionMessage)�	_truncate�_MAX_ERROR_CODE_LENGTH�_MAX_MESSAGE_LENGTH)r	rOr�r�r;�field_prefixrrr
r���
�
�z%CSMSerializer._serialize_parsed_errorcKsH|dkrdnd}|�|jj|j�||d<|�t|�|j�||d<dS)Nr�r�r��SdkException�SdkExceptionMessage)r�rjr�_MAX_EXCEPTION_CLASS_LENGTH�strr�)r	rPr�r�r;r�rrr
r��r�z'CSMSerializer._serialize_wire_exceptioncCs t|t�rdSt|t�rdSdS)Nr�r�)r^r4rrrcrrr
r��s


�zCSMSerializer._get_event_typecCs"|�|�}|�|�\}}|�d�S)N�
access_key)�_get_auth_value�_get_auth_match�group)r	r@�auth_valr+�
auth_matchrrr
r��s

zCSMSerializer._get_access_keycCs<|�|�sdS|�|�}|�|�\}}|dkrdS|�d�S)Nr|�signing_region)r�r�r�r�)r	r@r��signature_versionr�rrr
r��s


zCSMSerializer._get_regioncCs|�t|�dd��|j�S)Nz
User-Agentr�)r�rrN�_MAX_USER_AGENT_LENGTH�r	r@rrr
r�s�zCSMSerializer._get_user_agentcCsd|vS�N�
Authorizationrr�rrr
r�
szCSMSerializer._is_signedcCst|d�Sr�)rr�rrr
r�
r�zCSMSerializer._get_auth_valuecCs2|j��D]\}}|�|�}|r||fSqdS)N)NN)�_AUTH_REGEXSr��match)r	r�r��regexr�rrr
r�s
�zCSMSerializer._get_auth_matchcCs*t|�|krt�d||�|d|�S|S)Nz6Truncating following value to maximum length of %s: %s)r�rr)r	�text�
max_lengthrrr
r�s�zCSMSerializer._truncateN)&rr r!r�r�r�r�r�r��re�compiler�r�rr~r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�rrrr
ruBsR���
	ruc@s eZdZdZdd�Zdd�ZdS)�SocketPublisheri cCs||_||f|_||_dS)a)Publishes monitor events to a socket

        :type socket: socket.socket
        :param socket: The socket object to use to publish events

        :type host: string
        :param host: The host to send events to

        :type port: integer
        :param port: The port on the host to send events to

        :param serializer: The serializer to use to serialize the event
            to a form that can be published to the socket. This must
            have a `serialize()` method that accepts a monitor event
            and return bytes
        N)�_socket�_address�_serializer)r	�socket�host�port�
serializerrrr
r%s

zSocketPublisher.__init__cCsF|j�|�}t|�|jkrt�dt|�|j�dS|j�||j�dS)z�Publishes a specified monitor event

        :type event: BaseMonitorEvent
        :param event: The monitor event to be sent
            over the publisher's socket to the desired address.
        z`Serialized event of size %s exceeds the maximum length allowed: %s. Not sending event to socket.N)	r�r�r��_MAX_MONITOR_EVENT_LENGTHrrr��sendtor�)r	rd�serialized_eventrrr
r:s�zSocketPublisher.publishN)rr r!r�rrrrrr
r�"sr�)r��loggingr�r$�botocore.compatrrr�botocore.retryhandlerrr`�	getLoggerrrrr"rgr4rrrur�rrrr
�<module>s
,`<Fa
@ Telegram