require("commonrequire")
local UIManager = require("ui/uimanager")
local HTTPClient = require("httpclient")
local DEBUG = require("dbg")
--DEBUG:turnOn()

local service = [[
{
    "base_url" : "http://httpbin.org",
    "name" : "api",
    "methods" : {
        "get_info" : {
            "path" : "/get",
            "method" : "GET",
            "required_params" : [
                "user"
            ],
            "optional_params" : [
                "age"
            ],
        },
        "post_info" : {
            "path" : "/post",
            "method" : "POST",
            "required_params" : [
                "user"
            ],
            "optional_params" : [
                "age"
            ],
            "payload" : [
                "user",
                "age",
            ],
        },
    }
}
]]

describe("Lua Spore modules #notest #nocov", function()
    local Spore = require("Spore")
    local client = Spore.new_from_string(service)
    client:enable('Format.JSON')
    it("should complete GET request", function()
        local info = {user = 'john', age = '25'}
        local res = client:get_info(info)
        assert.are.same(res.body.args, info)
    end)
    it("should complete POST request", function()
        local info = {user = 'sam', age = '26'}
        local res = client:post_info(info)
        assert.are.same(res.body.json, info)
    end)
end)

describe("Lua Spore modules with async http request #notest #nocov", function()
    local Spore = require("Spore")
    local client = Spore.new_from_string(service)
    local async_http_client = HTTPClient:new()
    package.loaded['Spore.Middleware.AsyncHTTP'] = {}
    require('Spore.Middleware.AsyncHTTP').call = function(args, req)
        req:finalize()
        local result
        async_http_client:request({
            url = req.url,
            method = req.method,
            body = req.env.spore.payload,
            on_headers = function(headers)
                for header, value in pairs(req.headers) do
                    if type(header) == 'string' then
                        headers:add(header, value)
                    end
                end
            end,
        }, function(res)
            result = res
            -- Turbo HTTP client uses code instead of status
            -- change to status so that Spore can understand
            result.status = res.code
            coroutine.resume(args.thread)
            UIManager.INPUT_TIMEOUT = 100 -- no need in production
        end)
        return coroutine.create(function() coroutine.yield(result) end)
    end
    it("should complete GET request", function()
        UIManager:quit()
        local co = coroutine.create(function()
            local info = {user = 'john', age = '25'}
            local res = client:get_info(info)
            UIManager:quit()
            assert.are.same(res.body.args, info)
        end)
        client:reset_middlewares()
        client:enable("Format.JSON")
        client:enable("AsyncHTTP", {thread = co})
        coroutine.resume(co)
        UIManager:runForever()
    end)
    it("should complete POST request", function()
        UIManager:quit()
        local co = coroutine.create(function()
            local info = {user = 'sam', age = '26'}
            local res = client:post_info(info)
            UIManager:quit()
            assert.are.same(res.body.json, info)
        end)
        client:reset_middlewares()
        client:enable("Format.JSON")
        client:enable("AsyncHTTP", {thread = co})
        coroutine.resume(co)
        UIManager:runForever()
    end)
end)