/*
    *  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.freeway;
  
  import java.util.ArrayList;
  
  import org.apache.log4j.Logger;
  import org.gnu.freeway.DaemonSocket;
  import org.gnu.freeway.protocol.afs.esed2.AFSUtils;
  import org.gnu.freeway.protocol.afs.esed2.RootNode;
  import org.gnu.freeway.protocol.afs.esed2.SearchResultCallback;
  import org.gnu.freeway.protocol.afs.esed2.SendQueriesContext;
  import org.gnu.freeway.protocol.afs.esed2.TestTerminateThread;
  import org.gnu.freeway.protocol.afs.swing.SController;
  import org.gnu.freeway.util.AbstractAction;
  import org.gnu.freeway.util.ConfigurationService;
  import org.gnu.freeway.util.CronService;
  import org.gnu.freeway.util.StateService;
  import org.gnu.freeway.util.Task;
  import org.gnu.freeway.util.crypto.HashCode160;
  import org.xnap.XNap;
  import org.xnap.search.AbstractSearch;
  import org.xnap.search.SearchFilter;
  import org.xnap.search.SearchHandler;
  
  /***
   * 
   */
  public class FreewaySearch extends AbstractSearch 
  	implements SearchResultCallback, TestTerminateThread
  {
  
  	private SearchHandler handler;
  	private SController controller;
  	private boolean done = false;
  	
  	private DaemonSocket socket = null;
  	private SendJob sendJob = null;
  	
  	private static Logger logger = Logger.getLogger(FreewaySearch.class);
  
  	/***
  	 * @param filter
  	 */
  	public FreewaySearch(SearchFilter filter, SController controller) 
  	{
  		super(filter);
  		this.controller = controller;
  	}
  
  	/*
  	 * @see org.xnap.search.Search#getStatus()
  	 */
  	public String getStatus() 
  	{
  		if (done) {
  			return XNap.tr("Done");
  		}
  		else {
  			return XNap.tr("Running");
  		}
  	}
  
  	/*
  	 * @see org.xnap.search.Search#isDone()
  	 */
  	public boolean isDone() 
  	{
  		return done;
  	}
  
  	/*
  	 * @see org.xnap.search.Search#start(org.xnap.search.SearchHandler)
  	 */
  	public void start(SearchHandler handler) 
  	{
  		this.handler = handler;
  		done = false;
  		socket = DaemonSocket.create
  		((ConfigurationService)controller.service(ConfigurationService.class),
  		  controller.getPreferences());
  		if (socket == null) {
  			done = true;
 		}
 		else {
 			startSearch();
 		}
 	}
 
 	/***
 	 * 
 	 */
 	private void startSearch() 
 	{
 		HashCode160[]	keys;
 		final SendQueriesContext	sqc;
 		Task	receiveThread;
 		String[] keywords;
 		ArrayList list = new ArrayList();
 		int i;
 		final CronService cron = (CronService)controller.service(CronService.class);
 		
 		String[] p = getFilter().getText().split("//s+");
 		
 		for (i=0; i<p.length; i++) {
 			if (p[i].length()>0) {
 				list.add(p[i]);
 			}
 		}
 
 		if (list.size() == 0) {
 			System.out.println("no keywords left");			
 		}
 
 		keywords = (String[]) list.toArray(new String[list.size()]);
 		
 		keys = AFSUtils.parseKeywords(keywords);
 		if (keys.length==0) {
 			done = true;
 			return;
 		}	
 		
 		sqc = new SendQueriesContext(keys, socket);
 		sqc.setTimeOut(0x00FFFFFF);	// "forever" is 6 months...
 		
 		sendJob = new SendJob(cron, sqc);
 		cron.addJob(sendJob, 0, 0);
 		
 		Task receiver = new Task("GNUNet SearchResult Receiver", new ReceiveJob(sqc));
 		receiver.launch();
 	}
 
 	/*
 	 * @see org.xnap.search.Search#stop()
 	 */
 	public void stop() 
 	{
 		done = true;
 		//  socket.closeTemporarily();
 		((CronService) controller.service(CronService.class)).deleteJob(sendJob, 0);
 		socket.destroy(); 
 	}
 	
 	private class SendJob extends AbstractAction
 	{
 		CronService cron;
 		SendQueriesContext sqc;
 	
 		public SendJob(CronService cron, SendQueriesContext sqc)
 		{
 			this.cron = cron;
 			this.sqc = sqc;
 		}
 	
 		public void perform() throws Throwable 
 		{
 			logger.debug("sending query again");
 			sqc.repeatedlySend(cron, controller.getPolicy());		
 		}
 	}
 	
 	private class ReceiveJob extends AbstractAction
 	{
 		SendQueriesContext sqc;
 		
 		ReceiveJob(SendQueriesContext sqc)
 		{
 			this.sqc = sqc;
 		}
 		
 		public void perform()
 		{
 			logger.debug("Receiving...");
 			sqc.receive((ConfigurationService) controller.service(ConfigurationService.class),
 							(StateService) controller.service(StateService.class),
 							FreewaySearch.this, FreewaySearch.this);
 			FreewaySearch.this.stop();
 		}
 	}
 
 	/*
 	 * @see org.gnu.freeway.protocol.afs.esed2.SearchResultCallback#searchResult(org.gnu.freeway.protocol.afs.esed2.RootNode)
 	 */
 	public void searchResult(RootNode node) 
 	{
 		handler.resultReceived(new FreewaySearchResult(node));		
 	}
 
 	/*
 	 * @see org.gnu.freeway.protocol.afs.esed2.SearchResultCallback#newNameFor(org.gnu.freeway.protocol.afs.esed2.RootNode, java.lang.String)
 	 */
 	public void newNameFor(RootNode arg0, String arg1) 
 	{
 		// TODO Auto-generated method stub
 	}
 
 	/*
 	 * @see org.gnu.freeway.protocol.afs.esed2.TestTerminateThread#test()
 	 */
 	public boolean test()
 	{
 		return done;
 	}
 }