/*
 * Created on 01/08/2003
 *
 */
package org.jivesoftware.smackx.packet;

import java.util.Iterator;

import org.jivesoftware.smack.*;
import org.jivesoftware.smack.filter.*;
import org.jivesoftware.smack.packet.*;
import org.jivesoftware.smackx.*;

import junit.framework.TestCase;

/**
 *
 * Test the Roster Exchange extension using the low level API
 *
 * @author Gaston Dombiak
 */
public class RosterExchangeTest extends TestCase {

    /**
     * Constructor for RosterExchangeTest.
     * @param arg0
     */
    public RosterExchangeTest(String arg0) {
        super(arg0);
    }

    /**
     * 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
     */
    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
     */
    public void testSendAndReceiveRosterEntries() {
        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);

            // Create a chat for each connection
            Chat chat1 = conn1.createChat(user2);
            final Chat chat2 = new Chat(conn2, user1, chat1.getChatID());

            // Create a Listener that listens for Messages with the extension "jabber:x:roster"
            // This listener will listen on the conn2 and answer an ACK if everything is ok
            PacketFilter packetFilter = new PacketExtensionFilter("x", "jabber:x:roster");
            PacketListener packetListener = new PacketListener() {
                public void processPacket(Packet packet) {
                    Message message = (Message) packet;
                    assertNotNull("Body is null", message.getBody());
                    try {
                        RosterExchange rosterExchange =
                            (RosterExchange) message.getExtension("x", "jabber:x:roster");
                        assertNotNull(
                            "Message without extension \"jabber:x:roster\"",
                            rosterExchange);
                        assertTrue(
                            "Roster without entries",
                            rosterExchange.getRosterEntries().hasNext());
                        for (Iterator it = rosterExchange.getRosterEntries(); it.hasNext();) {
                            RemoteRosterEntry remoteRosterEntry = (RemoteRosterEntry) it.next();
                        }
                    } catch (ClassCastException e) {
                        fail("ClassCastException - Most probable cause is that smack providers is misconfigured");
                    }
                    try {
                        chat2.sendMessage("ok");
                    } catch (Exception e) {
                        fail("An error occured sending ack " + e.getMessage());
                    }
                }
            };
            conn2.addPacketListener(packetListener, packetFilter);

            // 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");
            }
            // Wait for 2 seconds for a reply
            msg = chat1.nextMessage(2000);
            assertNotNull("No reply received", msg);
        } catch (Exception e) {
            fail(e.toString());
        } finally {
            if (conn1 != null)
                conn1.close();
            if (conn2 != null)
                conn2.close();
        }

    }

    /**
     * Low level API test.
     * 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
     * 3. User_1 will wait several seconds for an ACK from user_2, if none is received then something is wrong
     */
    public void testSendAndAcceptRosterEntries() {
        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();

            // Create a chat for each connection
            Chat chat1 = conn1.createChat(user2);
            final Chat chat2 = new Chat(conn2, user1, chat1.getChatID());

            // Create a Listener that listens for Messages with the extension "jabber:x:roster"
            // This listener will listen on the conn2, save the roster entries and answer an ACK if everything is ok
            PacketFilter packetFilter = new PacketExtensionFilter("x", "jabber:x:roster");
            PacketListener packetListener = new PacketListener() {
                public void processPacket(Packet packet) {
                    Message message = (Message) packet;
                    assertNotNull("Body is null", message.getBody());
                    try {
                        RosterExchange rosterExchange =
                            (RosterExchange) message.getExtension("x", "jabber:x:roster");
                        assertNotNull(
                            "Message without extension \"jabber:x:roster\"",
                            rosterExchange);
                        assertTrue(
                            "Roster without entries",
                            rosterExchange.getRosterEntries().hasNext());
                        // Add the roster entries to user2's roster
                        for (Iterator it = rosterExchange.getRosterEntries(); it.hasNext();) {
                            RemoteRosterEntry remoteRosterEntry = (RemoteRosterEntry) it.next();
                            user2_roster.createEntry(
                                remoteRosterEntry.getUser(),
                                remoteRosterEntry.getName(),
                                remoteRosterEntry.getGroupArrayNames());
                        }
                    } catch (ClassCastException e) {
                        fail("ClassCastException - Most probable cause is that smack providers is misconfigured");
                    } catch (Exception e) {
                        fail(e.toString());
                    }
                    try {
                        chat2.sendMessage("ok");
                    } catch (Exception e) {
                        fail("An error occured sending ack " + e.getMessage());
                    }
                }
            };
            conn2.addPacketListener(packetListener, packetFilter);

            // 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");
            }
            // Wait for 10 seconds for a reply
            msg = chat1.nextMessage(5000);
            assertNotNull("No reply received", msg);
        } catch (Exception e) {
            fail(e.toString());
        } finally {
            if (conn1 != null)
                conn1.close();
            if (conn2 != null)
                conn2.close();
        }

    }

}