KdZddlmZddlmZddlmZddlmZddlmZ ddl m Z ddl m Z ddlmZdd lmZdd lmZdd lmZe j(e j*j,Gd d ej.ZdZdZdZy)zDThe command to describe the status of the Config Management Feature.)absolute_import)division)unicode_literals)util)base) resources)utils)log)yaml)semverc*eZdZdZdZedZdZy)Fetcha?Prints the Config Management configuration applied to the given membership. The output is in the format that is used by the apply subcommand. The fields that have not been configured will be shown with default values. ## EXAMPLES To fetch the applied Config Management configuration, run: $ {command} configmanagementc.tj|yN)rAddMembershipResourceArg)clsparsers @lib/surface/container/fleet/config_management/fetch_for_apply.pyArgsz Fetch.Args/s &&v.cptj|ddd}|j}d}tj||}|j j |jjD]@\}}tj|tj|k(s2|5|j}B|.tjjdj|t!j"tj$}|d} t'|| |t)|| |t+|| |S)NT)prompt autoselectsearchzMembership {} not initializedspec)rParseMembership GetFeaturer !get_backfill_version_from_feature hubclientToPyDictmembershipSpecsitemsrMembershipPartialNamerr statusPrintformatr loadAPPLY_SPEC_VERSION_1merge_config_syncmerge_policy_controllermerge_hierarchy_controller) selfargs membershipfmembership_specversion full_namertemplate full_configs rRunz Fetch.Run3s %% Td4J AO55aDG>>2213D3DEKKM 4  $ $Y /  ' ' 3 4// N jj6==jIJyy334H6"Ko{G<O['B < OrN)__name__ __module__ __qualname____doc__ feature_name classmethodrr6rrrrs% $,//rrcj|r |jsy|tj}|jj}|jj}|jj |jj |d<n!|r |j s|r|j rd|d<|jjr|jj|d<|r9tj|tjtjk\r0|jjr|jj|d<n|d=|s|sy|r9tj|tjtjk\r|rd|d<n |r d|d<n|d=|drT|ddk(rL|jr|j|d <d D]+}t||st||t||||<-y|jr|j|d <d D]+}t||st||t||||<-y) #Merge configSync set in feature spec with the config template. ConfigSync has nested object structs need to be flatten. Args: spec: the ConfigManagementMembershipSpec message config: the dict loaded from full config template version: the version string of the membership NenabledT sourceFormat preventDriftgit sourceTypeocisyncWait) policyDir secretTypesyncRepogcpServiceAccountEmail)rG httpsProxyrH syncBranchrIsyncRevrJ) configSyncr CONFIG_SYNCrCrEr@rIrAr SemVerPREVENT_DRIFT_VERSIONrBOCI_SUPPORT_VERSION syncWaitSecshasattrgetattr)rconfigr2csrCrEfields rr*r*Ps T__  e " # # __(OO++ByM  ##,,bm __!!55B~ FMM'*fmm !!/ ##??77b > S FMM'*fmm / b b < "\*e3 ''bn e e!4!@C'5  ''bn e e!4!@C'5 rc|r |jsy|tj}t|tjD]I}t |j|st |j|1t |j|||<K| xs9t j|t jtjk\}|jj}|s|jddy|r||d<yy)r?N monitoring) policyControllerr POLICY_CONTROLLERlistrTrUr rPMONITORING_VERSIONrZpop)rrVr2crX valid_versionspec_monitorings rr+r+s T**  U $ $%!F52234e%%u- D))5 1 =..6ah 5+w!76== <"-))44/ EE,%AlOrc|r |jsy|tj}t|tjD]I}t |j|st |j|1t |j|||<Kyr)hierarchyControllerr HNCr]rTrU)rrVr`rXs rr,r,so T--  UYY!F599%&e((%0 D,,e 4 @1159ah 'rN)r: __future__rrr&googlecloudsdk.api_lib.container.fleetrgooglecloudsdk.callioper calliope_base*googlecloudsdk.command_lib.container.fleetrrssxK&'79@ND#$+]77==>-D -?-`D(N&< :r