package de.laures.cewolf.dp;

 import java.io.Serializable;

 import java.util.Date;

 import java.util.Map;

 import org.apache.commons.logging.Log;

 import org.apache.commons.logging.LogFactory;

 import org.jfree.data.general.Dataset;

 import org.jfree.data.time.MovingAverage;

 import org.jfree.data.xy.XYDataset;

 import de.laures.cewolf.DatasetProduceException;

 import de.laures.cewolf.DatasetProducer;

 /**

  * @author guido

  *

  * To change this generated comment edit the template variable "typecomment":

  * Window>Preferences>Java>Templates.

  * To enable and disable the creation of type comments go to

  * Window>Preferences>Java>Code Generation.

  */

 public class MovingAverageDatasetProducer implements DatasetProducer, Serializable {

 	private static final Log log = LogFactory.getLog(MovingAverageDatasetProducer.class);

 	/**

 	 * @see de.laures.cewolf.DatasetProducer#produceDataset(Map)

 	 */

 	public Object produceDataset(Map params) throws DatasetProduceException {

 		log.debug(params);

 		DatasetProducer datasetProducer = (DatasetProducer)params.get("producer");

 		log.debug(datasetProducer);

 		Dataset dataset = (Dataset)datasetProducer.produceDataset(params);

 		String suffix = (String)params.get("suffix");

 		int period = ((Integer)params.get("period")).intValue();

 		int skip = ((Integer)params.get("skip")).intValue();

 		if(dataset instanceof XYDataset){

 	        return MovingAverage.createMovingAverage((XYDataset)dataset, suffix, period, skip);

 		} else {

 			throw new DatasetProduceException("moving average only supported for XYDatasets");

 		}

 	}

 	/**

 	 * @see de.laures.cewolf.DatasetProducer#hasExpired(Map, Date)

 	 */

 	public boolean hasExpired(Map params, Date since) {

 		return true;

 	}

 	/**

 	 * @see de.laures.cewolf.DatasetProducer#getProducerId()

 	 */

 	public String getProducerId() {

 		return getClass().getName();

 	}

 }