mirror of
https://github.com/vanitasvitae/Smack.git
synced 2024-12-23 11:07:57 +01:00
faa0f21906
git-svn-id: http://svn.igniterealtime.org/svn/repos/smack/branches/smack_3_4_0@13883 b35dd754-fafc-0310-a699-88a17e54d16e
224 lines
7.8 KiB
Java
224 lines
7.8 KiB
Java
/**
|
|
* Copyright 2012 Florian Schmaus
|
|
*
|
|
* All rights reserved. Licensed under the Apache License, Version 2.0 (the "License");
|
|
* you may not use this file except in compliance with the License.
|
|
* You may obtain a copy of the License at
|
|
*
|
|
* http://www.apache.org/licenses/LICENSE-2.0
|
|
*
|
|
* Unless required by applicable law or agreed to in writing, software
|
|
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
* See the License for the specific language governing permissions and
|
|
* limitations under the License.
|
|
*/
|
|
package org.jivesoftware.smackx.ping;
|
|
|
|
import static org.junit.Assert.assertEquals;
|
|
import static org.junit.Assert.assertFalse;
|
|
import static org.junit.Assert.assertTrue;
|
|
|
|
import org.jivesoftware.smack.DummyConnection;
|
|
import org.jivesoftware.smack.ThreadedDummyConnection;
|
|
import org.jivesoftware.smack.packet.IQ;
|
|
import org.jivesoftware.smack.packet.Packet;
|
|
import org.jivesoftware.smack.ping.packet.Ping;
|
|
import org.jivesoftware.smack.test.util.TestUtils;
|
|
import org.jivesoftware.smack.util.PacketParserUtils;
|
|
import org.jivesoftware.smackx.packet.DiscoverInfo;
|
|
import org.junit.Before;
|
|
import org.junit.Test;
|
|
|
|
public class PingTest {
|
|
private DummyConnection dummyCon;
|
|
private ThreadedDummyConnection threadedCon;
|
|
|
|
@Before
|
|
public void setup() {
|
|
dummyCon = new DummyConnection();
|
|
threadedCon = new ThreadedDummyConnection();
|
|
}
|
|
|
|
@Test
|
|
public void checkProvider() throws Exception {
|
|
// @formatter:off
|
|
String control = "<iq from='capulet.lit' to='juliet@capulet.lit/balcony' id='s2c1' type='get'>"
|
|
+ "<ping xmlns='urn:xmpp:ping'/>"
|
|
+ "</iq>";
|
|
// @formatter:on
|
|
DummyConnection con = new DummyConnection();
|
|
|
|
// Enable ping for this connection
|
|
PingManager.getInstanceFor(con);
|
|
IQ pingRequest = PacketParserUtils.parseIQ(TestUtils.getIQParser(control), con);
|
|
|
|
assertTrue(pingRequest instanceof Ping);
|
|
|
|
con.processPacket(pingRequest);
|
|
|
|
Packet pongPacket = con.getSentPacket();
|
|
assertTrue(pongPacket instanceof IQ);
|
|
|
|
IQ pong = (IQ) pongPacket;
|
|
assertEquals("juliet@capulet.lit/balcony", pong.getFrom());
|
|
assertEquals("capulet.lit", pong.getTo());
|
|
assertEquals("s2c1", pong.getPacketID());
|
|
assertEquals(IQ.Type.RESULT, pong.getType());
|
|
}
|
|
|
|
@Test
|
|
public void checkSendingPing() throws Exception {
|
|
dummyCon = new DummyConnection();
|
|
PingManager pinger = PingManager.getInstanceFor(dummyCon);
|
|
pinger.ping("test@myserver.com");
|
|
|
|
Packet sentPacket = dummyCon.getSentPacket();
|
|
|
|
assertTrue(sentPacket instanceof Ping);
|
|
|
|
}
|
|
|
|
@Test
|
|
public void checkSuccessfulPing() throws Exception {
|
|
threadedCon = new ThreadedDummyConnection();
|
|
|
|
PingManager pinger = PingManager.getInstanceFor(threadedCon);
|
|
|
|
boolean pingSuccess = pinger.ping("test@myserver.com");
|
|
|
|
assertTrue(pingSuccess);
|
|
|
|
}
|
|
|
|
/**
|
|
* DummyConnection will not reply so it will timeout.
|
|
* @throws Exception
|
|
*/
|
|
@Test
|
|
public void checkFailedPingOnTimeout() throws Exception {
|
|
dummyCon = new DummyConnection();
|
|
PingManager pinger = PingManager.getInstanceFor(dummyCon);
|
|
|
|
boolean pingSuccess = pinger.ping("test@myserver.com");
|
|
|
|
assertFalse(pingSuccess);
|
|
|
|
}
|
|
|
|
/**
|
|
* Server returns an exception for entity.
|
|
* @throws Exception
|
|
*/
|
|
@Test
|
|
public void checkFailedPingToEntityError() throws Exception {
|
|
threadedCon = new ThreadedDummyConnection();
|
|
//@formatter:off
|
|
String reply =
|
|
"<iq type='error' id='qrzSp-16' to='test@myserver.com'>" +
|
|
"<ping xmlns='urn:xmpp:ping'/>" +
|
|
"<error type='cancel'>" +
|
|
"<service-unavailable xmlns='urn:ietf:params:xml:ns:xmpp-stanzas'/>" +
|
|
"</error>" +
|
|
"</iq>";
|
|
//@formatter:on
|
|
IQ serviceUnavailable = PacketParserUtils.parseIQ(TestUtils.getIQParser(reply), threadedCon);
|
|
threadedCon.addIQReply(serviceUnavailable);
|
|
|
|
PingManager pinger = PingManager.getInstanceFor(threadedCon);
|
|
|
|
boolean pingSuccess = pinger.ping("test@myserver.com");
|
|
|
|
assertFalse(pingSuccess);
|
|
}
|
|
|
|
@Test
|
|
public void checkPingToServerSuccess() throws Exception {
|
|
ThreadedDummyConnection con = new ThreadedDummyConnection();
|
|
PingManager pinger = PingManager.getInstanceFor(con);
|
|
|
|
boolean pingSuccess = pinger.pingMyServer();
|
|
|
|
assertTrue(pingSuccess);
|
|
}
|
|
|
|
/**
|
|
* Server returns an exception.
|
|
* @throws Exception
|
|
*/
|
|
@Test
|
|
public void checkPingToServerError() throws Exception {
|
|
ThreadedDummyConnection con = new ThreadedDummyConnection();
|
|
//@formatter:off
|
|
String reply =
|
|
"<iq type='error' id='qrzSp-16' to='test@myserver.com' from='" + con.getServiceName() + "'>" +
|
|
"<ping xmlns='urn:xmpp:ping'/>" +
|
|
"<error type='cancel'>" +
|
|
"<service-unavailable xmlns='urn:ietf:params:xml:ns:xmpp-stanzas'/>" +
|
|
"</error>" +
|
|
"</iq>";
|
|
//@formatter:on
|
|
IQ serviceUnavailable = PacketParserUtils.parseIQ(TestUtils.getIQParser(reply), con);
|
|
con.addIQReply(serviceUnavailable);
|
|
|
|
PingManager pinger = PingManager.getInstanceFor(con);
|
|
|
|
boolean pingSuccess = pinger.pingMyServer();
|
|
|
|
assertTrue(pingSuccess);
|
|
}
|
|
|
|
@Test
|
|
public void checkPingToServerTimeout() throws Exception {
|
|
DummyConnection con = new DummyConnection();
|
|
PingManager pinger = PingManager.getInstanceFor(con);
|
|
|
|
boolean pingSuccess = pinger.pingMyServer();
|
|
|
|
assertFalse(pingSuccess);
|
|
}
|
|
|
|
@Test
|
|
public void checkSuccessfulDiscoRequest() throws Exception {
|
|
ThreadedDummyConnection con = new ThreadedDummyConnection();
|
|
DiscoverInfo info = new DiscoverInfo();
|
|
info.addFeature(Ping.NAMESPACE);
|
|
|
|
//@formatter:off
|
|
String reply =
|
|
"<iq type='result' id='qrzSp-16' to='test@myserver.com'>" +
|
|
"<query xmlns='http://jabber.org/protocol/disco#info'><identity category='client' type='pc' name='Pidgin'/>" +
|
|
"<feature var='urn:xmpp:ping'/>" +
|
|
"</query></iq>";
|
|
//@formatter:on
|
|
IQ discoReply = PacketParserUtils.parseIQ(TestUtils.getIQParser(reply), con);
|
|
con.addIQReply(discoReply);
|
|
|
|
PingManager pinger = PingManager.getInstanceFor(con);
|
|
boolean pingSupported = pinger.isPingSupported("test@myserver.com");
|
|
|
|
assertTrue(pingSupported);
|
|
}
|
|
|
|
@Test
|
|
public void checkUnuccessfulDiscoRequest() throws Exception {
|
|
ThreadedDummyConnection con = new ThreadedDummyConnection();
|
|
DiscoverInfo info = new DiscoverInfo();
|
|
info.addFeature(Ping.NAMESPACE);
|
|
|
|
//@formatter:off
|
|
String reply =
|
|
"<iq type='result' id='qrzSp-16' to='test@myserver.com'>" +
|
|
"<query xmlns='http://jabber.org/protocol/disco#info'><identity category='client' type='pc' name='Pidgin'/>" +
|
|
"<feature var='urn:xmpp:noping'/>" +
|
|
"</query></iq>";
|
|
//@formatter:on
|
|
IQ discoReply = PacketParserUtils.parseIQ(TestUtils.getIQParser(reply), con);
|
|
con.addIQReply(discoReply);
|
|
|
|
PingManager pinger = PingManager.getInstanceFor(con);
|
|
boolean pingSupported = pinger.isPingSupported("test@myserver.com");
|
|
|
|
assertFalse(pingSupported);
|
|
}
|
|
}
|