/*
 * To change this license header, choose License Headers in Project Properties.
 * To change this template file, choose Tools | Templates
 * and open the template in the editor.
 */
package astmprotocols;

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import services.ResultSaverV2;
import util.ConfigUtil;

/**
 * @author relixus
 */
public class TestOrder extends Thread {

    ServerSocket serv;
    List l = new ArrayList();

    public TestOrder(ServerSocket serv) {
        this.serv = serv;
    }

    @Override
    public void run() {
        Socket sk = null;
        try {
            sk = serv.accept();
            String src = sk.getInetAddress() + "";
            System.out.println(new SimpleDateFormat("MMM/dd/yyyy hh:mm:ss a").format(new Date()));
            System.out.println(src);
            DataInputStream dis = new DataInputStream(sk.getInputStream());
            DataOutputStream dos = new DataOutputStream(sk.getOutputStream());
            String str = "";
            StringBuffer strb = new StringBuffer(); //FOR ASTM
            String strForVidas = new String(); //FOR MINI VIDAS
            for (;;) {
                int b = dis.readByte();
                char c = (char) b;

                //PARSE FOR MINI VIDAS
                if (b != 0x30 && b != 0x03 && b != 0x04 && b != 0x02) {
                    strForVidas = strForVidas + (char) c;
                }
                //PARSE FOR ASTM
                if (b != P400Emulator.enq
                        && b != P400Emulator.cr
                        && b != P400Emulator.lf
                        && b != P400Emulator.stx
                        && b != P400Emulator.eot
                        && b != P400Emulator.etx
                        && b != P400Emulator.record_separator) {
                    //      System.out.println((char)c+":"+(byte)c);
                    strb.append(c);
                }

                if (b == P400Emulator.enq) {
                    dos.writeByte(P400Emulator.ack);
                }

                if (b == P400Emulator.lf) {
                    //    System.out.println(strb.toString());

                    //ADD FRAME CHECKING CODE
                    l.add(strb.toString());
                    dos.writeByte(P400Emulator.ack);
                    strb = new StringBuffer();
                }

                if (b == P400Emulator.eot) {
                    System.out.println("CLOSING STREAMS");
                    dis.close();
                    dos.close();
                    sk.close();
                    break;
                }
            }
            System.out.println("SAVING RESULTS TO DB");
            if (src.equals("/" + ConfigUtil.miniVidas1Ip)) {
                new ResultSaverV2().saveResultsMiniVidas(str);
            } else {
                new ResultSaverV2().saveResults(l, src);
            }

            System.out.println("________________________________________");
            sk.close();
        } catch (Exception e) {
            e.printStackTrace();
            System.out.println("");
            System.out.println("");
        } finally {

        }
        //   this.interrupt();
    }

}