autopep8

Author: suzaku

gcm/gcm.py

@@ -8,20 +8,54 @@
 GCM_URL = 'https://android.googleapis.com/gcm/send'
 
 
-class GCMException(Exception): pass
-class GCMMalformedJsonException(GCMException): pass
-class GCMConnectionException(GCMException): pass
-class GCMAuthenticationException(GCMException): pass
-class GCMTooManyRegIdsException(GCMException): pass
-class GCMInvalidTtlException(GCMException): pass
+class GCMException(Exception):
+    pass
+
+
+class GCMMalformedJsonException(GCMException):
+    pass
+
+
+class GCMConnectionException(GCMException):
+    pass
+
+
+class GCMAuthenticationException(GCMException):
+    pass
+
+
+class GCMTooManyRegIdsException(GCMException):
+    pass
+
+
+class GCMInvalidTtlException(GCMException):
+    pass
 
 # Exceptions from Google responses
-class GCMMissingRegistrationException(GCMException): pass
-class GCMMismatchSenderIdException(GCMException): pass
-class GCMNotRegisteredException(GCMException): pass
-class GCMMessageTooBigException(GCMException): pass
-class GCMInvalidRegistrationException(GCMException): pass
-class GCMUnavailableException(GCMException): pass
+
+
+class GCMMissingRegistrationException(GCMException):
+    pass
+
+
+class GCMMismatchSenderIdException(GCMException):
+    pass
+
+
+class GCMNotRegisteredException(GCMException):
+    pass
+
+
+class GCMMessageTooBigException(GCMException):
+    pass
+
+
+class GCMInvalidRegistrationException(GCMException):
+    pass
+
+
+class GCMUnavailableException(GCMException):
+    pass
 
 
 # TODO: Refactor this to be more human-readable
@@ -79,12 +113,12 @@ def __init__(self, api_key, url=GCM_URL, proxy=None):
                 proxy = {protocol: proxy}
 
             auth = urllib2.HTTPBasicAuthHandler()
-            opener = urllib2.build_opener(urllib2.ProxyHandler(proxy), auth, urllib2.HTTPHandler)
+            opener = urllib2.build_opener(
+                urllib2.ProxyHandler(proxy), auth, urllib2.HTTPHandler)
             urllib2.install_opener(opener)
 
-
     def construct_payload(self, registration_ids, data=None, collapse_key=None,
-                            delay_while_idle=False, time_to_live=None, is_json=True, dry_run=False):
+                          delay_while_idle=False, time_to_live=None, is_json=True, dry_run=False):
         """
         Construct the dictionary mapping of parameters.
         Encodes the dictionary into JSON if for json requests.
@@ -140,7 +174,8 @@ def make_request(self, data, is_json=True):
         headers = {
             'Authorization': 'key=%s' % self.api_key,
         }
-        # Default Content-Type is defaulted to application/x-www-form-urlencoded;charset=UTF-8
+        # Default Content-Type is defaulted to
+        # application/x-www-form-urlencoded;charset=UTF-8
         if is_json:
             headers['Content-Type'] = 'application/json'
 
@@ -152,16 +187,19 @@ def make_request(self, data, is_json=True):
             response = urllib2.urlopen(req).read()
         except urllib2.HTTPError as e:
             if e.code == 400:
-                raise GCMMalformedJsonException("The request could not be parsed as JSON")
+                raise GCMMalformedJsonException(
+                    "The request could not be parsed as JSON")
             elif e.code == 401:
-                raise GCMAuthenticationException("There was an error authenticating the sender account")
+                raise GCMAuthenticationException(
+                    "There was an error authenticating the sender account")
             elif e.code == 503:
                 raise GCMUnavailableException("GCM service is unavailable")
             else:
                 error = "GCM service error: %d" % e.code
                 raise GCMUnavailableException(error)
         except urllib2.URLError as e:
-            raise GCMConnectionException("There was an internal error in the GCM server while trying to process the request")
+            raise GCMConnectionException(
+                "There was an internal error in the GCM server while trying to process the request")
 
         if is_json:
             response = json.loads(response)
@@ -173,11 +211,14 @@ def raise_error(self, error):
         elif error == 'Unavailable':
             # Plain-text requests will never return Unavailable as the error code.
             # http://developer.android.com/guide/google/gcm/gcm.html#error_codes
-            raise GCMUnavailableException("Server unavailable. Resent the message")
+            raise GCMUnavailableException(
+                "Server unavailable. Resent the message")
         elif error == 'NotRegistered':
-            raise GCMNotRegisteredException("Registration id is not valid anymore")
+            raise GCMNotRegisteredException(
+                "Registration id is not valid anymore")
         elif error == 'MismatchSenderId':
-            raise GCMMismatchSenderIdException("A Registration ID is tied to a certain group of senders")
+            raise GCMMismatchSenderIdException(
+                "A Registration ID is tied to a certain group of senders")
         elif error == 'MessageTooBig':
             raise GCMMessageTooBigException("Message can't exceed 4096 bytes")
 
@@ -196,7 +237,8 @@ def handle_plaintext_response(self, response):
 
     def handle_json_response(self, response, registration_ids):
         errors = group_response(response, registration_ids, 'error')
-        canonical = group_response(response, registration_ids, 'registration_id')
+        canonical = group_response(
+            response, registration_ids, 'registration_id')
 
         info = {}
         if errors:
@@ -212,7 +254,7 @@ def extract_unsent_reg_ids(self, info):
         return []
 
     def plaintext_request(self, registration_id, data=None, collapse_key=None,
-                            delay_while_idle=False, time_to_live=None, retries=5, dry_run=False):
+                          delay_while_idle=False, time_to_live=None, retries=5, dry_run=False):
         """
         Makes a plaintext request to GCM servers
 
@@ -245,7 +287,7 @@ def plaintext_request(self, registration_id, data=None, collapse_key=None,
         raise IOError("Could not make request after %d attempts" % attempt)
 
     def json_request(self, registration_ids, data=None, collapse_key=None,
-                        delay_while_idle=False, time_to_live=None, retries=5, dry_run=False):
+                     delay_while_idle=False, time_to_live=None, retries=5, dry_run=False):
         """
         Makes a JSON request to GCM servers
 
@@ -259,7 +301,8 @@ def json_request(self, registration_ids, data=None, collapse_key=None,
         if not registration_ids:
             raise GCMMissingRegistrationException("Missing registration_ids")
         if len(registration_ids) > 1000:
-            raise GCMTooManyRegIdsException("Exceded number of registration_ids")
+            raise GCMTooManyRegIdsException(
+                "Exceded number of registration_ids")
 
         attempt = 0
         backoff = self.BACKOFF_INITIAL_DELAY