From: Luiz Augusto von Dentz <luiz.von.dentz@xxxxxxxxx>
This adds an example of registering a player with use of
RegisterApplication.
---
test/example-player | 203 ++++++++++++++++++++++++++++++++++++++++++++
1 file changed, 203 insertions(+)
create mode 100644 test/example-player
diff --git a/test/example-player b/test/example-player
new file mode 100644
index 000000000..2beb08e44
--- /dev/null
+++ b/test/example-player
@@ -0,0 +1,203 @@
+#!/usr/bin/python
+
+from __future__ import print_function
+
+import os
+import sys
+import dbus
+import dbus.service
+import dbus.mainloop.glib
+try:
+ from gi.repository import GObject
+except ImportError:
+ import gobject as GObject
+import bluezutils
+
+PLAYER_IFACE = 'org.mpris.MediaPlayer2.Player'
+DBUS_OM_IFACE = 'org.freedesktop.DBus.ObjectManager'
+DBUS_PROP_IFACE = 'org.freedesktop.DBus.Properties'
+
+class InvalidArgsException(dbus.exceptions.DBusException):
+ _dbus_error_name = 'org.freedesktop.DBus.Error.InvalidArgs'
+
+class Player(dbus.service.Object):
+ def __init__(self, bus, path, obj):
+ self.path = path
+ dbus.service.Object.__init__(self, bus, self.path)
+
+ if obj != None:
+ mp = dbus.Interface(bus.get_object("org.bluez", obj),
+ "org.bluez.MediaPlayer1")
+ prop = dbus.Interface(bus.get_object("org.bluez", obj),
+ "org.freedesktop.DBus.Properties")
+
+ self.properties = prop.GetAll("org.bluez.MediaPlayer1")
+
+ bus.add_signal_receiver(self.properties_changed, path = obj,
+ dbus_interface = "org.freedesktop.DBus.Properties",
+ signal_name = "PropertiesChanged")
+ else:
+ self.track = dbus.Dictionary({"xesam:title" : "Title",
+ "xesam:artist" : ["Artist"],
+ "xesam:album" : "Album",
+ "xesam:genre" : ["Genre"],
+ "xesam:trackNumber" : dbus.Int32(1),
+ "mpris:length" : dbus.Int64(10000) },
+ signature="sv")
+
+ self.properties = dbus.Dictionary({"PlaybackStatus" : "playing",
+ "Identity" : "SimplePlayer",
+ "LoopStatus" : "None",
+ "Rate" : dbus.Double(1.0),
+ "Shuffle" : dbus.Boolean(False),
+ "Metadata" : self.track,
+ "Volume" : dbus.Double(1.0),
+ "Position" : dbus.Int64(0),
+ "MinimumRate" : dbus.Double(1.0),
+ "MaximumRate" : dbus.Double(1.0),
+ "CanGoNext" : dbus.Boolean(False),
+ "CanGoPrevious" : dbus.Boolean(False),
+ "CanPlay" : dbus.Boolean(False),
+ "CanSeek" : dbus.Boolean(False),
+ "CanControl" : dbus.Boolean(False),
+ },
+ signature="sv")
+
+ print('Register media player with:\n\tProperties: %s' \
+ % (self.properties))
+ handler = InputHandler(self)
+ GObject.io_add_watch(sys.stdin, GObject.IO_IN, handler.handle)
+
+ @dbus.service.method("org.freedesktop.DBus.Properties",
+ in_signature="ssv", out_signature="")
+ def Set(self, interface, key, value):
+ print("Set (%s, %s)" % (key, value), file=sys.stderr)
+ return
+
+ def get_properties(self):
+ return self.properties
+
+ def get_path(self):
+ return dbus.ObjectPath(self.path)
+
+ @dbus.service.method("org.freedesktop.DBus.Properties",
+ in_signature='s', out_signature='a{sv}')
+ def GetAll(self, interface):
+ if interface != PLAYER_IFACE:
+ raise InvalidArgsException()
+
+ return self.get_properties()
+
+ @dbus.service.signal("org.freedesktop.DBus.Properties",
+ signature="sa{sv}as")
+ def PropertiesChanged(self, interface, properties,
+ invalidated = dbus.Array()):
+ """PropertiesChanged(interface, properties, invalidated)
+
+ Send a PropertiesChanged signal. 'properties' is a dictionary
+ containing string parameters as specified in doc/media-api.txt.
+ """
+ pass
+
+ def help(self, func):
+ help(self.__class__.__dict__[func])
+
+ def properties_changed(self, interface, properties, invalidated):
+ print("properties_changed(%s, %s)" % (properties, invalidated))
+
+ self.PropertiesChanged(interface, properties, invalidated)
+
+class InputHandler:
+ commands = { 'PropertiesChanged': '(interface, properties)',
+ 'help': '(cmd)' }
+ def __init__(self, player):
+ self.player = player
+ print('\n\nAvailable commands:')
+ for cmd in self.commands:
+ print('\t', cmd, self.commands[cmd], sep='')
+
+ print("\nUse python syntax to pass arguments to available methods.\n" \
+ "E.g.: PropertiesChanged({'Metadata' : {'Title': 'My title', \
+ 'Album': 'my album' }})")
+ self.prompt()
+
+ def prompt(self):
+ print('\n>>> ', end='')
+ sys.stdout.flush()
+
+ def handle(self, fd, condition):
+ s = os.read(fd.fileno(), 1024).strip()
+ try:
+ cmd = s[:s.find('(')]
+ if not cmd in self.commands:
+ print("Unknown command ", cmd)
+ except ValueError:
+ print("Malformed command")
+ return True
+ try:
+ exec "self.player.%s" % s
+ except Exception as e:
+ print(e)
+ pass
+ self.prompt()
+ return True
+
+class Application(dbus.service.Object):
+ def __init__(self, bus, path, obj):
+ self.path = '/'
+ self.players = []
+ dbus.service.Object.__init__(self, bus, self.path)
+ self.add_player(Player(bus, path, obj))
+
+ def get_path(self):
+ return dbus.ObjectPath(self.path)
+
+ def add_player(self, player):
+ self.players.append(player)
+
+ @dbus.service.method(DBUS_OM_IFACE, out_signature='a{oa{sa{sv}}}')
+ def GetManagedObjects(self):
+ response = {}
+ print('GetManagedObjects')
+
+ for player in self.players:
+ response[player.get_path()] = { PLAYER_IFACE:
+ player.get_properties() }
+
+ return response
+
+def register_app_cb():
+ print('Media application registered')
+
+
+def register_app_error_cb(error):
+ print('Failed to register application: ' + str(error))
+ mainloop.quit()
+
+if __name__ == '__main__':
+ dbus.mainloop.glib.DBusGMainLoop(set_as_default=True)
+
+ bus = dbus.SystemBus()
+
+ if len(sys.argv) > 1:
+ path = bluezutils.find_adapter(sys.argv[1]).object_path
+ else:
+ path = bluezutils.find_adapter().object_path
+
+ media = dbus.Interface(bus.get_object("org.bluez", path),
+ "org.bluez.Media1")
+
+ path = "/test/player"
+
+ if len(sys.argv) > 2:
+ app = Application(bus, path, sys.argv[2])
+ else:
+ app = Application(bus, path, None)
+
+ mainloop = GObject.MainLoop()
+
+ media.RegisterApplication(app.get_path(), {},
+ reply_handler=register_app_cb,
+ error_handler=register_app_error_cb)
+
+ mainloop.run()
--
2.21.0
