brendan-myers / rpi3-wifi-conf-android Goto Github PK

BluetoothSocket mmSocket;

Spinner devicesSpinner;
Button refreshDevicesButton;
TextView ssidTextView;
TextView pskTextView;
Button startButton;
TextView messageTextView;
Button getSsidButton;

private DeviceAdapter adapter_devices;

final UUID uuid = UUID.fromString("815425a5-bfac-47bf-9321-c5ff980b5e11");
final byte delimiter = 33;
int readBufferPosition = 0;

@Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_main);

    ssidTextView = (TextView) findViewById(R.id.ssid_text);
    pskTextView = (TextView) findViewById(R.id.psk_text);
    messageTextView = (TextView) findViewById(R.id.messages_text);

    devicesSpinner = (Spinner) findViewById(R.id.devices_spinner);

    refreshDevicesButton = (Button) findViewById(R.id.refresh_devices_button);
    startButton = (Button) findViewById(R.id.start_button);
    getSsidButton = (Button) findViewById(R.id.get_ssid_button);


    refreshDevicesButton.setOnClickListener(new View.OnClickListener() {
        @Override
        public void onClick(View v) {
            refreshDevices();
        }
    });

    getSsidButton.setOnClickListener(new View.OnClickListener() {
        @Override
        public void onClick(View v) {

            String ssid = ssidTextView.getText().toString();
            String psk = pskTextView.getText().toString();

            BluetoothDevice device = (BluetoothDevice) devicesSpinner.getSelectedItem();
            getSsid();

        }
    });


    startButton.setOnClickListener(new View.OnClickListener() {
        @Override
        public void onClick(View v) {
            String ssid = ssidTextView.getText().toString();
            String psk = pskTextView.getText().toString();

            BluetoothDevice device = (BluetoothDevice) devicesSpinner.getSelectedItem();
            (new Thread(new workerThread(ssid, psk, device))).start();
        }
    });

    refreshDevices();
}

private void refreshDevices() {
    adapter_devices = new DeviceAdapter(this, R.layout.spinner_devices, new ArrayList<BluetoothDevice>());
    devicesSpinner.setAdapter(adapter_devices);

    BluetoothAdapter mBluetoothAdapter = BluetoothAdapter.getDefaultAdapter();

    if (!mBluetoothAdapter.isEnabled()) {
        Intent enableBluetooth = new Intent(BluetoothAdapter.ACTION_REQUEST_ENABLE);
        startActivityForResult(enableBluetooth, 0);
    }

    Set<BluetoothDevice> pairedDevices = mBluetoothAdapter.getBondedDevices();
    if (pairedDevices.size() > 0) {
        for (BluetoothDevice device : pairedDevices) {
            adapter_devices.add(device);
        }
    }
}

private void getSsid() {


    String control_value;



    String ssid2 = ssidTextView.getText().toString();
    String psk2 = pskTextView.getText().toString();

    BluetoothDevice device2 = (BluetoothDevice) devicesSpinner.getSelectedItem();




    clearOutput();

    writeOutput("Connecting to RPI");

    writeOutput("Device: " + device2.getName() + " - " + device2.getAddress());

    try {
        mmSocket = device2.createRfcommSocketToServiceRecord(uuid);
        if (!mmSocket.isConnected()) {
            mmSocket.connect();
            Thread.sleep(1000);
        }

        control_value = "1";


        writeOutput(control_value);



        OutputStream mmOutputStream = mmSocket.getOutputStream();
        final InputStream mmInputStream = mmSocket.getInputStream();

        waitForResponse(mmInputStream, -1);

        writeOutput("Connected.");

        writeOutput("Requesting SSIDs");

        mmOutputStream.write(control_value.getBytes());
        mmOutputStream.flush();
        waitForResponse(mmInputStream, -1);


        mmSocket.close();

        writeOutput("Success.");



    } catch (Exception e) {
        // TODO Auto-generated catch block
        e.printStackTrace();

        writeOutput("Failed.");
    }

    writeOutput("Done.");


}


