import rxjs, { ajax } from "../rxjs/index.js";
import { AjaxError } from "../error/index.js";

export default function(opts) {
    if (typeof opts === "string") opts = { url: opts };
    else if (typeof opts !== "object") throw new Error("unsupported call");
    if (!opts.headers) opts.headers = {};
    opts.headers["X-Requested-With"] = "XmlHttpRequest";
    const isJson = opts.responseType;
    return ajax({ ...opts, responseType: "text"}).pipe(
        rxjs.catchError((err) => rxjs.throwError(processError(err.xhr, err))),
        rxjs.map((res) => {
            let result = res.xhr.responseText;
            if (opts.responseType === "json") {
                const json = JSON.parse(result);
                if (json["status"] !== "ok") {
                    throw new AjaxError("Oups something went wrong", result);
                }
                res["responseJSON"] = json;
            }
            return res;
        }),
    );
}

function processError(xhr, err) {
    const response = (function(content) {
        let message = content;
        try {
            message = JSON.parse(content);
        } catch (err) {
            return {
                message: Array.from(new Set(
                    content.replace(/<[^>]*>/g, "")
                        .replace(/\n{2,}/, "\n")
                        .trim()
                        .split("\n")
                )).join(" "),
            };
        }
        return message || { message: "empty response" };
    })(xhr.responseText);

    const message = response.message || null;

    if (navigator.onLine === false) {
        return new AjaxError("Connection Lost", err, "NO_INTERNET");
    }
    switch(xhr.status) {
    case 500:
        return new AjaxError(
            message || "Oups something went wrong with our servers",
            err, "INTERNAL_SERVER_ERROR",
        );
        break;
    case 401:
        return new AjaxError(
            message || "Authentication error",
            err, "Unauthorized",
        );
    case 403:
        return new AjaxError(
            message || "You can\'t do that",
            err, "FORBIDDEN",
        );
        break;
    case 413:
        return new AjaxError(
            message || "Payload too large",
            err, "PAYLOAD_TOO_LARGE",
        );
    case 502:
        return new AjaxError(
            message || "The destination is acting weird",
            err, "BAD_GATEWAY",
        );
    case 409:
        if (response["error_summary"]) { // dropbox way to say doesn't exist
            return new AjaxError(
                "Doesn\'t exist",
                err, "UNKNOWN_PATH",
            );
        }
        return new AjaxError(
            message || "Oups you just ran into a conflict",
            err, "CONFLICT",
        );
    case 0:
        switch(xhr.responseText) {
        case "":
            return new AjaxError(
                "Service unavailable, if the problem persist, contact your administrator",
                err, "INTERNAL_SERVER_ERROR",
            );
            break;
        default:
            return new AjaxError(xhr.responseText, err, "INTERNAL_SERVER_ERROR");
        }
    default:
        return new AjaxError(message || "Oups something went wrong", err);
    }
}