// Copyright 2023 PingCAP, Inc.
//
// 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 <Columns/ColumnFixedString.h>
#include <Columns/ColumnString.h>
#include <Columns/ColumnsNumber.h>
#include <Common/TiFlashBuildInfo.h>
#include <DataTypes/DataTypeDate.h>
#include <DataTypes/DataTypeDateTime.h>
#include <DataTypes/DataTypeFixedString.h>
#include <DataTypes/DataTypeString.h>
#include <DataTypes/DataTypesNumber.h>
#include <Interpreters/QueryLog.h>
#include <Poco/Net/IPAddress.h>

#include <array>


namespace DB
{
Block QueryLogElement::createBlock()
{
    return {
        {ColumnUInt8::create(), std::make_shared<DataTypeUInt8>(), "type"},
        {ColumnUInt16::create(), std::make_shared<DataTypeDate>(), "event_date"},
        {ColumnUInt32::create(), std::make_shared<DataTypeDateTime>(), "event_time"},
        {ColumnUInt32::create(), std::make_shared<DataTypeDateTime>(), "query_start_time"},
        {ColumnUInt64::create(), std::make_shared<DataTypeUInt64>(), "query_duration_ms"},

        {ColumnUInt64::create(), std::make_shared<DataTypeUInt64>(), "read_rows"},
        {ColumnUInt64::create(), std::make_shared<DataTypeUInt64>(), "read_bytes"},

        {ColumnUInt64::create(), std::make_shared<DataTypeUInt64>(), "written_rows"},
        {ColumnUInt64::create(), std::make_shared<DataTypeUInt64>(), "written_bytes"},

        {ColumnUInt64::create(), std::make_shared<DataTypeUInt64>(), "result_rows"},
        {ColumnUInt64::create(), std::make_shared<DataTypeUInt64>(), "result_bytes"},

        {ColumnUInt64::create(), std::make_shared<DataTypeUInt64>(), "memory_usage"},

        {ColumnString::create(), std::make_shared<DataTypeString>(), "query"},
        {ColumnString::create(), std::make_shared<DataTypeString>(), "exception"},
        {ColumnString::create(), std::make_shared<DataTypeString>(), "stack_trace"},

        {ColumnUInt8::create(), std::make_shared<DataTypeUInt8>(), "is_initial_query"},

        {ColumnString::create(), std::make_shared<DataTypeString>(), "user"},
        {ColumnString::create(), std::make_shared<DataTypeString>(), "query_id"},
        {ColumnFixedString::create(16), std::make_shared<DataTypeFixedString>(16), "address"},
        {ColumnUInt16::create(), std::make_shared<DataTypeUInt16>(), "port"},

        {ColumnString::create(), std::make_shared<DataTypeString>(), "initial_user"},
        {ColumnString::create(), std::make_shared<DataTypeString>(), "initial_query_id"},
        {ColumnFixedString::create(16), std::make_shared<DataTypeFixedString>(16), "initial_address"},
        {ColumnUInt16::create(), std::make_shared<DataTypeUInt16>(), "initial_port"},

        {ColumnUInt8::create(), std::make_shared<DataTypeUInt8>(), "interface"},

        {ColumnString::create(), std::make_shared<DataTypeString>(), "os_user"},
        {ColumnString::create(), std::make_shared<DataTypeString>(), "client_hostname"},
        {ColumnString::create(), std::make_shared<DataTypeString>(), "client_name"},

        {ColumnUInt8::create(), std::make_shared<DataTypeUInt8>(), "http_method"},
        {ColumnString::create(), std::make_shared<DataTypeString>(), "http_user_agent"},

        {ColumnString::create(), std::make_shared<DataTypeString>(), "quota_key"},
    };
}


static std::array<char, 16> IPv6ToBinary(const Poco::Net::IPAddress & address)
{
    std::array<char, 16> res{};

    if (Poco::Net::IPAddress::IPv6 == address.family())
    {
        memcpy(res.data(), address.addr(), 16);
    }
    else if (Poco::Net::IPAddress::IPv4 == address.family())
    {
        /// Convert to IPv6-mapped address.
        memset(res.data(), 0, 10);
        res[10] = '\xFF';
        res[11] = '\xFF';
        memcpy(&res[12], address.addr(), 4);
    }
    else
        memset(res.data(), 0, 16);

    return res;
}


void QueryLogElement::appendToBlock(Block & block) const
{
    MutableColumns columns = block.mutateColumns();

    size_t i = 0;

    columns[i++]->insert(static_cast<UInt64>(type));
    columns[i++]->insert(static_cast<UInt64>(DateLUT::instance().toDayNum(event_time)));
    columns[i++]->insert(static_cast<UInt64>(event_time));
    columns[i++]->insert(static_cast<UInt64>(query_start_time));
    columns[i++]->insert((query_duration_ms));

    columns[i++]->insert((read_rows));
    columns[i++]->insert((read_bytes));

    columns[i++]->insert((written_rows));
    columns[i++]->insert((written_bytes));

    columns[i++]->insert((result_rows));
    columns[i++]->insert((result_bytes));

    columns[i++]->insert((memory_usage));

    columns[i++]->insertData(query.data(), query.size());
    columns[i++]->insertData(exception.data(), exception.size());
    columns[i++]->insertData(stack_trace.data(), stack_trace.size());

    columns[i++]->insert(static_cast<UInt64>(client_info.query_kind == ClientInfo::QueryKind::INITIAL_QUERY));

    columns[i++]->insert(client_info.current_user);
    columns[i++]->insert(client_info.current_query_id);
    columns[i++]->insertData(IPv6ToBinary(client_info.current_address.host()).data(), 16);
    columns[i++]->insert(static_cast<UInt64>(client_info.current_address.port()));

    columns[i++]->insert(client_info.initial_user);
    columns[i++]->insert(client_info.initial_query_id);
    columns[i++]->insertData(IPv6ToBinary(client_info.initial_address.host()).data(), 16);
    columns[i++]->insert(static_cast<UInt64>(client_info.initial_address.port()));

    columns[i++]->insert(static_cast<UInt64>(client_info.interface));

    columns[i++]->insert(client_info.os_user);
    columns[i++]->insert(client_info.client_hostname);
    columns[i++]->insert(client_info.client_name);

    columns[i++]->insert(client_info.quota_key);
    block.setColumns(std::move(columns));
}

} // namespace DB