/*
    *  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 javax.swing.Action;
  import javax.swing.Icon;
  
  import java.awt.event.ActionEvent;
  import java.io.File;
  
  import com.limegroup.gnutella.Downloader;
  import com.limegroup.gnutella.Endpoint;
  import com.limegroup.gnutella.InsufficientDataException;
  import com.limegroup.gnutella.RemoteFileDesc;
  import com.limegroup.gnutella.RouterService;
  import com.limegroup.gnutella.downloader.AlreadyDownloadingException;
  
  import org.xnap.XNap;
  import org.xnap.gui.StatusBar;
  import org.xnap.peer.Peer;
  import org.xnap.peer.action.AbstractBrowseAction;
  import org.xnap.peer.action.AbstractChatAction;
  import org.xnap.plugin.Plugin;
  import org.xnap.transfer.AbstractDownload;
  import org.xnap.transfer.action.AbstractDeleteAction;
  import org.xnap.transfer.action.AbstractResumeAction;
  
  /***
   * Downloads a file.
   */
  public class LimeWireDownload extends AbstractDownload {
  
      //--- Constant(s) ---
  
       //--- Data field(s) ---
  
      private Downloader download;
  
      //--- Constructor(s) ---
      
      public LimeWireDownload(Downloader download) 
      {
  		this.download = download;
      }
  
      //--- Method(s) ---
  
      public long getBytesTransferred() 
      {
  		return download.getAmountRead();
      }
  
      public Action[] getActions()
      {
  		return new Action[] {
  			new ResumeAction(), new DeleteAction(),
  			new BrowseAction(), new ChatAction(),
  		};
      }
  
      public File getFile()
      {
  		return download.getDownloadFragment();
      }
  
      public String getFilename()
      {
  		return download.getFileName();
      }
  
      public long getFilesize()
      {
  		return download.getContentLength();
      }
  
      public Peer getPeer()
      {
  		String host = download.getAddress();
  		return (host != null) ? new LimeWireServant(host) : null;
      }
  
      public Plugin getPlugin()
     {
 		return LimeWirePlugin.getInstance();
     }
 
     public String getStatus()
     {
 		switch (download.getState()) {
 		case Downloader.QUEUED:
 			return XNap.tr("Queued");
 		case Downloader.CONNECTING:
 			return XNap.tr("Connecting");
 		case Downloader.DOWNLOADING:
 			return XNap.tr("Downloading from {0} locations", 
 						   new Integer(download.getNumberOfAlternateLocations()));
 		case Downloader.WAITING_FOR_RETRY:
 			return XNap.tr("Waiting for retry");
 		case Downloader.COMPLETE:
 			return XNap.tr("Complete");
 		case Downloader.ABORTED:
 			return XNap.tr("Aborted");
 		case Downloader.GAVE_UP:
 			return XNap.tr("Gave up");
 		case Downloader.COULDNT_MOVE_TO_LIBRARY:
 			return XNap.tr("Could not move file to library");
 		case Downloader.WAITING_FOR_RESULTS:
 			return XNap.tr("Waiting for results");
 		case Downloader.CORRUPT_FILE:
 			return XNap.tr("Corrupted file");
 		case Downloader.REMOTE_QUEUED:
 			return XNap.tr("Remotely queued");
 		case Downloader.HASHING:
 			return XNap.tr("Hashing file");
 		case Downloader.SAVING:
 			return XNap.tr("Saveing file");
 		case Downloader.WAITING_FOR_USER:
 			return XNap.tr("Waiting for user");
 		case Downloader.WAITING_FOR_CONNECTIONS:
 			return XNap.tr("Waiting for connections");
 		default:
 			return XNap.tr("State {0}", new Integer(download.getState()));
 		}
     }
 
     public long getTotalBytesTransferred()
     {
 		return getBytesTransferred();
     }
 
     public boolean isDone()
     {
 		int s = download.getState();
 		return s == Downloader.COMPLETE || s == Downloader.ABORTED 
 			|| s == Downloader.COULDNT_MOVE_TO_LIBRARY;
     }
 
     public boolean isRunning()
     {
 		int s = download.getState();
 		return s == Downloader.DOWNLOADING; 
     }
 
 	/***
 	 *  @see xnap.transfer.Transfer#getAverageRate()
 	 */
 	public long getAverageRate() 
 	{
 		return (long)(download.getAverageBandwidth() * 1024);
 	}
 
 	/***
 	 *  @see xnap.transfer.Transfer#getCurrentRate()
 	 */
 	public long getCurrentRate() {
 		download.measureBandwidth();
 		try {
 			return (long)(download.getMeasuredBandwidth() * 1024);
 		}
 		catch (InsufficientDataException e) {
 			return -1;
 		}
 	}
 
 	/***
 	 *  @see xnap.transfer.Transfer#getIcon()
 	 */
 	public Icon getIcon() 
 	{
 		return LimeWirePlugin.ICON_16;
 	}
 
 	/***
 	 *  @see xnap.transfer.Transfer#getQueuePosition()
 	 */
 	public int getQueuePosition() 
 	{
 		String pos = download.getQueuePosition();
 		if (pos != null) {
 			try {
 				return Integer.parseInt(pos);
 			}
 			catch (NumberFormatException e) {
 			}
 		}
 		return -1;
 	}
 
 	/***
 	 *  @see xnap.transfer.Transfer#getRemainingTime()
 	 */
 	public int getRemainingTime() 
 	{
 		int time = download.getRemainingStateTime();
 		return (time == Integer.MAX_VALUE) ? -1 : time;
 	}
 
 	//--- Inner Class(es) ---
 
 	public class BrowseAction extends AbstractBrowseAction 
 	{
 		public BrowseAction()
 		{
 			setEnabled(download.hasBrowseEnabledHost());
 		}
 		
 		public void actionPerformed(ActionEvent event)
 		{
 			RemoteFileDesc desc = download.getBrowseEnabledHost();
 			if (desc != null) {
 				LimeWirePlugin.getSearchManager().browse(desc);
 			}										
 		}
 	}
 
 	public class ChatAction extends AbstractChatAction 
 	{
 		public ChatAction()
 		{
 			setEnabled(download.hasChatEnabledHost());
 		}
 		
 		public void actionPerformed(ActionEvent event)
 		{
 			Endpoint host = download.getChatEnabledHost();
 			RouterService.createChat(host.getAddress(), host.getPort());
 		}
 	}
 
 	public class ResumeAction extends AbstractResumeAction 
 	{
 		public void actionPerformed(ActionEvent event)
 		{
 			try {
 				download.resume();
 			}
 			catch (AlreadyDownloadingException e) {
 				StatusBar.setText(XNap.tr("Already downloading file!"));
 			}
 		}
 	}
 
 	public class DeleteAction extends AbstractDeleteAction 
 	{
 		public void actionPerformed(ActionEvent event)
 		{
 			download.stop();
 		}
 	}
 
 }