ASrSSKJr SSKJr SSKJr SSKrSSKJr "SS\R5r "S S \ 5r S r S r S r SrSrSrSrSrSrSrSrSrSrSrSrSrSrSrSrSrg)z*Utilities for `gcloud network-management`.)absolute_import)division)unicode_literalsN) exceptionsc\rSrSrSrSrg)NetworkManagementErrorz6Top-level exception for all Network Management errors.N__name__ __module__ __qualname____firstlineno____doc____static_attributes__r 9lib/googlecloudsdk/command_lib/network_management/util.pyrrs>rrc\rSrSrSrSrg)InvalidInputErrorzException for invalid input.r Nr r rrrrs$rrcS/n[U5S:aURS5 [U5Hup4URSRXS95 US:Xa"[U5S:XaURS5 MKU[U5S- :XaURS 5 MpU[U5S- :dMURS 5 M URS 5 S R U5$) zOCreates a message to specify at least one endpoint, separated by commas and or.zInvalid Connectivity Test. zAt least one of z--{endpoint_type}-{endpoint}) endpoint_typeendpointrz or z, or z, z must be specified.)lenappend enumerateformatjoin) endpointsr error_msgindexrs r"GetClearSingleEndpointAttrErrorMsgr%!s,-)^a '("9-oe &--' .   zc)n)v #i.1$ $w Y!# #t. ()  rc0U=RS- slU$)zXAdd locations/global to parent path, since it isn't automatically populated by apitools./locations/global)parent unused_ref unused_argsrequests rAppendLocationsGlobalToParentr-8s ..''. .rc0U=RS- slU$)Nr')namer)s r"UpdateOperationRequestNameVariabler0>s ,,%%, .rc`URnU(dXlU$X;a US-U-UlU$)z"Adds name of field to update mask.,) updateMask)field patch_request update_masks rAddFieldToUpdateMaskr7Cs>((+ $  *S058M rcH1SknX;a [XS5 g[XS5 g)N> cloudFunctionappEngineVersioncloudRunRevisionr)setattr)r endpoint_nameproto_endpoint_fieldss rClearEndpointValuer?Ms( + HT* HR(rcURn[X15n1SknSnUHn[XGS5(dMUS- nM US:d[XBS5(d/[XB5 [X1U5 X0l[ US-U-U5$/SQnUS:XaUR /SQ5 US :XaUR /S Q5 [ [X55e zNChecks if given endpoint can be removed from Connectivity Test and removes it.> instance ipAddress redisClusterr9 redisInstanceforwardingRuler:r;cloudSqlInstancegkeMasterClusterrNr.)rBz ip-addresszgke-master-clusterzcloud-sql-instancesource)zcloud-functionzapp-engine-versionzcloud-run-revision destination)zforwarding-rulezredis-instancez redis-clusterconnectivityTestgetattrr?r<r7extendrr% r5rr=testrendpoint_fieldsnon_empty_endpoint_fieldsr4r"s rClearSingleEndpointAttrrT[  ' '$ T )( / ex%%1$"'t++x/ D*%)" m+] I    % *9D rcp/SQnUH+upEnURU5(dM[UUU5nM- U$z5Handles clear_source_* and clear_destination_* flags.))clear_source_instancerJrB)clear_source_ip_addressrJrC)clear_source_gke_master_clusterrJrH)clear_source_cloud_sql_instancerJrG)clear_source_cloud_functionrJr9)clear_source_app_engine_versionrJr:)clear_source_cloud_run_revisionrJr;)clear_destination_instancerKrB)clear_destination_ip_addressrKrC)$clear_destination_gke_master_clusterrKrH)$clear_destination_cloud_sql_instancerKrG)!clear_destination_forwarding_rulerKrF) clear_destination_redis_instancerKrE)clear_destination_redis_clusterrKrD) IsSpecifiedrTr*argsr5flags_and_endpointsflagrr=s rClearEndpointAttrsrksI2-@(d= -   m-@ rcURn[X15n1SknSnUHn[XGS5(dMUS- nM US:d[XBS5(d/[XB5 [X1U5 X0l[ US-U-U5$/SQnUS:XaUR /SQ5 US :XaUR /S Q5 [ [X55erArLrPs rClearSingleEndpointAttrBetarmrUrcp/SQnUH+upEnURU5(dM[UUU5nM- U$rW)rfrmrgs rClearEndpointAttrsBetarosI2-@(d= 1   m-@ rcSS/n[R"S5nUHVnURU5(dM[X5nUR U5(aM>[ SR XV55e U$)z5Checks if all provided instances are in valid format.source_instancedestination_instancezEprojects/(?:[a-z][a-z0-9-\.:]*[a-z0-9])/zones/[-\w]+/instances/[-\w]+zInvalid value for flag {}: {} Expected instance in the following format: projects/my-project/zones/zone/instances/my-instancerecompilerfrNmatchrr r*rhr,flagsinstance_patternrjrBs rValidateInstanceNamesrzs %ZZNd $h  # #H - - EEKVF   .rcSS/n[R"S5nUHVnURU5(dM[X5nUR U5(aM>[ SR XV55e U$)z4Checks if all provided networks are in valid format.source_networkdestination_networkz>projects/(?:[a-z][a-z0-9-\.:]*[a-z0-9])/global/networks/[-\w]+zxInvalid value for flag {}: {} Expected network in the following format: projects/my-project/global/networks/my-networkrs)r*rhr,rxnetwork_patternrjnetworks rValidateNetworkURIsr)s %JJG/d #g  " "7 + + ??Ev@   .rcSS/n[R"S5nUHVnURU5(dM[X5nUR U5(aM>[ SR XV55e U$)zFChecks if all provided GKE Master Clusters URIs are in correct format.source_gke_master_clusterdestination_gke_master_clusterzPprojects/(?:[a-z][a-z0-9-\.:]*[a-z0-9])/(zones|locations)/[-\w]+/clusters/[-\w]+zInvalid value for flag {}: {} Expected Google Kubernetes Engine master cluster in the following format: projects/my-project/location/location/clusters/my-clusterrs)r*rhr,rxryrjclusters rValidateGKEMasterClustersURIsrAs"& %ZZYd #g  # #G , , IIOJ   .rcSS/n[R"S5nUHVnURU5(dM[X5nUR U5(aM>[ SR XV55e U$)zFChecks if all provided Cloud SQL Instances URIs are in correct format.source_cloud_sql_instancedestination_cloud_sql_instancez8projects/(?:[a-z][a-z0-9-\.:]*[a-z0-9])/instances/[-\w]+z~Invalid value for flag {}: {} Expected Cloud SQL instance in the following format: projects/my-project/instances/my-instancersrws rValidateCloudSQLInstancesURIsrXs"& %ZZAd $h  # #H - - ::@&:P   .rcS/n[R"S5nUHVnURU5(dM[X5nUR U5(aM>[ SR XV55e U$)zBChecks if all provided Cloud Functions URIs are in correct format.source_cloud_functionzIprojects/(?:[a-z][a-z0-9-\.:]*[a-z0-9])/locations/[-\w]+/functions/[-\w]+zInvalid value for flag {}: {} Expected Cloud Function in the following format: projects/my-project/locations/location/functions/my-functionrs)r*rhr,rxfunction_patternrjfunctions rValidateCloudFunctionsURIsrms %ZZRd   D ! !t"H  ! !( + +  K 6$ !    .rcS/n[R"S5nUHVnURU5(dM[X5nUR U5(aM>[ SR XV55e U$)zEChecks if all provided App Engine version URIs are in correct format.source_app_engine_versionzCapps/(?:[a-z][a-z0-9-\.:]*[a-z0-9])/services/[-\w]+/versions/[-\w]+zInvalid value for flag {}: {} Expected App Engine version in the following format: apps/my-project/services/my-service/versions/my-versionrs)r*rhr,rxversion_patternrjversions rValidateAppEngineVersionsURIsrs" %JJL/d   D ! !d!G   ) )  FFLfG    .rcS/n[R"S5nUHVnURU5(dM[X5nUR U5(aM>[ SR XV55e U$)zFChecks if all provided Cloud Run revisions URIs are in correct format.source_cloud_run_revisionzIprojects/(?:[a-z][a-z0-9-\.:]*[a-z0-9])/locations/[-\w]+/revisions/[-\w]+zInvalid value for flag {}: {} Expected Cloud Run revision in the following format: projects/my-project/locations/location/revisions/my-revisionrs)r*rhr,rxrevision_patternrjrevisions rValidateCloudRunRevisionsURIsrs" %ZZRd   D ! !t"H  ! !( + +  K 6$ !    .rcS/n[R"S5nUHGnURU5(dM[X5nUR U5(aM>[ S5e U$)zCChecks if all provided forwarding rules URIs are in correct format.destination_forwarding_rulezVprojects/(?:[a-z][a-z0-9-\.:]*[a-z0-9])/(global|regions/[-\w]+)/forwardingRules/[-\w]+zInvalid value for flag {flag}: {forwarding_rule} Expected forwarding rule in one of the following formats: projects/my-project/global/forwardingRules/my-forwarding-rule projects/my-project/regions/us-central1/forwardingRules/my-forwarding-rulertrurfrNrvr)r*rhr,rxforwarding_rule_patternrjforwarding_rules rValidateForwardingRulesURIsrsw$ %JJ_d   D ! !d)O " ( ( 9 9  [   .rcS/n[R"S5nUHGnURU5(dM[X5nUR U5(aM>[ S5e U$)zAChecks if all provided Redis Instance URIs are in correct format.destination_redis_instancezIprojects/(?:[a-z][a-z0-9-\.:]*[a-z0-9])/locations/[-\w]+/instances/[-\w]+zInvalid value for flag {flag}: {redis_instance} Expected Redis Instance in the following format: projects/my-project/locations/location/instances/my-redis-instance r)r*rhr,rxredis_instance_patternrjredis_instances rValidateRedisInstancesURIsrsq ' (%::Rd   D ! !T(N ! ' ' 7 7  U   .rcS/n[R"S5nUHGnURU5(dM[X5nUR U5(aM>[ S5e U$)z@Checks if all provided Redis Cluster URIs are in correct format.destination_redis_clusterzHprojects/(?:[a-z][a-z0-9-\.:]*[a-z0-9])/locations/[-\w]+/clusters/[-\w]+zInvalid value for flag {flag}: {redis_cluster} Expected Redis Cluster in the following format: projects/my-project/locations/location/clusters/my-redis-cluster r)r*rhr,rxredis_cluster_patternrj redis_clusters rValidateRedisClustersURIsrsq & '%**Qd   D ! !D'M & &} 5 5  S   .rctURS5(a!URS5(d [S5eU$)zZChecks if destination-gke-master-cluster was specified when destination-fqdn is specified.destination_fqdnrzXdestination-fqdn can only be specified when destination-gke-master-cluster is specified )rfr)r*rhr,s r ValidateFqdnrsD ())$2B2B&33  9  .r)r __future__rrrrtgooglecloudsdk.corerErrorrrr%r-r0r7r?rTrkrmrorzrrrrrrrrrrr rrrs1&' *?Z--?%.%.   )2j#L2j#L00.*.0..(( r