MainWindow.java

package clavardage;

import java.awt.*;
import java.awt.event.WindowListener;
import java.awt.event.WindowAdapter;
import java.awt.event.WindowEvent;
import java.awt.event.ActionEvent;
import java.awt.event.KeyAdapter;
import java.awt.event.KeyEvent;
import java.awt.event.ActionListener;
import java.lang.Thread;
import java.util.Set;

import javax.swing.JButton;
import javax.swing.JLabel;
import javax.swing.JPanel;
import javax.swing.JScrollPane;

import java.util.Iterator;
import java.net.InetAddress;
import java.util.ArrayList;

import java.util.Timer;
import java.util.TimerTask;

@SuppressWarnings("serial")
public class MainWindow extends Frame {

   public class onlineUpdater extends TimerTask {
      JPanel aP;
      OnlineUsersManager networkDiscovery;
      ConversationManager CM;

      public onlineUpdater(JPanel p, OnlineUsersManager nD,
            ConversationManager c) {
         this.aP = p;
         this.networkDiscovery = nD;
         this.CM = c;
      }

      public void run() {
            Set<String> usersSet = networkDiscovery.getOnlineUsers();
			//System.out.println("updating pseudos...");
            if (usersSet != null) { // Test if we have modifications to be done
               aP.removeAll();
               Iterator<String> it = usersSet.iterator();
               JLabel jl = new JLabel("-------- Currently Online Users : --------");
			   jl.setHorizontalAlignment(JLabel.CENTER);
               aP.add(jl);
               synchronized (usersSet) {
                  while (it.hasNext()) {
                     String aUser = it.next();
                     //System.out.println("test " + aUser);
                     JLabel jll = new JLabel(aUser);
					 jll.setHorizontalAlignment(JLabel.CENTER);
                     aP.add(jll);
                  }
               }
               CM.updatePseudos();
			   aP.updateUI();
         }
      }
   }

   private static JLabel lblInput;
   private Dialog login;
   private static String currentUserName;
   private static JPanel panelOnline;
   private static Label lblPseudoError;
   private static OnlineUsersManager networkDiscovery;
   private static TextField txtNewPseudo;
   private static TextField openConvWith;
   private static ConversationManager CM;
   private static boolean udpBased;
   private String sAddress;
   private String sPort;
   private static boolean bddBased;

   class DisplayHistory implements Runnable {
      public void setList(ArrayList<String> l) {
         new HistoryDisplayWindow(l);
      }

      public void run() {

      }
   }

   class MyButtonHistListener implements ActionListener {
      public void actionPerformed(ActionEvent e) {
         System.out.println("Creating an history display window");
         DisplayHistory d = new DisplayHistory();
         d.setList((new HistoryManager()).listAllHist());
         Thread thrD = new Thread(d);
         thrD.start();
      }
   }

   class MyButtonChatListener implements ActionListener {
      public void actionPerformed(ActionEvent e) {
         String distantUser = openConvWith.getText();
         openConvWith.setText("");
         if (distantUser.equals("")) {
            lblPseudoError.setText("Error : Empty field");
         } else if (distantUser.equals(currentUserName)) {
            lblPseudoError
                  .setText("Error : " + distantUser + " is your own pseudo");
         } else if (!networkDiscovery.isOnline(distantUser)) {
            lblPseudoError.setText("Error : " + distantUser + " is not online");
         } else {
            InetAddress hostAddress = networkDiscovery.getAddress(distantUser);
            System.out.println("Beginning communication with " + distantUser
                  + " at @" + hostAddress);
            int code = CM.createConversation(hostAddress, 8042);
			if(code == 1) { lblPseudoError.setText("Conversation déjà créée"); }
         }
      }
   }

   public class MyButtonChangePseudo implements ActionListener {
      public void actionPerformed(ActionEvent e) {
         if (!txtNewPseudo.getText().equals("")) {
            String newPse = txtNewPseudo.getText();
            int returnCode = networkDiscovery.notifyNewPseudo(newPse);
            txtNewPseudo.setText("");
            if (returnCode == -1) {
               lblPseudoError
                     .setText("Error : this pseudo is already used by a user");
            } else if (returnCode == -2) {
               lblPseudoError.setText("Error : this is already your pseudo");
            } else if (returnCode == 0) {
               lblPseudoError.setText("Pseudo change OK");
               currentUserName = newPse;
               lblInput.setText("Welcome " + currentUserName
                     + " in myChatroom. You can now start messaging online users");
            } else {
               lblPseudoError.setText("Error : unexpected return Code");
            }
         } else {
            lblPseudoError.setText("Error : empty text field");
         }
      }
   }

   public class MyButtonExitListener implements ActionListener {
      public void actionPerformed(ActionEvent e) {
         // Fermeture de la découverte réseau
         synchronized (networkDiscovery) {
            networkDiscovery.notifyOffline();
            networkDiscovery.closeCommunications();
         }
         /*
          * synchronized(CM) { CM.closeCM(); }
          */
         login.dispose();
         System.exit(0);
      }
   }

	WindowListener exitListener = new WindowAdapter() {

    @Override
    public void windowClosing(WindowEvent e) {
          // Fermeture de la découverte réseau
         synchronized (networkDiscovery) {
            networkDiscovery.notifyOffline();
            networkDiscovery.closeCommunications();
         }
         /*
          * synchronized(CM) { CM.closeCM(); }
          */
         login.dispose();
         System.exit(0);
    }
};

