#pragma once #include #include #include #include #include #include #include #include #include "message_container.h" #include "schema.h" namespace saw { class message_base { protected: bool set_explicitly_ = false; public: template T &as() { static_assert(std::is_base_of()); return dynamic_cast(*this); } template const T &as() const { static_assert(std::is_base_of()); return dynamic_cast(*this); } }; /* * Representing all message types * Description which type to use happens through the use of the schema classes * in schema.h The message classes are wrapper classes which store the data * according to the specified container class. * * The reader and builder classe exist to create some clarity while implementing * parsers. Also minor guarantess are provided if the message is used as a * template parameter. */ /* * Struct Message */ template class message...>, Container> final : public message_base { private: using SchemaType = schema::Struct...>; using MessageType = message; Container container_; static_assert(std::is_same_v, "Container should have same the schema as Message"); friend class builder; friend class reader; public: class reader; class builder { private: MessageType &message_; public: builder(MessageType &msg) : message_{msg} {} reader as_reader() { return reader{message_}; } /* * Initialize a member by index */ template typename std::enable_if< !schema_is_array< typename message_parameter_pack_type::Type>::Value, typename Container::template ElementType::builder>::type init() { return typename Container::template ElementType::builder{ message_.container_.template get()}; } /* * Initialize a member by their name * This is the preferred method for schema::Struct messages */ template typename std::enable_if< !schema_is_array::Value, V...>::Type>::Value, typename Container::template ElementType< message_parameter_key_pack_index::Value>:: builder>::type init() { constexpr size_t i = message_parameter_key_pack_index::Value; return init(); } template typename std::enable_if< schema_is_array< typename message_parameter_pack_type::Type>::Value, typename Container::template ElementType::builder>::type init(size_t size = 0) { auto array_builder = typename Container::template ElementType::builder{ message_.container_.template get(), size}; return array_builder; } /* * Version for array schema type */ template typename std::enable_if< schema_is_array::Value, V...>::Type>::Value, typename Container::template ElementType< message_parameter_key_pack_index::Value>:: builder>::type init(size_t size) { constexpr size_t i = message_parameter_key_pack_index::Value; return init(size); } }; class reader { private: MessageType &message_; public: reader(MessageType &msg) : message_{msg} {} builder as_builder() { return builder{message_}; } /* * Get member by index */ template typename Container::template ElementType::reader get() { return typename Container::template ElementType::reader{ message_.container_.template get()}; } /* * Get member by name * This is the preferred method for schema::Struct messages */ template typename Container::template ElementType< message_parameter_key_pack_index::Value>::reader get() { // The index of the first match constexpr size_t i = message_parameter_key_pack_index::Value; return get(); } }; builder build() { return builder{*this}; } reader read() { return reader{*this}; } }; /* * Union message class. Wrapper object */ template class message...>, Container> final : public message_base { private: using SchemaType = schema::Union...>; using MessageType = message; Container container_; static_assert(std::is_same_v, "Container should have same the schema as Message"); friend class builder; friend class reader; public: class reader; class builder { private: MessageType &message_; public: builder(MessageType &msg) : message_{msg} {} reader as_reader() { return reader{message_}; } template typename std::enable_if< !schema_is_array< typename message_parameter_pack_type::Type>::Value, typename Container::template ElementType::builder>::type init() { return typename Container::template ElementType::builder{ message_.container_.template get()}; } template typename std::enable_if< !schema_is_array::Value, V...>::Type>::Value, typename Container::template ElementType< message_parameter_key_pack_index::Value>:: builder>::type init() { constexpr size_t i = message_parameter_key_pack_index::Value; return init(); } /* * If Schema is Array */ template typename std::enable_if< schema_is_array< typename message_parameter_pack_type::Type>::Value, typename Container::template ElementType::builder>::type init(size_t size = 0) { return typename Container::template ElementType::builder{ message_.container_.template get(), size}; } template typename std::enable_if< schema_is_array::Value, V...>::Type>::Value, typename Container::template ElementType< message_parameter_key_pack_index::Value>:: builder>::type init(size_t size) { constexpr size_t i = message_parameter_key_pack_index::Value; return init(size); } }; class reader { private: MessageType &message_; public: reader(MessageType &msg) : message_{msg} {} builder as_builder() { return builder{message_}; } template typename Container::template ElementType::reader get() { return typename Container::template ElementType::reader{ message_.container_.template get()}; } template typename Container::template ElementType< message_parameter_key_pack_index::Value>::reader get() { // The index of the first match constexpr size_t i = message_parameter_key_pack_index::Value; return get(); } template static constexpr size_t to_index() noexcept { return message_parameter_key_pack_index::Value; } size_t index() const noexcept { return message_.container_.index(); } template bool has_alternative() const { return index() == to_index(); } }; }; /* * Array message class. Wrapper around an array schema element */ template class message, Container> final : public message_base { private: using SchemaType = schema::Array; using MessageType = message; Container container_; static_assert(std::is_same_v, "Container should have same Schema as Message"); friend class builder; friend class reader; public: class reader; class builder { private: MessageType &message_; public: builder(MessageType &msg, size_t size) : message_{msg} { if (size > 0) { message_.container_.resize(size); } } reader as_reader() { return reader{message_}; } typename Container::ElementType::builder init(size_t i) { return typename Container::ElementType::builder{ message_.container_.get(i)}; } size_t size() const { return message_.container_.size(); } void resize(size_t size) { message_.container_.resize(size); } }; class reader { private: MessageType &message_; public: reader(MessageType &msg) : message_{msg} {} builder as_builder() { return builder{message_, 0}; } typename Container::ElementType::reader get(size_t i) { return typename Container::ElementType::reader{ message_.container_.get(i)}; } size_t size() const { return message_.container_.size(); } }; }; /* * Tuple message class. Wrapper around a tuple schema */ template class message, Container> final : public message_base { private: using SchemaType = schema::Tuple; using MessageType = message; Container container_; static_assert(std::is_same_v, "Container should have same the schema as Message"); friend class builder; friend class reader; public: class reader; class builder { MessageType &message_; public: builder(MessageType &msg) : message_{msg} {} reader as_reader() { return reader{message_}; } template typename std::enable_if< !schema_is_array< typename message_parameter_pack_type::Type>::Value, typename Container::template ElementType::builder>::type init() { return typename Container::template ElementType::builder{ message_.container_.template get()}; } template typename std::enable_if< schema_is_array< typename message_parameter_pack_type::Type>::Value, typename Container::template ElementType::builder>::type init(size_t size = 0) { return typename Container::template ElementType::builder{ message_.container_.template get(), size}; } }; class reader { private: MessageType &message_; public: reader(MessageType &msg) : message_{msg} {} builder as_builder() { return builder{message_}; } template typename Container::template ElementType::reader get() { return typename Container::template ElementType::reader{ message_.container_.template get()}; } }; }; /* * Primitive type (float, double, uint8_t, uint16_t, uint32_t, uint64_t, int8_t, * int16_t, int32_t, int64_t) message class */ template class message, Container> final : public message_base { private: using SchemaType = schema::Primitive; using MessageType = message; Container container_; static_assert(std::is_same_v, "Container should have same the schema as Message"); friend class builder; friend class reader; public: class reader; class builder { private: MessageType &message_; public: builder(MessageType &msg) : message_{msg} {} reader as_reader() { return reader{message_}; } void set(const typename Container::ValueType &value) { message_.container_.set(value); } }; class reader { private: MessageType &message_; public: reader(message &msg) : message_{msg} {} builder as_builder() { return builder{message_}; } const typename Container::ValueType &get() const { return message_.container_.get(); } }; }; template class message final : public message_base { private: using SchemaType = schema::String; using MessageType = message; Container container_; static_assert(std::is_same_v, "Container should have same the schema as Message"); friend class builder; friend class reader; public: class reader; class builder { private: MessageType &message_; public: builder(MessageType &msg) : message_{msg} {} reader as_reader() { return reader{message_}; } void set(std::string &&str) { message_.container_.set(std::move(str)); } void set(const std::string_view str) { message_.container_.set(str); } void set(const char *str) { set(std::string_view{str}); } }; class reader { private: MessageType &message_; public: reader(MessageType &msg) : message_{msg} {} builder as_builder() { return builder{message_}; } const std::string_view get() const { return message_.container_.get(); } }; }; template > class heap_message_root { private: own> root_; public: heap_message_root(own> r) : root_{std::move(r)} {} typename message::builder build() { assert(root_); return typename message::builder{*root_}; } typename message::reader read() { assert(root_); return typename message::reader{*root_}; } }; template class heap_message_root, Container> { public: using Schema = schema::Array; private: own> root_; public: heap_message_root(own> r) : root_{std::move(r)} {} typename message::builder build(size_t size) { assert(root_); return typename message::builder{*root_, size}; } typename message::reader read() { assert(root_); return typename message::reader{*root_}; } }; /* * Minor helper for creating a message root */ template > inline heap_message_root new_heap_message_root() { own> root = heap>(); return heap_message_root{std::move(root)}; } } // namespace saw