DroidStar/android/src/main/java/USBSerialWrapper.java

/*
	Copyright (C) 2019-2021 Doug McLain

	This program is free software: you can redistribute it and/or modify
	it under the terms of the GNU General Public License as published by
	the Free Software Foundation, either version 3 of the License, or
	(at your option) any later version.

	This program is distributed in the hope that it will be useful,
	but WITHOUT ANY WARRANTY; without even the implied warranty of
	MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
	GNU General Public License for more details.

	You should have received a copy of the GNU General Public License
	along with this program.  If not, see <https://www.gnu.org/licenses/>.
*/

package DroidStar;
import java.util.Arrays;
import java.util.List;
import android.content.Intent;
import android.app.PendingIntent;
import android.content.Context;
import android.hardware.usb.UsbManager;
import android.hardware.usb.UsbDeviceConnection;
import com.hoho.android.usbserial.driver.UsbSerialDriver;
import com.hoho.android.usbserial.driver.UsbSerialPort;
import com.hoho.android.usbserial.driver.UsbSerialProber;
import com.hoho.android.usbserial.util.SerialInputOutputManagerTest;

public class USBSerialWrapper implements SerialInputOutputManagerTest.Listener {
    public static int counter = 0;
    public int id;
    public Context m_context;
    public int m_baudrate = 115200;
	public int m_databits = 8;
	public int m_stopbits = 1;
	public int m_parity = 0;
	public int m_flowcontrol = 0;
	public int m_rts = 0;
	public String m_devicename;
	
    UsbSerialPort m_port;
    SerialInputOutputManagerTest usbIoManager;
    private static final String ACTION_USB_PERMISSION = "org.dudetronics.droidstar.USB_PERMISSION";
    //private final ArrayBlockingQueue<PendingUsbPermission> queuedPermissions = new ArrayBlockingQueue<>(100);
    //private volatile boolean processingPermission = false;
    //private PendingUsbPermission currentPendingPermission;

    public USBSerialWrapper() {
        this.id = counter;
        System.out.println("Created USBSerialWrapper object with id: " + this.id);
        counter++;
    }
    
    public void set_port_name(String d)
    {
		m_devicename = d;
		System.out.println("Java Devicename: " + m_devicename);
	}
    
    public void set_baud_rate(int br)
    {
		m_baudrate = br;
		System.out.println("Java Baudrate: " + br);
	}
	
	public void set_data_bits(int db)
    {
		m_databits = db;
		System.out.println("Java DataBits: " + db);
	}
	
	public void set_stop_bits(int sb)
    {
		m_stopbits = sb;
		System.out.println("Java StopBits: " + sb);
	}
	
	public void set_parity(int p)
    {
		m_parity = p;
		System.out.println("Java Parity: " + p);
	}
	
	public void set_flow_control(int fc)
    {
		m_flowcontrol = fc;
		System.out.println("Java FlowControl: " + fc);
	}
	
	public void set_rts(int rts)
    {
		m_rts = rts;
		System.out.println("Java RTS: " + rts);
	}
	
	public String[] discover_devices(Context c)
	{
		System.out.println("Java: discover_devices()");
		UsbManager manager = (UsbManager) c.getSystemService(Context.USB_SERVICE);
		List<UsbSerialDriver> availableDrivers = UsbSerialProber.getDefaultProber().findAllDrivers(manager);
		String[] devices = new String[availableDrivers.size()];
		
		if (availableDrivers.isEmpty()) {
			System.out.println("No drivers found");
		}
		else {
			System.out.println(availableDrivers.size() + " found");

			for(int i = 0; i < availableDrivers.size(); ++i){
				devices[i] = availableDrivers.get(i).getDevice().getProductName() + ":" + availableDrivers.get(i).getDevice().getDeviceName();
				System.out.println("USB device getDeviceName() == " + availableDrivers.get(i).getDevice().getDeviceName());
				System.out.println("USB device getProductName() == " + availableDrivers.get(i).getDevice().getProductName());
				System.out.println("USB device getProductId() == " + availableDrivers.get(i).getDevice().getProductId());
				System.out.println("USB device getVendorId() == " + availableDrivers.get(i).getDevice().getVendorId());
			}
		}
		return devices;
	}
	
    public String setup_serial(Context c)
    {
		m_context = c;
		int devicenum = 0;
		UsbManager manager = (UsbManager) m_context.getSystemService(Context.USB_SERVICE);
		List<UsbSerialDriver> availableDrivers = UsbSerialProber.getDefaultProber().findAllDrivers(manager);
		
		if (availableDrivers.isEmpty()) {
			System.out.println("No drivers found");
			return "returning...";
		}
		else {
			System.out.println(availableDrivers.size() + " found");
			for(int i = 0; i < availableDrivers.size(); ++i){
				System.out.println("USB device getDeviceName() == " + availableDrivers.get(i).getDevice().getDeviceName());
				System.out.println("USB device getProductName() == " + availableDrivers.get(i).getDevice().getProductName());
				System.out.println("USB device getProductId() == " + availableDrivers.get(i).getDevice().getProductId());
				System.out.println("USB device getVendorId() == " + availableDrivers.get(i).getDevice().getVendorId());
				
				//if((availableDrivers.get(i).getDevice().getDeviceName()) == m_devicename){
				if(m_devicename.equals(availableDrivers.get(i).getDevice().getDeviceName())){
					devicenum = i;
					System.out.println("Found device == " + devicenum);
					
				}
			}
		}
		
		UsbSerialDriver driver = availableDrivers.get(devicenum);
		UsbDeviceConnection connection = manager.openDevice(driver.getDevice());
		
		if (connection == null) {
			// add UsbManager.requestPermission(driver.getDevice(), ..) handling here
			
			PendingIntent mPendingIntent = PendingIntent.getBroadcast(c, 0, new Intent(ACTION_USB_PERMISSION), PendingIntent.FLAG_MUTABLE);
			manager.requestPermission(driver.getDevice(), mPendingIntent);
			return "No connection, need permission?";
		}

		m_port = driver.getPorts().get(0); // Most devices have just one port (port 0)
		
		try {
			m_port.open(connection);
			m_port.setParameters(m_baudrate, m_databits, m_stopbits, m_parity);
			m_port.setRTS(true);
			
		} catch (Exception e) {
			System.out.println("Exception: " + e.getMessage());
		}
		
		System.out.println("Created UsbManager");
		
		usbIoManager = new SerialInputOutputManagerTest(m_port, this);
		usbIoManager.start();
		
		return "Yipee!";
	}
	
	public void write(byte[] data)
	{
		try {
			m_port.write(data, 0);
		} catch (Exception e) {
			System.out.println("Exception: " + e.getMessage());
		}
	}
	
	public byte[] read()
	{
		byte[] buffer = new byte[1024];
		int r = 0;
		
		try {
			r = m_port.read(buffer, 0);
		} catch (Exception e) {
			System.out.println("Exception: " + e.getMessage());
		}
		
		byte[] returnbytes = Arrays.copyOf(buffer, r);
		return returnbytes;
	}
	
	@Override
	public void onNewData(byte[] data) {
		data_received(data);
	}
	
	@Override
	public void onRunError(Exception e) {
		System.out.println("Exception: " + e.getMessage());
	}
	
	private static native void data_received(byte[] data);
}