Dashboard
PHP:
8.2.30
OS:
Linux
User:
dh_nv8b2m
/
/
usr
/
lib
/
python3
/
dist-packages
/
boto
/
__pycache__
📤 Upload
📝 New File
📁 New Folder
Close
Editing: utils.cpython-310.pyc
o ckF[�� � @ s� d Z ddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddlZ ddlZ ddlZ ddlZ ddlZddlZddlZddlmZmZmZmZ ddlmZ ddl m Z m Z e Z ddlm Z zddl!m"Z" W n e#y e$Z"Y nw g d�Z%e �&d �Z'e �&d �Z(e �&d �Z)d d � Z* d]dd�Z+d^dd�Z,d^dd�Z-d_dd�Z.d^dd�Z/G dd� de0�Z1d d � Z2 !d`d"d#�Z3 !dad$d%�Z4 !dbd&d'�Z5d(Z6d)Z7d*Z8e�9� Z:ed+d,� �Z;d^d-d.�Z<d/d0� Z=d^d1d2�Z>d3d4� Z?dcd5d6�Z@G d7d8� d8eA�ZBG d9d:� d:ejCjD�ZEG d;d<� d<e0�ZFG d=d>� d>eA�ZG ddd?d@�ZHdAdB� ZIdCdD� ZJdEdF� ZKdedJdK�ZLdLdM� ZMdfdOdP�ZNdNde fdQdR�ZOdSdT� ZPdUdV� ZQG dWdX� dXeA�ZRdYdZ� ZSd[d\� ZTdS )gz7 Some handy utility functions used by several classes. � N)�six�StringIO�urllib� encodebytes)�contextmanager)�md5�sha512)�json)�JSONDecodeError) �acl�cors�defaultObjectAcl�location�logging� partNumber�policy�requestPayment�torrent� versioning� versionId�versions�website�uploads�uploadIdzresponse-content-typezresponse-content-languagezresponse-expireszresponse-cache-controlz response-content-dispositionzresponse-content-encoding�delete� lifecycle�tagging�restore� storageClass� websiteConfig�compose�billing� userProject�encryptionConfigz(.)([A-Z][a-z]+)z([a-z])([0-9]+)z([a-z0-9])([A-Z])c C s( t | �dkr| S | d tj�| d �fS )N� r )�lenr �parse�unquote)�nv� r) �,/usr/lib/python3/dist-packages/boto/utils.py� unquote_vk s r+ c C sz |st j�� }i }|D ] }|�� }|| dur+|dv s!|�|j�r+t|| ��� ||< q d|vr4d|d< d|vr<d|d< |j|v rEd|d< |rMt|�|d< t |� � �}d| } |D ]}|| } |�|j�rn| d|| f 7 } qY| d| 7 } qY|� d �} | | d 7 } t | �d kr�| d � d �} d d� | D �} dd� | D �} t | �d kr�| j dd� d� dd� | D �} | d 7 } | d �| �7 } | S )zE Generates the aws canonical string for the given parameters N)� content-md5� content-type�dater- � r, r. z%s z%s:%s �?r r$ �&c S s g | ]}|� d d��qS )�=r$ )�split��.0�ar) r) r* � <listcomp>� s z$canonical_string.<locals>.<listcomp>c S s g | ] }|d t v rt|��qS )r )�qsa_of_interestr+ r4 r) r) r* r7 � � c S s | d S �Nr r) )�xr) r) r* �<lambda>� s z"canonical_string.<locals>.<lambda>)�keyc S s g | ]}d � |��qS )r2 )�joinr4 r) r) r* r7 � s )�boto�provider� get_default�lower� startswith� header_prefix�str�strip� date_header�sorted�keysr3 r% �sortr> ) �method�path�headers�expiresr@ �interesting_headersr= �lk�sorted_header_keys�buf�val�t�qsar) r) r* �canonical_stringr sL �� rV c C s` |st j�� }|j}| �� }|�� D ]}|�� t jjj j v r%|| ||< q|| ||| < q|S �N) r? r@ rA �metadata_prefix�copyrI rB �s3r= �Key�base_user_settable_fields)rM �metadatar@ rX � final_headers�kr) r) r* � merge_meta� s r` c C s� |st j�� }|j}i }| �� D ]4}|�� �|�rDtj� | | �}t |t �r7z|� d�}W n t y6 Y nw |||t|�d � < | |= q|S �N�utf-8)r? r@ rA rX rI rB rC r r& r' � isinstance�bytes�decode�UnicodeDecodeErrorr% )rM r@ rX r] �hkeyrS r) r) r* �get_aws_metadata� s" ��rh T� c C s8 t d|�D ]�}z2tj�i �}tj�|�}tj�| �}|j||d�}|�� } t| t j �s5t | d�r5| � d�} | W S tj jy_ } z| �� } | dkrU|sUW Y d} ~ dS W Y d} ~ n d} ~ w tyv } z tj�d� W Y d} ~ nd} ~ ww |d |kr�tj�d � t�td | tj�d d d��� qtj� d� dS )a Retry a url. This is specifically used for accessing the metadata service on an instance. Since this address should never be proxied (for security reasons), we create a ProxyHandler with a NULL dictionary to override any proxy settings in the environment. r )�timeoutre rb i� Nr/ z&Caught exception reading instance datar$ zSleeping before retrying� �Boto�max_retry_delay�< z'Unable to read instance data, giving up)�ranger �request� ProxyHandler� build_opener�Request�open�readrc r � string_types�hasattrre �error� HTTPError�getcode� Exceptionr? �log� exception�debug�time�sleep�min�config�get) �url� retry_on_404� num_retriesrj �i� proxy_handler�opener�req�r�result�e�coder) r) r* � retry_url� s: � ��� �� r� c C s t | ||�S rW )�LazyLoadMetadata)r� r� rj r) r) r* �_get_instance_metadata� s r� c sh e Zd Zddd�Zdd� Z� fdd�Zddd �Z� fd d �Z� fd d �Z� fdd�Z � fdd�Z � Z S )r� Nc C s� || _ || _i | _g | _|| _tjj| j | j| jd�}|r`|�d�}|D ]=}|� d�r8|dd� }| j� |� n#|� d�}|dkrR||d d � }|d|� d } n| }} | | j|< d | |< q$d S d S ) N�r� rj � �/r ���r2 r$ z /openssh-key) �_url� _num_retries�_leaves�_dicts�_timeoutr? �utilsr� r3 �endswith�append�find) �selfr� r� rj �data�fields�fieldr= �p�resourcer) r) r* �__init__� s* �zLazyLoadMetadata.__init__c C s | D ]}| | qd S rW r) �r� r= r) r) r* � _materialize s �z LazyLoadMetadata._materializec s || vr t t| ��|�S t t| ��|�}|d ur|S || jv r�| j| }d }td| j�D ]�}z5tjj| j t j j |dd� | j| j d�}|rS|d dkrSt�|�}W n�|�d�}|dkra|�d�}W n� ty� } z tj�d|jj|f � tj�d| � |}W Y d }~n d }~w ty� } ztj�d d |jj � |}� d }~ww tj�d d |d � |d | jkr�tt�� d| tj� ddd��}t � |� q,tj�d� tj�d|jj|f � |�|| |< n|| j v r�t| j | d | j�| |< t t| ��|�S )Nr z/:)�safer� �{r� z encountered '%s' exception: %sz corrupted JSON data found: %szencountered unretryablez '%s' exception, re-raisingz"Caught exception reading meta dataz for the '%s' tryr$ rk rl rm rn z#Unable to read meta data, giving upr� ) �superr� � __getitem__r� ro r� r? r� r� r� r r& �quoter� r �loadsr� r3 r r| r~ � __class__�__name__r{ rx r� �randomr� r� r r� r� ) r� r= rS r� �last_exceptionr� r� r� � next_sleep�r� r) r* r� s� �� �������� �� � �� �z LazyLoadMetadata.__getitem__c C s" z| | W S t y | Y S w rW )�KeyError)r� r= �defaultr) r) r* r� S s �zLazyLoadMetadata.getc � | � � tt| ��� S rW )r� r� r� �values�r� r� r) r* r� Y � zLazyLoadMetadata.valuesc r� rW )r� r� r� �itemsr� r� r) r* r� ] r� zLazyLoadMetadata.itemsc r� rW )r� r� r� �__str__r� r� r) r* r� a r� zLazyLoadMetadata.__str__c r� rW )r� r� r� �__repr__r� r� r) r* r� e r� zLazyLoadMetadata.__repr__rW ) r� � __module__� __qualname__r� r� r� r� r� r� r� r� � __classcell__r) r) r� r* r� � s C r� c C s d| ||f S )ax Builds an EC2 metadata URL for fetching information about an instance. Example: >>> _build_instance_metadata_url('http://169.254.169.254', 'latest', 'meta-data/') http://169.254.169.254/latest/meta-data/ :type url: string :param url: URL to metadata service, e.g. 'http://169.254.169.254' :type version: string :param version: Version of the metadata to get, e.g. 'latest' :type path: string :param path: Path of the metadata to get, e.g. 'meta-data/'. If a trailing slash is required it must be passed in with the path. :return: The full metadata URL z%s/%s/%sr) )r� �versionrL r) r) r* � _build_instance_metadata_urlj s r� �latest�http://169.254.169.254� meta-data/� c C sD zt || |�}t|||d�W S tjjy! tj�d|� Y dS w )a� Returns the instance metadata as a nested Python dictionary. Simple values (e.g. local_hostname, hostname, etc.) will be stored as string values. Values such as ancestor-ami-ids will be stored in the dict as a list of string values. More complex fields such as public-keys and will be stored as nested dicts. If the timeout is specified, the connection to the specified url will time out after the specified number of seconds. r� zBException caught when trying to retrieve instance metadata for: %sN)r� r� r rx �URLErrorr? r| r} )r� r� r� rj r� � metadata_urlr) r) r* �get_instance_metadata� s ��r� c C s� i }t || d�}z2t|||d�}|�d�}|D ] }t|d | d ||d�} | d dkr1t�| �} |r7| ||< q|W S tjjyF Y dS w )zF Returns the instance identity as a nested Python dictionary. zdynamic/instance-identity/r� r� r� r r� N)r� r� r3 r r� r rx r� ) r� r� rj r� �iid�base_urlr� r� r� rS r) r) r* �get_instance_identity� s$ � ��r� c C sb t || d�}t|d||d�}|r/|r/|�|�}i }|D ]}|�d�} | d �� || d �� < q|S )Nz user-dataF)r� r� rj r2 r$ r )r� r� r3 rF ) r� �sepr� rj r� �ud_url� user_data�l�nvpairrT r) r) r* �get_instance_userdata� s r� z%Y-%m-%dT%H:%M:%SZz%Y-%m-%dT%H:%M:%S.%fZz%a, %d %b %Y %H:%M:%S %Zc c sl � t �) t�tj�}zt�tj| �V W t�tj|� nt�tj|� w W d � dS 1 s/w Y dS )zE A context manager to set the locale in a threadsafe manner. N)� LOCALE_LOCK�locale� setlocale�LC_ALL)�name�savedr) r) r* r� � s � ""�r� c C s | st �� } t �t| �S rW )r �gmtime�strftime�ISO8601)�tsr) r) r* �get_ts� s r� c C s� t d��M | �� } ztj�| t�}|W W d � S tyP ztj�| t�}|W Y W d � S tyO tj�| t�}| Y Y W d � S w w 1 sTw Y d S )N�C)r� rF �datetime�strptimer� � ValueError� ISO8601_MS�RFC1123)r� �dtr) r) r* �parse_ts� s$ � � � ��r� c C sp |rd| |f } | � d�}d }z"|dd � D ]}|r t||�}qttd�|dd� ��|�}q|W S Y d S )Nz%s.%s�.r$ r r� )r3 �getattr� __import__r> )� module_name� class_name�modules�c�mr) r) r* � find_class� s r� c C s, d}|d7 }t j�|| |||f �}|�� S )z= Update your Dynamic DNS record with DNSMadeEasy.com z,https://www.dnsmadeeasy.com/servlet/updateipz$?username=%s&password=%s&id=%s&ip=%s)r rp �urlopenru )�username�password�dme_id� ip_address�dme_url�sr) r) r* � update_dme� s r� c C s� t j�d| � |du rt�� }zb| �d�r;| td�d� �dd�\}}t j||d�}|� |�}|� |�}|� |� n0|r^|r^t j �� } | �d| ||� t j �| �} t j �| �} t j �| � t j �| �} |�| �� � |�d� W |S � )z� Fetch a file based on the URI provided. If you do not pass in a file pointer a tempfile.NamedTemporaryFile, or None if the file could not be retrieved is returned. The URI can be either an HTTP url, or "s3://bucket_name/key_name" z Fetching %sNzs3://r� r$ )�aws_access_key_id�aws_secret_access_keyr )r? r| �info�tempfile�NamedTemporaryFilerC r% r3 � connect_s3� get_bucket�get_key�get_contents_to_filer rp � HTTPPasswordMgrWithDefaultRealm� add_password�HTTPBasicAuthHandlerrr �install_openerr� �writeru �seekr} ) �uri�filer� r� � bucket_name�key_namer� �bucketr= �passman� authhandlerr� r� r) r) r* � fetch_file� s0 � �r c @ sT e Zd Zddd�Zddd�Zdd � Zd d � Zeeedd �Zd d� Z ee edd�Z dS )� ShellCommandTFNc C s0 d| _ || _t� | _|| _|| _| j|d� d S )Nr )�cwd)� exit_code�commandr �log_fp�wait� fail_fast�run)r� r r r r r) r) r* r� $ s zShellCommand.__init__c C s� t j�d| j � tj| jdtjtjtj|d�| _| jri| j� � d u rDt � d� | j� � }| j �|d � | j �|d � | j� � d u s#t j�| j �� � | jj| _| jrf| jdkrftd| j d | j ��| jS d S )Nz running:%sT)�shell�stdin�stdout�stderrr r$ r zCommand z failed with status )r? r| r� r � subprocess�Popen�PIPE�processr �pollr r� � communicater r �getvalue� returncoder r r{ )r� r rT r) r) r* r , s0 � � ���zShellCommand.runc C s t �rW )�AttributeError�r� �valuer) r) r* � setReadOnlyB � zShellCommand.setReadOnlyc C s | j S rW )r r� r) r) r* � getStatusE s zShellCommand.getStatusz The exit code for the commandc C s | j �� S rW )r r r� r) r) r* � getOutputK � zShellCommand.getOutputz*The STDIN and STDERR output of the command)TFNrW ) r� r� r� r� r r$ r& �property�statusr' �outputr) r) r) r* r " s ��r c s( e Zd ZdZ� fdd�Zdd� Z� ZS )�AuthSMTPHandlera� This class extends the SMTPHandler in the standard Python logging module to accept a username and password on the constructor and to then use those credentials to authenticate with the SMTP server. To use this, you could add something like this in your boto config file: [handler_hand07] class=boto.utils.AuthSMTPHandler level=WARN formatter=form07 args=('localhost', 'username', 'password', 'from@abc', ['user1@abc', 'user2@xyz'], 'Logger Subject') c s& t t| ��||||� || _|| _dS )z� Initialize the handler. We have extended the constructor to accept a username/password for SMTP authentication. N)r� r, r� r� r� )r� �mailhostr� r� �fromaddr�toaddrs�subjectr� r) r* r� ` s � zAuthSMTPHandler.__init__c C s� z@| j }|s tj}t�| j|�}|�| j| j� | �|�}d| j d� | j �| � |�t j�� |f }|�| j | j |� |�� W dS ttfyJ � | �|� Y dS )z� Emit a record. Format the record and send it to the specified addressees. It would be really nice if I could add authorization to this class without having to resort to cut and paste inheritance but, no. z-From: %s To: %s Subject: %s Date: %s %s�,N)�mailport�smtplib� SMTP_PORT�SMTPr- �loginr� r� �formatr. r> r/ � getSubject�emailr� � formatdate�sendmail�quit�KeyboardInterrupt� SystemExit� handleError)r� �record�port�smtp�msgr) r) r* �emitm s& �zAuthSMTPHandler.emit)r� r� r� �__doc__r� rD r� r) r) r� r* r, R s r, c @ sp e Zd ZdZG dd� de�Zdd� Zdd� Zdd � Zd d � Z d d � Z dd� Z dd� Z dd� Z dd� Zdd� ZdS )�LRUCacheaq A dictionary-like object that stores only a certain number of items, and discards its least recently used item when full. >>> cache = LRUCache(3) >>> cache['A'] = 0 >>> cache['B'] = 1 >>> cache['C'] = 2 >>> len(cache) 3 >>> cache['A'] 0 Adding new items to the cache does not increase its size. Instead, the least recently used item is dropped: >>> cache['D'] = 3 >>> len(cache) 3 >>> 'B' in cache False Iterating over the cache returns the keys, starting with the most recently used: >>> for key in cache: ... print key D A C This code is based on the LRUCache class from Genshi which is based on `Myghty <http://www.myghty.org>`_'s LRUCache from ``myghtyutils.util``, written by Mike Bayer and released under the MIT license (Genshi uses the BSD License). c @ s e Zd Zdd� Zdd� ZdS )zLRUCache._Itemc C s d | _ | _|| _|| _d S rW )�previous�nextr= r# )r� r= r# r) r) r* r� � s zLRUCache._Item.__init__c C � t | j�S rW )�reprr# r� r) r) r* r� � r( zLRUCache._Item.__repr__N)r� r� r� r� r� r) r) r) r* �_Item� s rK c C s t � | _|| _d | _d | _d S rW )�dict�_dict�capacity�head�tail)r� rN r) r) r* r� � s zLRUCache.__init__c C s || j v S rW )rM r� r) r) r* � __contains__� r( zLRUCache.__contains__c c s& � | j }|r|jV |j}|sd S d S rW )rO r= rH )r� �curr) r) r* �__iter__� s � �zLRUCache.__iter__c C rI rW )r% rM r� r) r) r* �__len__� r( zLRUCache.__len__c C s | j | }| �|� |jS rW )rM � _update_itemr# )r� r= �itemr) r) r* r� � s zLRUCache.__getitem__c C sT | j �|�}|d u r | �||�}|| j |< | �|� d S ||_| �|� | �� d S rW )rM r� rK � _insert_itemr# rU � _manage_size)r� r= r# rV r) r) r* � __setitem__� s zLRUCache.__setitem__c C rI rW )rJ rM r� r) r) r* r� � r( zLRUCache.__repr__c C s: d |_ | j|_| jd ur|| j_ n|| _|| _| �� d S rW )rG rO rH rP rX )r� rV r) r) r* rW � s zLRUCache._insert_itemc C s` t | j�| jkr.| j| jj= | j| jkr | jj| _d | j_nd | _| _t | j�| jksd S d S rW )r% rM rN rP r= rO rG rH r� r) r) r* rX � s �zLRUCache._manage_sizec C sV | j |krd S |j}|j|_|jd ur||j_n|| _d |_| j |_| | j _| _ d S rW )rO rG rH rP )r� rV rG r) r) r* rU � s zLRUCache._update_itemN)r� r� r� rE �objectrK r� rQ rS rT r� rY r� rW rX rU r) r) r) r* rF � s % rF c @ s> e Zd ZdZeZd dd�Zdd� Zdd� Zd d � Z d d � Z dS )�Passwordzp Password object that stores itself as hashed. Hash defaults to SHA512 if available, MD5 otherwise. Nc C s || _ |r || _dS dS )zh Load the string from an initial value, this should be the raw hashed password. N)rE �hashfunc)r� rE r\ r) r) r* r� s �zPassword.__init__c C s( t |t�s |�d�}| �|��� | _d S ra )rc rd �encoder\ � hexdigestrE r" r) r) r* �set s z Password.setc C s t | j �S rW �rE r� r) r) r* r� r( zPassword.__str__c C s< |d u rdS t |t�s|�d�}t| �|��� �t| j�kS )NFrb )rc rd r] rE r\ r^ )r� �otherr) r) r* �__eq__ s zPassword.__eq__c C s | j rt| j �S dS r: )rE r% r� r) r) r* rT s zPassword.__len__�NN) r� r� r� rE �_hashfnr\ r� r_ r� rb rT r) r) r) r* r[ s r[ c C s� |pg }|rdt j�dd�| f } |st j�ddd �}|r�z�t j�ddd�}tjj�� }||d< ||d < ||d < tjjd d �|d < | |d< |rQ|� tjj � |�� |rktjj � dd�}|�|� tj�|� |� |� |D ]}|� |� qmt j�ddd�} t j�dd�r�t�| tt j�dd���} nt�| �} t j�dd�r�| �� | �� | �� t j�ddd�} t j�ddd�} | r�| �| | � | �|||�� � | �� W d S t j� d� Y d S d S )Nz[%s] %s�Instancez instance-id� Notification�smtp_to� smtp_fromr? �FromzReply-To�ToT)� localtime�Date�Subject�text�html� smtp_host� localhost� smtp_port�smtp_tls� smtp_userr/ � smtp_passz notify failed) r? r� � get_valuer9 �mime� multipart� MIMEMultipartr� r: �attachrn �MIMEText�base�MIMEBase� set_payload�encoders� encode_base64r3 r5 �int�getbool�ehlo�starttlsr6 r; � as_stringr< r| r} ) r0 �body� html_body� to_string� attachments�append_instance_id� from_stringrC �partrp �serverrt ru r) r) r* �notify& s` �� � � �r� c C sD t js t| t�r | S t| t j�st �| �} t| t j�r | �d�} | S ra )r �PY2rc rd rv � text_typer] �r# r) r) r* �get_utf8_value^ s r� c C s* t | t�st | t�rt| �} | S | g} | S rW )rc �list�tupler� r) r) r* �mklistk s �r� c C s( t �d| �}t�d|�}t�d|��� S )a~ Convert camel case to a "pythonic" name. Examples:: pythonize_name('CamelCase') -> 'camel_case' pythonize_name('already_pythonized') -> 'already_pythonized' pythonize_name('HTTPRequest') -> 'http_request' pythonize_name('HTTPStatus200Ok') -> 'http_status_200_ok' pythonize_name('UPPER') -> 'upper' pythonize_name('') -> '' z\1_\2)�_first_cap_regex�sub�_number_cap_regex�_end_cap_regexrB )r� �s1�s2r) r) r* �pythonize_namet s r� F� text/plain�:c C s� t jj�� }| D ]?\}}t||�}|�dd�\}} |dkr't jjj|| d�} nt jj� || �} | � |� t j � | � | j dd|d� |�| � q|�� } |rmt� } tjd| d �} z | �| � W | �� n| �� w | �� } | S ) a� Description: :param content: A list of tuples of name-content pairs. This is used instead of a dict to ensure that scripts run in order :type list of tuples: :param compress: Use gzip to compress the scripts, defaults to no compression :type bool: :param deftype: The type that should be assumed if nothing else can be figured out :type str: :param delimiter: mime delimiter :type str: :return: Final mime multipart :rtype: str: r� r$ rn )�_subtypezContent-Disposition� attachment)�filename�wb)�mode�fileobj)r9 rw rx ry �guess_mime_typer3 rn r{ r| r} r~ r r� � add_headerrz r� r �gzip�GzipFiler �closer )�content�compress�deftype� delimiter�wrapperr� �con� definite_type�maintype�subtype�mime_con�rcontentrR �gzr) r) r* �write_mime_multipart� s( r� c C s@ ddddddd�}|}|� � D ]\}}| �|�r |} |S q|S )z�Description: Guess the mime type of a block of text :param content: content we're finding the type of :type str: :param deftype: Default mime type :type str: :rtype: <type>: :return: <description> ztext/x-include-urlztext/x-shellscriptztext/cloud-configztext/upstart-jobztext/part-handlerztext/cloud-boothook)z#includez#!z #cloud-configz #upstart-jobz #part-handlerz#cloud-boothook)r� rC )r� r� �starts_with_mappings�rtype� possible_type�mimetyper) r) r* r� � s � �r� � c C s t | ||td�S )a� Compute MD5 hash on passed file and return results in a tuple of values. :type fp: file :param fp: File pointer to the file to MD5 hash. The file pointer will be reset to its current location before the method returns. :type buf_size: integer :param buf_size: Number of bytes per read request. :type size: int :param size: (optional) The Maximum number of bytes to read from the file pointer (fp). This is useful when uploading a file in multiple parts where the file is being split inplace into different parts. Less bytes may be available. :rtype: tuple :return: A tuple containing the hex digest version of the MD5 hash as the first element, the base64 encoded version of the plain digest as the second element and the data size as the third element. )�hash_algorithm)� compute_hashr )�fp�buf_size�sizer) r) r* � compute_md5� s r� c C s� |� }| � � }|r||k r| �|�}n| �|�}|rIt|t�s$|�d�}|�|� |r6|t|�8 }|dkr6n|rB||k rB| �|�}n| �|�}|s|�� }t|� � �� d�}|d dkrb|dd� }| � � | } | � |� ||| fS )Nrb r r� r� ) �tellru rc rd r] �updater% r^ r �digestre r ) r� r� r� r� �hash_obj�sposr� � hex_digest� base64_digest� data_sizer) r) r* r� � s0 � r� c s � fdd�|D �S )z� Takes a specific header name and a dict of headers {"name": "value"}. Returns a list of matching header names, case-insensitive. c s g | ] }|� � � � � kr|�qS r) )rB �r5 �h�r� r) r* r7 r9 z)find_matching_headers.<locals>.<listcomp>r) )r� rM r) r� r* �find_matching_headers s r� c s" t | � �}d�� fdd�|D ��S )z� Takes a specific header name and a dict of headers {"name": "value"}. Returns a string of all header values, comma-separated, that match the input header name, case-insensitive. r1 c 3 s( � | ]}� | d urt � | �V qd S rW r` r� �rM r) r* � <genexpr> s � ��z(merge_headers_by_name.<locals>.<genexpr>)r� r> )r� rM �matching_headersr) r� r* �merge_headers_by_name s r� c @ s e Zd ZdZddd�ZdS )� RequestHookz� This can be extended and supplied to the connection object to gain access to request and response object after the request completes. One use for this would be to implement some specific request logging. Fc C s d S rW r) )r� rp �responserx r) r) r* �handle_request_data# r% z RequestHook.handle_request_dataN)F)r� r� r� rE r� r) r) r) r* r� s r� c C s: | rt | t�s dS | �d�rdS t| �d��dkrdS dS )zQ Detect (naively) if the hostname is an IPV6 host. Return a boolean. F�[Tr� rk )rc rE rC r% r3 ��hostnamer) r) r* � host_is_ipv6' s r� c C s6 | � � } t| �r| �dd�d � d�S | �dd�d S )z� Given a hostname that may have a port name, ensure that the port is trimmed returning only the host, including hostnames that are IPV6 and may include brackets. z]:r$ r z[]r� )rF r� r3 r� r) r) r* � parse_host> s r� rc rW )Tri N)r� r� r� Nr� )r� r� Nr� )r� Nr� Nr� )NNN)NNNNT)Fr� r� )r� N)UrE r r �logging.handlersr r? � boto.providerr� r� r3 r� �re�email.mime.multipartr9 �email.mime.base�email.mime.text� email.utils�email.encodersr� � threadingr� � boto.compatr r r r � contextlibr �hashlibr r rd r �boto.compat.jsonr � ImportErrorr� r8 �compiler� r� r� r+ rV r` rh r� r� rL r� r� r� r� r� r� r� r� �Lockr� r� r� r� r� r� r rZ r �handlers� SMTPHandlerr, rF r[ r� r� r� r� r� r� r� r� r� r� r� r� r� r) r) r) r* �<module> s� % � � : #v � � � #07w& �8 -
Save
Cancel