QRdZddlmZddlmZddlmZddlmZddlZddlZddlZddl Z ddl m Z ddl m Z dd l mZdd l mZdd lmZdd lmZdd lmZddlmZddlmZddlmZddlmZGddej8ZdZdZGddeZ GddeZ!Gdde Z"Gdde Z#Gdde Z$Gd d!e Z%Gd"d#ej8Z&d$Z'd%Z(dNd'Z)dNd(Z*d)Z+d*Z,d+Z-d,Z.dNd-Z/dNd.Z0Gd/d0ejbZ2dNd1Z3d2Z4Gd3d4eZ5d5Z6Gd6d7eZ7d8Z8d9Z9dNd:Z:d;Z;d<ZZ>dNd?Z?dNd@Z@dNdAZAdNdBZBdNdCZCdNdDZDdEZEdFZFdGZGejdHe9dIdJd&dJKZIejdLeFdMdJd&dJKZJy)Oz-Shared resource flags for Cloud Run commands.)absolute_import)division)print_function)unicode_literalsN)global_methods)concepts)deps)util) exceptions) platforms)presentation_specs)log) properties) resources) console_iocLeZdZdZfdZej dZdZxZ S)PromptFallthroughz3Fall through to reading from an interactive prompt.c0tt| d|y)Nfunctionhint)superr__init__)selfr __class__s 3lib/googlecloudsdk/command_lib/run/resource_args.pyrzPromptFallthrough.__init__+s T+T+EcyNr parsed_argss r_PromptzPromptFallthrough._Prompt.srcNtjsy|j|Sr)r CanPromptr#r!s r_CallzPromptFallthrough._Call2s    !  << $$r) __name__ __module__ __qualname____doc__rabcabstractmethodr#r& __classcell__rs@rrr(s+;F  %rrc2tjj|jtj}|j dd}|j dd}t jdd|jdjS)aProduce a valid default service name from a container image path. Converts a file path or image path into a reasonable default service name by stripping file path delimeters, image tags, and image hashes. For example, the image name 'gcr.io/myproject/myimage:latest' would produce the service name 'myimage'. Args: image: str, The container path. Returns: A valid Cloud Run service name. :r@z [^a-zA-Z0-9-]-) ospathbasenamerstripsepsplitresubstriplower)image base_names r_GenerateServiceNamer@8ssggu||BFF34)ooc"1%)ooc"1%)  "i 0 6 6s ; A A CCrctjjtjj|\}}|r%tjj|\}}|r%t |S)a'Produce a valid default service name from a local file or directory path. Converts a file or directory path into a reasonable default service name by resolving relative paths to absolute paths, removing any extensions, and then removing any invalid characters. For example, the paths /tmp/foo/bar/.. and /tmp/foo.tar.gz would both produce the service name 'foo'. A source path of "." will be expanded to the current directory name." Args: source: str, The file or directory path. Returns: A valid Cloud Run service name. )r4r5splitextabspathr@)sourcer5exts r!_GenerateServiceNameFromLocalPathrFMsT"ggrwwv67)$   &ID# d ##rc.eZdZdZfdZdZdZxZS)ResourcePromptFallthroughzEFall through to reading the resource name from an interactive prompt.cXtt| dj|||_y)Nz.specify the {} name from an interactive prompt)rrHrformatresource_type_lower)rrKrs rrz"ResourcePromptFallthrough.__init__gs. #T38??   3Drc|jjdz}|j|}tj||S)Nz name)messagedefault)rK capitalize_DefaultNameFromArgsrPromptWithDefault)rr"rM default_names rr#z!ResourcePromptFallthrough._Promptos>&&113g=G,,[9L  ' ' NNrct|ddrt|jSt|ddrt|jSy)Nr>rDr2)getattrr@r>rFrDr!s rrPz.ResourcePromptFallthrough._DefaultNameFromArgsts?{GT* !+"3"3 44 h - .{/A/A BB r)r'r(r)r*rr#rPr-r.s@rrHrHdsM3O rrHc(eZdZdZfdZdZxZS)RegionPromptFallthroughz>Fall through to reading the region from an interactive prompt.c,tt| dy)Nz-specify the region from an interactive prompt)rrVrrrs rrz RegionPromptFallthrough.__init__s !417rctj}tj|}tj|ddd}||}t j jdj||r||_ |S)NzPlease specify a region: T)rM cancel_optionallow_freeformzHTo make this the default region, run `gcloud config set run/region {}`. ) rGetServerlessClientInstance ListRegionsr PromptChoicerstatusPrintrJregion)rr"client all_regionsidxras rr#zRegionPromptFallthrough._Promptsz  7 7 9F ,,V4K  ! !,  C  FJJ //5vf~!k Mrr'r(r)r*rr#r-r.s@rrVrV|sF rrVceZdZfdZxZS)ServicePromptFallthroughc,tt| dy)Nservice)rrgrrXs rrz!ServicePromptFallthrough.__init__s "D29=rr'r(r)rr-r.s@rrgrgs >>rrgceZdZfdZxZS)WorkerPoolPromptFallthroughc,tt| dy)N workerpool)rrlrrXs rrz$WorkerPoolPromptFallthrough.__init__s %t5lCrrjr.s@rrlrlsDDrrlceZdZfdZxZS)JobPromptFallthroughc,tt| dy)Njob)rrprrXs rrzJobPromptFallthrough.__init__s .u5rrjr.s@rrprps 66rrpceZdZfdZxZS)ExecutionPromptFallthroughc,tt| dy)N execution)rrtrrXs rrz#ExecutionPromptFallthrough.__init__s $d4[Arrjr.s@rrtrtsBBrrtc(eZdZdZfdZdZxZS)DefaultFallthroughzrUse the namespace "default". For Knative only. For Cloud Run, raises an ArgumentError if project not set. c0tt| ddy)Nz]For Cloud Run on Kubernetes Engine, defaults to "default". Otherwise, defaults to project ID.r)rrxrrXs rrzDefaultFallthrough.__init__s  d, 1-rcBtjtjk(s%tjtjk(ryt |ddsGt j jjjstjdy)NrNprojectzThe [project] resource is not properly specified. Please specify the argument [--project] on the command line or set the property [core/project].) r GetPlatform PLATFORM_GKEPLATFORM_KUBERNETESrTrVALUEScorer{Getr ArgumentErrorr!s rr&zDefaultFallthrough._Calls|9#9#99  "i&C&C C  Y-    ! ! ) ) - - /  $ $ -  rr'r(r)r*rr&r-r.s@rrxrxsrrxc Dtjddtjtj j jttjdtjtj jjgS)N namespacezJSpecific to Cloud Run for Anthos: Kubernetes namespace for the {resource}.r{name help_text fallthroughs) r ResourceParameterAttributeConfigr PropertyFallthroughrrrunrrxArgFallthroughrr{r rrNamespaceAttributeConfigrsx  2 2  5  " ":#4#4#8#8#B#B C     i (  " ":#4#4#9#9#A#A B   rctjtj}t gtjj z}||_|Sr)copydeepcopyr DEFAULT_PROJECT_ATTRIBUTE_CONFIGrxr)project_attribute_configrs rProjectAttributeConfigrsN!]]////<<=,+7' !!rFcR|r tg}ng}tjdd|S);Attribute config with fallthrough prompt only if requested.rizService for the {resource}.r)rgrrpromptrs rServiceAttributeConfigrs1 ,./LL  2 2 - rcR|r tg}ng}tjdd|S)rz worker-poolzWorkerPool for the {resource}.r)rlrrrs rWorkerPoolAttributeConfigrs1 /12LL  2 2 0 rc0tjddS)N configurationz!Configuration for the {resource}.rrrrr rrConfigurationAttributeConfigr s  2 2 &I rc0tjddS)NroutezRoute for the {resource}.rrr rrRouteAttributeConfigrs  2 2 9 rc0tjddS)NrevisionzRevision for the {resource}.rrr rrRevisionAttributeConfigrs  2 2 !? rc0tjddS)Ndomainz#Name of the domain to be mapped to.rrr rrDomainAttributeConfigrs  2 2 D rcR|r tg}ng}tjdd|S)NjobszJob for the {resource}.r)rprrrs rJobAttributeConfigr!s1 (*+LL  2 2 ) rcR|r tg}ng}tjdd|S)N executionsz Execution.r)rtrrrs rExecutionAttributeConfigr-s/ .01LL  2 2 >&% ((rFrr.s@rrr7sI)rrcT|r tdg}ng}tjdd|S)NtasktaskszTask.r)rrrrs rTaskAttributeConfigrLs1 4V<=LL  2 2 gL rctjddtjdtjt j jjtgS)NrazsThe Cloud region for the {resource}. Overrides the default `run/region` property value for this command invocation.--regionr) rrr rrrrrrarVr rrLocationAttributeConfigrVsY  2 2  E   j )  " ":#4#4#8#8#?#? @ ! #  rc.eZdZdZfdZdZdZxZS)ClusterPromptFallthroughDFall through to reading the cluster name from an interactive prompt.c,tt| dy)Nz5specify the cluster from a list of available clusters)rrrrXs rrz!ClusterPromptFallthrough.__init__hs "D2?rctjtjk7rytjj j jd}t|ddxs2tjjjj}|rdj|nd}tj||}|s$tjdj||Dcgc]}|j!|||}}t#j$|dj|d }||} |rd} nd j| j&} | j)} | j*|k7r| j-} d} t.j0j3d j| | | j5Scc}w) zFallthrough to reading the cluster name from an interactive prompt. Only prompt for cluster name if the user-specified platform is GKE. Args: parsed_args: Namespace, the args namespace. Returns: A cluster name string NT)requiredcluster_locationz in [{}]r2zJNo compatible clusters found{}. Ensure your cluster has Cloud Run enabled.zGKE cluster{}:rMrZz- && gcloud config set run/cluster_location {}z[To make this the default cluster, run `gcloud config set run/cluster {cluster}{location}`. )clusterlocation)r r|r}rrrr{rrTrrrJrMultiTenantClustersForProjectr ConfigurationError_GetClusterDescriptionrr^zoneName projectId RelativeNamerr_r`SelfLink) rr"r{rcluster_location_msg cluster_refsccluster_refs_descsrd cluster_reflocation_help_text cluster_names rr#z ClusterPromptFallthrough._Promptms)"8"88 $$,,00$0?G /6 8    1 1 5 5 7 0@ *+R"??!L   ) ) 77=v"8  A ##A'7A  ! ! ''(<= C s#K : @ @  ##%L' --/lJJ  +=      !!Gs1G c|j}|sdj||j}||jk7rdj||j}|S)z"Description of cluster for prompt.z{} in {})rrJrr)rrrr{responses rrz/ClusterPromptFallthrough._GetClusterDescriptionsS||~H ""8W\\:h'###""8W->->?h Or)r'r(r)r*rr#rr-r.s@rrresL E"N rrctjddtjtj j jtgS)Nrz\Name of the Kubernetes Engine cluster to use. Alternatively, set the property [run/cluster].r) rrr rrrrrrr rrClusterAttributeConfigrsJ  2 2  ;  " ":#4#4#8#8#@#@ A " $  rc(eZdZdZfdZdZxZS) ClusterLocationPromptFallthroughrc,tt| dy)Nz;specify the cluster location from a list of available zones)rrrrXs rrz)ClusterLocationPromptFallthrough.__init__s *D:Erct|ddxs2tjjjj }t jt jk(r|rtjDcgc]}|j|k(s|}}|s$tjdj||Dcgc]}|j}}t!j"|dj|d}||}t$j&j)dj||Syycc}wcc}w)a/Fallthrough to reading the cluster location from an interactive prompt. Only prompt for cluster location if the user-specified platform is GKE and if cluster name is already defined. Args: parsed_args: Namespace, the args namespace. Returns: A cluster location string rNzYNo cluster locations found for cluster [{}]. Ensure your clusters have Cloud Run enabled.zGKE cluster location for [{}]:Trz\To make this the default cluster location, run `gcloud config set run/cluster_location {}`. )rTrrrrrr r|r}r ListClustersrr rrJrrr^rr_r`)rr"rrclusterscluster_locationsrdrs rr#z(ClusterLocationPromptFallthrough._Prompts1  Y- /    ( ( , , .)"8"88\#0022aff 6L!2++ ;;A6,;O  ,448a16684  # # 299,G c #3'h jj ;;A6(;Ko)>J85s?D7D7D<rer.s@rrrsL $rrctjddtjtj j jtgS)Nrz`Zone in which the {resource} is located. Alternatively, set the property [run/cluster_location].r) rrr rrrrrrr rrClusterLocationAttributeConfigrsK  2 2  D  " ":#4#4#8#8#I#I J * ,  rcrtjdtjtt dS)Nz!container.projects.zones.clustersr)rr clusterId resource_name)r ResourceSpecrrrr rrGetClusterResourceSpecr s0   )99 ) +&(  rcVtjdtt|dS)Nzrun.namespaces.servicesri) namespacesId servicesIdr)rrrrrs rGetServiceResourceSpecrs)   +-'/  rcTtjdttdS)Nzrun.namespaces.configurationsr)rconfigurationsIdr)rrrrr rrGetConfigurationResourceSpecrs'   %+-35#  rcTtjdttdS)Nzrun.namespaces.routesr)rroutesIdr)rrrrr rrGetRouteResourceSpecr's'   +-#%  rcxtjd|s tntjt dS)Nzrun.namespaces.revisionsr)r revisionsIdr)rrrrr)is_worker_pool_revisions rGetRevisionResourceSpecr1s5    $,-  4 4)+  rcTtjdttdS)Nzrun.namespaces.domainmappings DomainMapping)rdomainmappingsIdr)rrrrr rrGetDomainMappingResourceSpecr<s'   %+-,.#  rcftjdtjt|ddS)Nzrun.namespaces.jobsrJobv1)rjobsIdr api_version)rrrrrs rGetJobResourceSpecrEs/   << v .  rcftjdtjt|ddS)Nzrun.namespaces.executionsr Executionr)r executionsIdrr)rrrrrs rGetExecutionResourceSpecr Os/   !<<+6:  rcftjdtjt|ddS)Nzrun.namespaces.tasksrTaskr)rtasksIdrr)rrrrrs rGetTaskResourceSpecrYs/   <<!0  rcdtjdtjt|ddS)Nzrun.namespaces.workerpools WorkerPoolr)r workerpoolsIdrr)rrrrrs rGetV1WorkerPoolResourceSpecrcs/   "<<-f5   rcvtjdtjtt |ddS)Nz"run.projects.locations.workerPoolsrv2) projectsId locationsId workerPoolsIdrr)rrrrrrs rGetV2WorkerPoolResourceSpecrms5   *::)+-f5   rc tjdtjtt |t ddS)Nz,run.projects.locations.workerPools.revisionsWorkerPoolRevisionr)rrrrrr)rrrrrrrs r#GetV2WorkerPoolRevisionResourceSpecrxs;   4::)+-f5)+( rcBtjddtS)Nz run.projectsr{)rr)rrrr rrGetProjectResourceSpecrs!   ') rcbtjdtjtddS)Nzrun.projects.locationsRegionr)rrrr)rrrrr rrGetRegionResourceSpecr s-   ::)+  rc tjdtdS#tj$r#tjdtdcYSwxYw)z*Returns a resource spec for the namespace.zrun.namespacesr)rrzrun.api.v1.namespaces)rrrrInvalidCollectionExceptionr rrGetNamespaceResourceSpecr#s\   -/!   - -  -/! s"3AAz --clusterz(Kubernetes Engine cluster to connect to.T)hiddenrprefixesrzCloud region to use.r)Kr* __future__rrrrr+rr4r:googlecloudsdk.api_lib.runr googlecloudsdk.calliope.conceptsrr r rgooglecloudsdk.command_lib.runr r (googlecloudsdk.command_lib.util.conceptsr googlecloudsdk.corerrrgooglecloudsdk.core.consoler Fallthroughrr@rFrHrVrgrlrprtrxrrrrrrrrrrrrrrrrrrrrrrrrrr rrrrrr r#ResourcePresentationSpecCLUSTER_PRESENTATIONREGION_PRESENTATIONr rrr1s4&%' 551B54G#*)2 %(( % D*$. 10/6>8> D";D 646 B!:B "))"J  "      )t':':)* X0Xv ,'8,^  &C)BB.    B(AA    r