Initial pass

3 files changed, 393 insertions, 0 deletions

diff --git a/app.py b/app.py
new file mode 100755
index 0000000..755d55c
--- /dev/null
+++ b/app.py
@@ -0,0 +1,209 @@
+#!/usr/bin/env python3
+
+import sqlite3
+import base64
+from copy import copy
+from datetime import datetime
+from collections import defaultdict
+
+from flask import Flask, render_template, jsonify, request, make_response
+
+app = Flask(__name__)
+
+
+class DataObject(object):
+
+    @classmethod
+    def from_db_row(cls, cursor, row):
+        return cls(*row)
+
+    def _update_json(self, data):
+        return
+
+    def to_json(self):
+        data = copy(self.__dict__)
+        self._update_json(data)
+        data['self'] = self.self_link
+        return data
+
+    def __repr__(self):
+        return '{self.__class__.__name__}({self.id!r}, {self.title!r})'.format(
+                self=self)
+
+    @property
+    def self_link(self):
+        return self.URL.format(self=self)
+
+
+class RSSItem(DataObject):
+
+    URL = '/item/{self.id}'
+
+    def __init__(self, id, title, author, feed_title, feed_url, url,
+            publish_date, content, read):
+        self.id = id
+        self.feed_url = RSSFeed(feed_url, None, None).self_link
+        self.feed_title = feed_title
+        self.title = title
+        self.author = author
+        self.url = url
+        self.publish_date = datetime.fromtimestamp(publish_date)
+        self.content = content
+        self.read = not bool(read)
+        self.no_content = len(content) < 100
+
+
+class RSSFeed(DataObject):
+
+    URL = '/feed/{self.id}'
+
+    def __init__(self, feed_url, url, title):
+        self.feed_url = feed_url
+        self.url = url
+        self.title = title
+
+    def _update_json(self, data):
+        data['items'] = '/feed/{}/items'.format(self.id)
+
+    @property
+    def id(self):
+        return base64.b64encode(
+                self.feed_url.encode('utf-8')).decode('utf-8').strip('=')
+
+    @staticmethod
+    def parse_token(token):
+        return base64.b64decode(
+                '{}========'.format(token).encode('utf-8')).decode('utf-8')
+
+
+
+class DBReader(object):
+
+    BASE_QUERY = '''
+        SELECT
+            i.id, i.title, i.author, f.title,
+            f.rssurl, i.url, i.pubDate, i.content,
+            i.unread
+        FROM
+            rss_item i
+        INNER JOIN rss_feed f
+            ON f.rssurl = i.feedurl
+        {where}
+            {where_cond}
+        ORDER BY
+            i.pubDate desc
+        '''
+
+    def __init__(self, db_path):
+        self.db_path = db_path
+
+    def _get_connection(self):
+        conn = sqlite3.connect(self.db_path)
+        conn.row_factory = RSSItem.from_db_row
+        return conn
+
+    def _fetch(self, where=None, params=()):
+        with self._get_connection() as con:
+            curs = con.cursor()
+            args = { 'where': '', 'where_cond': '' }
+
+            if where:
+                args.update({ 'where': 'WHERE', 'where_cond': where })
+
+            curs.execute(self.BASE_QUERY.format(**args), params)
+            return curs.fetchall()
+
+    def update_unread(self, id, unread=True):
+        with self._get_connection() as con:
+            con.execute(
+                'UPDATE rss_item SET unread = ? WHERE id = ?',
+                [1 if unread else 0, id])
+            con.commit()
+
+    def get_entry(self, id):
+        return self._fetch("i.id = ?", [id])[0]
+
+    def get_unread(self):
+        data = defaultdict(list)
+        unread = self._fetch("i.unread = ?", [1])
+
+        for record in unread:
+            data[record.feed_title].append(record)
+
+        return sorted(data.items())
+
+    def get_unread_for_feed(self, token, only_unread=False):
+        if only_unread:
+            return self._fetch("i.unread = ? AND i.feedurl = ?", [1, RSSFeed.parse_token(token)])
+        else:
+            return self._fetch("i.feedurl = ?", [RSSFeed.parse_token(token)])
+
+    def get_feeds(self):
+        with self._get_connection() as con:
+            con.row_factory = RSSFeed.from_db_row
+            curs = con.cursor()
+            curs.execute('SELECT rssurl, url, title FROM rss_feed')
+            return curs.fetchall()
+
+    def get_feed(self, token):
+        with self._get_connection() as con:
+            con.row_factory = RSSFeed.from_db_row
+            curs = con.cursor()
+            curs.execute('SELECT rssurl, url, title FROM rss_feed WHERE rssurl = ?', [RSSFeed.parse_token(token)])
+            return curs.fetchall()[0]
+
+
+def json_list(data):
+    return [i.to_json() for i in data]
+
+
+@app.route('/')
+def index():
+    reader = DBReader('../../cache.db')
+    return render_template('items.html', items=reader.get_unread())
+
+
+@app.route('/feed/')
+def feed_list():
+    reader = DBReader('../../cache.db')
+    return jsonify({ 'feeds': json_list(reader.get_feeds()) })
+
+
+@app.route('/feed/<token>')
+def feed(token):
+    reader = DBReader('../../cache.db')
+    return jsonify(reader.get_feed(token).to_json())
+
+
+@app.route('/feed/<token>/items')
+def feed_items(token):
+    reader = DBReader('../../cache.db')
+    return jsonify({ 'items': json_list(reader.get_unread_for_feed(token)) })
+
+
+@app.route('/feed/<token>/items/unread')
+def unread_feed_items(token):
+    reader = DBReader('../../cache.db')
+    return jsonify({ 'items': json_list(reader.get_unread_for_feed(token, True)) })
+
+
+@app.route("/item/<int:entry_id>", methods=["GET", "POST"])
+def item(entry_id):
+    #post read=1
+    reader = DBReader('../../cache.db')
+
+    if request.method == 'POST':
+        try:
+            read = bool(int(request.form.get('read')))
+        except:
+            return make_response('', 400)
+
+        reader.update_unread(entry_id, not read)
+        return make_response('', 204)
+    else:
+        return jsonify(reader.get_entry(entry_id).to_json())
+
+
+if __name__ == '__main__':
+    app.debug = True
+    app.run()
diff --git a/requirements.txt b/requirements.txt
new file mode 100644
index 0000000..632a1ef
--- /dev/null
+++ b/requirements.txt
@@ -0,0 +1 @@
+Flask==0.10.1
diff --git a/templates/items.html b/templates/items.html
new file mode 100644
index 0000000..093b211
--- /dev/null
+++ b/templates/items.html
@@ -0,0 +1,183 @@
+<!doctype html>
+<html class="no-js" lang="">
+    <head>
+        <title>RSS Reader</title>
+        <meta name="viewport" content="width=device-width, initial-scale=1">
+        <style type="text/css">
+            body {
+                font: 12px Georgia,serif;
+            }
+
+            .entries li {
+                position: relative;
+                list-style: none;
+                border: 1px solid #999;
+                margin: 0.5em 0;
+            }
+
+            .entries {
+                margin: 0;
+                padding: 0;
+            }
+
+            .entries a.headline {
+                display: block;
+                background: #ddd;
+                padding: 1em;
+                color: black;
+                text-decoration: none;
+                font-weight: bolder;
+            }
+
+            .entries .highlighted a.headline {
+                background-color: #FFFF99;
+            }
+
+            .entries li > input.read {
+                position: absolute;
+                top: 1em;
+                right: 1em;
+            }
+
+            .entries .content {
+                padding: 1em;
+                display: none;
+            }
+
+            h2 a.mark-all-read {
+                display: inline-block;
+                position: absolute;
+                right: 1em;
+            }
+        </style>
+
+        <script src="//code.jquery.com/jquery-2.1.1.min.js"></script>
+
+        <script type="text/javascript">
+            /**
+             * Copyright (c) 2007-2014 Ariel Flesler - aflesler<a>gmail<d>com | http://flesler.blogspot.com
+             * Licensed under MIT
+             * @author Ariel Flesler
+             * @version 1.4.12
+             */
+            ;(function(a){if(typeof define==='function'&&define.amd){define(['jquery'],a)}else{a(jQuery)}}(function($){var j=$.scrollTo=function(a,b,c){return $(window).scrollTo(a,b,c)};j.defaults={axis:'xy',duration:parseFloat($.fn.jquery)>=1.3?0:1,limit:true};j.window=function(a){return $(window)._scrollable()};$.fn._scrollable=function(){return this.map(function(){var a=this,isWin=!a.nodeName||$.inArray(a.nodeName.toLowerCase(),['iframe','#document','html','body'])!=-1;if(!isWin)return a;var b=(a.contentWindow||a).document||a.ownerDocument||a;return/webkit/i.test(navigator.userAgent)||b.compatMode=='BackCompat'?b.body:b.documentElement})};$.fn.scrollTo=function(f,g,h){if(typeof g=='object'){h=g;g=0}if(typeof h=='function')h={onAfter:h};if(f=='max')f=9e9;h=$.extend({},j.defaults,h);g=g||h.duration;h.queue=h.queue&&h.axis.length>1;if(h.queue)g/=2;h.offset=both(h.offset);h.over=both(h.over);return this._scrollable().each(function(){if(f==null)return;var d=this,$elem=$(d),targ=f,toff,attr={},win=$elem.is('html,body');switch(typeof targ){case'number':case'string':if(/^([+-]=?)?\d+(\.\d+)?(px|%)?$/.test(targ)){targ=both(targ);break}targ=win?$(targ):$(targ,this);if(!targ.length)return;case'object':if(targ.is||targ.style)toff=(targ=$(targ)).offset()}var e=$.isFunction(h.offset)&&h.offset(d,targ)||h.offset;$.each(h.axis.split(''),function(i,a){var b=a=='x'?'Left':'Top',pos=b.toLowerCase(),key='scroll'+b,old=d[key],max=j.max(d,a);if(toff){attr[key]=toff[pos]+(win?0:old-$elem.offset()[pos]);if(h.margin){attr[key]-=parseInt(targ.css('margin'+b))||0;attr[key]-=parseInt(targ.css('border'+b+'Width'))||0}attr[key]+=e[pos]||0;if(h.over[pos])attr[key]+=targ[a=='x'?'width':'height']()*h.over[pos]}else{var c=targ[pos];attr[key]=c.slice&&c.slice(-1)=='%'?parseFloat(c)/100*max:c}if(h.limit&&/^\d+$/.test(attr[key]))attr[key]=attr[key]<=0?0:Math.min(attr[key],max);if(!i&&h.queue){if(old!=attr[key])animate(h.onAfterFirst);delete attr[key]}});animate(h.onAfter);function animate(a){$elem.animate(attr,g,h.easing,a&&function(){a.call(this,targ,h)})}}).end()};j.max=function(a,b){var c=b=='x'?'Width':'Height',scroll='scroll'+c;if(!$(a).is('html,body'))return a[scroll]-$(a)[c.toLowerCase()]();var d='client'+c,html=a.ownerDocument.documentElement,body=a.ownerDocument.body;return Math.max(html[scroll],body[scroll])-Math.min(html[d],body[d])};function both(a){return $.isFunction(a)||typeof a=='object'?a:{top:a,left:a}};return j}));
+        </script>
+
+        <script type="text/javascript">
+            $(document).ready(function() {
+                $("a.headline").on("click", function(event) {
+                    event.preventDefault();
+                    var target = $(event.target);
+                    target.off("click");
+                    $.ajax(target.parents("li").attr("data-url")).done(function(data) {
+                        if (data.no_content) {
+                            var win = window.open(data.url, "_blank");
+                            if (!win) {
+                                alert("Popups are blocked");
+                            }
+                        } else {
+                            var contentArea = target.siblings("div.content");
+                            contentArea.append(data.content);
+                            contentArea.show();
+                        }
+                        target.parents("li").attr("data-target-url", data.url);
+                        target.siblings("input[type=checkbox]").attr("checked", true);
+                        target.siblings("input[type=checkbox]").trigger("change");
+                    });
+                    return false;
+                });
+
+                $("a.headline").on("mark-read", function(event) {
+                    var box = $(event.target).next("input[type=checkbox]");
+                    box.attr("checked", !box.is(":checked"));
+                    box.trigger("change");
+                });
+
+                $(".entries li > input[type=checkbox]").on("change", function(event) {
+                    var value = $(event.target).is(':checked') ? 1 : 0;
+                    $.ajax($(event.target).parents("li").attr("data-url"), {
+                        data: { read: value },
+                        type: "POST"
+                    });
+                });
+
+                $("h2 a.mark-all-read").on("click", function(event) {
+                    event.preventDefault();
+
+                    $(event.target).parents(".feed").find("a.headline").each(function(idx, box) {
+                        $(box).trigger("mark-read");
+                    });
+
+                    return false;
+                });
+
+                $(document).on("keydown", function(event) {
+                    var element = $(".entries .highlighted");
+
+                    switch (event.keyCode) {
+                        case 74: // J
+                            element.removeClass("highlighted");
+
+                            if (element.length == 0) {
+                                $(".entries li:first-child").first().addClass("highlighted");
+                            } else {
+                                var next = element.next("li");
+                                if (next.length != 1) {
+                                    element.parents(".feed").next(".feed").find("li").first().addClass("highlighted");
+                                } else {
+                                    next.addClass("highlighted");
+                                }
+                            }
+
+                            $.scrollTo(".highlighted", { margin: true, offset: -50 });
+                        break;
+                        case 75: // K
+                            element.removeClass("highlighted");
+
+                            if (element.length == 0) {
+                                $(".entries li:first-child").first().addClass("highlighted");
+                            } else {
+                                var prev = element.prev("li");
+                                if (prev.length != 1) {
+                                    element.parents(".feed").prev(".feed").find("li").last().addClass("highlighted");
+                                } else {
+                                    prev.addClass("highlighted");
+                                }
+                            }
+
+                            $.scrollTo(".highlighted", { margin: true, offset: -50 });
+                        break;
+                        case 79: // O
+                            var target = $(element).attr("data-target-url");
+                            if (target) {
+                                window.open(target, "_blank");
+                            } else {
+                                element.find("a.headline").trigger("click");
+                            }
+                        break;
+                        case 82: // R
+                            element.find("a.headline").trigger("mark-read");
+                        break;
+                    }
+                });
+            });
+        </script>
+    </head>
+    <body>
+        <h1>RSS Entries</h1>
+        {% for feed, records in items %}
+        <div class="feed">
+            <h2>{{ feed }} <a href="#" class="mark-all-read">Mark All Read</a></h2>
+            <ul class="entries">
+                {% for record in records %}
+                <li data-url="{{ record.self_link }}" >
+                <a class="headline" href="{{ record.url }}">{{ record.title }}</a>
+                <input type="checkbox" class="read" />
+                <div class="content"></div>
+                </li>
+                {% endfor %}
+            </ul>
+        </div>
+        {% endfor %}
+    </body>
+</html>