Pocket.recipe

#!/usr/bin/env python
# vim:ft=python tabstop=8 expandtab shiftwidth=4 softtabstop=4
from __future__ import print_function
__version__ = '2.7.7'

"""
2.7.7: Fix #63 #62
2.7.6: Fix #60 Untagged articles do not get included
2.7.5: Fix #59
2.7.4: Fix #46 KeyError: u'resolved_title'
2.7.3: Replace tld with standard Python way (not as good as tld but works without extra package) if SECTIONS_BY_DOMAIN_USING_TLD = False
2.7.2: Change default MAX_ARTICLES to 30
2.7.1: A fix for import tld
2.7:   Introduce ~/.pocket.py local config system
2.6.4: SECTIONS_BY_DOMAIN, an excellent implementation from @alvaroreig to make sections 
       by domains (of URLs) 210322
2.6.3: With fix from @AkashPatel95 #26 201122
2.6.2: Fix. Add also removal of H1 to clean up all titles, to insert a new one

**TAGS** (list of strings or empty list: []) if [] (empty list) then the plugin will connect Pocket and fetch articles based on the configuration of the plugin.
        Next, the plugin will get tags of these articles and group them into sections in the final ebook.
        If TAGS has elements, e.g., TAGS = ['tag1', 'tag2'] then only these tags will be fetched from Pocket.

**TAGS_EXCEPTIONS** (list of strings or empty list: []) if [] (empty list) then the plugin will ignore it.
        If TAGS_EXCEPTIONS has elements, e.g., TAGS_EXCEPTIONS = ['tag3', 'tag4'] then the articles tagged with this tags will be ignored.
        That is, tag3 and tag4 won't appear as sections, and it's articles won't appear in the  "Untagged" section.
        This variable is meant to be used with TAGS = [], as it doesn’t make any sense to specify a tag both in TAGS and in TAGS_EXCEPTIONS.

**URL_KEYWORD_EXCEPTIONS** (list of keywords such as, if the URL of the article contains any keyword, then the plugin will ignore the article)

**SECTIONS_BY_DOMAIN** If activated, the articles will be grouped by first level domain. This will override any
        tag configuration (that is: TAGS, TAGS_EXCEPTIONS, INCLUDE_UNTAGGED). This is because the recipe ignores duplicated
        articles, and therefore an article can't appear under a "real" (pocket) tag and under the fake tag with its domain.

**SECTIONS_BY_DOMAIN_USING_TLD** you can install TLD and use it to get domains, but this requires installed library in 
        a way that Calibre will see it (I had a huge problem to get this running @mmagnus), so there is a new
        way to get domain based on parsing URL, less sophisticated but more reliable (in my opinion @mmagnus)

**INCLUDE_UNTAGGED** (True or False) if True then put all fetched and untagged articles in the last section 'Untagged'.
        If False then skip these articles and don't create the section 'Untagged'. Bear in mind that if TAGS is populated ( e.g. TAGS = ['tag1', 'tag2']),
        INCLUDE_UNTAGED = True and other tags exist in Pokcet (e.g. tag3,tag4) then the Untagged section will include untagged articles 
        in Pocket AND articles tagged with tag3 and tag4. That behavior can be avoided using TAGS_EXCEPTION

**ARCHIVE_DOWNLOADED** (True or False) do you want to archive articles after fetching 

**MAX_ARTICLES** (number) how many articles do you want to fetch in total. Pocket seems to reject values too high, 1000 seems to work OK.

**SORT_METHOD** ('oldest' or 'newest') way how the articles are sorted

**OLDEST_ARTICLE** (number) fetch articles added (modified) in Pocket for number of days, 7 will give you articles added/modified in Pocket for the last week 
 
**TO_PULL** ('all' or 'unread') What articles to pull? unread only or all?

**TITLE_WITH_TAGS** (True or False) if True will the ebook filename will be like
        Pocket: INVEST P2P [Sun, 05 Jan 2020] for many tags this might be to long, if you make a single tag ebook this might be super fun!

**ALLOW_DUPLICATES** (True or False) if True articles that have multiple tags matching those defined in TAGS are duplicated in each matched tag
        Eg.: TAGS = ['tag1','tag2'] then article1 that has both tags will appear in both sections tag1 and tag2. 
"""
# CONFIGURATION ###########################################################
TAGS = [] # [] or ['tag1', 'tag2']
TAGS_EXCEPTIONS = [] # [] or ['tag3', 'tag4']
URL_KEYWORD_EXCEPTIONS = [] # [] or ['keyword1', 'keyword2']
SECTIONS_BY_DOMAIN = False
INCLUDE_UNTAGGED = True
ARCHIVE_DOWNLOADED = False
MAX_ARTICLES = 1000
OLDEST_ARTICLE = 365
SORT_METHOD = 'newest'
SORT_WITHIN_TAG_BY_TITLE = False
TO_PULL = 'unread'
TITLE_WITH_TAGS = False
ALLOW_DUPLICATES = True
USE_GLOBAL_CONFIG = False
# ADV CONFIGURATION #########################################################
SITE_PACKAGE_PATH = ''
#############################################################################
# code for configuration set in your home folder
if USE_GLOBAL_CONFIG:
    import os
    try:
        # variables as Python code into ~/.pocket.py to overwrite variables above, e.g.:
        user_path = os.path.expanduser("~")
        exec(open(user_path + '/.pocket.py').read())  # python3
    except: # FileNotFoundError: noooot perfect! 
        pass
