# -*- coding: utf-8 -*-
#
# Copyright (C) 2011  Tiger Soldier
#
# This file is part of OSD Lyrics.
#
# OSD Lyrics is free software: you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation, either version 3 of the License, or
# (at your option) any later version.
#
# OSD Lyrics is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License
# along with OSD Lyrics.  If not, see <https://www.gnu.org/licenses/>.
#

from optparse import OptionParser

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

from .consts import DAEMON_BUS_NAME

APP_BUS_PREFIX = 'org.osdlyrics.'


dbus.mainloop.glib.threads_init()


class AlreadyRunningException(Exception):
    """ Raised when a process with given bus name exists.
    """
    pass


class App:
    """ Basic class to create a component application for OSD Lyrics.

    The application creates a mainloop, owns a DBus name, and exits when the bus
    name of OSD Lyrics disappears.

    Once the app is created, it will parse `sys.argv`. The accepted arguments are:

     - `-w`, `--watch-daemon`: If not empty, watch the daemon with given bus name.
       The default value is the bus name of OSD Lyrics

    To create an component application owning the bus name ``org.osdlyrics.MyApp``,
    just simply follow the code below:

      app = App('MyApp')
      app.run()
    """

    def __init__(self, name, watch_daemon=True, singleton=True):
        """

        Arguments:
        - `name`: The suffix of the bus name. The full bus name is
          `org.osdlyrics.` + name
        - `watch_daemon`: Whether to watch daemon bus
        - `singleton`: If True, raise AlreadyRunningException if the bus name
                       already has an owner.
        """
        self._name = name
        self._namewatch = None
        self._watch_daemon = watch_daemon
        self._loop = GLib.MainLoop()
        self._conn = dbus.SessionBus(mainloop=DBusGMainLoop())
        self._bus_names = []
        try:
            self.request_bus_name(APP_BUS_PREFIX + name,
                                  singleton)
        except dbus.NameExistsException:
            raise AlreadyRunningException(
                'Process with bus name %s is already running' % (
                    APP_BUS_PREFIX + name))
        self._parse_options()

    def _parse_options(self):
        parser = OptionParser()
        parser.add_option('-w', '--watch-daemon',
                          dest='watch_daemon',
                          action='store',
                          default=DAEMON_BUS_NAME,
                          metavar='DAEMON_BUS_NAME',
                          help=('A well-known bus name on DBus. Exit when the'
                                ' name disappears. If set to empty string,'
                                ' this player proxy will not exit.'))
        options, args = parser.parse_args()
        if self._watch_daemon:
            self._watch_daemon_bus(options.watch_daemon)

    def _watch_daemon_bus(self, name):
        if name:
            self._namewatch = self._conn.watch_name_owner(name,
                                                          self._daemon_name_changed)

    def _daemon_name_changed(self, name):
        if not name:
            self._loop.quit()
            if (self._namewatch is not None):
                self._namewatch.cancel()
                self._namewatch = None

    @property
    def connection(self):
        """The DBus connection of the app"""
        return self._conn

    @property
    def loop(self):
        return self._loop

    def run(self):
        """
        Runs the main loop

        Return True if the loop is quited by the program. False if quited by Ctrl+C
        """
        try:
            self._loop.run()
        except KeyboardInterrupt:
            return False
        return True

    def run_on_main_thread(self, target, args=(), kwargs={}):
        """Run a callable on main thread.

        This is useful for notifying a thread is finished.
        """
        def timeout_func(*user_data):
            target(*args, **kwargs)
            return GLib.SOURCE_REMOVE
        GLib.timeout_add(0, timeout_func)

    def quit(self):
        """Quits the main loop"""
        self._loop.quit()

    def request_bus_name(self, bus_name, do_not_queue=False):
        """
        Request for additional well-known name on DBus
        """
        self._bus_names.append(dbus.service.BusName(bus_name,
                                                    self.connection,
                                                    do_not_queue=do_not_queue))