// Copyright (c) 2009 Dukascopy (Suisse) SA. All Rights Reserved.
package jforex.feed.test.out;

import java.util.Arrays;
import java.util.HashSet;
import java.util.List;

import com.dukascopy.api.*;
import com.dukascopy.api.IIndicators.AppliedPrice;
import com.dukascopy.api.feed.*;
import com.dukascopy.api.feed.util.*;

/**
 下記フィード操作を行います
   - フィード登録し、最新のフィードデータをログ出力します
   - フィードディスクリプタでヒストリーを取得します
   - フィードディスクリプタでインジケータ算出します
   - フィードチャートを開きます
 */
public class FeedHistIndFromList implements IStrategy, IFeedListener {

    private IConsole console;
    private IHistory history;
    private IIndicators indicators;

    @Configurable(value = "フィードタイプ", description = "パラメータダイアログでフィードタイプを選択します")
    public IFeedDescriptor feedDescriptor = new RangeBarFeedDescriptor(Instrument.EURUSD, PriceRange.TWO_PIPS, OfferSide.ASK);
    @Configurable("チャートを開く")
    public boolean openChart = false;
    
    final int dataCount = 3;

    @Override
    public void onStart(IContext context) throws JFException {

        history = context.getHistory();
        console = context.getConsole();
        indicators = context.getIndicators();
        
        if(feedDescriptor.getDataType() == DataType.TICKS){
            console.getErr().println("IFeedListener does not work with ticks yet!");
            context.stop();
        }

        context.setSubscribedInstruments( new HashSet<Instrument>(
                                              Arrays.asList(
                                                  new Instrument[] { feedDescriptor.getInstrument() }
                                              )
                                              ),
                                             true
                                   );

        if(openChart){            
            IChart chart = context.openChart(feedDescriptor);
            chart.add(indicators.getIndicator("EMA"), new Object[] { 12 });
        }

        console.getOut().println("subscribe to feed=" + feedDescriptor);
        context.subscribeToFeed(feedDescriptor, this);

    }

    @Override
    public void onFeedData(IFeedDescriptor feedDescriptor, ITimedData feedData) {
        console.getOut().println(feedData + " of feed: " + feedDescriptor);
        try {
            ITimedData lastFeedData = history.getFeedData(feedDescriptor, 0); //currently forming feed element
            List<ITimedData> feedDataList = history.getFeedData(feedDescriptor, dataCount, feedData.getTime(), 0);

            double[] ema = indicators.ema(
                                feedDescriptor,
                                AppliedPrice.CLOSE,
                                feedDescriptor.getOfferSide(),
                                12
                            ).calculate(dataCount,
                                feedData.getTime(),
                                0
                            );

            String feedDataName = feedData.getClass().getInterfaces()[0].getSimpleName();
            console.getOut().format("%s last=%s, previous=%s,\n previous 3 elements=%s \n ema for last 3=%s",
                                    feedDataName,
                                    lastFeedData,
                                    feedData,
                                    feedDataList,
                                    Arrays.toString(ema)
            ).println();

        } catch (JFException e) {
            console.getErr().println(e);
            e.printStackTrace();
        }
    }


    @Override
    public void onTick(Instrument instrument, ITick tick) throws JFException {    }
    @Override
    public void onBar(Instrument instrument, Period period, IBar askBar, IBar bidBar) throws JFException {    }
    @Override
    public void onMessage(IMessage message) throws JFException {    }
    @Override
    public void onAccount(IAccount account) throws JFException {    }
    @Override
    public void onStop() throws JFException {    }
}