public-mirrors/NewsBlur-viq
1
0
Fork 0
mirror of https://github.com/viq/NewsBlur.git synced 2025-09-18 21:43:31 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Undoing all idomatic read preferences.

Browse source
This commit is contained in:
Samuel Clay 2013-05-31 23:03:58 -07:00
parent 3dd09e4c4b
commit dc3abdc839
1 changed files with 10 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

23
apps/rss_feeds/models.py
View file

@ -1800,14 +1800,12 @@ class MFetchHistory(mongo.Document):
@classmethod
def feed(cls, feed_id, timezone=None, fetch_history=None):
params = dict(feed_id=feed_id, read_preference=pymongo.ReadPreference.PRIMARY)
if not fetch_history:
fetch_history = cls.objects.filter(feed_id=feed_id).limit(1)\
.read_preference(pymongo.ReadPreference.PRIMARY)
if not fetch_history:
fetch_history = cls.objects.create(feed_id=feed_id)
else:
fetch_history = fetch_history[0]
try:
fetch_history = cls.objects.get(**params)
except cls.DoesNotExist:
fetch_history = cls.objects.create(**params)
history = {}
for fetch_type in ['feed_fetch_history', 'page_fetch_history', 'push_history']:
@ -1828,12 +1826,11 @@ class MFetchHistory(mongo.Document):
def add(cls, feed_id, fetch_type, date=None, message=None, code=None, exception=None):
if not date:
date = datetime.datetime.now()
fetch_history = cls.objects.filter(feed_id=feed_id).limit(1)\
.read_preference(pymongo.ReadPreference.PRIMARY)
if not fetch_history:
fetch_history = cls.objects.create(feed_id=feed_id)
else:
fetch_history = fetch_history[0]
params = dict(feed_id=feed_id, read_preference=pymongo.ReadPreference.PRIMARY)
try:
fetch_history = cls.objects.get(**params)
except cls.DoesNotExist:
fetch_history = cls.objects.create(**params)
if fetch_type == 'feed':
history = fetch_history.feed_fetch_history or []
elif fetch_type == 'page':