dZddlmZddlmZddlmZddlZddlZddlmZddlm Z ddl m Z dd l m Z dd l m Z ejd d d gZdZej"dezZej"dezZdZdZ ddZy)zEUtilities for expanding and matching GCS notification configurations.)absolute_import)division)unicode_literalsN) api_factory) cloud_api)errors) storage_url)wildcard_iteratorNotificationIteratorResult bucket_urlnotification_configurationzC/(?P[^/]+)/notificationConfigs/(?P.+)z/?(projects/[^/]+/)?bucketsz/?bctj|xstj|}|rNtjtj j |jd|jdfSy)z?Extracts bucket StorageUrl and notification_id string from URL. bucket_namenotification_id)NN)+_CANONICAL_NOTIFICATION_CONFIGURATION_REGEXmatch&_JSON_NOTIFICATION_CONFIGURATION_REGEXr CloudUrlProviderPrefixGCSgroup) url_stringrs Mlib/googlecloudsdk/command_lib/storage/notification_configuration_iterator.py+get_bucket_url_and_notification_id_from_urlr-ss277 C?,22:>  !;!;!?!?!&]!; = KK) * ,, c|jtjjur |j s3|j s"t jd|jzyy)z7Raises error if URL is not supported for notifications.zYNotification configurations available on only Google Cloud Storage buckets. Invalid URL: N) schemer rr is_bucket is_providerrInvalidUrlErrorr)urls r*raise_error_if_not_gcs_bucket_matching_urlr"9sZ ** 2266 6 ==?coo/   79< H II0?rc#Ktjtjj}|D]%}t |\}}|r;|st jd|z|j||}t||Otj|}t||jr/tjtjjd}n|}tj|j t"j$j&D]:}|j)|jD]}t|j|<(yw)aYields bucket/notification tuples from command-line args. Given a list of strings that are bucket URLs ("gs://foo") or notification configuration URLs ("b/bucket/notificationConfigs/5"), yield tuples of bucket names and their associated notifications. Args: urls (list[str]): Bucket and notification configuration URLs to pull notification configurations from. accept_notification_configuration_urls (bool): Whether to raise an an error if a notification configuration URL is in `urls`. Yields: NotificationIteratorResult Raises: InvalidUrlError: Received notification configuration URL, but accept_notification_configuration_urls was False. Or received non-GCS bucket URL. z4Received disallowed notification configuration URL: *) fields_scopeN)rget_apir rrrrr get_notification_configurationr storage_url_from_stringr"rrr get_wildcard_iteratorrr FieldsScopeSHORT list_notification_configurations) urls&accept_notification_configuration_urlsclientr!r rr cloud_urlbucket_resources r'get_notification_configuration_iteratorr2Bs>,   {99== >& c3C8 J 3$$ BS HJ J$*#H#H o$' &z3M NN55c:i0;     ))+*D*D*H*H#N  .DD   i.C.C.I.IK/  3 3++ - '+?+F+F+EG G -K)sEE)T)__doc__ __future__rrr collectionsregooglecloudsdk.api_lib.storagerr"googlecloudsdk.command_lib.storagerr r namedtupler &_NOTIFICATION_CONFIGURATION_REGEX_TAILcompilerrrr"r2rrr=sL&' 645:@3[33 <1M"NPJ'.8bjj!$JJ/L+)3 22*4& I262Gr