package org.votech.plastic.managers;
   
   
   import java.util.Timer;
   import java.util.TimerTask;
   
   import org.apache.commons.logging.Log;
   import org.apache.commons.logging.LogFactory;
   import org.astrogrid.acr.ACRException;
  import org.astrogrid.acr.Finder;
  import org.astrogrid.acr.InvalidArgumentException;
  import org.astrogrid.acr.NotFoundException;
  import org.astrogrid.acr.builtin.ACR;
  import org.astrogrid.acr.builtin.Shutdown;
  import org.astrogrid.acr.builtin.ShutdownListener;
  import org.astrogrid.acr.system.WebServer;
  
  /**
   * @author jdt
   * 
   */
  public class AcrManagerImpl extends AbstractObservableManager implements	ShutdownListener, AcrManager {
  
  
  	public static class ObserverAdaptor implements ManagerObserver {
  
  		private AcrObserver observer;
  
  		public ObserverAdaptor(AcrObserver observer) {
  			this.observer = observer;
  		}
  
  		public void down() {
  			observer.acrDown();
  		}
  
  		public void up() {
  			observer.acrUp();
  		}
  
  	}
  
  
  	/**
  	 * Logger for this class
  	 */
  	private static final Log logger = LogFactory.getLog(AcrManagerImpl.class);
  
  	public interface AcrObserver {
  		public void acrUp();
  		public void acrDown();
  	}
  	
  
  	private int autoReconnect;
  
  
  
  	private String name;
  
  	private boolean startIfNotRunning;
  
  	/**
  	 * 
  	 * @param connectOnCreation
  	 * @param autoReconnectTimeMillis
  	 * @param parent
  	 *            the gui frame that is the parent of any dialogs.
  	 */
  	public AcrManagerImpl(boolean connectOnCreation, int autoReconnectTimeMillis,
  			String name) {
  		this.autoReconnect = autoReconnectTimeMillis;
  		this.name = name;
  		if (connectOnCreation) {
  			connect();
  		}
  	}
  
  	public AcrManagerImpl(boolean connectOnCreation, int autoReconnectTimeMillis) {
  		this(connectOnCreation, autoReconnectTimeMillis,  "");
  	}
  
  	/**
  	 * @param args
  	 * @throws ACRException
  	 * @throws NotFoundException
  	 * @throws InvalidArgumentException
  	 */
  	public static void main(String[] args) throws InvalidArgumentException,
  			NotFoundException, ACRException {
  		AcrManagerImpl manager = new AcrManagerImpl(false, 3000,
  				"AcrManager Test");
  
  		manager.addObserver(new ObserverAdaptor(new AcrObserver() {
  
  			public void acrUp() {
  				System.out.println("Acr is up");
  			}
  			public void acrDown() {
 				System.out.println("Acr is down");
 			}
 
 		}));
 
 		manager.connect();
 		ACR acr = manager.getAcr();
 		WebServer server = (WebServer) acr.getService(WebServer.class);
 		System.out.println(server.getUrlRoot());
 
 		manager.disconnect();
 		manager.connect();
 		//try something impossible
 	//	Registry reg = (Registry) acr.getService(Registry.class);
 	//	System.out.println(reg.resolveIdentifier(URI.create("ivo://dummy")));
 		
 		System.exit(0);
 	}
 
 	
 	/* (non-Javadoc)
      * @see org.votech.plastic.managers.AcrManager#getAcr()
      */
 	public ACR getAcr() {
 		return acr;
 	}
 
     /* (non-Javadoc)
      * @see org.votech.plastic.managers.AcrManager#connect()
      */
 	public void connect() {
 		connect(true);
 	}
 	/* (non-Javadoc)
 	 * @see org.votech.plastic.managers.Manager1#connect()
 	 */
 	/* (non-Javadoc)
      * @see org.votech.plastic.managers.AcrManager#connect(boolean)
      */
 	public void connect(boolean startIfNotRunning) {
 		logger.debug("Connecting to ACR...");
 		this.startIfNotRunning = startIfNotRunning;
 		if (isConnected()) {
 			logger.debug("...already connected.");
 			return;
 		}
 		logger.debug("Using finder");
 		Finder finder = new Finder();
 		try {
 			acr = finder.find(startIfNotRunning,true);
 		} catch (ACRException e1) {
 			logger.error("ACR failed to start - setting up retry");
 			setupRetry();
 			return;
 		}
 
 		try {
 			Shutdown shutdown = (Shutdown) acr.getService(Shutdown.class);
 			shutdown.addShutdownListener(this);
 		} catch (ACRException e) {
 			logger.error("Unable to register shutdown listener ", e);
 		}
 
 		
 		notifyObserversUp();
 		return;
 	}
     
     /* (non-Javadoc)
      * @see org.votech.plastic.managers.AcrManager#connectWhenReady()
      */
     public void connectWhenReady() {
         connect(false);
     }
 
 	private ACR acr;
 
 	/* (non-Javadoc)
 	 * @see org.votech.plastic.managers.Manager1#isConnected()
 	 */
 	/* (non-Javadoc)
      * @see org.votech.plastic.managers.AcrManager#isConnected()
      */
 	public boolean isConnected() {
 		return acr != null;
 	}
 
 	Timer timer = new Timer();
 
 	/* (non-Javadoc)
 	 * @see org.votech.plastic.managers.Manager1#disconnect()
 	 */
 	/* (non-Javadoc)
      * @see org.votech.plastic.managers.AcrManager#disconnect()
      */
 	public void disconnect() {
 		disconnect(-1);
 	}
 
 	/* (non-Javadoc)
 	 * @see org.votech.plastic.managers.Manager1#disconnect(int)
 	 */
 	/* (non-Javadoc)
      * @see org.votech.plastic.managers.AcrManager#disconnect(int)
      */
 	public void disconnect(int newReconnectTime) {
 		if (!isConnected())
 			return;// don't want to bother people a second time
 		this.autoReconnect = newReconnectTime;
 		/*
 		 * TODO talk to Noel about why this doesn't work try {
 		 * logger.debug("Deregistering shutdown listener"); Shutdown shutdown =
 		 * (Shutdown) acr.getService(Shutdown.class);
 		 * //shutdown.removeShutdownListener(this);
 		 * logger.debug("Deregistered"); } catch (ACRException e) {
 		 * logger.error("Unable to deregister shutdown listener ",e); }
 		 */
 		acr = null;
 		
 		notifyObserversDown();
 		if (autoReconnect >= 0) {
 			setupRetry();
 		}
 	}
 
 	private void setupRetry() {
 		logger.info("Attempting to reconnect in " + autoReconnect
 				+ " millis");
 		timer.schedule(new TimerTask() {
 			public void run() {
 				logger.debug("Attempt reconnection");
 				connect(startIfNotRunning);
 				if (isConnected()) notifyObserversUp();
 			}
 		}, autoReconnect);
 	}
 /*//put this idea on hold for now - problems seem to come from the service instance
  * rather than the acr itself, so difficult to trap
 	private class WrappedAcr implements ACR {
 
 		private ACR acr;
 
 		public WrappedAcr(ACR acr) {
 			this.acr = acr;
 		}
 
 		// Idea is that this will cause the manager to disconnect
 		public Object getService(Class arg0) throws ACRException,
 				InvalidArgumentException, NotFoundException {
 			Object obj;
 			try {
 				obj = acr.getService(arg0);
 			} catch (InvalidArgumentException e) {
 				// TODO Auto-generated catch block
 				e.printStackTrace();
 				throw e;
 			} catch (NotFoundException e) {
 				// TODO Auto-generated catch block
 				e.printStackTrace();
 				throw e;
 			} catch (ACRException e) {
 				// TODO Auto-generated catch block
 				e.printStackTrace();
 				throw e;
 			}
 			return obj;
 		}
 
 		public Object getService(String arg0) throws ACRException,
 				InvalidArgumentException, NotFoundException {
 			// TODO Auto-generated method stub
 			return null;
 		}
 
 	}
 */
 	public void halting() {
 		logger.info("Going, going gone");
 		disconnect(autoReconnect);
 	}
 
 	public String lastChance() {
 		logger.info("ACR is shutting down");
 		return name;
 	}
 
 
 
 
 }