|
@ -170,16 +170,15 @@ class RSSQueue: |
|
|
""" Run the query for one URI and apply filters """ |
|
|
""" Run the query for one URI and apply filters """ |
|
|
self.shutdown = False |
|
|
self.shutdown = False |
|
|
|
|
|
|
|
|
def dup_title(fd, title): |
|
|
def dup_title(title): |
|
|
for f in self.jobs: |
|
|
title = title.lower() |
|
|
if f == fd: |
|
|
for fd in self.jobs: |
|
|
for lk in self.jobs[fd]: |
|
|
for lk in self.jobs[fd]: |
|
|
item = self.jobs[fd][lk] |
|
|
item = self.jobs[fd][lk] |
|
|
if item.get('status', ' ')[0] == 'D' and \ |
|
|
if item.get('status', ' ')[0] == 'D' and \ |
|
|
item.get('title', '').lower() == title.lower(): |
|
|
item.get('title', '').lower() == title: |
|
|
return True |
|
|
return True |
|
|
return False |
|
|
return False |
|
|
return False |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if not feed: |
|
|
if not feed: |
|
@ -277,7 +276,7 @@ class RSSQueue: |
|
|
|
|
|
|
|
|
newlinks.append(link) |
|
|
newlinks.append(link) |
|
|
|
|
|
|
|
|
if cfg.no_dupes() and dup_title(feed, title): |
|
|
if cfg.no_dupes() and dup_title(title): |
|
|
logging.info("Ignoring duplicate job %s", atitle) |
|
|
logging.info("Ignoring duplicate job %s", atitle) |
|
|
continue |
|
|
continue |
|
|
|
|
|
|
|
@ -421,7 +420,7 @@ class RSSQueue: |
|
|
lst = self.jobs[feed] |
|
|
lst = self.jobs[feed] |
|
|
for link in lst: |
|
|
for link in lst: |
|
|
if lst[link].get('url', '') == id: |
|
|
if lst[link].get('url', '') == id: |
|
|
lst[link]['time'] = 'D' |
|
|
lst[link]['status'] = 'D' |
|
|
|
|
|
|
|
|
@synchronized(LOCK) |
|
|
@synchronized(LOCK) |
|
|
def clear_feed(self, feed): |
|
|
def clear_feed(self, feed): |
|
|