/**
 * Test_UnicastSocket.java
 *
 *
 *
 * @author Einar Vollset <einar.vollset@ncl.ac.uk>
 *
 */
package fake.net;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.InetAddress;

public class Test_UnicastSocket implements Runnable
{

    private MulticastSocket m_socket = null;
    private boolean m_initiator = false;

    public Test_UnicastSocket(String addr, boolean initiator) throws Exception
    {
        m_socket = new MulticastSocket(3778,addr);
        m_socket.setInterface(InetAddress.getByName(addr));
        m_initiator = initiator;

    }


    public void run()
    {
        try
        {
            if(m_initiator)
            {
                byte[] data = {0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 0};
                DatagramPacket toBeSent = new DatagramPacket(data, data.length, InetAddress.getByName("192.168.0.2"), 3778);
                m_socket.send(toBeSent);
                System.out.println("Sent1");

                byte[] buf = new byte[8192];
                DatagramPacket received = new DatagramPacket(buf, 8192);
                m_socket.receive(received);
                System.out.println("Received1");

                DatagramPacket toBeSent2 = new DatagramPacket(received.getData(), received.getData().length, InetAddress.getByName("192.168.0.3"), 3778);
                m_socket.send(toBeSent2);
                System.out.println("Sent2");


                byte[] buf2 = new byte[8192];
                DatagramPacket received2 = new DatagramPacket(buf2, 8192);
                m_socket.receive(received2);
                System.out.println("Received2");

                 DatagramPacket toBeSent3 = new DatagramPacket(received2.getData(), received2.getData().length, InetAddress.getByName("192.168.0.4"), 3778);
                m_socket.send(toBeSent3);
                System.out.println("Sent3");


                byte[] buf3 = new byte[8192];
                DatagramPacket received3 = new DatagramPacket(buf3, 8192);
                m_socket.receive(received3);
                System.out.println("Received3");


                System.out.println("data: " + data[0] + "-" + data[1] + "-" + data[2] + "-" + data[3] + "-" + data[4] + "-" + data[5] + "-" + data[6] + "-" + data[7] + "-" + data[8] + "-" + data[9] + "-" + data[10]);
                System.out.println("received3.getData(): " + received3.getData()[0] + "-" + received3.getData()[1] + "-" + received3.getData()[2] + "-" + received3.getData()[3] + "-" + received3.getData()[4] + "-" + received3.getData()[5] + "-" + received3.getData()[6] + "-" + received3.getData()[7] + "-" + received3.getData()[8] + "-" + received3.getData()[9] + "-" + received3.getData()[10]);

                m_socket.close();
            }
            else
            {
                byte[] buf = new byte[8192];
                DatagramPacket received = new DatagramPacket(buf, 8192);
                m_socket.receive(received);
                byte[] data = received.getData();
                DatagramPacket toBeSent = new DatagramPacket(data, data.length, InetAddress.getByName("192.168.0.1"), 3778);
                m_socket.send(toBeSent);
                System.out.println("Sent packet back");

                /*  byte[] buf2 = new byte[8192];
                  DatagramPacket received2 = new DatagramPacket(buf2, 8192);
                  m_socket.receive(received2);
                  byte[] data2 = received2.getData();
                  DatagramPacket toBeSent2 = new DatagramPacket(data2, data2.length, InetAddress.getByName("192.168.0.1"), 3778);
                  m_socket.send(toBeSent2);
                  System.out.println("Sent packet back");*/
            }
        }
        catch(IOException e)
        {
            e.printStackTrace();
        }

    }

    public static void main(String[] args)
    {

        try
        {
            Test_UnicastSocket test1 = new Test_UnicastSocket("192.168.0.1", true);
            Test_UnicastSocket test2 = new Test_UnicastSocket("192.168.0.2", false);
            Test_UnicastSocket test3 = new Test_UnicastSocket("192.168.0.3", false);
             Test_UnicastSocket test4 = new Test_UnicastSocket("192.168.0.4", false);
            new Thread(test2).start();
            new Thread(test1).start();
            new Thread(test4).start();
            new Thread(test3).start();
            System.out.println("Started all tests");
        }
        catch(Exception e)
        {
            e.printStackTrace();
        }
    }

//    DatagramPacket datagram = new DatagramPacket(packet.getBytes(), packet.getBytes().length, m_multicastAddress, Preferences.portNo);
//    m_multicastSocket.send(datagram);
//
//    byte[] buf = new byte[Preferences.maxPacketSize];
//    datagram = new DatagramPacket(buf, Preferences.maxPacketSize);
//    m_multicastSocket.receive(datagram);
}