/*
 * The MIT License (MIT)
 * 
 * Copyright (c) 2015 rusty-objects, http://rusty-objects.github.io
 * 
 * Permission is hereby granted, free of charge, to any person obtaining a copy
 * of this software and associated documentation files (the "Software"), to deal
 * in the Software without restriction, including without limitation the rights
 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
 * copies of the Software, and to permit persons to whom the Software is
 * furnished to do so, subject to the following conditions:
 * 
 * The above copyright notice and this permission notice shall be included in
 * all copies or substantial portions of the Software.
 * 
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
 * THE SOFTWARE.
 */

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

public class HelloWorld {

    private static final String PORT_NAME = "/dev/cu.RNBT-73C3-RNI-SPP";
    private static final int RATE     = 115200;
    private static final int DATABITS = 8;
    private static final int PARITY   = SerialPort.PARITY_NONE;
    private static final int STOPBITS = SerialPort.STOPBITS_1;

    public static void main(String argv[]) throws Exception {
        
        SerialPort port = null;
        InputStream input = null;
        OutputStream output = null;
        try {
            /*
             * Instantiate Serial Port
             */
            Enumeration portList = CommPortIdentifier.getPortIdentifiers();
            while (portList.hasMoreElements()) {
                CommPortIdentifier portId = (CommPortIdentifier) portList.nextElement();
                System.err.println("Found comm port: " + portId.getName());
        
                if (portId.getPortType() == CommPortIdentifier.PORT_SERIAL) {
                    if (portId.getName().equals(PORT_NAME)) {
                        port = (SerialPort)portId.open("hello world", 20_000);
                        input  = port.getInputStream();
                        output = port.getOutputStream();
                        port.setSerialPortParams(RATE, DATABITS, STOPBITS, PARITY);
                    }
                }
            }
            System.err.println("Open attempt: SUCCEEDED");
    
            /*
             * Kick the port
             */
            port.setDTR(false);
            try { Thread.sleep(500); } catch(Exception e) { }
            port.setDTR(true);

            /*
             * Speak!
             */
            if (output == null) return;
            System.err.println("Sending bytes");
            byte[] bytes = toBytes(new int[] {
                128, 132,
                140, 0, 1, 62, 32,
                141, 0
            });
            for (int i = 0; i < bytes.length; i++) {
                output.write(bytes[i]);
                Thread.sleep(250);
            }
            output.flush();
        } finally {
            if (input != null) input.close();
            if (output != null) output.close();
            if (port != null) port.close();
            System.err.println("Disconnected");
        }

    }

    private static byte[] toBytes(int[] input) {
        byte[] bytes = new byte[input.length];
        for (int i = 0; i < input.length; i++) bytes[i] = (byte) (input[i] & 0xff);
        return bytes;
    }

}

/*
 * The MIT License (MIT)
 * 
 * Copyright (c) 2015 rusty-objects, http://rusty-objects.github.io
 * 
 * Permission is hereby granted, free of charge, to any person obtaining a copy
 * of this software and associated documentation files (the "Software"), to deal
 * in the Software without restriction, including without limitation the rights
 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
 * copies of the Software, and to permit persons to whom the Software is
 * furnished to do so, subject to the following conditions:
 * 
 * The above copyright notice and this permission notice shall be included in
 * all copies or substantial portions of the Software.
 * 
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
 * THE SOFTWARE.
 */

import com.fazecast.jSerialComm.*;
import java.io.*;
import java.util.*;

public class HelloWorld {

    private static final String PORT_NAME = "/dev/cu.RNBT-73C3-RNI-SPP";
    private static final int RATE     = 115200;
    private static final int DATABITS = 8;
    private static final int PARITY   = SerialPort.NO_PARITY;
    private static final int STOPBITS = SerialPort.ONE_STOP_BIT;

    public static void main(String argv[]) throws Exception {
        
        SerialPort port = null;
        InputStream input = null;
        OutputStream output = null;
        try {
            /*
             * Instantiate Serial Port
             */
            for (SerialPort p : SerialPort.getCommPorts()) {
                if (p.getSystemPortName().equals(PORT_NAME)) port = p;
                System.err.println("Found comm port: " + p.getSystemPortName());
            }
            if (port == null) throw new IllegalStateException("Couldn't find: " + PORT_NAME);
    
            /*
             * Connect
             */
            boolean opened = port.openPort();
            System.err.println("Open attempt: " + (opened?"SUCCEEDED":"FAILED"));
            input = port.getInputStream();
            output = port.getOutputStream();
            port.setComPortParameters(RATE, DATABITS, STOPBITS, PARITY);
    
            /*
             * Kick the port
             */
            int settings = port.getFlowControlSettings();
            port.setFlowControl(settings ^ SerialPort.FLOW_CONTROL_DTR_ENABLED);
            try { Thread.sleep(500); } catch(Exception e) { }
            port.setFlowControl(settings);
    
            /*
             * Speak!
             */
            if (output == null) return;
            System.err.println("Sending bytes");
            byte[] bytes = toBytes(new int[] {
                128, 132,
                140, 0, 1, 62, 32,
                141, 0
            });
            for (int i = 0; i < bytes.length; i++) {
                output.write(bytes[i]);
                Thread.sleep(250); // seems to work better when I slow things down
            }
            output.flush();
        } finally {
            if (input != null) input.close();
            if (output != null) output.close();
            boolean success = false;
            if (port != null) success = port.closePort();
            System.err.println("Disconnected: " + success);
        }

    }

    private static byte[] toBytes(int[] input) {
        byte[] bytes = new byte[input.length];
        for (int i = 0; i < input.length; i++) bytes[i] = (byte) (input[i] & 0xff);
        return bytes;
    }

}