fist player content core

requirements.txt

@@ -14,6 +14,8 @@ requests
 eyed3
 # For the publisher event reactor loop:
 tornado
+# for collecting audiofiles
+pyyaml
 
 # RPi's GPIO packages: these are installed via APT on the PI
 # On regular machines, install them manually if needed for development

src/jukebox/components/playern/core/player_content.py

@@ -0,0 +1,34 @@
+import logging
+import yaml
+
+import jukebox.plugs as plugin
+import jukebox.cfghandler
+
+logger = logging.getLogger('jb.player_content')
+cfg = jukebox.cfghandler.get_handler('jukebox')
+
+
+class PlayerData:
+
+    def __init__(self):
+        self.audiofile = cfg.setndefault('players', 'content', 'audiofile', value='../../shared/audio/audiofiles.yaml')
+        self._database = {'audio': [],
+                          'podcasts': [],
+                          'livestreams': []}
+        self._fill_database(self.audiofile)
+
+    def _fill_database(self, yaml_file):
+        with open(yaml_file, 'r') as stream:
+            try:
+                self._database = yaml.safe_load(stream)
+                logger.debug("audiofiles database read")
+            except yaml.YAMLError as err:
+                logger.error(f"Error occured while reading {yaml_file}: {err}")
+
+    @plugin.tag
+    def read_player_content(self, content_type):
+        return self._database.get(content_type, "empty")
+
+    @plugin.tag
+    def get_location_of_file(self, filename):
+        [v.get('x', None) for v in self._database.values()]

src/jukebox/components/playern/plugin/__init__.py

@@ -10,6 +10,7 @@
 import jukebox.cfghandler
 from components.playern.backends.mpd.interfacing_mpd import MPDBackend
 from components.playern.core import PlayerCtrl
+from components.playern.core.player_content import PlayerData
 from components.playern.core.player_status import PlayerStatus
 
 logger = logging.getLogger('jb.player')
@@ -64,6 +65,8 @@ def init():
     player_status = PlayerStatus()
     player_status.publish()
 
+    player_content = PlayerData()
+
     # Create and register the players (this is explicit for the moment)
     register_mpd()