mirror of
https://codeberg.org/Mercury-IM/Smack
synced 2024-11-26 08:12:05 +01:00
changed "local entry" solution to "wrapper class" solution
git-svn-id: http://svn.igniterealtime.org/svn/repos/smack/trunk@2065 b35dd754-fafc-0310-a699-88a17e54d16e
This commit is contained in:
parent
779f6ab82f
commit
ca37ceb2f1
9 changed files with 1018 additions and 247 deletions
|
@ -114,15 +114,18 @@ entries to his roster.
|
||||||
RosterExchangeManager rosterExchangeManager2 = new RosterExchangeManager(conn2);
|
RosterExchangeManager rosterExchangeManager2 = new RosterExchangeManager(conn2);
|
||||||
<font color="#3f7f5f">// Create a RosterExchangeListener that will iterate over the received roster entries</font>
|
<font color="#3f7f5f">// Create a RosterExchangeListener that will iterate over the received roster entries</font>
|
||||||
RosterExchangeListener rosterExchangeListener = new RosterExchangeListener() {
|
RosterExchangeListener rosterExchangeListener = new RosterExchangeListener() {
|
||||||
public void entriesReceived(String from, Iterator rosterEntries) {
|
public void entriesReceived(String from, Iterator remoteRosterEntries) {
|
||||||
for (Iterator it = rosterEntries; it.hasNext();) {
|
while (remoteRosterEntries.hasNext()) {
|
||||||
try {
|
try {
|
||||||
<font color="#3f7f5f">// Get the received entry</font>
|
<font color="#3f7f5f">// Get the received entry</font>
|
||||||
RosterEntry entry = (RosterEntry) it.next();
|
RemoteRosterEntry remoteRosterEntry = (RemoteRosterEntry) remoteRosterEntries.next();
|
||||||
<font color="#3f7f5f">// Display the entry on the console</font>
|
<font color="#3f7f5f">// Display the remote entry on the console</font>
|
||||||
System.out.println(entry);
|
System.out.println(remoteRosterEntry);
|
||||||
<font color="#3f7f5f">// Add the entry to the user2's roster</font>
|
<font color="#3f7f5f">// Add the entry to the user2's roster</font>
|
||||||
user2_roster.createEntry(entry);
|
user2_roster.createEntry(
|
||||||
|
remoteRosterEntry.getUser(),
|
||||||
|
remoteRosterEntry.getName(),
|
||||||
|
remoteRosterEntry.getGroupArrayNames());
|
||||||
}
|
}
|
||||||
catch (XMPPException e) {
|
catch (XMPPException e) {
|
||||||
e.printStackTrace();
|
e.printStackTrace();
|
||||||
|
|
|
@ -66,8 +66,9 @@ public interface RosterExchangeListener {
|
||||||
* Called when roster entries are received as part of a roster exchange.
|
* Called when roster entries are received as part of a roster exchange.
|
||||||
*
|
*
|
||||||
* @param from the user that sent the entries.
|
* @param from the user that sent the entries.
|
||||||
* @param rosterEntries the entries sent by the user. These entries are local roster entries.
|
* @param rosterEntries the entries sent by the user. The entries are instances of
|
||||||
|
* RemoteRosterEntry.
|
||||||
*/
|
*/
|
||||||
public void entriesReceived(String from, Iterator rosterEntries);
|
public void entriesReceived(String from, Iterator remoteRosterEntries);
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
209
source/org/jivesoftware/smackx/RosterExchangeManager.java
Normal file
209
source/org/jivesoftware/smackx/RosterExchangeManager.java
Normal file
|
@ -0,0 +1,209 @@
|
||||||
|
/**
|
||||||
|
* $RCSfile$
|
||||||
|
* $Revision$
|
||||||
|
* $Date$
|
||||||
|
*
|
||||||
|
* Copyright (C) 2002-2003 Jive Software. All rights reserved.
|
||||||
|
* ====================================================================
|
||||||
|
* The Jive Software License (based on Apache Software License, Version 1.1)
|
||||||
|
*
|
||||||
|
* Redistribution and use in source and binary forms, with or without
|
||||||
|
* modification, are permitted provided that the following conditions
|
||||||
|
* are met:
|
||||||
|
*
|
||||||
|
* 1. Redistributions of source code must retain the above copyright
|
||||||
|
* notice, this list of conditions and the following disclaimer.
|
||||||
|
*
|
||||||
|
* 2. Redistributions in binary form must reproduce the above copyright
|
||||||
|
* notice, this list of conditions and the following disclaimer in
|
||||||
|
* the documentation and/or other materials provided with the
|
||||||
|
* distribution.
|
||||||
|
*
|
||||||
|
* 3. The end-user documentation included with the redistribution,
|
||||||
|
* if any, must include the following acknowledgment:
|
||||||
|
* "This product includes software developed by
|
||||||
|
* Jive Software (http://www.jivesoftware.com)."
|
||||||
|
* Alternately, this acknowledgment may appear in the software itself,
|
||||||
|
* if and wherever such third-party acknowledgments normally appear.
|
||||||
|
*
|
||||||
|
* 4. The names "Smack" and "Jive Software" must not be used to
|
||||||
|
* endorse or promote products derived from this software without
|
||||||
|
* prior written permission. For written permission, please
|
||||||
|
* contact webmaster@jivesoftware.com.
|
||||||
|
*
|
||||||
|
* 5. Products derived from this software may not be called "Smack",
|
||||||
|
* nor may "Smack" appear in their name, without prior written
|
||||||
|
* permission of Jive Software.
|
||||||
|
*
|
||||||
|
* THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED
|
||||||
|
* WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
|
||||||
|
* OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
|
||||||
|
* DISCLAIMED. IN NO EVENT SHALL JIVE SOFTWARE OR
|
||||||
|
* ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
|
||||||
|
* SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
|
||||||
|
* LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
|
||||||
|
* USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
|
||||||
|
* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
|
||||||
|
* OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
|
||||||
|
* OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
|
||||||
|
* SUCH DAMAGE.
|
||||||
|
* ====================================================================
|
||||||
|
*/
|
||||||
|
|
||||||
|
package org.jivesoftware.smackx;
|
||||||
|
|
||||||
|
import java.util.*;
|
||||||
|
|
||||||
|
import org.jivesoftware.smack.*;
|
||||||
|
import org.jivesoftware.smack.filter.*;
|
||||||
|
import org.jivesoftware.smack.packet.*;
|
||||||
|
import org.jivesoftware.smackx.packet.RosterExchange;
|
||||||
|
|
||||||
|
/**
|
||||||
|
*
|
||||||
|
* Manages Roster exchanges. A RosterExchangeManager provides a high level access to send
|
||||||
|
* rosters, roster groups and roster entries to XMPP clients. It also provides an easy way
|
||||||
|
* to hook up custom logic when entries are received from another XMPP client through
|
||||||
|
* RosterExchangeListeners.
|
||||||
|
*
|
||||||
|
* @author Gaston Dombiak
|
||||||
|
*/
|
||||||
|
public class RosterExchangeManager {
|
||||||
|
|
||||||
|
private List rosterExchangeListeners = new ArrayList();
|
||||||
|
|
||||||
|
private XMPPConnection con;
|
||||||
|
|
||||||
|
private PacketFilter packetFilter = new PacketExtensionFilter("x", "jabber:x:roster");
|
||||||
|
private PacketListener packetListener;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Creates a new roster exchange manager.
|
||||||
|
*
|
||||||
|
* @param con an XMPPConnection.
|
||||||
|
*/
|
||||||
|
public RosterExchangeManager(XMPPConnection con) {
|
||||||
|
this.con = con;
|
||||||
|
init();
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Adds a listener to roster exchanges. The listener will be fired anytime roster entries
|
||||||
|
* are received from remote XMPP clients.
|
||||||
|
*
|
||||||
|
* @param rosterExchangeListener a roster exchange listener.
|
||||||
|
*/
|
||||||
|
public void addRosterListener(RosterExchangeListener rosterExchangeListener) {
|
||||||
|
synchronized (rosterExchangeListeners) {
|
||||||
|
if (!rosterExchangeListeners.contains(rosterExchangeListener)) {
|
||||||
|
rosterExchangeListeners.add(rosterExchangeListener);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Removes a listener from roster exchanges. The listener will be fired anytime roster
|
||||||
|
* entries are received from remote XMPP clients.
|
||||||
|
*
|
||||||
|
* @param rosterExchangeListener a roster exchange listener..
|
||||||
|
*/
|
||||||
|
public void removeRosterListener(RosterExchangeListener rosterExchangeListener) {
|
||||||
|
synchronized (rosterExchangeListeners) {
|
||||||
|
rosterExchangeListeners.remove(rosterExchangeListener);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Sends a roster to userID. All the entries of the roster will be sent to the
|
||||||
|
* target user.
|
||||||
|
*
|
||||||
|
* @param roster the roster to send
|
||||||
|
* @param targetUserID the user that will receive the roster entries
|
||||||
|
*/
|
||||||
|
public void send(Roster roster, String targetUserID) {
|
||||||
|
// Create a new message to send the roster
|
||||||
|
Message msg = new Message(targetUserID);
|
||||||
|
// Create a RosterExchange Package and add it to the message
|
||||||
|
RosterExchange rosterExchange = new RosterExchange(roster);
|
||||||
|
msg.addExtension(rosterExchange);
|
||||||
|
|
||||||
|
// Send the message that contains the roster
|
||||||
|
con.sendPacket(msg);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Sends a roster entry to userID.
|
||||||
|
*
|
||||||
|
* @param rosterEntry the roster entry to send
|
||||||
|
* @param targetUserID the user that will receive the roster entries
|
||||||
|
*/
|
||||||
|
public void send(RosterEntry rosterEntry, String targetUserID) {
|
||||||
|
// Create a new message to send the roster
|
||||||
|
Message msg = new Message(targetUserID);
|
||||||
|
// Create a RosterExchange Package and add it to the message
|
||||||
|
RosterExchange rosterExchange = new RosterExchange();
|
||||||
|
rosterExchange.addRosterEntry(rosterEntry);
|
||||||
|
msg.addExtension(rosterExchange);
|
||||||
|
|
||||||
|
// Send the message that contains the roster
|
||||||
|
con.sendPacket(msg);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Sends a roster group to userID. All the entries of the group will be sent to the
|
||||||
|
* target user.
|
||||||
|
*
|
||||||
|
* @param rosterGroup the roster group to send
|
||||||
|
* @param targetUserID the user that will receive the roster entries
|
||||||
|
*/
|
||||||
|
public void send(RosterGroup rosterGroup, String targetUserID) {
|
||||||
|
// Create a new message to send the roster
|
||||||
|
Message msg = new Message(targetUserID);
|
||||||
|
// Create a RosterExchange Package and add it to the message
|
||||||
|
RosterExchange rosterExchange = new RosterExchange();
|
||||||
|
for (Iterator it = rosterGroup.getEntries(); it.hasNext();)
|
||||||
|
rosterExchange.addRosterEntry((RosterEntry) it.next());
|
||||||
|
msg.addExtension(rosterExchange);
|
||||||
|
|
||||||
|
// Send the message that contains the roster
|
||||||
|
con.sendPacket(msg);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Fires roster exchange listeners.
|
||||||
|
*/
|
||||||
|
private void fireRosterExchangeListeners(String from, Iterator rosterEntries) {
|
||||||
|
RosterExchangeListener[] listeners = null;
|
||||||
|
synchronized (rosterExchangeListeners) {
|
||||||
|
listeners = new RosterExchangeListener[rosterExchangeListeners.size()];
|
||||||
|
rosterExchangeListeners.toArray(listeners);
|
||||||
|
}
|
||||||
|
for (int i = 0; i < listeners.length; i++) {
|
||||||
|
listeners[i].entriesReceived(from, rosterEntries);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private void init() {
|
||||||
|
// Listens for all roster exchange packets and fire the roster exchange listeners.
|
||||||
|
packetListener = new PacketListener() {
|
||||||
|
public void processPacket(Packet packet) {
|
||||||
|
Message message = (Message) packet;
|
||||||
|
RosterExchange rosterExchange =
|
||||||
|
(RosterExchange) message.getExtension("x", "jabber:x:roster");
|
||||||
|
// Fire event for roster exchange listeners
|
||||||
|
fireRosterExchangeListeners(message.getFrom(), rosterExchange.getRosterEntries());
|
||||||
|
};
|
||||||
|
|
||||||
|
};
|
||||||
|
con.addPacketListener(packetListener, packetFilter);
|
||||||
|
}
|
||||||
|
|
||||||
|
public void destroy() {
|
||||||
|
if (con != null)
|
||||||
|
con.removePacketListener(packetListener);
|
||||||
|
|
||||||
|
}
|
||||||
|
public void finalize() {
|
||||||
|
destroy();
|
||||||
|
}
|
||||||
|
}
|
179
source/org/jivesoftware/smackx/packet/RemoteRosterEntry.java
Normal file
179
source/org/jivesoftware/smackx/packet/RemoteRosterEntry.java
Normal file
|
@ -0,0 +1,179 @@
|
||||||
|
/**
|
||||||
|
* $RCSfile$
|
||||||
|
* $Revision$
|
||||||
|
* $Date$
|
||||||
|
*
|
||||||
|
* Copyright (C) 2002-2003 Jive Software. All rights reserved.
|
||||||
|
* ====================================================================
|
||||||
|
* The Jive Software License (based on Apache Software License, Version 1.1)
|
||||||
|
*
|
||||||
|
* Redistribution and use in source and binary forms, with or without
|
||||||
|
* modification, are permitted provided that the following conditions
|
||||||
|
* are met:
|
||||||
|
*
|
||||||
|
* 1. Redistributions of source code must retain the above copyright
|
||||||
|
* notice, this list of conditions and the following disclaimer.
|
||||||
|
*
|
||||||
|
* 2. Redistributions in binary form must reproduce the above copyright
|
||||||
|
* notice, this list of conditions and the following disclaimer in
|
||||||
|
* the documentation and/or other materials provided with the
|
||||||
|
* distribution.
|
||||||
|
*
|
||||||
|
* 3. The end-user documentation included with the redistribution,
|
||||||
|
* if any, must include the following acknowledgment:
|
||||||
|
* "This product includes software developed by
|
||||||
|
* Jive Software (http://www.jivesoftware.com)."
|
||||||
|
* Alternately, this acknowledgment may appear in the software itself,
|
||||||
|
* if and wherever such third-party acknowledgments normally appear.
|
||||||
|
*
|
||||||
|
* 4. The names "Smack" and "Jive Software" must not be used to
|
||||||
|
* endorse or promote products derived from this software without
|
||||||
|
* prior written permission. For written permission, please
|
||||||
|
* contact webmaster@jivesoftware.com.
|
||||||
|
*
|
||||||
|
* 5. Products derived from this software may not be called "Smack",
|
||||||
|
* nor may "Smack" appear in their name, without prior written
|
||||||
|
* permission of Jive Software.
|
||||||
|
*
|
||||||
|
* THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED
|
||||||
|
* WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
|
||||||
|
* OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
|
||||||
|
* DISCLAIMED. IN NO EVENT SHALL JIVE SOFTWARE OR
|
||||||
|
* ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
|
||||||
|
* SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
|
||||||
|
* LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
|
||||||
|
* USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
|
||||||
|
* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
|
||||||
|
* OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
|
||||||
|
* OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
|
||||||
|
* SUCH DAMAGE.
|
||||||
|
* ====================================================================
|
||||||
|
*/
|
||||||
|
|
||||||
|
package org.jivesoftware.smackx.packet;
|
||||||
|
|
||||||
|
import java.util.*;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Represents a roster item, which consists of a JID and , their name and
|
||||||
|
* the groups the roster item belongs to. This roster item does not belong
|
||||||
|
* to the local roster. Therefore, it does not persist in the server.<p>
|
||||||
|
*
|
||||||
|
* The idea of a RemoteRosterEntry is to be used as part of a roster exchange.
|
||||||
|
*
|
||||||
|
* @author Gaston Dombiak
|
||||||
|
*/
|
||||||
|
public class RemoteRosterEntry {
|
||||||
|
|
||||||
|
private String user;
|
||||||
|
private String name;
|
||||||
|
private List groupNames;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Creates a new remote roster entry.
|
||||||
|
*
|
||||||
|
* @param user the user.
|
||||||
|
* @param name the user's name.
|
||||||
|
*/
|
||||||
|
public RemoteRosterEntry(String user, String name) {
|
||||||
|
this.user = user;
|
||||||
|
this.name = name;
|
||||||
|
groupNames = new ArrayList();
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Returns the user.
|
||||||
|
*
|
||||||
|
* @return the user.
|
||||||
|
*/
|
||||||
|
public String getUser() {
|
||||||
|
return user;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Returns the user's name.
|
||||||
|
*
|
||||||
|
* @return the user's name.
|
||||||
|
*/
|
||||||
|
public String getName() {
|
||||||
|
return name;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Sets the user's name.
|
||||||
|
*
|
||||||
|
* @param name the user's name.
|
||||||
|
*/
|
||||||
|
public void setName(String name) {
|
||||||
|
this.name = name;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Returns an Iterator for the group names (as Strings) that the roster entry
|
||||||
|
* belongs to.
|
||||||
|
*
|
||||||
|
* @return an Iterator for the group names.
|
||||||
|
*/
|
||||||
|
public Iterator getGroupNames() {
|
||||||
|
synchronized (groupNames) {
|
||||||
|
return Collections.unmodifiableList(groupNames).iterator();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Returns a String array for the group names that the roster entry
|
||||||
|
* belongs to.
|
||||||
|
*
|
||||||
|
* @return a String[] for the group names.
|
||||||
|
*/
|
||||||
|
public String[] getGroupArrayNames() {
|
||||||
|
synchronized (groupNames) {
|
||||||
|
return (String[])
|
||||||
|
(Collections
|
||||||
|
.unmodifiableList(groupNames)
|
||||||
|
.toArray(new String[groupNames.size()]));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Adds a group name.
|
||||||
|
*
|
||||||
|
* @param groupName the group name.
|
||||||
|
*/
|
||||||
|
public void addGroupName(String groupName) {
|
||||||
|
synchronized (groupNames) {
|
||||||
|
if (!groupNames.contains(groupName)) {
|
||||||
|
groupNames.add(groupName);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Removes a group name.
|
||||||
|
*
|
||||||
|
* @param groupName the group name.
|
||||||
|
*/
|
||||||
|
public void removeGroupName(String groupName) {
|
||||||
|
synchronized (groupNames) {
|
||||||
|
groupNames.remove(groupName);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public String toXML() {
|
||||||
|
StringBuffer buf = new StringBuffer();
|
||||||
|
buf.append("<item jid=\"").append(user).append("\"");
|
||||||
|
if (name != null) {
|
||||||
|
buf.append(" name=\"").append(name).append("\"");
|
||||||
|
}
|
||||||
|
buf.append(">");
|
||||||
|
synchronized (groupNames) {
|
||||||
|
for (int i = 0; i < groupNames.size(); i++) {
|
||||||
|
String groupName = (String) groupNames.get(i);
|
||||||
|
buf.append("<group>").append(groupName).append("</group>");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
buf.append("</item>");
|
||||||
|
return buf.toString();
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
|
@ -1,6 +1,55 @@
|
||||||
/*
|
/**
|
||||||
* Created on 27/07/2003
|
* $RCSfile$
|
||||||
|
* $Revision$
|
||||||
|
* $Date$
|
||||||
|
*
|
||||||
|
* Copyright (C) 2002-2003 Jive Software. All rights reserved.
|
||||||
|
* ====================================================================
|
||||||
|
* The Jive Software License (based on Apache Software License, Version 1.1)
|
||||||
|
*
|
||||||
|
* Redistribution and use in source and binary forms, with or without
|
||||||
|
* modification, are permitted provided that the following conditions
|
||||||
|
* are met:
|
||||||
|
*
|
||||||
|
* 1. Redistributions of source code must retain the above copyright
|
||||||
|
* notice, this list of conditions and the following disclaimer.
|
||||||
|
*
|
||||||
|
* 2. Redistributions in binary form must reproduce the above copyright
|
||||||
|
* notice, this list of conditions and the following disclaimer in
|
||||||
|
* the documentation and/or other materials provided with the
|
||||||
|
* distribution.
|
||||||
|
*
|
||||||
|
* 3. The end-user documentation included with the redistribution,
|
||||||
|
* if any, must include the following acknowledgment:
|
||||||
|
* "This product includes software developed by
|
||||||
|
* Jive Software (http://www.jivesoftware.com)."
|
||||||
|
* Alternately, this acknowledgment may appear in the software itself,
|
||||||
|
* if and wherever such third-party acknowledgments normally appear.
|
||||||
|
*
|
||||||
|
* 4. The names "Smack" and "Jive Software" must not be used to
|
||||||
|
* endorse or promote products derived from this software without
|
||||||
|
* prior written permission. For written permission, please
|
||||||
|
* contact webmaster@jivesoftware.com.
|
||||||
|
*
|
||||||
|
* 5. Products derived from this software may not be called "Smack",
|
||||||
|
* nor may "Smack" appear in their name, without prior written
|
||||||
|
* permission of Jive Software.
|
||||||
|
*
|
||||||
|
* THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED
|
||||||
|
* WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
|
||||||
|
* OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
|
||||||
|
* DISCLAIMED. IN NO EVENT SHALL JIVE SOFTWARE OR
|
||||||
|
* ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
|
||||||
|
* SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
|
||||||
|
* LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
|
||||||
|
* USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
|
||||||
|
* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
|
||||||
|
* OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
|
||||||
|
* OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
|
||||||
|
* SUCH DAMAGE.
|
||||||
|
* ====================================================================
|
||||||
*/
|
*/
|
||||||
|
|
||||||
package org.jivesoftware.smackx.packet;
|
package org.jivesoftware.smackx.packet;
|
||||||
|
|
||||||
import java.util.*;
|
import java.util.*;
|
||||||
|
@ -9,24 +58,27 @@ import org.jivesoftware.smack.*;
|
||||||
import org.jivesoftware.smack.packet.PacketExtension;
|
import org.jivesoftware.smack.packet.PacketExtension;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Represents XMPP Roster Item Exchange packets.
|
* Represents XMPP Roster Item Exchange packets.<p>
|
||||||
* The 'jabber:x:roster' namespace (which is not to be confused with the 'jabber:iq:roster' namespace) is used to
|
|
||||||
* send roster items from one client to another. A roster item is sent by adding to the <message/> element an <x/> child
|
|
||||||
* scoped by the 'jabber:x:roster' namespace. This <x/> element may contain one or more <item/> children (one for each roster item to be sent).
|
|
||||||
*
|
*
|
||||||
* Each <item/> element may possess the following attributes:
|
* The 'jabber:x:roster' namespace (which is not to be confused with the 'jabber:iq:roster'
|
||||||
|
* namespace) is used to send roster items from one client to another. A roster item is sent by
|
||||||
|
* adding to the <message/> element an <x/> child scoped by the 'jabber:x:roster' namespace. This
|
||||||
|
* <x/> element may contain one or more <item/> children (one for each roster item to be sent).<p>
|
||||||
*
|
*
|
||||||
* <jid/> -- The id of the contact being sent. This attribute is required.
|
* Each <item/> element may possess the following attributes:<p>
|
||||||
* <name/> -- A natural-language nickname for the contact. This attribute is optional.
|
|
||||||
*
|
*
|
||||||
* Each <item/> element may also contain one or more <group/> children specifying the natural-language name
|
* <jid/> -- The id of the contact being sent. This attribute is required.<br>
|
||||||
* of a user-specified group, for the purpose of categorizing this contact into one or more roster groups.
|
* <name/> -- A natural-language nickname for the contact. This attribute is optional.<p>
|
||||||
|
*
|
||||||
|
* Each <item/> element may also contain one or more <group/> children specifying the
|
||||||
|
* natural-language name of a user-specified group, for the purpose of categorizing this contact
|
||||||
|
* into one or more roster groups.
|
||||||
*
|
*
|
||||||
* @author Gaston Dombiak
|
* @author Gaston Dombiak
|
||||||
*/
|
*/
|
||||||
public class RosterExchange implements PacketExtension {
|
public class RosterExchange implements PacketExtension {
|
||||||
|
|
||||||
private List rosterItems = new ArrayList();
|
private List remoteRosterEntries = new ArrayList();
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Creates a new empty roster exchange package.
|
* Creates a new empty roster exchange package.
|
||||||
|
@ -42,47 +94,40 @@ public class RosterExchange implements PacketExtension {
|
||||||
* @param roster the roster to send to other XMPP entity.
|
* @param roster the roster to send to other XMPP entity.
|
||||||
*/
|
*/
|
||||||
public RosterExchange(Roster roster) {
|
public RosterExchange(Roster roster) {
|
||||||
RosterGroup rosterGroup = null;
|
// Add all the roster entries to the new RosterExchange
|
||||||
// Loop through all roster groups and add their entries to the new RosterExchange
|
for (Iterator rosterEntries = roster.getEntries(); rosterEntries.hasNext();) {
|
||||||
for (Iterator groups = roster.getGroups(); groups.hasNext(); ) {
|
this.addRosterEntry((RosterEntry) rosterEntries.next());
|
||||||
rosterGroup = (RosterGroup) groups.next();
|
|
||||||
for (Iterator entries = rosterGroup.getEntries(); entries.hasNext(); ) {
|
|
||||||
this.addRosterItem((RosterEntry) entries.next());
|
|
||||||
}
|
|
||||||
}
|
|
||||||
// Add the roster unfiled entries to the new RosterExchange
|
|
||||||
for (Iterator unfiledEntries = roster.getUnfiledEntries(); unfiledEntries.hasNext();) {
|
|
||||||
this.addRosterItem((RosterEntry) unfiledEntries.next());
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Adds a roster entry to the packet.
|
* Adds a roster entry to the packet.
|
||||||
*
|
*
|
||||||
* @param rosterEntry a roster item.
|
* @param rosterEntry a roster entry to add.
|
||||||
*/
|
*/
|
||||||
public void addRosterItem(RosterEntry rosterEntry) {
|
public void addRosterEntry(RosterEntry rosterEntry) {
|
||||||
RosterGroup rosterGroup = null;
|
RosterGroup rosterGroup = null;
|
||||||
// Create a new Item based on the rosterEntry and add it to the packet
|
// Create a new Entry based on the rosterEntry and add it to the packet
|
||||||
Item item = new Item(rosterEntry.getUser(), rosterEntry.getName());
|
RemoteRosterEntry remoteRosterEntry = new RemoteRosterEntry(rosterEntry.getUser(), rosterEntry.getName());
|
||||||
// Add the entry groups to the item
|
// Add the entry groups to the Entry
|
||||||
for (Iterator groups = rosterEntry.getGroups(); groups.hasNext();) {
|
for (Iterator groups = rosterEntry.getGroups(); groups.hasNext();) {
|
||||||
rosterGroup = (RosterGroup) groups.next();
|
rosterGroup = (RosterGroup) groups.next();
|
||||||
item.addGroupName(rosterGroup.getName());
|
remoteRosterEntry.addGroupName(rosterGroup.getName());
|
||||||
}
|
}
|
||||||
addRosterItem(item);
|
addRosterEntry(remoteRosterEntry);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Adds a roster item to the packet.
|
* Adds a remote roster entry to the packet.
|
||||||
*
|
*
|
||||||
* @param item a roster item.
|
* @param remoteRosterEntry a remote roster entry to add.
|
||||||
*/
|
*/
|
||||||
public void addRosterItem(Item item) {
|
public void addRosterEntry(RemoteRosterEntry remoteRosterEntry) {
|
||||||
synchronized (rosterItems) {
|
synchronized (remoteRosterEntries) {
|
||||||
rosterItems.add(item);
|
remoteRosterEntries.add(remoteRosterEntry);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Returns the XML element name of the extension sub-packet root element.
|
* Returns the XML element name of the extension sub-packet root element.
|
||||||
* Always returns "x"
|
* Always returns "x"
|
||||||
|
@ -105,158 +150,54 @@ public class RosterExchange implements PacketExtension {
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Returns an Iterator for the roster items in the packet.
|
* Returns an Iterator for the roster entries in the packet.
|
||||||
*
|
*
|
||||||
* @return and Iterator for the roster items in the packet.
|
* @return an Iterator for the roster entries in the packet.
|
||||||
*/
|
*/
|
||||||
public Iterator getRosterItems() {
|
public Iterator getRosterEntries() {
|
||||||
synchronized (rosterItems) {
|
synchronized (remoteRosterEntries) {
|
||||||
List entries =
|
List entries = Collections.unmodifiableList(new ArrayList(remoteRosterEntries));
|
||||||
Collections.unmodifiableList(new ArrayList(rosterItems));
|
|
||||||
return entries.iterator();
|
return entries.iterator();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Returns a count of the entries in the roster exchange.
|
||||||
|
*
|
||||||
|
* @return the number of entries in the roster exchange.
|
||||||
|
*/
|
||||||
|
public int getEntryCount() {
|
||||||
|
return remoteRosterEntries.size();
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Returns the XML representation of a Roster Item Exchange according the specification.
|
* Returns the XML representation of a Roster Item Exchange according the specification.
|
||||||
*
|
*
|
||||||
* Usually the XML representation will be inside of a Message XML representation like
|
* Usually the XML representation will be inside of a Message XML representation like
|
||||||
* in the following example:
|
* in the following example:
|
||||||
* <message id="MlIpV-4" to="gato1@gato.home" from="gato3@gato.home/Smack">
|
* <pre>
|
||||||
* <subject>Any subject you want</subject>
|
* <message id="MlIpV-4" to="gato1@gato.home" from="gato3@gato.home/Smack">
|
||||||
* <body>This message contains roster items.</body>
|
* <subject>Any subject you want</subject>
|
||||||
* <x xmlns="jabber:x:roster">
|
* <body>This message contains roster items.</body>
|
||||||
* <item jid="gato1@gato.home"/>
|
* <x xmlns="jabber:x:roster">
|
||||||
* <item jid="gato2@gato.home"/>
|
* <item jid="gato1@gato.home"/>
|
||||||
* </x>
|
* <item jid="gato2@gato.home"/>
|
||||||
* </message>
|
* </x>
|
||||||
|
* </message>
|
||||||
|
* </pre>
|
||||||
*
|
*
|
||||||
*/
|
*/
|
||||||
public String toXML() {
|
public String toXML() {
|
||||||
StringBuffer buf = new StringBuffer();
|
StringBuffer buf = new StringBuffer();
|
||||||
buf.append("<").append(getElementName()).append(" xmlns=\"").append(getNamespace()).append("\">");
|
buf.append("<").append(getElementName()).append(" xmlns=\"").append(getNamespace()).append(
|
||||||
// Loop through all roster items and append them to the string buffer
|
"\">");
|
||||||
for (Iterator i = getRosterItems(); i.hasNext();) {
|
// Loop through all roster entries and append them to the string buffer
|
||||||
Item entry = (Item) i.next();
|
for (Iterator i = getRosterEntries(); i.hasNext();) {
|
||||||
buf.append(entry.toXML());
|
RemoteRosterEntry remoteRosterEntry = (RemoteRosterEntry) i.next();
|
||||||
|
buf.append(remoteRosterEntry.toXML());
|
||||||
}
|
}
|
||||||
buf.append("</").append(getElementName()).append(">");
|
buf.append("</").append(getElementName()).append(">");
|
||||||
return buf.toString();
|
return buf.toString();
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* A roster item, which consists of a JID and , their name and
|
|
||||||
* the groups the roster item belongs to.
|
|
||||||
*/
|
|
||||||
public static class Item {
|
|
||||||
|
|
||||||
private String user;
|
|
||||||
private String name;
|
|
||||||
private List groupNames;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Creates a new roster item.
|
|
||||||
*
|
|
||||||
* @param user the user.
|
|
||||||
* @param name the user's name.
|
|
||||||
*/
|
|
||||||
public Item(String user, String name) {
|
|
||||||
this.user = user;
|
|
||||||
this.name = name;
|
|
||||||
groupNames = new ArrayList();
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Returns the user.
|
|
||||||
*
|
|
||||||
* @return the user.
|
|
||||||
*/
|
|
||||||
public String getUser() {
|
|
||||||
return user;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Returns the user's name.
|
|
||||||
*
|
|
||||||
* @return the user's name.
|
|
||||||
*/
|
|
||||||
public String getName() {
|
|
||||||
return name;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Sets the user's name.
|
|
||||||
*
|
|
||||||
* @param name the user's name.
|
|
||||||
*/
|
|
||||||
public void setName(String name) {
|
|
||||||
this.name = name;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Returns an Iterator for the group names (as Strings) that the roster item
|
|
||||||
* belongs to.
|
|
||||||
*
|
|
||||||
* @return an Iterator for the group names.
|
|
||||||
*/
|
|
||||||
public Iterator getGroupNames() {
|
|
||||||
synchronized (groupNames) {
|
|
||||||
return Collections.unmodifiableList(groupNames).iterator();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Returns a String array for the group names that the roster item
|
|
||||||
* belongs to.
|
|
||||||
*
|
|
||||||
* @return a String[] for the group names.
|
|
||||||
*/
|
|
||||||
public String[] getGroupArrayNames() {
|
|
||||||
synchronized (groupNames) {
|
|
||||||
return (String[])(Collections.unmodifiableList(groupNames).toArray(new String[groupNames.size()]));
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Adds a group name.
|
|
||||||
*
|
|
||||||
* @param groupName the group name.
|
|
||||||
*/
|
|
||||||
public void addGroupName(String groupName) {
|
|
||||||
synchronized (groupNames) {
|
|
||||||
if (!groupNames.contains(groupName)) {
|
|
||||||
groupNames.add(groupName);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Removes a group name.
|
|
||||||
*
|
|
||||||
* @param groupName the group name.
|
|
||||||
*/
|
|
||||||
public void removeGroupName(String groupName) {
|
|
||||||
synchronized (groupNames) {
|
|
||||||
groupNames.remove(groupName);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
public String toXML() {
|
|
||||||
StringBuffer buf = new StringBuffer();
|
|
||||||
buf.append("<item jid=\"").append(user).append("\"");
|
|
||||||
if (name != null) {
|
|
||||||
buf.append(" name=\"").append(name).append("\"");
|
|
||||||
}
|
|
||||||
buf.append(">");
|
|
||||||
synchronized (groupNames) {
|
|
||||||
for (int i = 0; i < groupNames.size(); i++) {
|
|
||||||
String groupName = (String) groupNames.get(i);
|
|
||||||
buf.append("<group>").append(groupName).append("</group>");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
buf.append("</item>");
|
|
||||||
return buf.toString();
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
|
@ -83,7 +83,7 @@ public class RosterExchangeProvider implements PacketExtensionProvider {
|
||||||
|
|
||||||
RosterExchange rosterExchange = new RosterExchange();
|
RosterExchange rosterExchange = new RosterExchange();
|
||||||
boolean done = false;
|
boolean done = false;
|
||||||
RosterExchange.Item item = null;
|
RemoteRosterEntry remoteRosterEntry = null;
|
||||||
while (!done) {
|
while (!done) {
|
||||||
int eventType = parser.next();
|
int eventType = parser.next();
|
||||||
if (eventType == XmlPullParser.START_TAG) {
|
if (eventType == XmlPullParser.START_TAG) {
|
||||||
|
@ -91,15 +91,15 @@ public class RosterExchangeProvider implements PacketExtensionProvider {
|
||||||
String jid = parser.getAttributeValue("", "jid");
|
String jid = parser.getAttributeValue("", "jid");
|
||||||
String name = parser.getAttributeValue("", "name");
|
String name = parser.getAttributeValue("", "name");
|
||||||
// Create packet.
|
// Create packet.
|
||||||
item = new RosterExchange.Item(jid, name);
|
remoteRosterEntry = new RemoteRosterEntry(jid, name);
|
||||||
}
|
}
|
||||||
if (parser.getName().equals("group")) {
|
if (parser.getName().equals("group")) {
|
||||||
String groupName = parser.nextText();
|
String groupName = parser.nextText();
|
||||||
item.addGroupName(groupName);
|
remoteRosterEntry.addGroupName(groupName);
|
||||||
}
|
}
|
||||||
} else if (eventType == XmlPullParser.END_TAG) {
|
} else if (eventType == XmlPullParser.END_TAG) {
|
||||||
if (parser.getName().equals("item")) {
|
if (parser.getName().equals("item")) {
|
||||||
rosterExchange.addRosterItem(item);
|
rosterExchange.addRosterEntry(remoteRosterEntry);
|
||||||
}
|
}
|
||||||
if (parser.getName().equals("x")) {
|
if (parser.getName().equals("x")) {
|
||||||
done = true;
|
done = true;
|
||||||
|
|
306
test/org/jivesoftware/smackx/RosterExchangeManagerTest.java
Normal file
306
test/org/jivesoftware/smackx/RosterExchangeManagerTest.java
Normal file
|
@ -0,0 +1,306 @@
|
||||||
|
/**
|
||||||
|
* $RCSfile$
|
||||||
|
* $Revision$
|
||||||
|
* $Date$
|
||||||
|
*
|
||||||
|
* Copyright (C) 2002-2003 Jive Software. All rights reserved.
|
||||||
|
* ====================================================================
|
||||||
|
* The Jive Software License (based on Apache Software License, Version 1.1)
|
||||||
|
*
|
||||||
|
* Redistribution and use in source and binary forms, with or without
|
||||||
|
* modification, are permitted provided that the following conditions
|
||||||
|
* are met:
|
||||||
|
*
|
||||||
|
* 1. Redistributions of source code must retain the above copyright
|
||||||
|
* notice, this list of conditions and the following disclaimer.
|
||||||
|
*
|
||||||
|
* 2. Redistributions in binary form must reproduce the above copyright
|
||||||
|
* notice, this list of conditions and the following disclaimer in
|
||||||
|
* the documentation and/or other materials provided with the
|
||||||
|
* distribution.
|
||||||
|
*
|
||||||
|
* 3. The end-user documentation included with the redistribution,
|
||||||
|
* if any, must include the following acknowledgment:
|
||||||
|
* "This product includes software developed by
|
||||||
|
* Jive Software (http://www.jivesoftware.com)."
|
||||||
|
* Alternately, this acknowledgment may appear in the software itself,
|
||||||
|
* if and wherever such third-party acknowledgments normally appear.
|
||||||
|
*
|
||||||
|
* 4. The names "Smack" and "Jive Software" must not be used to
|
||||||
|
* endorse or promote products derived from this software without
|
||||||
|
* prior written permission. For written permission, please
|
||||||
|
* contact webmaster@jivesoftware.com.
|
||||||
|
*
|
||||||
|
* 5. Products derived from this software may not be called "Smack",
|
||||||
|
* nor may "Smack" appear in their name, without prior written
|
||||||
|
* permission of Jive Software.
|
||||||
|
*
|
||||||
|
* THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED
|
||||||
|
* WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
|
||||||
|
* OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
|
||||||
|
* DISCLAIMED. IN NO EVENT SHALL JIVE SOFTWARE OR
|
||||||
|
* ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
|
||||||
|
* SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
|
||||||
|
* LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
|
||||||
|
* USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
|
||||||
|
* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
|
||||||
|
* OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
|
||||||
|
* OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
|
||||||
|
* SUCH DAMAGE.
|
||||||
|
* ====================================================================
|
||||||
|
*/
|
||||||
|
|
||||||
|
package org.jivesoftware.smackx;
|
||||||
|
|
||||||
|
import java.util.Iterator;
|
||||||
|
|
||||||
|
import junit.framework.TestCase;
|
||||||
|
|
||||||
|
import org.jivesoftware.smack.*;
|
||||||
|
import org.jivesoftware.smackx.packet.RemoteRosterEntry;
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
*
|
||||||
|
* Test the Roster Exchange extension using the high level API
|
||||||
|
*
|
||||||
|
* @author Gaston Dombiak
|
||||||
|
*/
|
||||||
|
public class RosterExchangeManagerTest extends TestCase {
|
||||||
|
|
||||||
|
private int entriesSent;
|
||||||
|
private int entriesReceived;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Constructor for RosterExchangeManagerTest.
|
||||||
|
* @param name
|
||||||
|
*/
|
||||||
|
public RosterExchangeManagerTest(String name) {
|
||||||
|
super(name);
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* High level API test.
|
||||||
|
* This is a simple test to use with a XMPP client and check if the client receives user1's roster
|
||||||
|
* 1. User_1 will send his/her roster to user_2
|
||||||
|
*/
|
||||||
|
public void testSendRoster() {
|
||||||
|
String host = "localhost";
|
||||||
|
String server_user1 = "gato3";
|
||||||
|
String user1 = "gato3@localhost";
|
||||||
|
String pass1 = "gato3";
|
||||||
|
|
||||||
|
String user2 = "gato4@localhost";
|
||||||
|
|
||||||
|
XMPPConnection conn1 = null;
|
||||||
|
|
||||||
|
try {
|
||||||
|
// Connect to the server and log in the users
|
||||||
|
conn1 = new XMPPConnection(host);
|
||||||
|
conn1.login(server_user1, pass1);
|
||||||
|
|
||||||
|
// Send user1's roster to user2
|
||||||
|
try {
|
||||||
|
RosterExchangeManager rosterExchangeManager = new RosterExchangeManager(conn1);
|
||||||
|
rosterExchangeManager.send(conn1.getRoster(), user2);
|
||||||
|
// Wait half second so that the complete test can run
|
||||||
|
Thread.sleep(500);
|
||||||
|
} catch (Exception e) {
|
||||||
|
e.printStackTrace();
|
||||||
|
fail("An error occured sending the roster");
|
||||||
|
}
|
||||||
|
|
||||||
|
} catch (Exception e) {
|
||||||
|
fail(e.toString());
|
||||||
|
} finally {
|
||||||
|
if (conn1 != null)
|
||||||
|
conn1.close();
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* High level API test.
|
||||||
|
* This is a simple test to use with a XMPP client and check if the client receives user1's roster groups
|
||||||
|
* 1. User_1 will send his/her RosterGroups to user_2
|
||||||
|
*/
|
||||||
|
public void testSendRosterGroup() {
|
||||||
|
String host = "localhost";
|
||||||
|
String server_user1 = "gato3";
|
||||||
|
String user1 = "gato3@localhost";
|
||||||
|
String pass1 = "gato3";
|
||||||
|
|
||||||
|
String user2 = "gato4@localhost";
|
||||||
|
|
||||||
|
XMPPConnection conn1 = null;
|
||||||
|
|
||||||
|
try {
|
||||||
|
// Connect to the server and log in the users
|
||||||
|
conn1 = new XMPPConnection(host);
|
||||||
|
conn1.login(server_user1, pass1);
|
||||||
|
|
||||||
|
// Send user1's RosterGroups to user2
|
||||||
|
try {
|
||||||
|
RosterExchangeManager rosterExchangeManager = new RosterExchangeManager(conn1);
|
||||||
|
for (Iterator it = conn1.getRoster().getGroups(); it.hasNext(); )
|
||||||
|
rosterExchangeManager.send((RosterGroup)it.next(), user2);
|
||||||
|
// Wait half second so that the complete test can run
|
||||||
|
Thread.sleep(500);
|
||||||
|
} catch (Exception e) {
|
||||||
|
e.printStackTrace();
|
||||||
|
fail("An error occured sending the roster");
|
||||||
|
}
|
||||||
|
|
||||||
|
} catch (Exception e) {
|
||||||
|
fail(e.toString());
|
||||||
|
} finally {
|
||||||
|
if (conn1 != null)
|
||||||
|
conn1.close();
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* High level API test.
|
||||||
|
* 1. User_1 will send his/her roster to user_2
|
||||||
|
* 2. User_2 will receive the entries and iterate over them to check if everything is fine
|
||||||
|
* 3. User_1 will wait several seconds for an ACK from user_2, if none is received then something is wrong
|
||||||
|
*/
|
||||||
|
public void testSendAndReceiveRoster() {
|
||||||
|
String host = "localhost";
|
||||||
|
String server_user1 = "gato3";
|
||||||
|
String user1 = "gato3@localhost";
|
||||||
|
String pass1 = "gato3";
|
||||||
|
|
||||||
|
String server_user2 = "gato4";
|
||||||
|
String user2 = "gato4@localhost";
|
||||||
|
String pass2 = "gato4";
|
||||||
|
|
||||||
|
XMPPConnection conn1 = null;
|
||||||
|
XMPPConnection conn2 = null;
|
||||||
|
|
||||||
|
try {
|
||||||
|
// Connect to the server and log in the users
|
||||||
|
conn1 = new XMPPConnection(host);
|
||||||
|
conn1.login(server_user1, pass1);
|
||||||
|
conn2 = new XMPPConnection(host);
|
||||||
|
conn2.login(server_user2, pass2);
|
||||||
|
|
||||||
|
RosterExchangeManager rosterExchangeManager1 = new RosterExchangeManager(conn1);
|
||||||
|
RosterExchangeManager rosterExchangeManager2 = new RosterExchangeManager(conn2);
|
||||||
|
|
||||||
|
// Create a RosterExchangeListener that will iterate over the received roster entries
|
||||||
|
RosterExchangeListener rosterExchangeListener = new RosterExchangeListener() {
|
||||||
|
public void entriesReceived(String from, Iterator remoteRosterEntries) {
|
||||||
|
int received = 0;
|
||||||
|
assertNotNull("From is null", from);
|
||||||
|
assertNotNull("rosterEntries is null",remoteRosterEntries);
|
||||||
|
assertTrue("Roster without entries",remoteRosterEntries.hasNext());
|
||||||
|
while (remoteRosterEntries.hasNext()) {
|
||||||
|
received++;
|
||||||
|
RemoteRosterEntry remoteEntry = (RemoteRosterEntry) remoteRosterEntries.next();
|
||||||
|
System.out.println(remoteEntry);
|
||||||
|
}
|
||||||
|
entriesReceived = received;
|
||||||
|
}
|
||||||
|
};
|
||||||
|
rosterExchangeManager2.addRosterListener(rosterExchangeListener);
|
||||||
|
|
||||||
|
// Send user1's roster to user2
|
||||||
|
try {
|
||||||
|
entriesSent = conn1.getRoster().getEntryCount();
|
||||||
|
entriesReceived = 0;
|
||||||
|
rosterExchangeManager1.send(conn1.getRoster(), user2);
|
||||||
|
} catch (Exception e) {
|
||||||
|
fail("An error occured sending the message with the roster");
|
||||||
|
}
|
||||||
|
// Wait for 2 seconds
|
||||||
|
Thread.sleep(2000);
|
||||||
|
assertEquals("Number of sent and received entries does not match", entriesSent, entriesReceived);
|
||||||
|
} catch (Exception e) {
|
||||||
|
fail(e.toString());
|
||||||
|
} finally {
|
||||||
|
if (conn1 != null)
|
||||||
|
conn1.close();
|
||||||
|
if (conn2 != null)
|
||||||
|
conn2.close();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* High level API test.
|
||||||
|
* 1. User_1 will send his/her roster to user_2
|
||||||
|
* 2. User_2 will automatically add the entries that receives to his/her roster in the corresponding group
|
||||||
|
* 3. User_1 will wait several seconds for an ACK from user_2, if none is received then something is wrong
|
||||||
|
*/
|
||||||
|
public void testSendAndAcceptRoster() {
|
||||||
|
String host = "localhost";
|
||||||
|
String server_user1 = "gato3";
|
||||||
|
String user1 = "gato3@localhost";
|
||||||
|
String pass1 = "gato3";
|
||||||
|
|
||||||
|
String server_user2 = "gato4";
|
||||||
|
String user2 = "gato4@localhost";
|
||||||
|
String pass2 = "gato4";
|
||||||
|
|
||||||
|
XMPPConnection conn1 = null;
|
||||||
|
XMPPConnection conn2 = null;
|
||||||
|
|
||||||
|
try {
|
||||||
|
// Connect to the server and log in the users
|
||||||
|
conn1 = new XMPPConnection(host);
|
||||||
|
conn1.login(server_user1, pass1);
|
||||||
|
conn2 = new XMPPConnection(host);
|
||||||
|
conn2.login(server_user2, pass2);
|
||||||
|
final Roster user2_roster = conn2.getRoster();
|
||||||
|
|
||||||
|
RosterExchangeManager rosterExchangeManager1 = new RosterExchangeManager(conn1);
|
||||||
|
RosterExchangeManager rosterExchangeManager2 = new RosterExchangeManager(conn2);
|
||||||
|
|
||||||
|
// Create a RosterExchangeListener that will accept all the received roster entries
|
||||||
|
RosterExchangeListener rosterExchangeListener = new RosterExchangeListener() {
|
||||||
|
public void entriesReceived(String from, Iterator remoteRosterEntries) {
|
||||||
|
int received = 0;
|
||||||
|
assertNotNull("From is null", from);
|
||||||
|
assertNotNull("remoteRosterEntries is null",remoteRosterEntries);
|
||||||
|
assertTrue("Roster without entries",remoteRosterEntries.hasNext());
|
||||||
|
while (remoteRosterEntries.hasNext()) {
|
||||||
|
received++;
|
||||||
|
try {
|
||||||
|
RemoteRosterEntry remoteRosterEntry = (RemoteRosterEntry) remoteRosterEntries.next();
|
||||||
|
user2_roster.createEntry(
|
||||||
|
remoteRosterEntry.getUser(),
|
||||||
|
remoteRosterEntry.getName(),
|
||||||
|
remoteRosterEntry.getGroupArrayNames());
|
||||||
|
}
|
||||||
|
catch (XMPPException e) {
|
||||||
|
fail(e.toString());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
entriesReceived = received;
|
||||||
|
}
|
||||||
|
};
|
||||||
|
rosterExchangeManager2.addRosterListener(rosterExchangeListener);
|
||||||
|
|
||||||
|
// Send user1's roster to user2
|
||||||
|
try {
|
||||||
|
entriesSent = conn1.getRoster().getEntryCount();
|
||||||
|
entriesReceived = 0;
|
||||||
|
rosterExchangeManager1.send(conn1.getRoster(), user2);
|
||||||
|
} catch (Exception e) {
|
||||||
|
fail("An error occured sending the message with the roster");
|
||||||
|
}
|
||||||
|
// Wait for 2 seconds
|
||||||
|
Thread.sleep(2000);
|
||||||
|
assertEquals("Number of sent and received entries does not match", entriesSent, entriesReceived);
|
||||||
|
} catch (Exception e) {
|
||||||
|
fail(e.toString());
|
||||||
|
} finally {
|
||||||
|
if (conn1 != null)
|
||||||
|
conn1.close();
|
||||||
|
if (conn2 != null)
|
||||||
|
conn2.close();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
76
test/org/jivesoftware/smackx/RosterExchangeTests.java
Normal file
76
test/org/jivesoftware/smackx/RosterExchangeTests.java
Normal file
|
@ -0,0 +1,76 @@
|
||||||
|
/**
|
||||||
|
* $RCSfile$
|
||||||
|
* $Revision$
|
||||||
|
* $Date$
|
||||||
|
*
|
||||||
|
* Copyright (C) 2002-2003 Jive Software. All rights reserved.
|
||||||
|
* ====================================================================
|
||||||
|
* The Jive Software License (based on Apache Software License, Version 1.1)
|
||||||
|
*
|
||||||
|
* Redistribution and use in source and binary forms, with or without
|
||||||
|
* modification, are permitted provided that the following conditions
|
||||||
|
* are met:
|
||||||
|
*
|
||||||
|
* 1. Redistributions of source code must retain the above copyright
|
||||||
|
* notice, this list of conditions and the following disclaimer.
|
||||||
|
*
|
||||||
|
* 2. Redistributions in binary form must reproduce the above copyright
|
||||||
|
* notice, this list of conditions and the following disclaimer in
|
||||||
|
* the documentation and/or other materials provided with the
|
||||||
|
* distribution.
|
||||||
|
*
|
||||||
|
* 3. The end-user documentation included with the redistribution,
|
||||||
|
* if any, must include the following acknowledgment:
|
||||||
|
* "This product includes software developed by
|
||||||
|
* Jive Software (http://www.jivesoftware.com)."
|
||||||
|
* Alternately, this acknowledgment may appear in the software itself,
|
||||||
|
* if and wherever such third-party acknowledgments normally appear.
|
||||||
|
*
|
||||||
|
* 4. The names "Smack" and "Jive Software" must not be used to
|
||||||
|
* endorse or promote products derived from this software without
|
||||||
|
* prior written permission. For written permission, please
|
||||||
|
* contact webmaster@jivesoftware.com.
|
||||||
|
*
|
||||||
|
* 5. Products derived from this software may not be called "Smack",
|
||||||
|
* nor may "Smack" appear in their name, without prior written
|
||||||
|
* permission of Jive Software.
|
||||||
|
*
|
||||||
|
* THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED
|
||||||
|
* WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
|
||||||
|
* OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
|
||||||
|
* DISCLAIMED. IN NO EVENT SHALL JIVE SOFTWARE OR
|
||||||
|
* ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
|
||||||
|
* SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
|
||||||
|
* LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
|
||||||
|
* USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
|
||||||
|
* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
|
||||||
|
* OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
|
||||||
|
* OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
|
||||||
|
* SUCH DAMAGE.
|
||||||
|
* ====================================================================
|
||||||
|
*/
|
||||||
|
|
||||||
|
package org.jivesoftware.smackx;
|
||||||
|
|
||||||
|
import org.jivesoftware.smackx.packet.RosterExchangeTest;
|
||||||
|
|
||||||
|
import junit.framework.Test;
|
||||||
|
import junit.framework.TestSuite;
|
||||||
|
|
||||||
|
/**
|
||||||
|
*
|
||||||
|
* Test suite that runs all the Roster Exchange extension tests
|
||||||
|
*
|
||||||
|
* @author Gaston Dombiak
|
||||||
|
*/
|
||||||
|
public class RosterExchangeTests {
|
||||||
|
|
||||||
|
public static Test suite() {
|
||||||
|
TestSuite suite = new TestSuite("High and low level API tests for roster exchange extension");
|
||||||
|
//$JUnit-BEGIN$
|
||||||
|
suite.addTest(new TestSuite(RosterExchangeManagerTest.class));
|
||||||
|
suite.addTest(new TestSuite(RosterExchangeTest.class));
|
||||||
|
//$JUnit-END$
|
||||||
|
return suite;
|
||||||
|
}
|
||||||
|
}
|
|
@ -9,13 +9,12 @@ import java.util.Iterator;
|
||||||
import org.jivesoftware.smack.*;
|
import org.jivesoftware.smack.*;
|
||||||
import org.jivesoftware.smack.filter.*;
|
import org.jivesoftware.smack.filter.*;
|
||||||
import org.jivesoftware.smack.packet.*;
|
import org.jivesoftware.smack.packet.*;
|
||||||
import org.jivesoftware.smackx.packet.RosterExchange;
|
|
||||||
|
|
||||||
import junit.framework.TestCase;
|
import junit.framework.TestCase;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
* Test the Roster Exchange extension
|
* Test the Roster Exchange extension using the low level API
|
||||||
*
|
*
|
||||||
* @author Gaston Dombiak
|
* @author Gaston Dombiak
|
||||||
*/
|
*/
|
||||||
|
@ -30,19 +29,67 @@ public class RosterExchangeTest extends TestCase {
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
* Low level API test.
|
||||||
|
* This is a simple test to use with a XMPP client and check if the client receives the message
|
||||||
* 1. User_1 will send his/her roster entries to user_2
|
* 1. User_1 will send his/her roster entries to user_2
|
||||||
* 2. User_2 will receives the entries and iterate over them to check if everything is fine
|
*/
|
||||||
|
public void testSendRosterEntries() {
|
||||||
|
String host = "localhost";
|
||||||
|
String server_user1 = "gato3";
|
||||||
|
String user1 = "gato3@localhost";
|
||||||
|
String pass1 = "gato3";
|
||||||
|
|
||||||
|
String user2 = "gato4@localhost";
|
||||||
|
|
||||||
|
XMPPConnection conn1 = null;
|
||||||
|
|
||||||
|
try {
|
||||||
|
// Connect to the server and log in the users
|
||||||
|
conn1 = new XMPPConnection(host);
|
||||||
|
conn1.login(server_user1, pass1);
|
||||||
|
|
||||||
|
// Create a chat for each connection
|
||||||
|
Chat chat1 = conn1.createChat(user2);
|
||||||
|
|
||||||
|
// Create the message to send with the roster
|
||||||
|
Message msg = chat1.createMessage();
|
||||||
|
msg.setSubject("Any subject you want");
|
||||||
|
msg.setBody("This message contains roster items.");
|
||||||
|
// Create a RosterExchange Package and add it to the message
|
||||||
|
assertTrue("Roster has no entries", conn1.getRoster().getEntryCount() > 0);
|
||||||
|
RosterExchange rosterExchange = new RosterExchange(conn1.getRoster());
|
||||||
|
msg.addExtension(rosterExchange);
|
||||||
|
|
||||||
|
// Send the message that contains the roster
|
||||||
|
try {
|
||||||
|
chat1.sendMessage(msg);
|
||||||
|
} catch (Exception e) {
|
||||||
|
fail("An error occured sending the message with the roster");
|
||||||
|
}
|
||||||
|
} catch (Exception e) {
|
||||||
|
fail(e.toString());
|
||||||
|
} finally {
|
||||||
|
if (conn1 != null)
|
||||||
|
conn1.close();
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Low level API test.
|
||||||
|
* 1. User_1 will send his/her roster entries to user_2
|
||||||
|
* 2. User_2 will receive the entries and iterate over them to check if everything is fine
|
||||||
* 3. User_1 will wait several seconds for an ACK from user_2, if none is received then something is wrong
|
* 3. User_1 will wait several seconds for an ACK from user_2, if none is received then something is wrong
|
||||||
*/
|
*/
|
||||||
public void testSendAndReceiveRosterEntries() {
|
public void testSendAndReceiveRosterEntries() {
|
||||||
String host = "localhost";
|
String host = "localhost";
|
||||||
String server_user1 = "gato3";
|
String server_user1 = "gato3";
|
||||||
String user1 = "gato3@gato.home";
|
String user1 = "gato3@localhost";
|
||||||
String pass1 = "gato3";
|
String pass1 = "gato3";
|
||||||
|
|
||||||
String server_user2 = "gato1";
|
String server_user2 = "gato4";
|
||||||
String user2 = "gato1@gato.home";
|
String user2 = "gato4@localhost";
|
||||||
String pass2 = "gato1";
|
String pass2 = "gato4";
|
||||||
|
|
||||||
XMPPConnection conn1 = null;
|
XMPPConnection conn1 = null;
|
||||||
XMPPConnection conn2 = null;
|
XMPPConnection conn2 = null;
|
||||||
|
@ -66,14 +113,18 @@ public class RosterExchangeTest extends TestCase {
|
||||||
Message message = (Message) packet;
|
Message message = (Message) packet;
|
||||||
assertNotNull("Body is null", message.getBody());
|
assertNotNull("Body is null", message.getBody());
|
||||||
try {
|
try {
|
||||||
RosterExchange rosterExchange = (RosterExchange) message.getExtension("x","jabber:x:roster");
|
RosterExchange rosterExchange =
|
||||||
assertNotNull("Message without extension \"jabber:x:roster\"", rosterExchange);
|
(RosterExchange) message.getExtension("x", "jabber:x:roster");
|
||||||
assertTrue("Roster without entries", rosterExchange.getRosterItems().hasNext());
|
assertNotNull(
|
||||||
for (Iterator it = rosterExchange.getRosterItems(); it.hasNext();) {
|
"Message without extension \"jabber:x:roster\"",
|
||||||
RosterExchange.Item item = (RosterExchange.Item) it.next();
|
rosterExchange);
|
||||||
|
assertTrue(
|
||||||
|
"Roster without entries",
|
||||||
|
rosterExchange.getRosterEntries().hasNext());
|
||||||
|
for (Iterator it = rosterExchange.getRosterEntries(); it.hasNext();) {
|
||||||
|
RemoteRosterEntry remoteRosterEntry = (RemoteRosterEntry) it.next();
|
||||||
}
|
}
|
||||||
}
|
} catch (ClassCastException e) {
|
||||||
catch (ClassCastException e){
|
|
||||||
fail("ClassCastException - Most probable cause is that smack providers is misconfigured");
|
fail("ClassCastException - Most probable cause is that smack providers is misconfigured");
|
||||||
}
|
}
|
||||||
try {
|
try {
|
||||||
|
@ -86,10 +137,11 @@ public class RosterExchangeTest extends TestCase {
|
||||||
conn2.addPacketListener(packetListener, packetFilter);
|
conn2.addPacketListener(packetListener, packetFilter);
|
||||||
|
|
||||||
// Create the message to send with the roster
|
// Create the message to send with the roster
|
||||||
Message msg = new Message(user2);
|
Message msg = chat1.createMessage();
|
||||||
msg.setSubject("Any subject you want");
|
msg.setSubject("Any subject you want");
|
||||||
msg.setBody("This message contains roster items.");
|
msg.setBody("This message contains roster items.");
|
||||||
// Create a RosterExchange Package and add it to the message
|
// Create a RosterExchange Package and add it to the message
|
||||||
|
assertTrue("Roster has no entries", conn1.getRoster().getEntryCount() > 0);
|
||||||
RosterExchange rosterExchange = new RosterExchange(conn1.getRoster());
|
RosterExchange rosterExchange = new RosterExchange(conn1.getRoster());
|
||||||
msg.addExtension(rosterExchange);
|
msg.addExtension(rosterExchange);
|
||||||
|
|
||||||
|
@ -102,11 +154,9 @@ public class RosterExchangeTest extends TestCase {
|
||||||
// Wait for 2 seconds for a reply
|
// Wait for 2 seconds for a reply
|
||||||
msg = chat1.nextMessage(2000);
|
msg = chat1.nextMessage(2000);
|
||||||
assertNotNull("No reply received", msg);
|
assertNotNull("No reply received", msg);
|
||||||
}
|
} catch (Exception e) {
|
||||||
catch (Exception e) {
|
|
||||||
fail(e.toString());
|
fail(e.toString());
|
||||||
}
|
} finally {
|
||||||
finally {
|
|
||||||
if (conn1 != null)
|
if (conn1 != null)
|
||||||
conn1.close();
|
conn1.close();
|
||||||
if (conn2 != null)
|
if (conn2 != null)
|
||||||
|
@ -116,6 +166,7 @@ public class RosterExchangeTest extends TestCase {
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
* Low level API test.
|
||||||
* 1. User_1 will send his/her roster entries to user_2
|
* 1. User_1 will send his/her roster entries to user_2
|
||||||
* 2. User_2 will automatically add the entries that receives to his/her roster in the corresponding group
|
* 2. User_2 will automatically add the entries that receives to his/her roster in the corresponding group
|
||||||
* 3. User_1 will wait several seconds for an ACK from user_2, if none is received then something is wrong
|
* 3. User_1 will wait several seconds for an ACK from user_2, if none is received then something is wrong
|
||||||
|
@ -123,11 +174,11 @@ public class RosterExchangeTest extends TestCase {
|
||||||
public void testSendAndAcceptRosterEntries() {
|
public void testSendAndAcceptRosterEntries() {
|
||||||
String host = "localhost";
|
String host = "localhost";
|
||||||
String server_user1 = "gato3";
|
String server_user1 = "gato3";
|
||||||
String user1 = "gato3@gato.home";
|
String user1 = "gato3@localhost";
|
||||||
String pass1 = "gato3";
|
String pass1 = "gato3";
|
||||||
|
|
||||||
String server_user2 = "gato4";
|
String server_user2 = "gato4";
|
||||||
String user2 = "gato4@gato.home";
|
String user2 = "gato4@localhost";
|
||||||
String pass2 = "gato4";
|
String pass2 = "gato4";
|
||||||
|
|
||||||
XMPPConnection conn1 = null;
|
XMPPConnection conn1 = null;
|
||||||
|
@ -153,19 +204,25 @@ public class RosterExchangeTest extends TestCase {
|
||||||
Message message = (Message) packet;
|
Message message = (Message) packet;
|
||||||
assertNotNull("Body is null", message.getBody());
|
assertNotNull("Body is null", message.getBody());
|
||||||
try {
|
try {
|
||||||
RosterExchange rosterExchange = (RosterExchange) message.getExtension("x","jabber:x:roster");
|
RosterExchange rosterExchange =
|
||||||
assertNotNull("Message without extension \"jabber:x:roster\"", rosterExchange);
|
(RosterExchange) message.getExtension("x", "jabber:x:roster");
|
||||||
assertTrue("Roster without entries", rosterExchange.getRosterItems().hasNext());
|
assertNotNull(
|
||||||
|
"Message without extension \"jabber:x:roster\"",
|
||||||
|
rosterExchange);
|
||||||
|
assertTrue(
|
||||||
|
"Roster without entries",
|
||||||
|
rosterExchange.getRosterEntries().hasNext());
|
||||||
// Add the roster entries to user2's roster
|
// Add the roster entries to user2's roster
|
||||||
for (Iterator it = rosterExchange.getRosterItems(); it.hasNext();) {
|
for (Iterator it = rosterExchange.getRosterEntries(); it.hasNext();) {
|
||||||
RosterExchange.Item item = (RosterExchange.Item) it.next();
|
RemoteRosterEntry remoteRosterEntry = (RemoteRosterEntry) it.next();
|
||||||
user2_roster.createEntry(item.getUser(), item.getName(), item.getGroupArrayNames());
|
user2_roster.createEntry(
|
||||||
|
remoteRosterEntry.getUser(),
|
||||||
|
remoteRosterEntry.getName(),
|
||||||
|
remoteRosterEntry.getGroupArrayNames());
|
||||||
}
|
}
|
||||||
}
|
} catch (ClassCastException e) {
|
||||||
catch (ClassCastException e){
|
|
||||||
fail("ClassCastException - Most probable cause is that smack providers is misconfigured");
|
fail("ClassCastException - Most probable cause is that smack providers is misconfigured");
|
||||||
}
|
} catch (Exception e) {
|
||||||
catch (Exception e) {
|
|
||||||
fail(e.toString());
|
fail(e.toString());
|
||||||
}
|
}
|
||||||
try {
|
try {
|
||||||
|
@ -178,10 +235,11 @@ public class RosterExchangeTest extends TestCase {
|
||||||
conn2.addPacketListener(packetListener, packetFilter);
|
conn2.addPacketListener(packetListener, packetFilter);
|
||||||
|
|
||||||
// Create the message to send with the roster
|
// Create the message to send with the roster
|
||||||
Message msg = new Message(user2);
|
Message msg = chat1.createMessage();
|
||||||
msg.setSubject("Any subject you want");
|
msg.setSubject("Any subject you want");
|
||||||
msg.setBody("This message contains roster items.");
|
msg.setBody("This message contains roster items.");
|
||||||
// Create a RosterExchange Package and add it to the message
|
// Create a RosterExchange Package and add it to the message
|
||||||
|
assertTrue("Roster has no entries", conn1.getRoster().getEntryCount() > 0);
|
||||||
RosterExchange rosterExchange = new RosterExchange(conn1.getRoster());
|
RosterExchange rosterExchange = new RosterExchange(conn1.getRoster());
|
||||||
msg.addExtension(rosterExchange);
|
msg.addExtension(rosterExchange);
|
||||||
|
|
||||||
|
@ -194,11 +252,9 @@ public class RosterExchangeTest extends TestCase {
|
||||||
// Wait for 10 seconds for a reply
|
// Wait for 10 seconds for a reply
|
||||||
msg = chat1.nextMessage(5000);
|
msg = chat1.nextMessage(5000);
|
||||||
assertNotNull("No reply received", msg);
|
assertNotNull("No reply received", msg);
|
||||||
}
|
} catch (Exception e) {
|
||||||
catch (Exception e) {
|
|
||||||
fail(e.toString());
|
fail(e.toString());
|
||||||
}
|
} finally {
|
||||||
finally {
|
|
||||||
if (conn1 != null)
|
if (conn1 != null)
|
||||||
conn1.close();
|
conn1.close();
|
||||||
if (conn2 != null)
|
if (conn2 != null)
|
||||||
|
|
Loading…
Reference in a new issue