/*
 * Copyright (c) 2023, Caoimhe Byrne <caoimhebyrne06@gmail.com>
 *
 * SPDX-License-Identifier: BSD-2-Clause
 */

#include "Message.h"
#include <AK/MemoryStream.h>
#include <AK/Stream.h>
#include <AK/String.h>

namespace SpiceAgent {

ErrorOr<String> clipboard_data_type_to_mime_type(ClipboardDataType data_type)
{
    switch (data_type) {
    case ClipboardDataType::Text:
        return "text/plain"_string;

    case ClipboardDataType::PNG:
        return "image/png"_string;

    case ClipboardDataType::BMP:
        return "image/bitmap"_string;

    case ClipboardDataType::JPG:
        return "image/jpeg"_string;

    case ClipboardDataType::TIFF:
        return "image/tiff"_string;

    default:
        return Error::from_string_literal("Unable to determine mime type!");
    }
}

ErrorOr<ClipboardDataType> clipboard_data_type_from_raw_value(u32 value)
{
    if (value >= to_underlying(ClipboardDataType::__End)) {
        return Error::from_string_literal("Unsupported clipboard type");
    }

    return static_cast<ClipboardDataType>(value);
}

ErrorOr<ClipboardDataType> clipboard_data_type_from_mime_type(String const& mime_type)
{
    if (mime_type == "text/plain")
        return ClipboardDataType::Text;

    // We treat image/x-serenityos as a standard PNG here
    if (mime_type == "image/png" || mime_type == "image/x-serenityos")
        return ClipboardDataType::PNG;

    if (mime_type == "image/bitmap")
        return ClipboardDataType::BMP;

    if (mime_type == "image/jpeg")
        return ClipboardDataType::JPG;

    if (mime_type == "image/tiff")
        return ClipboardDataType::TIFF;

    return Error::from_string_literal("Unable to determine clipboard data type!");
}

ErrorOr<AnnounceCapabilitiesMessage> AnnounceCapabilitiesMessage::read_from_stream(AK::Stream& stream)
{
    // If this message is a capabilities request, we don't have to parse anything else.
    auto is_requesting = TRY(stream.read_value<u32>()) == 1;
    if (is_requesting) {
        return AnnounceCapabilitiesMessage(is_requesting);
    }

    return Error::from_string_literal("Unexpected non-requesting announce capabilities message received!");
}

ErrorOr<void> AnnounceCapabilitiesMessage::write_to_stream(AK::Stream& stream)
{
    TRY(stream.write_value<u32>(is_request()));

    // Each bit in this u32 indicates if a certain capability is enabled or not.
    u32 capabilities_bits = 0;
    for (auto capability : capabilities()) {
        // FIXME: At the moment, we only support up to 32 capabilities as the Spice protocol
        //        only contains 17 capabilities.
        auto capability_value = to_underlying(capability);
        VERIFY(capability_value < 32);

        capabilities_bits |= 1 << capability_value;
    }

    TRY(stream.write_value(capabilities_bits));

    return {};
}

ErrorOr<String> AnnounceCapabilitiesMessage::debug_description()
{
    StringBuilder builder;
    TRY(builder.try_append("AnnounceCapabilities { "sv));
    TRY(builder.try_appendff("is_request = {}, ", is_request()));
    TRY(builder.try_appendff("capabilities.size() = {}", capabilities().size()));
    TRY(builder.try_append(" }"sv));
    return builder.to_string();
}

ErrorOr<ClipboardGrabMessage> ClipboardGrabMessage::read_from_stream(AK::Stream& stream)
{
    auto types = Vector<ClipboardDataType>();
    while (!stream.is_eof()) {
        auto value = TRY(stream.read_value<u32>());
        types.append(TRY(clipboard_data_type_from_raw_value(value)));
    }

    return ClipboardGrabMessage(types);
}

ErrorOr<void> ClipboardGrabMessage::write_to_stream(AK::Stream& stream)
{
    for (auto type : types()) {
        TRY(stream.write_value(type));
    }

    return {};
}

ErrorOr<String> ClipboardGrabMessage::debug_description()
{
    StringBuilder builder;
    TRY(builder.try_append("ClipboardGrabMessage { "sv));
    TRY(builder.try_appendff("types = {}", types()));
    TRY(builder.try_append(" }"sv));
    return builder.to_string();
}

ErrorOr<ClipboardRequestMessage> ClipboardRequestMessage::read_from_stream(AK::Stream& stream)
{
    auto value = TRY(stream.read_value<u32>());
    auto type = TRY(clipboard_data_type_from_raw_value(value));
    return ClipboardRequestMessage(type);
}

ErrorOr<void> ClipboardRequestMessage::write_to_stream(AK::Stream& stream)
{
    TRY(stream.write_value(data_type()));
    return {};
}

ErrorOr<String> ClipboardRequestMessage::debug_description()
{
    StringBuilder builder;
    TRY(builder.try_append("ClipboardRequest { "sv));
    TRY(builder.try_appendff("data_type = {}", data_type()));
    TRY(builder.try_append(" }"sv));
    return builder.to_string();
}

ErrorOr<ClipboardMessage> ClipboardMessage::read_from_stream(AK::Stream& stream)
{
    auto value = TRY(stream.read_value<u32>());
    if (value >= to_underlying(ClipboardDataType::__End)) {
        return Error::from_string_literal("Unsupported clipboard type");
    }

    auto type = static_cast<ClipboardDataType>(value);
    auto contents = TRY(stream.read_until_eof());
    return ClipboardMessage(type, contents);
}

ErrorOr<void> ClipboardMessage::write_to_stream(AK::Stream& stream)
{
    TRY(stream.write_value(data_type()));
    TRY(stream.write_until_depleted(contents()));

    return {};
}

ErrorOr<String> ClipboardMessage::debug_description()
{
    StringBuilder builder;
    TRY(builder.try_append("Clipboard { "sv));
    TRY(builder.try_appendff("data_type = {}, ", data_type()));
    TRY(builder.try_appendff("contents.size() = {}", contents().size()));
    TRY(builder.try_append(" }"sv));
    return builder.to_string();
}

ErrorOr<FileTransferStartMessage> FileTransferStartMessage::read_from_stream(AK::Stream& stream)
{
    auto id = TRY(stream.read_value<u32>());

    auto metadata_bytes = TRY(stream.read_until_eof());
    auto metadata_content = TRY(String::from_utf8(metadata_bytes));

    // TODO: We need some sort of INIParser, or we need to make Core::ConfigFile not depend on having an actual Core::File
    // The first line in the file should always be `[vdagent-file-xfer]`
    auto lines = TRY(metadata_content.split('\n'));
    if (lines.is_empty() || lines.at(0) != "[vdagent-file-xfer]") {
        return Error::from_string_literal("Failed to parse file transfer metadata");
    }

    Optional<String> name = {};
    Optional<u32> size = {};

    for (auto const& line : lines) {
        // Ignore the header, we already assume that it is [vdagent-file-xfer]
        if (line.starts_with('['))
            continue;

        if (line.starts_with_bytes("name="sv)) {
            auto parsed_name = TRY(line.replace("name="sv, ""sv, ReplaceMode::FirstOnly));
            if (parsed_name.is_empty()) {
                return Error::from_string_literal("Failed to parse file name!");
            }

            name = parsed_name;
        }

        if (line.starts_with_bytes("size="sv)) {
            auto size_string = TRY(line.replace("size="sv, ""sv, ReplaceMode::FirstOnly));
            size = size_string.to_number<u32>(TrimWhitespace::Yes);
        }
    }

    // Verify that we actually parsed any data
    if (!name.has_value() || !size.has_value()) {
        return Error::from_string_literal("Invalid transfer start message received!");
    }

    return FileTransferStartMessage(id, Metadata { name.release_value(), size.release_value() });
}

ErrorOr<String> FileTransferStartMessage::debug_description()
{
    StringBuilder builder;
    TRY(builder.try_append("FileTransferStart { "sv));
    TRY(builder.try_appendff("id = {}, ", id()));
    TRY(builder.try_appendff("metadata = Metadata {{ name = {}, size = {} }}", metadata().name, metadata().size));
    TRY(builder.try_append(" }"sv));
    return builder.to_string();
}

ErrorOr<FileTransferStatusMessage> FileTransferStatusMessage::read_from_stream(AK::Stream& stream)
{
    auto id = TRY(stream.read_value<u32>());
    auto status = TRY(stream.read_value<FileTransferStatus>());

    return FileTransferStatusMessage(id, status);
}

ErrorOr<void> FileTransferStatusMessage::write_to_stream(AK::Stream& stream)
{
    TRY(stream.write_value(id()));
    TRY(stream.write_value(status()));

    return {};
}

ErrorOr<String> FileTransferStatusMessage::debug_description()
{
    StringBuilder builder;
    TRY(builder.try_append("FileTransferStatus { "sv));
    TRY(builder.try_appendff("id = {}, ", id()));
    TRY(builder.try_appendff("status = {}", status()));
    TRY(builder.try_append(" }"sv));
    return builder.to_string();
}

ErrorOr<FileTransferDataMessage> FileTransferDataMessage::read_from_stream(AK::Stream& stream)
{
    auto id = TRY(stream.read_value<u32>());
    auto size = TRY(stream.read_value<u64>());

    auto contents = TRY(ByteBuffer::create_uninitialized(size));
    TRY(stream.read_until_filled(contents));

    return FileTransferDataMessage(id, move(contents));
}

ErrorOr<String> FileTransferDataMessage::debug_description()
{
    StringBuilder builder;
    TRY(builder.try_append("FileTransferData { "sv));
    TRY(builder.try_appendff("id = {}, ", id()));
    TRY(builder.try_appendff("contents.size() = {}", contents().size()));
    TRY(builder.try_append(" }"sv));
    return builder.to_string();
}

}