diff frontends/src/bridge/DBus.py @ 372:f964dcec1611

core: plugins refactored according to bridge + updatedValue now use profile
author Goffi <goffi@goffi.org>
date Wed, 06 Jul 2011 01:06:18 +0200
parents efbfccfed623
children e66d300c5d42
line wrap: on
line diff
--- a/frontends/src/bridge/DBus.py	Wed Jul 06 01:04:24 2011 +0200
+++ b/frontends/src/bridge/DBus.py	Wed Jul 06 01:06:18 2011 +0200
@@ -21,12 +21,12 @@
 
 from bridge_frontend import BridgeFrontend
 import dbus, dbus.glib
-from logging import debug
+from logging import debug, error
 
 const_INT_PREFIX = "org.goffi.SAT"  #Interface prefix
 const_OBJ_PATH = '/org/goffi/SAT/bridge'
-const_COMM_SUFFIX = ".communication"
-const_REQ_SUFFIX = ".request"
+const_CORE_SUFFIX = ".core"
+const_PLUGIN_SUFFIX = ".plugin"
 
 class BridgeExceptionNoService(Exception):
     pass
@@ -37,194 +37,196 @@
             self.sessions_bus = dbus.SessionBus()
             self.db_object = self.sessions_bus.get_object(const_INT_PREFIX,
                                 const_OBJ_PATH)
-            self.db_comm_iface = dbus.Interface(self.db_object,
-                                dbus_interface=const_INT_PREFIX + const_COMM_SUFFIX)
-            self.db_req_iface = dbus.Interface(self.db_object,
-                                dbus_interface=const_INT_PREFIX + const_REQ_SUFFIX)
+            self.db_core_iface = dbus.Interface(self.db_object,
+                                dbus_interface=const_INT_PREFIX + const_CORE_SUFFIX)
+            self.db_plugin_iface = dbus.Interface(self.db_object,
+                                dbus_interface=const_INT_PREFIX + const_PLUGIN_SUFFIX)
         except dbus.exceptions.DBusException,e:
             if e._dbus_error_name=='org.freedesktop.DBus.Error.ServiceUnknown':
                 raise BridgeExceptionNoService
             else:
                 raise e
-        #props = self.db_comm_iface.getProperties()
+        #props = self.db_core_iface.getProperties()
 
-    def register(self, functionName, handler, iface="communication"):
-        if iface == "communication":
-            self.db_comm_iface.connect_to_signal(functionName, handler)
-        elif iface == "request":
-            self.db_req_iface.connect_to_signal(functionName, handler)
+    def register(self, functionName, handler, iface="core"):
+        if iface == "core":
+            self.db_core_iface.connect_to_signal(functionName, handler)
+        elif iface == "plugin":
+            self.db_plugin_iface.connect_to_signal(functionName, handler)
+        else:
+            error(_('Unknown interface'))
 
     def addContact(self, entity, profile_key="@DEFAULT@"):
-        return self.db_comm_iface.addContact(entity, profile_key)
+        return self.db_core_iface.addContact(entity, profile_key)
 
     def asyncConnect(self, profile_key="@DEFAULT@", callback=None, errback=None):
-        return self.db_comm_iface.asyncConnect(profile_key, reply_handler=callback, error_handler=errback)
+        return self.db_core_iface.asyncConnect(profile_key, reply_handler=callback, error_handler=errback)
 
     def callMenu(self, category, name, menu_type, profile_key):
-        return unicode(self.db_req_iface.callMenu(category, name, menu_type, profile_key))
+        return unicode(self.db_core_iface.callMenu(category, name, menu_type, profile_key))
 
     def confirmationAnswer(self, id, accepted, data):
-        return self.db_req_iface.confirmationAnswer(id, accepted, data)
+        return self.db_core_iface.confirmationAnswer(id, accepted, data)
 
     def connect(self, profile_key="@DEFAULT@"):
-        return self.db_comm_iface.connect(profile_key)
+        return self.db_core_iface.connect(profile_key)
 
     def createProfile(self, profile):
