mirror of
https://github.com/vanitasvitae/Smack.git
synced 2024-12-20 17:47:57 +01:00
113 lines
3 KiB
Java
113 lines
3 KiB
Java
|
package org.jivesoftware.smackx.provider;
|
||
|
|
|
||
|
|
import org.jivesoftware.smack.PacketCollector;
|
||
|
|
import org.jivesoftware.smack.SmackConfiguration;
|
||
|
|
import org.jivesoftware.smack.filter.PacketFilter;
|
||
|
|
import org.jivesoftware.smack.filter.PacketTypeFilter;
|
||
|
|
import org.jivesoftware.smack.packet.IQ;
|
||
|
|
import org.jivesoftware.smack.provider.IQProvider;
|
||
|
|
import org.jivesoftware.smack.provider.ProviderManager;
|
||
|
|
import org.jivesoftware.smack.test.SmackTestCase;
|
||
|
|
import org.jivesoftware.smackx.packet.Jingle;
|
||
|
|
|
||
|
|
public class JingleProviderTest extends SmackTestCase {
|
||
|
|
|
||
|
|
public JingleProviderTest(final String name) {
|
||
|
|
super(name);
|
||
|
|
}
|
||
|
|
|
||
|
|
public void testProviderManager() {
|
||
|
|
IQProvider iqProv;
|
||
|
|
String elementNamee = Jingle.getElementName();
|
||
|
|
String nameSpace = Jingle.getNamespace();
|
||
|
|
|
||
|
|
System.out.println("Testing if the Jingle IQ provider is registered...");
|
||
|
|
|
||
|
|
// Verify that the Jingle IQProvider is registered.
|
||
|
|
iqProv = (IQProvider)ProviderManager.getInstance().getIQProvider(elementNamee, nameSpace);
|
||
|
|
|
||
|
|
assertNotNull(iqProv);
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Test for parsing a Jingle
|
||
|
|
*/
|
||
|
|
public void testParseIQSimple() {
|
||
|
|
|
||
|
|
// Create a dummy packet for testing...
|
||
|
|
IQfake iqSent = new IQfake (
|
||
|
|
" <jingle xmlns='http://jabber.org/protocol/jingle'" +
|
||
|
|
" initiator=\"gorrino@viejo.com\"" +
|
||
|
|
" responder=\"colico@hepatico.com\"" +
|
||
|
|
" action=\"transport-info\" sid=\"\">" +
|
||
|
|
" <transport xmlns='http://jabber.org/protocol/jingle/transport/ice'>" +
|
||
|
|
" <candidate generation=\"1\"" +
|
||
|
|
" ip=\"192.168.1.1\"" +
|
||
|
|
" password=\"secret\"" +
|
||
|
|
" port=\"8080\"" +
|
||
|
|
" username=\"username\"" +
|
||
|
|
" preference=\"1\"/>" +
|
||
|
|
" </transport>" +
|
||
|
|
"</jingle>");
|
||
|
|
|
||
|
|
iqSent.setTo(getFullJID(0));
|
||
|
|
iqSent.setFrom(getFullJID(0));
|
||
|
|
iqSent.setType(IQ.Type.GET);
|
||
|
|
|
||
|
|
// Create a filter and a collector...
|
||
|
|
PacketFilter filter = new PacketTypeFilter(IQ.class);
|
||
|
|
PacketCollector collector = getConnection(0).createPacketCollector(filter);
|
||
|
|
|
||
|
|
System.out.println("Testing if a Jingle IQ can be sent and received...");
|
||
|
|
|
||
|
|
// Send the iq packet with an invalid namespace
|
||
|
|
getConnection(0).sendPacket(iqSent);
|
||
|
|
|
||
|
|
// Receive the packet
|
||
|
|
IQ iqReceived = (IQ)collector.nextResult(SmackConfiguration.getPacketReplyTimeout());
|
||
|
|
|
||
|
|
// Stop queuing results
|
||
|
|
collector.cancel();
|
||
|
|
|
||
|
|
if (iqReceived == null) {
|
||
|
|
fail("No response from server");
|
||
|
|
}
|
||
|
|
else if (iqReceived.getType() == IQ.Type.ERROR) {
|
||
|
|
fail("The server did reply with an error packet: " + iqReceived.getError().getCode());
|
||
|
|
}
|
||
|
|
else {
|
||
|
|
assertTrue(iqReceived instanceof Jingle);
|
||
|
|
|
||
|
|
Jingle jin = (Jingle) iqReceived;
|
||
|
|
|
||
|
|
System.out.println("Sent: " + iqSent.toXML());
|
||
|
|
System.out.println("Received: " + jin.toXML());
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Simple class for testing an IQ...
|
||
|
|
* @author Alvaro Saurin
|
||
|
|
*/
|
||
|
|
private class IQfake extends IQ {
|
||
|
|
private String s;
|
||
|
|
|
||
|
|
public IQfake(final String s) {
|
||
|
|
super();
|
||
|
|
this.s = s;
|
||
|
|
}
|
||
|
|
|
||
|
|
public String getChildElementXML() {
|
||
|
|
StringBuffer buf = new StringBuffer();
|
||
|
|
buf.append(s);
|
||
|
|
return buf.toString();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
protected int getMaxConnections() {
|
||
|
|
return 2;
|
||
|
|
}
|
||
|
|
|
||
|
|
}
|