package jforex.strategies.renko;
import com.dukascopy.api.*;
import com.dukascopy.api.feed.IFeedDescriptor;
import com.dukascopy.api.feed.util.*;
import com.dukascopy.api.feed.*;
import java.util.*;
import com.dukascopy.api.*;
import com.dukascopy.api.IContext;
import com.dukascopy.api.IBar;
import com.dukascopy.api.PriceRange;
import com.dukascopy.api.feed.FeedDescriptor;
import com.dukascopy.api.feed.IFeedDescriptor;
import com.dukascopy.api.feed.IRenkoBar;
import com.dukascopy.api.feed.IRenkoBarFeedListener;
import com.dukascopy.api.IIndicators.AppliedPrice;
import com.dukascopy.api.IEngine.OrderCommand;
import static com.dukascopy.api.IOrder.State.*;
import com.dukascopy.api.instrument.IInstrumentGroup;

public class ReportStrategy implements IStrategy , IRenkoBarFeedListener {
    private IEngine engine;
    private IConsole console;
    private IHistory history;
    private IContext context;
    private IIndicators indicators;
    private IUserInterface userInterface;
    
    @Configurable("Instrument:")   public Instrument selectedInstrument = Instrument.XAUUSD;
    @Configurable("OfferSide:")    public OfferSide selectedOfferSide = OfferSide.ASK;
    @Configurable("Chart 1 > BrickSizeInPips:") public int BrickSizeInPips = 10;    
    @Configurable("Chart 1 > Renko type:")   public RenkoType renkoType = RenkoType.MEDIAN;     
    @Configurable("SuperTrend_a on Chart1:")  public int    sp_v1 = 3; 
    @Configurable("SuperTrend_b on Chart1:")  public double sp_v2 = 9.2; 
    
    private PriceRange renkoPriceRange;
    private IFeedDescriptor feed_chart1;
    private PriceRange selectedPriceRange;
    

    @Override
    public void onStart(IContext context) throws JFException {
        this.engine = context.getEngine();
        this.console = context.getConsole();
        this.history = context.getHistory();
        this.context = context;
        this.indicators = context.getIndicators();
        this.userInterface = context.getUserInterface();
        
        
        this.selectedPriceRange = PriceRange.valueOf(BrickSizeInPips);
        this.context.subscribeToRenkoBarFeed(selectedInstrument,selectedOfferSide, selectedPriceRange, this);
        this.feed_chart1 = new FeedDescriptor();
        feed_chart1.setDataType(DataType.RENKO);
        feed_chart1.setRenkoType(renkoType);
        feed_chart1.setInstrument(selectedInstrument);
        feed_chart1.setOfferSide(selectedOfferSide);
        feed_chart1.setPriceRange(selectedPriceRange);
        renkoPriceRange = PriceRange.valueOf(BrickSizeInPips);
        IChart chart = context.getChart(selectedInstrument); 
        if (chart == null) {
           context.openChart(feed_chart1);
        }        
     
    }

    private void print(String message) {
        console.getOut().println(message);
    }
    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 {
    }

    public void onBar(Instrument instrument, OfferSide offerSide, PriceRange brickSize, IRenkoBar renkoBar){
    
      double chart1_bar1_open = 0, chart1_bar1_close = 0, sp = 0;
     
      if (instrument != this.selectedInstrument) {
            return;
      }    
      
      try
      {
         if (offerSide.equals(selectedOfferSide)
               && feed_chart1.getRenkoType() == renkoType)
               {
                 IBar Bar1 = history.getRenkoBar(selectedInstrument, selectedOfferSide, renkoPriceRange, 1);
                 chart1_bar1_open = Bar1.getOpen();
                 chart1_bar1_close = Bar1.getClose();
                 print("Chart 1 > Bar 1 OPEN  = " + chart1_bar1_open + "   " + "Bar 1 CLOSE = " + chart1_bar1_close);                   
                 sp = getsuperTrend(feed_chart1,sp_v1, sp_v2);
                 console.getOut().println("Chart1 > sp5: "+sp);
                                                                            
         }

        }catch(Exception ex){
          print("Exception:"+ex.getMessage());
        }
    }

    public double getsuperTrend(IFeedDescriptor obj, int val1, double val2) throws JFException{
       double val=0;
       try{
          double [] spVal = indicators.superTrend(obj, AppliedPrice.CLOSE, selectedOfferSide, val1, val2).calculate(1); 
          val = !Double.isNaN((double) spVal[0]) ? (double) spVal[0] : (double) spVal[1];
         
          }catch (Exception e){
            print("Error to getsuperTrend");
            val=-1;
            }
      return val;
    }


}//end class