From: André L. V. Loureiro <loureiro.andrew@gmail.com>
Date: Fri, 29 May 2009 23:23:13 +0000 (-0400)
Subject: Merge
X-Git-Url: https://vcs.maemo.org/git/?p=zukebox;a=commitdiff_plain;h=cd91982a7568cb4ccbbff082a63017bc17c88e51

Merge
---

diff --git a/zukebox_server/src/server/zb_server.py~HEAD~7 b/zukebox_server/src/server/zb_server.py~HEAD~7
new file mode 100644
index 0000000..c1f16ea
--- /dev/null
+++ b/zukebox_server/src/server/zb_server.py~HEAD~7
@@ -0,0 +1,120 @@
+
+from ziface import ZIface
+import dbus.service
+import dbus.mainloop.glib
+import os
+
+from brisa.core.reactors import GLib2Reactor
+reactor = GLib2Reactor()
+
+from brisa.core import log
+from brisa.core import config
+from brisa.upnp.device import Device
+from brisa.upnp.services.cds import ContentDirectory
+from brisa.upnp.services.connmgr import ConnectionManagerServer
+
+from zukebox_server.services.playlist.zb_playlist import PlayList
+
+dbus.mainloop.glib.DBusGMainLoop(set_as_default=True)
+
+class ZukeBoxServer(ZIface, dbus.service.Object):
+    """
+    Introduction
+    ============
+    ZukeBox is an abstraction for a JukeBox.
+    How works?
+        In a JukeBox somebody pay and choose a song for play, this way the
+    JukeBox should have default set of songs. ZukeBox has the same idea,
+    except for payment ;) , you can choose a song availble in the server 
+    called ZukeBox Server or send a request for server to play your music, 
+    
+    Thus the clientes should be scan the network and get services availble 
+    in ZukeBox Server.
+    Services availble are:
+        1. Show the songs availble in the ZukeBox Server.
+        2. Play a song availble.
+        3. Play a song sent by a control point.
+    Some services will be availble too throught dbus.service a method for 
+    rescan the default paths and save in the database.
+    """
+
+    DBUS_SERVICE_NAME = "br.org.zagaia"
+    DBUS_OBJ_PATH = "/br/org/zagaia/ZukeBox"
+    DBUS_IFACE = "br.org.zagaia.ZukeBox"
+
+    plugins_folder = config.get_parameter("zukebox_server", "plugins")
+    plugins_module_path = "zukebox_server.plugins"
+
+    def __init__(self, _server_name, _listen_url):
+        """ ZukeBox Server Construct
+        @param _server_name: Name of the ZukeBox Server
+        @param _listen_url: url to listen for requests
+
+        @type _server_name: string
+        @type _listen_url: string
+        """
+        ZIface.__init__(self)
+        bus = dbus.SessionBus()
+        busname = dbus.service.BusName(self.DBUS_SERVICE_NAME, bus=bus)
+
+        dbus.service.Object.__init__(self, busname, self.DBUS_OBJ_PATH)
+        self.server_name = _server_name
+        self.listen_url = _listen_url
+        self.device = None
+        self.cds = None
+
+    def _create_device(self):
+        model_name = "ZukeBox Server version 0.1"
+        project_page = "http://portal.fucapi.edu.br/nepcomp/zagaia"
+        serial_no = '0000010'
+        model_description = 'A UPnP Audio Server for ZukeBox'
+
+        self.device = Device('urn:schemas-upnp-org:device:ZukeBoxServer:1',
+                self.server_name, force_listen_url=self.listen_url,
+                manufacturer="Zagaia Laboratory and INdT Brazil",
+                manufacturer_url=project_page,
+                model_description=model_description,
+                model_name=model_name, model_number=serial_no,
+                model_url=project_page, serial_number=serial_no)
+
+    def _create_services(self):
+        self.cds = ContentDirectory(self.plugins_folder,
+                self.plugins_module_path)
+        cm = ConnectionManagerServer()
+        mod_path = config.get_parameter("zukebox_server", "home")
+        x_path = os.path.join(mod_path, "xml_descriptions")
+        print x_path
+        playlist = PlayList(positions=10, xml_path=x_path)
+
+        self.device.add_service(self.cds)
+        self.device.add_service(cm)
+        self.device.add_service(playlist)
+
+    def start(self):
+        """Start the ZukeBox Server"""
+        self._create_device()
+        self._create_services()
+        self.device.start()
+        reactor.add_after_stop_func(self.device.stop)
+        reactor.main()
+
+    # DBUS
+    @dbus.service.method(DBUS_IFACE)
+    def halt(self):
+        reactor.main_quit()
+
+    @dbus.service.method(DBUS_IFACE)
+    def rescan_audio_folder(self):
+        if not self.cds:
+            return
+        pm = self.cds.control_controller.plugin_manager
+        if not "audio_library" in pm.plugins_instances:
+            return
+        pm.plugins_instances["audio_library"].process_audio_folder()
+
+    @dbus.service.method(DBUS_IFACE)
+    def reload_config(self):
+        config.manager.update()
+
+
+