ran black on entire project

Author: tbarbugli

stream/__init__.py

@@ -1,37 +1,53 @@
 import re
 import os
 
-__author__ = 'Thierry Schellenbach'
-__copyright__ = 'Copyright 2014, Stream.io, Inc'
-__credits__ = ['Thierry Schellenbach, mellowmorning.com, @tschellenbach']
-__license__ = 'BSD-3-Clause'
-__version__ = '2.12.0'
-__maintainer__ = 'Thierry Schellenbach'
-__email__ = 'support@getstream.io'
-__status__ = 'Production'
+__author__ = "Thierry Schellenbach"
+__copyright__ = "Copyright 2014, Stream.io, Inc"
+__credits__ = ["Thierry Schellenbach, mellowmorning.com, @tschellenbach"]
+__license__ = "BSD-3-Clause"
+__version__ = "2.12.0"
+__maintainer__ = "Thierry Schellenbach"
+__email__ = "support@getstream.io"
+__status__ = "Production"
 
 
-def connect(api_key=None, api_secret=None, app_id=None, version='v1.0',
-            timeout=3.0, location=None, base_url=None):
-    '''
+def connect(
+    api_key=None,
+    api_secret=None,
+    app_id=None,
+    version="v1.0",
+    timeout=3.0,
+    location=None,
+    base_url=None,
+):
+    """
     Returns a Client object
 
     :param api_key: your api key or heroku url
     :param api_secret: the api secret
     :param app_id: the app id (used for listening to feed changes)
-    '''
+    """
     from stream.client import StreamClient
-    stream_url = os.environ.get('STREAM_URL')
+
+    stream_url = os.environ.get("STREAM_URL")
     # support for the heroku STREAM_URL syntax
     if stream_url and not api_key:
         pattern = re.compile(
-            'https\:\/\/(\w+)\:(\w+)\@([\w-]*).*\?app_id=(\d+)', re.IGNORECASE)
+            "https\:\/\/(\w+)\:(\w+)\@([\w-]*).*\?app_id=(\d+)", re.IGNORECASE
+        )
         result = pattern.match(stream_url)
         if result and len(result.groups()) == 4:
             api_key, api_secret, location, app_id = result.groups()
-            location = None if location in ('getstream', 'stream-io-api') else location
+            location = None if location in ("getstream", "stream-io-api") else location
         else:
-            raise ValueError('Invalid api key or heroku url')
+            raise ValueError("Invalid api key or heroku url")
 
-    return StreamClient(api_key, api_secret, app_id, version, timeout,
-                        location=location, base_url=base_url)
+    return StreamClient(
+        api_key,
+        api_secret,
+        app_id,
+        version,
+        timeout,
+        location=location,
+        base_url=base_url,
+    )

stream/collections.py

@@ -1,5 +1,4 @@
 class Collections(object):
-
     def __init__(self, client, token):
         """
         Used to manipulate data at the 'meta' endpoint
@@ -15,7 +14,7 @@ def create_reference(self, collection_name, id):
         if isinstance(id, (dict,)) and id.get("id") is not None:
             _id = id.get("id")
         return "SO:%s:%s" % (collection_name, _id)
-   
+
     def upsert(self, collection_name, data):
         """
         "Insert new or update existing data.
@@ -33,8 +32,12 @@ def upsert(self, collection_name, data):
 
         data_json = {collection_name: data}
 
-        response = self.client.post('collections/', service_name='api',
-                                    signature=self.token, data={'data': data_json})
+        response = self.client.post(
+            "collections/",
+            service_name="api",
+            signature=self.token,
+            data={"data": data_json},
+        )
         return response
 
     def select(self, collection_name, ids):
@@ -56,11 +59,15 @@ def select(self, collection_name, ids):
 
         foreign_ids = []
         for i in range(len(ids)):
-            foreign_ids.append('%s:%s' % (collection_name, ids[i]))
-        foreign_ids = ','.join(foreign_ids)
+            foreign_ids.append("%s:%s" % (collection_name, ids[i]))
+        foreign_ids = ",".join(foreign_ids)
 
-        response = self.client.get('collections/', service_name='api', params={'foreign_ids': foreign_ids},
-                                   signature=self.token)
+        response = self.client.get(
+            "collections/",
+            service_name="api",
+            params={"foreign_ids": foreign_ids},
+            signature=self.token,
+        )
 
         return response
 
@@ -80,17 +87,16 @@ def delete_many(self, collection_name, ids):
             ids = [ids]
         ids = [str(i) for i in ids]
 
-        params = {'collection_name': collection_name, 'ids': ids}
+        params = {"collection_name": collection_name, "ids": ids}
 
-        response = self.client.delete('collections/', service_name='api', params=params,
-                                      signature=self.token)
+        response = self.client.delete(
+            "collections/", service_name="api", params=params, signature=self.token
+        )
 
         return response
 
     def add(self, collection_name, data, id=None, user_id=None):
-        payload = dict(
-            id=id, data=data, user_id=user_id,
-        )
+        payload = dict(id=id, data=data, user_id=user_id)
         return self.client.post(
             "collections/%s" % collection_name,
             service_name="api",
@@ -100,7 +106,9 @@ def add(self, collection_name, data, id=None, user_id=None):
 
     def get(self, collection_name, id):
         return self.client.get(
-            "collections/%s/%s" % (collection_name, id), service_name="api", signature=self.token
+            "collections/%s/%s" % (collection_name, id),
+            service_name="api",
+            signature=self.token,
         )
 
     def update(self, collection_name, id, data=None):
@@ -114,5 +122,7 @@ def update(self, collection_name, id, data=None):
 
     def delete(self, collection_name, id):
         return self.client.delete(
-            "collections/%s/%s" % (collection_name, id), service_name="api", signature=self.token
+            "collections/%s/%s" % (collection_name, id),
+            service_name="api",
+            signature=self.token,
         )

stream/exceptions.py

@@ -1,7 +1,4 @@
-
-
 class StreamApiException(Exception):
-
     def __init__(self, error_message, status_code=None):
         Exception.__init__(self, error_message)
         self.detail = error_message
@@ -11,78 +8,87 @@ def __init__(self, error_message, status_code=None):
     code = 1
 
     def __repr__(self):
-        return '%s (%s)' % (self.__class__.__name__, self.detail)
+        return "%s (%s)" % (self.__class__.__name__, self.detail)
 
     def __unicode__(self):
-        return '%s (%s)' % (self.__class__.__name__, self.detail)
+        return "%s (%s)" % (self.__class__.__name__, self.detail)
 
 
 class ApiKeyException(StreamApiException):
 
-    '''
+    """
     Raised when there is an issue with your Access Key
