this repo has no description
edavis.dev
1from feeds.popular import PopularFeed
2from feeds.rapidfire import RapidFireFeed
3
4class FeedManager:
5 def __init__(self):
6 self.feeds = {}
7
8 def register(self, feed):
9 self.feeds[feed.FEED_URI] = feed()
10
11 def process_commit(self, commit):
12 for feed in self.feeds.values():
13 feed.process_commit(commit)
14
15 def serve_feed(self, feed_uri, limit, offset, langs):
16 feed = self.feeds.get(feed_uri)
17 if feed is not None:
18 return feed.serve_feed(limit, offset, langs)
19
20 def serve_feed_debug(self, feed_uri, limit, offset, langs):
21 feed = self.feeds.get(feed_uri)
22 if feed is not None:
23 return feed.serve_feed_debug(limit, offset, langs)
24
25 def run_tasks_minute(self):
26 for feed in self.feeds.values():
27 feed.run_tasks_minute()
28
29
30manager = FeedManager()
31# manager.register(PopularFeed)
32manager.register(RapidFireFeed)