fso-frameworkd 0.10.1-3 / usr / lib / python2.7 / dist-packages / framework / subsystems / oeventsd / fso_actions.py

# -*- coding: UTF-8 -*-
"""
The freesmartphone Events Module - Python Implementation

(C) 2008-2009 Michael 'Mickey' Lauer <mlauer@vanille-media.de>
(C) 2008 Jan 'Shoragan' Lübbe <jluebbe@lasnet.de>
(C) 2008 Guillaume 'Charlie' Chereau
(C) 2008 Openmoko, Inc.
GPLv2 or later

Package: oeventsd
Module: fso_actions

"""

__VERSION__ = "0.5.1.1"
MODULE_NAME = "oeventsd"

import framework.patterns.tasklet as tasklet

from action import Action
from action import QueuedDBusAction, DBusAction
from framework.controller import Controller
from framework.config import installprefix
from framework.patterns import dbuscache

import gobject
import dbus
import os, subprocess, shlex

import logging
logger = logging.getLogger( MODULE_NAME )

#============================================================================#
class SetProfile( Action ):
#============================================================================#
    function_name = 'SetProfile'

    def __init__( self, profile ):
        self.profile = profile

    @tasklet.tasklet
    def __trigger( self ):
        prefs = dbuscache.dbusInterfaceForObjectWithInterface(
            "org.freesmartphone.opreferencesd",
            "/org/freesmartphone/Preferences",
            "org.freesmartphone.Preferences" )
        # First, store the current profile
        # FIXME: we should use profile push and pop instead
        self.backup_profile = yield tasklet.WaitDBus( prefs.GetProfile )
        # Then we can set the profile
        yield tasklet.WaitDBus( prefs.SetProfile, self.profile )

    def trigger( self, **kargs ):
        self.__trigger().start()

    def untrigger( self, **kargs ):
        # FIXME: how do we handle the case where we untrigger the action
        #       before we finish the trigger tasklet ?
        SetProfile( self.backup_profile ).trigger()

    def __repr__( self ):
        return "SetProfile(%s)" % self.profile

#============================================================================#
class AudioAction(Action):
#============================================================================#
    """
    A dbus action on the freesmartphone audio device
    """
    def __init__(self, path, loop=0, length=0):
        super(AudioAction, self).__init__()
        self.path = path
        self.loop = loop
        self.length = length

    def trigger(self, **kargs):
        QueuedDBusAction(
            dbus.SystemBus(),
            'org.freesmartphone.odeviced',
            '/org/freesmartphone/Device/Audio',
            'org.freesmartphone.Device.Audio',
            'PlaySound', self.path, self.loop, self.length).trigger()

    def untrigger(self, **kargs):
        QueuedDBusAction(
            dbus.SystemBus(),
            'org.freesmartphone.odeviced',
            '/org/freesmartphone/Device/Audio',
            'org.freesmartphone.Device.Audio',
            'StopSound', self.path).trigger()

#============================================================================#
class SetAudioScenarioAction(DBusAction):
#============================================================================#
    """
    A dbus action on the freesmartphone audio device
    """
    def __init__(self, scenario = None, action = 'set' ):
        bus = dbus.SystemBus()
        service = 'org.freesmartphone.odeviced'
        obj = '/org/freesmartphone/Device/Audio'
        interface = 'org.freesmartphone.Device.Audio'
        if action == 'set':
            # FIXME gsmhandset ugly ugly hardcoded
            super(SetAudioScenarioAction, self).__init__(bus, service, obj, interface, "SetScenario", scenario)
        else:
            logger.error( "unhandled action '%s' for Audio scenario" % action )

#============================================================================#
class AudioScenarioAction(Action):
#============================================================================#
    function_name = 'SetScenario'

    def __init__(self, scenario):
        self.scenario = scenario

    def trigger(self, **kargs):
        logger.info("Set Audio Scenario %s", self.scenario)
        # TODO: retreive the current scenario so that we can use it when we reset the scenario
        self.backup_scenario = 'stereoout'
        SetAudioScenarioAction(self.scenario).trigger()

    def untrigger(self, **kargs):
        logger.info("Revert Audio Scenario to %s", self.backup_scenario)
        SetAudioScenarioAction(self.backup_scenario).trigger()

    def __repr__(self):
        return "SetScenario(%s)" % self.scenario

#============================================================================#
class DisplayBrightnessAction(DBusAction):
#============================================================================#
    """
    A dbus action on a Display device
    """
    # FIXME: device specific, needs to go away from here / made generic (parametric? just take the first?)
    function_name = 'SetDisplayBrightness'

    def __init__(self, target, brightness):
        bus = dbus.SystemBus()
        service = 'org.freesmartphone.odeviced'
        obj = '/org/freesmartphone/Device/Display/%s' % target
        interface = 'org.freesmartphone.Device.Display'
        super(DisplayBrightnessAction, self).__init__(bus, service, obj, interface, 'SetBrightness', brightness)

