,vdZddlmZddlmZddlmZddlmZddlZddlZddlZddl m Z ddl m Z dd lmZdd lmZdd lmZdd lmZdd lmZddlmZddlmZddlmZddlmZddlmZddlm Z ddlm!Z!ddlm"Z"ddlm#Z#ddl$m%Z%e jLZ'ejPrdZ)ndZ)Gdde*Z+y)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^eZdZdZd fd ZdZdZdZdZdZ d dZ d Z d Z d d Z xZS) PubsubApiz;Wraps calls to the Cloud Pub/Sub v1 interface via apitools.ctt| ||_t |_t |_d|_tjddd|_ tjddd}|rd|znd|_ |j|jz|jz|_ t||| |d k\}|d k\}tj |j|j|||j" |_t'|_|j(|j$_t+|_|j,|j$_t/|j"t0r|j$j3d d yy)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:// Credentialsgs_pubsub_hostzpubsub.googleapis.comgs_pubsub_portN:) credentials)urlhttp log_request log_responser key'AIzaSyDnacJHrKma0048b13sh8cgxNUwulubmJM)superr__init__loggerr certs_filerr# http_baserget host_base host_porturl_baserapitools_clientPubsubV1r api_clientr num_retriesrmax_retry_wait isinstancerAddGlobalParam)selfr*r debugrr$r% __class__s #platform/gsutil/gslib/pubsub_api.pyr)zPubsubApi.__init__;sA )T#%DK"nDO DIDNZZ /? 79DNZZ /?FN/=cN*2DN^^dnn4t~~EDM v;GA:KQJL%..4==48II;F>ZPGA __ , , 0 0 99 +A &&qZ&@@A$= A#AA#ctj|} |jjj |S#t $r}|j ||Yd}~yd}~wwxYw)N)namer@)rBTopicr3rDCreaterFrG)r8rAr?rJs r; CreateTopiczPubsubApi.CreateTopicns[  # # 4EA __ , , 3 3E :: +A &&qZ&@@ArLctj|} |jjj |S#t $r}|j ||Yd}~yd}~wwxYw)zOnly used in system tests.r>r@N)rB!PubsubProjectsTopicsDeleteRequestr3rDDeleterFrGrHs r; DeleteTopiczPubsubApi.DeleteTopicus^AAGA __ , , 3 3G << +A &&qZ&@@ArLctj|} |jjj |S#t $r}|j ||Yd}~yd}~wwxYw)N)resourcer@)rB'PubsubProjectsTopicsGetIamPolicyRequestr3rD GetIamPolicyrFrGrHs r;GetTopicIamPolicyzPubsubApi.GetTopicIamPolicy~s^GGGA __ , , 9 9' BB +A &&qZ&@@ArLctj|}tj||} |jjj |S#t $r}|j||Yd}~yd}~wwxYw)N)policy)rWsetIamPolicyRequestr@)rBSetIamPolicyRequest'PubsubProjectsTopicsSetIamPolicyRequestr3rD SetIamPolicyrFrG)r8rAr\policy_requestrIrJs r;SetTopicIamPolicyzPubsubApi.SetTopicIamPolicysq&::&INGGAGA __ , , 9 9' BB +A &&qZ&@@As$A A:A55A:c|jjtjr.|jj dt j |j||}|r|)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. zTranslateExceptionAndRaise: %sr@)r* isEnabledForloggingDEBUGr9 traceback format_exc_TranslateApitoolsException)r8rJrAtranslated_exceptions r;rGz%PubsubApi._TranslateExceptionAndRaisesb {{ . kk8!,,.0;; j<"   r<ct|tjrVt|ddrH t j |j jt}d|vrd|dvr|ddSyyyy#t$rYywxYw)Ncontenterrormessage) r6apitools_exceptions HttpErrorgetattrjsonloadsrldecoder Exception)r8 http_errorjson_objs r;_GetMessageFromHttpErrorz"PubsubApi._GetMessageFromHttpErrors*1;;< Y - ZZ 2 2 9 9$ ?@(  Y(72C%CG$Y/ /&D  .=    sAA22 A>=A>c |jd}|jd}|dk\r||djdd}d|zSy#t$rYywxYw)Nzwww-authenticatezscope="r"zAcceptable scopes: %s)responsefindsplitru)r8rvwww_authenticate scope_idxscopess r;!_GetAcceptableScopesFromHttpErrorz+PubsubApi._GetAcceptableScopesFromHttpErrorsr #,,-?@#'' 2i a!)*-33C8;&//     sAA AAct|tjr=|j|}|jdk(rt |xsd|jS|jdk(radt |vrt|xsd|jSdt |vrtt|j|j|S|jd k(rd t |vrt|xsd |jSd t |vrt|xsd |jSdt |vrtd|jSdt |vrtd|jSdt |vr+tt|j|j|St|xs |j|jS|jdk(rt||jS|jdk(r|rtd|z|jS|jdk(rt||jSt||jSy)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. iz Bad Request)statusizLogin RequiredzAccess denied: login required.insufficient_scope)rbodyiz7The 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 ConfiguredzAccess 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.iizThe topic %s already exists.iN)r6rorprx status_coder strr "_INSUFFICIENT_OAUTH2_SCOPE_MESSAGErrnr r r )r8rJrArns r;riz%PubsubApi._TranslateApitoolsExceptions?!(223--a0g # #7#;m*+--9 9 ==C  s1v %&w(H'G./mm= ="SV +'0]]99!<> > ==C  DA N&w'E2E./mm= = ;s1v E&w(C(C./mm= =(3q6 1&]]$ $%A .&*]] $ $ "SV +'0]]99!<> > 'w';!))./mm= = ==C  ?? ==C J > K'(}}6 6 ==C $WQ]]CC gamm <rsE&%' >1/-1,C3QU#.2,/&$7$A$A !;!!#*% &% R=R=r<