dZddlZddlmZddlmZddlmZddlm Z ddl m Z ddl mZe jj j"j$Zd Zd Zd Zd Zdd ZdZdZdZdZdZdZdZdZ dZ!dZ"de#de#fdZ$y)zHContains shared methods for printing k8s object in a human-readable way.N)resource_name_conversion) conditions) console_attr)custom_printer_base) condition)vendor_settingscL |j||S#t$r|cYSwxYw)zBChoose the best symbol (if it's in this encoding) or an alternate.)encode UnicodeError)bestaltencodings >lib/googlecloudsdk/command_lib/run/printers/v2/printer_util.py _PickSymbolr s,KK K  Js  ##ctjj}tj|}|t dd|dfStj |rt dd|dfSy)zAReturn a tuple of ready_symbol and display color for this object.….yellow✔+green)Xred)rGetConsoleAttr GetEncodingrGetTerminalConditionrIsConditionReady)recordrterminal_conditions rReadySymbolAndColorr )ss  ( ( * 6 6 8(!66v>-sH= ""#56 -sH =w FF cVtj|}|rl|jr`t|\}}t j j tjdj||jd|S|$t j j ddSy)zDReturns the record's status condition Ready (or equivalent) message.z{} {}dz Error getting status informationr) rrmessager rrColorizetextwrapfillformat)rrsymbolcolors rFormatReadyMessager,8s!66v>.66'/MFE  & & ( 1 1 gnnV-?-G-GH#N  !  & & ( 1 1*E  r!c|jsy|jxsd}d}|jjr|jj}dj||S)NzUnknown update information?zLast updated on {} by {})r last_modifierlast_transition_timer))rmodifierr0s rLastUpdatedMessager2IsY  " " '  ! ! (S( 33!44II # * *+? JJr!c^tj}|jt|}|r't j |j \}}}}}}n$t j|j \}}}}|rdnd|z} |rdnd|z} |jdj|| || S)z(Returns a display header for a resource.zregions zregion z Multi-Region r$z{} {} {} in {}) rrr&r rGetInfoFromFullChildNamenameGetInfoFromFullName Emphasizer)) ris_multi_regionis_child_resourceconstatus_region resource_kindr5placekinds r BuildHeaderrASs##%# 3<<,V4 5& 99&++F)Avq!]D !44V[[A#Av}d):i6 A%,/" E$ '..vtT5I JJr!cd}|j}|r+tjd|fd||jfgS|jsy |jd}tjd|j r |j ndfd|j r |j ndfd||jfgS#t$rYywxYw)aEReturns the VPC Network setting. Either the values of the vpc-access-connector and vpc-access-egress, or the values of the network and subnetwork in network-interfaces annotation and vpc-access-egress. Args: record: googlecloudsdk.generated_clients.gapic_clients.run_v2.types.vendor_settings.VpcAccess. c|tjjjk(ry|tjjjk(ryy)Nz all-trafficzprivate-ranges-onlyr$)r VpcAccess VpcEgress ALL_TRAFFICPRIVATE_RANGES_ONLY)egresss r _GetEgressz!GetVpcNetwork.._GetEgressps? **44@@@  ?,,66JJ J " r! ConnectorEgressr$rNetworkSubnet) connectorcpLabeledrHnetwork_interfacesnetwork subnetwork Exception)rrIrNnetwork_interfaces r GetVpcNetworkrVds) :: i  v}} %    " " 11!4 :: ):)B)B  % %  ++  ( (    v}} %    s A,B88 CCcXtj|jd\}}}}|S)zExtracts short name from a resource. Args: resource: dict representing a Cloud Run v2 resource. Returns: Short name of the resource. r5rr6getresourcer<r5s rGetNameFromDictr\s/+>>ll6-!Q4 +r!c\tj|jd\}}}}}}|S)zExtracts short name from a resource. Args: resource: dict representing a Cloud Run v2 child resource. Returns: Short name of the resource. r5rr4rYrZs rGetChildNameFromDictr_s41IIll6!Q1a +r!cXtj|jd\}}}}|S)zExtracts region from a resource. Args: resource: dict representing a Cloud Run v2 resource. Returns: Region of the resource. r5rX)r[r<r=s rGetRegionFromDictras/-@@ll6/!VQ -r!c\tj|jd\}}}}}}|S)zExtracts region from a child resource. Args: resource: dict representing a Cloud Run v2 child resource. Returns: Region of the resource. r5r^)r[r<parents rGetParentFromDictrds43KKll6!Q61a -r!cn|jdr$|jdjd}|r|Sy)zExtracts last transition time from a resource. Args: resource: dict representing a Cloud Run v2 resource. Returns: Last transition time of the resource if it exists, otherwise None. rr0NrY)r[results rGetLastTransitionTimeFromDictrhs7\\&' \\. / 3 34J KF m r!c`|jdD]}|jd|k(s|cSy)z>Returns the condition matching the given type from a resource.rtype_Nrf)r[condition_typers r_GetConditionFromDictrls1<< -i}}W/ . r!c^|jdr|jdSt|dS)z*Returns the ready condition of a resource.rReady)rYrl)r[s r_GetReadyConditionFromDictros, \\&' <<, -- x 11r!ctjj}t|}| t dd|S|j dt k(r t dd|Sy)zReturn a ready_symbol for a resource. Args: resource: dict representing a Cloud Run v2 resource. Returns: A string representing the symbol for the resource ready state. rrstaterrr)rrrrorrY_CONDITION_SUCCEEDED_VALUE)r[rready_conditions rGetReadySymbolFromDictrtsb ( ( * 6 6 8(.x8/ 0#x @@7#'AA -sH == r!cPt|d}|r|jdtk(Sy)zReturn active state for a resource. Args: resource: dict representing a Cloud Run v2 resource. Returns: True if the resource is active, false otherwise. ActiverqF)rlrYrr)r[active_conditions rGetActiveStateFromDictrxs.+8X>    (,F FF r!cmek_keyreturnc4|sy|jdd}|S)zReturns the CMEK name from a full CMEK key name. Args: cmek_key: The full CMEK key name. Returns: The CMEK name. r$/)split)ry cmek_names rGetCMEKrs#  nnS!"%) r!)FF)%__doc__r'googlecloudsdk.command_lib.runr!googlecloudsdk.command_lib.run.v2rgooglecloudsdk.core.consolergooglecloudsdk.core.resourcerrO;googlecloudsdk.generated_clients.gapic_clients.run_v2.typesrcondition_objectsr ConditionStateCONDITION_SUCCEEDEDvaluerrrr r,r2rArVr\r_rardrhrlrortrxstrrr!rrs OC84BfW%%99??  "KK"2j      2&  c c r!