aboutsummaryrefslogtreecommitdiff
path: root/feedgetter.py
diff options
context:
space:
mode:
Diffstat (limited to 'feedgetter.py')
-rwxr-xr-xfeedgetter.py77
1 files changed, 36 insertions, 41 deletions
diff --git a/feedgetter.py b/feedgetter.py
index aa463b7d..cc4fb5ca 100755
--- a/feedgetter.py
+++ b/feedgetter.py
@@ -35,6 +35,7 @@ from BeautifulSoup import BeautifulSoup
from datetime import datetime
import utils
+import mongodb
feeds_list = []
list_of_threads = []
@@ -53,6 +54,9 @@ class FeedGetter(object):
# Create the base if not exists.
utils.create_base()
+ # MongoDB connections
+ self.articles = mongodb.Articles()
+
# mutex to protect the SQLite base
self.locker = threading.Lock()
@@ -113,16 +117,18 @@ class FeedGetter(object):
feed_image = a_feed.feed.image.href
except:
feed_image = "/img/feed-icon-28x28.png"
- try:
- self.c.execute('insert into feeds values (?,?,?,?,?)', (\
- utils.clear_string(a_feed.feed.title.encode('utf-8')), \
- a_feed.feed.link.encode('utf-8'), \
- feed_link, \
- feed_image,
- "0"))
- except sqlite3.IntegrityError:
- # feed already in the base
- pass
+
+ collection_dic = {"collection_id": feed_link,\
+ "feed_image": feed_image, \
+ "feed_title": utils.clear_string(a_feed.feed.title.encode('utf-8')), \
+ "feed_link": feed_link, \
+ "site_title": a_feed.feed.link.encode('utf-8'), \
+ "mail": False \
+ }
+
+ self.articles.add_collection(collection_dic)
+
+ articles = []
for article in a_feed['entries']:
description = ""
try:
@@ -142,37 +148,26 @@ class FeedGetter(object):
except:
post_date = datetime(*article.published_parsed[:6])
- try:
- # try. Will only success if the article is not already in the data base
- self.c.execute('insert into articles values (?, ?, ?, ?, ?, ?, ?)', (\
- post_date, \
- article_title, \
- article.link.encode('utf-8'), \
- description, \
- "0", \
- feed_link, \
- "0"))
- result = self.c.execute("SELECT mail from feeds WHERE feed_site_link='" + \
- a_feed.feed.link.encode('utf-8') + "'").fetchall()
- if result[0][0] == "1":
- # if subscribed to the current feed
- # send the article by e-mail
- try:
- threading.Thread(None, utils.send_mail, None, (utils.mail_from, utils.mail_to, \
- a_feed.feed.title.encode('utf-8'), \
- article_title, description) \
- ).start()
- except Exception, e:
- # SMTP acces denied, to many SMTP connections, etc.
- top = traceback.extract_stack()[-1]
- print ", ".join([type(e).__name__, os.path.basename(top[0]), str(top[1])])
- except sqlite3.IntegrityError:
- # article already in the data base
- pass
- except Exception, e:
- # Missing information (updated_parsed, ...)
- top = traceback.extract_stack()[-1]
- print ", ".join([type(e).__name__, os.path.basename(top[0]), str(top[1]), str(traceback.extract_stack()[-2][3])])
+
+ article = {"article_id": article.link.encode('utf-8'), \
+ "article_date": post_date, \
+ "article_link": article.link.encode('utf-8'), \
+ "article_title": article_title, \
+ "article_content": description, \
+ "article_readed": False, \
+ "article_like": False \
+ }
+
+ articles.append(article)
+
+ self.articles.add_articles(articles, feed_link)
+
+ # send new articles by e-mail if desired.
+ #threading.Thread(None, utils.send_mail, None, (utils.mail_from, utils.mail_to, \
+ #a_feed.feed.title.encode('utf-8'), \
+ #article_title, description) \
+ #).start()
+
if __name__ == "__main__":
bgstack15