wireguard-android/app/src/main/java/com/wireguard/android/model/TunnelManager.java

package com.wireguard.android.model;

import android.content.SharedPreferences;
import android.support.annotation.NonNull;

import com.wireguard.android.Application.ApplicationScope;
import com.wireguard.android.backend.Backend;
import com.wireguard.android.configStore.ConfigStore;
import com.wireguard.android.model.Tunnel.State;
import com.wireguard.android.model.Tunnel.Statistics;
import com.wireguard.android.util.AsyncWorker;
import com.wireguard.android.util.ExceptionLoggers;
import com.wireguard.android.util.ObservableKeyedList;
import com.wireguard.android.util.ObservableSortedKeyedArrayList;
import com.wireguard.config.Config;

import java.util.Collections;
import java.util.Comparator;
import java.util.Set;

import javax.inject.Inject;

import java9.util.Comparators;
import java9.util.concurrent.CompletableFuture;
import java9.util.concurrent.CompletionStage;
import java9.util.stream.Collectors;
import java9.util.stream.StreamSupport;

/**
 * Maintains and mediates changes to the set of available WireGuard tunnels,
 */

@ApplicationScope
public final class TunnelManager {
    public static final String KEY_PRIMARY_TUNNEL = "primary_config";
    private static final Comparator<String> COMPARATOR = Comparators.<String>thenComparing(
            String.CASE_INSENSITIVE_ORDER, Comparators.naturalOrder());
    private static final String KEY_RESTORE_ON_BOOT = "restore_on_boot";
    private static final String KEY_RUNNING_TUNNELS = "enabled_configs";
    private static final String TAG = TunnelManager.class.getSimpleName();

    private final AsyncWorker asyncWorker;
    private final Backend backend;
    private final ConfigStore configStore;
    private final SharedPreferences preferences;
    private final ObservableKeyedList<String, Tunnel> tunnels =
            new ObservableSortedKeyedArrayList<>(COMPARATOR);

    @Inject
    public TunnelManager(final AsyncWorker asyncWorker, final Backend backend,
                         final ConfigStore configStore, final SharedPreferences preferences) {
        this.asyncWorker = asyncWorker;
        this.backend = backend;
        this.configStore = configStore;
        this.preferences = preferences;
    }

    private Tunnel addToList(final String name, final Config config, final State state) {
        final Tunnel tunnel = new Tunnel(this, name, config, state);
        tunnels.add(tunnel);
        return tunnel;
    }

    public CompletionStage<Tunnel> create(@NonNull final String name, final Config config) {
        if (!Tunnel.isNameValid(name))
            return CompletableFuture.failedFuture(new IllegalArgumentException("Invalid name"));
        if (tunnels.containsKey(name)) {
            final String message = "Tunnel " + name + " already exists";
            return CompletableFuture.failedFuture(new IllegalArgumentException(message));
        }
        return asyncWorker.supplyAsync(() -> configStore.create(name, config))
                .thenApply(savedConfig -> addToList(name, savedConfig, State.DOWN));
    }

    CompletionStage<Void> delete(final Tunnel tunnel) {
        return asyncWorker.runAsync(() -> {
            backend.setState(tunnel, State.DOWN);
            configStore.delete(tunnel.getName());
        }).thenAccept(x -> {
            if (tunnel.getName().equals(preferences.getString(KEY_PRIMARY_TUNNEL, null)))
                preferences.edit().remove(KEY_PRIMARY_TUNNEL).apply();
            tunnels.remove(tunnel);
        });
    }

    CompletionStage<Config> getTunnelConfig(final Tunnel tunnel) {
        final CompletionStage<Config> completion =
                asyncWorker.supplyAsync(() -> configStore.load(tunnel.getName()));
        completion.thenAccept(tunnel::onConfigChanged);
        return completion;
    }

