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