diff options
author | Jonny Lamb <jonny.lamb@collabora.co.uk> | 2011-01-03 15:27:35 +0000 |
---|---|---|
committer | Jonny Lamb <jonny.lamb@collabora.co.uk> | 2011-01-03 15:27:55 +0000 |
commit | bb5ea0cb107b80933d886e17059f9662058db2d0 (patch) | |
tree | 200a7fc15f9a48d4b658c64223b815c9c26aba05 | |
parent | 8ef108d09cba245f71cdb6dc2a18cfc4ed2d7025 (diff) | |
download | telepathy-mission-control-bb5ea0cb107b80933d886e17059f9662058db2d0.tar.gz |
delay-then-dont-call-approvers.py: test non-interactive approvers
Signed-off-by: Jonny Lamb <jonny.lamb@collabora.co.uk>
-rw-r--r-- | test/twisted/Makefile.am | 1 | ||||
-rw-r--r-- | test/twisted/dispatcher/delay-then-dont-call-approvers.py | 128 |
2 files changed, 129 insertions, 0 deletions
diff --git a/test/twisted/Makefile.am b/test/twisted/Makefile.am index 9c57ec3d..6f5bdaad 100644 --- a/test/twisted/Makefile.am +++ b/test/twisted/Makefile.am @@ -41,6 +41,7 @@ TWISTED_BASIC_TESTS = \ dispatcher/create-text.py \ dispatcher/created-behind-our-back.py \ dispatcher/delay-approvers.py \ + dispatcher/delay-then-dont-call-approvers.py \ dispatcher/dispatch-activatable.py \ dispatcher/dispatch-before-connected.py \ dispatcher/dispatch-delayed-by-mini-plugin.py \ diff --git a/test/twisted/dispatcher/delay-then-dont-call-approvers.py b/test/twisted/dispatcher/delay-then-dont-call-approvers.py new file mode 100644 index 00000000..90040228 --- /dev/null +++ b/test/twisted/dispatcher/delay-then-dont-call-approvers.py @@ -0,0 +1,128 @@ +# Copyright (C) 2010 Collabora Ltd. +# +# This library is free software; you can redistribute it and/or +# modify it under the terms of the GNU Lesser General Public +# License as published by the Free Software Foundation; either +# version 2.1 of the License, or (at your option) any later version. +# +# This library is distributed in the hope that it will be useful, but +# WITHOUT ANY WARRANTY; without even the implied warranty of +# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU +# Lesser General Public License for more details. +# +# You should have received a copy of the GNU Lesser General Public +# License along with this library; if not, write to the Free Software +# Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA +# 02110-1301 USA + +import dbus +import dbus.bus +import dbus.service + +from servicetest import EventPattern, tp_name_prefix, tp_path_prefix, \ + call_async, sync_dbus +from mctest import exec_test, SimulatedConnection, SimulatedClient, \ + create_fakecm_account, enable_fakecm_account, SimulatedChannel, \ + expect_client_setup +import constants as cs + +def test(q, bus, mc): + params = dbus.Dictionary({"account": "someguy@example.com", + "password": "secrecy"}, signature='sv') + cm_name_ref, account = create_fakecm_account(q, bus, mc, params) + conn = enable_fakecm_account(q, bus, mc, account, params) + + text_fixed_properties = dbus.Dictionary({ + cs.CHANNEL + '.TargetHandleType': cs.HT_CONTACT, + cs.CHANNEL + '.ChannelType': cs.CHANNEL_TYPE_TEXT, + }, signature='sv') + + # Empathy is an observer for text channels with + # DelayApprovers=TRUE. + empathy = SimulatedClient(q, bus, 'Empathy', + observe=[text_fixed_properties], approve=[], + handle=[], delay_approvers=True) + + # Kopete is an approver and handler for text channels. + kopete = SimulatedClient(q, bus, 'Kopete', + observe=[], approve=[text_fixed_properties], + handle=[text_fixed_properties]) + + expect_client_setup(q, [empathy, kopete]) + + # subscribe to the OperationList interface (MC assumes that until this + # property has been retrieved once, nobody cares) + + cd = bus.get_object(cs.CD, cs.CD_PATH) + cd_props = dbus.Interface(cd, cs.PROPERTIES_IFACE) + assert cd_props.Get(cs.CD_IFACE_OP_LIST, 'DispatchOperations') == [] + + # A text channel appears! + channel_properties = dbus.Dictionary(text_fixed_properties, + signature='sv') + channel_properties[cs.CHANNEL + '.TargetID'] = 'juliet' + channel_properties[cs.CHANNEL + '.TargetHandle'] = \ + conn.ensure_handle(cs.HT_CONTACT, 'juliet') + channel_properties[cs.CHANNEL + '.InitiatorID'] = 'juliet' + channel_properties[cs.CHANNEL + '.InitiatorHandle'] = \ + conn.ensure_handle(cs.HT_CONTACT, 'juliet') + channel_properties[cs.CHANNEL + '.Requested'] = False + channel_properties[cs.CHANNEL + '.Interfaces'] = dbus.Array(signature='s') + + chan = SimulatedChannel(conn, channel_properties) + chan.announce() + + e = q.expect('dbus-signal', + path=cs.CD_PATH, + interface=cs.CD_IFACE_OP_LIST, + signal='NewDispatchOperation') + + cdo_path = e.args[0] + cdo = bus.get_object(cs.CD, cdo_path) + cdo_iface = dbus.Interface(cdo, cs.CDO) + cdo_props_iface = dbus.Interface(cdo, cs.PROPERTIES_IFACE) + + # Empathy, the observer, gets the channel to observe. Because it + # has DelayApprovers=TRUE, Kopete should not have + # AddDispatchOperation called on it until Empathy returns from + # ObserveChannels, but Empathy will call Claim on the CDO so we + # should ensure neither ADO or HC is called on any of our clients. + forbidden = [EventPattern('dbus-method-call', + interface=cs.APPROVER, method='AddDispatchOperation'), + EventPattern('dbus-method-call', + interface=cs.HANDLER, method='HandleChannels')] + q.forbid_events(forbidden) + + o = q.expect('dbus-method-call', + path=empathy.object_path, + interface=cs.OBSERVER, method='ObserveChannels', + handled=False) + + # Waste a little time here and there. We can't call sync_dbus + # here because it calls Ping and libdbus returns from Ping + # synchronously and doesn't turn the main loop handle enough. + call_async(q, cd_props, 'Get', cs.CD_IFACE_OP_LIST, 'DispatchOperations') + event = q.expect('dbus-return', method='Get') + + # We can't call this synchronously because MC won't return until + # ObserveChannels calls return. + call_async(q, cdo_iface, 'Claim') + + # Finally return from ObserveChannels. + q.dbus_return(o.message, bus=bus, signature='') + + q.expect('dbus-return', method='Claim') + + q.expect_many( + EventPattern('dbus-signal', interface=cs.CDO, signal='Finished'), + EventPattern('dbus-signal', interface=cs.CD_IFACE_OP_LIST, + signal='DispatchOperationFinished'), + ) + + # Now there are no more active channel dispatch operations + assert cd_props.Get(cs.CD_IFACE_OP_LIST, 'DispatchOperations') == [] + + q.unforbid_events(forbidden) + +if __name__ == '__main__': + exec_test(test, {}) |