X-Git-Url: http://git.maemo.org/git/?p=theonering;a=blobdiff_plain;f=src%2Fcapabilities.py;h=a64c38bb0456deff522d99714f1d4def464acc74;hp=6c7ba15e5efe9d6aa264d1f2d866ceb90f6153c5;hb=8894c48314aa35230635af3f4ae8814234ae3fa1;hpb=a840b976430685dbf23bee4e590d1ee23594728c

diff --git a/src/capabilities.py b/src/capabilities.py
index 6c7ba15..a64c38b 100644
--- a/src/capabilities.py
+++ b/src/capabilities.py
@@ -1,11 +1,105 @@
 import logging
 
+import dbus
+import telepathy
+
 import tp
+from tp._generated import Connection_Interface_Contact_Capabilities
+import util.misc as misc_utils
+
+
+_moduleLogger = logging.getLogger(__name__)
+
+
+class CapabilitiesMixin(
+	tp.ConnectionInterfaceCapabilities,
+	Connection_Interface_Contact_Capabilities.ConnectionInterfaceContactCapabilities,
+):
+
+	_CAPABILITIES = {
+		telepathy.CHANNEL_TYPE_TEXT: (
+			telepathy.CONNECTION_CAPABILITY_FLAG_CREATE,
+			0,
+		),
+		telepathy.CHANNEL_TYPE_STREAMED_MEDIA: (
+			telepathy.CONNECTION_CAPABILITY_FLAG_CREATE |
+				telepathy.CONNECTION_CAPABILITY_FLAG_INVITE,
+			telepathy.CHANNEL_MEDIA_CAPABILITY_AUDIO,
+		),
+	}
+
+	text_chat_class = (
+		{
+			telepathy.CHANNEL_INTERFACE + '.ChannelType': telepathy.CHANNEL_TYPE_TEXT,
+			telepathy.CHANNEL_INTERFACE + '.TargetHandleType': dbus.UInt32(telepathy.HANDLE_TYPE_CONTACT),
+		},
+		[
+			telepathy.CHANNEL_INTERFACE + '.TargetHandle',
+			telepathy.CHANNEL_INTERFACE + '.TargetID',
+		],
+	)
+
+	audio_chat_class = (
+		{
+			telepathy.CHANNEL_INTERFACE + '.ChannelType': telepathy.CHANNEL_TYPE_STREAMED_MEDIA,
+			telepathy.CHANNEL_INTERFACE + '.TargetHandleType': dbus.UInt32(telepathy.HANDLE_TYPE_CONTACT),
+		},
+		[
+			telepathy.CHANNEL_INTERFACE + '.TargetHandle',
+			telepathy.CHANNEL_INTERFACE + '.TargetID',
+			telepathy.CHANNEL_TYPE_STREAMED_MEDIA + '.InitialAudio',
+		],
+	)
+
+	av_chat_class = (
+		{
+			telepathy.CHANNEL_INTERFACE + '.ChannelType': telepathy.CHANNEL_TYPE_STREAMED_MEDIA,
+			telepathy.CHANNEL_INTERFACE + '.TargetHandleType': dbus.UInt32(telepathy.HANDLE_TYPE_CONTACT),
+		},
+		[
+			telepathy.CHANNEL_INTERFACE + '.TargetHandle',
+			telepathy.CHANNEL_INTERFACE + '.TargetID',
+			telepathy.CHANNEL_TYPE_STREAMED_MEDIA + '.InitialAudio',
+			telepathy.CHANNEL_TYPE_STREAMED_MEDIA + '.InitialVideo',
+		],
+	)
+
+	def __init__(self):
+		tp.ConnectionInterfaceCapabilities.__init__(self)
+		Connection_Interface_Contact_Capabilities.ConnectionInterfaceContactCapabilities.__init__(self)
+
+	def get_handle_by_id(self, handleType, handleId):
+		"""
+		@abstract
+		"""
+		raise NotImplementedError("Abstract function called")
+
+	@misc_utils.log_exception(_moduleLogger)
+	def GetCapabilities(self, handleIds):
+		ret = []
+		for handleId in handleIds:
+			if handleId != 0 and (telepathy.HANDLE_TYPE_CONTACT, handleId) not in self._handles:
+				raise telepathy.errors.InvalidHandle
 
+			h = self.get_handle_by_id(telepathy.HANDLE_TYPE_CONTACT, handleId)
+			for type, (gen, spec) in self._CAPABILITIES.iteritems():
+				ret.append([handleId, type, gen, spec])
+		return ret
 
-_moduleLogger = logging.getLogger('capabilities')
+	def GetContactCapabilities(self, handles):
+		if 0 in handles:
+			raise telepathy.InvalidHandle('Contact handle list contains zero')
 
+		ret = dbus.Dictionary({}, signature='ua(a{sv}as)')
+		for i in handles:
+			handle = self.get_handle_by_id(telepathy.HANDLE_TYPE_CONTACT, i)
+			contactCapabilities = dbus.Dictionary(
+				(self.text_chat_class, self.audio_chat_class),
+				signature="sv",
+			)
+			ret[handle] = dbus.Array(contactCapabilities, signature='(a{sv}as)')
 
-class CapabilitiesMixin(tp.ConnectionInterfaceCapabilities):
+		return ret
 
-	pass
+	def UpdateCapabilities(self, caps):
+		_moduleLogger.info("Ignoring updating contact capabilities")