format code

Author: Linusp

inoreader/__init__.py

@@ -1,4 +1,4 @@
 # coding: utf-8
 from .client import InoreaderClient
 
-__all__ = ['InoreaderClient']
+__all__ = ["InoreaderClient"]

inoreader/article.py

@@ -23,7 +23,7 @@ def __init__(
         self.categories = categories
         self.link = link
         self.published = published
-        self.content = content.strip() if content else ''
+        self.content = content.strip() if content else ""
         self.text = extract_text(self.content)
         self.author = author
         self.feed_id = feed_id
@@ -33,22 +33,22 @@ def __init__(
     @classmethod
     def from_json(cls, data):
         article_data = {
-            'id': data['id'],
-            'title': data['title'],
-            'categories': data['categories'],
-            'published': data['published'],
-            'content': data.get('summary', {}).get('content'),
-            'author': data.get('author'),
+            "id": data["id"],
+            "title": data["title"],
+            "categories": data["categories"],
+            "published": data["published"],
+            "content": data.get("summary", {}).get("content"),
+            "author": data.get("author"),
         }
-        links = [item['href'] for item in data['canonical']]
-        article_data['link'] = links[0] if links else ''
+        links = [item["href"] for item in data["canonical"]]
+        article_data["link"] = links[0] if links else ""
 
         # feed info
         article_data.update(
             {
-                'feed_id': data['origin']['streamId'],
-                'feed_title': normalize_whitespace(data['origin']['title']),
-                'feed_link': data['origin']['htmlUrl'],
+                "feed_id": data["origin"]["streamId"],
+                "feed_title": normalize_whitespace(data["origin"]["title"]),
+                "feed_link": data["origin"]["htmlUrl"],
             }
         )
 

inoreader/client.py

@@ -25,20 +25,20 @@
 
 class InoreaderClient(object):
     # paths
-    TOKEN_PATH = '/oauth2/token'
-    USER_INFO_PATH = 'user-info'
-    TAG_LIST_PATH = 'tag/list'
-    SUBSCRIPTION_LIST_PATH = 'subscription/list'
-    STREAM_CONTENTS_PATH = 'stream/contents/'
-    EDIT_TAG_PATH = 'edit-tag'
-    EDIT_SUBSCRIPTION_PATH = 'subscription/edit'
+    TOKEN_PATH = "/oauth2/token"
+    USER_INFO_PATH = "user-info"
+    TAG_LIST_PATH = "tag/list"
+    SUBSCRIPTION_LIST_PATH = "subscription/list"
+    STREAM_CONTENTS_PATH = "stream/contents/"
+    EDIT_TAG_PATH = "edit-tag"
+    EDIT_SUBSCRIPTION_PATH = "subscription/edit"
 
     # tags
-    GENERAL_TAG_TEMPLATE = 'user/-/label/{}'
-    READ_TAG = 'user/-/state/com.google/read'
-    STARRED_TAG = 'user/-/state/com.google/starred'
-    LIKED_TAG = 'user/-/state/com.google/like'
-    BROADCAST_TAG = 'user/-/state/com.google/broadcast'
+    GENERAL_TAG_TEMPLATE = "user/-/label/{}"
+    READ_TAG = "user/-/state/com.google/read"
+    STARRED_TAG = "user/-/state/com.google/starred"
+    LIKED_TAG = "user/-/state/com.google/like"
+    BROADCAST_TAG = "user/-/state/com.google/broadcast"
 
     def __init__(
         self, app_id, app_key, access_token, refresh_token, expires_at, config_manager=None
@@ -51,9 +51,9 @@ def __init__(
         self.session = requests.Session()
         self.session.headers.update(
             {
-                'AppId': self.app_id,
-                'AppKey': self.app_key,
-                'Authorization': 'Bearer {}'.format(self.access_token),
+                "AppId": self.app_id,
+                "AppKey": self.app_key,
+                "Authorization": "Bearer {}".format(self.access_token),
             }
         )
         self.config_manager = config_manager
@@ -76,16 +76,16 @@ def parse_response(response, json_data=True):
     def refresh_access_token(self):
         url = urljoin(BASE_URL, self.TOKEN_PATH)
         payload = {
-            'client_id': self.app_id,
-            'client_secret': self.app_key,
-            'grant_type': 'refresh_token',
-            'refresh_token': self.refresh_token,
+            "client_id": self.app_id,
+            "client_secret": self.app_key,
+            "grant_type": "refresh_token",
+            "refresh_token": self.refresh_token,
         }
         response = self.parse_response(requests.post(url, json=payload, proxies=self.proxies))
-        self.access_token = response['access_token']
-        self.refresh_token = response['refresh_token']
-        self.expires_at = datetime.now().timestamp() + response['expires_in']
-        self.session.headers['Authorization'] = 'Bearer {}'.format(self.access_token)
+        self.access_token = response["access_token"]
+        self.refresh_token = response["refresh_token"]
+        self.expires_at = datetime.now().timestamp() + response["expires_in"]
+        self.session.headers["Authorization"] = "Bearer {}".format(self.access_token)
 
         if self.config_manager:
             self.config_manager.access_token = self.access_token
@@ -103,47 +103,47 @@ def get_folders(self):
         self.check_token()
 
         url = urljoin(BASE_URL, self.TAG_LIST_PATH)
-        params = {'types': 1, 'counts': 1}
+        params = {"types": 1, "counts": 1}
         response = self.parse_response(self.session.post(url, params=params, proxies=self.proxies))
 
         folders = []
-        for item in response['tags']:
-            if item.get('type') != 'folder':
+        for item in response["tags"]:
+            if item.get("type") != "folder":
                 continue
 
-            folder_name = item['id'].split('/')[-1]
-            folders.append({'name': folder_name, 'unread_count': item['unread_count']})
+            folder_name = item["id"].split("/")[-1]
+            folders.append({"name": folder_name, "unread_count": item["unread_count"]})
 
-        folders.sort(key=itemgetter('name'))
+        folders.sort(key=itemgetter("name"))
         return folders
 
     def get_tags(self):
         self.check_token()
 
         url = urljoin(BASE_URL, self.TAG_LIST_PATH)
-        params = {'types': 1, 'counts': 1}
+        params = {"types": 1, "counts": 1}
         response = self.parse_response(self.session.post(url, params=params, proxies=self.proxies))
 
         tags = []
-        for item in response['tags']:
-            if item.get('type') != 'tag':
+        for item in response["tags"]:
+            if item.get("type") != "tag":
                 continue
 
-            folder_name = item['id'].split('/')[-1]
-            tags.append({'name': folder_name, 'unread_count': item['unread_count']})
+            folder_name = item["id"].split("/")[-1]
+            tags.append({"name": folder_name, "unread_count": item["unread_count"]})
 
-        tags.sort(key=itemgetter('name'))
+        tags.sort(key=itemgetter("name"))
         return tags
 
     def get_subscription_list(self):
         self.check_token()
 
         url = urljoin(BASE_URL, self.SUBSCRIPTION_LIST_PATH)
         response = self.parse_response(self.session.get(url, proxies=self.proxies))
-        for item in response['subscriptions']:
+        for item in response["subscriptions"]:
             yield Subscription.from_json(item)
 
-    def get_stream_contents(self, stream_id, c='', limit=None):
+    def get_stream_contents(self, stream_id, c="", limit=None):
         fetched_count = 0
         stop = False
         while not stop:
@@ -161,16 +161,16 @@ def get_stream_contents(self, stream_id, c='', limit=None):
             if c is None:
                 break
 
-    def __get_stream_contents(self, stream_id, continuation=''):
+    def __get_stream_contents(self, stream_id, continuation=""):
         self.check_token()
 
         url = urljoin(BASE_URL, self.STREAM_CONTENTS_PATH + quote_plus(stream_id))
-        params = {'n': 50, 'r': '', 'c': continuation, 'output': 'json'}  # default 20, max 1000
+        params = {"n": 50, "r": "", "c": continuation, "output": "json"}  # default 20, max 1000
         response = self.parse_response(self.session.post(url, params=params, proxies=self.proxies))
-        if 'continuation' in response:
-            return response['items'], response['continuation']
+        if "continuation" in response:
+            return response["items"], response["continuation"]
         else:
-            return response['items'], None
+            return response["items"], None
 
     def fetch_articles(self, folder=None, tags=None, unread=True, starred=False, limit=None):
         self.check_token()
@@ -179,20 +179,20 @@ def fetch_articles(self, folder=None, tags=None, unread=True, starred=False, lim
         if folder:
             url = urljoin(url, quote_plus(self.GENERAL_TAG_TEMPLATE.format(folder)))
 
-        params = {'c': str(uuid4())}
+        params = {"c": str(uuid4())}
         if unread:
-            params['xt'] = self.READ_TAG
+            params["xt"] = self.READ_TAG
 
         if starred:
-            params['it'] = self.STARRED_TAG
+            params["it"] = self.STARRED_TAG
 
         fetched_count = 0
         response = self.parse_response(self.session.post(url, params=params, proxies=self.proxies))
-        for data in response['items']:
+        for data in response["items"]:
             categories = {
-                category.split('/')[-1]
-                for category in data.get('categories', [])
-                if category.find('label') > 0
+                category.split("/")[-1]
+                for category in data.get("categories", [])
+                if category.find("label") > 0
             }
             if tags and not categories.issuperset(set(tags)):
                 continue
@@ -202,17 +202,17 @@ def fetch_articles(self, folder=None, tags=None, unread=True, starred=False, lim
             if limit and fetched_count >= limit:
                 break
 
-        continuation = response.get('continuation')
+        continuation = response.get("continuation")
         while continuation and (not limit or fetched_count < limit):
-            params['c'] = continuation
+            params["c"] = continuation
             response = self.parse_response(
                 self.session.post(url, params=params, proxies=self.proxies)
             )
-            for data in response['items']:
+            for data in response["items"]:
                 categories = {
-                    category.split('/')[-1]
-                    for category in data.get('categories', [])
-                    if category.find('label') > 0
+                    category.split("/")[-1]
+                    for category in data.get("categories", [])
+                    if category.find("label") > 0
                 }
                 if tags and not categories.issuperset(set(tags)):
                     continue
@@ -221,7 +221,7 @@ def fetch_articles(self, folder=None, tags=None, unread=True, starred=False, lim
                 if limit and fetched_count >= limit:
                     break
 
-            continuation = response.get('continuation')
+            continuation = response.get("continuation")
 
     def fetch_unread(self, folder=None, tags=None, limit=None):
         for article in self.fetch_articles(folder=folder, tags=tags, unread=True):
@@ -237,7 +237,7 @@ def add_general_label(self, articles, label):
         url = urljoin(BASE_URL, self.EDIT_TAG_PATH)
         for start in range(0, len(articles), 10):
             end = min(start + 10, len(articles))
-            params = {'a': label, 'i': [articles[idx].id for idx in range(start, end)]}
+            params = {"a": label, "i": [articles[idx].id for idx in range(start, end)]}
             self.parse_response(
                 self.session.post(url, params=params, proxies=self.proxies), json_data=False
             )
@@ -248,7 +248,7 @@ def remove_general_label(self, articles, label):
         url = urljoin(BASE_URL, self.EDIT_TAG_PATH)
         for start in range(0, len(articles), 10):
             end = min(start + 10, len(articles))
-            params = {'r': label, 'i': [articles[idx].id for idx in range(start, end)]}
+            params = {"r": label, "i": [articles[idx].id for idx in range(start, end)]}
             self.parse_response(
                 self.session.post(url, params=params, proxies=self.proxies), json_data=False
             )
@@ -285,16 +285,16 @@ def edit_subscription(self, stream_id, action, title=None, add_folder=None, remo
         url = urljoin(BASE_URL, self.EDIT_SUBSCRIPTION_PATH)
         # https://us.inoreader.com/developers/edit-subscription
         # The documentation looks a bit outdated, `follow`/`unfollow` don't work
-        action = {'follow': 'subscribe', 'unfollow': 'unsubscribe'}.get(action) or action
-        params = {'ac': action, 's': stream_id}
+        action = {"follow": "subscribe", "unfollow": "unsubscribe"}.get(action) or action
+        params = {"ac": action, "s": stream_id}
         if title:
-            params['t'] = title
+            params["t"] = title
 
         if add_folder:
-            params['a'] = add_folder
+            params["a"] = add_folder
 
         if remove_folder:
-            params['r'] = remove_folder
+            params["r"] = remove_folder
 
         r = self.session.post(url, params=params, proxies=self.proxies)
         response = self.parse_response(

inoreader/config.py

@@ -20,55 +20,55 @@ def load(self):
             self.data[section_name] = dict(config_parser[section_name])
 
     def save(self):
-        with codecs.open(self.config_file, mode='w', encoding='utf-8') as f:
+        with codecs.open(self.config_file, mode="w", encoding="utf-8") as f:
             config_parser = ConfigParser()
             config_parser.update(self.data)
             config_parser.write(f)
 
     @property
     def app_id(self):
-        return self.data.get('auth', {}).get('appid')
+        return self.data.get("auth", {}).get("appid")
 
     @app_id.setter
     def app_id(self, value):
-        self.data.setdefault('auth', {})['appid'] = value
+        self.data.setdefault("auth", {})["appid"] = value
 
     @property
     def app_key(self):
-        return self.data.get('auth', {}).get('appkey')
+        return self.data.get("auth", {}).get("appkey")
 
     @app_key.setter
     def app_key(self, value):
-        self.data.setdefault('auth', {})['appkey'] = value
+        self.data.setdefault("auth", {})["appkey"] = value
 
     @property
     def access_token(self):
-        return self.data.get('auth', {}).get('access_token')
+        return self.data.get("auth", {}).get("access_token")
 
     @access_token.setter
     def access_token(self, value):
-        self.data.setdefault('auth', {})['access_token'] = value
+        self.data.setdefault("auth", {})["access_token"] = value
 
     @property
     def refresh_token(self):
-        return self.data.get('auth', {}).get('refresh_token')
+        return self.data.get("auth", {}).get("refresh_token")
 
     @refresh_token.setter
     def refresh_token(self, value):
-        self.data.setdefault('auth', {})['refresh_token'] = value
+        self.data.setdefault("auth", {})["refresh_token"] = value
 
     @property
     def expires_at(self):
-        return self.data.get('auth', {}).get('expires_at')
+        return self.data.get("auth", {}).get("expires_at")
 
     @expires_at.setter
     def expires_at(self, value):
-        self.data.setdefault('auth', {})['expires_at'] = value
+        self.data.setdefault("auth", {})["expires_at"] = value
 
     @property
     def proxies(self):
-        return self.data.get('proxies', {})
+        return self.data.get("proxies", {})
 
     @proxies.setter
     def proxies(self, value):
-        self.data['proxies'] = value
+        self.data["proxies"] = value

inoreader/consts.py

@@ -1,10 +1,10 @@
 # coding: utf-8
 import os
 
-BASE_URL = 'https://www.inoreader.com/reader/api/0/'
-LOGIN_URL = 'https://www.inoreader.com/accounts/ClientLogin'
+BASE_URL = "https://www.inoreader.com/reader/api/0/"
+LOGIN_URL = "https://www.inoreader.com/accounts/ClientLogin"
 
-DEFAULT_APPID = 'your_app_id'
-DEFAULT_APPKEY = 'your_app_key'
+DEFAULT_APPID = "your_app_id"
+DEFAULT_APPKEY = "your_app_key"
 
-CONFIG_FILE = os.path.join(os.environ.get('HOME'), '.inoreader')
+CONFIG_FILE = os.path.join(os.environ.get("HOME"), ".inoreader")