#############################################################################
from calibre.constants import config_dir
from calibre.utils.config import JSONConfig
from calibre.web.feeds.news import BasicNewsRecipe
from collections import namedtuple
from os import path
from time import localtime, strftime, time
#############################################################################
import sys
SITE_PACKAGE_PATH = ''
if SECTIONS_BY_DOMAIN:
        from urllib.parse import urlparse

import errno
import json
import mechanize
import operator

try:
        from urllib.error import HTTPError
except ImportError:
        from urllib2 import HTTPError

__license__ = 'GPL v3'
__copyright__ = '2019, David Orchard'



class PocketConfig:
        __file_path = path.join(config_dir, 'custom_recipes', 'Pocket.json')

        class AuthState:
                FirstRun = 1
                Authorizing = 2
                Authorized = 3

        def __init__(self, state = AuthState.FirstRun, token = None, user = None):
                # Default values
                self.state = state
                self.token = token
                self.user = user

        @staticmethod
        def from_file():
                config = PocketConfig()
                config.load()
                return config

        def load(self):
                try:
                        with open(self.__file_path) as config:
                                config = json.load(config)

                        if isinstance(config, dict):
                                for key in self.__dict__.keys():
                                        if config[key]:
                                                setattr(self, key, config[key])
                except IOError as e:
                        # File not found
                        if e.errno != errno.ENOENT:
                           raise e

        def save(self):
                with open(self.__file_path, 'w') as config:
                        json.dump(self.__dict__, config)


