proxyplay/handler.py at master · P1-Ro/proxyplay · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
import re
import time

import cec
import dbus
from dbus.mainloop.glib import DBusGMainLoop
from gi.repository import GLib

from config import MAC_ADDRESS, SHUTDOWN_TIMEOUT

PROPERTIES = "org.freedesktop.DBus.Properties"


class Handler:
    def __init__(self):
        self.event_id = None

        DBusGMainLoop(set_as_default=True)

        cec.init()
        self.sound_bar = cec.Device(cec.CECDEVICE_AUDIOSYSTEM)

        self.bus = dbus.SystemBus()
        self.address = '/org/bluez/hci0/dev_' + MAC_ADDRESS.replace(":", "_")
        self.proxy = self.bus.get_object('org.bluez', self.address)

        self.device = dbus.Interface(self.proxy, "org.bluez.Device1")
        self.device.connect_to_signal("PropertiesChanged", self.handle_device_change, dbus_interface=PROPERTIES)
        self.init_loop()

        GLib.MainLoop().run()

    def init_loop(self):
        fd_string = self.proxy.Introspect()
        matcher = re.search("node name=\"(fd\\d+)\"", fd_string)

        if matcher:
            fd = matcher.group(1)
            print(fd)

            proxy = self.bus.get_object('org.bluez', self.address + "/" + fd)
            player = dbus.Interface(proxy, "org.bluez.MediaTransport1")
            player.connect_to_signal("PropertiesChanged", self.handle_media_change, dbus_interface=PROPERTIES)
        else:
            print("no device connected")

    def power_on(self):
        cec.set_active_source()
        if self.event_id is not None:
            GLib.source_remove(self.event_id)
            self.event_id = None

    def power_off(self):
        self.sound_bar.standby()
        self.event_id = None
        return False

    def handle_device_change(self, iface, obj, params):
        print(obj)
        if bool(obj["Connected"]):
            time.sleep(SHUTDOWN_TIMEOUT)
            self.init_loop()

    def handle_media_change(self, iface, obj, params):
        if "State" in obj:
            print(obj["State"])
            if obj["State"] == "active":
                self.power_on()
            elif obj["State"] == "idle":
                self.event_id = GLib.timeout_add_seconds(SHUTDOWN_TIMEOUT, self.power_off)


if __name__ == '__main__':
    handler = Handler()