#============================================================================#
class VibratorAction(Action):
#============================================================================#
    """
    A dbus action on the Openmoko Neo Vibrator device
    """
    function_name = 'Vibration'
    # FIXME: ATM it just takes the first and runs at full power, should fix.
    def __init__(self, target = 0, mode = "continuous"):
        self.mode = mode
        self.target = target

    def trigger(self, **kargs):
        if self.mode == "continuous":
            DBusAction(dbus.SystemBus(),
                        'org.freesmartphone.odeviced',
                        '/org/freesmartphone/Device/Vibrator/%s' % self.target,
                        'org.freesmartphone.Device.Vibrator',
                        'VibratePattern', 999, 300, 700, 90).trigger()
        elif self.mode == "oneshot":
            DBusAction(dbus.SystemBus(),
                        'org.freesmartphone.odeviced',
                        '/org/freesmartphone/Device/Vibrator/%s' % self.target,
                        'org.freesmartphone.Device.Vibrator',
                        'Vibrate', 400, 90).trigger()
        else:
            logger.warning( "invalid vibration mode '%s', valid are 'continuous' or 'oneshot'" )

    def untrigger(self, **kargs):
        DBusAction(dbus.SystemBus(),
                    'org.freesmartphone.odeviced',
                    '/org/freesmartphone/Device/Vibrator/%s' % self.target,
                    'org.freesmartphone.Device.Vibrator',
                    'Stop').trigger()

#============================================================================#
class BTHeadsetPlayingAction(Action):
#============================================================================#
    """
    A dbus action on the Bluetooth Headset API
    """
    function_name = 'BTHeadsetPlaying'
    def __init__(self):
        pass
    def trigger(self, **kargs):
        DBusAction(dbus.SystemBus(),
                    'org.freesmartphone.ophoned',
                    '/org/freesmartphone/Phone',
                    'org.freesmartphone.Phone',
                    'SetBTHeadsetPlaying', True).trigger()

    def untrigger(self, **kargs):
        DBusAction(dbus.SystemBus(),
                    'org.freesmartphone.ophoned',
                    '/org/freesmartphone/Phone',
                    'org.freesmartphone.Phone',
                    'SetBTHeadsetPlaying', False).trigger()

    def __repr__(self):
        return "BTHeadsetPlaying()"

#============================================================================#
class OccupyResourceAction(Action):
#============================================================================#
    function_name = 'OccupyResource'

    usageiface = None
    pending = {}
    held = {}

    @classmethod
    def onResourceAvailable( cls, name, state ):
        if state:
            cls.updatePending( name )
        # FIXME handle vanishing resources...

    @classmethod
    def updatePending( cls, name ):
        try:
            counter = cls.pending[name]
        except KeyError:
            pass
        else:
            if counter > 0:
                cls.usageiface.RequestResource( name,
                        reply_handler = lambda cls=cls,name=name: cls.onResourceRequestReply( name ),
                        error_handler = lambda cls=cls,name=name, e=None: cls.onResourceRequestError( name, e ) )
            else:
                cls.usageiface.ReleaseResource( name,
                        reply_handler = lambda cls=cls,name=name: cls.onResourceReleaseReply( name ),
                        error_handler = lambda cls=cls,name=name, e=None: cls.onResourceReleaseError( name, e ) )

    @classmethod
    def onResourceRequestReply( cls, name ):
        logger.debug( "onResourceRequestReply: %s" % name )
        amount = cls.pending[name]
        if amount > 0:
            del cls.pending[name]
            cls.held[name] = amount

    @classmethod
    def onResourceRequestError( cls, name, e ):
        logger.debug( "onResourceRequestError: %s: %s" % ( name, e ) )

    @classmethod
    def onResourceReleaseReply( cls, name ):
        logger.debug( "onResourceReleaseReply: %s" % name )
        del cls.pending[name]

    @classmethod
    def onResourceReleaseError( cls, name, e ):
        logger.debug( "onResourceReleaseError: %s: %s" % ( name, e ) )

    def __init__( self, resource ):
        self.resource = resource

        if self.usageiface is None:
            self.__class__.usageiface = dbuscache.dbusInterfaceForObjectWithInterface( \
                    "org.freesmartphone.ousaged",
                    "/org/freesmartphone/Usage",
                    "org.freesmartphone.Usage" )
            self.__class__.usageiface.connect_to_signal( "ResourceAvailable", self.__class__.onResourceAvailable )

    def __repr__( self ):
        return "OccupyResource(%s)" % ( self.resource )

    def trigger( self, **kargs ):
        if self.resource in self.__class__.pending:
            self.__class__.pending[self.resource] = self.__class__.pending[self.resource] + 1

        elif self.resource in self.__class__.held:
            self.__class__.held[self.resource] = self.__class__.held[self.resource] + 1

        else:
            self.__class__.pending[self.resource] = 1
            self.__class__.updatePending( self.resource )

    def untrigger( self, **kargs ):
        if self.resource in self.__class__.pending:
            counter = self.__class__.pending[self.resource]
            if counter > 1:
                self.__class__.pending[self.resource] = counter - 1
            else:
                self.__class__.pending[self.resource] = 0
                self.__class__.updatePending( self.resource )

        elif self.resource in self.__class__.held:
            counter = self.__class__.held[self.resource]
            if counter > 1:
                self.__class__.held[self.resource] = counter - 1
            else:
                del self.__class__.held[self.resource]
                self.__class__.pending[self.resource] = 0
                self.__class__.updatePending( self.resource )

        else:
            logger.error( "Untrigger for resource %s before trigger!? Ignoring..." % self.resource )

