[telepathy-gabble/master] ceci-nest-pas-un-serveur.py: use make_result_iq and send_error_reply

Guillaume Desmottes guillaume.desmottes at collabora.co.uk
Wed Aug 26 09:22:09 PDT 2009


---
 tests/twisted/search/ceci-nest-pas-un-serveur.py |   31 ++++++++++------------
 1 files changed, 14 insertions(+), 17 deletions(-)

diff --git a/tests/twisted/search/ceci-nest-pas-un-serveur.py b/tests/twisted/search/ceci-nest-pas-un-serveur.py
index b691bad..1c8db2b 100644
--- a/tests/twisted/search/ceci-nest-pas-un-serveur.py
+++ b/tests/twisted/search/ceci-nest-pas-un-serveur.py
@@ -6,8 +6,9 @@ fake servers which are broken in various ways.
 import dbus
 
 from twisted.words.protocols.jabber.client import IQ
+from twisted.words.xish import domish
 
-from gabbletest import exec_test
+from gabbletest import exec_test, send_error_reply, make_result_iq
 from servicetest import call_async, unwrap, make_channel_proxy, EventPattern
 
 from pprint import pformat
@@ -34,12 +35,10 @@ def call_create(q, requests, server):
 def not_a_search_server(q, stream, requests):
     iq = call_create(q, requests, 'notajud.localhost')
 
-    result = iq
-    result['type'] = 'error'
-    e = result.addElement('error')
+    e = domish.Element((None, 'error'))
     e['type'] = 'cancel'
     e.addElement((ns.STANZA, 'service-unavailable'))
-    stream.send(result)
+    send_error_reply(stream, iq, e)
 
     event = q.expect('dbus-error', method='CreateChannel')
     assert event.error.get_dbus_name() == cs.NOT_AVAILABLE, event.error
@@ -47,9 +46,8 @@ def not_a_search_server(q, stream, requests):
 def returns_invalid_fields(q, stream, requests):
     iq = call_create(q, requests, 'broken.localhost')
 
-    result = IQ(stream, "result")
-    result["id"] = iq["id"]
-    query = result.addElement((ns.SEARCH, 'query'))
+    result = make_result_iq(stream, iq)
+    query = result.firstChildElement()
     for f in ["first", "shoe-size", "nick", "star-sign"]:
         query.addElement(f)
     stream.send(result)
@@ -61,9 +59,8 @@ def returns_error_from_search(q, stream, conn, requests):
     server = 'nofunforyou.localhost'
     iq = call_create(q, requests, server)
 
-    result = IQ(stream, "result")
-    result["id"] = iq["id"]
-    query = result.addElement((ns.SEARCH, 'query'))
+    result = make_result_iq(stream, iq)
+    query = result.firstChildElement()
     query.addElement("first")
     stream.send(result)
 
@@ -76,13 +73,13 @@ def returns_error_from_search(q, stream, conn, requests):
         EventPattern('stream-iq', to=server, query_ns=ns.SEARCH),
         EventPattern('dbus-signal', signal='SearchStateChanged'),
         )
+
     iq = iq_event.stanza
-    iq['type'] = 'error'
-    error = iq.addElement('error')
+    error = domish.Element((None, 'error'))
     error['type'] = 'modify'
     error.addElement((ns.STANZA, 'not-acceptable'))
     error.addElement((ns.STANZA, 'text'), content="We don't believe in games here.")
-    stream.send(iq)
+    send_error_reply(stream, iq, error)
 
     ssc = q.expect('dbus-signal', signal='SearchStateChanged')
     new_state, reason, details = ssc.args
@@ -100,9 +97,8 @@ def returns_bees_from_search(q, stream, conn, requests):
     server = 'hivemind.localhost'
     iq = call_create(q, requests, server)
 
-    result = IQ(stream, "result")
-    result["id"] = iq["id"]
-    query = result.addElement((ns.SEARCH, 'query'))
+    result = make_result_iq(stream, iq)
+    query = result.firstChildElement()
     query.addElement("nick")
     stream.send(result)
 
@@ -119,6 +115,7 @@ def returns_bees_from_search(q, stream, conn, requests):
 
     result = IQ(stream, 'result')
     result['id'] = iq['id']
+    result['from'] = iq['to']
     result.addElement((ns.SEARCH, 'bees')).addElement('bzzzzzzz')
     stream.send(result)
 
-- 
1.5.6.5




More information about the telepathy-commits mailing list