pstlab / PLATINUm

import java.util.ArrayList;

import java.util.HashMap;

import java.util.HashSet;

import java.util.List;

import java.util.Map;

import java.util.Set;

import it.cnr.istc.pst.platinum.executive.dc.strategy.result.Action;

import it.cnr.istc.pst.platinum.executive.dc.strategy.result.Transition;

import it.cnr.istc.pst.platinum.executive.dc.strategy.result.Wait;

public class ListStrategy implements Strategy{

	private static int MAX_STRIKE = 99999999;

	private long horizon; 

	private long time;

	private int strikeTimer;

	private Set<StateSet> states;

	private Map<String,Long> timelineClocks;

	private Map<String,String> expectedState;

	private Set<String> uStates; 

	private Map<Transition,Map<String,String>> uPostConditions;

	private Map<Long,Integer> out;

	private int strikeMaxReached;

	//private PrintWriter writer;

	// ------------------------------ CONSTRUCTORS ------------------

	public ListStrategy(long horizon) {

		this.horizon = horizon;

		this.states = new HashSet<>();

		this.expectedState = new HashMap<>();

		this.uPostConditions = new HashMap<>();

		this.time = 0;

		this.out = new HashMap<>();

		this.uStates = new HashSet<>();

		this.strikeTimer = 0;

		this.strikeMaxReached = 0;

	}

	//---------------------------------- METHODS --------------------

	// the list strategy does not need building, kept for generalization

	@Override

	public void buildStrategyStructure() {return;}

	//returns next strategy step (repeat until wait!!) using plan clock

	//returns next strategy step (repeat until wait!!) using tic

	public List<Action> askAllStrategySteps(long tic, Map<String,String> actualState) { // throws Exception {

		System.out.println(expectedState + "tic " + tic + "\n\n");

		List<Action> actions = new ArrayList<>();

		this.updateExpectedState(actualState);

		this.updateClocks(tic);

		Action action = askSingleStrategyStep(this.expectedState);

		actions.add(action);

		while(action.getClass().equals(Transition.class)) {

			action = askSingleStrategyStep(this.expectedState);

			actions.add(action);

		}

		time = System.currentTimeMillis() - time;

		System.out.println("\n"+ "Answer all strategy steps: " + time + "ms, " + "\n");

		return actions;

	}

	//returns one action predicted for next step

	private Action askSingleStrategyStep(Map<String, String> actualState) { // throws Exception {

		//System.out.println(actualState + "\n\n");

		try

		{

			for(StateSet s : this.states) {

				if(s.isStateSetStatus(actualState)) { //change in map

					StateStrategy win = s.searchNextStepStrategy(timelineClocks);

					this.timelineClocks = win.applyPostConditions(this.timelineClocks, this.horizon);

					updateExpectedState(win.getAction());

					time = System.currentTimeMillis() - time;

					//System.out.println("\n"+ "Answer single strategy steps: " + time + "ms\n");

					return win.getAction();

				}

			}

		}

		catch (Exception ex) {

			System.out.println("Warning: no state or clock found -> return default action WAIT\n");

			this.strikeTimer = this.strikeTimer + 1;

			if(this.strikeTimer > this.strikeMaxReached) { this.strikeMaxReached = this.strikeTimer; }

			if(this.strikeTimer > ListStrategy.MAX_STRIKE) {

				System.out.println("PostConditionsan out of bounds, strike max reached\n");

			}

			//System.out.println("\n"+ "Answer single strategy steps: " + time + "ms\n");

		}

		// default action

		return new Wait();

	}

	//update list of expected states with list of actual states given, resets local clocks if state changed

	private void updateExpectedState(Map<String,String> actualStates) {

			if(!this.expectedState.get(timeline).equals(actualStates.get(timeline))) {

				resetClocks(timeline,new Transition(timeline,this.expectedState.get(timeline),this.expectedState.get(timeline)));

				this.expectedState.put(timeline, actualStates.get(timeline));

			}

		}

	}

	// Resets the local clocks of uncontrollable events that took place in the tic

		//this.timelineClocks.put(timeline+"."+timeline+"_clock",0);

		//System.out.println(" RESET CLOCK : " + timeline + " " + token + "<<<<<<<<<<<<<<<<<<<\n");

		Map<String,String> condToken = this.uPostConditions.get(token);

		//System.out.println("CONDTOKEN : " + condToken + "\n");

		if(condToken!=null) {

				if(condToken.get(cond).contains("0")) {

					this.timelineClocks.put(cond, 0l);

				}

				if(condToken.get(cond).contains("H")) {

					this.timelineClocks.put(cond, this.horizon*2);

				}

			}

			this.timelineClocks.put(timeline, 0l);

		}}

	//updates, after a winning transition, the next expected state

	private void updateExpectedState(Action action) {

		if(action.getClass().equals(Transition.class)) {

			Transition t = (Transition) action;

			this.expectedState.put(t.getTransitionTo().getTimeline(),t.getTransitionTo().getToken());

		}

	}

	//updates clocks through plan clock

	private void updateClocks(long n) {

			//System.out.println(">>> INCREMENT CLOCK BY " + n + ":::: CLOCK " + c + "\n");

			this.timelineClocks.put(c, this.timelineClocks.get(c)+n);

		}

	}

	@Override

	public void updateUncontrollable(Map<String, String> updatedState) {

		// TODO Auto-generated method stub

		System.out.println("WARNING: Unimplemented method 'updateUncontrollable'\n");

	}

	@Override

	public String toString() {

		return "Strategy [STRATEGY = " + this.states + "]";

	}

	//---------------------- GETTERS&SETTERS ------------------------

	public Set<StateSet> getStates() {

		return this.states;

	}

	public void addState(StateSet states) {

		this.states.add(states);

	}

	public Map<String,Long> getTimelineClocks() {

		return this.timelineClocks;

	}

	@Override

	public int getStrikeMaxReached() {

		return this.strikeMaxReached;

	}

	@Override

	public void setTimelineClocks(Map<String,Long> tc) {

		this.timelineClocks = tc;

	}

	public Map<String, String> getExpectedState() {

		return expectedState;

	}

	@Override

	public void setInitialState(Map<String, String> expectedState) {

		this.expectedState = expectedState;

	}

	public Map<Transition, Map<String, String>> getuPostConditions() {

		return uPostConditions;

	}

	@Override

	public void setuPostConditions(Map<Transition, Map<String, String>> uPostConditions) {

		this.uPostConditions = uPostConditions;

	}

//	@Override //may be obsolete

//	public void getStrategyAsList(Set<StateSet> accumulatedStates) {

//		for (StateSet set : accumulatedStates) {

//			this.addState(set);

//		}	

//	}

	@Override

	public void getStrategyAsStrings(String ss, List<String> statesLine){

			StateSet stateSet = new StateSet(ss,statesLine);

			this.states.add(stateSet);

	}

	@Override

	public boolean isOutOfBounds() {

		return (this.strikeTimer > ListStrategy.MAX_STRIKE);

	}

//	@Override //OBSOLETE AND NOT WORKING

//	public boolean isStrategyFinished() {

//		for( String tl : this.expectedState.keySet()) {

//			if(!this.expectedState.get(tl).equals("finish")){

//				return false;

//			}

//		}

//		return true;

//	}

	public Set<String> getuStates() {

		return uStates;

	}

	@Override

	public void setuStates(Set<String> uStates) {

		this.uStates = uStates;

	}

	/*public void setWriter(PrintWriter writer) {

		this.writer = writer;

	}*/

}