import java.io.*;
import java.net.*;

public class ServeurConnectionHandle {

    private Socket socket;
    private BufferedReader in;
    private PrintWriter out;
    
    public ServeurConnectionHandle(Socket s) {
	socket = s;
	try {
	    System.out.print("Création des flux ");
	    in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
	    out = new PrintWriter(socket.getOutputStream(),true);
	    System.out.println("[OK]");
	    try {
		boolean actif = true;
		String msg;
		String reponse;
		do {
		    System.out.println("Serveur en attente de message... ");
		    msg = in.readLine(); 
		    if(msg==null) {
			actif = false;
			System.out.println("Le client s'est déconnecté brutalement.");			
		    } else if(msg.equals("/quit")) {
			actif = false;
			System.out.println("Le client s'est déconnecté.");
			
		    } else {
			System.out.println("Réception du message: "+ msg);
			System.out.print("Envoi d'un accusé de réception ");
			reponse = msg.concat(" [OK]");
			out.println(reponse);
			System.out.println("[OK]");
		    }
		} while(actif) ;
	    } catch (IOException e){
		System.err.println("Erreur de flux lors de la communication avec le client.");		
	    }
	} catch(IOException e) {
	    System.err.println("Erreur lors de la création des flux.");
	}
    } //end ServeurConnectionHandle(Socket s)


} //end ServeurConnectionHandle Class