package jforex.data;

import java.io.PrintStream;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Collection;
import java.util.List;
import java.util.TreeMap;

import com.dukascopy.api.Configurable;
import com.dukascopy.api.IAccount;
import com.dukascopy.api.IBar;
import com.dukascopy.api.IConsole;
import com.dukascopy.api.IContext;
import com.dukascopy.api.IHistory;
import com.dukascopy.api.IMessage;
import com.dukascopy.api.IStrategy;
import com.dukascopy.api.ITick;
import com.dukascopy.api.Instrument;
import com.dukascopy.api.JFException;
import com.dukascopy.api.LoadingDataListener;
import com.dukascopy.api.LoadingProgressListener;
import com.dukascopy.api.OfferSide;
import com.dukascopy.api.Period;
import com.dukascopy.api.util.DateUtils;

 
public class ReadTicksVsLiveMap implements IStrategy {
    
    @Configurable("")
    public Period period = Period.TEN_SECS;
    @Configurable("")
    public Instrument instrument = Instrument.EURUSD;
    @Configurable("log ticks")
    public boolean log = false;
        
    private TreeMap<Long, ITick> liveTicks;
    private IHistory history;
    private IConsole console;
    
    @Override
    public void onStart(IContext context) throws JFException {
        history = context.getHistory();
        console = context.getConsole();

    }

    @Override
    public void onTick(Instrument instrument, ITick tick) throws JFException {
        if(this.instrument != instrument || liveTicks == null){
            return;
        }
        liveTicks.put(tick.getTime(), tick);
        
    }

    @Override
    public void onBar(Instrument instrument, Period period, IBar askBar, IBar bidBar) throws JFException {
        if(this.instrument != instrument || this.period != period){
            return;
        }
        //should happen only on the first bar - start collecting live ticks
        if(liveTicks == null){
            liveTicks = new TreeMap<Long, ITick>();
            return; //since we have not collected any live ticks yet
        }
        if(liveTicks.size() > 1000){  
           if(log){
              console.getInfo().println("Clear live tick map");
           }
            liveTicks = new TreeMap<Long, ITick>();
            return; 
        }  
        
        long from = bidBar.getTime();
        long to = bidBar.getTime() + period.getInterval() - 1;
        List<Tk> liveTicksChunk = Tk.getInfos(liveTicks.subMap(from, true, to, true).values());
        compareWithReadTicks(from, to, liveTicksChunk);
    }
    
    private void compareWithReadTicks(final long from, final long to, final List<Tk> liveTicks) throws JFException {
        final List<Tk> readTicks = new ArrayList<Tk>();
         history.readTicks(
                 instrument, 
                 from, 
                 to - 1, //allow 1ms reserve for live ticks, since this is another thread
                 new LoadingDataListener() {  
                     @Override
                     public void newTick(Instrument instrument, long time, double ask, double bid, double askVol, double bidVol) {
                         readTicks.add(new Tk(ask, bid, time));
                     }

                     @Override
                     public void newBar(Instrument instrument, Period period, OfferSide side, long time, double open, double close, double low, double high, double vol) {
                         // no bars expected
                     }
                 },
                 new LoadingProgressListener() {

                     @Override
                     public void dataLoaded(long start, long end, long currentPosition, String information) {
                     }

                     @Override  
                     public void loadingFinished(boolean allDataLoaded, long start, long end, long currentPosition) {
                         compareTickLists( liveTicks,"liveTicks", readTicks, "readTicks", from, to);
                     }

                     @Override
                     public boolean stopJob() {
                         return false;
                     }
                 });

    }
    
    private void compareTickLists(List<Tk> list1, String info1, List<Tk> list2, String info2, long from, long to){
        if(!list1.equals(list2)){
            console.getErr().format("%s != %s", info1, info2).println();
            logAllTicks(console.getErr(), list1,info1, list2, info2, from, to);  
            List<Tk> temp = new ArrayList<Tk>(list2);
            list2.removeAll(list1);
            list1.removeAll(temp);
            console.getErr().format("%1$s not in %2$s:\n %3$s \n %2$s not in %1$s:\n %4$s", info1, info2, list1, list2).println();
        } else if(log){
            logAllTicks(console.getOut(),list1,info1, list2, info2, from, to);
        }
    }
    
    private void logAllTicks(PrintStream ps, List<?> list1, String info1, List<?> list2, String info2, long from, long to){
        ps.format("%s <- %s %s\n %s <- %s %s\n %s - %s", 
                list1, list1.size(), info1, 
                list2, list2.size(), info2,
                DateUtils.format(from), DateUtils.format(to)).println();  
    }

