Upgrade gsutil to 3.4

third_party/gsutil/20110627/boto/boto/cloudfront/__init__.py

Index: third_party/gsutil/20110627/boto/boto/cloudfront/__init__.py
diff --git a/third_party/gsutil/20110627/boto/boto/cloudfront/__init__.py b/third_party/gsutil/20110627/boto/boto/cloudfront/__init__.py
deleted file mode 100644
index 74ac0ce3e01abb0a53d871f3fee533d8fef6dc0b..0000000000000000000000000000000000000000
--- a/third_party/gsutil/20110627/boto/boto/cloudfront/__init__.py
+++ /dev/null
@@ -1,261 +0,0 @@
-# Copyright (c) 2006-2009 Mitch Garnaat http://garnaat.org/
-#
-# Permission is hereby granted, free of charge, to any person obtaining a
-# copy of this software and associated documentation files (the
-# "Software"), to deal in the Software without restriction, including
-# without limitation the rights to use, copy, modify, merge, publish, dis-
-# tribute, sublicense, and/or sell copies of the Software, and to permit
-# persons to whom the Software is furnished to do so, subject to the fol-
-# lowing conditions:
-#
-# The above copyright notice and this permission notice shall be included
-# in all copies or substantial portions of the Software.
-#
-# THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
-# OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABIL-
-# ITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT
-# SHALL THE AUTHOR BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, 
-# WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
-# OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
-# IN THE SOFTWARE.
-#
-
-import xml.sax
-import time
-import boto
-from boto.connection import AWSAuthConnection
-from boto import handler
-from boto.cloudfront.distribution import Distribution, DistributionSummary, DistributionConfig
-from boto.cloudfront.distribution import StreamingDistribution, StreamingDistributionSummary, StreamingDistributionConfig
-from boto.cloudfront.identity import OriginAccessIdentity
-from boto.cloudfront.identity import OriginAccessIdentitySummary
-from boto.cloudfront.identity import OriginAccessIdentityConfig
-from boto.cloudfront.invalidation import InvalidationBatch
-from boto.resultset import ResultSet
-from boto.cloudfront.exception import CloudFrontServerError
-
-class CloudFrontConnection(AWSAuthConnection):
-
-    DefaultHost = 'cloudfront.amazonaws.com'
-    Version = '2010-11-01'
-
-    def __init__(self, aws_access_key_id=None, aws_secret_access_key=None,
-                 port=None, proxy=None, proxy_port=None,
-                 host=DefaultHost, debug=0):
-        AWSAuthConnection.__init__(self, host,
-                aws_access_key_id, aws_secret_access_key,
-                True, port, proxy, proxy_port, debug=debug)
-
-    def get_etag(self, response):
-        response_headers = response.msg
-        for key in response_headers.keys():
-            if key.lower() == 'etag':
-                return response_headers[key]
-        return None
-
-    def _required_auth_capability(self):
-        return ['cloudfront']
-
-    # Generics
-    
-    def _get_all_objects(self, resource, tags):
-        if not tags:
-            tags=[('DistributionSummary', DistributionSummary)]
-        response = self.make_request('GET', '/%s/%s' % (self.Version, resource))
-        body = response.read()
-        boto.log.debug(body)
-        if response.status >= 300:
-            raise CloudFrontServerError(response.status, response.reason, body)
-        rs = ResultSet(tags)
-        h = handler.XmlHandler(rs, self)
-        xml.sax.parseString(body, h)
-        return rs
-
-    def _get_info(self, id, resource, dist_class):
-        uri = '/%s/%s/%s' % (self.Version, resource, id)
-        response = self.make_request('GET', uri)
-        body = response.read()
-        boto.log.debug(body)
-        if response.status >= 300:
-            raise CloudFrontServerError(response.status, response.reason, body)
-        d = dist_class(connection=self)
-        response_headers = response.msg
-        for key in response_headers.keys():
-            if key.lower() == 'etag':
-                d.etag = response_headers[key]
-        h = handler.XmlHandler(d, self)
-        xml.sax.parseString(body, h)
-        return d
-
-    def _get_config(self, id, resource, config_class):
-        uri = '/%s/%s/%s/config' % (self.Version, resource, id)
-        response = self.make_request('GET', uri)
-        body = response.read()
-        boto.log.debug(body)
-        if response.status >= 300:
-            raise CloudFrontServerError(response.status, response.reason, body)
-        d = config_class(connection=self)
-        d.etag = self.get_etag(response)
-        h = handler.XmlHandler(d, self)
-        xml.sax.parseString(body, h)
-        return d
-    
-    def _set_config(self, distribution_id, etag, config):
-        if isinstance(config, StreamingDistributionConfig):
-            resource = 'streaming-distribution'
-        else:
-            resource = 'distribution'
-        uri = '/%s/%s/%s/config' % (self.Version, resource, distribution_id)
-        headers = {'If-Match' : etag, 'Content-Type' : 'text/xml'}
-        response = self.make_request('PUT', uri, headers, config.to_xml())
-        body = response.read()
-        boto.log.debug(body)
-        if response.status != 200:
-            raise CloudFrontServerError(response.status, response.reason, body)
-        return self.get_etag(response)
-    
-    def _create_object(self, config, resource, dist_class):
-        response = self.make_request('POST', '/%s/%s' % (self.Version, resource),
-                                     {'Content-Type' : 'text/xml'}, data=config.to_xml())
-        body = response.read()
-        boto.log.debug(body)
-        if response.status == 201:
-            d = dist_class(connection=self)
-            h = handler.XmlHandler(d, self)
-            xml.sax.parseString(body, h)
-            d.etag = self.get_etag(response)
-            return d
-        else:
-            raise CloudFrontServerError(response.status, response.reason, body)
-        
-    def _delete_object(self, id, etag, resource):
-        uri = '/%s/%s/%s' % (self.Version, resource, id)
-        response = self.make_request('DELETE', uri, {'If-Match' : etag})
-        body = response.read()
-        boto.log.debug(body)
-        if response.status != 204:
-            raise CloudFrontServerError(response.status, response.reason, body)
-
-    # Distributions
-        
-    def get_all_distributions(self):
-        tags=[('DistributionSummary', DistributionSummary)]
-        return self._get_all_objects('distribution', tags)
-
-    def get_distribution_info(self, distribution_id):
-        return self._get_info(distribution_id, 'distribution', Distribution)
-
-    def get_distribution_config(self, distribution_id):
-        return self._get_config(distribution_id, 'distribution',
-                                DistributionConfig)
-    
-    def set_distribution_config(self, distribution_id, etag, config):
-        return self._set_config(distribution_id, etag, config)
-    
-    def create_distribution(self, origin, enabled, caller_reference='',
-                            cnames=None, comment=''):
-        config = DistributionConfig(origin=origin, enabled=enabled,
-                                    caller_reference=caller_reference,
-                                    cnames=cnames, comment=comment)
-        return self._create_object(config, 'distribution', Distribution)
-        
-    def delete_distribution(self, distribution_id, etag):
-        return self._delete_object(distribution_id, etag, 'distribution')
-
-    # Streaming Distributions
-        
-    def get_all_streaming_distributions(self):
-        tags=[('StreamingDistributionSummary', StreamingDistributionSummary)]
-        return self._get_all_objects('streaming-distribution', tags)
-
-    def get_streaming_distribution_info(self, distribution_id):
-        return self._get_info(distribution_id, 'streaming-distribution',
-                              StreamingDistribution)
-
-    def get_streaming_distribution_config(self, distribution_id):
-        return self._get_config(distribution_id, 'streaming-distribution',
-                                StreamingDistributionConfig)
-    
-    def set_streaming_distribution_config(self, distribution_id, etag, config):
-        return self._set_config(distribution_id, etag, config)
-    
-    def create_streaming_distribution(self, origin, enabled,
-                                      caller_reference='',
-                                      cnames=None, comment=''):
-        config = StreamingDistributionConfig(origin=origin, enabled=enabled,
-                                             caller_reference=caller_reference,
-                                             cnames=cnames, comment=comment)
-        return self._create_object(config, 'streaming-distribution',
-                                   StreamingDistribution)
-        
-    def delete_streaming_distribution(self, distribution_id, etag):
-        return self._delete_object(distribution_id, etag, 'streaming-distribution')
-
-    # Origin Access Identity
-
-    def get_all_origin_access_identity(self):
-        tags=[('CloudFrontOriginAccessIdentitySummary',
-               OriginAccessIdentitySummary)]
-        return self._get_all_objects('origin-access-identity/cloudfront', tags)
-
-    def get_origin_access_identity_info(self, access_id):
-        return self._get_info(access_id, 'origin-access-identity/cloudfront',
-                              OriginAccessIdentity)
-
-    def get_origin_access_identity_config(self, access_id):
-        return self._get_config(access_id,
-                                'origin-access-identity/cloudfront',
-                                OriginAccessIdentityConfig)
-    
-    def set_origin_access_identity_config(self, access_id,
-                                          etag, config):
-        return self._set_config(access_id, etag, config)
-    
-    def create_origin_access_identity(self, caller_reference='', comment=''):
-        config = OriginAccessIdentityConfig(caller_reference=caller_reference,
-                                            comment=comment)
-        return self._create_object(config, 'origin-access-identity/cloudfront',
-                                   OriginAccessIdentity)
-        
-    def delete_origin_access_identity(self, access_id, etag):
-        return self._delete_object(access_id, etag,
-                                   'origin-access-identity/cloudfront')
-
-    # Object Invalidation
-    
-    def create_invalidation_request(self, distribution_id, paths,
-                                    caller_reference=None):
-        """Creates a new invalidation request
-            :see: http://goo.gl/8vECq
-        """
-        # We allow you to pass in either an array or
-        # an InvalidationBatch object
-        if not isinstance(paths, InvalidationBatch):
-            paths = InvalidationBatch(paths)
-        paths.connection = self
-        uri = '/%s/distribution/%s/invalidation' % (self.Version,
-                                                    distribution_id)
-        response = self.make_request('POST', uri,
-                                     {'Content-Type' : 'text/xml'},
-                                     data=paths.to_xml())
-        body = response.read()
-        if response.status == 201:
-            h = handler.XmlHandler(paths, self)
-            xml.sax.parseString(body, h)
-            return paths
-        else:
-            raise CloudFrontServerError(response.status, response.reason, body)
-
-    def invalidation_request_status (self, distribution_id, request_id, caller_reference=None):
-        uri = '/%s/distribution/%s/invalidation/%s' % (self.Version, distribution_id, request_id )
-        response = self.make_request('GET', uri, {'Content-Type' : 'text/xml'})
-        body = response.read()
-        if response.status == 200:
-            paths = InvalidationBatch([])
-            h = handler.XmlHandler(paths, self)
-            xml.sax.parseString(body, h)
-            return paths
-        else:
-            raise CloudFrontServerError(response.status, response.reason, body)
-
-