Merging in latest boto.

boto/cloudfront/__init__.py

 # 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:
 #
@@ skipping 135 matching lines @@
         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=''):
+                            cnames=None, comment='', trusted_signers=None):
         config = DistributionConfig(origin=origin, enabled=enabled,
                                     caller_reference=caller_reference,
-                                    cnames=cnames, comment=comment)
+                                    cnames=cnames, comment=comment,
+                                    trusted_signers=trusted_signers)
         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=''):
+                                      cnames=None, comment='',
+                                      trusted_signers=None):
         config = StreamingDistributionConfig(origin=origin, enabled=enabled,
                                              caller_reference=caller_reference,
-                                             cnames=cnames, comment=comment)
+                                             cnames=cnames, comment=comment,
+                                             trusted_signers=trusted_signers)
         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',
@@ skipping 41 matching lines @@
                                      {'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)
+
+