package objects.comunication;

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

import communicator.Gui;

public class Server extends Thread {
    private volatile boolean stop = false;
    private String finalny;
    private DatagramSocket sock;

    public void run() {
        try {
            // 1. creating a server socket, parameter is local port number
            sock = new DatagramSocket(7777);

            // buffer to receive incoming data
            byte[] buffer = new byte[20];
            DatagramPacket incoming = new DatagramPacket(buffer, buffer.length);

            // communication loop
            while (!stop) {
                sock.receive(incoming);
                byte[] data = incoming.getData();
                String s = new String(data, 0, incoming.getLength());

                // echo the details of incoming data - client ip : client port -
                // client message
                finalny = (incoming.getAddress().getHostAddress() + " "
                        + incoming.getPort() + " - " + s);
                Gui.getTextArea().append(finalny + "\n");
            }
        }

        catch (IOException e) {
            System.err.println("IOException " + e);
        }
    }

    public void requestStop() {
        stop = true;
    }

    public String getFinalny() {
        return finalny;
    }

    public void setFinalny(String finalny) {
        this.finalny = finalny;
    }

}