package vpn.com.hamzatest.routing;

public class Config {
    public static final int CODE_SUCCEED = 0;

    public static final String SERVER_HOST = "http://www.vpngate.net:8080";
    //    public static final String SERVER_PORT = "8080";
}

public class ApiClient {

    private static OkHttpClient client = new OkHttpClient();
    private static final MediaType mediaType = MediaType.parse("application/x-www-form-urlencoded; charset=utf-8");

    //    private static final String PROTOCAL = "http";
    private static final String API_PREFIX = "";
    private static final String HOST = Config.SERVER_HOST + API_PREFIX;

    private static final String registerUrl = "";
    private static final String getUserDataUrl = "";
    private static final String getConnectionUrl = "/connection";
    private static final String delConnectionUrl = "/connection";
    private static final String signinUrl = "/signIn";
    private static final String inviteUrl = "/invite";
    private static final String serverListUrl = "/serverlist";

    public static VultureContract.User register(String username, String password) throws IOException {
        RequestBody rb = RequestBody.create(mediaType, "username=" + username + "&" + "password=" + password);
        Request req = new Request.Builder()
                .url(HOST + registerUrl)
                .post(rb)
                .build();
        Response res = client.newCall(req).execute();
        Gson gson = new Gson();
        String re = res.body().string();
        ApiResponse rr = gson.fromJson(re, RegisterResponse.class);
        // close body avoid leak
        res.body().close();
        if (rr != null && rr.success()) {
            return new VultureUser(username, password);
        } else {
            return null;
        }
    }

    public static VultureUserData getUserData(String username, String password) throws IOException {
        Request req = new Request.Builder()
                .url(HOST + getUserDataUrl + "/" + username + "?password=" + password)
                .get()
                .build();
        Response res = client.newCall(req).execute();
        Gson gson = new Gson();
        String re = res.body().string();
        ApiResponse udr = gson.fromJson(re, UserDataResponse.class);
        // close body avoid leak
        res.body().close();
        if (udr != null && udr.success()) {
            return (VultureUserData) udr.getMessage();
        } else {
            return null;
        }
    }

    public static VultureConnection getConnection(String username, String password) throws IOException {
        Request req = new Request.Builder()
                .url(HOST + "/" + username + getConnectionUrl + "?password=" + password)
                .get()
                .build();
        Response res = client.newCall(req).execute();
        Gson gson = new Gson();
        String re = res.body().string();
        ApiResponse gcr = gson.fromJson(re, GetConnectionResponse.class);
        // close body avoid leak
        res.body().close();
        if (gcr != null && gcr.success()) {
            return (VultureConnection) gcr.getMessage();
        } else {
            return null;
        }
    }

    public static VultureConnection getSpecifyConnection(String username, String password, String serverIp) throws IOException {
        Request req = new Request.Builder()
                .url(HOST + "/" + username + getConnectionUrl + "?password=" + password + "&server=" + serverIp)
                .get()
                .build();
        Response res = client.newCall(req).execute();
        Gson gson = new Gson();
        String re = res.body().string();
        ApiResponse gcr = gson.fromJson(re, GetConnectionResponse.class);
        // close body avoid leak
        res.body().close();
        if (gcr != null && gcr.success()) {
            return (VultureConnection) gcr.getMessage();
        } else {
            return null;
        }
    }

    public static boolean deleteConnection(String username, String password) throws IOException {
        Request req = new Request.Builder()
                .url(HOST + "/" + username + delConnectionUrl + "?password=" + password)
                .delete()
                .build();
        Response res = client.newCall(req).execute();
        Gson gson = new Gson();
        String re = res.body().string();
        ApiResponse dcr = gson.fromJson(re, DelConnectionResponse.class);
        // close body avoid leak
        res.body().close();
        return dcr != null && dcr.success();
    }

    public static boolean signIn(String username) throws IOException {
        Request req = new Request.Builder()
                .url(HOST + "/" + username + signinUrl)
                .get()
                .build();
        Response res = client.newCall(req).execute();
        Gson gson = new Gson();
        String re = res.body().string();
        ApiResponse sr = gson.fromJson(re, SignResponse.class);
        // close body avoid leak
        res.body().close();
        return sr != null && sr.success();
    }

    public static boolean invite(String username, String password, String code) throws IOException {
        RequestBody rb = RequestBody.create(mediaType, "username=" + username + "&" + "password=" + password + "&" + "code=" + code);
        Request req = new Request.Builder()
                .url(HOST + "/" + username + inviteUrl)
                .post(rb)
                .build();
        Response res = client.newCall(req).execute();
        Gson gson = new Gson();
        String re = res.body().string();
        ApiResponse ir = gson.fromJson(re, InviteResponse.class);
        // close body avoid leak
        res.body().close();
        return ir != null && ir.success();
    }

    public static VultureServer[] getServerList(String username) throws IOException {
        Request req = new Request.Builder()
                .url(HOST + "/" + username + serverListUrl)
                .get()
                .build();
        Response res = client.newCall(req).execute();
        Gson gson = new Gson();
        String re = res.body().string();
        ApiResponse ir = gson.fromJson(re, GetServerListResponse.class);
        // close body avoid leak
        res.body().close();
        if (ir != null && ir.success()) {
            return (VultureServer[]) ir.getMessage();
        }else{
            return null;
        }
    }

    // return -1 when timeout
    public static long pingServer(String serverIp){
        long msBefore = System.currentTimeMillis();

        Request req = new Request.Builder()
                .url("http://" + serverIp)
                .get()
                .build();
        try {
            Response res = client.newCall(req).execute();
            // close body avoid leak
            res.body().close();
        } catch (IOException e) {
            e.printStackTrace();
            return -1;
        }
        long msAfter = System.currentTimeMillis();
        return msAfter - msBefore;
    }

}