this repo has no description
1class FeedManager:
2 def __init__(self):
3 self.feeds = {}
4
5 def register(self, feed):
6 self.feeds[feed.FEED_URI] = feed()
7
8 def process_commit(self, commit):
9 for feed in self.feeds.values():
10 feed.process_commit(commit)
11
12 def serve_feed(self, feed_uri, limit, offset, langs):
13 feed = self.feeds.get(feed_uri)
14 if feed is not None:
15 return feed.serve_feed(limit, offset, langs)
16
17 def serve_feed_debug(self, feed_uri, limit, offset, langs):
18 feed = self.feeds.get(feed_uri)
19 if feed is not None:
20 return feed.serve_feed_debug(limit, offset, langs)
21
22 def run_tasks_minute(self):
23 for feed in self.feeds.values():
24 feed.run_tasks_minute()