-- Copyright © by Jeff Foley 2017-2023. All rights reserved.
-- Use of this source code is governed by Apache 2 LICENSE that can be found in the LICENSE file.
-- SPDX-License-Identifier: Apache-2.0

local json = require("json")

name = "WhoisXMLAPI"
type = "api"

function start()
    set_rate_limit(2)
end

function check()
    local c
    local cfg = datasrc_config()
    if (cfg ~= nil) then
        c = cfg.credentials
    end

    if (c ~= nil and c.key ~= nil and c.key ~= "") then
        return true
    end
    return false
end

function vertical(ctx, domain)
    local c
    local cfg = datasrc_config()
    if (cfg ~= nil) then
        c = cfg.credentials
    end

    if (c == nil or c.key == nil or c.key == "") then
        return
    end

    local resp, err = request(ctx, {['url']=build_url(domain, c.key)})
    if (err ~= nil and err ~= "") then
        log(ctx, "vertical request to service failed: " .. err)
        return
    elseif (resp.status_code < 200 or resp.status_code >= 400) then
        log(ctx, "vertical request to service returned with status: " .. resp.status)
        return
    end

    local d = json.decode(resp.body)
    if (d == nil) then
        log(ctx, "failed to decode the JSON response")
        return
    elseif (d.result == nil or d['result'].count == nil or d['result'].count == 0) then
        return
    end

    for _, r in pairs(d['result'].records) do
        if (r.domain ~= nil and r.domain ~= "") then
            new_name(ctx, r.domain)
        end
    end
end

function build_url(domain, key)
    return "https://subdomains.whoisxmlapi.com/api/v1?apiKey=" .. key .. "&domainName=" .. domain
end

function horizontal(ctx, domain)
    local c
    local cfg = datasrc_config()
    if (cfg ~= nil) then
        c = cfg.credentials
    end

    if (c == nil or c.key == nil or c.key == "") then
        return
    end

    local body, err = json.encode({
        ['apiKey']=c.key, 
        ['searchType']="current",
        ['mode']="purchase",
        ['basicSearchTerms']={include={domain}},
    })
    if (err ~= nil and err ~= "") then
        return
    end

    local resp, err = request(ctx, {
        ['url']="https://reverse-whois.whoisxmlapi.com/api/v2",
        ['method']="POST",
        ['header']={['Content-Type']="application/json"},
        ['body']=body,
    })
    if (err ~= nil and err ~= "") then
        log(ctx, "horizontal request to service failed: " .. err)
        return
    elseif (resp.status_code < 200 or resp.status_code >= 400) then
        log(ctx, "horizontal request to service returned with status: " .. resp.status)
        return
    end

    local d = json.decode(resp.body)
    if (d == nil) then
        log(ctx, "failed to decode the JSON horizontal response")
        return
    elseif (d.domainsList == nil or d.domainsCount == nil or d.domainsCount == 0) then
        return
    end

    for _, name in pairs(d.domainsList) do
        if (name ~= nil and name ~= "") then
            associated(ctx, domain, name)
        end
    end
end

function asn(ctx, addr, asn)
    local c
    local cfg = datasrc_config()
    if (cfg ~= nil) then
        c = cfg.credentials
    end

    if (c == nil or c.key == nil or c.key == "") then
        return
    end

    local prefix
    if (asn == 0) then
        if (addr == "") then
            return
        end

        asn = get_asn(ctx, addr, c.key)
        if (asn == 0) then
            return
        end
    end

    local a = as_info(ctx, asn, c.key)
    if (a == nil) then
        return
    end

    new_asn(ctx, {
        ['addr']=addr,
        ['asn']=asn,
        ['prefix']=a.netblocks[1],
        ['cc']=a.cc,
        ['registry']=a.registry,
        ['desc']=a.desc,
        ['netblocks']=a.netblocks,
    })
end

function get_asn(ctx, ip, key)
    local url = "https://ip-netblocks.whoisxmlapi.com/api/v2?apiKey=" .. key .. "&ip=" .. ip

    local resp, err = request(ctx, {['url']=url})
    if (err ~= nil and err ~= "") then
        log(ctx, "get_asn request to service failed: " .. err)
        return 0
    elseif (resp.status_code < 200 or resp.status_code >= 400) then
        log(ctx, "get_asn request to service returned with status: " .. resp.status)
        return 0
    end

    local d = json.decode(resp.body)
    if (d == nil) then
    elseif (d.result == nil or d['result'].count == nil or d['result'].count == 0) then
        return
    elseif (d['result'].inetnums == nil or #(d['result'].inetnums) == 0) then
        return
    end

    local asn = 0
    for _, r in pairs(d['result'].inetnums) do
        if r.as ~= nil and r['as'].asn ~= nil and r['as'].asn > 0 then
            asn = r['as'].asn
            break
        end
    end

    return asn
end

function as_info(ctx, asn, key)
    local url = "https://ip-netblocks.whoisxmlapi.com/api/v2?apiKey=" .. key .. "&asn=" .. tostring(asn)

    local resp, err = request(ctx, {['url']=url})
    if (err ~= nil and err ~= "") then
        log(ctx, "as_info request to service failed: " .. err)
        return nil
    elseif (resp.status_code < 200 or resp.status_code >= 400) then
        log(ctx, "as_info request to service returned with status: " .. resp.status)
        return nil
    end

    local d = json.decode(resp.body)
    if (d == nil) then
    elseif (d.result == nil or d['result'].count == nil or d['result'].count == 0) then
        return
    elseif (d['result'].inetnums == nil or #(d['result'].inetnums) == 0) then
        return
    end

    local cc = ""
    local name = ""
    local registry = ""
    local netblocks = {}
    for i, r in pairs(d['result'].inetnums) do
        if i == 1 then
            registry = r.source
            if r.org ~= nil then
                cc = r.org.country
                name = r.org.name
            end
        end
        if r.as ~= nil and r['as'].asn == asn and r['as'].route ~= nil and r['as'].route ~= "" then
            table.insert(netblocks, r['as'].route)
        end
    end

    return {
        ['asn']=asn,
        ['desc']=name,
        ['cc']=cc,
        ['registry']=registry,
        ['netblocks']=netblocks,
    }
end