'wf<dZddlZddlmZddlmZddlmZdZdZ dZ d Z d Z d Z d Zd ZdZej#eeZej&eZdZGddeZdZy)zConfigure bucket notification resources to interact with Google Cloud Pub/Sub. See [Cloud Pub/Sub Notifications for Google Cloud Storage](https://cloud.google.com/storage/docs/pubsub-notifications) N)NotFound)_DEFAULT_TIMEOUT) DEFAULT_RETRYOBJECT_FINALIZEOBJECT_METADATA_UPDATE OBJECT_DELETEOBJECT_ARCHIVE JSON_API_V1NONEz-//pubsub.googleapis.com/projects/{}/topics/{}z)(?P[a-z][a-z0-9-]{4,28}[a-z0-9])z (?P[A-Za-z](\w|[-_.~+%])+)zpResource has invalid topic: {}; see https://cloud.google.com/storage/docs/json_api/v1/notifications/insert#topicc:eZdZdZdddddedfdZedZedZ edZ edZ edZ ed Z ed Zed Zed Zed ZedZedZedZdZdZdedfdZdeefdZdeefdZdeefdZy)BucketNotificationaRepresent a single notification resource for a bucket. See: https://cloud.google.com/storage/docs/json_api/v1/notifications :type bucket: :class:`google.cloud.storage.bucket.Bucket` :param bucket: Bucket to which the notification is bound. :type topic_name: str :param topic_name: (Optional) Topic name to which notifications are published. :type topic_project: str :param topic_project: (Optional) Project ID of topic to which notifications are published. If not passed, uses the project ID of the bucket's client. :type custom_attributes: dict :param custom_attributes: (Optional) Additional attributes passed with notification events. :type event_types: list(str) :param event_types: (Optional) Event types for which notification events are published. :type blob_name_prefix: str :param blob_name_prefix: (Optional) Prefix of blob names for which notification events are published. :type payload_format: str :param payload_format: (Optional) Format of payload for notification events. :type notification_id: str :param notification_id: (Optional) The ID of the notification. Nc ,||_||_||jj}| t d||_i|_|||j d<|||j d<|||j d<|||j d<||j d<y)Nz8Client project not set: pass an explicit topic_project.custom_attributes event_typesobject_name_prefixidpayload_format)_bucket _topic_nameclientproject ValueError_topic_project _properties) selfbucket topic_name topic_projectrrblob_name_prefixrnotification_ids u/home/panchajanya/Development/work/volatility3/venv/lib/python3.12/site-packages/google/cloud/storage/notification.py__init__zBucketNotification.__init__Ws %  "MM11M  WX X+  (4ED  0 1  ".9D  ] +  '5ED  1 2  &%4D  T "-;)*c|jd}| tdt|\}}||||}||_|S)aConstruct an instance from the JSON repr returned by the server. See: https://cloud.google.com/storage/docs/json_api/v1/notifications :type resource: dict :param resource: JSON repr of the notification :type bucket: :class:`google.cloud.storage.bucket.Bucket` :param bucket: Bucket to which the notification is bound. :rtype: :class:`BucketNotification` :returns: the new notification instance topiczResource has no topic)r)getr_parse_topic_pathr)clsresourcer topic_pathnamerinstances r! from_api_reprz BucketNotification.from_api_repr}sM\\'*  45 5)*5 gvt7;'r#c|jS)z*Bucket to which the notification is bound.)rrs r!rzBucketNotification.buckets||r#c|jS)z0Topic name to which notifications are published.)rr/s r!rzBucketNotification.topic_namesr#c|jS)z9Project ID of topic to which notifications are published.)rr/s r!rz BucketNotification.topic_projects"""r#c8|jjdS)z2Custom attributes passed with notification events.rrr&r/s r!rz$BucketNotification.custom_attributess##$788r#c8|jjdS)z8Event types for which notification events are published.rr3r/s r!rzBucketNotification.event_typess##M22r#c8|jjdS)zAPrefix of blob names for which notification events are published.rr3r/s r!rz#BucketNotification.blob_name_prefixs##$899r#c8|jjdS)z)Format of payload of notification events.rr3r/s r!rz!BucketNotification.payload_formats##$455r#c8|jjdS)z'Server-set ID of notification resource.rr3r/s r!r z"BucketNotification.notification_ids##D))r#c8|jjdS))Server-set ETag of notification resource.etagr3r/s r!r:zBucketNotification.etags##F++r#c8|jjdS)r9selfLinkr3r/s r! self_linkzBucketNotification.self_links##J//r#c.|jjS)z%The client bound to this notfication.)rrr/s r!rzBucketNotification.clients{{!!!r#cNd|jjd|jS)z#The URL path for this notification./b/z/notificationConfigs/)rr+r r/s r!pathzBucketNotification.paths*T[[%%&&;D[[F r#cn|jj|jj|y)zwHelper for :meth:`reload`. :type response: dict :param response: resource mapping from server N)rclearupdate)rresponses r!_set_propertiesz"BucketNotification._set_propertiess*   )r#c(|jtd|j|j|}i}|jj|jj|d<d|jj d}|j j}|j$tj|jd|d<n-tj|j|j|d<|j||||||_y) aAPI wrapper: create the notification. See: https://cloud.google.com/storage/docs/json_api/v1/notifications/insert If :attr:`user_project` is set on the bucket, bills the API request to that project. :type client: :class:`~google.cloud.storage.client.Client` :param client: (Optional) The client to use. If not passed, falls back to the ``client`` stored on the notification's bucket. :type timeout: float or tuple :param timeout: (Optional) The amount of time, in seconds, to wait for the server response. See: :ref:`configuring_timeouts` :type retry: google.api_core.retry.Retry or google.cloud.storage.retry.ConditionalRetryPolicy :param retry: (Optional) How to retry the RPC. See: :ref:`configuring_retries` :raises ValueError: if the notification already exists. Nz#Notification already exists w/ id: userProjectr@z/notificationConfigsr% query_paramstimeoutretry) r rrCr user_projectr+rcopyr_TOPIC_REF_FMTformatr_post_resource)rrrNrOrMrA propertiess r!createzBucketNotification.creates .    +5d6J6J5KL %%f- ;; # # /*.++*B*BL 'T[[%%&&:;%%**, ?? ""0"7"78J8JB"OJw "0"7"7""DOO#Jw "00  % 1 r#c|j td|j|}i}|jj|jj|d< |j |j |||y#t$rYywxYw)aTest whether this notification exists. See: https://cloud.google.com/storage/docs/json_api/v1/notifications/get If :attr:`user_project` is set on the bucket, bills the API request to that project. :type client: :class:`~google.cloud.storage.client.Client` or ``NoneType`` :param client: (Optional) The client to use. If not passed, falls back to the ``client`` stored on the current bucket. :type timeout: float or tuple :param timeout: (Optional) The amount of time, in seconds, to wait for the server response. See: :ref:`configuring_timeouts` :type retry: google.api_core.retry.Retry or google.cloud.storage.retry.ConditionalRetryPolicy :param retry: (Optional) How to retry the RPC. See: :ref:`configuring_retries` :rtype: bool :returns: True, if the notification exists, else False. :raises ValueError: if the notification has no ID. 8Notification ID not set: set an explicit notification_idrJrLTF)r rrCrrP _get_resourcerArrrrNrOrMs r!existszBucketNotification.existss4    'WX X%%f- ;; # # /*.++*B*BL '    ) !   sA;; BBc|j td|j|}i}|jj|jj|d<|j |j |||}|j|y)aUpdate this notification from the server configuration. See: https://cloud.google.com/storage/docs/json_api/v1/notifications/get If :attr:`user_project` is set on the bucket, bills the API request to that project. :type client: :class:`~google.cloud.storage.client.Client` or ``NoneType`` :param client: (Optional) The client to use. If not passed, falls back to the ``client`` stored on the current bucket. :type timeout: float or tuple :param timeout: (Optional) The amount of time, in seconds, to wait for the server response. See: :ref:`configuring_timeouts` :type retry: google.api_core.retry.Retry or google.cloud.storage.retry.ConditionalRetryPolicy :param retry: (Optional) How to retry the RPC. See: :ref:`configuring_retries` :raises ValueError: if the notification has no ID. NrXrJrL)r rrCrrPrYrArH)rrrNrOrMrGs r!reloadzBucketNotification.reloadLs2    'WX X%%f- ;; # # /*.++*B*BL ''' II% (  X&r#c|j td|j|}i}|jj|jj|d<|j |j |||y)aDelete this notification. See: https://cloud.google.com/storage/docs/json_api/v1/notifications/delete If :attr:`user_project` is set on the bucket, bills the API request to that project. :type client: :class:`~google.cloud.storage.client.Client` or ``NoneType`` :param client: (Optional) The client to use. If not passed, falls back to the ``client`` stored on the current bucket. :type timeout: float or tuple :param timeout: (Optional) The amount of time, in seconds, to wait for the server response. See: :ref:`configuring_timeouts` :type retry: google.api_core.retry.Retry or google.cloud.storage.retry.ConditionalRetryPolicy :param retry: (Optional) How to retry the RPC. See: :ref:`configuring_retries` :raises: :class:`google.api_core.exceptions.NotFound`: if the notification does not exist. :raises ValueError: if the notification has no ID. NrXrJrL)r rrCrrP_delete_resourcerArZs r!deletezBucketNotification.deletevsx4    'WX X%%f- ;; # # /*.++*B*BL ' II%  r#)__name__ __module__ __qualname____doc__NONE_PAYLOAD_FORMATr" classmethodr-propertyrrrrrrrr r:r=rrArCrHrrVrr[r]r`r#r!r r 0st$R*$r|s  /;4/$<!*,*@?9#**+;=PQ -. ! n n b 7r#