import java.io.BufferedReader;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.util.ArrayList;

import com.ptibiscuit.coffeemachine.CoffeeMachine;

public class Controleur extends Thread
{

    int m_port;
    String message = "+";
    String ligne;
    String m_fichier;
    ArrayList<String> al = new ArrayList<String>();

    public Controleur(int port, String fichier)
    {
        m_port = port;
        m_fichier = fichier;
    }

    public void run()
    {
        CoffeeMachine cofmach = new CoffeeMachine(m_port);
        cofmach.addConnectionListener(new ConnectionManager());
        cofmach.addDeconnectionListener(new ConnectionManager());
        cofmach.addMessageListener(new ConnectionManager());
        System.out.println("Serveur PluginLoumea - Version 1b");
        System.out.println("--------------------");
        System.out.println("Ecoute sur le port " + m_port + "...");

        try
        {
            cofmach.start();
        }
        catch (IOException e)
        {
            e.printStackTrace();
        }

        this.ReadFile();

    }

    public void ReadFile()
    {
        try
        {
            InputStream is = new FileInputStream(m_fichier);
            InputStreamReader isr = new InputStreamReader(is);
            BufferedReader in = new BufferedReader(isr);

            while ((ligne = in.readLine()) != null)
            {
                al.add(ligne);
            }


            for(int i = 0; i < al.size(); i++)
            {
                message += al.get(i) + " ";
            }

            message.trim();

        }
        catch(Exception e)
        {
            e.printStackTrace();
        }

    }
}