next commit

5 files changed, 237 insertions, 58 deletions

diff --git a/app/java/src/DNSProxyConnection.java b/app/java/src/DNSProxyConnection.java
new file mode 100644
index 0000000..f96af80
--- /dev/null
+++ b/app/java/src/DNSProxyConnection.java
@@ -0,0 +1,39 @@
+package org.pihole.dnsproxy;
+
+import android.os.ParcelFileDescriptor;
+
+import android.util.Log;
+
+import java.io.IOException;
+
+public class DNSProxyConnection {
+
+    public static String THREAD_NAME = "org.pihole.dnsproxy.service.thread";
+
+    private DNSProxyService service;
+    private Thread thread;
+    private ParcelFileDescriptor networkInterface;
+
+    public DNSProxyConnection(DNSProxyService service) {
+        this.service = service;
+    }
+
+    public void start() {
+        DNSProxyRunner runner = new DNSProxyRunner(this.service);
+        runner.setOnEstablishListener(parcelFileDescriptor -> {
+            this.networkInterface = parcelFileDescriptor;
+        });
+
+        this.thread = new Thread(runner, DNSProxyConnection.THREAD_NAME);
+        this.thread.start();
+    }
+
+    public void stop() {
+        try {
+            this.thread.stop();
+            this.networkInterface.close();
+        } catch (IOException exception) {
+            Log.e(DNSProxyService.LOG_TAG, "Connection failed", exception);
+        }
+    }
+}
diff --git a/app/java/src/DNSProxyRunner.java b/app/java/src/DNSProxyRunner.java
new file mode 100644
index 0000000..0c136e8
--- /dev/null
+++ b/app/java/src/DNSProxyRunner.java
@@ -0,0 +1,53 @@
+package org.pihole.dnsproxy;
+
+import android.os.ParcelFileDescriptor;
+
+import android.util.Log;
+
+import java.io.FileInputStream;
+import java.io.FileOutputStream;
+import java.io.IOException;
+
+import java.net.InetSocketAddress;
+import java.net.SocketAddress;
+
+import java.nio.channels.DatagramChannel;
+
+public class DNSProxyRunner implements Runnable {
+    public interface OnEstablishListener {
+        void onEstablish(ParcelFileDescriptor networkInterface);
+    }
+    private OnEstablishListener onEstablishListener;
+
+    private DNSProxyService service;
+
+    DNSProxyRunner(DNSProxyService service) {
+        this.service = service;
+    }
+
+    @Override
+    public void run() {
+        try {
+            DatagramChannel tunnel = DatagramChannel.open();
+
+            if(!this.service.protect(tunnel.socket())) {
+                throw new IllegalStateException("Cannot protect tunnel");
+            }
+
+            // SocketAddress server = new InetSocketAddress("servername", "serverport");
+            //
+            // tunnel.connect(server);
+            // tunnel.configureBlocking(false);
+            //
+            // ParcelFileDescriptor networkInterface = this.handshake(tunnel);
+            // FileInputStream in = new FileInputStream(networkInterface.getFileDescriptor());
+            // FileOutputStream out = new FileOutputStream(networkInterface.getFileDescriptor());
+        } catch (IOException exception) {
+            Log.e(DNSProxyService.LOG_TAG, "Cannot use socket", exception);
+        }
+    }
+
+    public void setOnEstablishListener(OnEstablishListener listener) {
+        this.onEstablishListener = listener;
+    }
+}
diff --git a/app/java/src/DNSProxyService.java b/app/java/src/DNSProxyService.java
new file mode 100644
index 0000000..117e6fc
--- /dev/null
+++ b/app/java/src/DNSProxyService.java
@@ -0,0 +1,52 @@
+package org.pihole.dnsproxy;
+
+import android.app.Service;
+
+import android.content.Intent;
+
+import android.net.VpnService;
+
+public class DNSProxyService extends VpnService {
+
+    public static String LOG_TAG = "org.pihole.dnsproxy.log";
+    public static String NOTIFICATION = "org.pihole.dnsproxy.service";
+
+    private static DNSProxyConnection connection;
+
+    @Override
+    public int onStartCommand(Intent intent, int flags, int startId)    {
+        this.start();
+
+        return Service.START_STICKY;
+    }
+
+    @Override
+    public void onDestroy() {
+        this.stop();
+
+        super.onDestroy();
+    }
+
+    public static boolean isRunning()
+    {
+        return DNSProxyService.connection != null;
+    }
+
+    public void start() {
+        DNSProxyService.connection = new DNSProxyConnection(this);
+        // DNSProxyService.connection.start();
+
+        // send notification when started
+        Intent notification = new Intent(DNSProxyService.NOTIFICATION);
+        sendBroadcast(notification);
+    }
+
+    public void stop() {
+        // DNSProxyService.connection.stop();
+        DNSProxyService.connection = null;
+
+        // send notification when stopped
+        Intent notification = new Intent(DNSProxyService.NOTIFICATION);
+        sendBroadcast(notification);
+    }
+}
diff --git a/app/java/src/DNSService.java b/app/java/src/DNSService.java
deleted file mode 100644
index 4f760a5..0000000
--- a/app/java/src/DNSService.java
+++ /dev/null
@@ -1,33 +0,0 @@
-package org.pihole.dnsproxy;
-
-import android.app.AlertDialog;
-import android.app.Service;
-
-import android.content.Intent;
-
-import android.net.VpnService;
-
-public class DNSService extends VpnService {
-
-    private static boolean isRunning = false;
-
-    @Override
-    public int onStartCommand(Intent intent, int flags, int startId)    {
-        //VpnService.prepare();
-
-        DNSService.isRunning = true;
-
-        return Service.START_STICKY;
-    }
-
-    @Override
-    public void onDestroy() {
-        DNSService.isRunning = false;
-        super.onDestroy();
-    }
-
-    public static boolean isRunning()
-    {
-        return DNSService.isRunning;
-    }
-}
diff --git a/app/java/src/MainActivity.java b/app/java/src/MainActivity.java
index 9fd99f6..f437c9d 100644
--- a/app/java/src/MainActivity.java
+++ b/app/java/src/MainActivity.java
@@ -3,7 +3,10 @@ package org.pihole.dnsproxy;
 import android.app.Activity;
 import android.app.AlertDialog;
 
