package praktikum5.aufgabe4;

import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {
    private ServerSocket socket;

    public Server(ServerSocket socket) {
        this.socket = socket;
    }

    public String echo() throws IOException {
        var clientSocket = socket.accept();
        var in = clientSocket.getInputStream();
        var out = clientSocket.getOutputStream();
        var reader = new InputStreamReader(in);
        var writer = new OutputStreamWriter(out);

        var msg = "";
        var curr = reader.read();
        while (curr != -1) {
            msg += (char)curr;
            curr = reader.read();
        }

        writer.write(msg);
        writer.flush();
        writer.close();

        return msg;
    }

    public static void main(String[] args) {
        try {
            int port = 4711;
            var socket = new ServerSocket(port);
            var server = new Server(socket);
            System.out.println("Listening on port " + port);
            while (true) {
                var msg = server.echo();
                System.out.println("Request: " + msg);
            }
        } catch (Exception e) {
            System.out.println(e);
        }
    }
}