rweather / noise-java Goto Github PK

    Observable.fromCallable(new Callable<Void>() {
        @RequiresApi(api = Build.VERSION_CODES.KITKAT)
        @Override
        public Void call() throws Exception {

            try {
                HandshakeState initiator = new HandshakeState("Noise_XX_25519_ChaChaPoly_SHA256", INITIATOR);
            
                String init_prologue = "";
             
                TestMessage testMessage = new TestMessage();
                testMessage.ciphertext = bytesToHex("\\n".getBytes());
                testMessage.payload = bytesToHex("\\n".getBytes());

                if (initiator.needsLocalKeyPair()) {
                    StringBuilder clientKey = new StringBuilder();

                    String host = "localhost";
                    int port = 7000;
                    InetAddress address = InetAddress.getByName(host);
                    Socket socket = new Socket(address, port);

                    BufferedReader reader = null, reader1 = null;
                    try {
                        reader = new BufferedReader(
                                new InputStreamReader(context.getAssets().open("client_key_25519"),
                                        "UTF-8"));

                        String line;
                        while ((line = reader.readLine()) != null) {
                            clientKey.append(line);
                        }

                        initiator.getLocalKeyPair().setPrivateKey(clientKey.toString().getBytes()
                                , 0);

                        initiator.start();

                        byte[] message = new byte[128];
                        byte[] plaintext = new byte[128];

                        int len = 0;

                        while (true) {
                            if (initiator.getAction() == WRITE_MESSAGE) {
                                len = initiator.writeMessage(message, 0,
                                        testMessage.payload.getBytes(), 0,
                                        testMessage.payload.getBytes().length);

                                OutputStreamWriter osw = new OutputStreamWriter(socket.getOutputStream());
                                BufferedWriter bw = new BufferedWriter(osw);
                                String strMessage = new String(message, "UTF-8");
                                bw.write(strMessage);
                                bw.flush();

                                Log.e(NoiseManager.class.getSimpleName(),
                                        "Message sent to the server : " + strMessage);
                            }  else {
                                break;
                            }
                        }
                    } catch (IOException e) {
                        e.printStackTrace();
                    } finally {
                        if (reader != null) {
                            try {
                                reader.close();
                                //socket.close();
                            } catch (IOException e) {
                                e.printStackTrace();
                            }
                        }
                    }

                }
            } catch (NoSuchAlgorithmException e) {
                e.printStackTrace();
            } catch (UnknownHostException e) {
                e.printStackTrace();
            } catch (IOException e) {
                e.printStackTrace();
            }

            return null;
        }
    }).observeOn(AndroidSchedulers.mainThread())
            .subscribeOn(Schedulers.io())
            .subscribe(new Subscriber<Void>() {
                @Override
                public void onCompleted() {
                    Log.e(NoiseManager.class.getSimpleName(), "onCompleted");
                }

                @Override
                public void onError(Throwable e) {
                    e.printStackTrace();
                    Log.e(NoiseManager.class.getSimpleName(), "onError");
                }

                @Override
                public void onNext(Void o) {
                    Log.e(NoiseManager.class.getSimpleName(), "onNext");
                }
            });
}

// Bouncy Castle doesn't currently (June 2016) have an
// implementation of BLAKE2s, but look for the most
// obvious provider name in case one is added in the future.