h?dZddlZddlmZddlmZddlmZddlm Z dZ dZ d Z d Z d Zd Zd ZdZdZeeeZejeZdZGddeZdZdS)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)create_trace_span)_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#topicceZdZdZdddddedfdZedZedZ edZ edZ edZ ed Z ed Zed Zed Zed ZedZedZedZdZdZdedfdZdeefdZdeefdZdeefdZdS)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|_| ||jd<| ||jd<| ||jd<| ||jd<||jd<dS)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 e/var/www/html/e360mart/e360mart_env/lib/python3.11/site-packages/google/cloud/storage/notification.py__init__zBucketNotification.__init__Xs %  "M1M  WXX X+  (4ED 0 1  ".9D ] +  '5ED 1 2  &%4D T "-;)***c|d}|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 topicNzResource has no topic)r)getr_parse_topic_pathr)clsresourcer topic_pathnamerinstances r" from_api_reprz BucketNotification.from_api_repr~s^\\'**  455 5)*55 g3vt7;;;'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.)rr0s r"rzBucketNotification.topic_names r$c|jS)z9Project ID of topic to which notifications are published.)rr0s r"rz BucketNotification.topic_projects ""r$c6|jdS)z2Custom attributes passed with notification events.rrr'r0s r"rz$BucketNotification.custom_attributess##$7888r$c6|jdS)z8Event types for which notification events are published.rr4r0s r"rzBucketNotification.event_typess##M222r$c6|jdS)zAPrefix of blob names for which notification events are published.rr4r0s r"r z#BucketNotification.blob_name_prefixs##$8999r$c6|jdS)z)Format of payload of notification events.rr4r0s r"rz!BucketNotification.payload_formats##$4555r$c6|jdS)z'Server-set ID of notification resource.rr4r0s r"r!z"BucketNotification.notification_ids##D)))r$c6|jdS))Server-set ETag of notification resource.etagr4r0s r"r;zBucketNotification.etags##F+++r$c6|jdS)r:selfLinkr4r0s r" self_linkzBucketNotification.self_links##J///r$c|jjS)z%The client bound to this notfication.)rrr0s r"rzBucketNotification.clients{!!r$c0d|jjd|jS)z#The URL path for this notification./b/z/notificationConfigs/)rr,r!r0s r"pathzBucketNotification.paths#ST[%RRD[F r$cl|j|j|dS)zwHelper for :meth:`reload`. :type response: dict :param response: resource mapping from server N)rclearupdate)rresponses r"_set_propertiesz"BucketNotification._set_propertiess6     )))))r$c0td5|jtd|jd||}i}|jj|jj|d<d|jjd}|j}|j $t |j d |d <n(t |j |j |d <| ||||| |_ddddS#1swxYwYdS) 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. z!Storage.BucketNotification.creater,Nznotification_id already set to z(; must be None to create a Notification. userProjectrAz/notificationConfigsr& query_paramstimeoutretry)rr!rrDr user_projectr,rcopyr_TOPIC_REF_FMTformatr_post_resource)rrrPrQrOrB propertiess r"createzBucketNotification.creates~.$G H H H  #/ td6Jttt))&11FL{'3.2k.F ]+?)???D)..00J&&4&;&;DrrBrDrIrrXrr]r_rbr$r"rr1sF$$R*$<$<$<$rs  //////IIIIII;;;;;;444444/$<!*,*@?9#**+;=PQQ -.. ! xxxxxxxxv 77777r$