/*-
 * Copyright 2015 Diamond Light Source Ltd.
 *
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v1.0
 * which accompanies this distribution, and is available at
 * http://www.eclipse.org/legal/epl-v10.html
 */

package org.eclipse.dawnsci.plotting.api.filter;

import java.util.Arrays;
import java.util.List;

import org.eclipse.core.runtime.IProgressMonitor;
import org.eclipse.core.runtime.IStatus;
import org.eclipse.core.runtime.Status;
import org.eclipse.core.runtime.jobs.Job;
import org.eclipse.dawnsci.analysis.api.dataset.IDataset;
import org.eclipse.dawnsci.plotting.api.IPlottingSystem;
import org.eclipse.dawnsci.plotting.api.trace.ITrace;
import org.eclipse.dawnsci.plotting.api.trace.TraceWillPlotEvent;

/**
 * Uses a job to process the filter which might take a second or two
 * to run and therefore should be run in a job.
 * 
 * Uses the name of the original data to update the value, therefore the
 * filtered data ends up getting the same name.
 */
public abstract class AbstractDelayedFilter extends AbstractPlottingFilter  {
	
	private FilterJob       job;
	private IPlottingSystem system;
	private String          filterName;
	private TraceWillPlotEvent evt;
	private boolean         isOn=true;

	@Override
	public void filter(IPlottingSystem system, TraceWillPlotEvent evt) throws Exception {
		
		if (job==null) this.job = new FilterJob(filterName);

		this.system = system;
		final ITrace trace = (ITrace)evt.getSource();
		if (trace.getRank()!=getRank()) {
			if (getRank()>0) return;
		}
		
		this.evt = evt;
		if (!isOn) return;
		cache.add(new OriginalData(evt));
		
		system.setEnabled(false);
		job.schedule();
	}
	
	private class FilterJob extends Job {
				
		public FilterJob(String filterName) {
			super(filterName);
		}

		@Override
		protected IStatus run(IProgressMonitor monitor) {
			try {
				isOn = false;
				if (getRank()==1) {
					IDataset[] filtered = filter(evt.getXData(), evt.getYData());
					system.updatePlot1D(filtered[0]!=null?filtered[0]:evt.getXData(), Arrays.asList(filtered[1]), monitor);
				} else {
					Object[] filtered = filter(evt.getImage(), evt.getAxes());
					system.updatePlot2D((IDataset)filtered[0], (List<IDataset>)filtered[1], getName(), monitor);
				}
				fireFilterApplied(new FilterEvent(this));

			} catch (Exception ne) {
				ne.printStackTrace();
				return Status.CANCEL_STATUS;
			} finally {
				isOn = true;
				system.setEnabled(true);
			}

			return Status.OK_STATUS;
		}
	}

	public String getFilterName() {
		return filterName;
	}

	public void setFilterName(String filterName) {
		this.filterName = filterName;
	}

}

@@ -1401,18 +1401,16 @@
 ption %7B%0A
-%09%09
 %0A%09%09if (j
@@ -1415,16 +1415,104 @@
 (job
+ 
 ==
+ 
 null)
- 
+%0A%09%09%09this.job = new FilterJob(filterName);%0A%0A%09%09if (!job.getName().equals(filterName))%0A%09%09%09
 this
@@ -1545,17 +1545,16 @@
 rName);%0A
-%0A
 %09%09this.s
@@ -2633,24 +2633,74 @@
 US;%0A%09%09%7D%0A%09%7D%0A%0A
+%09public boolean isFilterOn() %7B%0A%09%09return isOn;%0A%09%7D%0A%0A
 %09public Stri

Add isOn method to AbstractDelayedFilter