package dmo.fs.spa;

import java.io.IOException;
import java.sql.SQLException;
import java.util.Arrays;
import java.util.Date;
import java.util.Map;
import java.util.concurrent.ExecutionException;
import java.util.stream.Collectors;

import jakarta.enterprise.inject.spi.CDI;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import dmo.fs.db.wsnext.DbConfiguration;
import dmo.fs.db.router.wsnext.CassandraRouter;
import dmo.fs.db.router.wsnext.FirebaseRouter;
import dmo.fs.db.router.wsnext.Neo4jRouter;
import dmo.fs.spa.db.cassandra.SpaCassandra;
import dmo.fs.spa.db.SpaDatabase;
import dmo.fs.spa.db.SpaDbConfiguration;
import dmo.fs.spa.db.firebase.SpaFirebase;
import dmo.fs.spa.db.neo4j.SpaNeo4j;
import dmo.fs.spa.utils.SpaLogin;
import dmo.fs.spa.utils.SpaLoginImpl;
import io.vertx.core.Future;
import io.vertx.core.json.JsonArray;
import io.vertx.core.json.JsonObject;
import io.vertx.mutiny.core.Promise;
import io.vertx.mutiny.core.Vertx;
import io.vertx.reactivex.core.eventbus.EventBus;

public class SpaApplication {
    protected static final Logger logger = LoggerFactory.getLogger(SpaApplication.class.getName());
    protected EventBus eb;
    protected SpaDatabase spaDatabase;
    protected Vertx vertx;
    protected SpaCassandra spaCassandra;
    protected Boolean isCassandra = false;
    protected Boolean isFirebase = false;
    protected Boolean isNeo4j = false;
    protected SpaFirebase spaFirebase;
    protected SpaNeo4j spaNeo4j;

    public SpaApplication() throws InterruptedException, IOException, SQLException {
        Object spaDb =  SpaDbConfiguration.getSpaDb();
        if(spaDb instanceof SpaDatabase) {
            spaDatabase = (SpaDatabase)spaDb;
        } else if(spaDb instanceof SpaCassandra) {
            spaCassandra = (SpaCassandra)spaDb;
            isCassandra = true;
            CassandraRouter cassandraRouter = CDI.current().select(CassandraRouter.class).get();
            eb = cassandraRouter.getEb();
        } else if(spaDb instanceof SpaFirebase) {
            spaFirebase = SpaDbConfiguration.getSpaDb();
            FirebaseRouter firebaseRouter = CDI.current().select(FirebaseRouter.class).get();
            spaFirebase.setDbf(firebaseRouter.getDbf());
            isFirebase = true;
        } else if(spaDb instanceof SpaNeo4j) {
            spaNeo4j = SpaDbConfiguration.getSpaDb();
            Neo4jRouter neo4jRouter = CDI.current().select(Neo4jRouter.class).get();
            spaNeo4j.setDriver(neo4jRouter.getDriver());
            isNeo4j = true;
        } else {
            throw new InterruptedException(String.format("%s - %s","Database not supported", SpaDbConfiguration.getSpaDb()));
        }
    }

    public Future<Void> setDatabase(SpaDatabase spaDatabase) {
        if (DbConfiguration.isUsingCassandra() || DbConfiguration.isUsingFirebase()
            || DbConfiguration.isUsingNeo4j()) {
            io.vertx.core.Promise<Void> setupPromise = io.vertx.core.Promise.promise();
            setupPromise.complete();
            return setupPromise.future();
        }

        return spaDatabase.databaseSetup();
    }

    public Promise<SpaLogin> getLogin(String queryData) throws InterruptedException, ExecutionException, SQLException {
        SpaLogin spaLogin = createSpaLogin();
        JsonObject loginObject = new JsonObject(String.join("", "{\"data\":", queryData, "}"));
        String name;
        String password;
        if(!queryData.contains("[")) {
            name = loginObject.getJsonObject("data").getString("name");
            password = loginObject.getJsonObject("data").getString("password");
        } else {
            JsonArray data = loginObject.getJsonArray("data");
            name = data.getJsonObject(0).getString("value");
            password = data.getJsonObject(1).getString("value");
        }

        spaLogin.setName(name);
        spaLogin.setPassword(password);
        
        if (isCassandra.equals(true)) {
            return spaCassandra.getLogin(spaLogin, eb);
        } else if (isFirebase.equals(true)) {
            return spaFirebase.getLogin(spaLogin);
        } else if (isNeo4j.equals(true)) {
            return spaNeo4j.getLogin(spaLogin);
        }
        return spaDatabase.getLogin(spaLogin);
    }

    public Promise<SpaLogin> addLogin(String bodyData) throws InterruptedException, ExecutionException {
        SpaLogin spaLogin = createSpaLogin();
        JsonObject loginObject = new JsonObject(String.join("", "{\"data\":", bodyData, "}"));
        String userName = null;
        String password = null;
        JsonArray data = loginObject.getJsonArray("data");
        int size = loginObject.getJsonArray("data").getList().size();

        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");

        if (isCassandra.equals(true)) {
            return spaCassandra.addLogin(spaLogin, eb);
        } else if (isFirebase.equals(true)) {
            spaLogin.setId("0");
            return spaFirebase.addLogin(spaLogin);
        } else if (isNeo4j.equals(true)) {
            spaLogin.setId("0");
            return spaNeo4j.addLogin(spaLogin);
        }

        return spaDatabase.addLogin(spaLogin);
    }

    public Promise<SpaLogin> unregisterLogin(String queryData) throws InterruptedException, ExecutionException {
        SpaLogin spaLogin = createSpaLogin();
        Map<String, String> queryMap = mapQuery(queryData);

        String name = queryMap.get("user");
        String password = queryMap.get("password");

        spaLogin.setName(name);
        spaLogin.setPassword(password);
        
        if (isCassandra.equals(true)) {
            return spaCassandra.removeLogin(spaLogin, eb);
        } else if (isFirebase.equals(true)) {
            return spaFirebase.removeLogin(spaLogin);
        } else if (isNeo4j.equals(true)) {
            return spaNeo4j.removeLogin(spaLogin);
        }
        return spaDatabase.removeLogin(spaLogin);
    }

    public Map<String, String> mapQuery(String queryString) {
        return Arrays.stream(queryString.split("&")).map(s -> s.split("="))
                .collect(Collectors.toMap(s -> s[0], s -> s[1]));
    }

    // @Override
	public SpaLogin createSpaLogin() {
		return new SpaLoginImpl();
	}

    public Vertx getVertx() {
		return vertx;
	}
    
	public void setVertx(Vertx vertx) {
		this.vertx = vertx;
	}
}