import java.io.*;
import java.net.*;
import java.util.*;
import java.awt.*;
import java.awt.event.*;

class Connexion extends Thread {

    protected Socket client;
    protected Serveur serveur;
    protected Nettoyeur nettoyeur;
    protected BufferedReader in;  // jdk 1.2
    protected PrintStream out;
    
    // pour attribuer un identificateur unique
    private static int numero = 0;
    private int ident;
    // des informations sur le client obtenu par le "terrain"
    private char equipe;
    private PointDuTerrain pos;

    public Connexion(Socket clientSocket, 
		     Nettoyeur n,
		     Serveur s) {
	client = clientSocket;
	nettoyeur = n;
	serveur = s;
	ident = numero;
	numero++;
	// le terrain donne des renseignements.
	equipe = serveur.terrain.equipe(ident);
	pos = serveur.terrain.centre();
	try {
	    in=new BufferedReader(new 
				  InputStreamReader(client.getInputStream()));
	    out=new PrintStream(client.getOutputStream());
	}
	catch(IOException e) {
	    try {
		client.close();
	    }
	    catch(IOException el) {}
	    System.err.println(e.getMessage());
	    return;
	}
    }
    
    public String toString(String motClef){
	return motClef +
	    " " + String.valueOf(ident)+
	    " " + equipe+ 
	    " " + pos.toString();
    }

    public void run() {
	String ligne;
	int coup;
	Connexion c;

	try {
	    synchronized(serveur.connexions) {
		for (int i = 0; i<serveur.connexions.size();i++) {
		    c = (Connexion) serveur.connexions.elementAt(i);
		    if (c.isAlive())
			c.out.println(toString("Joueur"));
		}
	    }
	    while (true) {
		//ligne = in.readLine();
		coup = in.read();
		// il faut se prémunir d'une propre déconnexion brutale.
		if ((coup == -1)||(coup == KeyEvent.VK_END))
		    break;
		ligne = toString("Bouge");
		if (pos.newPosition(serveur.terrain,coup)) {
		    ligne = ligne + " " + pos.toString();
		    synchronized(serveur.connexions) {
			for (int i = 0; i<serveur.connexions.size();i++) {
			    c = (Connexion)serveur.connexions.elementAt(i);
				// et des autres également.
			    if (c.isAlive())
				c.out.println(ligne);
			}
		    }
		}
	    }
	}
	catch(IOException e) {
	}
	finally {
	    try {
		synchronized(serveur.connexions) {
		    for (int i = 0; i<serveur.connexions.size();i++) {
			c = (Connexion) serveur.connexions.elementAt(i);
			if (c.isAlive())
			    c.out.println(toString("Arret"));
		    }
		}
		client.close();
	    }
	    catch(IOException e) {}
	    finally {
		synchronized(serveur.connexions) {
		    System.out.print("Fin de connexion...");
		    serveur.connexions.notify();
		}
	    }
	}
    }
}