X-Git-Url: https://git.kaliko.me/?a=blobdiff_plain;f=sima%2Fcore.py;h=e3bde2c6abfec4b43d2034ff8d46f5dd2a75691d;hb=3232d76fccc3b431bd42a34a5f182667efa346d0;hp=2d8b960b23e876351a9e234358028d0951f81f2b;hpb=c1bda032095902bdcd183c530a9c4de28f3c828a;p=mpd-sima.git diff --git a/sima/core.py b/sima/core.py index 2d8b960..e3bde2c 100644 --- a/sima/core.py +++ b/sima/core.py @@ -20,19 +20,26 @@ class Sima(object): """Main class, plugin and player management """ - def __init__(self, conf, dbfile): + def __init__(self, conf): self.enabled = True self.config = conf - self.sdb = SimaDB(db_path=dbfile) + self.sdb = SimaDB(db_path=conf.get('sima', 'db_file')) 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)