aboutsummaryrefslogtreecommitdiff
path: root/pyAggr3g470r.py
diff options
context:
space:
mode:
authorcedricbonhomme <devnull@localhost>2010-03-22 22:36:34 +0100
committercedricbonhomme <devnull@localhost>2010-03-22 22:36:34 +0100
commit3aa4143dee58eb21d224ec69ce232612ddd38ce5 (patch)
tree3cbe18167b4bb73952f6d76ace0965e6cbeeb41f /pyAggr3g470r.py
parentThe database of feeds is monitored with the Python gamin module. (diff)
downloadnewspipe-3aa4143dee58eb21d224ec69ce232612ddd38ce5.tar.gz
newspipe-3aa4143dee58eb21d224ec69ce232612ddd38ce5.tar.bz2
newspipe-3aa4143dee58eb21d224ec69ce232612ddd38ce5.zip
Added: email notification of new articles.
Diffstat (limited to 'pyAggr3g470r.py')
-rwxr-xr-x[-rw-r--r--]pyAggr3g470r.py79
1 files changed, 52 insertions, 27 deletions
diff --git a/pyAggr3g470r.py b/pyAggr3g470r.py
index ed52f67f..fc5bce84 100644..100755
--- a/pyAggr3g470r.py
+++ b/pyAggr3g470r.py
@@ -12,38 +12,32 @@ import time
import sqlite3
import cherrypy
import threading
-import ConfigParser
from cherrypy.lib.static import serve_file
import utils
import feedgetter
-config = ConfigParser.RawConfigParser()
-config.read("./cfg/pyAggr3g470r.cfg")
-path = config.get('global','path')
-sqlite_base = os.path.abspath(config.get('global', 'sqlitebase'))
-
bindhost = "0.0.0.0"
cherrypy.config.update({ 'server.socket_port': 12556, 'server.socket_host': bindhost})
path = {'/css/style.css': {'tools.staticfile.on': True, \
- 'tools.staticfile.filename':path+'css/style.css'}, \
+ 'tools.staticfile.filename':utils.path+'css/style.css'}, \
'/css/img/feed-icon-28x28.png': {'tools.staticfile.on': True, \
- 'tools.staticfile.filename':path+'css/img/feed-icon-28x28.png'}, \
+ 'tools.staticfile.filename':utils.path+'css/img/feed-icon-28x28.png'}, \
'/css/img/delicious.png': {'tools.staticfile.on': True, \
- 'tools.staticfile.filename':path+'css/img/delicious.png'}, \
+ 'tools.staticfile.filename':utils.path+'css/img/delicious.png'}, \
'/css/img/digg.png': {'tools.staticfile.on': True, \
- 'tools.staticfile.filename':path+'css/img/digg.png'}, \
+ 'tools.staticfile.filename':utils.path+'css/img/digg.png'}, \
'/css/img/reddit.png': {'tools.staticfile.on': True, \
- 'tools.staticfile.filename':path+'css/img/reddit.png'}, \
+ 'tools.staticfile.filename':utils.path+'css/img/reddit.png'}, \
'/css/img/scoopeo.png': {'tools.staticfile.on': True, \
- 'tools.staticfile.filename':path+'css/img/scoopeo.png'}, \
+ 'tools.staticfile.filename':utils.path+'css/img/scoopeo.png'}, \
'/css/img/blogmarks.png': {'tools.staticfile.on': True, \
- 'tools.staticfile.filename':path+'css/img/blogmarks.png'}, \
+ 'tools.staticfile.filename':utils.path+'css/img/blogmarks.png'}, \
'/var/histogram.png':{'tools.staticfile.on': True, \
- 'tools.staticfile.filename':path+'var/histogram.png'}}
+ 'tools.staticfile.filename':utils.path+'var/histogram.png'}}
htmlheader = '<html xmlns="http://www.w3.org/1999/xhtml" xml:lang="en" lang="en">\n' + \
'<head>' + \
@@ -119,6 +113,10 @@ class Root:
html += "<br />\n"
html += """<a href="/all_articles/%s">All articles</a>""" % (rss_feed_id,)
+ if self.feeds[rss_feed_id][6] == "0":
+ html += """ <a href="/tuned/start:%s">Stay tuned</a>""" % (rss_feed_id,)
+ else:
+ html += """ <a href="/tuned/stop:%s">Stop staying tuned</a>""" % (rss_feed_id,)
html += """ <a href="/mark_as_read/Feed_FromMainPage:%s">Mark all as read</a>""" % (rss_feed_id,)
if self.feeds[rss_feed_id][1] != 0:
html += """ <a href="/unread/%s" title="Unread article(s)"
@@ -155,7 +153,7 @@ class Root:
<a href="/unread/All">%s unread article(s)</a>.<br />""" % \
(self.nb_articles, sum([feed[1] for feed in self.feeds.values()]))
html += """Database: %s.\n<br />Size: %s bytes.</p>\n""" % \
- (os.path.abspath(sqlite_base), os.path.getsize(sqlite_base))
+ (os.path.abspath(utils.sqlite_base), os.path.getsize(utils.sqlite_base))
html += """<form method=get action="/fetch/">\n<input
type="submit" value="Fetch all feeds"></form>\n"""
@@ -525,7 +523,7 @@ class Root:
LOCKER.acquire()
param, _, identifiant = target.partition(':')
try:
- conn = sqlite3.connect(sqlite_base, isolation_level = None)
+ conn = sqlite3.connect(utils.sqlite_base, isolation_level = None)
c = conn.cursor()
# Mark all articles as read.
if param == "All":
@@ -554,6 +552,33 @@ class Root:
mark_as_read.exposed = True
+ def tuned(self, param):
+ """
+ """
+ try:
+ action, feed_id = param.split(':')
+ except:
+ return self.error_page("Bad URL")
+ conn = sqlite3.connect(utils.sqlite_base, isolation_level = None)
+ c = conn.cursor()
+ if action == "start":
+ try:
+ c.execute("UPDATE feeds SET mail=1 WHERE feed_site_link='" +
+ self.feeds[feed_id][5].encode('utf-8') + "'")
+ except:
+ pass
+ else:
+ try:
+ c.execute("UPDATE feeds SET mail=0 WHERE feed_site_link='" +
+ self.feeds[feed_id][5].encode('utf-8') + "'")
+ except:
+ pass
+ conn.commit()
+ c.close()
+
+ tuned.exposed = True
+
+
def update(self, path=None, event = None):
"""
Synchronizes transient objects with the database,
@@ -566,9 +591,9 @@ class Root:
self.top_words = utils.top_words(self.articles, 10)
if "pylab" not in utils.IMPORT_ERROR:
utils.create_histogram(self.top_words)
- print "Base (%s) loaded" % sqlite_base
+ print "Base (%s) loaded" % utils.sqlite_base
else:
- print "Base (%s) empty!" % sqlite_base
+ print "Base (%s) empty!" % utils.sqlite_base
def watch_base(self):
@@ -578,15 +603,15 @@ class Root:
When a change is detected, reload the base.
"""
mon = gamin.WatchMonitor()
- mon.watch_file(sqlite_base, self.update)
+ mon.watch_file(utils.sqlite_base, self.update)
time.sleep(10)
ret = mon.event_pending()
try:
- print "Watching %s" % sqlite_base
+ print "Watching %s" % utils.sqlite_base
while True:
ret = mon.event_pending()
if ret > 0:
- print "The base of feeds (%s) has changed.\nReloading..." % sqlite_base
+ print "The base of feeds (%s) has changed.\nReloading..." % utils.sqlite_base
ret = mon.handle_one_event()
time.sleep(2)
except KeyboardInterrupt:
@@ -603,17 +628,17 @@ class Root:
"""
old_size = 0
try:
- print "Watching %s" % sqlite_base
+ print "Watching %s" % utils.sqlite_base
while True:
time.sleep(5)
# very simple test
- if os.path.getsize(sqlite_base) != old_size:
- print "The base of feeds (%s) has changed.\nReloading..." % sqlite_base
+ if os.path.getsize(utils.sqlite_base) != old_size:
+ print "The base of feeds (%s) has changed.\nReloading..." % utils.sqlite_base
self.update()
- old_size = os.path.getsize(sqlite_base)
+ old_size = os.path.getsize(utils.sqlite_base)
except KeyboardInterrupt:
pass
- print "Stop watching", sqlite_base
+ print "Stop watching", utils.sqlite_base
if __name__ == '__main__':
@@ -626,7 +651,7 @@ if __name__ == '__main__':
thread_watch_base = threading.Thread(None, root.watch_base, None, ())
except:
print "The gamin module is not installed."
- print "The base of feeds will be monitored"
+ print "The base of feeds will be monitored with the simple method."
thread_watch_base = threading.Thread(None, root.watch_base_classic, None, ())
thread_watch_base.setDaemon(True)
thread_watch_base.start()
bgstack15