private void writeOutput(final String text) {
    runOnUiThread(new Runnable() {
        @Override
        public void run() {
            String currentText = messageTextView.getText().toString();
            messageTextView.setText(currentText + "\n" + text);
        }
    });
}

private void clearOutput() {
    runOnUiThread(new Runnable() {
        @Override
        public void run() {
            messageTextView.setText("");
        }
    });
}

/*
 * TODO actually use the timeout
 */
private void waitForResponse(InputStream mmInputStream, long timeout) throws IOException {
    int bytesAvailable;

    while (true) {
        bytesAvailable = mmInputStream.available();
        if (bytesAvailable > 0) {
            byte[] packetBytes = new byte[bytesAvailable];
            byte[] readBuffer = new byte[1024];
            mmInputStream.read(packetBytes);

            for (int i = 0; i < bytesAvailable; i++) {
                byte b = packetBytes[i];

                if (b == delimiter) {
                    byte[] encodedBytes = new byte[readBufferPosition];
                    System.arraycopy(readBuffer, 0, encodedBytes, 0, encodedBytes.length);
                    final String data = new String(encodedBytes, "US-ASCII");

                    writeOutput("Received:" + data);

                    return;
                } else {
                    readBuffer[readBufferPosition++] = b;
                }
            }
        }
    }
}


final class workerThread implements Runnable {
    private String ssid;
    private String psk;
    private BluetoothDevice device;
    private String control_value;


    public workerThread(String ssid, String psk, BluetoothDevice device) {
        this.ssid = ssid;
        this.psk = psk;
        this.device = device;
    }

    public void run() {
        clearOutput2();
        writeOutput2("Starting config update.");

        writeOutput2("Device: " + device.getName() + " - " + device.getAddress());

        try {
            mmSocket = device.createRfcommSocketToServiceRecord(uuid);
            if (!mmSocket.isConnected()) {
                mmSocket.connect();
                Thread.sleep(1000);
            }

            control_value = "2";

            writeOutput2(control_value);

            writeOutput2("Connected.");

            OutputStream mmOutputStream = mmSocket.getOutputStream();
            final InputStream mmInputStream = mmSocket.getInputStream();

            waitForResponse2(mmInputStream, -1);



            mmOutputStream.write(control_value.getBytes());
            mmOutputStream.flush();
            waitForResponse2(mmInputStream, -1);

            writeOutput2("Sending SSID.");

            mmOutputStream.write(ssid.getBytes());
            mmOutputStream.flush();
            waitForResponse(mmInputStream, -1);

            writeOutput2("Sending PSK.");

            mmOutputStream.write(psk.getBytes());
            mmOutputStream.flush();
            waitForResponse2(mmInputStream, -1);

            mmSocket.close();

            writeOutput2("Success.");

        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();

            writeOutput2("Failed.");
        }

        writeOutput2("Done.");
    }
}

private void writeOutput2(final String text) {
    runOnUiThread(new Runnable() {
        @Override
        public void run() {
            String currentText = messageTextView.getText().toString();
            messageTextView.setText(currentText + "\n" + text);
        }
    });
}

private void clearOutput2() {
    runOnUiThread(new Runnable() {
        @Override
        public void run() {
            messageTextView.setText("");
        }
    });
}

/*
 * TODO actually use the timeout
 */
private void waitForResponse2(InputStream mmInputStream, long timeout) throws IOException {
    int bytesAvailable;

    while (true) {
        bytesAvailable = mmInputStream.available();
        if (bytesAvailable > 0) {
            byte[] packetBytes = new byte[bytesAvailable];
            byte[] readBuffer = new byte[1024];
            mmInputStream.read(packetBytes);

            for (int i = 0; i < bytesAvailable; i++) {
                byte b = packetBytes[i];

                if (b == delimiter) {
                    byte[] encodedBytes = new byte[readBufferPosition];
                    System.arraycopy(readBuffer, 0, encodedBytes, 0, encodedBytes.length);
                    final String data = new String(encodedBytes, "US-ASCII");

                    writeOutput("Received:" + data);

                    return;
                } else {
                    readBuffer[readBufferPosition++] = b;
                }
            }
        }
    }
}