class Pocket(BasicNewsRecipe):
        config = PocketConfig.from_file()

        __author__ = 'David Orchard'
        description = '''

                Modified by Marcin Magnus.

                Fetches articles saved with <a href="https://getpocket.com/">Pocket</a> and archives them.<br>
        ''' + ('''
                Click <a href="https://getpocket.com/connected_applications">here</a>
                to disconnect Calibre from the Pocket account "{}".
        '''.format(config.user) if config.user else '''
                Run 'Fetch News' with this source scheduled to initiate authentication with Pocket.
        ''')
        publisher = 'Pocket.com'
        category = 'info, custom, Pocket'

        # User-configurable settings -----------------------------------------------
        tagsList = TAGS 
        oldest_article = OLDEST_ARTICLE
        max_articles = MAX_ARTICLES
        archive_downloaded = ARCHIVE_DOWNLOADED
        include_untagged = INCLUDE_UNTAGGED    
        series_name = 'Pocket'
        sort_method = SORT_METHOD
        to_pull = TO_PULL

        publication_type = 'magazine'
        title = "Pocket"
        # timefmt = '' # uncomment to remove date from the filenames, if commented then you will get something like `Pocket [Wed, 13 May 2020]`
        masthead_url = "https://github.com/mmagnus/Pocket-Plus-Calibre-Plugin/raw/master/doc/masthead.png"
        # will make square cover; this will replace text and cover of the default
        # cover_url = "https://github.com/mmagnus/Pocket-Plus-Calibre-Plugin/raw/master/doc/cover.png"
        # --------------------------------------------------------------------------
        
        # Inherited developer settings
        auto_cleanup = True
        no_stylesheets = True
        use_embedded_content = False
        if ALLOW_DUPLICATES:
            ignore_duplicate_articles = {}
        else:
            ignore_duplicate_articles = {'url'}

        # Custom developer settings
        consumer_key = '87006-2ecad30a91903f54baf0ee05'
        redirect_uri = 'https://calibre-ebook.com/'
        base_url = 'https://app.getpocket.com'
        to_archive = []

        simultaneous_downloads = 10
        
        extra_css = '.touchscreen_navbar {display: none;}'
        extra_css = '.calibre_navbar { visibility: hidden; }'
        # TITLE_WITH_TAGS
        tags_title = ' '
        if tagsList:
                if tagsList[-1] != '' and TITLE_WITH_TAGS:  # ugly hack
                        tags_title = ':' + ' '.join(tagsList).upper() + ' '

        def first_run(self):
                request = mechanize.Request("https://getpocket.com/v3/oauth/request",
                                (u'{{'
                                        '"consumer_key":"{0}",'
                                        '"redirect_uri":"{1}"'
                                '}}').format(
                                        self.consumer_key,
                                        self.redirect_uri
                                ),
                                headers = {
                                        'Content-Type': 'application/json; charset=UTF8',
                                        'X-Accept': 'application/json'
                                }
                        )
                response = self.browser.open(request)
                response = json.load(response)
                self.config = PocketConfig(
                                state = PocketConfig.AuthState.Authorizing,
                                token = response['code']
                )

        def authorize(self):
                assert self.config.state == PocketConfig.AuthState.Authorizing, "Authorization process not yet begun"
                assert self.config.token, "No request token"
                request = mechanize.Request("https://getpocket.com/v3/oauth/authorize",
                                (u'{{'
                                        '"consumer_key":"{0}",'
                                        '"code":"{1}"'
                                '}}').format(
                                        self.consumer_key,
                                        self.config.token
                                ),
                                headers = {
                                        'Content-Type': 'application/json; charset=UTF8',
                                        'X-Accept': 'application/json'
                                }
                        )
                try:
                        response = self.browser.open(request)
                        response = json.load(response)
                        self.config = PocketConfig(
                                        state = PocketConfig.AuthState.Authorized,
                                        token = response["access_token"],
                                        user = response["username"],
                        )
                except HTTPError as e:
                        if e.code == 403:
                                # The code has already been used, or the user denied access
                                self.reauthorize()
                        raise e

        def parse_index(self):
                assert self.config.state == PocketConfig.AuthState.Authorized, "Not yet authorized"
                assert self.config.token, "No access token"

                articles = []
                section_dict = {} #dictionary with the sections and its articles. the sections
                                    #cant be domains or tags depending on SECTIONS_BY_DOMAIN

                ############ GET ALL ITEMS #############
                # get every item and iterate them. Build the section_dict
                # with tags or domains as keys, depending on SECTIONS_BY_DOMAIN
                request = mechanize.Request("https://getpocket.com/v3/get",
                                        (u'{{'
                                                '"consumer_key":"{0}",'
                                                '"access_token":"{1}",'
                                                '"count":"{2}",'
                                                '"since":"{3}",'
                                                '"state":"{5}",'
                                                '"detailType":"complete",'
                                                '"sort":"{4}"' '}}').format(
                                                self.consumer_key,
                                                self.config.token,
                                                self.max_articles,
                                                int(time()) - 86400 * self.oldest_article,
                                                self.sort_method, 
                                                self.to_pull,
                                        ),
                                        headers = {
                                                'Content-Type': 'application/json; charset=UTF8',
                                                'X-Accept': 'application/json'
                                        }
                                )

                try:
                    response = self.browser.open(request)
                    response = json.load(response)
                except HTTPError as e:
                    if e.code == 401:
                        # Calibre access has been removed
                        self.reauthorize()
                        raise e

                if not response['list']:
                    self.abort_recipe_processing('No unread articles in the Pocket account "{}"'.format(self.config.user))
                else:
                    for item in dict(response['list']):
                        if response['list'][item]['status'] == '2':
                            del response['list'][item]
                        # If the URL contains any URL_KEYWORD_EXCEPTIONS, ignore article
                        elif any(pattern in response['list'][item]['given_url'] for pattern in URL_KEYWORD_EXCEPTIONS):
                            print("Ignoring article due to keyword patterns:" + response['list'][item]['given_url'])
                            del response['list'][item]
                        elif SECTIONS_BY_DOMAIN:
                            # the keys of section_dict will be domains
                            # Extract domain from the URL
                            domain =  urlparse(response['list'][item]['resolved_url']).netloc.replace('www.', '')

                            url = response['list'][item]['resolved_url']
                            print('>> url', url, file=sys.stderr)
                            print('>>> domain', domain, file=sys.stderr)                                

                            # Add the article under its domain
                            if domain not in section_dict:
                                    section_dict[domain] = [item]
                            else:
                                    section_dict[domain].append(item)
                        else:
                            # the keys of section_dict will be tags
                            article_tags = response['list'][item].get('tags')

                            if article_tags: #this test True if the dict is not empty
                                article_tags = list(article_tags.keys())
                            else:
                                if INCLUDE_UNTAGGED:
                                    article_tags = ['Untagged']
                                else:
                                    article_tags = None

                            # tag could be None if article untagged and INCLUDE_UNTAGGED=False
                            if article_tags and not any(tagcheck in TAGS_EXCEPTIONS for tagcheck in article_tags):
                                if (len(TAGS) == 0):
                                    #autotags enabled, insert tag and item
                                    for tagcheck in article_tags:
                                        if tagcheck not in section_dict:
                                            section_dict[tagcheck] = [item]
                                        else:
                                            section_dict[tagcheck].append(item)
                                else:
                                    # explicit tags, check that
                                    # the tag belongs to the explicit array TAGS
                                    # OR is is an untagged article and INCLUDE_UNTAGGED=True
                                    for tagcheck in article_tags:
                                        if tagcheck in TAGS or (tagcheck == 'Untagged' and INCLUDE_UNTAGGED):
                                            if tagcheck not in section_dict:
                                                section_dict[tagcheck] = [item]
                                            else:
                                                section_dict[tagcheck].append(item)

                    ############ APPEND ARTS FOR EACH TAG/DOMAIN #############
                    # At this point the section_dict is completed, either with
                    # domains or with tags

                    for section in section_dict:
                        arts = []
                        for item in section_dict.get(section):
                            try:
                                title = response['list'][item]['resolved_title']
                            except KeyError:
                                title = 'error: title'
                            try:
                                url =  response['list'][item]['resolved_url']
                            except KeyError:
                                url = 'error: url'
                            try:
                                desc = response['list'][item]['excerpt']
                            except KeyError:
                                desc = 'error: description'
                            arts.append({
                                        'title': title,
                                        'url': url,
                                        'date': response['list'][item]['time_added'],
                                        'description': desc,})

                            if (
                                self.archive_downloaded
                                and response['list'][item]['item_id'] not in self.to_archive
                            ):
                                self.to_archive.append(response['list'][item]['item_id'])


                        if not SECTIONS_BY_DOMAIN and SORT_WITHIN_TAG_BY_TITLE:
                            arts = sorted(arts, key = lambda i: i['title'])

                        if arts:
                                articles.append((section, arts))

                    if not articles:
                        self.abort_recipe_processing('No articles in the Pocket account %s to download' % (self.config.user)) #, ' '.join(self.tags))) \n[tags: %s]
                    return articles
        

        def reauthorize(self):
                self.config = PocketConfig();
                self.ensure_authorization()

        def ensure_authorization(self):
                if self.config.state is PocketConfig.AuthState.FirstRun:
                        self.first_run()
                        self.config.save()
                        self.abort_recipe_processing('''
                                Calibre must be granted access to your Pocket account. Please click
                                <a href="https://getpocket.com/auth/authorize?request_token={0}&redirect_uri={1}">here</a>
                                to authenticate via a browser, and then re-fetch the news.
                        '''.format(self.config.token, self.redirect_uri))
                elif self.config.state is PocketConfig.AuthState.Authorizing:
                        self.authorize()
                        self.config.save()

        def get_browser(self, *args, **kwargs):
                self.browser = BasicNewsRecipe.get_browser(self)
                self.ensure_authorization()
                return self.browser

        def archive(self):
                assert self.config.state == PocketConfig.AuthState.Authorized, "Not yet authorized"
                assert self.config.token, "No access token"

                if not self.to_archive:
                        return

                archived_time = int(time())
                request = mechanize.Request("https://getpocket.com/v3/send",
                                (u'{{'
                                        '"consumer_key":"{0}",'
                                        '"access_token":"{1}",'
                                        '"actions":{2}'
                                '}}').format(
                                        self.consumer_key,
                                        self.config.token,
                                        json.dumps([{
                                                'action': 'archive',
                                                'item_id': item_id,
                                                'time': archived_time,
                                        } for item_id in self.to_archive])
                                ),
                                headers = {
                                        'Content-Type': 'application/json; charset=UTF8',
                                        'X-Accept': 'application/json'
                                }
                        )
                response = self.browser.open(request)

        def cleanup(self):
                # If we're in another state, then downloading didn't complete
                # (e.g. reauthorization needed) so there is no archiving to do
                if self.config.state == PocketConfig.AuthState.Authorized:
                        self.archive()

        # TODO: This works with EPUB, but not mobi/azw3
        # BUG: https://bugs.launchpad.net/calibre/+bug/1838486
        def postprocess_book(self, oeb, opts, log):
                oeb.metadata.add('series', self.series_name)

        def postprocess_html(self, soup, first):
                title = soup.find('title').text # get title

                h1s = soup.findAll('h1')  # get all h1 headers
                for h1 in h1s:
                        if title in h1.text:
                                h1 = h1.clear()  # clean this tag, so the h1 will be there only

                h2s = soup.findAll('h2')  # get all h2 headers
                for h2 in h2s:
                        if title in h2.text:
                                h2 = h2.clear()  # clean this tag, so the h1 will be there only

                body = soup.find('body')
                new_tag = soup.new_tag('h1')
                new_tag.append(title)
                body.insert(0, new_tag)
                # print(soup.prettify(), file=sys.stderr)
                return soup

        def default_cover(self, cover_file):
                """
                Create a generic cover for recipes that don't have a cover
                This override adds time to the cover
                """
                try:
                        from calibre.ebooks import calibre_cover
                        title = self.title if isinstance(self.title, unicode) else \
                                self.title.decode('utf-8', 'replace')
                        # print('>> title', title, file=sys.stderr)
                        date = strftime(self.timefmt)
                        time = strftime('%a %d %b %Y %-H:%M')
                        img_data = calibre_cover(title, date, time)
                        cover_file.write(img_data)
                        cover_file.flush()
                except:
                        self.log.exception('Failed to generate default cover')
                        return False
                return True