sdis1819-t2g11

import java.io.IOException;

import java.net.DatagramPacket;

import java.net.InetAddress;

import java.net.MulticastSocket;

import java.util.concurrent.ConcurrentHashMap;

import java.io.ByteArrayOutputStream;

public abstract class Channel extends Thread {

    public enum ChannelType {

        MC, MDB, MDR

    }

    protected InetAddress channelAdress;

    protected int port;

    protected int peerId;

    protected ChannelsInfo cInfo;

    protected MulticastSocket socket;

    protected ChannelType type;

    protected PeersInfo peersInfo;

    public Channel(PeersInfo peersInfo, ChannelsInfo cInfo, int id, InetAddress addr, int port) {

        this.peersInfo=peersInfo;

        this.peerId = id;

        this.channelAdress = addr;

        this.port = port;

        this.cInfo = cInfo;

    }

    public int getPort() {

        return port;

    }

    public void setPort(int porta) {

        this.port = porta;

    }

    public InetAddress getChannelAddress() {

        return channelAdress;

    }

    public MulticastSocket getSocket() {

        return this.socket;

    }

    public void setSocket(MulticastSocket socket) {

        this.socket = socket;

    }

    private void close() {

        try {

            this.socket.leaveGroup(this.channelAdress);

            this.socket.close();

        } catch (IOException e) {

            throw new RuntimeException("Socket couldn't be closed.", e);

        }

    }

    public byte[] createMessage(String protocol, String version, int senderId, String fileId, String[] args,

                                byte[] body) {

        String msg = "";

        msg = protocol + " " + version + " " + senderId + " " + fileId + " ";

        for (String arg : args) {

            msg += arg + " ";

        }

        msg += "\r\n\r\n";

        System.out.println(msg);

        ByteArrayOutputStream append = new ByteArrayOutputStream();

        try {

            append.write(msg.getBytes());

            if (body != null) {

                append.write(body);

            }

        } catch (IOException e) {

            e.printStackTrace();

        }

        return append.toByteArray();

    }

    @Override

    public void run() {

        System.out.println("The channel is now running.");

    }

}