message.hpp

Go to the documentation of this file.

#ifndef ZIO_MESSAGE_HPP_SEEN
#define ZIO_MESSAGE_HPP_SEEN

#include "zio/interned.hpp"

#include <vector>
#include <string>

namespace zio {

    namespace level {
        enum MessageLevel {
            undefined=0,
            trace,verbose,debug,info,summary,warning,error,fatal,
        };

        const char* name(MessageLevel lvl);
    }

    struct PrefixHeader {
        level::MessageLevel level{level::undefined};
        std::string form{"    "}; // we keep this exactly length 4
        std::string label{""};

        std::string dumps() const;
        // Return false if s can not be parsed as a prefix header
        bool loads(const std::string& s);
    };

    typedef uint64_t origin_t;
    typedef uint64_t granule_t;
    typedef uint64_t seqno_t;

    struct CoordHeader {
        origin_t origin{0};
        granule_t granule{0};
        seqno_t seqno{0};
    };
    struct Header {
        PrefixHeader prefix;
        CoordHeader coord;
    };

    class Message {
    public:
        typedef Header header_t;
        typedef uint32_t routing_id_t;

        Message();
        Message(const std::string& form, level::MessageLevel lvl = level::undefined);
        Message(const header_t h);
        Message(const header_t h, multipart_t&& pl);
        
        level::MessageLevel level() const;
        void set_level(level::MessageLevel level);

        std::string form() const;
        void set_form(const std::string& form);

        std::string label() const;
        void set_label(const std::string& label);

        zio::json label_object() const;
        void set_label_object(const zio::json& lobj);

        const PrefixHeader& prefix() const { return m_header.prefix; }
        const CoordHeader& coord() const { return m_header.coord; }
        origin_t origin() const { return m_header.coord.origin; }
        granule_t granule() const { return m_header.coord.granule; }
        seqno_t seqno() const { return m_header.coord.seqno; }

        void set_coord(origin_t origin=0, granule_t gran=0);

        void set_seqno(int seqno) { m_header.coord.seqno = seqno; }

        message_t encode() const;

        void decode(const message_t& dat);

        void fromparts(const multipart_t& allparts);

        multipart_t toparts() const;

        const multipart_t& payload() const { return m_payload; }
        void clear_payload() { m_payload.clear(); }
        void add(message_t&& spmsg) { m_payload.add(std::move(spmsg)); }

        routing_id_t routing_id() const { return m_rid; }
        
        void set_routing_id(routing_id_t rid) { m_rid = rid; }


    private:
        header_t m_header;
        multipart_t m_payload;
        routing_id_t m_rid;
        
    };


}

#endif