    CompletionStage<State> getTunnelState(final Tunnel tunnel) {
        final CompletionStage<State> completion =
                asyncWorker.supplyAsync(() -> backend.getState(tunnel));
        completion.thenAccept(tunnel::onStateChanged);
        return completion;
    }

    CompletionStage<Statistics> getTunnelStatistics(final Tunnel tunnel) {
        final CompletionStage<Statistics> completion =
                asyncWorker.supplyAsync(() -> backend.getStatistics(tunnel));
        completion.thenAccept(tunnel::onStatisticsChanged);
        return completion;
    }

    public ObservableKeyedList<String, Tunnel> getTunnels() {
        return tunnels;
    }

    public void onCreate() {
        asyncWorker.supplyAsync(configStore::enumerate)
                .thenAcceptBoth(asyncWorker.supplyAsync(backend::enumerate), this::onTunnelsLoaded)
                .whenComplete(ExceptionLoggers.E);
    }

    private void onTunnelsLoaded(final Set<String> present, final Set<String> running) {
        for (final String name : present)
            addToList(name, null, running.contains(name) ? State.UP : State.DOWN);
    }

    CompletionStage<Tunnel> rename(final Tunnel tunnel, final String name) {
        if (!Tunnel.isNameValid(name))
            return CompletableFuture.failedFuture(new IllegalArgumentException("Invalid name"));
        if (tunnels.containsKey(name)) {
            final String message = "Tunnel " + name + " already exists";
            return CompletableFuture.failedFuture(new IllegalArgumentException(message));
        }
        final State originalState = tunnel.getState();
        return asyncWorker.supplyAsync(() -> {
            backend.setState(tunnel, State.DOWN);
            final Config newConfig = configStore.create(name, tunnel.getConfig());
            final Tunnel newTunnel = new Tunnel(this, name, newConfig, State.DOWN);
            if (originalState == State.UP) {
                backend.setState(newTunnel, originalState);
                newTunnel.onStateChanged(originalState);
            }
            configStore.delete(tunnel.getName());
            return newTunnel;
        }).whenComplete((newTunnel, e) -> {
            if (e != null)
                return;
            tunnels.remove(tunnel);
            tunnels.add(newTunnel);
        });
    }

    public CompletionStage<Void> restoreState() {
        if (!preferences.getBoolean(KEY_RESTORE_ON_BOOT, false))
            return CompletableFuture.completedFuture(null);
        final Set<String> tunnelsToEnable =
                preferences.getStringSet(KEY_RUNNING_TUNNELS, Collections.emptySet());
        final CompletableFuture[] futures = StreamSupport.stream(tunnelsToEnable)
                .map(tunnels::get)
                .map(tunnel -> tunnel.setState(State.UP))
                .toArray(CompletableFuture[]::new);
        return CompletableFuture.allOf(futures);
    }

    public CompletionStage<Void> saveState() {
        final Set<String> runningTunnels = StreamSupport.stream(tunnels)
                .filter(tunnel -> tunnel.getState() == State.UP)
                .map(Tunnel::getName)
                .collect(Collectors.toUnmodifiableSet());
        preferences.edit().putStringSet(KEY_RUNNING_TUNNELS, runningTunnels).apply();
        return CompletableFuture.completedFuture(null);
    }

    CompletionStage<Config> setTunnelConfig(final Tunnel tunnel, final Config config) {
        final CompletionStage<Config> completion = asyncWorker.supplyAsync(() -> {
            final Config appliedConfig = backend.applyConfig(tunnel, config);
            return configStore.save(tunnel.getName(), appliedConfig);
        });
        completion.thenAccept(tunnel::onConfigChanged);
        return completion;
    }

    CompletionStage<State> setTunnelState(final Tunnel tunnel, final State state) {
        final CompletionStage<State> completion =
                asyncWorker.supplyAsync(() -> backend.setState(tunnel, state));
        completion.thenAccept(tunnel::onStateChanged);
        return completion;
    }
}