File: //lib/python3.9/site-packages/oci/__pycache__/util.cpython-39.opt-1.pyc
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
)
% �