ODSrSSKJr SSKJr SSKJr SSKrSSKrSSKJr SSKJ r SSKJ r SSK J r SS K Jr SSKJ r SS KJr SS KJr SS KJr SS KJr SSKJr SSKJr SSKJr SSKr\R8"S5r\R8"S\R<5rSr \ S-r!\ S-r"Sr#Sr$/SQr%Sr&Sr'Sr(Sr)Sr*Sr+S7Sjr,S r-S!r.S"r/S#r0S$r1S%r2S&r3S'r4S(r5S8S)jr6S*r7S9S+jr8S:S,jr9S-r:S:S.jr;S/rS:S2jr?S:S3jr@S4rAS5rBS:S6jrCg);z6Common helper methods for Service Management commands.)absolute_import)division)unicode_literalsN)encoding) exceptions) list_pager)apis)log) properties) resources)yaml)resource_printer)files)retryz^.+@([^.@][^@]+)$z)^([a-f0-9][a-f0-9]:){19}[a-f0-9][a-f0-9]$zgcloud endpoints operations z describe {0}zwait {0}zservicemanagement.servicesz"servicemanagement.services.configs) zservicemanagement.services.getz-servicemanagement.services.getProjectSettingsz!servicemanagement.services.deletez!servicemanagement.services.updatezservicemanagement.services.bindz0servicemanagement.services.updateProjectSettingsz servicemanagement.services.checkz!servicemanagement.services.reportz'servicemanagement.services.setIamPolicyz'servicemanagement.services.getIamPolicyc0[R"SS5$Nservicemanagementv1)r GetMessagesModule5lib/googlecloudsdk/api_lib/endpoints/services_util.pyrrA   3T ::rc0[R"SS5$r)r GetClientInstancerrrrrErrcg)Nz servicemanagement.googleapis.comrrrrGetServiceManagementServiceNamerIs +rcU(a5[RRRR U5 U$[RRRR SS9nU$)zValidate the project ID, if supplied, otherwise return the default project. Args: project_id: The ID of the project to validate. If None, gcloud's default project's ID will be returned. Returns: The validated project ID. T)required)r VALUEScoreprojectValidateGet project_ids rGetValidatedProjectr'Ms\""++J7 ""''//33T3BJ rc[5RnU"UUUS9n[5RR U5$)aLReturns the project settings for a given service, project, and view. Args: service: The service for which to return project settings. consumer_project_id: The consumer project id for which to return settings. view: The view (CONSUMER_VIEW or PRODUCER_VIEW). Returns: A ProjectSettings message with the settings populated. ) serviceNameconsumerProjectIdview)r2ServicemanagementServicesProjectSettingsGetRequestrservices_projectSettingsr$)serviceconsumer_project_idr+ get_requestrequests rGetProjectSettingsr2^sF#$DD +  '   5 5 9 9' BBrc0[5RUS9$)N)producerProjectId)r$ServicemanagementServicesListRequestr%s rGetProducedListRequestr6xs!   A A" B rcN[R"U/U[RS9 g)zPrints the given resource. Args: resource: The resource to print out. print_format: The print_format value to pass along to the resource_printer. )r print_formatoutN)rPrintr r9)resourcer8s r PrettyPrintr<~s!  ''rc[5nURRnXRURUR 4;a$[ R"U5R5$g)zConvert a ConfigChange.ChangeType enum to a string. Args: change_type: The ConfigChange.ChangeType enum to convert. Returns: An easily readable string representing the ConfigChange.ChangeType enum. z [unknown]) r ConfigChangeChangeTypeValueValuesEnumADDEDREMOVEDMODIFIEDsix text_typelower) change_typemessagesenumss rPushAdvisorChangeTypeToStringrIsQ (    9 9%[[%--@@ == % + + -- rcSRURURUR[ UR 5S9nUR H!nUSRUR5- nM# U$)zConvert a ConfigChange message to a printable string. Args: config_change: The ConfigChange message to convert. Returns: An easily readable string representing the ConfigChange message. zbElement [{element}] (old value = {old_value}, new value = {new_value}) was {change_type}. Advice: )element old_value new_valuerFz * {0})formatrKoldValuenewValuerI changeTypeadvices description) config_changeresultadvices rPushAdvisorConfigChangeToStringrWs DEKV%--'00'009!,,. FLF/ %%f iv1122F& -rc "^[5n[5nURRnURUR /mUR US9n[[R"URUU4SjSSSS95nU(aUS$S$) a.Return the latest Rollout for a service. This function returns the most recent Rollout that has a status of SUCCESS or IN_PROGRESS. Args: service: The name of the service for which to retrieve the active Rollout. Returns: The Rollout message corresponding to the active Rollout for the service. r)c">URT;$N)status)rallowed_statusess r,GetActiveRolloutForService..sahh*::rpageSizerollouts) predicatelimitbatch_size_attributefieldrN) rrRolloutStatusValueValuesEnumSUCCESS IN_PROGRESS,ServicemanagementServicesRolloutsListRequestlistr YieldFromListservices_rollouts)r.clientrGstatusesreqrUr^s @rGetActiveRolloutForServicerss  &  (    3 3(&&(<(<=== > #   " " :)  &&$&rcU(aKUR(a:URRRVs/sHoRPM sn$/$s snf)zGet the active service config IDs from a Rollout message. Args: rollout: The rollout message to inspect. Returns: A list of active service config IDs as indicated in the rollout message. )trafficPercentStrategy percentagesadditionalPropertieskey)rolloutps r$GetActiveServiceConfigIdsFromRolloutr{sU //"99EE ! !" #"aEE" ## I #sAc.[U5n[U5$r[)rsr{)r.active_rollouts r#GetActiveServiceConfigIdsForServicer~s-g6. -n ==rcUR5nUH)nURUR55(dM) g g)zChecks to see if a file name matches one of the given extensions. Args: filename: The full path to the file to check extensions: A list of candidate extensions. Returns: True if the filename matches one of the extensions, otherwise False. TF)rEendswith)filename extensionsfexts rFilenameMatchesExtensionrs7nn! czz#))+  rc[U/SQ5$)N)z.pbz .descriptorz .proto.binrrs rIsProtoDescriptorrs !4 66rc[US/5$)Nz.protorrs r IsRawProtors !(XJ 77rc[U5(a[R"U5$[R"U5$![Ra*n[ R "SRX55eSnAff=f)Nz-Could not open service config file [{0}]: {1})rrReadBinaryFileContentsReadFileContentsErrorcalliope_exceptionsBadFileExceptionrN) file_pathexs rReadServiceConfigFilersnO##  ) )) 44  ! !) ,, O  . .7>>yM OOOs%>>A<%A77A<c[5n[5n[R"X$R5nXlX6lURUUS9nURRU5$)a?Pushes a given normalized Google service configuration. Args: service_name: name of the service project: the producer project Id config_dict: the parsed contents of the Google Service Config file. config_id: The id name for the config Returns: Result of the ServicesConfigsCreate request (a Service object) )r)r.) rrr DictToMessageServicer4id-ServicemanagementServicesConfigsCreateRequestservices_configsCreate) service_namer" config_dict config_idrGrpservice_configcreate_requests r!PushNormalizedGoogleServiceConfigrso (  &))+7G7GH.%,"<<" =  ' ' 77rcDURS05RS5$)N serviceConfigr)get)responses r0GetServiceConfigIdFromSubmitConfigSourceResponser+s or * . .t 44rc[5n[5nURUS9nURR U5 UR UUS9nUR UUS9n URRU 5n [X5n U RS05n U RS/5n SnU HnURSS5R5nUS :Xa[RO[RnS RURS 5URS 5S 9nU"U5 US :XdMUS- nM US:a/SRXS:aSOS5n[ R""U5eU $)aPushes a given set of service configuration files. Args: service_name: name of the service. config_files: a list of ConfigFile message objects. is_async: whether to wait for aync operations or not. validate_only: whether to perform a validate-only run of the operation or not. config_id: an optional name for the config Returns: Full response from the SubmitConfigSource request. Raises: ServiceDeployErrorException: the SubmitConfigSource API call returned a diagnostic with a level of ERROR. )r) configSource validateOnly)r)submitConfigSourceRequestr diagnosticsrkindERRORz {l}: {m} locationmessage)lmrazW{0} diagnostic error{1} found in service configuration deployment. See log for details.s)rr ConfigSourcerextendSubmitConfigSourceRequest-ServicemanagementServicesConfigsSubmitRequestrSubmitProcessOperationResultrupperr errorwarningrNrServiceDeployErrorException)r config_filesis_async validate_onlyrrGrp config_sourceconfig_source_requestsubmit_request api_response operationrr num_errors diagnosticrloggermsg exception_msgs rPushMultipleServiceConfigFilesr/s{& (  &''9'5-\*"<<  = <<"$9= ((//?,$\<) ]]:r *( ]B/+*j >>&" % + + -D'/SYYs{{F    .. $ y(A  CC 3K wAoj !^89?#NS:D  0 0 ?? /rc[5nURUUURRRS9n[ X/UUS9$)aPushes a given Open API service configuration. Args: service_name: name of the service spec_file_contents: the contents of the Open API spec file. spec_file_path: the path of the Open API spec file. is_async: whether to wait for aync operations or not. validate_only: whether to perform a validate-only run of the operation or not. Returns: Full response from the SubmitConfigSource request. ) fileContentsfilePathfileType)r)r ConfigFileFileTypeValueValuesEnum OPEN_API_YAMLr)rspec_file_contentsspec_file_pathrrrG config_files rPushOpenApiServiceConfigrksT  (##%##'' $+ ( mX6C EErc[5n[5nURUS9nURR U5 g![ R [ R4a gf=f)zCheck if a service resource exists. Args: service_name: name of the service to check if exists. Returns: Whether or not the service exists. rYTF)rr#ServicemanagementServicesGetRequestservicesr$apitools_exceptionsHttpForbiddenErrorHttpNotFoundError)rrGrpr0s rDoesServiceExistrsr (  &<<=+ OO $   0 0  / / 1  sA$A('A(c[5n[5nURUUS9nURR U5n[ XbS9 g)zCreates a Service resource. Args: service_name: name of the service to be created. project: the project Id is_async: If False, the method will block until the operation completes. )r)r4)rN)rrManagedServicerrGetProcessedOperationResult)rr"rrGrprrUs r CreateServicersM (  &**+. ?? ! !. 1&f8rc<[R"[U5SL$r[)rematchFINGERPRINT_REGEX) fingerprints rValidateFingerprintrs #[ 1 ==rcl[RU=(d S5SL=(a [U5S:*$)aReturns true if the input is a valid email string. This method uses a somewhat rudimentary regular expression to determine input validity, but it should suffice for basic sanity checking. It also verifies that the email string is no longer than 254 characters, since that is the specified maximum length. Args: email: The email string to validate Returns: A bool -- True if the input is valid, False otherwise rN) EMAIL_REGEXrlen)emails rValidateEmailStringrs,   5;B 't 3 IE c8IIrcv[X5nU(aT[RURS55n[R R SRU55 U$[RURS55n[R R SRU55 U$)aValidate and process Operation outcome for user display. Args: result: The message to process (expected to be of type Operation)' is_async: If False, the method will block until the operation completes. Returns: The processed Operation message in Python dict form namezdAsynchronous operation is in progress... Use the following command to wait for its completion: {0} z`Operation finished successfully. The following command can describe the Operation details: {0} )r OP_WAIT_CMDrNrr r\r:OP_DESCRIBE_CMD)rUropcmds rrrs#64"   RVVF^ ,CJJ++16#;8 )   0CJJ66TRUS9nTRRU5nUR(a U[lgg)N) operationsIdTF)%ServicemanagementOperationsGetRequest operationsr$doneroperation_response) operation_idr1rUrprGs r_CheckOperation)WaitForOperation.._CheckOperation sI<<!=G   " "7 +F {{,2)  rg?i'i@w)exponential_sleep_multiplierwait_ceiling_ms max_wait_msFi)should_retry_ifsleep_mszTTimed out while waiting for operation {0}. Note that the operation is still pending.z0The operation with ID {0} resulted in a failure.) rr rrrRetryer RetryOnResultMaxRetrialsExceptionr TimeoutErrorrNrOperationErrorException) operation_refrpr r rGs ` @rrrs)-%  (++, L MMsE(**7-%~u#+8+%((..:  , ,:AA,O QQ  , ,,  # #L  ! !#66[R"T5$![a [R"S5 gf=f)Nz2No JSON detected in service config. Trying YAML...)jsonloads ValueErrorr info) input_stringsrTryJsonLoadJsonOrYaml..TryJsonLs6E ZZ %% E hhCDEs  <<cR>[R"T5$![Rayn[URS5(aTURR n[ R"SURS-<SURS-<S35 SnAgSnAgSnAff=f)N problem_markz.Service config YAML had an error at position (ra:)) r loadYAMLParseErrorhasattr inner_errorr$r rlinecolumn)emarkr s rTryYamlLoadJsonOrYaml..TryYamlRs}2 YY| $$   2  / /}})) YYq[$++a-1 2 2 02sB&A*B!!B&r)r r!r/s` rLoadJsonOrYamlr1BsE 2  girc[5n[5nURR5nURR URRR USS95 URUS9nURUUS9nURUUS9nURRU5n [X5n U RSS5$)a)Creates a Rollout for a Service Config within it's service. Args: service_config_id: The service config id service_name: The name of the service is_async: (Optional) Wheter or not operation should be asynchronous Returns: The rollout object or long running operation if is_async is true gY@)rxvalue)rv)r)ru)ryr)rN) rrTrafficPercentStrategyPercentagesValuerwappendAdditionalPropertyrh.ServicemanagementServicesRolloutsCreateRequestrorrr) service_config_idrrrGrprvtraffic_percent_strategyryrollout_createrollout_operationrs r CreateRolloutr=_s (  &//@@B+ ""))&&77JJuK.0&<<=   5  8'JJK...55nE/:"  D !!r)rr[)FN)F)D__doc__ __future__rrrrrapitools.base.pyrrrr googlecloudsdk.api_lib.endpointsgooglecloudsdk.api_lib.utilr googlecloudsdk.calliopergooglecloudsdk.corer r r r googlecloudsdk.core.resourcergooglecloudsdk.core.utilrrrCcompiler IGNORECASEr OP_BASE_CMDrrSERVICES_COLLECTIONCONFIG_COLLECTIONALL_IAM_PERMISSIONSrrrr'r2r6r<rIrWrsr{r~rrrrrrrrrrrrrrrrr1r=rrrrMsJ =&' %>'7,E#*)$9** jj-. JJ0"--A, .J& 28 ;;,"C4 ".'D  > "6 8O158:5 CG9|E:29(>J$ 0!HA1-h :"r