N>dZddlmZddlmZddlmZddlmZddlmZddl m Z ddl m Z dd l mZdd lmZdd lmZdd lmZdd lmZdZGddej,ZdZdZGdde ZGddeZy)z$Utilities for Eventarc Triggers API.)absolute_import)division)unicode_literals) list_pager)common)EventarcClientBase)apis)types) exceptions) resources) iso_duration)timesceZdZdZy)NoFieldsSpecifiedErrorz:Error when no fields were specified for a Patch operation.N)__name__ __module__ __qualname____doc__/lib/googlecloudsdk/api_lib/eventarc/triggers.pyrr"sBrrcxtjj|jd}|j S)Nz$eventarc.projects.locations.triggers) collection)r REGISTRYParseRelativeNamenameSelfLink)resourcetriggers r GetTriggerURIr!&s7    0 0mm F 1 H'    rc4tj|sytj|}t j t }tj||}tj|k\rytj|dtjS)aComputes the time by which the trigger will become active. Args: event_type: str, the trigger's event type. update_time: str, the time when the trigger was last modified. Returns: The active time as a string, or None if the trigger is already active. N)minutesz%H:%M:%S)fmttzinfo) r IsAuditLogTyper ParseDateTimer DurationMAX_ACTIVE_DELAY_MINUTESGetDateTimePlusDurationNowFormatDateTimeLOCAL) event_type update_time update_dtdelay active_dts rTriggerActiveTimer3,sr   j ) !!+.)   (@ A%++Iu=) YY[I    iZ LLrc@eZdZdZfdZdZdZdZdZdZ xZ S)_BaseTriggersClientzBase Triggers Client.ctt| tjddt j tjd}|j|_|j|_ |j|_ y)Nv1r ) superr5__init__rAPI_NAMEr GetClientInstanceMESSAGES_MODULE _messagesprojects_locations_triggers_serviceprojects_locations_operations_operation_service)selfclient __class__s rr9z_BaseTriggersClient.__init__DsY t-footYO  # #FOOT :F++DN66DM$BBDrc|jj|jj||j }|j j |S)a!Creates a new Trigger. Args: trigger_ref: Resource, the Trigger to create. trigger_message: Trigger, the trigger message that holds trigger's event_filters, service account, destination, transport, etc. Returns: A long-running operation for create. )parentr triggerId)r=.EventarcProjectsLocationsTriggersCreateRequestParent RelativeNameNamer?Create)rB trigger_reftrigger_message create_reqs rrLz_BaseTriggersClient.CreateKsYNN!!#002""$O&J ==   ++rc|jj|j}|jj |S)zDeletes a Trigger. Args: trigger_ref: Resource, the Trigger to delete. Returns: A long-running operation for delete. r)r=.EventarcProjectsLocationsTriggersDeleteRequestrJr?Delete)rBrM delete_reqs rrSz_BaseTriggersClient.Delete\s?NN  % % 'O)J ==   ++rc|jj|j}|jj |S)zyGets a Trigger. Args: trigger_ref: Resource, the Trigger to get. Returns: The Trigger message. rQ)r=+EventarcProjectsLocationsTriggersGetRequestrJr?Get)rBrMget_reqs rrWz_BaseTriggersClient.Getis?nnHH  % % 'I)G ==  W %%rc|jj|j|}tj|j |d||dS)aiLists Triggers in a given location. Args: location_ref: Resource, the location to list Triggers in. limit: int or None, the total number of results to return. page_size: int, the number of entries in each batch (affects requests made, but not the yielded results). Returns: A generator of Triggers in the location. )rFpageSizetriggersrZ)field batch_sizelimitbatch_size_attribute)r=,EventarcProjectsLocationsTriggersListRequestrJr YieldFromListr?)rB location_refr^ page_sizelist_reqs rListz_BaseTriggersClient.ListvsV~~JJ((*YK@H  # # '  ))rc|jj|j||}|jj |S)aiUpdates a Trigger. Args: trigger_ref: Resource, the Trigger to update. trigger_message: Trigger, the trigger message that holds trigger's event_filters, service account, destination, transport, etc. update_mask: str, a comma-separated list of Trigger fields to update. Returns: A long-running operation for update. )rr updateMask)r=-EventarcProjectsLocationsTriggersPatchRequestrJr?Patch)rBrMrN update_mask patch_reqs rriz_BaseTriggersClient.PatchsGLL  % % 'M I ==  y ))r) rrrrr9rLrSrWreri __classcell__)rDs@rr5r5As%C," , &),*rr5cFeZdZdZdZdZdZdZdZdZ dZ d Z d Z y ) TriggersClientV1z3Client for Triggers service in the Eventarc GA API.c B|gn=|jD cgc]"\} } |jj| | $c} } } |E|jD]2\} } | j|jj| | d4|r|j nd} |jj | }|jj |}|r|j nd}|jj|j | |||||| Scc} } w)a Builds a Trigger message with the given data. Args: trigger_ref: Resource, the Trigger to create. event_filters: dict or None, the Trigger's event filters. event_filters_path_pattern: dict or None, the Trigger's event filters in path pattern format. event_data_content_type: str or None, the data content type of the Trigger's event. service_account: str or None, the Trigger's service account. destination_message: Destination message or None, the Trigger's destination. transport_topic_ref: Resource or None, the user-provided transport topic. channel_ref: Resource or None, the channel for 3p events labels: dict or None, the Trigger's labels. Returns: A Trigger message with a destination service. N) attributevaluezmatch-path-pattern)rprqoperator)topic)pubsub)r eventFilterseventDataContentTypeserviceAccount destination transportchannellabels)itemsr= EventFilterappendrJPubsub TransportTrigger)rBrM event_filtersevent_filters_path_patternevent_data_content_typeservice_accountdestination_messagetransport_topic_ref channel_refr{keyrqfilter_messagestransport_topic_namertryrzs rBuildTriggerMessagez$TriggersClientV1.BuildTriggerMessages:>*1b'--/8/JC ""S">/8O"-288:*#u NN & &U5I ' K L; /;;"&^^ " ")= " >F(((7I,7k&&(TG >> ! !  % % '$4&' "  !8s'Dcx|jj||||}|jj|S)aBuilds a Destination message for a destination Cloud Run service. Args: destination_run_service: str or None, the destination Cloud Run service. destination_run_job: str or None, the destination Cloud Run job. destination_run_path: str or None, the path on the destination Cloud Run service. destination_run_region: str or None, the destination Cloud Run service's region. Returns: A Destination message for a destination Cloud Run service. )servicejobpathregion)cloudRun)r=CloudRun Destination)rBdestination_run_servicedestination_run_jobdestination_run_pathdestination_run_region run_messages rBuildCloudRunDestinationMessagez0TriggersClientV1.BuildCloudRunDestinationMessagesC$..))'  !% *'K >> % %{ % ;;rcz|jj|||||}|jj|S)a]Builds a Destination message for a destination GKE service. Args: destination_gke_cluster: str or None, the destination GKE service's cluster. destination_gke_location: str or None, the location of the destination GKE service's cluster. destination_gke_namespace: str or None, the destination GKE service's namespace. destination_gke_service: str or None, the destination GKE service. destination_gke_path: str or None, the path on the destination GKE service. Returns: A Destination message for a destination GKE service. )clusterlocation namespacerr)gke)r=GKEr)rBdestination_gke_clusterdestination_gke_locationdestination_gke_namespacedestination_gke_servicedestination_gke_path gke_messages rBuildGKEDestinationMessagez+TriggersClientV1.BuildGKEDestinationMessagesF(..$$')+' ! %#K >> % %+ % 66rc`dj|||}|jj|S)aBuilds a Workflow Destination message with the given data. Args: project_id: the ID of the project. destination_workflow: str or None, the Trigger's destination Workflow ID. destination_workflow_location: str or None, the location of the Trigger's destination Workflow. It defaults to the Trigger's location. Returns: A Destination message with a Workflow destination. z%projects/{}/locations/{}/workflows/{})workflowformatr=r)rB project_iddestination_workflowdestination_workflow_locationworkflow_messages rBuildWorkflowDestinationMessagez0TriggersClientV1.BuildWorkflowDestinationMessages8?EE13GI >> % %/? % @@rc`dj|||}|jj|S)aBuilds a Function Destination message with the given data. Args: project_id: the ID of the project. destination_function: str or None, the Trigger's destination Function ID. destination_function_location: str or None, the location of the Trigger's destination Function. It defaults to the Trigger's location. Returns: A Destination message with a Function destination. z%projects/{}/locations/{}/functions/{}) cloudFunctionr)rBrdestination_functiondestination_function_locationfunction_messages rBuildFunctionDestinationMessagez0TriggersClientV1.BuildFunctionDestinationMessage#s8?EE13GI >> % %4D % EErc|jj|}|jj|}|jj||S)aIBuilds a HTTP Endpoint Destination message with the given data. Args: destination_http_endpoint_uri: str or None, the Trigger's destination uri. network_attachment: str or None, the Trigger's destination network attachment. Returns: A Destination message with a HTTP Endpoint destination. )uri)networkAttachment) httpEndpoint networkConfig)r= HttpEndpoint NetworkConfigr)rBdestination_http_endpoint_urinetwork_attachmenthttp_endpoint_messagenetwork_config_messages r#BuildHTTPEndpointDestinationMessagez4TriggersClientV1.BuildHTTPEndpointDestinationMessage5sd!NN77 )8"^^99,: >> % %*, & rc<g}|r|jd|r|jd|r|jd|r|jd| r|jd| r|jd| r|jd| s| r|jd|s|r|jd |s|r|jd |r|jd |r|jd |r|jd |s tddj|S)a;Builds an update mask for updating a Cloud Run trigger. Args: event_filters: bool, whether to update the event filters. event_filters_path_pattern: bool, whether to update the event filters with path pattern syntax. event_data_content_type: bool, whether to update the event data content type. service_account: bool, whether to update the service account. destination_run_service: bool, whether to update the destination Cloud Run service. destination_run_job: bool, whether to update the desintation Cloud Run job. destination_run_path: bool, whether to update the destination Cloud Run path. destination_run_region: bool, whether to update the destination Cloud Run region. destination_gke_namespace: bool, whether to update the destination GKE service namespace. destination_gke_service: bool, whether to update the destination GKE service name. destination_gke_path: bool, whether to update the destination GKE path. destination_workflow: bool, whether to update the destination workflow. destination_workflow_location: bool, whether to update the destination workflow location. destination_function: bool, whether to update the destination function. destination_function_location: bool, whether to update the destination function location. labels: bool, whether to update the labels. Returns: The update mask as a string. Raises: NoFieldsSpecifiedError: No fields are being updated. zdestination.cloudRun.pathzdestination.cloudRun.regionzdestination.cloudRun.servicezdestination.cloudRun.jobzdestination.gke.namespacezdestination.gke.servicezdestination.gke.pathzdestination.workflowzdestination.cloudFunctionrurwrvr{z*Must specify at least one field to update.,)r~rjoin)rBrrrrrrrrrrrrrrrr{rjs rBuildUpdateMaskz TriggersClientV1.BuildUpdateMaskOsnK45677834 4523/0</0<452()*/0 "  "#O PP 88K  rc@tj|jS)zGets the Trigger's event type.)r EventFiltersMessageToTyperu)rBrNs r GetEventTypezTriggersClientV1.GetEventTypes  * *?+G+G HHrcB|jjjS)zReturns the labels value class.)r=r LabelsValue)rBs rLabelsValueClassz!TriggersClientV1.LabelsValueClasss >> ! ! - --rN) rrrrrrrrrrrrrrrrrnrns8;8t<278A$F$4T!lI.rrnN)r __future__rrrapitools.base.pyrgooglecloudsdk.api_lib.eventarcr$googlecloudsdk.api_lib.eventarc.basergooglecloudsdk.api_lib.utilr #googlecloudsdk.command_lib.eventarcr googlecloudsdk.corer r googlecloudsdk.core.utilr rr)Errorrr!r3r5rnrrrrsr+&''2C,5*)1*CZ--C M*[*,[*|L.*L.r