6SrSSKrSSKrSSKrSSKrSSKJr SrSrSr Sr Sr S r S r S rSS jrS rSrSrSrSrSrSrSrSrSrSrSrSrSrSrSrSr g)z-Helper utilities for fleet packages commands.N)yamlv1alphaatable(info.rolloutStrategyInfo.rollingStrategyInfo.clusters.membership.basename():label=CLUSTER, info.rolloutStrategyInfo.rollingStrategyInfo.clusters.current.version:label=CURRENT_VERSION, info.rolloutStrategyInfo.rollingStrategyInfo.clusters.current.syncState:label=SYNC_STATE, info.rolloutStrategyInfo.rollingStrategyInfo.clusters.desired.version:label=DESIRED_VERSION, info.rolloutStrategyInfo.rollingStrategyInfo.clusters.startTime:label=START_TIME, info.rolloutStrategyInfo.rollingStrategyInfo.clusters.endTime:label=END_TIME, info.rolloutStrategyInfo.rollingStrategyInfo.clusters.state:label=STATE, trim_message():label=MESSAGE)atable(info.rolloutStrategyInfo.allAtOnceStrategyInfo.clusters.membership.basename():label=CLUSTER, info.rolloutStrategyInfo.allAtOnceStrategyInfo.clusters.current.version:label=CURRENT_VERSION, info.rolloutStrategyInfo.allAtOnceStrategyInfo.clusters.current.syncState:label=SYNC_STATE, info.rolloutStrategyInfo.allAtOnceStrategyInfo.clusters.desired.version:label=DESIRED_VERSION, info.rolloutStrategyInfo.allAtOnceStrategyInfo.clusters.startTime:label=START_TIME, info.rolloutStrategyInfo.allAtOnceStrategyInfo.clusters.endTime:label=END_TIME, info.rolloutStrategyInfo.allAtOnceStrategyInfo.clusters.state:label=STATE, trim_message():label=MESSAGE)atable(info.rolloutStrategyInfo.rollingStrategyInfo.clusters.membership.basename():label=CLUSTER, info.rolloutStrategyInfo.rollingStrategyInfo.clusters.current.version:label=CURRENT_VERSION, info.rolloutStrategyInfo.rollingStrategyInfo.clusters.current.syncState:label=SYNC_STATE, info.rolloutStrategyInfo.rollingStrategyInfo.clusters.desired.version:label=DESIRED_VERSION, info.rolloutStrategyInfo.rollingStrategyInfo.clusters.startTime:label=START_TIME, info.rolloutStrategyInfo.rollingStrategyInfo.clusters.endTime:label=END_TIME, info.rolloutStrategyInfo.rollingStrategyInfo.clusters.state:label=STATE, all_messages():label=MESSAGES)atable(info.rolloutStrategyInfo.allAtOnceStrategyInfo.clusters.membership.basename():label=CLUSTER, info.rolloutStrategyInfo.allAtOnceStrategyInfo.clusters.current.version:label=CURRENT_VERSION, info.rolloutStrategyInfo.allAtOnceStrategyInfo.clusters.current.syncState:label=SYNC_STATE, info.rolloutStrategyInfo.allAtOnceStrategyInfo.clusters.desired.version:label=DESIRED_VERSION, info.rolloutStrategyInfo.allAtOnceStrategyInfo.clusters.startTime:label=START_TIME, info.rolloutStrategyInfo.allAtOnceStrategyInfo.clusters.endTime:label=END_TIME, info.rolloutStrategyInfo.allAtOnceStrategyInfo.clusters.state:label=STATE, all_messages():label=MESSAGES)c[$N)_DEFAULT_API_VERSION@lib/googlecloudsdk/command_lib/container/fleet/packages/utils.py ApiVersionr As r cUcgUR(aURR(aURRR(a&U(a [UlO [ UlS/UlURRR(a'U(a [UlO [UlS/Ulgggg)zSets format for `rollouts describe` depending on rollout strategy. Args: rollout: Rollout from `rollouts describe` args: Command line args less: Whether to show truncate rollout messages Returns: None Nz7info.rolloutStrategyInfo.rollingStrategyInfo.clusters[]z9info.rolloutStrategyInfo.allAtOnceStrategyInfo.clusters[]) inforolloutStrategyInforollingStrategyInfo3ROLLOUTS_DESCRIBE_ROLLING_TRUNCATED_MESSAGES_FORMATformat.ROLLOUTS_DESCRIBE_ROLLING_FULL_MESSAGES_FORMATflattenallAtOnceStrategyInfo5ROLLOUTS_DESCRIBE_ALLATONCE_TRUNCATED_MESSAGES_FORMAT0ROLLOUTS_DESCRIBE_ALLATONCE_FULL_MESSAGES_FORMAT)rolloutargslesss r FormatForRolloutsDescriberEs _  \\gll66||'';; I D OPdl||''== K F Edl >7\r cPURS5(dURS5(d/$[RRU5(a/$/n[R "U5nUH3nU(dM [R "U5nURU5 M5 U$)N.yaml.yml)endswithospathisdirr load_all_pathdumpappend)r" resourcesloaded_resourcesresourcedumped_resources r _LoadResourcesFromFiler+cs -- DMM&$9$9 IWW]]4 I)''-"hx (+o'# r cNURS5(dUS- n[RRU5S-n[R"USS9Vs/sHCn[RR U5(dM)URS5(dMAUPME sn$s snf)zReturns paths of all .yaml and .yml files in a directory and subdirectories. Args: path: The root directory to search in. Returns: A list of strings, where each string is a path to a .yaml or .yml file. /z/**/*T)pathname recursive)rr)r r!r"dirnameglobisfile)r" glob_pathps r _AllFilesUnderDirr5qs s  CKDggood#g-)yy)t< ? r cSUS3$)NzSource file or dir not found: .r r:s r _FileNotFoundMessagerKs )$q 11r cSUS3$)Nz)Source is not of type directory or file: rJr r:s r _FileWrongTypeMessagerMs 4TF! <*VariantsFromGlobPattern..s, " #277??4#8 9 9"s57)r!r"rArEr1r#sortr2r+r; ValueErrorr5list itertoolschain from_iterabler?) glob_patternuser_expanded_glob expanded_globresources_by_variant_nameorigin_by_variant_name is_file_maskpathsr4r"r' variant_name files_listresources_per_file all_resourcess r VariantsFromGlobPatternrfs&ww)),7$-MGG&&}5M L(BFl,B, ))M "%  21q!1QE 2**,d   *40 1$7,  3),)9:*8;556  5>L 115 .   t  &t,  " Y__::;MNO =,T2,  3),)9:*8;556  5BL 115 .?@ #"G 3s =(G )G cSn[U5nU(dg[U5S:a[US5U:a USSUS-$US$)zShows the first cluster-level message and truncates it if it's too long. Args: resource: A RolloutInfo resource Returns: Message limited to 40 characters (rrN...$_GetClusterLevelMessagesFromResourcelen)r)truncated_message_lengthmessagess r !TransformTrimClusterLevelMessagesrpsY  1( ;(  ]aC ,/GG A;00 1E 99 !r cURS05nU(a2URSS5nU(a[U5S:aUSSS-$U$g)zTrims rollout-level message if it's too long. Args: resource: A Rollout resource Returns: String message limited to 40 characters rmessagerirhNrj)getrm)r) rollout_inforollout_messages r TransformTrimRolloutLevelMessagervsTfb),"&&y"5O _  "s#e++  r c2/nU(d/$URS05RS05nUR5HwnURS/5nSU;a!URURS/55 URS05nSU;dMVURURS/55 My URS05RS/5nU(a5UH/nURSS5nU(dMURU5 M1 U$) zGathers cluster-level messages from a Rollout resource. Args: resource: A Rollout resource, from `... rollouts describe ...` Returns: A list of messages from the Rollout resource. rrclustersrocurrenterrors errorMessageri)rsvaluesextendr&) r)rorollout_strategy_infortrxry info_errorserror info_messages r rlrl s(  I",,vr266R,224l B/HXoohll:r23ll9b)GWoogkk*b12 5 VR(,,Xr:+YY~r2l  % /r cT[U5nU(dg[U5S:XaUS$U$)zReturns all cluster-level messages from a Rollout resource. Args: resource: A Rollout resource, from `... rollouts describe ...` Returns: A single string or string array of cluster-level messages. rirrrk)r)ros r TransformAllClusterLevelMessagesr,s/2( ;(   8} A; /r c/nUcgURS05RS/5nUH/nURSS5nU(dMURU5 M1 U(dg[U5S:XaUS$U$)zBGathers errors from 'info.Errors' and returns their errorMessages.rirrzr{rr)rsr&rm)r)rorzr error_messages r TransformListFleetPackageErrorsr=s{ (  << # ' '" 5&eIInb1M}oom$   8} A; /r c4UR(dXlU$)a:Upserts the correct fleet package name into fleet package resource. Args: fleet_package: A user-inputted FleetPackage which may or may not have a name fully_qualified_name: The fully qualified name of the FleetPackage resource. Returns: A FleetPackage that definitely has the correct fully qualified name. )r>) fleet_packagefully_qualified_names r UpsertFleetPackageNamerPs   - r cV[U5(aURRRnUbuUR S5(a_US:XaSURRlU$URRRSSURRlU$)awRemoves leading slash from fleet package path if it uses Cloud Build. If we don't remove the leading slash, parsing the path will fail for cloud build. See b/352756986#comment13 Args: fleet_package: A user-inputted FleetPackage which may need its path fixed. Returns: A FleetPackage with a fixed path if it uses Cloud Build, unchanged if it doesn't use Cloud Build. Nr-z./r)_FleetPackageUsesCloudBuildresourceBundleSelectorcloudBuildRepositoryr" startswith)rr"s r FixFleetPackagePathForCloudBuildr_s!//  / / D D I ID DOOC00 IM ,,AAF   0 0 E E J J12 N ,,AAF r cjU=(a+ UR=(a URRSL$r)rr)rs r rrxs3P  . .P  . . C C4 Or )F)!__doc__r1rXr!r7googlecloudsdk.corerr _RESOURCE_BUNDLE_PROJECT_SEGMENT!_RESOURCE_BUNDLE_LOCATION_SEGMENTrrrrr rr+r5r;r?rBrHrKrMrfrprvrlrrrrrr r r rs4  $ #$ $%!75395526.460< &!!"2=C#L$ &B"& 2r