/
lib
/
python3.9
/
site-packages
/
oci
/
__pycache__
/
Upload File
HOME
a ���fA4 � @ s� d dl mZ d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl m Z d dl Z zd dl mZ W n ey� d dlmZ Y n0 d dlmZ d dlZe�e�Ze�e�ZdZdZdZd Zd Zd Zd e Z d e Z zd dl m Z W n e�y d dl Z Y n0 e!� Z"dd� Z#dd� Z$dd� Z%dd� Z&G dd� de!�Z'e'ddd�Z(e'ddd�Z)d d � Z*d d � Z+ee*ee+iZ,d d!� Z-d"d#� Z.e fd$d%�Z/d&d'� Z0d(d)� Z1d*d+� Z2d,d-� Z3d.d/� Z4d0d1� Z5d2d3� Z6d4d5� Z7dS )6� )�absolute_importN)�six)�urlparse)�SEEK_SETZinstance_principalZ(delegation_token_with_instance_principalZresource_principalZdelegation_token_fileZauthentication_typei �d � c C s� t | tj�r| S | tu r dS t | tjtjf�r`| js@tj� | �} t | tj�rX| j dd�S | � � S t | tj �rt| � � S t | t j �r�dd� t�| �D �S t | t j�r�dd� | D �S t| d�s�| S i }t�| j�D ]$}t| |t�}|tur�t|�||< q�|S ) z�Helper to flatten models into dicts for rendering. The following conversions are applied: * datetime.date, datetime.datetime, datetime.time are converted into ISO8601 UTC strings N�T)�sepc S s i | ]\}}|t |��qS � ��to_dict)�.0�k�vr r �,/usr/lib/python3.9/site-packages/oci/util.py� <dictcomp>I � zto_dict.<locals>.<dictcomp>c S s g | ] }t |��qS r r )r r r r r � <listcomp>K r zto_dict.<locals>.<listcomp>� swagger_types)� isinstancer Z string_types� NONE_SENTINEL�datetime�timeZtzinfo�pytzZutcZlocalizeZ isoformat�date�abc�MappingZ iteritems�Iterable�hasattrZiterkeysr �getattr� missing_attrr )�obj�as_dict�key�valuer r r r 0 s0 r c C s t | �}tj|ddd�S )z9Returns a string of the model flattened as a dict, sorted� T)�indentZ sort_keys)r �json�dumps)Zmodelr" r r r �formatted_flat_dictY s �r) c C s | d u p| t u p| |v S �N)r )Z value_to_testZallowed_valuesr r r �#value_allowed_none_or_none_sentinelc s r+ c C sV t j�t j�| ��}t|d��}|�� }W d � n1 s<0 Y t�|��d�S )a� Takes a file path and returns a Base64-encoded string which can be provided as the value of the ``user_data`` key in the ``metadata`` dictionary when launching an instance(see :py:class:`~oci.core.models.LaunchInstanceDetails` for more information). :param str file_path: The path to the file whose contents will be Base64-encoded :return: The Base64-encoded string :rtype: str �rbNzutf-8) �os�path� expandvars� expanduser�open�read�base64Z b64encode�decode)Z file_path� full_path�fZ file_contentsr r r �)file_content_as_launch_instance_user_datag s &r7 c sD e Zd ZdZi Zd � fdd� Zd dd�Zdd� Zd d � ZeZ � Z S ) �Sentinela� Named singletons for clear docstrings. Also used to differentiate an explicit param of None from a lack of argument. .. code-block:: pycon >>> missing = Sentinel("Missing", False) >>> also_missing = Sentinel("Missing", False) >>> assert missing is also_missing >>> repr(missing) <Missing> >>> assert bool(missing) is False Tc sN t j�|d �}|d u r2tt | ��| � }t j|< n|j|urJtd�|���|S )Nz;Tried to get existing Sentinel {!r} with wrong truthy value)r8 �_symbols�get�super�__new__�truthy� ValueError�format)�cls�namer= �sentinel�� __class__r r r< � s zSentinel.__new__c C s || _ || _d S r* �rA r= )�selfrA r= r r r �__init__� s zSentinel.__init__c C s d� | j�S )Nz<{}>)r? rA �rF r r r �__repr__� s zSentinel.__repr__c C s | j S r* )r= rH r r r �__bool__� s zSentinel.__bool__)T)T) �__name__� __module__� __qualname__�__doc__r9 r< rG rI rJ Z __nonzero__� __classcell__r r rC r r8 { s r8 �NoneFrE ZWaitResourceNotFoundc C s� ddl m} i }| �t�}|d u r4tj�d�t���tj � |�}tj � |�s^tj�d�|���t |dd�� }|� � �� }W d � n1 s�0 Y |d u r�tj�d��||d< |f i |��S ) Nr )�'InstancePrincipalsDelegationTokenSignerzERROR: {} was not provided.z,ERROR: delegation token file not found at {}�r)�modez)ERROR: delegation_token was not provided.�delegation_token)�oci.auth.signersrQ r: � DELEGATION_TOKEN_FILE_FIELD_NAME�oci� exceptions� InvalidConfigr? r- r. r0 �isfiler1 r2 �strip)�configrQ Z signer_kwargsZdelegation_token_file_pathZ#expanded_delegation_token_file_pathr6 rT r r r �4_get_signer_from_delegation_token_instance_principal� s * r] c C s ddl m} |� S )Nr )� get_resource_principal_signer)rU r^ )r\ r^ r r r �#_get_signer_from_resource_principal� s r_ c C s t | �}t�|�}|| �S r* )�#get_authentication_type_from_config� AUTH_TYPE_TO_SIGNER_FUNCTION_MAPr: )r\ � auth_typeZsigner_functionr r r �#get_signer_from_authentication_type� s rc c C s` | � t�}|d u r td�t���|tkrJt| v r4tS tj� d�tt���ntj� d�|���d S )Nz{} not providedzAThe authentication type {} requires config values for the keys {}z+The authentication type {} is not supported) r: � AUTHENTICATION_TYPE_FIELD_NAMEr> r? �1INSTANCE_PRINCIPAL_AUTHENTICATION_TYPE_VALUE_NAMErV �<DELEGATION_TOKEN_WITH_INSTANCE_PRINCIPAL_AUTHENTICATION_TYPErW rX rY )r\ rb r r r r` � s r` c C s� t �d� z�d}t}d}d}d}|r�t| d�r<| j�|�}n t| d�rR| �|�}ntd��t|�dkrjd }||7 }|t|�7 }|r ||kr td ��q ||d �W S t t fy� td ��Y n0 d S ) Nz�Reading the stream to calculate its content-length. Process may freeze for very big streams. Consider passing in content length for big objectsTr � r �bufferr2 zuStream object does not contain a 'read' property. Cannot auto calculate content length, please pass in content lengthFz{Stream size is greater than the buffer_limit, please pass in a bigger buffer_limit or pass in content length to the request)�content_length� byte_contentzRStream object's content length cannot be calculated, please pass in content length) �logger�warning�DEFAULT_PART_SIZEr rh r2 � TypeError�len� BufferError�IOError�OSError)�streamZ buffer_limitZ keep_readingZ part_sizeri Zcontentrj r r r �,back_up_body_calculate_stream_content_length� s, rt c C s: t | d�s(t | d�s(t | d�s(t | d�r,dS t�d� dS )N�__len__ro �fileno�tellTz�Request did not contain content-length and stream object does not contain fileno or tell property. Stream object will be read to calculate content-lengthF)r rk rl )�or r r �(is_content_length_calculable_by_req_util s ( ry c C s t | �}|jd |j S )a Takes a Service Endpoint with base-path embedded and extracts the Service Endpoint from it. :param str endpoint_with_base_path: Service Endpoint with base-path embedded :return: The Service Endpoint without base-path. :rtype: str z://)r �scheme�netloc)Zendpoint_with_base_pathZparsed_endpointr r r �extract_service_endpoint s r| c K s2 | j }|dkr.|�d�}|r*t|d�r*dS dS dS )NZcall_api�bodyr2 TF)rK r: r )Zfunc_refZ func_kwargsZ func_namer} r r r �%should_record_body_position_for_retry s r~ c C sf d}t | dd �d urLz | �� }W q^ ttfyH d}d }t�d� Y q^0 nd}d }t�d� ||fS )NTrw FzVUnable to record body position for rewinding. This request will not be retried/rewound)r rw rq rr rk rl )r} Zis_body_rewindable� body_positionr r r � record_body_position_for_rewind! s r� c C sV t | dd �d urHz| �|t� W n" ttfyB t�d� Y dS 0 dS t�d� dS )N�seekzUUnable to reset body position for rewinding. This request will not be retried/rewoundFT)r r� r rq rr rk rl )r} r r r r � rewind_body4 s r� c C s� d}zZd}t |d�r |�t�}nt |d�r6|j�t�}t|�dkrDq\|t|�7 }| �|� qW n$ ttfy� t� d� d}Y n0 |S )Nr rg r2 rh z&Unable to read stream body for signing���) r r2 rm rh ro �updaterq rr rk rl )Zsigning_algorithmr} Z bytes_read�chunkr r r �read_stream_for_signingB s r� c C s t �dd| �}t �dd|��� S )Nz(.)([A-Z][a-z]+)z\1_\2z([a-z0-9])([A-Z]))�re�sub�lower)rA �s1r r r �camel_to_snakeU s r� c C s& i }| � � D ]\}}||t|�< q |S r* )�itemsr� )Z dictionaryZoutdictr r r r r �camel_to_snake_keysZ s r� )8Z __future__r r3 r r' r� r- Zos.pathr Z oci._vendorr Zoci.exceptionsrW � urllib.parser � ImportError�ior ZloggingZ getLoggerrK rk re rf Z&RESOURCE_PRINCIPAL_AUTHENTICATION_TYPErV rd ZMEBIBYTE�DEFAULT_BUFFER_SIZErm �collections.abcr � collections�objectr r r) r+ r7 r8 r ZWAIT_RESOURCE_NOT_FOUNDr] r_ ra rc r` rt ry r| r~ r� r� r� r� r� r r r r �<module> sj ) % �