   public MainWindow(String userName, boolean isUDPBased, String serverAddress, String serverPort, boolean isBDDBased) {
      // Création de la fenêtre graphique
	  super("Chat Room");
      //this.setTitle("Chat Room");
      bddBased = isBDDBased;
      udpBased = isUDPBased;
      sAddress = serverAddress;
      sPort = serverPort;
      currentUserName = userName;
      login = new Dialog(this);
      lblInput = new JLabel(
            "Welcome " + currentUserName
                  + " in myChatroom. You can now start messaging online users",
            JLabel.CENTER); // Construct by invoking a constructor via the new
                           // operator
      panelOnline = new JPanel(new GridLayout(0, 1));
      JScrollPane sB = new JScrollPane(panelOnline);
      lblPseudoError = new Label("");
      login.setLayout(new GridLayout(0, 1));
      JButton chat = new JButton("Send a message to :");
      openConvWith = new TextField();
      txtNewPseudo = new TextField();
	  openConvWith.addKeyListener(new KeyAdapter() {
        @Override
        public void keyPressed(KeyEvent e) {
		        if(e.getKeyCode() == KeyEvent.VK_ENTER){
		              String distantUser = openConvWith.getText();
         openConvWith.setText("");
         if (distantUser.equals("")) {
            lblPseudoError.setText("Error : Empty field");
         } else if (distantUser.equals(currentUserName)) {
            lblPseudoError
                  .setText("Error : " + distantUser + " is your own pseudo");
         } else if (!networkDiscovery.isOnline(distantUser)) {
            lblPseudoError.setText("Error : " + distantUser + " is not online");
         } else {
            InetAddress hostAddress = networkDiscovery.getAddress(distantUser);
            System.out.println("Beginning communication with " + distantUser
                  + " at @" + hostAddress);
            int code = CM.createConversation(hostAddress, 8042);
			if(code == 1) { lblPseudoError.setText("Conversation déjà créée"); }
         }
		        }
		    }
      });
	  txtNewPseudo.addKeyListener(new KeyAdapter() {
        @Override
        public void keyPressed(KeyEvent e) {
		            if(e.getKeyCode() == KeyEvent.VK_ENTER){
						 if (!txtNewPseudo.getText().equals("")) {
            String newPse = txtNewPseudo.getText();
            int returnCode = networkDiscovery.notifyNewPseudo(newPse);
            txtNewPseudo.setText("");
            if (returnCode == -1) {
               lblPseudoError
                     .setText("Error : this pseudo is already used by a user");
            } else if (returnCode == -2) {
               lblPseudoError.setText("Error : this is already your pseudo");
            } else if (returnCode == 0) {
               lblPseudoError.setText("Pseudo change OK");
               currentUserName = newPse;
               lblInput.setText("Welcome " + currentUserName
                     + " in myChatroom. You can now start messaging online users");
            } else {
               lblPseudoError.setText("Error : unexpected return Code");
            }
         } else {
            lblPseudoError.setText("Error : empty text field");
         }
					}
		       
		    }
      });
      JButton changePseudo = new JButton("Set new pseudo :");
      changePseudo.addActionListener(new MyButtonChangePseudo());
      chat.addActionListener(new MyButtonChatListener());
      JButton exit = new JButton("Quit");
      exit.addActionListener(new MyButtonExitListener());
      JButton displayHist = new JButton("Display all available histories");
      displayHist.addActionListener(new MyButtonHistListener());
      login.setSize(850, 550);
      login.add(lblInput);
      login.add(sB);
      login.add(chat);
      login.add(openConvWith);
      login.add(exit);
      login.add(changePseudo);
      login.add(txtNewPseudo);
      login.add(lblPseudoError);
      login.add(displayHist);
      if(udpBased) {
	login.add(new JLabel("UDP-Based network discovery mode"));
      }
      else {
	login.add(new JLabel("presence Server discovery mode"));
      }
      if(bddBased) {
	login.add(new JLabel("Histories save mode : Database"));
      }
      else {
	login.add(new JLabel("Histories save mode : File System"));
      }
      login.setVisible(true);
	  login.addWindowListener(exitListener);

      // Lancement de la découverte Réseau
      // On passe au OnlineUsersManager l'information sur le fonctionnement en UDP ou via un serveur de présence HTTP
		HistoryManager.BDD= bddBased;// mode historique
      networkDiscovery = new OnlineUsersManager(userName, udpBased, sAddress, sPort);
      Thread networkDiscoveryThread = new Thread(networkDiscovery);
      networkDiscoveryThread.start();

      // Création du gestionnaire d'historique

      HistoryManager HM = new HistoryManager();
      Thread historyManagerThread = new Thread(HM);
      historyManagerThread.start();

      // Lancement du service de Messagerie
      CM = new ConversationManager();
      CM.setDiscovery(networkDiscovery);
      CM.setHistoryM(HM);
      Thread t = new Thread(CM);
      t.start();

      // Lancement du thread de màj des pseudos
	   Timer timer = new Timer();
	if(udpBased) {
		timer.scheduleAtFixedRate(new onlineUpdater(panelOnline,
		    networkDiscovery, CM),
		           0,   //initial delay
		           500);  //subsequent rate
	} else { // We reduce the update rate if we use a presence server in order not to overload it with requests
		timer.scheduleAtFixedRate(new onlineUpdater(panelOnline,
		    networkDiscovery, CM),
		           0,   //initial delay
		           1000);  //subsequent rate
	}

   }
}