#!/usr/bin/python3 -u

import os
import sys
import time

try:
    import dbus
    import dbus.mainloop.glib
    from gi.repository import GLib
except:
    sys.stderr.write('python3-dbus is missing !\n')
    sys.exit(1)

state_file_path = '/tmp/RaySession/jack_current_parameters'

name_base = 'org.jackaudio'
control_interface_name = name_base + '.JackControl'
configure_interface_name = name_base + '.Configure'
patchbay_interface_name = name_base + '.JackPatchbay'
service_name = name_base + '.service'
last_file_write = 0.0

def dbus_signal_receiver(*args, **kwds):
    global last_file_write

    # dbus signal for something else than JACK, do nothing
    if not kwds['interface'].startswith('org.jackaudio.'):
        return

    if not kwds['member'] in ('ServerStarted', 'ServerStopped',
                              'PortAppeared'):
        return

    if kwds['member'] == 'PortAppeared':
        # file already saved in last 3s
        if time.time() - last_file_write < 3:
            return

        # PortAppeared doesn't concerns a physical port, do nothing
        if not args[5] & 0x4:
            return

    jack_status = 1
    if kwds['member'] == 'ServerStopped':
        jack_status = 0

    write_the_file(jack_started=jack_status)

def write_the_file(at_start=False, jack_started=-1):
    global last_file_write
    
    output_string = "daemon_pid:%i\n" % os.getpid()

    # Check if JACK is started, start output_string store
    if jack_started == -1:
        jack_started = control_iface.IsStarted()
    output_string += "jack_started:%s\n" % str(jack_started)

    output_string += "reliable_infos:%i\n" \
                        % int(not bool(at_start and jack_started))

    params = configure_iface.GetParametersInfo(['engine'])
    for param in params:
        isset, default, value = configure_iface.GetParameterValue(
            ['engine', param[1]])
        if isset:
            output_string += '/engine/%s:%s\n' % (param[1], value)

    params = configure_iface.GetParametersInfo(['driver'])
    for param in params:
        isset, default, value = configure_iface.GetParameterValue(
                                                    ['driver', param[1]])
        if isset:
            output_string += '/driver/%s:%s\n' % (param[1], value)

    is_leaf, internals = configure_iface.ReadContainer(['internals'])
    for internal in internals:
        params = configure_iface.GetParametersInfo(
                                                ['internals', internal])
        for param in params:
            isset, default, value = configure_iface.GetParameterValue(
                                        ['internals', internal, param[1]])
            if isset:
                output_string += '/internals/%s/%s:%s\n' % (
                                                internal, param[1], value)

    state_dir = os.path.dirname(state_file_path)
    if not os.path.exists(state_dir):
        os.makedirs(state_dir)
        # give read/write access to all users
        os.chmod(state_dir, 0o777)

    file = open(state_file_path, 'w')
    file.write(output_string)
    file.close()
    last_file_write = time.time()


if __name__ == '__main__':
    if os.path.exists(state_file_path):
        file = open(state_file_path, 'r')
        file_contents = file.read()
        file.close()

        jack_checker_pid = 0
        for line in file_contents.split('\n'):
            if line.startswith('daemon_pid:'):
                pid_str = line.replace('daemon_pid:', '', 1)
                if pid_str.isdigit():
                    jack_checker_pid = int(pid_str)
                    break

        if os.path.isdir('/proc/%i' % jack_checker_pid):
            # this daemon is already running, just exit
            sys.stderr.write('jack checker daemon already running\n')
            sys.exit()
        else:
            os.remove(state_file_path)

    dbus.mainloop.glib.DBusGMainLoop(set_as_default=True)

    loop = GLib.MainLoop()

    bus = dbus.SessionBus()
    controller = bus.get_object(service_name, "/org/jackaudio/Controller")
    control_iface = dbus.Interface(controller, control_interface_name)
    configure_iface = dbus.Interface(controller, configure_interface_name)
    patchbay_iface = dbus.Interface(controller, patchbay_interface_name)

    bus.add_signal_receiver(dbus_signal_receiver,
                            destination_keyword="dest",
                            path_keyword="path",
                            member_keyword="member",
                            interface_keyword="interface",
                            sender_keyword="sender")

    if len(sys.argv) >= 2 and sys.argv[1] in ('-f', '--force-reliable'):
        write_the_file()
    else:
        write_the_file(at_start=True)

    loop.run()
    sys.exit()