-        return self.db_req_iface.createProfile(profile)
+        return self.db_core_iface.createProfile(profile)
 
     def delContact(self, entity, profile_key="@DEFAULT@"):
-        return self.db_comm_iface.delContact(entity, profile_key)
+        return self.db_core_iface.delContact(entity, profile_key)
 
     def deleteProfile(self, profile):
-        return self.db_req_iface.deleteProfile(profile)
+        return self.db_core_iface.deleteProfile(profile)
 
     def disconnect(self, profile_key="@DEFAULT@"):
-        return self.db_comm_iface.disconnect(profile_key)
+        return self.db_core_iface.disconnect(profile_key)
 
     def getConfig(self, section, name):
-        return unicode(self.db_comm_iface.getConfig(section, name))
+        return unicode(self.db_core_iface.getConfig(section, name))
 
     def getContacts(self, profile_key="@DEFAULT@"):
-        return self.db_comm_iface.getContacts(profile_key)
+        return self.db_core_iface.getContacts(profile_key)
 
     def getHistory(self, from_jid, to_jid, size):
-        return self.db_comm_iface.getHistory(from_jid, to_jid, size)
+        return self.db_core_iface.getHistory(from_jid, to_jid, size)
 
     def getMenuHelp(self, category, name, menu_type):
-        return unicode(self.db_req_iface.getMenuHelp(category, name, menu_type))
+        return unicode(self.db_core_iface.getMenuHelp(category, name, menu_type))
 
     def getMenus(self, ):
-        return self.db_req_iface.getMenus()
+        return self.db_core_iface.getMenus()
 
     def getParamA(self, name, category, attribute="value", profile_key="@DEFAULT@"):
-        return unicode(self.db_comm_iface.getParamA(name, category, attribute, profile_key))
+        return unicode(self.db_core_iface.getParamA(name, category, attribute, profile_key))
 
     def getParams(self, profile_key="@DEFAULT@"):
-        return unicode(self.db_comm_iface.getParams(profile_key))
+        return unicode(self.db_core_iface.getParams(profile_key))
 
     def getParamsCategories(self, ):
-        return self.db_comm_iface.getParamsCategories()
+        return self.db_core_iface.getParamsCategories()
 
     def getParamsForCategory(self, category, profile_key="@DEFAULT@"):
-        return unicode(self.db_comm_iface.getParamsForCategory(category, profile_key))
+        return unicode(self.db_core_iface.getParamsForCategory(category, profile_key))
 
     def getParamsUI(self, profile_key="@DEFAULT@"):
-        return unicode(self.db_comm_iface.getParamsUI(profile_key))
+        return unicode(self.db_core_iface.getParamsUI(profile_key))
 
     def getPresenceStatus(self, profile_key="@DEFAULT@"):
-        return self.db_comm_iface.getPresenceStatus(profile_key)
+        return self.db_core_iface.getPresenceStatus(profile_key)
 
     def getProfileName(self, profile_key="@DEFAULT@"):
-        return unicode(self.db_req_iface.getProfileName(profile_key))
+        return unicode(self.db_core_iface.getProfileName(profile_key))
 
     def getProfilesList(self, ):
-        return self.db_req_iface.getProfilesList()
+        return self.db_core_iface.getProfilesList()
 
     def getProgress(self, id):
-        return self.db_req_iface.getProgress(id)
+        return self.db_core_iface.getProgress(id)
 
     def getVersion(self, ):
-        return unicode(self.db_req_iface.getVersion())
+        return unicode(self.db_core_iface.getVersion())
 
     def getWaitingSub(self, profile_key="@DEFAULT@"):
-        return self.db_comm_iface.getWaitingSub(profile_key)
+        return self.db_core_iface.getWaitingSub(profile_key)
 
     def isConnected(self, profile_key="@DEFAULT@"):
-        return self.db_comm_iface.isConnected(profile_key)
+        return self.db_core_iface.isConnected(profile_key)
 
     def launchAction(self, action_type, data, profile_key="@DEFAULT@"):
