import java.io.*;
import java.util.*;
import gnu.io.*;

public class LinkSerial extends Link {
	protected SerialPort p = null;
	protected BufferedReader i = null;
	protected InputStream inputStream = null;
	protected InputStreamReader is = null;
	protected PrintWriter o = null;

	protected String wantedPortName;
	protected int serialSpeed;

	public LinkSerial(IniFile ini) {
		wantedPortName = ini.getValueSafe("SERIAL", "port","COM4");
		serialSpeed = Integer.parseInt(ini.getValueSafe("SERIAL", "speed", "57600"));
	}
	
	public LinkSerial(String serialPort, int speed) {
		wantedPortName=serialPort;
		serialSpeed=speed;
	}
		
	public boolean Connect() {
		/* Get all available ports */
		Enumeration portIdentifiers = CommPortIdentifier.getPortIdentifiers();

		/* Find requested port */
		CommPortIdentifier portId = null;
		while (portIdentifiers.hasMoreElements()) {
			CommPortIdentifier p = (CommPortIdentifier)portIdentifiers.nextElement();
			if (p.getPortType() == CommPortIdentifier.PORT_SERIAL && p.getName().equals(wantedPortName)) {
				portId = p;
				break;
			}
		}

		/* Found port? */
		if (portId == null) {
			System.err.println("# Failed to find serial port.");
			return false;
		}

		/* Open port */
		try {
			p = (SerialPort)portId.open("name", 100);
		} catch (PortInUseException e) {
			System.err.println("# Serial port already in use." + e);
			return false;
		}

		/* Setup port */
		try {
			p.setSerialPortParams(serialSpeed, SerialPort.DATABITS_8, SerialPort.STOPBITS_1, SerialPort.PARITY_NONE);
			p.enableReceiveTimeout(65000); /* as long of timeout as possible, fight win32 rxtx bug */
		} catch ( Exception e ) {
			System.err.println("# Error configuring serial port.");
			return false;
		}

		/* Create streams for port */
		try {
			inputStream = p.getInputStream();
			is = new InputStreamReader(p.getInputStream());
			i = new BufferedReader(is);
			o = new PrintWriter(p.getOutputStream(), true);
		} catch (IOException e) {
			System.err.println("# Failed to create stream.");
			return false;
		}

		p.disableReceiveThreshold();

		return true;
	}
	
	public void sendLine(String s) {
		try {
			o.print(s);
			o.flush();
		} catch ( Exception e ) {
			System.err.println("# sendLine had an exception: " + e);
		}
	}
	
	public boolean dataReady ( ) {
		try {
			return i.ready();
		} catch ( Exception E ) {
			return false;
		}
	}
	
	public int[] getRawPacket(char startsWith, int len) {
		int [] buff=new int[len];
		int n;
		
		try {
			while ( startsWith != inputStream.read() ) {
			}
			
			buff[0]=startsWith;
			
			for ( n=1 ; n<len ; n++ ) {
				buff[n]=inputStream.read();
			}
			
		} catch (IOException e) {
			e.printStackTrace();
			return null;
		}
		
		
		return buff;
	}
	
	public String getLine() {
		String line;

      while ( true ) {
			try {
				line=i.readLine();
				
				/* reached the end of the stream */
				if ( line == null ) {
					break;
				}
			} catch ( IOException e ) {
				System.err.println("# readLine had an exception. Probably due to windows rxtx bug: " + e);
				continue;
			}
			
			if ( line != null ) {
				return line;
			}
		}

		return "";

/*
		try {
			line = i.readLine();
		} catch (IOException e) {
			line = null;
		}
		return line;
*/
	}
	
	public boolean Disconnect() {
		try {
			o.close();
			i.close();
			p.close();
		} catch (IOException e) {
			System.err.println("Failed to close.");
			return false;
		}

		return true;
	}


    public void emptyInputBuffer() {
      try {
         while ( i.ready() ) {
            i.read();
            //System.err.print(".");
         }
      } catch (IOException e) {
         e.printStackTrace();
      }

    }


}