diff finch/libgnt/pygnt/example/rss/gntrss.py @ 18681:ef15236a0866

A proof-of-conecpt RSS reader using pygnt.

--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/finch/libgnt/pygnt/example/rss/gntrss.py	Sat Jul 28 11:30:54 2007 +0000
@@ -0,0 +1,164 @@
+#!/usr/bin/env python
+
+# A very simple and stupid RSS reader
+#
+# Uses the Universal Feed Parser
+#
+
+import threading
+import feedparser
+import gobject
+import sys
+import time
+
+##
+# The FeedItem class. It will update emit 'delete' signal when it's
+# destroyed.
+##
+class FeedItem(gobject.GObject):
+    __gproperties__ = {
+        'unread' : (gobject.TYPE_BOOLEAN, 'read',
+            'The unread state of the item.',
+            False, gobject.PARAM_READWRITE)
+    }
+    __gsignals__ = {
+        'delete' : (gobject.SIGNAL_RUN_LAST, gobject.TYPE_NONE, (gobject.TYPE_OBJECT,))
+    }
+    def __init__(self, item, parent):
+        self.__gobject_init__()
+        self.date = item['date']
+        self.date_parsed = item['date_parsed']
+        self.title = item['title']
+        self.summary = item['summary']
+        self.link = item['link']
+        self.parent = parent
+        self.unread = True
+
+    def remove(self):
+        self.emit('delete', self.parent)
+
+    def do_set_property(self, property, value):
+        if property.name == 'unread':
+            self.unread = value
+
+gobject.type_register(FeedItem)
+
+def item_hash(item):
+    return str(item['date'] + item['title'])
+
+##
+# The Feed class. It will update the 'link', 'title', 'desc' and 'items'
+# attributes if/when they are updated (triggering 'notify::<attr>' signal)
+##
+class Feed(gobject.GObject):
+    __gproperties__ = {
+        'link' : (gobject.TYPE_STRING, 'link',
+            'The web page this feed is associated with.',
+            '...', gobject.PARAM_READWRITE),
+        'title' : (gobject.TYPE_STRING, 'title',
+            'The title of the feed.',
+            '...', gobject.PARAM_READWRITE),
+        'desc' : (gobject.TYPE_STRING, 'description',
+            'The description for the feed.',
+            '...', gobject.PARAM_READWRITE),
+        'items' : (gobject.TYPE_POINTER, 'items',
+            'The items in the feed.', gobject.PARAM_READWRITE),
+        'unread' : (gobject.TYPE_INT, 'unread',
+            'Number of unread items in the feed.', 0, 10000, 0, gobject.PARAM_READWRITE)
+    }
+    __gsignals__ = {
+        'added' : (gobject.SIGNAL_RUN_LAST, gobject.TYPE_NONE, (gobject.TYPE_OBJECT,))
+    }
+
+    def __init__(self, url):
+        self.__gobject_init__()
+        self.url = url           # The url of the feed itself
+        self.link = url          # The web page associated with the feed
+        self.desc = url
+        self.title = url
+        self.unread = 0
+        self.timer = 0
+        self.items = []
+        self.hash = {}
+
+    def do_set_property(self, property, value):
+        if property.name == 'link':
+            self.link = value
+        elif property.name == 'desc':
+            self.desc = value
+        elif property.name == 'title':
+            self.title = value
+        elif property.name == 'unread':
+            self.unread = value
+        pass
+
+    def check_thread_for_death(self):
+        #if self.thread.running:
+        #    sys.stderr.write(time.ctime() + "continue")
+        #    return True
+        # The thread has ended!!
+        #result = self.thread.result
+        #self.thread = None
+        result = feedparser.parse(self.url)
+        channel = result['channel']
+        self.set_property('link', channel['link'])
+        self.set_property('desc', channel['description'])
+        self.set_property('title', channel['title'])
+        self.set_property('unread', len(result['items']))
+        self.timer = 0
+        items = result['items']
+        tmp = {}
+        for item in self.items:
+            tmp[hash(item)] = item
+
+        for item in items:
+            try:
+                exist = self.hash[item_hash(item)]
+                del tmp[hash(exist)]
+            except:
+                itm = FeedItem(item, self)
+                self.items.append(itm)
+                self.emit('added', itm)
+                self.hash[item_hash(item)] = itm
+        for hv in tmp:
+            tmp[hv].remove()
+
+        return False
+
+    def refresh(self):
+        #if self.thread == 0:
+        #   self.thread = FeedReader(self)
+        #   self.thread.start()
+        if self.timer == 0:
+            self.timer = gobject.timeout_add(1000, self.check_thread_for_death)
+
+gobject.type_register(Feed)
+
+##
+# A FeedReader class, which is threaded to make sure it doesn't freeze the ui
+# (this thing doesn't quite work ... yet)
+##
+class FeedReader(threading.Thread):
+    def __init__(self, feed):
+        self.feed = feed
+        self.running = True
+        threading.Thread.__init__(self)
+
+    def run(self):
+        sys.stderr.write(str(time.ctime()) + " STARTED!!!\n\n\n")
+        self.running = True
+        self.result = feedparser.parse(self.feed.url)
+        self.running = False
+        sys.stderr.write(str(time.ctime()) + " DONE!!!\n\n\n")
+
+feeds = []
+urls = ("http://rss.slashdot.org/Slashdot/slashdot",
+        "http://www.python.org/channews.rdf",
+        "http://pidgin.im/rss.php",
+        "./rss.php"
+        )
+
+for url in urls:
+    feed = Feed(url)
+    feeds.append(feed)
+