8SrSSKrSSKrSSKrSSKJr SrSrSrSr Sr S r S r S r S S jrS rSrSrSrSrSrS!SjrSrSrSrSrSrSrSrSrSrSrSr Sr!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 @s 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 FormatForRolloutsDescriberDs _  \\gll66||'';; I D OPdl||''== K F Edl >7\r cPURS5(dURS5(d/$[RRU5(a/$/n[R "U5nUH3nU(dM [R "U5nURU5 M5 U$)Nz.yamlz.yml)endswithospathisdirr load_all_pathdumpappend)r resourcesloaded_resourcesresourcedumped_resources r _LoadResourcesFromFiler)bs -- DMM&$9$9 IWW]]4 I)''-"hx (+o'# r cURS5(dUS- n[RRU5S-n[R"USS9$)N/z/**/*T)pathname recursive)rrr dirnameglob)r glob_paths r _AllFilesUnderDirr1psG s  CKDggood#g-) D r cB[R"U5R$r)pathlibPathstemr s r _VariantNameFromPathr7ys d   r cdURS5(dUS- nURS5SnU$)Nr+)rsplit)r variant_names r _VariantNameFromDirr<}s2 s  CKDC$, r c@[RRU5$r)rr expanduserr6s r ExpandPathForUserr?s   D !!r c[RRU5nUnSU;a[RRU5nU$)N$)rr r> expandvars)r user_expanded_pathvars_expanded_paths r _ExpandPathForUserAndVarsrEsBww))$/) ++,>? r cU(dU$[U5n[U5n[RRU5(a[RR X#5$U$)aCreates glob pattern by combining source and variants_pattern. Args: source: Directory or source configuration file. variants_pattern: Optional variants_pattern for use with source. Returns: A glob_pattern for use with 'VariantsFromGlobPattern'. If source is a directory, the pattern is applied within the directory. If source is not a directory i.e., a file, the pattern is not applied. Ex: source=/cfg/, variants_pattern='*.yaml'; returns '/cfg/*.yaml'. source=manifest.yaml, variants_pattern=*; returns manifest.yaml. )rErr r!join)sourcevariants_patternexpanded_sourceexpanded_variants_patterns r 'GlobPatternFromSourceAndVariantsPatternrLsN  M-f5/78HIWW]]?## 77<< CC r cSUS3$)NzSource file or dir not found: .r r6s r _FileNotFoundMessagerOs )$q 11r cSUS3$)Nz)Source is not of type directory or file: rNr r6s r _FileWrongTypeMessagerQs 4TF! <>/ * * 2?C DD +1P 'r c[RRU5nUnSU;a[RRU5n[R"U5nUR 5 0n[ U5S:Xa[RRUS5(a[US5nU(aXTS'U$[RRUS5(ah[US5n/nUHGn[RRU5n [U 5nU(dM6URU5 MI U(aXtS'U$[ U5S:aUHn [RRU 5(a%[U 5nU(a[U 5n XTU 'MJML[RRU 5(dMr[U 5n/nUHGn[RRU5n [U 5nU(dM6URU5 MI U(dM[U 5n XtU 'M U$)a Returns a dictionary of input-format variants discovered from a glob. Gets all files from user-supplied glob pattern and creates variant(s). There will be a single variant 'default' if the inputted glob pattern has no wildcards, and multiple variants if there are wildcards. These variant(s) can be used for more advanced deployment setups. Args: glob_pattern: Pattern compatible with python's glob library Returns: A dict of input-formatted variants, for example: {'us-a': [resources...], 'us-b': [resources...]} rArrdefault)rr r>rBr/sortlenrSr)r!r1abspathextendr7r<) glob_patternuser_expanded_glob expanded_globpathsvariantsr% files_list all_resourcesfilefull_file_pathr r;s r VariantsFromGlobPatternrfsww)),7$-MGG&&}5M ))M "%**, (Z1_ ww~~eAh(q2i ': /9 uQx $U1X.jm$.*>: 9   y )  +& /% 5zA~   *40 -d3,#,<   77==  &t,  D77??40.,^<) Y   +  =,T2,#0< !" /r 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...$_GetClusterLevelMessagesFromResourcerZ)r'truncated_message_lengthmessagess r !TransformTrimClusterLevelMessagesrosY  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)getrZ)r' rollout_inforollout_messages r TransformTrimRolloutLevelMessagerusTfb),"&&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. rrclustersrncurrenterrors errorMessageri)rrvaluesr\r$) r'rnrollout_strategy_inforsrwrx info_errorserror info_messages r rlrls(  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'rns r TransformAllClusterLevelMessagesr8s/2( ;(   8} A; /r c/nUcgURS05RS/5nUH/nURSS5nU(dMURU5 M1 U(dg[U5S:XaUS$U$)zBGathers errors from 'info.Errors' and returns their errorMessages.rirryrzrr)rrr$rZ)r'rnryr~ error_messages r TransformListFleetPackageErrorsrIs{ (  << # ' '" 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. )name) fleet_packagefully_qualified_names r UpsertFleetPackageNamer\s   - 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 FixFleetPackagePathForCloudBuildrks!//  / / 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 rrs3P  . .P  . . C C4 Or )Fr)"__doc__r/rr3googlecloudsdk.corerr _RESOURCE_BUNDLE_PROJECT_SEGMENT!_RESOURCE_BUNDLE_LOCATION_SEGMENTrrrrr rr)r1r7r<r?rErLrOrQrVrfrorurlrrrrrr r r rs4 $ #$ $%!75395526.460< !"22=E7t$ &B"& 2r