X-Git-Url: http://git.kaliko.me/?a=blobdiff_plain;f=sima%2Fcore.py;h=ad21db6f16da571b46d7f8b7ac68253c04421f7c;hb=e09e76d41b2f041de935e9e884009e3187005ab9;hp=2d8b960b23e876351a9e234358028d0951f81f2b;hpb=c1bda032095902bdcd183c530a9c4de28f3c828a;p=mpd-sima.git diff --git a/sima/core.py b/sima/core.py index 2d8b960..ad21db6 100644 --- a/sima/core.py +++ b/sima/core.py @@ -26,13 +26,20 @@ class Sima(object): self.sdb = SimaDB(db_path=dbfile) self.log = getLogger('sima') self.plugins = list() - self.player = PlayerClient() # Player client + self.player = self._get_player() # Player client try: self.player.connect() except (PlayerError, PlayerUnHandledError) as err: self.log.error('Fails to connect player: {}'.format(err)) self.shutdown() - self.short_history = deque(maxlen=40) + self.short_history = deque(maxlen=60) + + def _get_player(self): + """Instanciate the player""" + host = self.config.get('MPD', 'host') + port = self.config.get('MPD', 'port') + pswd = self.config.get('MPD', 'password', fallback=None) + return PlayerClient(host, port, pswd) def add_history(self): self.short_history.appendleft(self.player.current) @@ -65,6 +72,13 @@ class Sima(object): pl_callback = getattr(plugin, 'callback_need_track')() if pl_callback: to_add.extend(pl_callback) + if not to_add: + self.log.warning('Queue plugins returned anything!') + for plugin in self.plugins: + self.log.info('calling fb for {}'.format(plugin)) + pl_callback = getattr(plugin, 'callback_need_track_fb')() + if pl_callback: + to_add.extend(pl_callback) for track in to_add: self.player.add(track)