package dmo.fs.spa.utils;

import java.io.IOException;
import java.io.InputStream;
import java.util.Date;
import java.util.Iterator;
import java.util.Map;
import java.util.Properties;
import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
import org.jooq.SQLDialect;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;
import io.reactivex.rxjava3.disposables.Disposable;
import io.vertx.core.json.JsonArray;
import io.vertx.core.json.JsonObject;

public class SpaUtil {
    private static String env = "dev";
    private static String defaultDb = "h2";

    public void await(final Disposable disposable) {
        while (!disposable.isDisposed()) {
            try {
                Thread.sleep(100);
            } catch (final InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

    public static void setEnv(final String envMode) {
        env = envMode;
    }

    public static String getEnv() {
        return env;
    }

    public static JsonNode getDefaultNode() throws IOException {
        final ObjectMapper jsonMapper = new ObjectMapper();
        JsonNode node;

        try (InputStream in = SpaUtil.class.getResourceAsStream("/database_spa_config.json")) {
            node = jsonMapper.readTree(in);
        }

        final String defaultdbProp = System.getProperty("DEFAULT_DB");
        final String defaultdbEnv = System.getenv("DEFAULT_DB");
        defaultDb = node.get("defaultdb").textValue();
        /*
         * use environment variable first, if set, than properties and then from config json
         */
        defaultDb = defaultdbEnv != null ? defaultdbEnv
                : defaultdbProp != null ? defaultdbProp : defaultDb;

        return node.get(defaultDb);
    }

    public static String getDefaultDb() throws IOException {
        getDefaultNode();
        return defaultDb;
    }

    public static Map<String, String> jsonNodeToMap(final JsonNode jsonNode, final String env) {
        final Map<String, String> defaultMap = new ConcurrentHashMap<>();
        final JsonNode credentials = jsonNode.get(env).get("credentials");
        final JsonNode config = jsonNode.get(env).get("config");
        Iterator<String> fields = config.fieldNames();

        while (fields.hasNext()) {
            final String field = fields.next();
            if (config.get(field) != null) {
                defaultMap.put(field, config.get(field).textValue());
            }
        }

        fields = credentials.fieldNames();
        while (fields.hasNext()) {
            final String field = fields.next();
            if (credentials.get(field) != null) {
                defaultMap.put("CRED:" + field, credentials.get(field).textValue());
            }
        }
        return defaultMap;
    }

    public Properties mapToProperties(final Map<String, String> map) {
        final Properties properties = new Properties();
        final Set<Map.Entry<String, String>> set = map.entrySet();
        for (final Map.Entry<String, String> entry : set) {
            if (entry.getKey().startsWith("CRED:")) {
                properties.put(entry.getKey().substring(5), entry.getValue());
            }
        }

        final Set<Object> keys = properties.keySet();
        for (final Object key : keys) {
            map.remove("CRED:" + key.toString());
        }

        return properties;
    }

    public static SQLDialect getSqlDialect() {
        String database;
        try {
            database = getDefaultDb();
            database = "sqlite3".equals(database) ? "SQLITE" : database.toUpperCase();
            for (final SQLDialect sqlDialect : SQLDialect.values()) {
                if (database.equals(sqlDialect.name())) {
                    return sqlDialect;
                }
            }
        } catch (final IOException e) {
            e.printStackTrace();
        }

        return SQLDialect.DEFAULT;
    }

    public static SpaLogin parseBody(String bodyData, SpaLogin spaLogin) {
        JsonObject loginObject = new JsonObject(String.join("", "{\"data\":", bodyData, "}"));
        JsonArray data = loginObject.getJsonArray("data");
        int size = loginObject.getJsonArray("data").getList().size();
        String userName = null;
        String password = null;

        for (int i = 0; i < size; i++) {
            String name = data.getJsonObject(i).getString("name");
            switch (name) {
                case "username":
                    userName = data.getJsonObject(i).getString("value");
                    break;
                case "password":
                    password = data.getJsonObject(i).getString("value");
                    break;
                default:
                    break;
            }
        }

        spaLogin.setName(userName);
        spaLogin.setPassword(password);
        spaLogin.setId(0l);
        spaLogin.setLastLogin(new Date());
        spaLogin.setStatus("0");

        return spaLogin;
    }

    public static SpaLogin createSpaLogin() {
        return new SpaLoginImpl();
    }
}