diff options
Diffstat (limited to 'app/src/main/java/se/leap/bitmaskclient/pluggableTransports/Dispatcher.java')
| -rw-r--r-- | app/src/main/java/se/leap/bitmaskclient/pluggableTransports/Dispatcher.java | 216 |
1 files changed, 0 insertions, 216 deletions
diff --git a/app/src/main/java/se/leap/bitmaskclient/pluggableTransports/Dispatcher.java b/app/src/main/java/se/leap/bitmaskclient/pluggableTransports/Dispatcher.java deleted file mode 100644 index 210c94b6..00000000 --- a/app/src/main/java/se/leap/bitmaskclient/pluggableTransports/Dispatcher.java +++ /dev/null @@ -1,216 +0,0 @@ -/** - * Copyright (c) 2019 LEAP Encryption Access Project and contributers - * - * 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 <http://www.gnu.org/licenses/>. - */ -package se.leap.bitmaskclient.pluggableTransports; - -import android.content.Context; -import androidx.annotation.WorkerThread; -import android.text.TextUtils; -import android.util.Log; - -import java.io.File; -import java.io.IOException; -import java.io.InputStreamReader; -import java.io.OutputStreamWriter; -import java.util.StringTokenizer; - - -/** - * Created by cyberta on 22.02.19. - */ - -public class Dispatcher { - private static final String ASSET_KEY = "piedispatcher"; - public static final String DISPATCHER_PORT = "4430"; - public static final String DISPATCHER_IP = "127.0.0.1"; - private static final String TAG = Dispatcher.class.getName(); - private final String remoteIP; - private final String remotePort; - private final String certificate; - private final String iatMode; - private File fileDispatcher; - private Context context; - private Thread dispatcherThread = null; - private int dispatcherPid = -1; - - public Dispatcher(Context context, Obfs4Options obfs4Options) { - this.context = context.getApplicationContext(); - this.remoteIP = obfs4Options.remoteIP; - this.remotePort = obfs4Options.remotePort; - this.certificate = obfs4Options.cert; - this.iatMode = obfs4Options.iatMode; - } - - @WorkerThread - public void initSync() { - try { - fileDispatcher = installDispatcher(); - - // start dispatcher - dispatcherThread = new Thread(() -> { - try { - StringBuilder dispatcherLog = new StringBuilder(); - String dispatcherCommand = fileDispatcher.getCanonicalPath() + - " -transparent" + - " -client" + - " -state " + context.getFilesDir().getCanonicalPath() + "/state" + - " -target " + remoteIP + ":" + remotePort + - " -transports obfs4" + - " -options \"" + String.format("{\\\"cert\\\": \\\"%s\\\", \\\"iatMode\\\": \\\"%s\\\"}\"", certificate, iatMode) + - " -logLevel DEBUG -enableLogging" + - " -proxylistenaddr "+ DISPATCHER_IP + ":" + DISPATCHER_PORT; - - Log.d(TAG, "dispatcher command: " + dispatcherCommand); - runBlockingCmd(new String[]{dispatcherCommand}, dispatcherLog); - } catch (IOException e) { - e.printStackTrace(); - } catch (Exception e) { - e.printStackTrace(); - } - }); - dispatcherThread.start(); - - // get pid of dispatcher, try several times in case the dispatcher - // process is not spawned yet - StringBuilder log = new StringBuilder(); - String pidCommand = "ps | grep piedispatcher"; - for (int i = 0; i < 5; i++) { - runBlockingCmd(new String[]{pidCommand}, log); - if (!TextUtils.isEmpty(log)) { - break; - } - Thread.sleep(100); - } - - String output = log.toString(); - StringTokenizer st = new StringTokenizer(output, " "); - st.nextToken(); // proc owner - dispatcherPid = Integer.parseInt(st.nextToken().trim()); - } catch(Exception e){ - if (dispatcherThread.isAlive()) { - Log.e(TAG, e.getMessage() + ". Shutting down Dispatcher thread."); - stop(); - } - } - } - - public String getPort() { - return DISPATCHER_PORT; - } - - public void stop() { - Log.d(TAG, "Shutting down Dispatcher thread."); - if (dispatcherThread != null && dispatcherThread.isAlive()) { - try { - killProcess(dispatcherPid); - } catch (Exception e) { - e.printStackTrace(); - } - dispatcherThread.interrupt(); - } - } - - private void killProcess(int pid) throws Exception { - String killPid = "kill -9 " + pid; - runCmd(new String[]{killPid}, null, false); - } - - public boolean isRunning() { - return dispatcherThread != null && dispatcherThread.isAlive(); - } - - private File installDispatcher(){ - File fileDispatcher = null; - BinaryInstaller bi = new BinaryInstaller(context,context.getFilesDir()); - - String arch = System.getProperty("os.arch"); - if (arch.contains("arm")) - arch = "armeabi-v7a"; - else - arch = "x86"; - - try { - fileDispatcher = bi.installResource(arch, ASSET_KEY, false); - } catch (Exception ioe) { - Log.d(TAG,"Couldn't install dispatcher: " + ioe); - } - - return fileDispatcher; - } - - @WorkerThread - private void runBlockingCmd(String[] cmds, StringBuilder log) throws Exception { - runCmd(cmds, log, true); - } - - @WorkerThread - private int runCmd(String[] cmds, StringBuilder log, - boolean waitFor) throws Exception { - - int exitCode = -1; - Process proc = Runtime.getRuntime().exec("sh"); - OutputStreamWriter out = new OutputStreamWriter(proc.getOutputStream()); - - try { - for (String cmd : cmds) { - Log.d(TAG, "executing CMD: " + cmd); - out.write(cmd); - out.write("\n"); - } - - out.flush(); - out.write("exit\n"); - out.flush(); - } catch (IOException e) { - e.printStackTrace(); - } finally { - out.close(); - } - - if (waitFor) { - // Consume the "stdout" - InputStreamReader reader = new InputStreamReader(proc.getInputStream()); - readToLogString(reader, log); - - // Consume the "stderr" - reader = new InputStreamReader(proc.getErrorStream()); - readToLogString(reader, log); - - try { - exitCode = proc.waitFor(); - } catch (InterruptedException e) { - e.printStackTrace(); - } - } - - return exitCode; - } - - private void readToLogString(InputStreamReader reader, StringBuilder log) throws IOException { - final char buf[] = new char[10]; - int read = 0; - try { - while ((read = reader.read(buf)) != -1) { - if (log != null) - log.append(buf, 0, read); - } - } catch (IOException e) { - reader.close(); - throw new IOException(e); - } - reader.close(); - } -} |