package schedframe.resources.computing.profiles.energy.airthroughput;

import java.util.ArrayList;
import java.util.List;

import org.joda.time.DateTimeUtils;

import schedframe.Parameters;
import schedframe.resources.computing.profiles.energy.airthroughput.plugin.AirflowEstimationPlugin;

public class AirflowProfile {
	
	protected List<AirflowValue> airflowHistory;
	
	protected AirflowEstimationPlugin airflowEstimationPlugin;
	protected List <AirflowState> airflowStates;
	protected Parameters parameters;

	public AirflowProfile(AirflowEstimationPlugin airflowEstimationPlugin, List<AirflowState> airflowStates) {
		super();
		this.airflowEstimationPlugin = airflowEstimationPlugin;
		this.airflowStates = airflowStates;
		this.airflowHistory = new ArrayList<AirflowValue>();
	}

	public List<AirflowState> getAirflowStates() {
		return airflowStates;
	}
	
	public void addToAirFlowHistory(double airflow) {

		if (airflowHistory.size() == 0) {
			AirflowValue usage = new AirflowValue(DateTimeUtils.currentTimeMillis(), airflow);
			airflowHistory.add(usage);
			return;
		}

		int lastIdx = airflowHistory.size() - 1;
		double lastAirflow = airflowHistory.get(lastIdx).getValue();
		if (lastAirflow != airflow) {
			AirflowValue usage = airflowHistory.get(lastIdx);
			long currentTime = DateTimeUtils.currentTimeMillis();
			if (usage.getTimestamp() == currentTime) {
				usage.setValue(airflow);
				if(lastIdx > 0 && airflowHistory.get(lastIdx - 1).getValue() == airflow)
					airflowHistory.remove(usage);
			} else {
				usage = new AirflowValue(DateTimeUtils.currentTimeMillis(), airflow);
				airflowHistory.add(usage);
			}
		}
	}

	public List<AirflowValue> getAirflowHistory() {
		return airflowHistory;
	}
	
	public void init(Parameters params){
		this.parameters = params;
	}

	public Parameters getParameters() {
		return parameters;
	}
}