Import unversioned prototypev0.1-preview

5 files changed, 233 insertions, 0 deletions

diff --git a/app/src/main/java/org/pacien/tincapp/commands/Command.java b/app/src/main/java/org/pacien/tincapp/commands/Command.java
new file mode 100644
index 0000000..28ff226
--- /dev/null
+++ b/app/src/main/java/org/pacien/tincapp/commands/Command.java
@@ -0,0 +1,67 @@
+package org.pacien.tincapp.commands;
+
+import com.annimon.stream.Collectors;
+import com.annimon.stream.Optional;
+import com.annimon.stream.Stream;
+
+import java.util.Arrays;
+import java.util.Collections;
+import java.util.LinkedList;
+import java.util.List;
+
+/**
+ * @author pacien
+ */
+class Command {
+
+        static private class Option {
+                final String key;
+                final Optional<java.lang.String> val;
+
+                Option(String key, String val) {
+                        this.key = key;
+                        this.val = Optional.ofNullable(val);
+                }
+
+                @Override
+                public String toString() {
+                        return val.isPresent() ? "--" + key + "=" + val.get() : "--" + key;
+                }
+        }
+
+        final private String cmd;
+        final private List<Option> opts;
+        final private List<String> args;
+
+        public Command(String cmd) {
+                this.cmd = cmd;
+                this.opts = new LinkedList<>();
+                this.args = new LinkedList<>();
+        }
+
+        public Command withOption(String key, String val) {
+                this.opts.add(new Option(key, val));
+                return this;
+        }
+
+        public Command withOption(String key) {
+                return this.withOption(key, null);
+        }
+
+        public Command withArguments(String... args) {
+                this.args.addAll(Arrays.asList(args));
+                return this;
+        }
+
+        public List<String> asList() {
+                return Collections.unmodifiableList(
+                                Stream.concat(Stream.of(Collections.singleton(this.cmd)),
+                                                Stream.concat(Stream.of(this.opts).map(Option::toString), Stream.of(this.args)))
+                                                .collect(Collectors.toList()));
+        }
+
+        public String[] asArray() {
+                return this.asList().toArray(new String[0]);
+        }
+
+}
diff --git a/app/src/main/java/org/pacien/tincapp/commands/Executor.java b/app/src/main/java/org/pacien/tincapp/commands/Executor.java
new file mode 100644
index 0000000..edf229c
--- /dev/null
+++ b/app/src/main/java/org/pacien/tincapp/commands/Executor.java
@@ -0,0 +1,44 @@
+package org.pacien.tincapp.commands;
+
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStreamReader;
+import java.util.Collections;
+import java.util.LinkedList;
+import java.util.List;
+
+/**
+ * @author pacien
+ */
+final class Executor {
+
+        private Executor() {
+                // static class
+        }
+
+        static {
+                System.loadLibrary("exec");
+        }
+
+        /**
+         * @return -1 on error, forked child PID otherwise
+         */
+        static private native int forkExec(String[] argcv);
+
+        static public void forkExec(Command cmd) throws IOException {
+                if (forkExec(cmd.asArray()) == -1)
+                        throw new IOException();
+        }
+
+        static public List<String> call(Command cmd) throws IOException {
+                Process proc = new ProcessBuilder(cmd.asList()).start();
+                BufferedReader outputReader = new BufferedReader(new InputStreamReader(proc.getInputStream()));
+
+                String line;
+                List<String> list = new LinkedList<>();
+                while ((line = outputReader.readLine()) != null) list.add(line);
+
+                return Collections.unmodifiableList(list);
+        }
+
+}
diff --git a/app/src/main/java/org/pacien/tincapp/commands/PermissionFixer.java b/app/src/main/java/org/pacien/tincapp/commands/PermissionFixer.java
new file mode 100644
index 0000000..b00d0d6
--- /dev/null
+++ b/app/src/main/java/org/pacien/tincapp/commands/PermissionFixer.java
@@ -0,0 +1,34 @@
+package org.pacien.tincapp.commands;
+
+import android.annotation.SuppressLint;
+import android.content.Context;
+
+import com.annimon.stream.Stream;
+
+import org.pacien.tincapp.context.AppPaths;
+
+import java.io.File;
+
+/**
+ * @author pacien
+ */
+final public class PermissionFixer {
+
+        private PermissionFixer() {
+                // static class
+        }
+
+        @SuppressLint({"SetWorldReadable", "SetWorldWritable"})
+        static private Boolean setAllRWXPermissions(File f) {
+                return f.setReadable(true, false)
+                                && f.setWritable(true, false)
+                                && f.setExecutable(true, false);
+        }
+
+        static public Boolean makePrivateDirsPublic(Context ctx) {
+                return Stream.of(AppPaths.confDir(ctx), AppPaths.logDir(ctx), AppPaths.pidDir(ctx))
+                                .map(PermissionFixer::setAllRWXPermissions)
+                                .reduce((x, y) -> x && y).get();
+        }
+
+}
diff --git a/app/src/main/java/org/pacien/tincapp/commands/Tinc.java b/app/src/main/java/org/pacien/tincapp/commands/Tinc.java
new file mode 100644
index 0000000..ca11698
--- /dev/null
+++ b/app/src/main/java/org/pacien/tincapp/commands/Tinc.java
@@ -0,0 +1,60 @@
+package org.pacien.tincapp.commands;
+
+import android.content.Context;
+
+import com.annimon.stream.Stream;
+
+import org.pacien.tincapp.context.AppPaths;
+
+import java.io.IOException;
+import java.util.List;
+
+/**
+ * @author pacien
+ */
+final public class Tinc {
+
+        private Tinc() {
+                // static class
+        }
+
+        static private Command newCommand(Context ctx, String netName) {
+                return new Command(AppPaths.tinc(ctx).getAbsolutePath())
+                                .withOption("config", AppPaths.confDir(ctx, netName).getAbsolutePath())
+                                .withOption("pidfile", AppPaths.pidFile(ctx, netName).getAbsolutePath());
+        }
+
+        // independently runnable commands
+
+        static public List<String> network(Context ctx) throws IOException {
+                return Executor.call(new Command(AppPaths.tinc(ctx).getAbsolutePath())
+                                .withOption("config", AppPaths.confDir(ctx).getAbsolutePath())
+                                .withArguments("network"));
+        }
+
+        static public List<String> fsck(Context ctx, String netName, Boolean fix) throws IOException {
+                Command cmd = newCommand(ctx, netName).withArguments("fsck");
+                if (fix) cmd = cmd.withOption("force");
+                return Executor.call(cmd);
+        }
+
+        // commands requiring a running tinc daemon
+
+        static public void stop(Context ctx, String netName) throws IOException {
+                Executor.call(newCommand(ctx, netName).withArguments("stop"));
+        }
+
+        static public List<String> dumpNodes(Context ctx, String netName, Boolean reachable) throws IOException {
+                Command cmd = reachable
+                                ? newCommand(ctx, netName).withArguments("dump", "reachable", "nodes")