/*
    * Created on Apr 25, 2005, Copyright UC Regents
    */
   package org.telscenter.pas.otrunk;
   
   import java.awt.event.ActionEvent;
   import java.beans.beancontext.BeanContextServices;
   import java.io.ByteArrayInputStream;
   import java.io.ByteArrayOutputStream;
  import java.io.StringReader;
  import java.net.URL;
  import java.util.TooManyListenersException;
  import java.util.logging.Logger;
  
  import javax.swing.AbstractAction;
  import javax.swing.Action;
  
  import net.sf.sail.common.beansupport.ITitleAware;
  import net.sf.sail.common.beansupport.SailBeanContextChildSupport;
  import net.sf.sail.core.beans.event.SessionEvent;
  import net.sf.sail.core.beans.event.SessionEventListener;
  import net.sf.sail.core.beans.service.AgentService;
  import net.sf.sail.core.beans.service.SessionService;
  import net.sf.sail.core.entity.IAgent;
  import net.sf.sail.core.entity.ISock;
  import net.sf.sail.core.entity.MismatchedAgentSetSizeException;
  import net.sf.sail.core.entity.Rim;
  import net.sf.sail.core.entity.Role;
  import net.sf.sail.core.entity.UnsupportedRimShapeException;
  
  import org.concord.otrunk.datamodel.OTDatabase;
  import org.concord.otrunk.view.OTViewer;
  import org.concord.otrunk.view.OTViewerHelper;
  import org.concord.otrunk.xml.XMLDatabase;
  
  /***
   * Bean representing the PAS project.
   * 
   * @author turadg
   */
  public class PasOTViewer extends SailBeanContextChildSupport 
  	implements ITitleAware
  {
  	static {
  		// I don't know if this will be soon enough
  		// but lets see
          System.setProperty("apple.laf.useScreenMenuBar","true");
  	}
  	
  	/***
  	 * Logger for this class
  	 */
  	private static final Logger logger = Logger.getLogger(PasOTViewer.class
  			.getName());
  
  	private static final long serialVersionUID = 1L;
  	
  	private URL authoredDataURL;
  
  	private AgentService agentService;
  	private SessionService sessionService;
  		
  	private Rim workRim;
  
  	private ISock workSock;
  
  	private boolean hideTree = false;
  	private int userMode = 0; 
  		
  	OTViewer viewer = null;
  	OTViewerHelper viewerHelper = new OTViewerHelper();
  	
  	SessionEventListener sessionListener = new SessionEventListener() {
  
  		public void sessionInitiated(SessionEvent e) {
  		}
  
  		public void sessionStarted(SessionEvent e) 
  		{
  			viewer = new OTViewer();
  
  			viewer.setUserMode(getUserMode());
  			
  			String authoredDataUrlStr = getAuthoredDataURL().toExternalForm();
  			
  			// Figure out if there is a url being set through the configuration
  			String authoredDataConfigUrlStr = 
  				sessionService.getProperty("sailotrunk.otmlurl", null);
  			
  			// In the future we can load both the config url string
  			// and the interally set (pod) url string. So the data can 
  			// be split up.  For now we'll just replace the old string
  			// with the new one
  			if(authoredDataConfigUrlStr != null) {
  				authoredDataUrlStr = authoredDataConfigUrlStr;
  			}
  			
  			
  			viewer.init(authoredDataUrlStr);	
 
 			AbstractAction exitAction = new AbstractAction(){
 				/***
 				 * Not intended to be serialized, just added remove compile warning
 				 */
 				private static final long serialVersionUID = 1L;
 				
 				public void actionPerformed(ActionEvent e) {
                     viewer.getViewContainerPanel().setCurrentObject(null);
 					saveDataInternal();
 					
 					getSessionService().userRequestsTermination();
 				}				
 			};
 			exitAction.putValue(Action.NAME, "Exit");		
 			
 			viewer.setExitAction(exitAction);
 			
 			viewer.updateMenuBar();
 			
 			if(viewer.getUserMode() == OTViewerHelper.NO_USER_MODE){
 				// if we are in no user mode then we don't need to read data in from the 
 				// sock or initialize the user data.
 				return;
 			}
 			
 			ISock sock = getWorkSock();
 			
 			Object lastEntry = null;
 			if(sock != null && sock.size() > 0){
 				lastEntry = sock.peek();
 			}
 			
 			if(lastEntry != null){
 				try {
 					XMLDatabase userDB = null;
 					if(lastEntry instanceof String) {
 						StringReader reader = new StringReader((String)lastEntry);
 
 						// FIXME need to pass in some context url this is needed
 						// for any referenced resources in the otml
 						userDB = (XMLDatabase) viewerHelper.loadOTDatabase(reader, null);
 
 					} else if(lastEntry instanceof byte[]){
 						ByteArrayInputStream inStream = new ByteArrayInputStream((byte[])lastEntry); 
 
 						userDB = (XMLDatabase) viewerHelper.loadOTDatabase(inStream, null);
 					}										
 					
 					if(userDB != null){
 						viewer.loadUserDataDb(userDB, null);
 						((XMLDatabase)userDB).setDirty(false);
 					} else {
 						viewer.newAnonUserData();					
 					}
 				} catch (Exception exp) {
 					exp.printStackTrace();
 					viewer.newAnonUserData();
 				}
 			} else {
 				viewer.newAnonUserData();
 			}
 		}
 
 		public void sessionStopped(SessionEvent e) {
 			saveDataInternal();
 		}
 
 	};
 
 	protected void registerDesiredServices(BeanContextServices bcs) {
 	}
 		
 	
 	/***
 	 * This method can be called more than once in the authoring runtime, when
 	 * the preview is shown more than once.
 	 * 
 	 * @param bcs
 	 * @param serviceClass
 	 * @param project
 	 */
 	protected void consumeService(BeanContextServices bcs, Class serviceClass) {
 		if (serviceClass == SessionService.class) {
 			try {
 				sessionService = (SessionService) bcs.getService(this, this,
 						SessionService.class, this, this);
 
 				sessionService.addSessionEventListener(sessionListener);
 			} catch (TooManyListenersException e1) {
 				// TODO Auto-generated catch block
 				logger
 						.severe("BeanContextServices, Class -  : exception: " + e1); //$NON-NLS-1$
 			}
 		}
 		if (serviceClass == AgentService.class)
 		{
 			try
 			{
 				final AgentService p = (AgentService) bcs.getService(this,
 						this, AgentService.class, this, this);
 				agentService = p;
 			}
 			catch (TooManyListenersException e)
 			{
 				e.printStackTrace();
 			}
 		}
 	}
 	
 	/***
 	 * @return the sessionService
 	 */
 	public SessionService getSessionService() {
 		return sessionService;
 	}
 
 	/***
 	 * @param sessionService the sessionService to set
 	 */
 	public void setSessionService(SessionService sessionService) {
 		this.sessionService = sessionService;
 	}
 
 	protected ISock getRimSock(Rim rim)
 	{
 		ISock sock = null;
 		if (rim != null)
 		{
 			try {
 				IAgent agent = agentService.getAgentsInRole(Role.RUN_WORKGROUP).getSingle();
 				sock = agentService.getSock(rim, agent);
 			} catch (MismatchedAgentSetSizeException e) {
 				// TODO Auto-generated catch block
 				e.printStackTrace();
 			} catch (UnsupportedRimShapeException e) {
 				// TODO Auto-generated catch block
 				e.printStackTrace();
 			}
 		}
 		return sock;
 	}
 
 	public Rim getWorkRim() {
 		return workRim;
 	}
 
 	public void setWorkRim(Rim workRim) {
 		this.workRim = workRim;
 	}
 
 	public ISock getWorkSock() {
 		if (workSock == null) {
 			workSock = getRimSock(getWorkRim());
 		}
 		return workSock;
 	}
 
 
 	public URL getAuthoredDataURL()
 	{
 		return authoredDataURL;
 	}
 
 	public void setAuthoredDataURL(URL url)
 	{
 		authoredDataURL = url;
 	}
 	
 	public String getTitle() {
 		return "SailOTViewer title";
 	}
 
 
 	public void setTitle(String title) {
 	}
 
 
 	public boolean isHideTree() {
 		return hideTree;
 	}
 
 
 	public void setHideTree(boolean hideTree) {
 		this.hideTree = hideTree;
 	}
 
 
 	public int getUserMode() {
 		return userMode;
 	}
 
 
 	public void setUserMode(int userMode) {
 		this.userMode = userMode;
 	}	
 
 	private void saveDataInternal()
 	{
 		OTDatabase userDB = viewer.getUserDataDb();
 
 		if(userDB == null){
 			// no user database was created 
 			return;
 		}
 		
 		// If the database hasn't been modified, don't
 		// save anything
 		if(userDB instanceof XMLDatabase &&
 				!((XMLDatabase)userDB).isDirty()){
 			return;
 		}
 		
 		ISock sock = getWorkSock();
 		try {
 			if(sock != null && userDB != null){
 
 				// this is a hack to test this should be moved
 				// to the converter
 				//getWorkRim().setShape(bytes.getClass());
 
 				if(getWorkRim().getShape() == byte[].class){
 					ByteArrayOutputStream out = new ByteArrayOutputStream();
 					viewerHelper.saveOTDatabase(userDB, out);
 					byte [] bytes = out.toByteArray();
 					sock.add(bytes);
 					if(userDB instanceof XMLDatabase){
 						((XMLDatabase)userDB).setDirty(false);
 					}
 				} else {
 					String userData = viewerHelper.saveOTDatabase(userDB);
 					sock.add(userData);
 				}
 			} else {
 				System.err.println("No sock in OTrunkStep - cannot save data");
 			}
 			
 		} catch (Exception e1) {
 			// TODO Auto-generated catch block
 			e1.printStackTrace();
 		}										
 
 	}
 
 }