From d38459d454f09dfffd828967a7686980763a2f3e Mon Sep 17 00:00:00 2001 From: cyBerta Date: Fri, 4 Feb 2022 12:56:30 +0100 Subject: remove (shapeshifter) Dispatcher and Binary-Installer class, they're deprected and unused --- .../openvpn/core/connection/Obfs4Connection.java | 5 +- .../leap/bitmaskclient/eip/VpnConfigGenerator.java | 4 +- .../pluggableTransports/BinaryInstaller.java | 204 ------------------- .../pluggableTransports/Dispatcher.java | 216 --------------------- 4 files changed, 5 insertions(+), 424 deletions(-) delete mode 100644 app/src/main/java/se/leap/bitmaskclient/pluggableTransports/BinaryInstaller.java delete mode 100644 app/src/main/java/se/leap/bitmaskclient/pluggableTransports/Dispatcher.java (limited to 'app') diff --git a/app/src/main/java/de/blinkt/openvpn/core/connection/Obfs4Connection.java b/app/src/main/java/de/blinkt/openvpn/core/connection/Obfs4Connection.java index c780f487..82a7a6aa 100644 --- a/app/src/main/java/de/blinkt/openvpn/core/connection/Obfs4Connection.java +++ b/app/src/main/java/de/blinkt/openvpn/core/connection/Obfs4Connection.java @@ -2,8 +2,9 @@ package de.blinkt.openvpn.core.connection; import se.leap.bitmaskclient.pluggableTransports.Obfs4Options; -import static se.leap.bitmaskclient.pluggableTransports.Dispatcher.DISPATCHER_IP; -import static se.leap.bitmaskclient.pluggableTransports.Dispatcher.DISPATCHER_PORT; +import static se.leap.bitmaskclient.pluggableTransports.Shapeshifter.DISPATCHER_IP; +import static se.leap.bitmaskclient.pluggableTransports.Shapeshifter.DISPATCHER_PORT; + /** * Created by cyberta on 08.03.19. diff --git a/app/src/main/java/se/leap/bitmaskclient/eip/VpnConfigGenerator.java b/app/src/main/java/se/leap/bitmaskclient/eip/VpnConfigGenerator.java index 303959d0..5ddb74ab 100644 --- a/app/src/main/java/se/leap/bitmaskclient/eip/VpnConfigGenerator.java +++ b/app/src/main/java/se/leap/bitmaskclient/eip/VpnConfigGenerator.java @@ -49,8 +49,8 @@ import static se.leap.bitmaskclient.base.models.Constants.REMOTE; import static se.leap.bitmaskclient.base.models.Constants.TRANSPORT; import static se.leap.bitmaskclient.base.models.Constants.TYPE; import static se.leap.bitmaskclient.base.models.Constants.UDP; -import static se.leap.bitmaskclient.pluggableTransports.Dispatcher.DISPATCHER_IP; -import static se.leap.bitmaskclient.pluggableTransports.Dispatcher.DISPATCHER_PORT; +import static se.leap.bitmaskclient.pluggableTransports.Shapeshifter.DISPATCHER_IP; +import static se.leap.bitmaskclient.pluggableTransports.Shapeshifter.DISPATCHER_PORT; public class VpnConfigGenerator { private JSONObject generalConfiguration; diff --git a/app/src/main/java/se/leap/bitmaskclient/pluggableTransports/BinaryInstaller.java b/app/src/main/java/se/leap/bitmaskclient/pluggableTransports/BinaryInstaller.java deleted file mode 100644 index 0d6aa61e..00000000 --- a/app/src/main/java/se/leap/bitmaskclient/pluggableTransports/BinaryInstaller.java +++ /dev/null @@ -1,204 +0,0 @@ -/* Copyright (c) 2009, Nathan Freitas, Orbot / The Guardian Project - http://openideals.com/guardian */ -/* See LICENSE for licensing information */ - -package se.leap.bitmaskclient.pluggableTransports; - -import android.content.Context; -import android.util.Log; - -import java.io.DataInputStream; -import java.io.DataOutputStream; -import java.io.File; -import java.io.FileNotFoundException; -import java.io.FileOutputStream; -import java.io.IOException; -import java.io.InputStream; -import java.io.OutputStream; -import java.util.concurrent.TimeoutException; -import java.util.zip.ZipEntry; -import java.util.zip.ZipInputStream; - -public class BinaryInstaller { - - File installFolder; - Context context; - - public BinaryInstaller(Context context, File installFolder) - { - this.installFolder = installFolder; - - this.context = context; - } - - public void deleteDirectory(File file) { - if( file.exists() ) { - if (file.isDirectory()) { - File[] files = file.listFiles(); - for(int i=0; i 0) - { - - stmOut.write(buffer, 0, bytecount); - - } - - stmOut.close(); - stm.close(); - - if (zis != null) - zis.close(); - - - return true; - - } - - //copy the file from inputstream to File output - alternative impl - public static boolean copyFile (InputStream is, File outputFile) - { - - try { - if (outputFile.exists()) - outputFile.delete(); - - boolean newFile = outputFile.createNewFile(); - DataOutputStream out = new DataOutputStream(new FileOutputStream(outputFile)); - DataInputStream in = new DataInputStream(is); - - int b = -1; - byte[] data = new byte[1024]; - - while ((b = in.read(data)) != -1) { - out.write(data); - } - - if (b == -1); //rejoice - - // - out.flush(); - out.close(); - in.close(); - // chmod? - - return newFile; - - - } catch (IOException ex) { - Log.e("Binaryinstaller", "error copying binary", ex); - return false; - } - - } - - /** - * Copies a raw resource file, given its ID to the given location - * @param ctx context - * @param resid resource id - * @param file destination file - * @param mode file permissions (E.g.: "755") - * @throws IOException on error - * @throws InterruptedException when interrupted - */ - public static void copyRawFile(Context ctx, int resid, File file, String mode, boolean isZipd) throws IOException, InterruptedException - { - final String abspath = file.getAbsolutePath(); - // Write the iptables binary - final FileOutputStream out = new FileOutputStream(file); - InputStream is = ctx.getResources().openRawResource(resid); - - if (isZipd) - { - ZipInputStream zis = new ZipInputStream(is); - ZipEntry ze = zis.getNextEntry(); - is = zis; - } - - byte buf[] = new byte[1024]; - int len; - while ((len = is.read(buf)) > 0) { - out.write(buf, 0, len); - } - out.close(); - is.close(); - // Change the permissions - Runtime.getRuntime().exec("chmod "+mode+" "+abspath).waitFor(); - } - - - private void setExecutable(File fileBin) { - fileBin.setReadable(true); - fileBin.setExecutable(true); - fileBin.setWritable(false); - fileBin.setWritable(true, true); - } - -} 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 . - */ -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(); - } -} -- cgit v1.2.3