/* -*- Mode: C++; tab-width: 4; c-basic-offset: 4; indent-tabs-mode: nil -*- */
/*
 *   Copyright 2020-2021 Couchbase, 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.
 */

#pragma once

#include <couchbase/fmt/key_value_extended_error_info.hxx>
#include <couchbase/fmt/key_value_status_code.hxx>

#include "client_opcode.hxx"
#include "client_opcode_fmt.hxx"
#include "cmd_info.hxx"
#include "core/io/mcbp_message.hxx"
#include "core/utils/byteswap.hxx"
#include "datatype.hxx"
#include "enhanced_error_info.hxx"
#include "frame_info_id.hxx"
#include "magic.hxx"
#include "magic_fmt.hxx"
#include "status.hxx"
#include <couchbase/cas.hxx>

#include <cmath>
#include <cstring>
#include <fmt/core.h>
#include <gsl/assert>
#include <optional>

namespace couchbase::core::protocol
{

double
parse_server_duration_us(const io::mcbp_message& msg);

bool
parse_enhanced_error(std::string_view str, key_value_extended_error_info& info);

template<typename Body>
class client_response
{
  private:
    Body body_;
    magic magic_{ magic::client_response };
    client_opcode opcode_{ client_opcode::invalid };
    header_buffer header_{};
    std::uint8_t data_type_{ 0 };
    std::vector<std::byte> data_{};
    std::uint16_t key_size_{ 0 };
    std::uint8_t framing_extras_size_{ 0 };
    std::uint8_t extras_size_{ 0 };
    std::size_t body_size_{ 0 };
    key_value_status_code status_{};
    std::optional<key_value_extended_error_info> error_;
    std::uint32_t opaque_{};
    std::uint64_t cas_{};
    cmd_info info_{};

  public:
    client_response() = default;
    explicit client_response(io::mcbp_message&& msg)
      : client_response(std::move(msg), {})
    {
    }

    client_response(io::mcbp_message&& msg, const cmd_info& info)
      : header_(msg.header_data())
      , data_(std::move(msg.body))
      , info_(info)
    {
        verify_header();
        parse_body();
    }

    [[nodiscard]] client_opcode opcode() const
    {
        return opcode_;
    }

    [[nodiscard]] key_value_status_code status() const
    {
        return status_;
    }

    [[nodiscard]] couchbase::cas cas() const
    {
        return couchbase::cas{ cas_ };
    }

    [[nodiscard]] std::uint32_t opaque() const
    {
        return opaque_;
    }

    Body& body()
    {
        return body_;
    }

    [[nodiscard]] const Body& body() const
    {
        return body_;
    }

    [[nodiscard]] header_buffer& header()
    {
        return header_;
    }

    void verify_header()
    {
        Expects(header_[0] == static_cast<std::byte>(magic::alt_client_response) ||
                header_[0] == static_cast<std::byte>(magic::client_response));
        Expects(header_[1] == static_cast<std::byte>(Body::opcode));
        magic_ = static_cast<magic>(header_[0]);
        opcode_ = static_cast<client_opcode>(header_[1]);
        data_type_ = std::to_integer<std::uint8_t>(header_[5]);

        std::uint16_t status = 0;
        memcpy(&status, header_.data() + 6, sizeof(status));
        status = utils::byte_swap(status);
        status_ = static_cast<key_value_status_code>(status);

        extras_size_ = std::to_integer<std::uint8_t>(header_[4]);
        if (magic_ == magic::alt_client_response) {
            framing_extras_size_ = std::to_integer<std::uint8_t>(header_[2]);
            key_size_ = std::to_integer<std::uint8_t>(header_[3]);
        } else {
            memcpy(&key_size_, header_.data() + 2, sizeof(key_size_));
            key_size_ = utils::byte_swap(key_size_);
        }

        std::uint32_t field = 0;
        memcpy(&field, header_.data() + 8, sizeof(field));
        body_size_ = utils::byte_swap(field);
        data_.resize(body_size_);

        memcpy(&opaque_, header_.data() + 12, sizeof(opaque_));
        opaque_ = utils::byte_swap(opaque_);

        memcpy(&cas_, header_.data() + 16, sizeof(cas_));
        cas_ = utils::byte_swap(cas_);
    }

    [[nodiscard]] std::optional<key_value_extended_error_info> error_info() const
    {
        return error_;
    }

    [[nodiscard]] std::string error_message() const
    {
        if (error_) {
            return fmt::format(R"(magic={}, opcode={}, status={}, error={})", magic_, opcode_, status_, *error_);
        }
        return fmt::format("magic={}, opcode={}, status={}", magic_, opcode_, status_);
    }

    void parse_body()
    {
        parse_framing_extras();
        bool parsed = body_.parse(status_, header_, framing_extras_size_, key_size_, extras_size_, data_, info_);
        if (status_ != key_value_status_code::success && !parsed && has_json_datatype(data_type_)) {
            key_value_extended_error_info err;
            std::vector<std::uint8_t>::difference_type offset = framing_extras_size_ + extras_size_ + key_size_;
            std::string_view enhanced_error_text{ reinterpret_cast<const char*>(data_.data()) + offset,
                                                  data_.size() - static_cast<std::size_t>(offset) };
            if (parse_enhanced_error(enhanced_error_text, err)) {
                error_.emplace(err);
            }
        }
    }

    void parse_framing_extras()
    {
        if (framing_extras_size_ == 0) {
            return;
        }
        size_t offset = 0;
        while (offset < framing_extras_size_) {
            auto frame_size = std::to_integer<std::uint8_t>(data_[offset] & std::byte{ 0b1111 });
            auto frame_id = std::to_integer<std::uint8_t>((data_[offset] >> 4U) & std::byte{ 0b1111 });
            ++offset;
            if (frame_id == static_cast<std::uint8_t>(response_frame_info_id::server_duration) && frame_size == 2 &&
                framing_extras_size_ - offset >= frame_size) {
                std::uint16_t encoded_duration{};
                std::memcpy(&encoded_duration, data_.data() + offset, sizeof(encoded_duration));
                encoded_duration = utils::byte_swap(encoded_duration);
                info_.server_duration_us = std::pow(encoded_duration, 1.74) / 2;
            }
            offset += frame_size;
        }
    }

    [[nodiscard]] std::vector<std::byte>& data()
    {
        return data_;
    }
};
} // namespace couchbase::core::protocol