,SrSSKJr SSKJr SSKJr SSKJr SSKrSSKrSSKrSSK J r SSK J r SS KJr SS KJr SS KJr SS KJr SS KJr SSKJr SSKJr SSKJr SSKJr SSKJr SSKJ r SSKJ!r! SSKJ"r" SSKJ#r# SSK$J%r% \ RLr'\RP"5(aSr)OSr)"SS\*5r+g)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`cn^\rSrSrSrSU4SjjrSrSrSrSr Sr SS jr S r S r SS jrS rU=r$) PubsubApi8z;Wraps calls to the Cloud Pub/Sub v1 interface via apitools.c$>[[U] 5 Xl[ 5Ul[ 5UlSUl[R"SSS5Ul [R"SSS5nU(aSU-OSUl URUR-UR-Ul [XUS 9 US :nUS :n[R "URURUUUR"S 9Ul['5UlUR(UR$l[+5UlUR,UR$l[/UR"[05(aUR$R3S S 5 gg)aPerforms 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*PubsubApi.__init__;s@ )T#%K"nDO DIDNZZ /? 79DNZZ /?FN/=cN*2DN^^dnn4t~~EDM ;GA:KQJL%..4==48II;F>ZPGA __ , , 0 0 99 +A &&q&@A$; AAAc[R"US9nURRR U5$![ anUR X1S9 SnAgSnAff=f)N)namerB)rDTopicr4rFCreaterHrI)r9rCrArLs r< CreateTopicPubsubApi.CreateTopicnsV  # # 4EA __ , , 3 3E :: +A &&q&@ArOc[R"US9nURRR U5$![ anUR X1S9 SnAgSnAff=f)zOnly used in system tests.r@rBN)rD!PubsubProjectsTopicsDeleteRequestr4rFDeleterHrIrJs r< DeleteTopicPubsubApi.DeleteTopicusYAAGA __ , , 3 3G << +A &&q&@ArOc[R"US9nURRR U5$![ anUR X1S9 SnAgSnAff=f)N)resourcerB)rD'PubsubProjectsTopicsGetIamPolicyRequestr4rF GetIamPolicyrHrIrJs r<GetTopicIamPolicyPubsubApi.GetTopicIamPolicy~sYGGGA __ , , 9 9' BB +A &&q&@ArOc[R"US9n[R"XS9nURRR U5$![ anURXQS9 SnAgSnAff=f)N)policy)r\setIamPolicyRequestrB)rDSetIamPolicyRequest'PubsubProjectsTopicsSetIamPolicyRequestr4rF SetIamPolicyrHrI)r9rCrbpolicy_requestrKrLs r<SetTopicIamPolicyPubsubApi.SetTopicIamPolicysj&::&INGGAGA __ , , 9 9' BB +A &&q&@As$A A2A--A2cURR[R5(a/URR S[ R "55 URXS9nU(aUee)aTranslates 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: %srB)r+ isEnabledForloggingDEBUGr: traceback format_exc_TranslateApitoolsException)r9rLrCtranslated_exceptions r<rI%PubsubApi._TranslateExceptionAndRaisesc {{ .. kk8!,,.0;; <"   r>c"[U[R5(a`[USS5(aM[R "UR R[55nSU;aSUS;aUSS$gggg![a gf=f)Ncontenterrormessage) r7apitools_exceptions HttpErrorgetattrjsonloadsrtdecoder Exception)r9 http_errorjson_objs r<_GetMessageFromHttpError"PubsubApi._GetMessageFromHttpErrors*1;;<< Y - - ZZ 2 2 9 9$ ?@(  Y(72C%CG$Y/ /&D  .=    sA B B BcURSnURS5nUS:aX#SRS5SnSU-$g![a gf=f)Nzwww-authenticatezscope="r"zAcceptable scopes: %s)responsefindsplitr})r9r~www_authenticate scope_idxscopess r<!_GetAcceptableScopesFromHttpError+PubsubApi._GetAcceptableScopesFromHttpErrorsp #,,-?@#'' 2i a!*-33C8;&//     sAA AAc[U[R5(GaFURU5nURS:Xa[ U=(d SURS9$URS:XaeS[ U5;a[U=(d SURS9$S[ U5;a([[URURU5S9$GOURS :XaS [ U5;a[U=(d S URS9$S [ U5;a[U=(d S URS9$S[ U5;a[SURS9$S[ U5;a[SURS9$S[ U5;a([[URURU5S9$[U=(d URURS9$URS:Xa[X1RS9$URS:XaU(a[SU-URS9$URS:Xa[X1RS9$[X1RS9$g)aTranslates 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)r7rwrxr status_coder strr "_INSUFFICIENT_OAUTH2_SCOPE_MESSAGErrvr r r )r9rLrCrvs r<rp%PubsubApi._TranslateApitoolsExceptionsA!(2233--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 $W]]CC gmm <) r4r,r/r0r$r-r+r6r5r1)NNr)N)__name__ __module__ __qualname____firstlineno____doc__r*rMrTrYr_rhrIrrrp__static_attributes__ __classcell__)r;s@r<rr8sFC*PXAAAAA *  (G=G=r>r),r __future__rrrrrzrlrnapitools.base.pyrrwbotorgslib.cloud_apir r r r r gslib.gcs_json_credentialsrgslib.no_op_credentialsr!gslib.third_party.pubsub_apitoolsrr2rrD gslib.utilsrgslib.utils.boto_utilrrrrgslib.utils.constantsrrxrHInvokedViaCloudSdkrobjectrr>r<rsE&%' >1/-1,C3QU#.2,/&$7$A$A !!##*% &% R=R=r>