package ie.jackhiggins.csvsender;

import java.io.IOException;
import java.net.*;
import java.util.ArrayList;
import java.util.logging.Level;
import java.util.logging.Logger;
import org.jumpmind.symmetric.csv.CsvReader;

/**
 * Hello world!
 *
 */
public class App
{
    private static DatagramSocket dgramSock;
    private static InetAddress address;
    public static void main(String[] args) throws IOException {

        try {
            dgramSock = new DatagramSocket(11000);
        } catch (SocketException ex) {
            //Logger.getLogger(SignalToNoise.class.getName()).log(Level.SEVERE, null, ex);
        }


        try {
            address = InetAddress.getByName("10.172.8.59");
        } catch (UnknownHostException ex) {
            //Logger.getLogger(SignalToNoise.class.getName()).log(Level.SEVERE, null, ex);
        }
        int port = 11000;

        Thread volSender = new Thread(new VolSender());
        volSender.start();

        try {
            ReadFromCSV();
        } catch (Exception ex) {
            Logger.getLogger(App.class.getName()).log(Level.SEVERE, null, ex);
        }

    }

    private static void ReadFromCSV() throws Exception {
        while(true){
            CsvReader reader = new CsvReader("C:\\Users\\Jack\\Desktop\\EURUSD_Ticks_02.03.2012-03.03.2012.csv",',');
            reader.readHeaders();
            while(reader.readRecord()){
                float bid = Float.parseFloat(reader.get(1));
                float ask = Float.parseFloat(reader.get(2));
                float bidVol = Float.parseFloat(reader.get(3));
                float askVol = Float.parseFloat(reader.get(4));

                SendBid(bid,bidVol);
                Thread.sleep(100);
                SendAsk(ask,askVol);
                Thread.sleep(100);
            }
        }

    }

    private static void SendBid(float price, float vol){
        //Bid:3.92:BTC:4.4443 USD\n
        SendDatagram("Bid:"+vol+":BTC:"+price+ " USD");
    }

    private static void SendAsk(float price, float vol){
        SendDatagram("Ask:"+vol+":BTC:"+price+ " USD");
    }

    private static void SendVol(float vol){
        //"Vol:19,460.94985697 BTC#High:$4.73800#Low:$4.58000#Avg:$4.66883#Last:$4.64571";
        //System.out.println(vol);
        SendDatagram("Vol:"+vol);
    }

    private static void SendDatagram(String text){
                byte[] buf = text.getBytes();

        DatagramPacket packet = new DatagramPacket(buf, buf.length, address, 11000);
        try {
            dgramSock.send(packet);
        } catch (IOException ex) {
            Logger.getLogger(App.class.getName()).log(Level.SEVERE, null, ex);
        }
        double d = 1.2;
        float f = Float.parseFloat(d+"");
    }




    static class VolSender implements Runnable{

        private int interpolPoints = 100;

        public void run() {
            while(true){
                try{
                    CsvReader reader = new CsvReader("C:\\Users\\Jack\\Desktop\\SPX500.csv",',');
                    float prevVol = 0;

                    while(reader.readRecord()){
                        float vol = Float.parseFloat(reader.get(1));

                        float interpolDiff = (vol - prevVol)/interpolPoints;

                        for(int i=0;i<interpolPoints-1;i++){
                            float toSend = prevVol+(interpolDiff*(i+1));
                            SendVol(toSend);
                            Thread.sleep(10);
                        }
                        prevVol = vol;

                    }
                }catch(Exception e){

                }

            }
        }

    }
}