message.hpp

//SPDX-License-Identifier: LicenseRef-Apache-License-2.0
//Author: Blayne Dennis
 
#ifndef __SIMPLE_THREADING_MESSAGE__
#define __SIMPLE_THREADING_MESSAGE__
 
#include "data.hpp"
#include "context.hpp"
 
namespace st { // simple thread 
namespace detail {
namespace message {
 
struct context {
    context(const std::size_t c) : m_id(c) { }
 
    context(const std::size_t c, st::data&& d) :
        m_id(c),
        m_data(std::move(d))
    { }
 
    virtual ~context() { }
 
    std::size_t m_id;
    st::data m_data;
};
 
}
}
 
struct message : public st::shared_context<message, detail::message::context> {
    virtual ~message() { }
 
    static inline message make(message msg) {
        return std::move(msg);
    }
 
    static inline message make(std::size_t id, st::data&& d) {
        message msg;
        msg.ctx(std::make_shared<detail::message::context>(id, std::move(d)));
        return msg;
    }
 
    template <typename T>
    static message make(std::size_t id, T&& t) {
        return st::message::make(id, st::data::make<T>(std::forward<T>(t)));
    }
 
    static inline message make(std::size_t id) {
        message msg;
        msg.ctx(std::make_shared<detail::message::context>(id));
        return msg;
    }
 
    static inline message make() {
        return message::make(0);
    }
 
    const std::size_t id() const {
        return ctx()->m_id;
    }
 
    inline st::data& data() {
        return ctx()->m_data;
    }
};
 
}
 
#endif