a !f@sdZddlZddlmZddlmZddlmZddlmZ ddlm Z ddl m Z dd l mZz4dd lmZdd lmZddlmZddlmZWn&eyd ZdZZdZZYn0d ZeoejdduZGdddeZdS)z9Client for interacting with the Google Cloud Pub/Sub API.N) JSONClient) Connection) _PublisherAPI)_SubscriberAPI) _IAMPolicyAPI) SubscriptionTopic) PublisherApi) SubscriberApiFTZGCLOUD_ENABLE_GAXc@sbeZdZdZeZdZZZe ddZ e ddZ e ddZ dd d Z dd d ZdddZdS)ClientaClient to bundle configuration needed for API requests. :type project: string :param project: the project which the client acts on behalf of. Will be passed when creating a topic. If not passed, falls back to the default inferred from the environment. :type credentials: :class:`oauth2client.client.OAuth2Credentials` or :class:`NoneType` :param credentials: The OAuth2 Credentials to use for the connection owned by this client. If not passed (and if no ``http`` object is passed), falls back to the default inferred from the environment. :type http: :class:`httplib2.Http` or class that defines ``request()``. :param http: An optional HTTP object to make requests. If not passed, an ``http`` object is created that is bound to the ``credentials`` for the current object. NcCs2|jdur,tr t}t||_n t|j|_|jS)z'Helper for publisher-related API calls.N)_publisher_api_USE_GAXGeneratedPublisherAPIGAXPublisherAPIJSONPublisherAPI connectionself generatedrU/var/www/html/python-backend/venv/lib/python3.9/site-packages/gcloud/pubsub/client.py publisher_apiGs    zClient.publisher_apicCs2|jdur,tr t}t||_n t|j|_|jS)z(Helper for subscriber-related API calls.N)_subscriber_apirGeneratedSubscriberAPIGAXSubscriberAPIJSONSubscriberAPIrrrrrsubscriber_apiRs    zClient.subscriber_apicCs|jdurt|j|_|jS)z(Helper for IAM policy-related API calls.N)_iam_policy_apirrrrrriam_policy_api]s  zClient.iam_policy_apics4j}|j||\}}fdd|D}||fS)aList topics for the project associated with this client. See: https://cloud.google.com/pubsub/reference/rest/v1/projects.topics/list Example: .. literalinclude:: pubsub_snippets.py :start-after: [START client_list_topics] :end-before: [END client_list_topics] :type page_size: int :param page_size: maximum number of topics to return, If not passed, defaults to a value set by the API. :type page_token: string :param page_token: opaque marker for the next "page" of topics. If not passed, the API will return the first page of topics. :rtype: tuple, (list, str) :returns: list of :class:`gcloud.pubsub.topic.Topic`, plus a "next page token" string: if not None, indicates that more topics can be retrieved with another call (pass that value as ``page_token``). csg|]}t|qSr)r from_api_repr.0resourcerrr sz&Client.list_topics..)r list_topicsproject)r page_size page_tokenapi resources next_tokentopicsrrrr&ds zClient.list_topicscs:j}|j||\}}ifdd|D}||fS)aList subscriptions for the project associated with this client. See: https://cloud.google.com/pubsub/reference/rest/v1/projects.topics/list Example: .. literalinclude:: pubsub_snippets.py :start-after: [START client_list_subscriptions] :end-before: [END client_list_subscriptions] :type page_size: int :param page_size: maximum number of topics to return, If not passed, defaults to a value set by the API. :type page_token: string :param page_token: opaque marker for the next "page" of topics. If not passed, the API will return the first page of topics. :rtype: tuple, (list, str) :returns: list of :class:`gcloud.pubsub.subscription.Subscription`, plus a "next page token" string: if not None, indicates that more topics can be retrieved with another call (pass that value as ``page_token``). csg|]}tj|dqS))r-)rr!r"rr-rrr%sz-Client.list_subscriptions..)rlist_subscriptionsr')rr(r)r*r+r,Z subscriptionsrr.rr/s zClient.list_subscriptionsFcCst|||dS)a Creates a topic bound to the current client. Example: .. literalinclude:: pubsub_snippets.py :start-after: [START client_topic] :end-before: [END client_topic] :type name: string :param name: the name of the topic to be constructed. :type timestamp_messages: boolean :param timestamp_messages: To be passed to ``Topic`` constructor. :rtype: :class:`gcloud.pubsub.topic.Topic` :returns: Topic created with the current client. )clienttimestamp_messagesr)rnamer1rrrtopicsz Client.topic)NN)NN)F)__name__ __module__ __qualname____doc__rZ_connection_classr rrpropertyrrr r&r/r3rrrrr /s     " $r )r7osZ gcloud.clientrZgcloud.pubsub.connectionrrrrrrZgcloud.pubsub.subscriptionrZgcloud.pubsub.topicr Z$google.cloud.pubsub.v1.publisher_apir rZ%google.cloud.pubsub.v1.subscriber_apir rZgcloud.pubsub._gaxrr ImportErrorZ _HAVE_GAXenvirongetrr rrrrs(