straw/MessageManager.py

   1 """ MessageManager.py
   2
   3 Manages status messages
   4 """
   5 __copyright__ = "Copyright (c) 2002-2005 Free Software Foundation, Inc."
   6 __license__ = """
   7 Straw is free software; you can redistribute it and/or modify it under the
   8 terms of the GNU General Public License as published by the Free Software
   9 Foundation; either version 2 of the License, or (at your option) any later
  10 version.
  11
  12 Straw is distributed in the hope that it will be useful, but WITHOUT ANY
  13 WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR
  14 A PARTICULAR PURPOSE. See the GNU General Public License for more details.
  15
  16 You should have received a copy of the GNU General Public License along with
  17 this program; if not, write to the Free Software Foundation, Inc., 59 Temple
  18 Place - Suite 330, Boston, MA 02111-1307, USA. """
  19
  20 import logging
  21 import dbus
  22 import dbus.service
  23 import dbus.glib
  24 from dbus import DBusException
  25 import gobject
  26 import Config
  27
  28 from subscribe import subscribe_show
  29
  30 # Based on the values from NetworkManager/include/NetworkManager.h
  31 # We only care about CONNECTED and DISCONNECTED at the moment.
  32 NM_STATE_CONNECTED = 3
  33 NM_STATE_DISCONNECTED = 4
  34
  35 class FeedReader(dbus.service.Object):
  36     service_name = "org.gnome.feed.Reader"
  37     object_path = "/org/gnome/feed/Reader"
  38
  39     def __init__(self):
  40         try:
  41             self._session_bus = dbus.SessionBus()
  42             self._service = dbus.service.BusName(self.service_name, bus=self._session_bus)
  43             dbus.service.Object.__init__(self, self._service, self.object_path)
  44         except DBusException, e:
  45             logging.info(_("Error while initializing feed subscribe service: [%s]" % str(e)))
  46
  47     @dbus.service.method("org.gnome.feed.Reader")
  48     def Subscribe(self, url):
  49         subscribe_show(url)
  50         return True
  51
  52 class NetworkListener(object):
  53     SERVICE_NAME = "org.freedesktop.NetworkManager"
  54     SERVICE_PATH = "/org/freedesktop/NetworkManager"
  55
  56     def __init__(self):
  57         pass
  58
  59     def set_state(self, state):
  60         pass #self._config.offline = not (state == NM_STATE_CONNECTED)
  61
  62     def active_cb(self, path):
  63         pass #self._config.offline = False
  64
  65     def inactive_cb(self, path):
  66         pass #self._config.offline = True
  67
  68 def start_services():
  69     try:
  70         systemBus = dbus.SystemBus()
  71         proxy_obj = systemBus.get_object(NetworkListener.SERVICE_NAME, NetworkListener.SERVICE_PATH)
  72         nl = NetworkListener()
  73
  74         # don't touch offline if it has been previously set.
  75         #if not Config.get_instance().offline:
  76         #    nl.set_state(proxy_obj.state())
  77
  78         nm_interface = dbus.Interface(proxy_obj, NetworkListener.SERVICE_NAME)
  79         nm_interface.connect_to_signal('DeviceNowActive', nl.active_cb)
  80         nm_interface.connect_to_signal('DeviceNoLongerActive', nl.inactive_cb)
  81     except DBusException, e:
  82         logging.info(_("Unable to find NetworkManager service: [%s]" % str(e)))
  83
  84 class StatusMessageManager(gobject.GObject):
  85
  86     __gsignals__ = {
  87         'changed' : (gobject.SIGNAL_RUN_LAST, gobject.TYPE_NONE,())
  88         }
  89
  90     def __init__(self):
  91         gobject.GObject.__init__(self)
  92         self.__messages = []
  93
  94     def post_message(self, message):
  95         self.__messages.append(message)
  96         self.emit('changed')
  97
  98     def read_message(self):
  99         return self.__messages.pop(0)
 100
 101     def number_of_messages(self):
 102         return len(self.__messages)
 103
 104 _smmanager = None
 105 def post_status_message(text):
 106     global _smmanager
 107     if not _smmanager:
 108         get_status_manager()
 109     _smmanager.post_message(text)
 110
 111 def get_status_manager():
 112     global _smmanager
 113     if not _smmanager:
 114         _smmanager = StatusMessageManager()
 115     return _smmanager