/*
    *  XNap - A P2P framework and client.
    *
    *  See the file AUTHORS for copyright information.
    *
    *  This program is free software; you can redistribute it and/or modify
    *  it under the terms of the GNU General Public License as published by
    *  the Free Software Foundation.
    *
   *  This program is distributed in the hope that it will be useful,
   *  but WITHOUT ANY WARRANTY; without even the implied warranty of
   *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
   *  GNU General Public License for more details.
   *
   *  You should have received a copy of the GNU General Public License
   *  along with this program; if not, write to the Free Software
   *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
   */
  
  package org.xnap.plugin.limewire;
  
  import java.text.NumberFormat;
  import java.util.ArrayList;
  
  import javax.swing.SwingUtilities;
  
  import org.xnap.XNap;
  import org.xnap.gui.table.AbstractColumnTableModel;
  import org.xnap.gui.table.Column;
  import org.xnap.gui.table.NumberCellRenderer;
  import org.xnap.gui.table.TimeCellRenderer;
  import org.xnap.gui.util.SwingSynchronizedTask;
  import org.xnap.util.Scheduler;
  import org.xnap.util.XNapTask;
  
  import com.limegroup.gnutella.ManagedConnection;
  
  /***
   * Table model for {@link ManagedConnection} objects.
   *
   * FIX: the connections that have been initialized before the gui
   * was visible are not displayed in the table
   */
  public class LimeWireConnectionTableModel extends AbstractColumnTableModel
  {
  
      //--- Constant(s) ---
      
      public static int UPDATE_INTERVAL = 1 * 1000;
  
      //--- Data field(s) ---
  
      private ArrayList data = new ArrayList();
      private XNapTask task;
  
      //--- Constructor(s) ---
  
      public LimeWireConnectionTableModel() 
      {
  		Column columns[] = new Column[] {
  			new Column("host", XNap.tr("Host"), String.class),
  			new Column("status", XNap.tr("Status"), String.class),
  			new Column("msgCount", XNap.tr("Messages (I/O)"), String.class),
  			new Column("dropped", XNap.tr("Dropped (I/O)"), String.class),
  			new Column("bandwidth", XNap.tr("Bandwidth (I/O)"), String.class),
  			new Column("connectionType", XNap.tr("Connection Type"), String.class),
  			new Column("hosts", XNap.tr("Hosts"), Long.class, new NumberCellRenderer()),
  			new Column("protocol", XNap.tr("Protocol"), String.class),
  			new Column("vendor", XNap.tr("Vendor"), String.class),
  			new Column("uptime", XNap.tr("Uptime"), Integer.class, 
  					   new TimeCellRenderer()),
  			new Column("compressed", XNap.tr("Compressed (I/O)"), 
  					   String.class),
  		};
  		addColumns(columns);
      }
  
      //--- Method(s) ---
  
  	public void add(final ManagedConnection c)
  	{
  		Runnable runner = new Runnable()
  			{
  				public void run()
  				{
  					data.add(c);
  					fireTableRowsInserted(data.size() - 1, data.size() - 1);
  				}
  			};
  		SwingUtilities.invokeLater(runner);
  	}
  
  	/***
  	 * @param c
  	 */
  	public void update(ManagedConnection c) 
  	{
  	}
  
 	/***
 	 * @param c
 	 */
 	public void remove(final ManagedConnection c) 
 	{
 		Runnable runner = new Runnable()
 			{
 				public void run()
 				{
 					int i = data.indexOf(c);
 					if (i != -1) {
 						data.remove(i);
 						fireTableRowsDeleted(i, i);
 					}
 				}
 			};
 		SwingUtilities.invokeLater(runner);
 	}
 
     public int getRowCount() 
     {
         return data.size();
     }
 
     public Object get(int i, int j) 
     {
 		ManagedConnection c = (ManagedConnection)data.get(i);
 		StringBuffer sb = new StringBuffer();
 		
         switch (j) {
 		case 0:
 			return (c.isInitialized())
 				? c.getAddress() + ":"  + c.getSocket().getPort() 
 				: c.getAddress();
 		case 1:
 			return c.isOutgoing() ? XNap.tr("Outgoing") : XNap.tr("Incoming");
 		case 2:
 			sb.append(c.getNumMessagesReceived());
 			sb.append(" / ");
 			sb.append(c.getNumMessagesSent());
 			return sb.toString();
 		case 3:
 			sb.append(c.getNumReceivedMessagesDropped());
 			sb.append(" / ");
 			sb.append(c.getNumSentMessagesDropped());
 			return sb.toString();
 		case 4:
 			NumberFormat n = NumberFormat.getNumberInstance();
 			n.setMinimumFractionDigits(3);
 			n.setMaximumFractionDigits(3);
 			sb.append(n.format(c.getMeasuredDownstreamBandwidth()));
 			sb.append(" / ");
 			sb.append(n.format(c.getMeasuredUpstreamBandwidth()));
 			sb.append(" KB/s");
 			return sb.toString();
 		case 5:
 			return (c.isClientSupernodeConnection() 
 					|| c.isSupernodeSupernodeConnection())
 				? XNap.tr("Supernode")
 				: c.isSupernodeClientConnection()
 				? XNap.tr("Leaf")
 				: XNap.tr("Servant");
 		case 6: 
  			return (c.isClientSupernodeConnection() 
 					|| c.isSupernodeSupernodeConnection())
 				? new Long(c.getNumIntraUltrapeerConnections())
 				: new Long(-1);
 		case 7:
 			return c.getVersion();
 		case 8:
 			return c.getUserAgent();
 		case 9:
 			int length = (int)((System.currentTimeMillis() 
 								- c.getConnectionTime()) / 1000);
 			return new Integer(length);
 		default:
 			return null;
         }
     }
 
 	public String getIO(long in, long out)
 	{
 		StringBuffer sb = new StringBuffer();
 		sb.append(in);
 		sb.append(" / ");
 		sb.append(out);
 		return sb.toString();
 	}
 
     public void setConnected(boolean connected)
     {
 		if (task != null) {
 			task.cancel();
 			task = null;
 		}
 
 		if (connected) {
 			task = new Updater();
 			Scheduler.run(0, UPDATE_INTERVAL, task);
 		}
     }
 
     //--- Inner Class(es) ---
 
     private class Updater extends SwingSynchronizedTask
     {
 	
 		public void runSynchronized()
 		{
 			fireTableRowsUpdated(0, data.size() - 1);
 		}
 
     }
 
 }