#=========================================================================#
class UserAlertAction(Action):
#=========================================================================#
    function_name = '___abstract_dont_use_this_directly____'

    def __init__( self, *args, **kwargs ):
        Action.__init__( self )
        logger.debug( "%s: init", self )
        self.audio_action = None
        self.vibrator_action = None
        self.eventname = self.__class__.event_name # needs to be populated in derived classes
        self.vibratormode = self.__class__.vibrator_mode # dito
        gobject.idle_add( self.initFromMainloop )

    def initFromMainloop( self ):
        self.__init().start()
        return False # mainloop: don't call me again

    def cbPreferencesServiceNotify( self, key, value ):
        """
        Audio preferences have changed. Reload.
        """
        k = str(key)
        if k == "%s-tone" % self.eventname:
            self.tone = str(value)
        elif k == "%s-volume" % self.eventname:
            self.volume = int(value)
        elif k == "%s-loop" % self.eventname:
            self.loop = int(value)
        elif k == "%s-length" % self.eventname:
            self.length = int(value)
        elif k == "%s-vibration" % self.eventname:
            self.vibrate = int(value)

        self.sound_path = os.path.join( installprefix, "share/sounds/", self.tone )
        self.audio_action = AudioAction( self.sound_path, self.loop, self.length ) if self.volume != 0 else None
        self.vibrator_action = VibratorAction( mode=self.vibratormode ) if self.vibrate != 0 else None

        logger.debug( "user alert action changed for %s: audio=%s, vibrator=%s", self.eventname, self.audio_action, self.vibrator_action )

    @tasklet.tasklet
    def __init( self ):
        """
        We need to make DBus calls and wait for the result,
        So we use a tasklet to avoid blocking the mainloop.
        """

        logger.debug( "user alert action init from mainloop for %s", self.eventname )
        # We get the 'phone' preferences service and
        # retreive the tone and volume config values
        # We are careful to use 'yield' cause the calls could be blocking.
        try:
            prefs = dbuscache.dbusInterfaceForObjectWithInterface(
                "org.freesmartphone.opreferencesd",
                "/org/freesmartphone/Preferences",
                "org.freesmartphone.Preferences" )
            phone_prefs = yield tasklet.WaitDBus( prefs.GetService, "phone" )
            phone_prefs = dbuscache.dbusInterfaceForObjectWithInterface(
                "org.freesmartphone.opreferencesd",
                phone_prefs,
                "org.freesmartphone.Preferences.Service" )

        except dbus.DBusException: # preferences daemon probably not present
            logger.warning( "org.freesmartphone.opreferencesd not present. Can't get alert tones." )
        else:
            # connect to signal for later notifications
            phone_prefs.connect_to_signal( "Notify", self.cbPreferencesServiceNotify )

            # FIXME does that still work if (some of) the entries are missing?
            self.tone =    yield tasklet.WaitDBus( phone_prefs.GetValue, "%s-tone" % self.eventname )
            self.volume =  yield tasklet.WaitDBus( phone_prefs.GetValue, "%s-volume" % self.eventname )
            self.loop =    yield tasklet.WaitDBus( phone_prefs.GetValue, "%s-loop" % self.eventname )
            self.length =  yield tasklet.WaitDBus( phone_prefs.GetValue, "%s-length" % self.eventname )
            self.vibrate = yield tasklet.WaitDBus( phone_prefs.GetValue, "%s-vibration" % self.eventname )

            self.tone = str(self.tone)
            self.volume = int(self.volume)
            self.loop = int(self.loop)
            self.length = int(self.length)
            self.vibrate = int(self.vibrate)

            self.sound_path = os.path.join( installprefix, "share/sounds/", self.tone )
            self.audio_action = AudioAction( self.sound_path, self.loop, self.length ) if self.volume != 0 else None
            self.vibrator_action = VibratorAction( mode=self.vibratormode ) if self.vibrate != 0 else None

        logger.debug( "user alert action for %s: audio=%s, vibrator=%s", self.eventname, self.audio_action, self.vibrator_action )

    def trigger(self, **kargs):
        logger.info( "UserAlertAction %s play", self.eventname )
        if self.audio_action is not None:
            self.audio_action.trigger()
        if self.vibrator_action is not None:
            self.vibrator_action.trigger()

    def untrigger(self, **kargs):
        logger.info( "UserAlertAction %s stop", self.eventname )
        if self.audio_action is not None:
            self.audio_action.untrigger()
        if self.vibrator_action is not None:
            self.vibrator_action.untrigger()

    def __repr__(self):
        return "Abstract UserAlertAction()"

