peak_icv_serializer.hpp

Go to the documentation of this file.

 
#pragma once
 
#include <peak_common/serialization/peak_common_iarchive.hpp>
#include <peak_common/serialization/peak_common_iserializer.hpp>
 
#include <peak_icv/exceptions/detail/peak_icv_exception_helpers.hpp>
#include <peak_icv/exceptions/peak_icv_exception.hpp>
#include <peak_icv/serialization/detail/peak_icv_serialization_helper.hpp>
#include <peak_icv/serialization/peak_icv_archive.hpp>
#include <peak_icv/serialization/peak_icv_serialization_types.hpp>
#include <peak_icv/serialization/peak_icv_serializer.hpp>
#include <peak_icv/utils/peak_icv_backend_accessor.hpp>
 
namespace peak
{
namespace icv
{
class Serializer : public peak::common::serialization::ISerializer
{
public:
    explicit Serializer(SerializationType type = SerializationType::Json);
 
    void Write(const peak::common::serialization::IArchive& archive, std::ostream& stream) override;
 
private:
    SerializationType m_type;
};
 
inline Serializer::Serializer(peak::icv::SerializationType type)
    : m_type{ type }
{}
 
inline void Serializer::Write(const peak::common::serialization::IArchive& archive, std::ostream& stream)
{
    std::vector<char> buffer;
 
    auto* archiveHandle = [&archive]() {
        try
        {
            const auto& realArchive = dynamic_cast<const Archive&>(archive);
            return peak::common::detail::BackendAccessor<Archive>::BackendHandle(realArchive);
        }
        catch (std::bad_cast&)
        {
            throw InternalErrorException("The given archive is invalid. This should not happen.", PEAK_ICV_STATUS_INTERNAL_ERROR);
        }
    }();
 
    size_t size{};
    detail::ExecuteAndMapReturnCodes([&] {
        return PEAK_ICV_C_ABI_PREFIX peak_icv_Archive_ToString_GetSizeInBytes(
            archiveHandle, helper::MapSerializationTypeToApi(m_type), &size);
    });
 
    buffer.resize(size);
 
    detail::ExecuteAndMapReturnCodes([&] {
        return PEAK_ICV_C_ABI_PREFIX peak_icv_Archive_ToString(
            archiveHandle, helper::MapSerializationTypeToApi(m_type), buffer.data(), &size);
    });
 
    stream.write(buffer.data(), static_cast<std::streamsize>(buffer.size() - 1));
}
 
} /* namespace icv */
} /* namespace peak */