/*
 * Copyright (c) 2022-2023 Huawei Device Co., Ltd.
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

#include <pthread.h>
#include <thread>

#include "dns_resolv_listen.h"
#include "netmanager_base_common_utils.h"
#include "netnative_log_wrapper.h"
#include "singleton.h"
#include "dns_quality_diag.h"

#include "dns_manager.h"
#include <netdb.h>

namespace OHOS {
namespace nmd {
using namespace OHOS::NetManagerStandard::CommonUtils;

void StartListen()
{
    NETNATIVE_LOG_D("Enter threadStart");
    DnsResolvListen().StartListen();
}

DnsManager::DnsManager() : dnsProxyListen_(std::make_shared<DnsProxyListen>())
{
    std::thread t(StartListen);
    std::string threadName = "DnsMgerListen";
    pthread_setname_np(t.native_handle(), threadName.c_str());
    t.detach();
}

void DnsManager::EnableIpv6(uint16_t netId, std::string &destination, const std::string &nextHop)
{
    auto pos = destination.find("/");
    if (pos != std::string::npos) {
        destination = destination.substr(0, pos);
    }
    if (!(IsValidIPV6(destination) && (IsValidIPV6(nextHop) || nextHop.empty()))) {
        NETNATIVE_LOGE("check IsValidIPV6 faild");
        return;
    }
    DnsParamCache::GetInstance().EnableIpv6(netId);
}

int32_t DnsManager::SetResolverConfig(uint16_t netId, uint16_t baseTimeoutMillis, uint8_t retryCount,
                                      const std::vector<std::string> &servers, const std::vector<std::string> &domains)
{
    NETNATIVE_LOG_D("manager_SetResolverConfig netId[%{public}d]", netId);
    return DnsParamCache::GetInstance().SetResolverConfig(netId, baseTimeoutMillis, retryCount, servers, domains);
}

int32_t DnsManager::GetResolverConfig(uint16_t netId, std::vector<std::string> &servers,
                                      std::vector<std::string> &domains, uint16_t &baseTimeoutMillis,
                                      uint8_t &retryCount)
{
    NETNATIVE_LOG_D("manager_GetResolverConfig netId[%{public}d]", netId);
    return DnsParamCache::GetInstance().GetResolverConfig(netId, servers, domains, baseTimeoutMillis, retryCount);
}

int32_t DnsManager::CreateNetworkCache(uint16_t netId)
{
    NETNATIVE_LOG_D("manager_CreateNetworkCache netId[%{public}d]", netId);
    return DnsParamCache::GetInstance().CreateCacheForNet(netId);
}

int32_t DnsManager::DestroyNetworkCache(uint16_t netId)
{
    return DnsParamCache::GetInstance().DestroyNetworkCache(netId);
}

void DnsManager::SetDefaultNetwork(uint16_t netId)
{
    DnsParamCache::GetInstance().SetDefaultNetwork(netId);
}

void StartProxyListen()
{
    NETNATIVE_LOG_D("begin StartProxyListen");
    DnsProxyListen().StartListen();
}

void DnsManager::ShareDnsSet(uint16_t netId)
{
    dnsProxyListen_->SetParseNetId(netId);
}

void DnsManager::StartDnsProxyListen()
{
    dnsProxyListen_->OnListen();
    std::thread t(StartProxyListen);
    std::string threadName = "DnsPxyListen";
    pthread_setname_np(t.native_handle(), threadName.c_str());
    t.detach();
}

void DnsManager::StopDnsProxyListen()
{
    dnsProxyListen_->OffListen();
}

void DnsManager::GetDumpInfo(std::string &info)
{
    NETNATIVE_LOG_D("Get dump info");
    DnsParamCache::GetInstance().GetDumpInfo(info);
}

int32_t DnsManager::GetAddrInfo(const std::string &hostName, const std::string &serverName, const AddrInfo &hints,
                                uint16_t netId, std::vector<AddrInfo> &res)
{
    if (netId == 0) {
        netId = DnsParamCache::GetInstance().GetDefaultNetwork();
        NETNATIVE_LOG_D("DnsManager DnsGetaddrinfo netId == 0 defaultNetId_ : %{public}d", netId);
    }
    struct addrinfo hint = {};
    struct addrinfo *result;
    struct queryparam qparam = {};

    if ((hostName.size() == 0) && (serverName.size() == 0)) {
        return -1;
    }

    qparam.qp_netid = netId;
    qparam.qp_type = 1;

    hint.ai_family = hints.aiFamily;
    hint.ai_flags = hints.aiFlags;
    hint.ai_protocol = hints.aiProtocol;
    hint.ai_socktype = hints.aiSockType;
 
    int32_t ret = getaddrinfo_ext(((hostName.size() == 0) ? NULL : hostName.c_str()),
                                  ((serverName.size() == 0) ? NULL : serverName.c_str()),
                                  &hint, &result, &qparam);
    if (ret == 0) {
        ret = FillAddrInfo(res, result);
        freeaddrinfo(result);
    }

    return ret;
}

int32_t DnsManager::RegisterDnsResultCallback(const sptr<NetsysNative::INetDnsResultCallback> &callback,
                                              uint32_t timeStep)
{
    return DnsQualityDiag::GetInstance().RegisterResultListener(callback, timeStep);
}

int32_t DnsManager::UnregisterDnsResultCallback(const sptr<NetsysNative::INetDnsResultCallback> &callback)
{
    return DnsQualityDiag::GetInstance().UnregisterResultListener(callback);
}

int32_t DnsManager::RegisterDnsHealthCallback(const sptr<NetsysNative::INetDnsHealthCallback> &callback)
{
    return DnsQualityDiag::GetInstance().RegisterHealthListener(callback);
}

int32_t DnsManager::UnregisterDnsHealthCallback(const sptr<NetsysNative::INetDnsHealthCallback> &callback)
{
    return DnsQualityDiag::GetInstance().UnregisterHealthListener(callback);
}

int32_t DnsManager::AddUidRange(int32_t netId, const std::vector<NetManagerStandard::UidRange> &uidRanges)
{
    NETNATIVE_LOG_D("DnsManager::AddUidRange");
    return DnsParamCache::GetInstance().AddUidRange(netId, uidRanges);
}

int32_t DnsManager::DelUidRange(int32_t netId, const std::vector<NetManagerStandard::UidRange> &uidRanges)
{
    NETNATIVE_LOG_D("DnsManager::DelUidRange");
    return DnsParamCache::GetInstance().DelUidRange(netId, uidRanges);
}

int32_t DnsManager::FillAddrInfo(std::vector<AddrInfo> &addrInfo, addrinfo *res)
{
    int32_t resNum = 0;
    addrinfo *tmp = res;

    while (tmp) {
        AddrInfo info;
        info.aiFlags = static_cast<int32_t>(tmp->ai_flags);
        info.aiFamily = static_cast<int32_t>(tmp->ai_family);
        info.aiSockType = static_cast<int32_t>(tmp->ai_socktype);
        info.aiProtocol = static_cast<int32_t>(tmp->ai_protocol);
        info.aiAddrLen = tmp->ai_addrlen;
        if (memcpy_s(&info.aiAddr, sizeof(info.aiAddr), tmp->ai_addr, tmp->ai_addrlen) != 0) {
            NETNATIVE_LOGE("memcpy_s failed");
        }
        if (strcpy_s(info.aiCanonName, sizeof(info.aiCanonName), tmp->ai_canonname) != 0) {
            NETNATIVE_LOGE("strcpy_s failed");
        }

        ++resNum;
        addrInfo.emplace_back(info);
        tmp = tmp->ai_next;
        if (resNum >= MAX_RESULTS) {
            break;
        }
    }
    NETNATIVE_LOGI("FillAddrInfo %{public}d", resNum);
    return 0;
}

#ifdef FEATURE_NET_FIREWALL_ENABLE
int32_t DnsManager::SetFirewallDefaultAction(FirewallRuleAction inDefault, FirewallRuleAction outDefault)
{
    return DnsParamCache::GetInstance().SetFirewallDefaultAction(inDefault, outDefault);
}

int32_t DnsManager::SetFirewallCurrentUserId(int32_t userId)
{
    return DnsParamCache::GetInstance().SetFirewallCurrentUserId(userId);
}

int32_t DnsManager::SetFirewallRules(NetFirewallRuleType type, const std::vector<sptr<NetFirewallBaseRule>> &ruleList,
                                     bool isFinish)
{
    return DnsParamCache::GetInstance().SetFirewallRules(type, ruleList, isFinish);
}

int32_t DnsManager::ClearFirewallRules(NetFirewallRuleType type)
{
    return DnsParamCache::GetInstance().ClearFirewallRules(type);
}

int32_t DnsManager::RegisterNetFirewallCallback(const sptr<NetsysNative::INetFirewallCallback> &callback)
{
    return DnsParamCache::GetInstance().RegisterNetFirewallCallback(callback);
}
int32_t DnsManager::UnRegisterNetFirewallCallback(const sptr<NetsysNative::INetFirewallCallback> &callback)
{
    return DnsParamCache::GetInstance().UnRegisterNetFirewallCallback(callback);
}
#endif
} // namespace nmd
} // namespace OHOS