//package strategies;
package singlejartest;

import java.util.*;
import java.text.SimpleDateFormat;
import java.util.TimeZone;

import com.dukascopy.api.*;
import com.dukascopy.api.feed.*;

public class TestStrategy implements IStrategy 
{
    /////////////////////////////
    //constants used for console logging
    /////////////////////////////
    static final int INFO = 0;
    static final int WARNING = 1;
    static final int ERROR = 2;
    
    /////////////////////////////
    //Configurable input parameters
    /////////////////////////////
    @Configurable("Instrument") public Instrument _instrument = Instrument.GBPUSD;    

    @Configurable("Larger EMA Period") public int _largerEmaPeriod = 30;
    @Configurable("Smaller EMA Period") public int _smallerEmaPeriod = 24;
    @Configurable("Tiny EMA Period") public int _tinyEmaPeriod = 3;
    @Configurable("MACD Fast Period") public int _macdFastPeriod = 12;
    @Configurable("MACD Slow Period") public int _macdSlowPeriod = 33;
    @Configurable("MACD Signal Period") public int _macdSignalPeriod = 9;
    @Configurable("Debug Printing") public boolean _debugPrintFlag = true;
    
    /////////////////////////////
    //JForex interfaces for future use
    /////////////////////////////
    private IConsole _console;
    private IContext _context;
    private IIndicators _indicators;
    
    /////////////////////////////
    //misc
    /////////////////////////////
    Period _period = Period.createCustomPeriod(Unit.Hour, 2);    
    final SimpleDateFormat sdf = new SimpleDateFormat("yyyy.MM.dd 'at' HH:mm:ss z");


    private void debugPrint (int level, String strToPrint)
    {
        if (_debugPrintFlag)
        {
            switch (level)
            {
                case ERROR:
                    _console.getErr().println(strToPrint);
                    break;
                case WARNING:
                    _console.getWarn().println(strToPrint);
                    break;
                case INFO:
                default:
                    _console.getOut().println(strToPrint);
            }
        }
    }
    


    /////////////////////////////
    // IStrategy interface methods
    /////////////////////////////
    
    public void onStart(IContext context) throws JFException 
    {
        _console = context.getConsole();
        _context = context;
        _indicators = context.getIndicators();
        
        sdf.setTimeZone(TimeZone.getTimeZone("GMT"));

        //subscribe to instrument
        Set<Instrument> instSet = new HashSet<Instrument>();
        instSet.add(_instrument);
        context.setSubscribedInstruments(instSet);    
    
        debugPrint (INFO, "Subscribing to: " + instSet.toString() + " " + _period);
        
        //subscribing to custom Period
        this._context.subscribeToBarsFeed
        (_instrument,
        _period, 
        OfferSide.BID, 
        new IBarFeedListener() 
        { 
            public void onBar(Instrument instrument, Period period, OfferSide offerSide, IBar bar) 
            { 
                debugPrint (INFO, "Received new " + period + " bar for " + instrument + ", open = " + bar.getOpen() + ", high = " + bar.getHigh() + ", low = " + bar.getLow() + ", close = " + bar.getClose());
                
                try 
                {
                    double emaSmallerArray[]  =  _indicators.ema(_instrument, _period, OfferSide.BID, IIndicators.AppliedPrice.CLOSE, _smallerEmaPeriod, bar.getTime(), bar.getTime());
                    double emaLargerArray[]  =  _indicators.ema(_instrument, _period, OfferSide.BID, IIndicators.AppliedPrice.CLOSE, _largerEmaPeriod, bar.getTime(), bar.getTime());
                    double emaShadowArray[]  =  _indicators.ema(_instrument, _period, OfferSide.BID, IIndicators.AppliedPrice.CLOSE, _tinyEmaPeriod, bar.getTime(), bar.getTime());
                    double[][] macdArray =  _indicators.macd(_instrument, _period, OfferSide.BID, IIndicators.AppliedPrice.CLOSE, _macdFastPeriod, _macdSlowPeriod, _macdSignalPeriod, bar.getTime(), bar.getTime()); 
                    
                    double emaSmaller = emaSmallerArray[0];
                    double emaLarger = emaLargerArray[0];
                    double emaShadow = emaShadowArray[0];
                    double macdHistogram = macdArray[2][0];
                    
                    double bid  = bar.getClose();
                    
                    debugPrint (INFO, "Bar at " + sdf.format(new Date(bar.getTime())) + 
                                      ", ema values 24 = " + emaSmaller  + 
                                      ", 30 = " + emaLarger  + 
                                      ", 3 = " + emaShadow + 
                                      ", macd histogram = " + macdHistogram );
                }
                catch (JFException e) 
                {
                    debugPrint (ERROR, "Exception: " + e.toString());
                    e.printStackTrace();
                }
            }
        });       
    }
    

    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 {
    }
    
    public void onBar(Instrument instrument, Period period, IBar askBar, IBar bidBar) throws JFException {
    }
}