package jforex.history;

import com.dukascopy.api.*;

@RequiresFullAccess
public class ReadBarsExample2 implements IStrategy {
	private IContext context;
	private IConsole console;
	private IHistory history;
	private int numberOfBarsLoaded;
	private boolean executed;
	
	public void onStart(IContext context) throws JFException {
		this.context = context;
		this.history = context.getHistory();
		this.console = context.getConsole();
	}

	public void onAccount(IAccount account) throws JFException {
	}

	public void onMessage(IMessage message) throws JFException {
	}

	public void onStop() throws JFException {
	}

	public void onTick(Instrument instrument, ITick tick) throws JFException {
		if (!executed) {
			console.getOut().println("Calling readBars method");
			history.readBars(Instrument.EURUSD, Period.TEN_SECS, OfferSide.BID,
					history.getBarStart(Period.DAILY, tick.getTime()) - Period.DAILY.getInterval(), // yesterday start
					history.getBarStart(Period.DAILY, tick.getTime()) - Period.TEN_SECS.getInterval(), // yesterday end
					new LoadingDataListener() {
						public void newTick(Instrument instrument, long time, double ask, double bid, double askVol, double bidVol) {
							//no ticks expected, because we are loading bars
						}
						public void newBar(Instrument instrument, Period period, OfferSide side, long time, double open, double close, double low, double high, double vol) {
							++numberOfBarsLoaded;
						}
					}, new MyLoadingProgressListener(Instrument.EURUSD, Period.TEN_SECS));
			console.getOut().println("Exited readBars method, bars read - " + numberOfBarsLoaded);
			executed = true;
			context.stop();
		}
	}

    public void onBar(Instrument instrument, Period period, IBar askBar, IBar bidBar) throws JFException {
    }
    
    private class MyLoadingProgressListener implements LoadingProgressListener{
    	
    	private final Instrument instrument;
    	private final Period period;
    	
    	public MyLoadingProgressListener (Instrument instrument, Period period){
    		this.instrument = instrument;
    		this.period = period;
    	}

    	@Override
    	public void dataLoaded(long start, long end, long currentPosition, String information) {
    		console.getOut().println(information);
    		
    	}

    	@Override
    	public void loadingFinished(boolean allDataLoaded, long start, long end, long currentPosition) {
			if (allDataLoaded) {
				console.getOut().println(instrument + ", " + period + ", All data loaded succesfully, number of bars loaded: " + numberOfBarsLoaded);
				context.stop();
			} else {
				console.getOut().println(instrument + ", " + period + ", For some reason loading failed or was canceled by the user");
				context.stop();
			}    		
    	}

    	@Override
    	public boolean stopJob() {
    		// TODO Auto-generated method stub
    		return false;
    	}
    	
    }
    
    
}