o <@sdZddlmZddlmZddlmZddlZddlmZddlm Z ddl m Z dd l m Z dd l mZdd l mZdd lmZd ZedZedZdZddZddZddZddZddZddZddZdS)z,Common helper methods for Services commands.)absolute_import)division)unicode_literalsN)encoding) exceptions) apis_internal)log) properties) transport)retryzgcloud services operations z describe {0}zwait {0}zservicemanagement.servicescCs tddS)Nservicemanagementv1)r_GetMessagesModulerrJ/tmp/google-cloud-sdk/lib/googlecloudsdk/api_lib/services/services_util.pyGetMessagesModule's rcCs:ddlm}tjjj}|jtj |d}t j dd|dS)zDGet a client instance for service management without resource quota.r) transports)response_encodingenable_resource_quotar r ) http_client) googlecloudsdk.core.credentialsrr VALUESbilling quota_projectIsExplicitlySetGetApitoolsTransportr ENCODINGr_GetClientInstance)rrrrrrGetClientInstance,s rcCs.|r tjjj||Stjjjjdd}|S)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 rcoreprojectValidateGet) project_idrrrGetValidatedProject@s  r%cshfdd}g}ztjddddj|||gddd Wntjy+td |w|r2|d Sd S) aZWait till the operation is done. Args: name: The name of operation. get_op_func: The function that gets the operation. Raises: exceptions.OperationErrorException: when the getting operation API fails. apitools_exceptions.HttpError: Another miscellaneous error with the service. Returns: The result of the operation cs |}|jr |||j S)N)doneappend)nameresultop get_op_funcrr_CheckOp`s zWaitOperation.._CheckOpg?i'i@w)exponential_sleep_multiplierwait_ceiling_ms max_wait_msTi)should_retry_ifsleep_mszTTimed out while waiting for operation {0}. Note that the operation is still pending.rN)r Retryer RetryOnResultMaxRetrialsExceptionr TimeoutErrorformat)r(r,r-r)rr+r WaitOperationQs"   r8cCsZ|jstjd|jdS|jr!td|j|jj |jj tjd|jdS)zPrint the operation. Args: op: The long running operation. Raises: OperationErrorException: if the operation fails. Returns: Nothing. %Operation "{0}" is still in progress.N@The operation "{0}" resulted in a failure "{1}". Details: "{2}".&Operation "{0}" finished successfully.) r&rstatusPrintr7r(errorrOperationErrorExceptionmessagedetailsr*rrrPrintOperationus rCc Cs|jstjd|jdS|jr!td|j|jj |jj |j rrr?r@rAresponsejsondumpsr MessageToDictrBrrrPrintOperationWithResponses&    rQc Cs|jstjd|jdS|jr&|jj}|dd}t d|j||j rAtjd|jt j t|j ddd d dStjd |jdS) zPrint the operation with response for update consumer policy. Args: op: The long running operation. Raises: OperationErrorException: if the operation fails. Returns: Nothing. r9NzPlease specify forcez,Please specify --bypass-api-usage-check flagz/The operation "{0}" resulted in a failure "{1}"rDTrErFrIr;)r&rr<r=r7r(r>r@replacerr?rMrNrOrrP)r* error_messagemodified_messagerrr1PrintOperationWithResponseForUpdateConsumerPolicys4   rU)__doc__ __future__rrrrNapitools.base.pyrgooglecloudsdk.api_lib.servicesrgooglecloudsdk.api_lib.utilrgooglecloudsdk.corerr r googlecloudsdk.core.utilr OP_BASE_CMDOP_DESCRIBE_CMD OP_WAIT_CMDSERVICES_COLLECTIONrrr%r8rCrQrUrrrrs.          $