usersEntryPoint.lua

require('si_configReader')

local json = require('json')
local log = require('log')
local controller = {}

local function new()
    controller._repository = require('repository')

    return controller
end

local function isNumber(value)
    local result, _ = pcall(function() math.floor(value) end)
    return result
end

local function parseId(uri)
    return tonumber(string.split(string.split(uri, '/')[3], '?')[1])
end

local function getUser(id)
    return controller._repository.getUser(id);
end

local function getUserVisits(id, fromDate, toDate, country, toDistance)
    if (fromDate ~= nil and not isNumber(fromDate))
            or (toDate ~= nil and not isNumber(toDate))
            or (toDistance ~= nil and not isNumber(toDistance))
            or (country ~= nil and type(country) ~= 'string') then
        return 400, {}
    end
    fromDate = tonumber(fromDate)
    toDate = tonumber(toDate)
    toDistance = tonumber(toDistance)
    if country ~= nil then
        country = country:gsub('+', ' ')
    end
    local status, visits = controller._repository.getUserVisits(id, fromDate, toDate, country, toDistance);
    local response = {}
    response.visits = visits
    return status, response
end

local function saveUser(userJson)
    if userJson.id == nil or not isNumber(userJson.id) then
        return 400
    end

    for _, value in pairs(userJson) do
        if value == nil then
            return 400
        end
    end
    return controller._repository.saveUser(userJson);
end

local function updateUser(userId, userJson)
    for arg, value in pairs(userJson) do
        if arg == 'id' then
            return 400
        end
        if value == nil then
            return 400
        end
    end
    if (userJson.birth_date ~= nil and not isNumber(userJson.birth_date)) then
        return 400
    end

    return controller._repository.updateUser(userId, userJson);
end

function userEndpoint(req)
    local status = 200
    local response = {}
    if req.method == 'GET' then
        local userId = parseId(req.uri)
        if string.match(req.uri, '/visits') then
            local s, r = getUserVisits(userId, req.args.fromDate, req.args.toDate, req.args.country, req.args.toDistance)
            status = s
            response = r
        else
            response = getUser(userId)
            if not response then
                status = 404
            end
        end
    end
    if req.method == 'POST' then
        local parseStatus, jsonBody = pcall(function()
            return json.decode(req.body)
        end)
        if not parseStatus then
            return 400, response
        end
        if string.match(req.uri, '/new') then
            status = saveUser(jsonBody)
        else
            local userId = parseId(req.uri)
            status = updateUser(userId, jsonBody)
        end
    end

    return status, response
end

return {
    new = new
}