-        return unicode(self.db_req_iface.launchAction(action_type, data, profile_key))
+        return unicode(self.db_core_iface.launchAction(action_type, data, profile_key))
 
     def registerNewAccount(self, login, password, email, host, port=5222):
-        return unicode(self.db_comm_iface.registerNewAccount(login, password, email, host, port))
+        return unicode(self.db_core_iface.registerNewAccount(login, password, email, host, port))
 
     def sendMessage(self, to_jid, message, subject='', mess_type="chat", profile_key="@DEFAULT@"):
-        return self.db_comm_iface.sendMessage(to_jid, message, subject, mess_type, profile_key)
+        return self.db_core_iface.sendMessage(to_jid, message, subject, mess_type, profile_key)
 
     def setParam(self, name, value, category, profile_key="@DEFAULT@"):
-        return self.db_comm_iface.setParam(name, value, category, profile_key)
+        return self.db_core_iface.setParam(name, value, category, profile_key)
 
     def setPresence(self, to_jid='', show='', priority=0, statuses={}, profile_key="@DEFAULT@"):
-        return self.db_comm_iface.setPresence(to_jid, show, priority, statuses, profile_key)
+        return self.db_core_iface.setPresence(to_jid, show, priority, statuses, profile_key)
 
     def subscription(self, sub_type, entity, profile_key="@DEFAULT@"):
-        return self.db_comm_iface.subscription(sub_type, entity, profile_key)
+        return self.db_core_iface.subscription(sub_type, entity, profile_key)
 
     def updateContact(self, entity, name, groups, profile_key="@DEFAULT@"):
-        return self.db_comm_iface.updateContact(entity, name, groups, profile_key)
+        return self.db_core_iface.updateContact(entity, name, groups, profile_key)
 
 
 #methods from plugins
     def getRoomJoined(self, profile_key='@DEFAULT@'):
-        return self.db_comm_iface.getRoomJoined(profile_key)
+        return self.db_plugin_iface.getRoomJoined(profile_key)
 
     def getRoomSubjects(self, profile_key='@DEFAULT@'):
-        return self.db_comm_iface.getRoomSubjects(profile_key)
+        return self.db_plugin_iface.getRoomSubjects(profile_key)
 
     def joinMUC(self, service, roomId, nick, profile_key='@DEFAULT@'):
-        return self.db_comm_iface.joinMUC(service, roomId, nick, profile_key)
+        return self.db_plugin_iface.joinMUC(service, roomId, nick, profile_key)
 
     def tarotGameLaunch(self, players, profile_key='@DEFAULT@'):
-        return self.db_comm_iface.tarotGameLaunch(players, profile_key)
+        return self.db_plugin_iface.tarotGameLaunch(players, profile_key)
     
     def tarotGameCreate(self, room_jid, players, profile_key='@DEFAULT@'):
-        return self.db_comm_iface.tarotGameCreate(room_jid, players, profile_key)
+        return self.db_plugin_iface.tarotGameCreate(room_jid, players, profile_key)
 
     def tarotGameReady(self, player, referee, profile_key='@DEFAULT@'):
-        return self.db_comm_iface.tarotGameReady(player, referee, profile_key)
+        return self.db_plugin_iface.tarotGameReady(player, referee, profile_key)
 
     def tarotGameContratChoosed(self, player, referee, contrat, profile_key='@DEFAULT@'):
-        return self.db_comm_iface.tarotGameContratChoosed(player, referee, contrat, profile_key)
+        return self.db_plugin_iface.tarotGameContratChoosed(player, referee, contrat, profile_key)
 
     def tarotGamePlayCards(self, player, referee, cards, profile_key='@DEFAULT@'):
-        return self.db_comm_iface.tarotGamePlayCards(player, referee, cards, profile_key)
+        return self.db_plugin_iface.tarotGamePlayCards(player, referee, cards, profile_key)
 
     def quizGameLaunch(self, players, profile_key='@DEFAULT@'):
