dZddlmZddlmZddlmZddlZddlmZddlm Z ddl m Z dd l m Z d d d Z d ZdZdZdZe j$e j&j(e j*Gdde j,Zy)z7Command to list all triggers in a project and location.)absolute_import)division)unicode_literalsN)triggers)base)flags)typesz {description}z To list all triggers in location ``us-central1'', run: $ {command} --location=us-central1 To list all triggers in all locations, run: $ {command} --location=- or $ {command} ) DESCRIPTIONEXAMPLESz table( name.scope("triggers"):label=NAME, eventFilters.type():label=TYPE, destination():label=DESTINATION, active_status():label=ACTIVE, name.scope("locations").segment(0):label=LOCATION ) a table( name.scope("triggers"):label=NAME, matchingCriteria.type():label=TYPE, destination.cloudRunService.service:label=DESTINATION_RUN_SERVICE, destination.cloudRunService.path:label=DESTINATION_RUN_PATH, active_status():label=ACTIVE ) c|jd|jd}tj|}tj||d}|rdj |SdS)N eventFiltersmatchingCriteria updateTimezBy {}Yes)getr EventFiltersDictToTyperTriggerActiveTimeformat)trigger event_filters event_type active_times %lib/surface/eventarc/triggers/list.py _ActiveStatusrDsY++ngkk:L.MN-++M:***:w|7LM+(3 $>>c|jd}|yd|vrW|jd}|jd}|rdj|S|jd}dj|Sd|vr1|jd}d j|jdSd |vrMd }|jd }tj||}|r d j|j d SdSd|vrMd}|jd}tj||}|r dj|j d SdSd|vr1|jd}dj|jdSy)aGenerate a destination string for the trigger. Based on different destination types, this function returns a destination string accordingly: * Cloud Run trigger: "Cloud Run: {cloud run service or job}" * GKE trigger: "GKE: {gke service}" * Workflows trigger: "Workflows: {workflow name}" * Cloud Functions trigger: "Cloud Functions: {cloud function name}" For unknown destination (e.g. new types of destination and corrupted destination), this function returns an empty string. Args: trigger: eventarc trigger proto in python map format. Returns: A string representing the destination for the trigger. destinationcloudRunjobzCloud Run job: {}servicezCloud Run service: {}gkezGKE: {} cloudFunctionz)^projects/.*/locations/.*/functions/(.*)$zCloud Functions: {}workflowz)^projects/.*/locations/.*/workflows/(.*)$z Workflows: {} httpEndpointzHTTP endpoint: {}uri)rrresearchgroup)rrdestr r!cloud_function_str_patternmatchworkflows_str_patterns r _Destinationr/Ksp( M*+ ; ??: &D ((5/C ' ' ,,hhy!G " ) )' 22  ??5 !D   DHHY/ 00+%!L ??? +D II0$ 7E;@ ' ' A 7HbH[ G ??: &D II+T 2E5:? ! !%++a. 1CC$ ??> *D  % %dhhuo 66 rc*eZdZdZeZedZdZy)ListzList Eventarc triggers.cZtj|dddtj||jj t |jj tj|jjtttjdy)NzjThe location for which to list triggers. This should be either ``global'' or one of the supported regions.FT)requiredallow_aggregation) active_statusrtype)rAddLocationResourceArgAddProjectResourceArg display_info AddFormat_FORMAT AddUriFuncr GetTriggerURI AddTransformsrr/r r)parsers rArgsz List.Argss    6  ' !!'* ""8#9#9: %%&#,,'rctj}|jjj |jj j }|j ||j|jS)zRun the list command.) rTriggersClientV1CONCEPTSprojectParselocationr1limit page_size)selfargsclient location_refs rRunzList.RunsY  & & (FMM!==))//1L ;;|TZZ @@rN) __name__ __module__ __qualname____doc___DETAILED_HELP detailed_help staticmethodr@rMrrr1r1s$  -"Arr1)rQ __future__rrrr(googlecloudsdk.api_lib.eventarcrgooglecloudsdk.callioper#googlecloudsdk.command_lib.eventarcrr rRr; _FORMAT_BETArr/ ReleaseTracks ReleaseTrackGADefaultUniverseOnly ListCommandr1rUrrr`s>&' 4(55  &  ?2jD%%(()A4  A*Ar