From eefe2bdea6e79548ef5a0c0a50b3afc495b034b3 Mon Sep 17 00:00:00 2001
From: Daniel Weipert <code@drogueronin.de>
Date: Thu, 11 May 2023 20:03:37 +0200
Subject: next commit

---
 app/java/src/DNSProxyRunner.java | 53 ++++++++++++++++++++++++++++++++++++++++
 1 file changed, 53 insertions(+)
 create mode 100644 app/java/src/DNSProxyRunner.java

(limited to 'app/java/src/DNSProxyRunner.java')

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;
+    }
+}
-- 
cgit v1.2.3