U $FZh?@sdZddlZddlmZddlmZddlmZddlm Z dZ dZ d Z d Z d Zd Zd ZdZdZeeeZeeZdZGdddeZddZdS)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_RETRYZOBJECT_FINALIZEZOBJECT_METADATA_UPDATEZ OBJECT_DELETEZOBJECT_ARCHIVEZ 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@seZdZdZdddddedfddZeddZeddZ ed d Z ed d Z ed dZ eddZ eddZeddZeddZeddZeddZeddZeddZdd Zd!d"Zdedfd#d$Zdeefd%d&Zdeefd'd(Zdeefd)d*ZdS)+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 Cs||_||_|dkr|jj}|dkr,td||_i|_|dk rJ||jd<|dk r\||jd<|dk rn||jd<|dk r||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_projectrr blob_name_prefixr notification_idrh/home/aprabhat/apps/x.techxrdev.in/venv/lib/python3.8/site-packages/google/cloud/storage/notification.py__init__Xs"     zBucketNotification.__init__cCs>|d}|dkrtdt|\}}||||d}||_|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_pathnamerinstancerrr from_api_repr~s  z BucketNotification.from_api_reprcCs|jS)z*Bucket to which the notification is bound.)r rrrrrszBucketNotification.bucketcCs|jS)z0Topic name to which notifications are published.)rr&rrrrszBucketNotification.topic_namecCs|jS)z9Project ID of topic to which notifications are published.)rr&rrrrsz BucketNotification.topic_projectcCs |jdS)z2Custom attributes passed with notification events.rrrr&rrrrsz$BucketNotification.custom_attributescCs |jdS)z8Event types for which notification events are published.r r'r&rrrr szBucketNotification.event_typescCs |jdS)zAPrefix of blob names for which notification events are published.r r'r&rrrrsz#BucketNotification.blob_name_prefixcCs |jdS)z)Format of payload of notification events.r r'r&rrrr sz!BucketNotification.payload_formatcCs |jdS)z'Server-set ID of notification resource.r r'r&rrrrsz"BucketNotification.notification_idcCs |jdS))Server-set ETag of notification resource.etagr'r&rrrr)szBucketNotification.etagcCs |jdS)r(ZselfLinkr'r&rrr self_linkszBucketNotification.self_linkcCs|jjS)z%The client bound to this notfication.)rrr&rrrrszBucketNotification.clientcCsd|jjd|jS)z#The URL path for this notification./b/z/notificationConfigs/)rr#rr&rrrpathszBucketNotification.pathcCs|dkr|j}|S)a:Check client or verify over-ride. :type client: :class:`~google.cloud.storage.client.Client` or ``NoneType`` :param client: the client to use. :rtype: :class:`google.cloud.storage.client.Client` :returns: The client passed in or the bucket's client. N)r)rrrrr_require_clients z"BucketNotification._require_clientcCs|j|j|dS)zwHelper for :meth:`reload`. :type response: dict :param response: resource mapping from server N)rclearupdate)rresponserrr_set_propertiess z"BucketNotification._set_propertiesc Cstdd|jdk r(td|jd||}i}|jjdk rN|jj|d<d|jjd}|j}|j dkrt |j d |d <nt |j |j |d <|j |||||d |_W5QRXdS) 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. userProjectr+z/notificationConfigsr query_paramstimeoutretry)rrrr-r user_projectr#rcopyr_TOPIC_REF_FMTformatrZ_post_resource)rrr7r8r6r, propertiesrrrcreates0        zBucketNotification.createc Cstdd|jdkrtd||}i}|jjdk rD|jj|d<z|j|j|||dWn tk r|YW5QRdSXW5QRdSW5QRXdS) 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. z!Storage.BucketNotification.existsr2N8Notification ID not set: set an explicit notification_idr3r5FT) rrrr-rr9 _get_resourcer,rrrr7r8r6rrrexistss&      zBucketNotification.existsc Csptdd\|jdkrtd||}i}|jjdk rD|jj|d<|j|j|||d}||W5QRXdS)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. z!Storage.BucketNotification.reloadr2Nr?r3r5) rrrr-rr9r@r,r1)rrr7r8r6r0rrrreloadQs      zBucketNotification.reloadc CsftddR|jdkrtd||}i}|jjdk rD|jj|d<|j|j|||dW5QRXdS)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. z!Storage.BucketNotification.deleter2Nr?r3r5)rrrr-rr9Z_delete_resourcer,rArrrdelete~s     zBucketNotification.delete)__name__ __module__ __qualname____doc__NONE_PAYLOAD_FORMATr classmethodr%propertyrrrrr rr rr)r*rr,r-r1rr>rrBrCrDrrrrr1sR) &              52-rcCs4t|}|dkr tt||d|dfS)aVerify that a topic path is in the correct format. Expected to be of the form: //pubsub.googleapis.com/projects/{project}/topics/{topic} where the ``project`` value must be "6 to 30 lowercase letters, digits, or hyphens. It must start with a letter. Trailing hyphens are prohibited." (see [`resource manager docs`](https://cloud.google.com/resource-manager/reference/rest/v1beta1/projects#Project.FIELDS.project_id)) and ``topic`` must have length at least two, must start with a letter and may only contain alphanumeric characters or ``-``, ``_``, ``.``, ``~``, ``+`` or ``%`` (i.e characters used for URL encoding, see [`topic spec`](https://cloud.google.com/storage/docs/json_api/v1/notifications/insert#topic)). Args: topic_path (str): The topic path to be verified. Returns: Tuple[str, str]: The ``project`` and ``topic`` parsed from the ``topic_path``. Raises: ValueError: If the topic path is invalid. Nr#r) _TOPIC_REF_REmatchr _BAD_TOPICr<group)r"rMrrrrs r)rHreZgoogle.api_core.exceptionsrZ+google.cloud.storage._opentelemetry_tracingrZgoogle.cloud.storage.constantsrZgoogle.cloud.storage.retryrZOBJECT_FINALIZE_EVENT_TYPEZ!OBJECT_METADATA_UPDATE_EVENT_TYPEZOBJECT_DELETE_EVENT_TYPEZOBJECT_ARCHIVE_EVENT_TYPEZJSON_API_V1_PAYLOAD_FORMATrIr;Z_PROJECT_PATTERNZ_TOPIC_NAME_PATTERNr<Z_TOPIC_REF_PATTERNcompilerLrNobjectrrrrrrs,      }