dZddlmZddlmZddlmZddlmZddlmZddlm Z ddl m Z dd l m Z dd lmZdd lmZGd d ej"ZdZGdde Zy)z$Utilities for Eventarc Channels API.)absolute_import)division)unicode_literals) list_pager)common)common_publishing)EventarcClientBase)apis) exceptions) resourcesceZdZdZy)NoFieldsSpecifiedErrorz:Error when no fields were specified for a Patch operation.N)__name__ __module__ __qualname____doc__/lib/googlecloudsdk/api_lib/eventarc/channels.pyrrsBrrcxtjj|jd}|j S)Nz$eventarc.projects.locations.channels) collection)r REGISTRYParseRelativeNamenameSelfLink)resourcechannelss r GetChannelURIr"s7    1 1mm F2H(    rcZeZdZdZfdZd dZdZdZdZdZ dZ d Z d Z d Z xZS) ChannelClientV1z@Channel Client for interaction with v1 of Eventarc Channels API.ctt| tjtj dt jtjtj }|j|_ |j|_ t jtjtj }|j|_ |j|_y)Nchannel)superr __init__rAPI_NAME API_VERSION_1r GetClientInstanceMESSAGES_MODULE _messagesprojects_locations_channels_servicer_publishing_messages_publishing_service)selfclientpublishing_client __class__s rr$zChannelClientV1.__init__+s /4)&//6;O;O*35 # #FOOV5I5I JF++DN66DM../@/I/I/@/N/NP!2 A AD0LLDrc|jj|jj||j |}|j j |S)aACreates a new Channel. Args: channel_ref: Resource, the Channel to create. channel_message: Channel, the channel message that holds channel's name, provider, etc. dry_run: If set, the changes will not be commited, only validated Returns: A long-running operation for create. )parentr" channelId validateOnly)r).EventarcProjectsLocationsChannelsCreateRequestParent RelativeNameNamer+Create)r. channel_refchannel_messagedry_run create_reqs rr:zChannelClientV1.Create<s\NN!!#002""$ OJ ==   ++rc|jj|j}|jj |S)zDeletes the specified Channel. Args: channel_ref: Resource, the Channel to delete. Returns: A long-running operation for delete. r)r).EventarcProjectsLocationsChannelsDeleteRequestr8r+Delete)r.r; delete_reqs rrBzChannelClientV1.DeleteOs?NN  % % 'O)J ==   ++rc|jj|j}|jj |S)zGets the requested Channel. Args: channel_ref: Resource, the Channel to get. Returns: The Channel message. r@)r)+EventarcProjectsLocationsChannelsGetRequestr8r+Get)r.r;get_reqs rrFzChannelClientV1.Get\s?nnHH  % % 'I)G ==  W %%rc|jj|j|}tj|j |d||dS)ajList available channels in location. Args: location_ref: Resource, the location to list Channels 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 Channels in the location. )r3pageSizerrI)servicerequestfieldlimit batch_sizebatch_size_attribute)r),EventarcProjectsLocationsChannelsListRequestr8r YieldFromListr+)r. location_refrM page_sizelist_reqs rListzChannelClientV1.ListisV~~JJ((*YK@H  # # '  ))rc|jj|j||}|jj |S)aMUpdates the specified Channel. Args: channel_ref: Resource, the Channel to update. channel_message: Channel, the channel message that holds channel's name, provider, etc. update_mask: str, a comma-separated list of Channel fields to update. Returns: A long-running operation for update. )rr" updateMask)r)-EventarcProjectsLocationsChannelsPatchRequestr8r+Patch)r.r;r< update_mask patch_reqs rrYzChannelClientV1.PatchsGLL  % % 'M I ==  y ))rc2tj|jjj|}|jj|g}|jj |j |}|jj|y)zPublish to a Channel. Args: channel_ref: Resource, the channel to publish to. cloud_event: A CloudEvent representation to be passed as the request body. )events)r"3googleCloudEventarcPublishingV1PublishEventsRequestN) rTransformEventsForPublishingr,3GoogleCloudEventarcPublishingV1PublishEventsRequestEventsValueListEntry?EventarcpublishingProjectsLocationsChannelsPublishEventsRequestr8r- PublishEvents)r.r; cloud_eventevents_value_list_entrypublish_events_request publish_reqs rPublishzChannelClientV1.Publishs0LL !! < <  {, "66jj'(k*++kk((*> ! !  % % '%   "  &2%>%>%@ "  rcg}|r|jd|r|jd|r|jd|s tddj|S)aaBuilds an update mask for updating a channel. Args: crypto_key: bool, whether to update the crypto key. clear_crypto_key: bool, whether to clear the crypto key. labels: bool, whether to update the labels. Returns: The update mask as a string. Raises: NoFieldsSpecifiedError: No fields are being updated. rjrlz*Must specify at least one field to update.,)appendrjoin)r. crypto_keyclear_crypto_keyrlrZs rBuildUpdateMaskzChannelClientV1.BuildUpdateMasksZK)) "  "#O PP 88K  rcB|jjjS)N)r)rm LabelsValue)r.s rLabelsValueClszChannelClientV1.LabelsValueClss >> ! ! - --r)F)rrrrr$r:rBrFrUrYrhrprwrz __classcell__)r1s@rr r (s9HM",& , &),*$80 !4.rr N)r __future__rrrapitools.base.pyrgooglecloudsdk.api_lib.eventarcrr$googlecloudsdk.api_lib.eventarc.baser googlecloudsdk.api_lib.utilr googlecloudsdk.corer r Errorrrr rrrrsP+&''2=C,*)CZ--C e.(e.r