dZddlZddlZddlZddlZddlZddlZddlm Z ddl m Z ddl mZddl mZddlmZddlm ZddlmZddlm Z dd lmZdd lmZdd lmZdd lmZddlm Zdd lmZddlmZddlmZddlm Z ddl!m"Z"ddl!m#Z#ddl$Z$dZ%gdZ&dZ'dZ(dZ)dZ*dZ+dZ,dZ-Gddej\Z/dZ0dZ1d Z2d!Z3 d8d"Z4d#Z5d$Z6 d9d%Z7d&Z8d'Z9d(Z:d)Z;d*Zd-Z?d.Z@d/ZAd0ZBd:d1ZCd;d2ZDd3ZEd4ZFd5ZGd6ZHd7ZIy)>   (IAv+11  * *599; 7 ::<   2- %--33):4&&%%*$((, '"""*11C7-GM ))00" # * * 1 ' w##))&=N)OJ"**:7IJ&-- ''0A0F0F.G 0":       g v '      g     G N N)00)00 O  %226;MN(//"))2C2H2H0g&8N#%,N"  , '<N(/N$ O  . .  0 0  $$*F+>$?  s 8 L 9Mci}|jjD]:}|jD])}||vrg||<||j|j+<|S)zIGet mapping of profile to list of targets where the profile is activated.)serialPipelinestagesprofilesr9targetId)rxprofile_to_targetsstageprofiles r(_GetProfileToTargetMappingrs_**11e>> * *&(7#!((8"2 r'chi}|jD]\}}t|dk(s|||d<|S)zKGet mapping of profile to target that is only activated in a single target.r)itemsr8)rtarget_to_unique_profilertargetss r(!_GetUniqueProfilesToTargetMappingrsC,224gw 7|q-4wqz*5 "!r'ct|}t|}t|t|jjk7rt j d|S)zGet one unique profile for every target if it exists. Args: pipeline_obj: The Delivery Pipeline object. Returns: A map of target_id to profile. Raises: Error: If the pipeline targets don't each have a dedicated profile. z=Target should use one profile not shared with another target.)rrr8rrcore_exceptionsrS)rxrrs r(_GetTargetAndUniqueProfilesrs\2,?>  !"c,*E*E*L*L&MM   G  "!r'ctj5}d}d} |rE|}tj|tj j |tj} nF|rD|}tj|tj j |tj} tj j|s%tjdj|tj||tj j|t } tj"| 5} | j%dt'j(| | ddddt+|||||} t,j.j1dj| | cdddS#1swYRxYw#1swYyxYw) a Generates a Skaffold file and uploads the file and k8 manifest to GCS. Args: kubernetes_manifest: path to kubernetes manifest (e.g. /home/user/k8.yaml). If provided, a Skaffold file will be generated and uploaded to GCS on behalf of the customer. cloud_run_manifest: path to Cloud Run manifest (e.g. /home/user/service.yaml). If provided, a Skaffold file will be generated and uploaded to GCS on behalf of the customer. gcs_client: client for Google Cloud Storage API. gcs_source_staging: directory in google cloud storage to use for staging ignore_file: the ignore file to use hide_logs: whether to show logs, defaults to False pipeline_obj: the pipeline_obj used for this release. Returns: the gcs uri where the tarball was uploaded. rz$could not find manifest file [{src}]rz(# Auto-generated by Google Cloud Deploy T) round_tripNz4Generated Skaffold file can be found here: {gcs_uri})r)rTemporaryDirectoryr CreateSkaffoldFileForManifestrrWbasenameGKE_GENERATED_SKAFFOLD_TEMPLATE%CLOUD_RUN_GENERATED_SKAFFOLD_TEMPLATEexistsrBadFileExceptionrshutilcopyjoinGENERATED_SKAFFOLD FileWriterwriterdumprr rr) rrrrrkrzrxtemp_dirmanifest skaffold_yaml skaffold_pathrXrs r(rr*s}6 !XHM$h#AA  ''  8 $  7 7m #h#AA  ''  8 $  = =m 77>>( #  ) ) 0 7 7H 7 E   KK(#GGLL+=>M   - (Agg9: ii qT2 ) & GJJ>EE F  Y"!6 ) (7"!s%D%G:*F5$AG5F> :GG cr|sd}|sd}|jdr tjjdytj j |s%tjdj|tj j|rt|||yt|||y)aChecks that the specified source contains a skaffold or deploy config file. Args: source: the location of the source files skaffold_file: path of the skaffold file relative to the source directory deploy_config_file: path of the deploy config file relative to the source directory. Raises: BadFileException: If the source directory or files can't be found. rzdeploy-config.yamlrzNSkipping config file check. Reason: source is not a local archive or directoryzcould not find source [{src}]rN) rr rrrrWrrrrr_VerifyConfigFileIsInArchive_VerifyConfigFileIsInFolder)rirrrss r(r^r^ts #M - wJJ = 77>>& !  ' ''..6.:  ww~~f 8JK 7IJr'c (tjj|\}}|tvr+t j ddj tztj|st j dtj|d5} |j|dddy#t$rI |j|n3#t$r't j dj||wxYwYZwxYw#1swYyxYw) ayVerifies the skaffold or deploy config file is in the archive. Args: source: the location of the source archive. skaffold_file: path of the skaffold file in the source archive. deploy_config_file: path of the deploy config file in the source archive. Raises: BadFileException: If the config file is not a readable compressed file or can't be found. zlocal file [{src}] is none of , z?Specified source file is not a readable compressed file archivezr:gz)modezvCould not find skaffold or deploy config file. File [{skaffold}] or [{deploy_config}] does not exist in source archiver deploy_configN) rrWr_ALLOWED_SOURCE_EXTrrrtarfile is_tarfileopen getmemberKeyErrorr)rirrrsrextarchives r(rrs 77  F #&!S##  ' '(4995H+II    F #  ' 'I ||F(G    &)(    ,-  ++ EEKV&6HFLF    .  )(sBDB33 D=CD0C??DDDDDcNtjj||}tjj||}tjj|sFtjj|s&t j dj ||yy)agVerifies the skaffold or deploy config file is in the folder. Args: source: the location of the source files skaffold_file: path of the skaffold file relative to the source directory deploy_config_file: path of the deploy config file relative to the source directory. Raises: BadFileException: If the config file can't be found. zdCould not find skaffold or deploy config file. File [{skaffold}] or [{deploy_config}] does not existrN)rrWrrrrr)rirrrspath_to_skaffoldpath_to_deploy_configs r(rrsWW\\&-8'',,v/AB ( )"''..3  ' ' ,,2F%5J-3-  3 )r'c6|r t|}t|||S)z3Set the image substitutions for the release config.)r\rL)rGrHrFrIs r(reres "? 3F 68^ <BB4HLK@@EEEk002??AB +-? ??A!  ( (- ii-44[%HI jj299+FG ,,-  & &$II-44T5==IJJJ9@@FGd##$s:&F8AF #A3H% H"3A$HH"%J18A.J,,J1ct|||\}}}|r0|tjdjt |z }|r0|t jdjt |z }|r0|t jdjt |z }tjj|y)aKPrints differences between current and snapped delivery pipeline and target definitions. Args: release_ref: protorpc.messages.Message, release resource object. release_obj: apitools.base.protorpclite.messages.Message, release message. target_id: str, target id, e.g. test/stage/prod. prompt: str, prompt text.  N) r@RESOURCE_CREATEDrr BulletedListRESOURCE_NOT_FOUNDRESOURCE_CHANGEDr rr)rr8 target_idpromptr<r;r:s r( PrintDiffrIYss r(rDrDrs0 X a!$HQK  /r'czd}|jD])}tj|j|k(s&|}|S|S)zGet the snapped target in a release by target ID. Args: release_obj: apitools.base.protorpclite.messages.Message, release message object. target_id: str, target ID. Returns: target message object. N)r-r r.r)r8rGr>sss r(GetSnappedTargetrNsF*  ' 'bBGG$ 1j  ( r'cg}g}tjtj}tjtj tj tjtjtjg}|D]i}t||}|s|jj}||jk(r|j|I||jk(r|j|jk|rEdj!|Dcgc]}|j"c}} t%j&d|d| d|rMdj!|Dcgc]}|j"c}} t(j*j-d| dyt/|} |j0j2} | | j4k(rt%j&d|d| | j6k(r t(j*j-d yycc}wcc}w) ayChecks the support state on a release. If the release is in maintenance mode, a warning will be logged. If the release is in expiration mode, an exception will be raised. Args: release_obj: The release object to check. action: the action that is being performed that requires the check. Raises: an core_exceptions.Error if any support state is unsupported rz You can't z' because the versions used for tools: [zS] are no longer supported. https://cloud.google.com/deploy/docs/select-tool-versionz'WARNING: The versions used for tools: [zp] are in maintenance mode and will be unsupported soon. https://cloud.google.com/deploy/docs/select-tool-versionNz because the Skaffold version that was used to create the release is no longer supported. https://cloud.google.com/deploy/docs/using-skaffold/select-skaffold#skaffold_version_deprecation_and_maintenance_policyzWARNING: This release's Skaffold version is in maintenance mode and will be unsupported soon. https://cloud.google.com/deploy/docs/using-skaffold/select-skaffold#skaffold_version_deprecation_and_maintenance_policy)rr_r`rr r!r"r#r$r%_GetToolVersionSupportStateToolVersionSupportedCondition&ToolVersionSupportStateValueValuesEnum&TOOL_VERSION_SUPPORT_STATE_UNSUPPORTEDr9+TOOL_VERSION_SUPPORT_STATE_MAINTENANCE_MODErrKrrSr rr_GetSkaffoldSupportStateSkaffoldSupportedCondition#SkaffoldSupportStateValueValuesEnum"SKAFFOLD_SUPPORT_STATE_UNSUPPORTED'SKAFFOLD_SUPPORT_STATE_MAINTENANCE_MODE) r8actiontools_in_maintenancetools_unsupportedrGtoolststatetool_version_enumjoinedskaffold_support_stateskaffold_support_state_enums r(CheckReleaseSupportStaterds  * *;+H+H+J K( << :: 99 == ?? >>  % a ' Q 7E ..UU !HHHq! #OO O!!!$  YY):;):A):; )=A)=> ?FJJ 1&:C C  4K@))MM $ G GH    VH? ?  $ L LMJJ ?MC<?s HH c|jr6|jjr |jjjSy)zGets the Skaffold Support State from the release. Args: release_obj: release message obj. Returns: None or SkaffoldSupportStateValueValuesEnum N) conditionskaffoldSupportedConditionskaffoldSupportState)r8s r(rUrUs6{44OO  ; ; P PP r'c|jsy|tjk(r7|jjr |jjjSy|tj k(r7|jj r |jj jSy|tjk(r7|jjr |jjjSy|tjk(r7|jjr |jjjSy|tjk(r7|jjr |jjjSy|tjk(r6|jjr |jjjSy)zGets the Tool Version Support State from the release for a particular tool. Args: release_obj: release message obj. tool: Tools.Enum. Returns: None or ToolVersionSupportStateValueValuesEnum N)rfrr dockerVersionSupportedConditiontoolVersionSupportStater!helmVersionSupportedConditionr"kptVersionSupportedConditionr# kubectlVersionSupportedConditionr$"kustomizeVersionSupportedConditionr%!skaffoldVersionSupportedCondition)r8tools r(rPrPsv     U\\<<    ? ? W W8 3 uzz::    = = U U. ) uyy99    < < T T$  u}}==    @ @ X X  u??    B B Z Z   u~~>>    A A Y Y r')NF)F)N)Nr)J__doc__r*enumos.pathrrrrapitools.base.pyrr1!googlecloudsdk.api_lib.cloudbuildr"googlecloudsdk.api_lib.clouddeployrrgooglecloudsdk.api_lib.storagergooglecloudsdk.callioper!googlecloudsdk.command_lib.deployrr r r r googlecloudsdk.corerr rrgooglecloudsdk.core.resourcergooglecloudsdk.core.utilrrr:_RELEASE_COLLECTIONrrrErCrFr-r/rEnumrr4r0rLr\r{rrdrcrrrrr^rrrerrfr&r@rIrDrNrdrUrPr&r'r(rsV7   >6:@6>98:;A9=#)$;** @.+!/   %DII&K,T+BJ(VNzYx""2GTK>! H2=  :G@T2"*M` *r'