a !f*@s|dZddlmZddlmZddlmZddlmZddl m Z ddl m Z ddl mZGd d d eZGd d d eZd S)z9Client for interacting with the Google Cloud Storage API.) _LocalStack) JSONClient)NotFound)IteratorBatchBucket) ConnectioncseZdZdZeZdfdd ZeddZej ddZdd Z d d Z ed d Z ddZ ddZddZddZddZdddZZS)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. Ncs(d|_tt|j|||dt|_dS)N)project credentialshttp) _connectionsuperr __init__r _batch_stack)selfr r r __class__V/var/www/html/python-backend/venv/lib/python3.9/site-packages/gcloud/storage/client.pyr2s zClient.__init__cCs|jdur|jS|jSdS)zGet connection or batch on the client. :rtype: :class:`gcloud.storage.connection.Connection` :returns: The connection set on the client, or the batch if one is set. N) current_batchrrrrr connection8s zClient.connectioncCs|jdurtd||_dS)aSet connection on the client. Intended to be used by constructor (since the base class calls) self.connection = connection Will raise if the connection is set more than once. :type value: :class:`gcloud.storage.connection.Connection` :param value: The connection set on the client. :raises: :class:`ValueError` if connection has already been set. Nz Connection already set on client)r ValueError)rvaluerrrrEs cCs|j|dS)zPush a batch onto our stack. "Protected", intended for use by batch context mgrs. :type batch: :class:`gcloud.storage.batch.Batch` :param batch: newly-active batch N)rpush)rbatchrrr _push_batchVszClient._push_batchcCs |jS)aPop a batch from our stack. "Protected", intended for use by batch context mgrs. :raises: IndexError if the stack is empty. :rtype: :class:`gcloud.storage.batch.Batch` :returns: the top-most batch/transaction, after removing it. )rpoprrrr _pop_batch`s zClient._pop_batchcCs|jjS)zCurrently-active batch. :rtype: :class:`gcloud.storage.batch.Batch` or ``NoneType`` (if no batch is active). :returns: The batch at the top of the batch stack. )rtoprrrrrkszClient.current_batchcCs t||dS)aFactory constructor for bucket object. .. note:: This will not make an HTTP request; it simply instantiates a bucket object owned by this client. :type bucket_name: string :param bucket_name: The name of the bucket to be instantiated. :rtype: :class:`gcloud.storage.bucket.Bucket` :returns: The bucket object created. )clientnamerr bucket_namerrrbucketus z Client.bucketcCs t|dS)aFactory constructor for batch object. .. note:: This will not make an HTTP request; it simply instantiates a batch object owned by this client. :rtype: :class:`gcloud.storage.batch.Batch` :returns: The batch object created. r#rrrrrrs z Client.batchcCst||d}|j|d|S)aGet a bucket by name. If the bucket isn't found, this will raise a :class:`gcloud.storage.exceptions.NotFound`. For example:: >>> try: >>> bucket = client.get_bucket('my-bucket') >>> except gcloud.exceptions.NotFound: >>> print 'Sorry, that bucket does not exist!' This implements "storage.buckets.get". :type bucket_name: string :param bucket_name: The name of the bucket to get. :rtype: :class:`gcloud.storage.bucket.Bucket` :returns: The bucket matching the name provided. :raises: :class:`gcloud.exceptions.NotFound` r$r()r reloadrr&r'rrr get_buckets  zClient.get_bucketcCs&z ||WSty YdS0dS)aaGet a bucket by name, returning None if not found. You can use this if you would rather check for a None value than catching an exception:: >>> bucket = client.lookup_bucket('doesnt-exist') >>> print bucket None >>> bucket = client.lookup_bucket('my-bucket') >>> print bucket :type bucket_name: string :param bucket_name: The name of the bucket to get. :rtype: :class:`gcloud.storage.bucket.Bucket` :returns: The bucket matching the name provided or None if not found. N)r,rr%rrr lookup_buckets  zClient.lookup_bucketcCst||d}|j|d|S)aCreate a new bucket. For example:: >>> bucket = client.create_bucket('my-bucket') >>> print bucket This implements "storage.buckets.insert". If the bucket already exists, will raise :class:`gcloud.exceptions.Conflict`. :type bucket_name: string :param bucket_name: The bucket name to create. :rtype: :class:`gcloud.storage.bucket.Bucket` :returns: The newly created bucket. r)r()r creater+rrr create_buckets  zClient.create_bucketnoAclcCs`d|ji}|dur||d<|dur*||d<||d<|durB||d<t||d}|dur\||_|S)aGet all buckets in the project associated to the client. This will not populate the list of blobs available in each bucket. >>> for bucket in client.list_buckets(): >>> print bucket This implements "storage.buckets.list". :type max_results: integer or ``NoneType`` :param max_results: Optional. Maximum number of buckets to return. :type page_token: string or ``NoneType`` :param page_token: Optional. Opaque marker for the next "page" of buckets. If not passed, will return the first page of buckets. :type prefix: string or ``NoneType`` :param prefix: Optional. Filter results to buckets whose names begin with this prefix. :type projection: string or ``NoneType`` :param projection: If used, must be 'full' or 'noAcl'. Defaults to 'noAcl'. Specifies the set of properties to return. :type fields: string or ``NoneType`` :param fields: Selector specifying which fields to include in a partial response. Must be a list of fields. For example to get a partial response with just the next page token and the language of each bucket returned: 'items/id,nextPageToken' :rtype: iterable of :class:`gcloud.storage.bucket.Bucket` objects. :returns: All buckets belonging to this project. r NZ maxResultsprefix projectionfields)r# extra_params)r _BucketIteratorZnext_page_token)rZ max_resultsZ page_tokenr1r2r3r4resultrrr list_bucketss& zClient.list_buckets)NNN)NNNr0N)__name__ __module__ __qualname____doc__r Z_connection_classrpropertyrsetterrr!rr'rr,r-r/r7 __classcell__rrrrr s&      r cs*eZdZdZdfdd ZddZZS)r5aAn iterator listing all buckets. You shouldn't have to use this directly, but instead should use the helper methods on :class:`gcloud.storage.connection.Connection` objects. :type client: :class:`gcloud.storage.client.Client` :param client: The client to use for making connections. :type extra_params: dict or ``NoneType`` :param extra_params: Extra query string parameters for the API call. Ncstt|j|d|ddS)Nz/b)r#pathr4)rr5r)rr#r4rrrr$sz_BucketIterator.__init__ccs<|dgD]*}|d}t|j|}|||Vq dS)zFactory method which yields :class:`.Bucket` items from a response. :type response: dict :param response: The JSON API response for a page of buckets. itemsr$N)getr r#Z_set_properties)rresponseitemr$r'rrrget_items_from_response(s    z'_BucketIterator.get_items_from_response)N)r8r9r:r;rrDr>rrrrr5s r5N)r;Zgcloud._helpersrZ gcloud.clientrZgcloud.exceptionsrZgcloud.iteratorrZgcloud.storage.batchrZgcloud.storage.bucketr Zgcloud.storage.connectionr r r5rrrrs       |