    @Override
    public void onMessage(IMessage message) throws JFException {}

    @Override
    public void onAccount(IAccount account) throws JFException {}

    @Override
    public void onStop() throws JFException {}
    
    /**
     * Convenience class for tick data comparisons and more concise logging
     */
    private static class Tk {
        
        private static final SimpleDateFormat TIME_FORMAT = new SimpleDateFormat("HH:mm:ss:SSS");
        static {
            TIME_FORMAT.setTimeZone(DateUtils.GMT_TIME_ZONE);
        }
        
        private final double ask;
        private final double bid;
        private final long time;
        
        Tk(ITick tick){
            ask = tick.getAsk();
            bid = tick.getBid();
            time = tick.getTime();
        }
        
        Tk(double ask, double bid, long time){
            this.ask = ask;
            this.bid = bid;        
            this.time = time;
        }
        
        static List<Tk> getInfos(Collection<ITick> ticks){
            List<Tk> list = new ArrayList<Tk>();
            for(ITick t : ticks){
                list.add(new Tk(t));
            }
            return list;
        }
        
        @Override
        public String toString(){
            return String.format("%s %s %s", TIME_FORMAT.format(time), bid, ask);
        }

        @Override
        public int hashCode() {
            final int prime = 31;
            int result = 1;
            long temp;
            temp = Double.doubleToLongBits(ask);
            result = prime * result + (int) (temp ^ (temp >>> 32));
            temp = Double.doubleToLongBits(bid);
            result = prime * result + (int) (temp ^ (temp >>> 32));
            result = prime * result + (int) (time ^ (time >>> 32));
            return result;
        }

        @Override
        public boolean equals(Object obj) {
            if (this == obj)
                return true;
            if (obj == null)
                return false;
            if (getClass() != obj.getClass())
                return false;
            Tk other = (Tk) obj;
            if (Double.doubleToLongBits(ask) != Double.doubleToLongBits(other.ask))
                return false;
            if (Double.doubleToLongBits(bid) != Double.doubleToLongBits(other.bid))
                return false;
            if (time != other.time)
                return false;
            return true;
        }
    }

}

package test;

import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
import java.io.FileWriter;
import java.sql.Date;
import java.text.SimpleDateFormat;
import java.util.HashSet;
import java.util.Set;
import java.util.TimeZone;
import java.util.TreeMap;

import com.dukascopy.api.IAccount;
import com.dukascopy.api.IBar;
import com.dukascopy.api.IContext;
import com.dukascopy.api.IMessage;
import com.dukascopy.api.IStrategy;
import com.dukascopy.api.ITick;
import com.dukascopy.api.Instrument;
import com.dukascopy.api.JFException;
import com.dukascopy.api.Period;
import com.dukascopy.api.system.ClientFactory;
import com.dukascopy.api.system.IClient;

public class TestOnTickVsReadTicks extends Thread implements IStrategy {

   public static String dir = "/home/user/tmp/data";
   private FileWriter fileWriter;

   private String format(long time) {
      try {
         Date date = new Date(time);

         SimpleDateFormat sdf = new SimpleDateFormat(
               "yyyy-MM-dd HH:mm:ss.SSS");
         sdf.setTimeZone(TimeZone.getTimeZone("UTC"));
         return sdf.format(date);

      } catch (Exception ex) {
         ex.printStackTrace();
         System.exit(1);
      }

      return null;
   }

   @Override
   public void onStart(IContext context) throws JFException {
      // TODO Auto-generated method stub

   }

   @Override
   public void onTick(Instrument instrument, ITick tick) throws JFException {
      try {
         if (fileWriter == null) {
            File d = new File(dir);
            if (!d.exists()) {
               d.mkdirs();
            }
            fileWriter = new FileWriter(dir + "/" + instrument.toString().replace("/", "") + ".csv");
         } else {
            String str = format(tick.getTime()) + "," + tick.getBid() + "," + tick.getAsk() + "\n";
            System.out.print(instrument.toString().replace("/", "") + "," + str);
            fileWriter.write(str);
            fileWriter.flush();
         }
      } catch (Exception ex) {
         ex.printStackTrace();
         System.exit(1);
      }
   }

   @Override
   public void onBar(Instrument instrument, Period period, IBar askBar,
         IBar bidBar) throws JFException {
      // TODO Auto-generated method stub

   }

   @Override
   public void onMessage(IMessage message) throws JFException {
      // TODO Auto-generated method stub

   }

