From 0a896168838ce192cc93ef513f0cc43560f71c4f Mon Sep 17 00:00:00 2001
From: Ed Page <eopage@byu.net>
Date: Thu, 4 Feb 2010 08:05:35 -0600
Subject: [PATCH] Getting closer to an auto-accept calls system

---
 hand_tests/dbus_signals.py |  114 +++++++++++++++++++++++++++++++++++---------
 1 file changed, 92 insertions(+), 22 deletions(-)

diff --git a/hand_tests/dbus_signals.py b/hand_tests/dbus_signals.py
index c6805ca..512d19b 100755
--- a/hand_tests/dbus_signals.py
+++ b/hand_tests/dbus_signals.py
@@ -9,27 +9,39 @@ import telepathy
 DBUS_PROPERTIES = 'org.freedesktop.DBus.Properties'
 
 
-class AutoAcceptCall(object):
+class AutoAcceptAttempt(object):
 
-	def __init__(self):
-		self._sessionBus = dbus.SessionBus()
-		self._chan = None
+	def __init__(self, bus, chan):
+		self._sessionBus = bus
+		self._chan = chan
 
-	def start(self):
-		self._sessionBus.add_signal_receiver(
-			self._on_new_channel,
-			"NewChannel",
-			"org.freedesktop.Telepathy.Connection",
-			None,
-			None
-		)
+		self._selfHandle = None
+		self._initiatorHandle = None
+		self._initiatorID = None
+		self._targetHandle = None
+		self._targetID = None
+		self._pendingHandles = None
 
-	def _on_new_channel(self, channelObjectPath, channelType, handleType, handle, supressHandler):
-		if channelType != telepathy.interfaces.CHANNEL_TYPE_STREAMED_MEDIA:
-			return
+		if False:
+			# @bug Unsure why this isn't working
+			self._chan[DBUS_PROPERTIES].Get(
+				telepathy.interfaces.CONNECTION_INTERFACE,
+				'SelfHandle',
+				reply_handler = self._on_got_self_handle,
+				error_handler = self._on_nothing,
+			)
+		else:
+			self._chan[telepathy.interfaces.CHANNEL_INTERFACE_GROUP].GetSelfHandle(
+				reply_handler = self._on_got_self_handle,
+				error_handler = self._on_nothing,
+			)
+
+		self._chan[DBUS_PROPERTIES].GetAll(
+			telepathy.interfaces.CHANNEL_INTERFACE,
+			reply_handler = self._on_got_all,
+			error_handler = self._on_nothing,
+		)
 
-		serviceName = channelObjectPath.rsplit("/", 1)[0][1:].replace("/", ".")
-		self._chan = telepathy.client.Channel(serviceName, channelObjectPath)
 		if False:
 			# @bug Unsure why this isn't working
 			self._chan[DBUS_PROPERTIES].Get(
@@ -44,18 +56,46 @@ class AutoAcceptCall(object):
 				error_handler = self._on_nothing,
 			)
 
-	def _on_got_pending_members(self, pendings):
-		for pendingHandle, instigatorHandle, reason, message in pendings:
-			print pendingHandle, instigatorHandle, reason, message
+	def _pickup_if_ready(self):
+		if None in (
+			self._selfHandle,
+			self._initiatorHandle,
+			self._initiatorID,
+			self._targetHandle,
+			self._targetID,
+			self._pendingHandles,
+		):
+			# Note ready yet, still some outstanding requests
+			return
+
+		if self._selfHandle != self._targetHandle:
+			# Turns out it was an inbound call
+			return
 
-		# @bug does not distinguish between inbound and outbound channels
 		# @bug does not distinguish between who the call is from for use for TOR auto-pickup
-		pendingHandles = [pendingWithInfo[0] for pendingWithInfo in pendings]
 		self._chan[telepathy.interfaces.CHANNEL_INTERFACE_GROUP].AddMembers(
 			reply_handler = self._on_members_added,
 			error_handler = self._on_nothing,
 		)
 
+	def _on_got_self_handle(self, selfHandle):
+		self._pickup_if_ready()
+
+	def _on_got_all(self, properties):
+		self._initiatorID = properties["InitiatorID"]
+		self._initiatorHandle = properties["InitiatorHandle"]
+		self._targetID = properties["InitiatorID"]
+		self._targetHandle = properties["InitiatorHandle"]
+
+		self._pickup_if_ready()
+
+	def _on_got_pending_members(self, pendings):
+		for pendingHandle, instigatorHandle, reason, message in pendings:
+			print pendingHandle, instigatorHandle, reason, message
+
+		self._pendingHandles = [pendingWithInfo[0] for pendingWithInfo in pendings]
+		self._pickup_if_ready()
+
 	def _on_members_added(self):
 		print "Should be picked up now"
 
@@ -63,6 +103,36 @@ class AutoAcceptCall(object):
 		print "ERROR", args
 
 
+class AutoAcceptCall(object):
+
+	def __init__(self):
+		self._sessionBus = dbus.SessionBus()
+		self._activeAttempts = []
+
+	def start(self):
+		self._sessionBus.add_signal_receiver(
+			self._on_new_channel,
+			"NewChannel",
+			"org.freedesktop.Telepathy.Connection",
+			None,
+			None
+		)
+
+	def _on_new_channel(self, channelObjectPath, channelType, handleType, handle, supressHandler):
+		if channelType != telepathy.interfaces.CHANNEL_TYPE_STREAMED_MEDIA:
+			return
+
+		serviceName = channelObjectPath.rsplit("/", 1)[0][1:].replace("/", ".")
+		chan = telepathy.client.Channel(serviceName, channelObjectPath)
+		# @bug does not distinguish between preferred CMs
+		# @todo Need a way to be notified on error, ignored, or if picked up
+		attemptPickup = AutoAcceptAttempt(self._sessionBus, chan)
+		self._activeAttempts.append(attemptPickup)
+
+	def _on_nothing(*args):
+		print "ERROR", args
+
+
 if __name__ == "__main__":
 	l = dbus.mainloop.glib.DBusGMainLoop(set_as_default=True)
 	autoaccept = AutoAcceptCall()
-- 
1.7.9.5