SDIS1819-T2G01

import java.io.IOException;

import java.net.DatagramPacket;

import java.net.InetAddress;

import java.net.MulticastSocket;

import java.util.AbstractMap.SimpleEntry;

public class Socket implements Runnable {

    public MulticastSocket socket;

    public int port;

    public InetAddress address;

    public enum Type {

        MC, MDB, MDR

    }

    public Type type;

    public Server peer;

    // Message size(safe size)

    public static final int MESSAGE_SIZE = 65500;

    // Default constructor

    public Socket(Server peer, Type type) throws IOException {

        this.peer = peer;

        switch (type) {

        case MC:

            this.port = 8000;

            this.address = InetAddress.getByName("224.0.0.1");

            break;

        case MDB:

            this.port = 8001;

            this.address = InetAddress.getByName("224.0.0.2");

            break;

        case MDR:

            this.port = 8002;

            this.address = InetAddress.getByName("224.0.0.3");

            break;

        default:

            return;

        }

        this.type = type;

        this.socket = new MulticastSocket(this.port);

        this.socket.joinGroup(address);

    }

    // Specific constructor

    public Socket(Server peer, Type type, int port, String address) throws IOException {

        this.peer = peer;

        this.type = type;

        this.port = port;

        this.address = InetAddress.getByName(address);

        this.socket = new MulticastSocket(this.port);

        this.socket.joinGroup(this.address);

    }

    @Override

    public void run() {

        while (true) {

            byte[] buf = new byte[MESSAGE_SIZE];

            DatagramPacket packet = new DatagramPacket(buf, buf.length);

            try {

                this.socket.receive(packet);

                System.out.println("Packet received, launching interpreter");

                Server.pool.execute(new Interpreter(peer, packet));

            } catch (IOException e) {

                e.printStackTrace();

            }

        }

    }

}