MessagePtr.h

Go to the documentation of this file.

// Copyright Onix Solutions Limited [OnixS]. All rights reserved.
//
// This software owned by Onix Solutions Limited [OnixS] and is
// protected by copyright law and international copyright treaties.
//
// Access to and use of the software is governed by the terms of the applicable
// OnixS Software Services Agreement (the Agreement) and Customer end user license
// agreements granting a non-assignable, non-transferable and non-exclusive license
// to use the software for it's own data processing purposes under the terms defined
// in the Agreement.
//
// Except as otherwise granted within the terms of the Agreement, copying or
// reproduction of any part of this source code or associated reference material
// to any other location for further reproduction or redistribution, and any
// amendments to this copyright notice, are expressly prohibited.
//
// Any reproduction or redistribution for sale or hiring of the Software not in
// accordance with the terms of the Agreement is a violation of copyright law.
//
 
#pragma once
 
#include <OnixS/ICE/BOE/testing/ABI.h>
#include <OnixS/ICE/BOE/Messaging.h>
 
#include <memory>
 
ONIXS_ICEBOE_NAMESPACE_BEGIN
namespace Testing {
 
using namespace Messaging;
 
 
[[noreturn]] ONIXS_ICEBOE_EXPORTED
void throwWrongType(UInt16, UInt16);

inline bool isMessageValid(const SbeMessage msg) noexcept
{
    return msg.valid();
}

inline bool isMessageValid(const TagBased::Message& msg) noexcept
{
    return static_cast<bool>(msg);
}

template<typename Message>
class MessagePtr
{
public:
    using Container = std::shared_ptr<UInt8>;

    MessagePtr(Container&&, MessageSize);

    template <class AnotherType>
    explicit
    MessagePtr(const MessagePtr<AnotherType>& rhs)
        : size_(rhs.size_)
        , container_(rhs.container_)
        , message_()
    {
        fromAnotherType(rhs);
    }

    template <class AnotherType>
    explicit
    MessagePtr(MessagePtr<AnotherType>&& rhs)
        : size_(rhs.size_)
        , container_(std::move(rhs.container_))
        , message_()
    {
        fromAnotherType(rhs);
    }

    MessagePtr()
        : size_(0)
        , container_()
        , message_()
    {
    }
 
    MessagePtr(const MessagePtr&) = default;
    MessagePtr& operator=(const MessagePtr&) = default;

    MessagePtr(MessagePtr&& rhs) noexcept
    {
        rhs.swap(*this);
        rhs.reset();
    }

    MessagePtr& operator=(MessagePtr&& rhs) noexcept
    {
        if (&rhs == this)
            return *this;
 
        rhs.swap(*this);
        rhs.reset();
 
        return *this;
    }

    bool valid() const noexcept
    {
        return isMessageValid(message_);
    }

    void swap(MessagePtr& rhs) noexcept
    {
        std::swap(rhs.size_, size_);
        std::swap(rhs.container_, container_);
        std::swap(rhs.message_, message_);
    }

    Message* operator->() noexcept
    {
        assert(valid());
        return &message_;
    }

    const Message* operator->() const noexcept
    {
        assert(valid());
        return &message_;
    }

    Message& operator*() noexcept
    {
        return message_;
    }

    const Message& operator*() const noexcept
    {
        return message_;
    }

    Message& message() noexcept
    {
        assert(valid());
        return message_;
    }

    const Message& message() const noexcept
    {
        assert(valid());
        return message_;
    }

    operator Message() noexcept
    {
        return message();
    }

    operator const Message() const noexcept
    {
        return message();
    }

    UInt8* buf() noexcept
    {
        return container_.get();
    }

    void reset()
    {
        size_ = 0;
        container_.reset();
        message_ = Message();
    }

    std::string toString() const
    {
        return message_.toString();
    }
 
private:
 
    template<typename MessageT>
    static constexpr typename std::enable_if<!std::is_base_of<TagBased::Message, MessageT>::value, MessageTemplateId>::type
        getTemplateId()
    {
        ONIXS_ICEBOE_STATIC_ASSERT(std::is_base_of<SbeMessage, MessageT>::value);
 
        return MessageT::TemplateId;
    }
 
    template<typename MessageT>
    static constexpr typename std::enable_if<std::is_base_of<TagBased::Message, MessageT>::value, MessageTemplateId>::type
        getTemplateId()
    {
        ONIXS_ICEBOE_STATIC_ASSERT(std::is_base_of<SbeMessage, typename MessageT::Binary>::value);
 
        return MessageT::Binary::TemplateId;
    }
 
    template<typename MessageT>
    static typename std::enable_if<!std::is_base_of<TagBased::Message, MessageT>::value, MessageT>::type
        typify(SbeMessage message)
    {
        ONIXS_ICEBOE_STATIC_ASSERT(std::is_base_of<SbeMessage, MessageT>::value);
 
        return Messaging::typify<MessageT>(message);
    }
 
    template<typename MessageT>
    static typename std::enable_if<std::is_base_of<TagBased::Message, MessageT>::value, MessageT>::type
        typify(SbeMessage message)
    {
        ONIXS_ICEBOE_STATIC_ASSERT(std::is_base_of<SbeMessage, typename MessageT::Binary>::value);
 
        return MessageT(Messaging::typify<typename Message::Binary>(message));
    }
 
    template <class AnotherType>
    void fromAnotherType(const MessagePtr<AnotherType>& rhs)
    {
        if(rhs->templateId() != getTemplateId<Message>())
            throwWrongType(getTemplateId<Message>(), rhs->templateId());
 
        message_ = this->typify<Message>(rhs);
    }
 
private:
    MessageSize size_;
    Container container_;
    Message message_;
 
    template<class T> friend class MessagePtr;
};
 
 
template<>
inline MessagePtr<SbeMessage>::MessagePtr(Container&& container, MessageSize size)
    : size_(size)
    , container_(std::move(container))
    , message_(container_.get(), size_)
{
}

template <typename AnotherType, typename BaseType>
MessagePtr<AnotherType> cast(const MessagePtr<BaseType>& ptr)
{
    return MessagePtr<AnotherType>(ptr);
}
 
}
ONIXS_ICEBOE_NAMESPACE_END