/*
 * Andrea Caravano (www.andreacaravano.net)
 *
 * Esercizio 2: "StoAspettando"
 * Descrizione: Progettare un’applicazione Client/Server Multithread in Java che attenda, per ogni client collegato,
 * un numero non precisato di stringhe. L’invio del client termina quando la stringa ricevuta dal server
 * corrisponde a “FINE-INVIO”.
 * Prima di concludere la comunicazione, vengono inviate nuovamente al client le stringhe ricevute, trasformate
 * in maiuscolo.
 *
 * Possibile soluzione
 * Componente Client
 *
 * N.B.: L'esercizio scaturisce dalla sola fantasia dell'autore e intende rappresentare una applicazione didattica.
 * I dettagli in esso contenuti potrebbero non essere corrispondenti alla realtà e intendono valutare le abilità nella gestione delle strutture dati proposte.
 */

import java.io.*;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Scanner;

public class ClientStoAspettando {

    static final String INDIRIZZOSERVER = "127.0.0.1";
    static final int PORTASERVER = 9000;

    public static void main(String[] args) {
        try (Socket processoClient = new Socket(INDIRIZZOSERVER, PORTASERVER)) {
            System.out.format("Connesso al processo server avviato con il seguente indirizzo di socket: %s%n", processoClient.getRemoteSocketAddress());
            System.out.format("Processo client avviato con il seguente indirizzo di socket: %s%n", processoClient.getLocalSocketAddress());
            avviaComunicazione(processoClient);
        } catch (UnknownHostException e) {
            System.err.println("Server non contattabile. Possibile errore di immissione.");
        } catch (IOException e) {
            System.err.format("Errore connessione con server: %s%n", e.getMessage());
        }
    }

    private static void avviaComunicazione(Socket processoClient) throws IOException {
        BufferedReader BR = new BufferedReader(new InputStreamReader(processoClient.getInputStream(), "UTF-8"));
        PrintWriter PW = new PrintWriter(new OutputStreamWriter(processoClient.getOutputStream(), "UTF-8"), true);
        Scanner S = new Scanner(System.in);
        String stringaClient = " ";
        while (stringaClient.equals("FINE-INVIO") == false) {
            System.out.print("Immetti la stringa da inviare al server: ");
            stringaClient = S.nextLine();
            PW.println(stringaClient);
        }
        PW.println(stringaClient);
        S = new Scanner(BR.readLine());
        int contaStringhe = S.nextInt();
        System.out.println();
        System.out.println("Stringhe ricevute dal server: ");
        for (int i = 0; i < contaStringhe; i++) {
            String stringaRicevuta = BR.readLine();
            System.out.println(stringaRicevuta);
        }
    }
}

/*
 * Andrea Caravano (www.andreacaravano.net)
 *
 * Esercizio 2: "StoAspettando"
 * Descrizione: Progettare un’applicazione Client/Server Multithread in Java che attenda, per ogni client collegato,
 * un numero non precisato di stringhe. L’invio del client termina quando la stringa ricevuta dal server
 * corrisponde a “FINE-INVIO”.
 * Prima di concludere la comunicazione, vengono inviate nuovamente al client le stringhe ricevute, trasformate
 * in maiuscolo.
 *
 * Possibile soluzione
 * Componente Server
 *
 * N.B.: L'esercizio scaturisce dalla sola fantasia dell'autore e intende rappresentare una applicazione didattica.
 * I dettagli in esso contenuti potrebbero non essere corrispondenti alla realtà e intendono valutare le abilità nella gestione delle strutture dati proposte.
 */

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class ServerStoAspettando {
    static final int PORTALISTEN = 9000;
    static ExecutorService esecutore = Executors.newCachedThreadPool();
    static final String FINESEQUENZA = "FINE-INVIO";

    public static void main(String[] args) {
        try (ServerSocket procServer = new ServerSocket(PORTALISTEN)) {
            System.out.format("Processo server avviato con il seguente indirizzo di socket: %s%n", procServer.getLocalSocketAddress());
            while (true) {
                try {
                    Socket tempSocket = procServer.accept();
                    esecutore.execute(() -> {
                        try (Socket varClient = tempSocket) {
                            System.out.format("Thread ID = %d - Indirizzo di socket del client: %s%n", Thread.currentThread().getId(), varClient.getRemoteSocketAddress());
                            avviaComunicazione(varClient);
                        } catch (IOException e) {
                            System.err.format("Errore di avvio della comunicazione: %s%n", e.getMessage());
                        }
                    });
                } catch (IOException e) {
                    System.err.format("Errore nella creazione di nuovi socket: %s%n", e.getMessage());
                }
            }
        } catch (IOException e) {
            System.err.format("Errore lato server: %s%n", e.getMessage());
        }
    }

    private static void avviaComunicazione(Socket varClient) {
        try (
                BufferedReader BR = new BufferedReader(new InputStreamReader(varClient.getInputStream(), "UTF-8"));
                PrintWriter PW = new PrintWriter(new OutputStreamWriter(varClient.getOutputStream(), "UTF-8"), true)
        ) {
            String stringaRicevuta = BR.readLine();
            int contaStringhe = 0;
            ArrayList<String> listaStringhe = new ArrayList<>();
            while (stringaRicevuta.equals(FINESEQUENZA) == false) {
                contaStringhe++;
                listaStringhe.add(stringaRicevuta);
                stringaRicevuta = BR.readLine();
            }
            PW.println(contaStringhe); // Segnalo al client il numero di stringhe che gli sto per inviare.
            for (String s : listaStringhe) {
                PW.println(s.toUpperCase());
            }
        } catch (IOException e) {
            System.err.format("Errore di I/O: %s%n", e.getMessage());
        }
    }
}