oF"SrSSKJr SSKJr SSKJr SSKrSSKrSSKJr SSK J r SSK J r S r S S S S .rSSS.rSrSrSrSrSrSrSrSrSrSrSrSrSrSrSrS rS!r S"r!S#r"S$r#S%r$S&r%S'r&S(r'S)r(S*r)S+r*S,r+g)-zResource parsing helpers.)absolute_import)division)unicode_literalsN)Any) exceptions)parsersiDATAPROC_METASTOREDATAPLEXBIGQUERY)dpmsdataplexbigqueryserviceslakes)r r cjUS:dUS:a&[R"SSRU55eU$)zKPython hook to validate that the port is between 1024 and 65535, inclusive.iiz--portz-Port ({0}) is not in the range [1025, 65535].rBadArgumentExceptionformat)ports 6lib/googlecloudsdk/command_lib/metastore/validators.py ValidatePortr's: D[D5L  ) )AHHN  +c[US5$)z+Python hook to validate the scaling factor.z--scaling-factorValidateScalingFactorFloatscaling_factors rValidateScalingFactorr0s #N4F GGrc[US5$)z/Python hook to validate the min scaling factor.z--min-scaling-factorrrs rValidateMinScalingFactorr 5 #N4J KKrc[US5$)z/Python hook to validate the max scaling factor.z--max-scaling-factorrrs rValidateMaxScalingFactorr#:r!rcDUS:dUS:a&[R"USRU55eUS:a2US-S-S:wa&[R"USRU55eUS:a/US-S:wa&[R"US RU55eU$) z(Validate the scaling factor float value.g?z4Scaling factor ({0}) is not in the range [0.1, 6.0]. rzUScaling factor less than 1.0 ({0}) should be a multiple of 0.1 (e.g. (0.1, 0.2, 0.3))g?zQScaling greater than 1.0 ({0}) should be a multiple of 1.0 (e.g. (1.0, 2.0, 3.0))r)r flag_names rrr?sc^a/  ) )>EE    nr1A5:  ) ) 228&2H  ~3q8  ) ) ))/)?  rc^U4SjnU$)z-Validates the gcs uri is formatted correctly.c>URS5(d&[R"TSRU55eU$)Nzgs://z'Expected URI {0} to start with `gs://`.) startswithrrr)gcs_uriarg_names rProcessValidateGcsUri..ProcessZs?   g & &  + + =DDWM  Nrr-r.s` rValidateGcsUrir2Ws .rc[R"S5nURU5(d&[R"SSR X55eU$)Nz^(.+)/(.+)@(.+)$--kerberos-principalz0Kerberos Principal {0} does not match ReGeX {1}.)recompilematchrrr)kerberos_principalpatterns rValidateKerberosPrincipalr:dsP JJ* +' ) * *  ) ):AA    rcjUS:dUS:a&[R"SSRU55eU$)z:Validates that the hour falls between 0 and 23, inclusive.rz --maintenance-window-hour-of-dayz$Hour of day ({0}) is not in [0, 23].r)hours rValidateHourOfDayr>ps: AX  ) )*.55d;  +rc[U5[:a*[R"USR [55eU$)z\Validates that the string field is not longer than STRING_MAX_LENGTH, to avoid abuse issues.z7The string field can not be longer than {0} characters.)lenSTRING_MAX_LENGTHrrr)r-s rValidateStringFieldrBzs=]&&  ) )AHH    /rc[R"S5nURU5(d[R"SS5eU$)a3Validates the connection name of a CloudSQL instance, must be in the form '{project_id}:{region}:{instance_id}'. Args: connection_name: The CloudSQL instance connection name string. Returns: The connection name string. Raises: BadArgumentException: when the input string does not match the pattern. z^([^:]+:){2}[^:]+$z--instance-connection-namezRThe instance connection name should be in the format project_id:region:instance_idr5r6r7rr)connection_namer9s r&ValidateCloudSqlInstanceConnectionNamerFsE JJ, -'  ' '  ) )$ )  rc^U4SjnU$)z{Validates the resource name of a compute network, must be in the form 'projects/{project_id}/global/networks/{network_id}'.c>[R"S5nURU5(d[R"TS5eU$)Nz&^projects/[^/]+/global/networks/[^/]+$zdThe network resource name should be in the format projects//global/networks/rD resource_namer9r-s rr.,ValidateNetworkResourceName..ProcesssEjjBCG == ' '  + +  @  rr0r1s` rValidateNetworkResourceNamerL .rc^U4SjnU$)zValidates the resource name of a compute subnetwork, must be in the form 'projects/{project_id}/regions/{region_id}/subnetworks/{subnetwork_id}'.c>[R"S5nURU5(d[R"TS5eU$)Nz0^projects/[^/]+/regions/[^/]+/subnetworks/[^/]+$zzThe subnetwork resource name should be in the format projects/{project_id}/regions/{region_id}/subnetworks/{subnetwork_id}rDrIs rr./ValidateSubnetworkResourceName..ProcesssEjjLMG == ' '  + +  S  rr0r1s` rValidateSubnetworkResourceNamerQrMrc[R"S5nURU5(d[R"SS5e[ U5S:a[R"SS5eU$)zValidates the hive database name. Args: db_name: the hive database name. Returns: the hive database name. Raises: BadArgumentException: when the database name doesn't conform to the pattern or is longer than 64 characters. z^[0-9a-zA-Z$_-]+$z--hive-database-namezhive database name must start with an alphanumeric character, and contain only the following characters: letters, numbers, dashes (-), and underscores (_).@z3hive database name must be less than 64 characters.)r5r6r7rrr@)db_namer9s rValidateHiveDatabaseNamerUsk JJ+ ,' w    ) )    \B  ) )=  .rc~[R"U5 U$![a [R"SS5ef=f)zValidates the Cloud SQL IP address. Args: ip_address: the Cloud SQL IP address. Returns: the IP address. Raises: BadArgumentException: when the IP address is invalid. z --ip-addresszInvalid IP address.) ipaddress IPv4Address ValueErrorrr) ip_addresss rValidateCloudSqlIpAddressr[sC *%    ) ) s"<cSnU"U5(d[R"SS5eU$![a [R"SS5ef=f)zValidates the subnet IP range. Args: cidr: the CIDR range for the subnet. Returns: the CIDR range. Raises: BadArgumentException: when the CIDR range is invalid. c/SQnS/nS/n/SQnS/nS/nUU-U-U-U-U-n[R"U5nUH/n UR[R"U 55(dM/ g g) zMChecks if a given CIDR block is contained within a list of valid CIDR ranges.)z 10.0.0.0/8z 172.16.0.0/12z192.168.0.0/16z 100.64.0.0/10z 192.0.0.0/24)z 192.0.2.0/24z198.51.100.0/24z203.0.113.0/24z192.88.99.0/24z 198.18.0.0/15TF)rW IPv4Network subnet_of) cidrrfc_1918_spacesrfc_6598_spacesrfc_6890_spacesrfc_5737_spacesrfc_7526_spacesrfc_2544_spacesvalid_cidr_ranges cidr_block valid_ranges rIsCidrWithinValidRanges6ValidateSubnetIpRange..IsCidrWithinValidRangessHO&'O%&OKO'(O&'O             &&t,J(   i33K@ A A) rz--subnet-ip-rangez]The subnet IP range is invalid, see https://cloud.google.com/vpc/docs/subnets.md#valid-rangeszInvalid CIDR address block.)rrrY)r`rjs rValidateSubnetIpRangerlsi2  "4 ( (  + +  G  ) +   ) )% s $,"Ac[R"S5nURU5(d[R"SS5eU$)a+Validates the Cloud Storage bucket name used for CDC during migration, should not start with 'gs://'. Args: bucket_name: the Cloud Storage bucket name. Returns: the Cloud Storage bucket name. Raises: BadArgumentException: when the Cloud Storage bucket name doesn't conform to the pattern. z^(?!gs://)([a-z0-9\._-]+)$z--bucketzInvalid bucket namerD) bucket_namer9s rValidateMigrationBucketNamero#sC JJ4 5' { # #  ) )  rc[R"S5nURU5(d[R"SS5eU$)a%Validates the root path inside the Cloud Storage bucket used for CDC during migration, must start with a forward slash ('/') character. Args: root_path: the root path inside the Cloud Storage bucket. Returns: the root path. Raises: BadArgumentException: when the root path is invalid. z ^/([^\n\r]*)$z --root-pathzInvalid root pathrD) root_pathr9s rValidateMigrationRootPathrr9sC JJ' (' y ! !  ) )  rc[XU5$)aNValidates that the mutual exclusive configurations of Dataproc Metastore service are not set at the same time. Args: req: A request with `service` field. Returns: A request without service mutex configuration conflicts. Raises: BadArgumentException: when mutual exclusive configurations of service are set at the same time. )ValidateServiceMutexConfigForV1 unused_ref unused_argsreqs rValidateServiceMutexConfigryNs )# FFrcFURR(aURRR(a`URRRR(a1[ UR5(a[ R "SS5eU$)ahValidates exclusively for V1 fields that the mutual exclusive configurations of Dataproc Metastore service are not set at the same time. Args: req: A request with `service` field. Returns: A request without service mutex configuration conflicts. Raises: BadArgumentException: when mutual exclusive configurations of service are set at the same time. r4zoKerberos configuration cannot be used in conjunction with --network-config-from-file or --consumer-subnetworks.)servicehiveMetastoreConfigkerberosConfig principal _IsNetworkConfigPresentInServicerrrus rrtrt]so kk%% ++ ) ) 8 8 ++ ) ) 8 8 B B *3;; 7 7  ) ) A  *rc@[UR55nURRR(aSU;a[ R "SS5eURRR(aSU;a[ R "SS5eU$)aValidates that the cron_schedule and backup_location are set when the scheduled backup is enabled. Args: unused_ref: A resource ref to the parsed metastore service resource. args: The parsed args namespace from CLI. req: A request with `service` field. Returns: A request with service scheduled backups configurations required. Raises: BadArgumentException: when cron_schedule and backup_location are not set when the scheduled backup is enabled. z--scheduled-backup-cronzI--scheduled-backup-cron must be set when the scheduled backup is enabled.z--scheduled-backup-locationzM--scheduled-backup-location must be set when the scheduled backup is enabled.)setGetSpecifiedArgNamesr{scheduledBackupenabledrr)rvargsrxargs_sets rValidateScheduledBackupConfigsrws**, -( kk!!)) #8 3  ) )!    kk!!)) 'x 7  ) )%   *rcTUR=(a URR$N) networkConfig consumers)r{s rrrs    B7#8#8#B#BBrc~[UR55nSU;aSU;a[R"SS5eU$)aValidate if users run update federation command with --clear-backends arg only. Args: unused_ref: A resource ref to the parsed Federation resource. args: The parsed args namespace from CLI. update_federation_req: The request for the API call. Returns: String request Raises: BadArgumentException: When users run update federation command with --clear-backends arg only. z--clear-backendsz--update-backendsz4--clear-backends must be used with --update-backends)rrrr)rvrupdate_federation_reqrs rValidateClearBackendsrsH**, -(8#(;8(K  ) )>  rcJUR5(a[U5S:$g)NrF)isdigitint)strings r_IsZeroOrPositiveNumberrs! ^^ v;!  rcNSRSUR555$)N|c3*# UH upUv M g7frr0).0keyvalues r ,_GetMetastoreTypeFromDict..s=*=:,... For example: 1=dpms:dpms1,2=dataplex:lake1 Returns: Backend metastore dict Raises: BadArgumentException: When the input backends is invalid or duplicated keys rzCannot be empty,=rrz8Invalid backends format or key of backend is less than 0r&:zDuplicated keys of backendszInvalid backends type)name metastoreType)rrsplitr@rMETASTORE_TYPE_DICTkeysr) backends backend_dictbackenddatarank_and_metastorerrrgenerated_namebackend_metastores_dicts r&ValidateBackendsAndReturnMetastoreDictrsk,   ) ),8I JJ NN3 'dC !#  + + 1  Q C "3 ' '  + +  D  q !E#kk#. "#q(  + + 1    + + 5 q!)<)A)A)CC  + + / 66MNN,-DQ-GH0?@ rcURRRHSnURRR UR 5R55URlMU U$)zGenerate the long backend name of Dataproc Metastore federation requests. Args: job_ref: A resource ref to the parsed Federation resource. request: The request for the API call. Returns: Modified request for the API call. ) federationbackendMetastoresadditionalPropertiesrrrParent RelativeName)job_refrequestprops rParseBackendsIntoRequestr!sT  22GGdjjoo,,W^^-=-J-J-LMDJJOH .rcURRb!URRRcU$URRRHn[R"U5 M U$)aValidates that the kms keys are valid. Args: req: A request with `service` field. Returns: The unchaged request. Raises: InvalidResourceException: If the line is invalid. RequiredFieldOmittedException: If resource is underspecified. UnknownCollectionException: If no collection is provided or can be inferred. WrongResourceCollectionException: If the provided URL points into a collection other than the one specified. )r{encryptionConfigkmsKeysrParseCloudKmsKey)rvrwrxkms_keys rValidateKmsKeysr1s\" kk""* kk""**2 J--55g W%6 *r),__doc__ __future__rrrrWr5typingrgooglecloudsdk.callioper$googlecloudsdk.command_lib.metastorerrArrrrr r#rr2r:r>rBrFrLrQrUr[rlrorrryrtrrrrrrrrrr0rrrs '' .8  )3HH L L 0   *   :,2j,* G 4" JC0 >%P4n   r