+import android.content.BroadcastReceiver;
+import android.content.Context;
 import android.content.Intent;
+import android.content.IntentFilter;
 
 import android.net.VpnService;
 
@@ -18,51 +21,116 @@ import android.widget.Toast;
 public class MainActivity extends Activity {
 
     private Button buttonStart;
+    private Intent dnsProxyService;
+
+    private BroadcastReceiver receiver = new BroadcastReceiver() {
+
+        /**
+         * Set button_start state on receive from DNSProxyService
+         */
+        @Override
+        public void onReceive(Context context, Intent intent) {
+            Bundle bundle = intent.getExtras();
+            // if (bundle != null) {
+                setStateButtonStart();
+            // }
+        }
+    };
 
     @Override
     protected void onCreate(Bundle savedInstanceState) {
         super.onCreate(savedInstanceState);
+
         setContentView(R.layout.main);
 
         this.buttonStart = (Button) findViewById(R.id.button_start);
-        this.buttonStart.setText(DNSService.isRunning() ? "Stop" : "Start");
+        this.dnsProxyService = new Intent(this, DNSProxyService.class);
     }
 
     @Override
     public void onResume() {
         super.onResume();
-        this.buttonStart.setText("on RESSSSUME");
+
+        this.setStateButtonStart();
+        registerReceiver(this.receiver, new IntentFilter(DNSProxyService.NOTIFICATION));
     }
 
     @Override
-    public void onRequestPermissionsResult(int requestCode, String[] permissions, int[] grantResults) {}
+    public void onPause() {
+        super.onPause();
 
-    public void onStartClick(View view) {
-        Intent intent = VpnService.prepare(this);
-        if (intent != null) {
-            startActivityForResult(intent, 0);
+        unregisterReceiver(receiver);
+    }
+
+    /**
+     * is called by "startActivityForResult" internally
+     */
+    @Override
+    public void onActivityResult(int request, int result, Intent data) {
+        if (result == RESULT_OK) {
+          this.start();
         }
-        //Intent intent = new Intent(this, DNSService.class);
+    }
 
-        if (!DNSService.isRunning()) {
-            startService(intent);
+    @Override
+    public void onRequestPermissionsResult(int requestCode, String[] permissions, int[] grantResults) {}
 
-            new AlertDialog.Builder(this)
-                .setTitle("PROXY START")
-                .setMessage("BRRR")
-                .show();
-            Toast.makeText(this, "service starting", Toast.LENGTH_SHORT).show();
-            this.buttonStart.setText("Stop");
+    /**
+     * button_start is clicked
+     */
+    public void onClickButtonStart(View view) {
+        if (!DNSProxyService.isRunning()) { //start
+            Intent intent = DNSProxyService.prepare(this);
+
+            if (intent != null) {
+                startActivityForResult(intent, 0);
+            } else {
+                this.onActivityResult(0, RESULT_OK, null);
+            }
+        }
+        else { // stop
+            this.stop();
         }
-        else {
-            stopService(intent);
-
-            new AlertDialog.Builder(this)
-                .setTitle("PROXY STOP")
-                .setMessage("RRRB")
-                .show();
-            Toast.makeText(this, "service stopping", Toast.LENGTH_SHORT).show();
-            this.buttonStart.setText("Start");
+    }
+
+    /**
+     * Set button_start text
+     */
+    public void setStateButtonStart() {
+        if (!DNSProxyService.isRunning()) {
+            this.buttonStart.setText(getString(R.string.button_start__start));
+        } else {
+            this.buttonStart.setText(getString(R.string.button_start__stop));
         }
     }
+
+    /**
+     * Start DNSProxyService
+     */
+    public void start() {
+        startService(this.dnsProxyService);
+
+        Toast
+            .makeText(
+                this,
+                getString(R.string.service_starting),
+                Toast.LENGTH_SHORT
+            )
+            .show();
+    }
+
+    /**
+     * Stop DNSProxyService
+     */
+    public void stop() {
+        stopService(this.dnsProxyService);
+
+        Toast
+            .makeText(
+                this,
+                getString(R.string.service_stopping),
+                Toast.LENGTH_SHORT
+            )
+            .show();
+    }
 }