/*
    * The contents of this file are subject to the terms 
    * of the Common Development and Distribution License 
    * (the "License").  You may not use this file except 
    * in compliance with the License.
    * 
    * You can obtain a copy of the license at 
    * http://www.sun.com/cddl/cddl.html. 
    * See the License for the specific language governing 
   * permissions and limitations under the License.
   * 
   * When distributing Covered Code, include this CDDL 
   * HEADER in each file and include the License file at 
   * license.txt.  If applicable, add the following below 
   * this CDDL HEADER, with the fields enclosed by brackets 
   * "[]" replaced with your own identifying information: 
   * Portions Copyright [yyyy] [name of copyright owner]
   * 
   * Portions Copyright 2004 eBay, Inc.
   */
  package com.ebay.carad.os.vitalsigns;
  
  import java.util.Collection;
  import java.util.Collections;
  import java.util.Date;
  import java.util.HashSet;
  import java.util.List;
  
  import org.apache.log4j.Logger;
  
  import com.ebay.carad.os.vitalsigns.dao.IDataDAO;
  import com.ebay.carad.os.vitalsigns.util.NanoHTTPD;
  
  /***
   * @author Jeremy Thomerson
   * @version $Id$
   */
  public class DashboardAgent extends AbstractListenerContainer implements IDashboardAgent, Runnable {
  
      private static final Logger LOGGER = Logger.getLogger(DashboardAgent.class);
  
      private IDataDAO mDefaultDataDAO = IDataDAO.NO_OP_INSTANCE;
      private List /*<IDashboardReportContainer>*/ mReports;
      private String mDestinationPath;
      private boolean mRunHTTPServer = false;
      private int mRunHTTPServerPort = 8080;
      private String mTitle;
  
      public DashboardAgent() {
          super();
      }
  
      public void run() {
          if (isRunHTTPServer()) {
              try {
                  LOGGER.info("starting HTTP server");
                  new NanoHTTPD(mRunHTTPServerPort, mDestinationPath);
                  LOGGER.info("HTTP Server License:\n" + NanoHTTPD.LICENCE + "\n");
              } catch (Exception ex) {
                  LOGGER.error("ERROR starting HTTP server [proceeding with dashboard execution]: " + ex.getMessage());
              }
          }
          try {
              runAllReports();
          } catch(Exception ex) {
              ReportingException rex = new ReportingException("error while running reports that was uncaught by any previous ReportingException: " + ex.getMessage(), ex);
              LOGGER.error(rex.getMessage(), rex);
              fireListenersException(this, rex, null);
          }
          LOGGER.info("DashboardAgent#run() method is complete.  If you used the example config, the app will keep running because the cron job bean has daemon threads running in the background.");
      }
  
      public void runAllReports() {
          long now = System.currentTimeMillis();
          LOGGER.info("starting reporting [for timestamp: " + new Date(now) + "]");
          fireListenersStarted(this);
          fireReportsListenersStarted();
          for (ReportContainerIterator it = new ReportContainerIterator(mReports); it.hasNext(); ) { // run logs for each report.
              IDashboardReport rep = it.next();
              try {
                  rep.run(this, now);
                  fireListenersReportRan(this, rep);
                  if (rep instanceof AbstractListenerContainer) {
                  	((AbstractListenerContainer) rep).fireListenersReportRan(this, rep);
                  }
  //                fireReportsListenersReportRan(rep);
              } catch(ReportingException re) {
                  fireListenersException(this, re, rep);
              }
          }
          fireListenersCompleted(this);
          fireReportsListenersCompleted();
          LOGGER.info("completed reporting [for timestamp: " + new Date(now) + "]");
      }
  
      private void fireReportsListenersStarted() {
          for (ReportContainerIterator it = new ReportContainerIterator(mReports); it.hasNext(); ) { // run logs for each report.
              IDashboardReport rep = it.next();
              try {
                 if (rep instanceof AbstractListenerContainer) {
                     ((AbstractListenerContainer) rep).fireListenersStarted(this);
                 }
             } catch(ReportingException re) {
                 fireListenersException(this, re, rep);
             }
         }
     }
     protected void fireListenersException(IReportingListenerContainer agent, ReportingException re, IDashboardReport rep) {
     	// first call super to call our listeners
     	super.fireListenersException(agent, re, rep);
     	// now fire reports listeners
     	fireReportsListenersReportingException(rep, re);
     }
     private void fireReportsListenersReportingException(IDashboardReport report, ReportingException rex) {
         for (ReportContainerIterator it = new ReportContainerIterator(mReports); it.hasNext(); ) { // run logs for each report.
             IDashboardReport rep = it.next();
             try {
                 if (rep instanceof AbstractListenerContainer) {
                     ((AbstractListenerContainer) rep).fireListenersException(this, rex, report);
                 }
             } catch(ReportingException re) {
                 fireListenersException(this, re, rep);
             }
         }
     }
     private void fireReportsListenersCompleted() {
         for (ReportContainerIterator it = new ReportContainerIterator(mReports); it.hasNext(); ) { // run logs for each report.
             IDashboardReport rep = it.next();
             try {
                 if (rep instanceof AbstractListenerContainer) {
                     ((AbstractListenerContainer) rep).fireListenersCompleted(this);
                 }
             } catch(ReportingException re) {
                 fireListenersException(this, re, rep);
             }
         }
     }
     
     public IDataDAO getDefaultDataDAO() {
         return mDefaultDataDAO;
     }
 
     public List getReports() {
         return Collections.unmodifiableList(mReports);
     }
 
     /* IoC Methods */
     public void setDefaultDataDAO(IDataDAO dao) {
         mDefaultDataDAO = dao;
     }
     public void setReports(List reports) {
         mReports = reports;
         checkConsistency();
     }
 
     private void checkConsistency() {
         Collection containedIDs = new HashSet();
         for (ReportContainerIterator it = new ReportContainerIterator(mReports); it.hasNext(); ) {
             IDashboardReport rep = it.next();
             Integer id = new Integer(rep.getID());
             if (containedIDs.contains(id)) {
                 throw new IllegalStateException("Duplicate report ID: " + id);
             }
             containedIDs.add(id);
         }
     }
 
     public String getDestinationPath() {
         return mDestinationPath;
     }
     
     public void setDestinationPath(String destinationPath) {
         mDestinationPath = destinationPath;
     }
 
     public String getTitle() {
         return mTitle;
     }
 
     public void setTitle(String title) {
         mTitle = title;
     }
 
     public boolean isRunHTTPServer() {
         return mRunHTTPServer;
     }
 
     public void setRunHTTPServer(boolean runHTTPServer) {
         mRunHTTPServer = runHTTPServer;
     }
 
     public int getRunHTTPServerPort() {
         return mRunHTTPServerPort;
     }
 
     public void setRunHTTPServerPort(int runHTTPServerPort) {
         mRunHTTPServerPort = runHTTPServerPort;
     }
     
 }