import socketFactory from "./letsEncryptCerts"

if (!global.networkUtilsThingSoopyPromise) {

    let jURL = Java.type("java.net.URL")
    let jStandardCharsets = Java.type("java.nio.charset.StandardCharsets")
    let jCollectors = Java.type("java.util.stream.Collectors")
    let jBufferedReader = Java.type("java.io.BufferedReader")
    let jInputStreamReader = Java.type("java.io.InputStreamReader")
    let jString = Java.type("java.lang.String")
    var JHttpsUrlConnection = Java.type('javax.net.ssl.HttpsURLConnection');

    function getUrlContent(theUrl, { userAgent = "Mozilla/5.0", includeConnection = false, postData = undefined } = {}) {

        if (global.soopyv2loggerthing) {
            global.soopyv2loggerthing.logMessage("Loading API: " + theUrl, 4)
        }

        // if(theUrl.includes("soopy.dev")){
        //     throw new Error("Testing to ensure the module works when my server is down")
        // }
        // Thread.sleep(1000) //simulating high ping

        let conn = new jURL(theUrl).openConnection()
        if (conn instanceof JHttpsUrlConnection) {
            conn.setSSLSocketFactory(socketFactory);
        }
        conn.setRequestProperty("User-Agent", userAgent)

        if (postData) {
            conn.setRequestMethod("POST");
            conn.setRequestProperty("Content-Type", "application/json");
            conn.setDoOutput(true);

            let jsonInputString = new jString(JSON.stringify(postData))

            let os
            try {
                os = conn.getOutputStream()
                input = jsonInputString.getBytes("utf-8");
                os.write(input, 0, input.length);
            } finally {
                os.close()
            }
        }

        let stringData

        if (conn.getResponseCode() < 400) {
            stringData = new jBufferedReader(
                new jInputStreamReader(conn.getInputStream(), jStandardCharsets.UTF_8))
                .lines()
                .collect(jCollectors.joining("\n"));

            conn.getInputStream().close()
        } else {
            stringData = new jBufferedReader(
                new jInputStreamReader(conn.getErrorStream(), jStandardCharsets.UTF_8))
                .lines()
                .collect(jCollectors.joining("\n"));

            conn.getErrorStream().close()
        }

        if (includeConnection) {
            return { stringData, connection: conn }
        }

        return stringData
    }

    function fetch(url, options = { userAgent: "Mozilla/5.0" }) {
        let loadedConnection = undefined
        let loadedString = undefined
        let loadedJSON = undefined

        let ret = {
            loadSync() {
                if (loadedString === undefined) {
                    options.includeConnection = true

                    try {
                        let data = getUrlContent(url, options)
                        loadedString = data.stringData
                        loadedConnection = data.connection
                    } catch (e) {
                        errorData = e
                        loadedString = null
                    }
                }

                return ret
            },
            async load(_ifError = false) {
                if (loadedString === undefined) {
                    options.includeConnection = true

                    await new Promise((res, rej) => {
                        pendingRequests.push({
                            callback: (data) => {
                                loadedString = data.stringData
                                loadedConnection = data.connection
                                res()
                            },
                            errcallback: (e) => {
                                rej(e)
                            },
                            url: url,
                            options: options
                        })
                    })
                }
            },
            textSync() {
                ret.loadSync()

                return loadedString
            },
            async text() {
                await ret.load()

                return loadedString
            },
            jsonSync() {
                if (loadedJSON === undefined) {
                    let str = ret.textSync()

                    loadedJSON = JSON.parse(str)
                }

                return loadedJSON
            },
            async json() {
                if (loadedJSON === undefined) {
                    let str = await ret.text()

                    loadedJSON = JSON.parse(str)
                }

                return loadedJSON
            },
            responseCode() {
                return loadedConnection?.getResponseCode() || -1
            }
        }
        return ret
    }

    let pendingRequests = []
    let pendingResolves = []
    let runningThread = false

    register("tick", () => {
        try {
            while (pendingResolves.length > 0) {
                let [callback, data] = pendingResolves.shift()

                callback(data)
            }
        } catch (e) {
            console.log(JSON.stringify(e, undefined, 2))
            console.log(e.stack)
        }

        if (pendingRequests.length > 0 && !runningThread) {
            runningThread = true
            new Thread(() => {
                while (pendingRequests.length > 0) {
                    let req = pendingRequests.shift()

                    try {
                        let data = getUrlContent(req.url, req.options)

                        pendingResolves.push([req.callback, data])
                    } catch (e) {
                        pendingResolves.push([req.errcallback, e])
                    }
                }

                runningThread = false
            }).start()
        }
    })

    global.networkUtilsThingSoopyPromise = fetch
}

export default global.networkUtilsThingSoopyPromise