#=========================================================================#
class RingToneAction(UserAlertAction):
#=========================================================================#
    function_name = 'RingTone'
    event_name = "ring"
    vibrator_mode = "continuous"

    def __repr__(self):
        return "RingToneAction()"

#=========================================================================#
class MessageToneAction(UserAlertAction):
#=========================================================================#
    function_name = 'MessageTone'
    event_name = "message"
    vibrator_mode = "oneshot"

    def __repr__(self):
        return "MessageToneAction()"

#=========================================================================#
class CommandAction(Action):
#=========================================================================#
    function_name = 'Command'

    def __init__( self, cmd = 'true', env = {} ):
        self.cmd = cmd
        self.env = env

    def trigger(self, **kargs):
        logger.info( "CommandAction %s", self.cmd )

        env = {}
        env.update( os.environ )
        env.update( self.env )

        # FIXME if we are interested in tracking the process, then we
        # should use glib's spawn async and add a child watch
        try:
            subprocess.call( shlex.split( self.cmd ), env = env )
        except Exception, e:
            logger.error( "Error while executing external command '%s': %s", self.cmd, e )

    def __repr__(self):
        return "CommandAction(%s, %s)" % ( self.cmd, self.env )

#============================================================================#
class SuspendAction(DBusAction):
#============================================================================#
    """
    A dbus action to supend the device
    """
    function_name = 'Suspend'

    def __init__(self):
        bus = dbus.SystemBus()
        service = 'org.freesmartphone.ousaged'
        obj = '/org/freesmartphone/Usage'
        interface = 'org.freesmartphone.Usage'
        super(SuspendAction, self).__init__(bus, service, obj, interface, 'Suspend')

#============================================================================#
class ShutdownAction(DBusAction):
#============================================================================#
    """
    A dbus action to shutdown the device
    """
    function_name = 'Shutdown'

    def __init__(self):
        bus = dbus.SystemBus()
        service = 'org.freesmartphone.ousaged'
        obj = '/org/freesmartphone/Usage'
        interface = 'org.freesmartphone.Usage'
        super(ShutdownAction, self).__init__(bus, service, obj, interface, 'Shutdown')

#============================================================================#
class ExternalDBusAction(DBusAction):
#============================================================================#
    function_name = "ExternalDBusAction"

    """
    A flexible dbus action
    """
    def __init__(self, bus, service, obj, interface, method, *args):
        """Create the DBus action

        arguments:
        - bus       the DBus bus name (or a string : 'system' | 'session')
        - service   the DBus name of the service
        - obj       the DBus path of the object
        - interface the Dbus interface of the signal
        - method    the DBus name of the method
        - args      the arguments for the method

        """
        # some arguments checking
        if isinstance(bus, str):
            if bus == 'system':
                bus = dbus.SystemBus()
            elif bus == 'session':
                bus = dbus.SessionBus()
            else:
                raise TypeError("Bad dbus bus : %s" % bus)
        if not obj:
            obj = None

        assert isinstance(service, str), "service is not str"
        assert obj is None or isinstance(obj, str), "obj is not str or None"
        assert isinstance(interface, str), "interface is not str"
        assert isinstance(signal, str), "signal is not str"

        super(ExternalDBusAction, self).__init__(bus, service, obj, interface, method, *args)

    def __repr__( self ):
        return "ExternalDBusAction(bus = %s, service = %s, obj = %s, itf = %s, method = %s)" % (self.bus, self.service, self.obj, self.interface, self.method)

#============================================================================#
if __name__ == "__main__":
#============================================================================#
    pass