summaryrefslogtreecommitdiff
path: root/tests
diff options
context:
space:
mode:
authorWill Thompson <will.thompson@collabora.co.uk>2009-03-23 09:27:10 (GMT)
committerWill Thompson <will.thompson@collabora.co.uk>2009-03-23 11:10:58 (GMT)
commit9c0918273c4d588cc9b34de7a7ea1fc05afd48fa (patch)
tree817e1da0276635c4e6cd23be6198c6c3114d9ec2 /tests
parent9c2c89340bbb042d81956646d4af51299baba7ee (diff)
downloadtelepathy-haze-9c0918273c4d588cc9b34de7a7ea1fc05afd48fa.tar.gz
telepathy-haze-9c0918273c4d588cc9b34de7a7ea1fc05afd48fa.tar.xz
Steal Destroy() test from Gabble
Diffstat (limited to 'tests')
-rw-r--r--tests/twisted/Makefile.am1
-rw-r--r--tests/twisted/text/destroy.py139
2 files changed, 140 insertions, 0 deletions
diff --git a/tests/twisted/Makefile.am b/tests/twisted/Makefile.am
index 04a4630..4d85717 100644
--- a/tests/twisted/Makefile.am
+++ b/tests/twisted/Makefile.am
@@ -2,6 +2,7 @@ TWISTED_TESTS = \
connect/success.py \
connect/fail.py \
presence/presence.py \
+ text/destroy.py \
text/ensure.py \
text/initiate-requestotron.py \
text/initiate.py \
diff --git a/tests/twisted/text/destroy.py b/tests/twisted/text/destroy.py
new file mode 100644
index 0000000..6e488da
--- /dev/null
+++ b/tests/twisted/text/destroy.py
@@ -0,0 +1,139 @@
+"""
+Test text channel not being recreated because although there were still
+pending messages, we destroyed it with extreme prejudice.
+"""
+
+import dbus
+
+from twisted.words.xish import domish
+
+from hazetest import exec_test
+from servicetest import call_async, EventPattern, tp_path_prefix
+
+def test(q, bus, conn, stream):
+ conn.Connect()
+ q.expect('dbus-signal', signal='StatusChanged', args=[0, 1])
+
+ self_handle = conn.GetSelfHandle()
+
+ jid = 'foo@bar.com'
+ call_async(q, conn, 'RequestHandles', 1, [jid])
+
+ event = q.expect('dbus-return', method='RequestHandles')
+ foo_handle = event.value[0][0]
+
+ call_async(q, conn, 'RequestChannel',
+ 'org.freedesktop.Telepathy.Channel.Type.Text', 1, foo_handle, True)
+
+ ret, old_sig, new_sig = q.expect_many(
+ EventPattern('dbus-return', method='RequestChannel'),
+ EventPattern('dbus-signal', signal='NewChannel'),
+ EventPattern('dbus-signal', signal='NewChannels'),
+ )
+
+ text_chan = bus.get_object(conn.bus_name, ret.value[0])
+ chan_iface = dbus.Interface(text_chan,
+ 'org.freedesktop.Telepathy.Channel')
+ text_iface = dbus.Interface(text_chan,
+ 'org.freedesktop.Telepathy.Channel.Type.Text')
+ destroyable_iface = dbus.Interface(text_chan,
+ 'org.freedesktop.Telepathy.Channel.Interface.Destroyable')
+
+ assert old_sig.args[0] == ret.value[0]
+ assert old_sig.args[1] == u'org.freedesktop.Telepathy.Channel.Type.Text'
+ # check that handle type == contact handle
+ assert old_sig.args[2] == 1
+ assert old_sig.args[3] == foo_handle
+ assert old_sig.args[4] == True # suppress handler
+
+ assert len(new_sig.args) == 1
+ assert len(new_sig.args[0]) == 1 # one channel
+ assert len(new_sig.args[0][0]) == 2 # two struct members
+ assert new_sig.args[0][0][0] == ret.value[0]
+ emitted_props = new_sig.args[0][0][1]
+ assert emitted_props['org.freedesktop.Telepathy.Channel.ChannelType'] ==\
+ 'org.freedesktop.Telepathy.Channel.Type.Text'
+ assert emitted_props['org.freedesktop.Telepathy.Channel.'
+ 'TargetHandleType'] == 1
+ assert emitted_props['org.freedesktop.Telepathy.Channel.TargetHandle'] ==\
+ foo_handle
+ assert emitted_props['org.freedesktop.Telepathy.Channel.TargetID'] == jid
+ assert emitted_props['org.freedesktop.Telepathy.Channel.'
+ 'Requested'] == True
+ assert emitted_props['org.freedesktop.Telepathy.Channel.'
+ 'InitiatorHandle'] == self_handle
+ assert emitted_props['org.freedesktop.Telepathy.Channel.'
+ 'InitiatorID'] == 'test@localhost'
+
+ channel_props = text_chan.GetAll(
+ 'org.freedesktop.Telepathy.Channel',
+ dbus_interface=dbus.PROPERTIES_IFACE)
+ assert channel_props['TargetID'] == jid,\
+ (channel_props['TargetID'], jid)
+ assert channel_props['Requested'] == True
+ assert channel_props['InitiatorHandle'] == self_handle,\
+ (channel_props['InitiatorHandle'], self_handle)
+ assert channel_props['InitiatorID'] == 'test@localhost',\
+ channel_props['InitiatorID']
+
+ text_iface.Send(0, 'hey')
+
+ event = q.expect('stream-message')
+
+ elem = event.stanza
+ assert elem.name == 'message'
+ assert elem['type'] == 'chat'
+ body = list(event.stanza.elements())[0]
+ assert body.name == 'body'
+ assert body.children[0] == u'hey'
+
+ # <message type="chat"><body>hello</body</message>
+ m = domish.Element((None, 'message'))
+ m['from'] = 'foo@bar.com/Pidgin'
+ m['type'] = 'chat'
+ m.addElement('body', content='hello')
+ stream.send(m)
+
+ event = q.expect('dbus-signal', signal='Received')
+
+ hello_message_id = event.args[0]
+ hello_message_time = event.args[1]
+ assert event.args[2] == foo_handle
+ # message type: normal
+ assert event.args[3] == 0
+ # flags: none
+ assert event.args[4] == 0
+ # body
+ assert event.args[5] == 'hello'
+
+ messages = text_chan.ListPendingMessages(False,
+ dbus_interface='org.freedesktop.Telepathy.Channel.Type.Text')
+ assert messages == \
+ [(hello_message_id, hello_message_time, foo_handle,
+ 0, 0, 'hello')], messages
+
+ # destroy the channel without acking the message; it does not come back
+
+ call_async(q, destroyable_iface, 'Destroy')
+
+ event = q.expect('dbus-signal', signal='Closed')
+ assert tp_path_prefix + event.path == text_chan.object_path,\
+ (tp_path_prefix + event.path, text_chan.object_path)
+
+ event = q.expect('dbus-return', method='Destroy')
+
+ # assert that it stays dead
+
+ try:
+ chan_iface.GetChannelType()
+ except dbus.DBusException:
+ pass
+ else:
+ raise AssertionError("Why won't it die?")
+
+ conn.Disconnect()
+ q.expect('dbus-signal', signal='StatusChanged', args=[2, 1])
+
+if __name__ == '__main__':
+ exec_test(test)
+