[Telepathy-commits] [telepathy-sofiasip/master] Incomplete test for AcknowledgePendingMessages
Mikhail Zabaluev
mikhail.zabaluev at nokia.com
Fri Oct 24 04:16:33 PDT 2008
Also tightened up header formation in fake proxy messages
---
tests/twisted/test-message.py | 14 ++++++++++++--
1 files changed, 12 insertions(+), 2 deletions(-)
diff --git a/tests/twisted/test-message.py b/tests/twisted/test-message.py
index 9994c2b..ce65b88 100644
--- a/tests/twisted/test-message.py
+++ b/tests/twisted/test-message.py
@@ -52,6 +52,7 @@ def test(q, bus, conn, sip):
prevhdr = event.sip_message.headers
q.expect('dbus-signal', signal='Sent')
+
url = twisted.protocols.sip.parseURL('sip:testacc at 127.0.0.1')
msg = twisted.protocols.sip.Request('MESSAGE', url)
send_message(sip, prevhdr, 'Hi')
@@ -59,6 +60,10 @@ def test(q, bus, conn, sip):
event = q.expect('dbus-signal', signal='NewChannel')
assert (event.args[1] == TEXT_TYPE and event.args[2] == 1)
+ # start using the new channel object
+ new_obj = bus.get_object(conn._named_service, event.args[0])
+ iface = dbus.Interface(new_obj, TEXT_TYPE)
+
handle = event.args[3]
name = conn.InspectHandles(1, [handle])[0]
@@ -66,6 +71,9 @@ def test(q, bus, conn, sip):
event = q.expect('dbus-signal', signal='Received')
assert event.args[5] == 'Hi'
+ iface.AcknowledgePendingMessages([event.args[0]])
+
+ # TODO: close the old channel
# Test conversion from an 8-bit encoding.
# Due to limited set of encodings available in some environments,
@@ -99,11 +107,13 @@ def send_message(sip, prevhdr, body, encoding=None):
msg.addHeader('content-type', 'text/plain; charset=%s' % encoding)
msg.addHeader('content-length', '%d' % len(msg.body))
msg.addHeader('call-id', prevhdr['call-id'][0])
- msg.addHeader('via', 'SIP/2.0/UDP 127.0.0.1;branch=ABCXYZ')
+ via = sip.getVia()
+ via.branch = 'z9hG4bKXYZ'
+ msg.addHeader('via', via.toString())
destVia = twisted.protocols.sip.parseViaHeader(prevhdr['via'][0])
host = destVia.received or destVia.host
- port = destVia.rport or destVia.port or self.PORT
+ port = destVia.rport or destVia.port
destAddr = twisted.protocols.sip.URL(host=host, port=port)
sip.sendMessage(destAddr, msg)
return True
--
1.5.6.5
More information about the Telepathy-commits
mailing list