OXIESEC PANEL
- Current Dir:
/
/
opt
/
gsutil
/
gslib
/
__pycache__
Server IP: 2a02:4780:11:1594:0:ef5:22d7:a
Upload:
Create Dir:
Name
Size
Modified
Perms
📁
..
-
02/11/2025 08:19:48 AM
rwxr-xr-x
📄
__init__.cpython-39.pyc
2.94 KB
02/11/2025 08:19:48 AM
rw-r--r--
📄
__main__.cpython-39.pyc
20.78 KB
02/11/2025 08:19:48 AM
rw-r--r--
📄
boto_resumable_upload.cpython-39.pyc
14.86 KB
02/11/2025 08:19:48 AM
rw-r--r--
📄
boto_translation.cpython-39.pyc
47.41 KB
02/11/2025 08:19:48 AM
rw-r--r--
📄
bucket_listing_ref.cpython-39.pyc
4.23 KB
02/11/2025 08:19:48 AM
rw-r--r--
📄
cloud_api.cpython-39.pyc
41.26 KB
02/11/2025 08:19:48 AM
rw-r--r--
📄
cloud_api_delegator.cpython-39.pyc
21.69 KB
02/11/2025 08:19:48 AM
rw-r--r--
📄
command.cpython-39.pyc
63.61 KB
02/11/2025 08:19:49 AM
rw-r--r--
📄
command_argument.cpython-39.pyc
4.25 KB
02/11/2025 08:19:49 AM
rw-r--r--
📄
command_runner.cpython-39.pyc
15.75 KB
02/11/2025 08:19:48 AM
rw-r--r--
📄
context_config.cpython-39.pyc
6.98 KB
02/11/2025 08:19:48 AM
rw-r--r--
📄
cred_types.cpython-39.pyc
851 bytes
02/11/2025 08:19:49 AM
rw-r--r--
📄
cs_api_map.cpython-39.pyc
3.25 KB
02/11/2025 08:19:48 AM
rw-r--r--
📄
daisy_chain_wrapper.cpython-39.pyc
8.35 KB
02/11/2025 08:19:49 AM
rw-r--r--
📄
devshell_auth_plugin.cpython-39.pyc
1.24 KB
02/11/2025 08:19:48 AM
rw-r--r--
📄
discard_messages_queue.cpython-39.pyc
989 bytes
02/11/2025 08:19:49 AM
rw-r--r--
📄
exception.cpython-39.pyc
5.84 KB
02/11/2025 08:19:48 AM
rw-r--r--
📄
file_part.cpython-39.pyc
4.04 KB
02/11/2025 08:19:49 AM
rw-r--r--
📄
gcs_json_api.cpython-39.pyc
53.37 KB
02/11/2025 08:19:49 AM
rw-r--r--
📄
gcs_json_credentials.cpython-39.pyc
13.84 KB
02/11/2025 08:19:49 AM
rw-r--r--
📄
gcs_json_media.cpython-39.pyc
19.41 KB
02/11/2025 08:19:49 AM
rw-r--r--
📄
help_provider.cpython-39.pyc
2.36 KB
02/11/2025 08:19:49 AM
rw-r--r--
📄
iamcredentials_api.cpython-39.pyc
7.62 KB
02/11/2025 08:19:49 AM
rw-r--r--
📄
impersonation_credentials.cpython-39.pyc
1.79 KB
02/11/2025 08:19:49 AM
rw-r--r--
📄
kms_api.cpython-39.pyc
9.34 KB
02/11/2025 08:19:49 AM
rw-r--r--
📄
lazy_wrapper.cpython-39.pyc
2.27 KB
02/11/2025 08:19:48 AM
rw-r--r--
📄
metrics.cpython-39.pyc
26.95 KB
02/11/2025 08:19:48 AM
rw-r--r--
📄
metrics_tuple.cpython-39.pyc
491 bytes
02/11/2025 08:19:48 AM
rw-r--r--
📄
name_expansion.cpython-39.pyc
20.03 KB
02/11/2025 08:19:49 AM
rw-r--r--
📄
no_op_credentials.cpython-39.pyc
936 bytes
02/11/2025 08:19:49 AM
rw-r--r--
📄
parallel_tracker_file.cpython-39.pyc
8.89 KB
02/11/2025 08:19:49 AM
rw-r--r--
📄
plurality_checkable_iterator.cpython-39.pyc
3.2 KB
02/11/2025 08:19:49 AM
rw-r--r--
📄
progress_callback.cpython-39.pyc
4.35 KB
02/11/2025 08:19:49 AM
rw-r--r--
📄
project_id.cpython-39.pyc
841 bytes
02/11/2025 08:19:48 AM
rw-r--r--
📄
pubsub_api.cpython-39.pyc
7.69 KB
02/11/2025 08:19:49 AM
rw-r--r--
📄
resumable_streaming_upload.cpython-39.pyc
5.23 KB
02/11/2025 08:19:49 AM
rw-r--r--
📄
seek_ahead_thread.cpython-39.pyc
4.09 KB
02/11/2025 08:19:49 AM
rw-r--r--
📄
sig_handling.cpython-39.pyc
4.62 KB
02/11/2025 08:19:49 AM
rw-r--r--
📄
storage_url.cpython-39.pyc
16.48 KB
02/11/2025 08:19:48 AM
rw-r--r--
📄
tab_complete.cpython-39.pyc
10.35 KB
02/11/2025 08:19:49 AM
rw-r--r--
📄
thread_message.cpython-39.pyc
12.17 KB
02/11/2025 08:19:49 AM
rw-r--r--
📄
tracker_file.cpython-39.pyc
17.01 KB
02/11/2025 08:19:49 AM
rw-r--r--
📄
tz_utc.cpython-39.pyc
2.05 KB
02/11/2025 08:19:49 AM
rw-r--r--
📄
ui_controller.cpython-39.pyc
30.35 KB
02/11/2025 08:19:49 AM
rw-r--r--
📄
wildcard_iterator.cpython-39.pyc
23.94 KB
02/11/2025 08:19:48 AM
rw-r--r--
Editing: pubsub_api.cpython-39.pyc
Close
a +(Wg�, � @ sF d Z ddlmZ ddlmZ ddlmZ ddlmZ ddlZddlZddlZddl m Z ddl m Z dd lmZ dd lmZ dd lmZ dd lmZ dd lmZ ddlmZ ddlmZ ddlmZ ddlmZ ddl m Z ddl m Z ddl m!Z! ddl m"Z" ddl m#Z# ddl$m%Z% e j&Z'e �(� �r.dZ)ndZ)G dd� de*�Z+dS ) z>JSON gsutil Cloud API implementation for Google Cloud Storage.� )�absolute_import)�print_function)�division)�unicode_literalsN)� exceptions)�config)�AccessDeniedException)�BadRequestException)�NotFoundException)�PreconditionException)�ServiceException)� SetUpJsonCredentialsAndCache)�NoOpCredentials)�pubsub_v1_client)�pubsub_v1_messages)� system_util)� GetCertsFile)�GetMaxRetryDelay)� GetNewHttp)� GetNumRetries)�UTF8zVInsufficient OAuth2 scope to perform this operation. Please re-run `gcloud auth login`zRInsufficient OAuth2 scope to perform this operation. Please re-run `gsutil config`c sn e Zd ZdZd� fdd� Zdd� Zdd � Zd d � Zd d � Zdd� Z ddd�Z dd� Z dd� Z ddd�Z � ZS )� PubsubApiz;Wraps calls to the Cloud Pub/Sub v1 interface via apitools.Nr c s� t t| ��� || _t� | _t� | _d| _t � ddd�| _ t � ddd�}|rTd| nd| _ | j| j | j | _ t| ||d � |d k}|d k}tj| j | j||| jd �| _t� | _| j| j_t� | _| j| j_t| jt�r�| j�d d � dS )a' Performs necessary setup for interacting with Google Cloud Pub/Sub. Args: logger: logging.logger for outputting log messages. credentials: Credentials to be used for interacting with Google Cloud Pub/Sub debug: Debug level for the API implementation (0..3). zhttps://� CredentialsZgs_pubsub_hostzpubsub.googleapis.com�gs_pubsub_portN�:� )� credentials� )�url�http� log_request� log_responser �key�'AIzaSyDnacJHrKma0048b13sh8cgxNUwulubmJM)�superr �__init__�loggerr � certs_filer r � http_baser �get� host_base� host_port�url_baser �apitools_clientZPubsubV1r � api_clientr � num_retriesr �max_retry_wait� isinstancer �AddGlobalParam)�selfr& r �debugr r r! �� __class__� � /opt/gsutil/gslib/pubsub_api.pyr% ; s8 �� �zPubsubApi.__init__c C sT t j|d�}z| jj�|�W S tyN } z| j||d� W Y d }~n d }~0 0 d S )N��topic�� topic_name)�apitools_messagesZ PubsubProjectsTopicsGetRequestr. �projects_topics�Get� TRANSLATABLE_APITOOLS_EXCEPTIONS�_TranslateExceptionAndRaise�r3 r< �request�er7 r7 r8 �GetTopicg s zPubsubApi.GetTopicc C sT t j|d�}z| jj�|�W S tyN } z| j||d� W Y d }~n d }~0 0 d S )N)�namer; )r= ZTopicr. r> �Creater@ rA )r3 r< r: rD r7 r7 r8 � CreateTopicn s zPubsubApi.CreateTopicc C sT t j|d�}z| jj�|�W S tyN } z| j||d� W Y d}~n d}~0 0 dS )zOnly used in system tests.r9 r; N)r= Z!PubsubProjectsTopicsDeleteRequestr. r> �Deleter@ rA rB r7 r7 r8 � DeleteTopicu s �zPubsubApi.DeleteTopicc C sT t j|d�}z| jj�|�W S tyN } z| j||d� W Y d }~n d }~0 0 d S )N)�resourcer; )r= Z'PubsubProjectsTopicsGetIamPolicyRequestr. r> � GetIamPolicyr@ rA rB r7 r7 r8 �GetTopicIamPolicy~ s �zPubsubApi.GetTopicIamPolicyc C sb t j|d�}t j||d�}z| jj�|�W S ty\ } z| j||d� W Y d }~n d }~0 0 d S )N)�policy)rK �setIamPolicyRequestr; )r= �SetIamPolicyRequestZ'PubsubProjectsTopicsSetIamPolicyRequestr. r> � SetIamPolicyr@ rA )r3 r< rN �policy_requestrC rD r7 r7 r8 �SetTopicIamPolicy� s �zPubsubApi.SetTopicIamPolicyc C s> | j �tj�r | j �dt�� � | j||d�}|r8|�n� dS )a+ Translates an HTTP exception and raises the translated or original value. Args: e: Any Exception. topic_name: Optional topic name in request that caused the exception. Raises: Translated CloudApi exception, or the original exception if it was not translatable. z TranslateExceptionAndRaise: %sr; N)r& � isEnabledFor�logging�DEBUGr4 � traceback� format_exc�_TranslateApitoolsException)r3 rD r< �translated_exceptionr7 r7 r8 rA � s ��z%PubsubApi._TranslateExceptionAndRaisec C sh t |tj�rdt|dd �rdz8t�|j�t��}d|v rNd|d v rN|d d W S W n t yb Y n0 d S )N�content�error�message) r1 �apitools_exceptions� HttpError�getattr�json�loadsr[ �decoder � Exception)r3 � http_error�json_objr7 r7 r8 �_GetMessageFromHttpError� s z"PubsubApi._GetMessageFromHttpErrorc C sX z@|j d }|�d�}|dkr>||d � �d�d }d| W S W n tyR Y n0 d S )Nzwww-authenticatezscope="r �"� zAcceptable scopes: %s)�response�find�splitrd )r3 re �www_authenticate� scope_idx�scopesr7 r7 r8 �!_GetAcceptableScopesFromHttpError� s z+PubsubApi._GetAcceptableScopesFromHttpErrorc C s� t |tj��r�| �|�}|jdkr4t|p*d|jd�S |jdkr�dt|�v r\t|pRd|jd�S dt|�v r~tt|j| � |�d�S �n|jd k�r<d t|�v r�t|p�d |jd�S d t|�v r�t|p�d |jd�S dt|�v r�td|jd�S dt|�v �r td|jd�S dt|�v �r$tt|j| � |�d�S t|�p0|j |jd�S nX|jdk�rVt ||jd�S |jdk�rz|�rzt d| |jd�S |jdk�r�t ||jd�S t ||jd�S dS )a- Translates apitools exceptions into their gsutil equivalents. Args: e: Any exception in TRANSLATABLE_APITOOLS_EXCEPTIONS. topic_name: Optional topic name in request that caused the exception. Returns: ServiceException for translatable exceptions, None otherwise. i� z Bad Request)�statusi� zLogin Requiredz Access denied: login required.�insufficient_scope)rq �bodyi� z7The account for the specified project has been disabledzAccount disabled.z,Daily Limit for Unauthenticated Use Exceededz8Access denied: quota exceeded. Is your project ID valid?zUser Rate Limit Exceededz5Rate limit exceeded. Please retry this request later.zAccess Not Configuredz�Access Not Configured. Please go to the Google Cloud Platform Console (https://cloud.google.com/console#/project) for your project, select APIs and Auth and enable the Google Cloud Pub/Sub API.i� i� z The topic %s already exists.i� N)r1 r^ r_ rg � status_coder �strr �"_INSUFFICIENT_OAUTH2_SCOPE_MESSAGErp r] r r r )r3 rD r< r] r7 r7 r8 rY � sp � � � � � ��� � � z%PubsubApi._TranslateApitoolsException)NNr )N)N)�__name__� __module__� __qualname__�__doc__r% rE rH rJ rM rS rA rg rp rY � __classcell__r7 r7 r5 r8 r 8 s , r ),rz � __future__r r r r ra rU rW �apitools.base.pyr r^ �botor �gslib.cloud_apir r r r r �gslib.gcs_json_credentialsr �gslib.no_op_credentialsr Z!gslib.third_party.pubsub_apitoolsr r- r r= � gslib.utilsr Zgslib.utils.boto_utilr r r r �gslib.utils.constantsr r_ r@ �InvokedViaCloudSdkrv �objectr r7 r7 r7 r8 �<module> s> ��