   @Override
   public void onAccount(IAccount account) throws JFException {
      // TODO Auto-generated method stub

   }

   @Override
   public void onStop() throws JFException {
      // TODO Auto-generated method stub

   }

   @Override
   public void run() {
      String jnlpHttpUrl_Real = "https://www.dukascopy.com/client/live/jclient/jforex.jnlp";
      String userName_Real = "user";
      String password_Real = "password";
   
      
      try {
         IClient client = ClientFactory.getDefaultInstance();
         
         while (true) {
            client.connect(jnlpHttpUrl_Real, userName_Real, password_Real);
            
            int i = 10; // wait max ten seconds
            while (i > 0 && !client.isConnected()) {
               Thread.sleep(1000);
               i--;
            }
   
            if (client.isConnected()) {
               System.out.println("connected");
               break;
            } else {
               System.out.println("not connected");
            }
         }
         
         Set<Instrument> instruments = new HashSet<Instrument>();
         instruments.add(Instrument.EURUSD); 

         client.setSubscribedInstruments(instruments);
         
         client.startStrategy(this);
         
      } catch (Exception ex) {
         ex.printStackTrace();
         System.exit(1);
      }
   }
   
   private static long parse(String str) {
      return parse(str, "yyyy-MM-dd HH:mm:ss.SSS", TimeZone.getTimeZone("UTC"));
   }
   
   private static long parse(String dateTime, String format, TimeZone timeZone) {
      try
        {
            SimpleDateFormat sdf = new SimpleDateFormat(format);
            sdf.setTimeZone(timeZone);
            return sdf.parse(dateTime).getTime();
        }
        catch(Exception ex)
        {
           System.exit(1);
           return 0;
        }
   }
   
   public static void main(String[] args) {
      if (args.length != 1) {
         System.out.println("args.length != 1");
         System.exit(1);
      }
      
      if (args[0].equals("-Writer")) {
         TestOnTickVsReadTicks test = new TestOnTickVsReadTicks();
         test.start();
      } else if (args[0].equals("-Compare")) {
         try {
            TreeMap<Long, ITick> liveTicks = new TreeMap<Long, ITick>();
            BufferedReader reader = new BufferedReader(new FileReader(TestOnTickVsReadTicks.dir + "/EURUSD.csv"));
            String line;
            
            while ((line = reader.readLine()) != null) {
               String[] sArray = line.split(",");
               long time = parse(sArray[0]);
               double bid = Double.parseDouble(sArray[1]);
               double ask = Double.parseDouble(sArray[2]);
                
               ITick tick = new Tick(time, bid, ask);
               liveTicks.put(time, tick);
            }
            reader.close();
            
            System.out.println("TODO: just compare TreeMap<Long, ITick> liveTicks with readTicks");
         } catch (Exception ex) {
            ex.printStackTrace();
            System.exit(1);
         }
      } else {
         System.out.println("bad args");
         System.exit(1);
      }
      
   }
   
   private static class Tick implements ITick {

      private long time;
      private double bid;
      private double ask;
      
      
      public Tick(long time, double bid, double ask) {
         super();
         this.time = time;
         this.bid = bid;
         this.ask = ask;
      }

      @Override
      public long getTime() {
         return time;
      }

      @Override
      public double getAsk() {
         return ask;
      }

      @Override
      public double getBid() {
         return bid;
      }

      @Override
      public double getAskVolume() {
         // TODO Auto-generated method stub
         return 0;
      }

      @Override
      public double getBidVolume() {
         // TODO Auto-generated method stub
         return 0;
      }

      @Override
      public double[] getAsks() {
         // TODO Auto-generated method stub
         return null;
      }

      @Override
      public double[] getBids() {
         // TODO Auto-generated method stub
         return null;
      }

      @Override
      public double[] getAskVolumes() {
         // TODO Auto-generated method stub
         return null;
      }

      @Override
      public double[] getBidVolumes() {
         // TODO Auto-generated method stub
         return null;
      }

      @Override
      public double getTotalAskVolume() {
         // TODO Auto-generated method stub
         return 0;
      }

      @Override
      public double getTotalBidVolume() {
         // TODO Auto-generated method stub
         return 0;
      }
      
   }
}
 

• If your program uses some parameters, please describe with which parameters it should get launched.
• If the program has to be launched multiple times, please describe the run order.
• If the program does not give itself the errors that you report as error statements (as it is done, for example, in the case that we provided) then please describe how otherwise program demonstrates the error.
• We do all the testing in DEMO environment.