/***
    * Created on Aug 5, 2005, Copyright UC Regents
    */
   package org.telscenter.pas.steps;
   
   import java.awt.BorderLayout;
   import java.awt.Component;
   import java.awt.image.BufferedImage;
   import java.beans.beancontext.BeanContextServices;
  import java.io.IOException;
  import java.io.InputStream;
  import java.io.StringBufferInputStream;
  import java.util.EmptyStackException;
  import java.util.TooManyListenersException;
  import java.util.logging.Logger;
  
  import javax.swing.JEditorPane;
  import javax.swing.JPanel;
  import javax.swing.SwingUtilities;
  
  import net.sf.sail.core.beans.service.AgentService;
  import net.sf.sail.core.beans.service.SessionService;
  import net.sf.sail.core.entity.AgentSet;
  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.User;
  
  import org.telscenter.pas.beans.PasStep;
  import org.telstech.sensemaker.ControlPanel;
  import org.telstech.sensemaker.DisplayPanel;
  import org.telstech.sensemaker.SXML;
  import org.telstech.sensemaker.SenseRoot;
  import org.telstech.sensemaker.io.IDataHandler;
  
  /***
   * @author turadg
   */
  public class Sensemaker extends PasStep implements IntroductionHtmlAware {
  	/***
  	 * Logger for this class
  	 */
  	private static final Logger logger = Logger.getLogger(Sensemaker.class
  			.getName());
  
  	private static final long serialVersionUID = 1L;
  
  	Rim<String> starterRim;
  
  	Rim<String> workRim;
  
  	String introductionHtml = ""; //$NON-NLS-1$
  
  	String[] stockClaims = new String[0];
  
  	private JPanel _panel;
  
  	private ISock<String> starterSock;
  
  	private ISock<String> workSock;
  
  	private ControlPanel controlPanel;
  
  	private SessionService sessionService;
  
  	private AgentService agentService;
  
  	protected void initializePasStep(BeanContextServices bcs) {
  		buildPanel();
  	}
  
  	public String getType() {
  		return "Sensemaker";
  	}
  
  	protected void consumeService(BeanContextServices bcs, Class<? extends Object> serviceClass) {
  		if (serviceClass == SessionService.class) {
  			try {
  				sessionService = (SessionService) bcs.getService(this, this,
  						SessionService.class, this, this);
  			} catch (TooManyListenersException e) {
  				// TODO Auto-generated catch block
  				logger
  						.severe("BeanContextServices, Class -  : exception: " + e); //$NON-NLS-1$
  			}
  		} else if (serviceClass == AgentService.class) {
  			try {
  				agentService = (AgentService) bcs.getService(this, this,
  						AgentService.class, this, this);
  			} catch (TooManyListenersException e) {
  				// TODO Auto-generated catch block
  				logger
  						.severe("BeanContextServices, Class -  : exception: " + e); //$NON-NLS-1$
  			}
  		}
  
  		if (agentService != null && sessionService != null)
 			bindItemsToSocks();
 	}
 
 	private void bindItemsToSocks() {
 		// FIX assumes all users in the session are in the same workgroup
 		User user = sessionService.getUsers().iterator().next();
 		AgentSet agentsOfUser = agentService.getAgentsOfUser(user);
 		AgentSet agentsOfUserInWorkgroup = agentsOfUser
 				.select(Role.RUN_WORKGROUP);
 		IAgent agent;
 		try {
 			agent = agentsOfUserInWorkgroup.getSingle();
 		} catch (MismatchedAgentSetSizeException e1) {
 			logger.severe("exception: " + e1); //$NON-NLS-1$
 			return;
 		}
 
 		try {
 			workSock = agentService.getSock(workRim, agent);
 			if (starterRim != null)
 				starterSock = agentService.getSock(starterRim, agent);
 			IDataHandler dataHandler = new RimDataHandler();
 			controlPanel.setDataHandler(dataHandler);
 		} catch (Exception e) {
 			throw new RuntimeException("could not bind to rim", e); //$NON-NLS-1$
 		}
 	}
 
 	public Component getComponent() {
 		return _panel;
 	}
 
 	/***
 	 * 
 	 */
 	private void buildPanel() {
 		int width = 700;
 		int height = 500;
 		BufferedImage bimage = new BufferedImage(width, height,
 				BufferedImage.TYPE_INT_RGB);
 		BufferedImage bimage2 = new BufferedImage(width, height,
 				BufferedImage.TYPE_INT_RGB);
 
 		JEditorPane introductionPane = new JEditorPane("text/html", //$NON-NLS-1$
 				introductionHtml);
 		introductionPane.setEditable(false);
 		DisplayPanel displayPanel = new DisplayPanel(bimage, bimage2, width,
 				height);
 		controlPanel = new ControlPanel(displayPanel);
 		controlPanel.setStockClaims(stockClaims);
 
 		// compose full UI
 		_panel = new JPanel();
 		_panel.setLayout(new BorderLayout());
 		_panel.add(introductionPane, BorderLayout.NORTH);
 		_panel.add(displayPanel, BorderLayout.CENTER);
 		_panel.add(controlPanel, BorderLayout.SOUTH);
 		_panel.validate();
 	}
 
 	public String getIntroductionHtml() {
 		return introductionHtml;
 	}
 
 	public void setIntroductionHtml(String introductionHtml) {
 		Object old = this.introductionHtml;
 		this.introductionHtml = introductionHtml;
 		firePropertyChange("introductionHtml", old, this.introductionHtml); //$NON-NLS-1$
 
 	}
 
 	public String[] getStockClaims() {
 		return stockClaims;
 	}
 
 	public void setStockClaims(String[] stockClaims) {
 		String[] old = this.stockClaims;
 		this.stockClaims = stockClaims;
 		if (controlPanel != null)
 			controlPanel.setStockClaims(stockClaims);
 		firePropertyChange("introductionHtml", old, this.stockClaims); //$NON-NLS-1$
 	}
 
 	public Rim<String> getStarterRim() {
 		return starterRim;
 	}
 
 	public void setStarterRim(Rim<String> starterRim) {
 		Object old = this.starterRim;
 		this.starterRim = starterRim;
 		firePropertyChange("starterRim", old, starterRim); //$NON-NLS-1$
 	}
 
 	public Rim<String> getWorkRim() {
 		return workRim;
 	}
 
 	public void setWorkRim(Rim<String> workRim) {
 		Object old = this.workRim;
 		this.workRim = workRim;
 		firePropertyChange("workRim", old, workRim); //$NON-NLS-1$
 	}
 
 	class RimDataHandler implements IDataHandler {
 
 		private ISock<String> sockToRead;
 
 		public RimDataHandler() {
 			if (workSock == null)
 				throw new IllegalStateException("workSock cannot be null"); //$NON-NLS-1$
 			if (starterSock != null)
 				sockToRead = starterSock;
 			else
 				sockToRead = workSock;
 			logger.info("rim handler built, starterSock:" + starterSock //$NON-NLS-1$
 					+ " workSock:" + workSock); //$NON-NLS-1$
 		}
 
 		public void save(SenseRoot root) throws IOException {
 			String data = root.toXML();
 			workSock.add(data);
 
 			// since there's something in it now
 			sockToRead = workSock;
 		}
 
 		@SuppressWarnings("deprecation")
 		public void load(final SenseRoot root) throws IOException {
 			String s;
 			try {
 				s = sockToRead.peek();
 			} catch (EmptyStackException e) {
 				// nothin' there
 				logger.severe("no document to load from sock " //$NON-NLS-1$
 						+ sockToRead
 						+ "\n// starterRim:" + starterRim + " workRim:" //$NON-NLS-1$ //$NON-NLS-2$
 						+ workRim + "\n// starterSock:" + starterSock //$NON-NLS-1$
 						+ " workSock:" + workSock); //$NON-NLS-1$
 				return;
 			}
 			final InputStream is = new StringBufferInputStream(s);
 			try {
 				Class.forName("com.microstar.xml.XmlParser"); //$NON-NLS-1$
 			} catch (ClassNotFoundException e1) {
 				e1.printStackTrace();
 				throw new RuntimeException(e1);
 			}
 
 			Runnable updateDisplay = new Runnable() {
 				public void run() {
 					try {
 						SXML.load(root, is);
 						is.close();
 					} catch (Exception e) {
 						throw new RuntimeException(e);
 					}
 				}
 
 			};
 			SwingUtilities.invokeLater(updateDisplay);
 		}
 
 	}
 
 }