sdis1819-t2g03

/*

 * To change this license header, choose License Headers in Project Properties.

 * To change this template file, choose Tools | Templates

 * and open the template in the editor.

 */

package sockets;

import utils.Utils;

import java.io.IOException;

import java.net.DatagramPacket;

import java.net.InetAddress;

import java.net.MulticastSocket;

import server.Peer;

public class Socket implements Runnable {

        protected int port;

        protected MulticastSocket socket;

        protected InetAddress address;

        protected Peer peer;

        public Socket(Peer peer, String address, String port) {

                this.peer = peer;

                try {

                        this.address = InetAddress.getByName(address);

                        this.port = Integer.parseInt(port);

                } catch (IOException e) {

                        e.printStackTrace();

                }

        }

        private void openSocket() {

                try{

                        socket = new MulticastSocket(port);

                        socket.setTimeToLive(1);

                        socket.joinGroup(address);

                } catch (IOException e){

                        e.printStackTrace();

                }

        }

        public MulticastSocket getSocket() {

                return socket;

        }

        @Override

        public void run() {

                openSocket();

                byte[] buffer = new byte[Utils.PACKET_SIZE];

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

                while(true) {

                        try {

                                this.socket.receive(packet);

                        }

                        catch(IOException e) {

                                e.printStackTrace();

                        }

                        try {

                                peer.pushMsgHandler(packet.getData(), packet.getLength());

                        } catch(IOException e) {

                                e.printStackTrace();

                        }

                }

        }

        public void sendMsg(byte[] msg) {

                DatagramPacket packet = new DatagramPacket(msg, msg.length, address, port);

                try {

                        socket.send(packet);

                } catch (IOException e) {

                        e.printStackTrace();

                }

        }

    public enum SocketType {

        MC, MDB, MDR

    }

}