-    '''
+    """
+
     status_code = 401
     code = 2
 
 
 class SignatureException(StreamApiException):
 
-    '''
+    """
     Raised when there is an issue with the signature you provided
-    '''
+    """
+
     status_code = 401
     code = 3
 
 
 class InputException(StreamApiException):
 
-    '''
+    """
     Raised when you send the wrong data to the API
-    '''
+    """
+
     status_code = 400
     code = 4
 
 
 class CustomFieldException(StreamApiException):
 
-    '''
+    """
     Raised when there are missing or misconfigured custom fields
-    '''
+    """
+
     status_code = 400
     code = 5
 
 
 class FeedConfigException(StreamApiException):
 
-    '''
+    """
     Raised when there are missing or misconfigured custom fields
-    '''
+    """
+
     status_code = 400
     code = 6
 
 
 class SiteSuspendedException(StreamApiException):
 
-    '''
+    """
     Raised when the site requesting the data is suspended
-    '''
+    """
+
     status_code = 401
     code = 7
 
+
 class InvalidPaginationException(StreamApiException):
 
-    '''
+    """
     Raised when there is an issue with your Access Key
-    '''
+    """
+
     status_code = 401
     code = 8
 
 
 class MissingRankingException(FeedConfigException):
-    '''
+    """
     Raised when you didn't configure the ranking for the given feed
-    '''
+    """
+
     status_code = 400
     code = 12
 
@@ -93,57 +99,64 @@ class MissingUserException(MissingRankingException):
 
 
 class RankingException(FeedConfigException):
-    '''
+    """
     Raised when there is a runtime issue with ranking the feed
-    '''
+    """
+
     status_code = 400
     code = 11
 
 
 class RateLimitReached(StreamApiException):
 
-    '''
+    """
     Raised when too many requests are performed
-    '''
+    """
+
     status_code = 429
     code = 9
 
 
 class OldStorageBackend(StreamApiException):
-    '''
+    """
     Raised if you try to perform an action which only works with the new storage
-    '''
+    """
+
     status_code = 400
     code = 13
 
 
 class BestPracticeException(StreamApiException):
-    '''
+    """
     Raised if best practices are enforced and you do something that
     would break a high volume integration
-    '''
+    """
+
     status_code = 400
     code = 15
 
 
 class DoesNotExistException(StreamApiException):
-    '''
+    """
     Raised when the requested resource could not be found.
-    '''
+    """
+
     status_code = 404
     code = 16
 
 
 class NotAllowedException(StreamApiException):
-    '''
+    """
     Raised when the requested action is not allowed for some reason.
-    '''
+    """
+
     status_code = 403
     code = 17
 
 
 def get_exceptions():
     from stream import exceptions
+
     classes = []
     for k in dir(exceptions):
         a = getattr(exceptions, k)

stream/feed.py

@@ -132,16 +132,16 @@ def get(self, enrich=False, reactions=None, **params):
         else:
             feed_url = self.feed_url
 
-        if reactions is not None and not isinstance(reactions, (dict, )):
+        if reactions is not None and not isinstance(reactions, (dict,)):
             raise TypeError("reactions argument should be a dictionary")
 
         if reactions is not None:
-            if reactions.get('own'):
-                params['withOwnReactions'] = True
-            if reactions.get('recent'):
-                params['withRecentReactions'] = True
-            if reactions.get('counts'):
-                params['withReactionCounts'] = True
+            if reactions.get("own"):
+                params["withOwnReactions"] = True
+            if reactions.get("recent"):
+                params["withRecentReactions"] = True
+            if reactions.get("counts"):
+                params["withReactionCounts"] = True
 
         response = self.client.get(feed_url, params=params, signature=token)
         return response