-        return self.db_comm_iface.quizGameLaunch(players, profile_key)
+        return self.db_plugin_iface.quizGameLaunch(players, profile_key)
     
     def quizGameCreate(self, room_jid, players, profile_key='@DEFAULT@'):
-        return self.db_comm_iface.quizGameCreate(room_jid, players, profile_key)
+        return self.db_plugin_iface.quizGameCreate(room_jid, players, profile_key)
 
     def quizGameReady(self, player, referee, profile_key='@DEFAULT@'):
-        return self.db_comm_iface.quizGameReady(player, referee, profile_key)
+        return self.db_plugin_iface.quizGameReady(player, referee, profile_key)
 
     def quizGameAnswer(self, player, referee, answer, profile_key='@DEFAULT@'):
-        return self.db_comm_iface.quizGameAnswer(player, referee, answer, profile_key)
+        return self.db_plugin_iface.quizGameAnswer(player, referee, answer, profile_key)
 
     def sendFile(self, to, path, profile_key='@DEFAULT@'):
-        return self.db_comm_iface.sendFile(to, path, profile_key)
+        return self.db_plugin_iface.sendFile(to, path, profile_key)
 
     def findGateways(self, target, profile_key='@DEFAULT@'):
-        return self.db_comm_iface.findGateways(target, profile_key)
+        return self.db_plugin_iface.findGateways(target, profile_key)
 
     def getCard(self, target, profile_key='@DEFAULT@'):
-        return self.db_comm_iface.getCard(target, profile_key)
+        return self.db_plugin_iface.getCard(target, profile_key)
 
     def getCardCache(self, target):
-        return self.db_comm_iface.getCardCache(target)
+        return self.db_plugin_iface.getCardCache(target)
 
     def getAvatarFile(self, hash):
-        return self.db_comm_iface.getAvatarFile(hash)
+        return self.db_plugin_iface.getAvatarFile(hash)
 
     def in_band_register(self, target, profile_key='@DEFAULT@'):
-        return self.db_comm_iface.in_band_register(target, profile_key)
+        return self.db_plugin_iface.in_band_register(target, profile_key)
 
     def gatewayRegister(self, action, target, data, profile_key='@DEFAULT@'):
         if data == None:
             data = [('', '')] #XXX: we have to do this awful hack because python dbus need to guess the signature
-        return self.db_req_iface.gatewayRegister(action, target, data, profile_key)
+        return self.db_plugin_iface.gatewayRegister(action, target, data, profile_key)
 
     def getLastMicroblogs(self, jid, max_items, profile_key='@DEFAULT@', callback=None, errback=None):
-        return self.db_comm_iface.getLastMicroblogs(jid, max_items, profile_key, reply_handler=callback, error_handler=errback)
+        return self.db_plugin_iface.getLastMicroblogs(jid, max_items, profile_key, reply_handler=callback, error_handler=errback)
 
     def getMblogNodes(self, profile_key='@DEFAULT@', callback=None, errback=None):
-        return self.db_comm_iface.getMblogNodes(profile_key, reply_handler=callback, error_handler=errback)
+        return self.db_plugin_iface.getMblogNodes(profile_key, reply_handler=callback, error_handler=errback)
     
     def sendGroupBlog(self, groups, message, profile_key='@DEFAULT@'):
-        return self.db_comm_iface.sendGroupBlog(groups, message, profile_key)
+        return self.db_plugin_iface.sendGroupBlog(groups, message, profile_key)
     
     def sendPersonalEvent(self, event_type, data, profile_key='@DEFAULT@'):
-        return self.db_comm_iface.sendPersonalEvent(event_type, data, profile_key)
+        return self.db_plugin_iface.sendPersonalEvent(event_type, data, profile_key)
     
     def setMicroblogAccess(self, access="presence", profile_key='@DEFAULT@', callback=None, errback=None):
-        return self.db_comm_iface.setMicroblogAccess(access, profile_key, reply_handler=callback, error_handler=errback)
+        return self.db_plugin_iface.setMicroblogAccess(access, profile_key, reply_handler=callback, error_handler=errback)