ZeroMqEntityPublisher.h

Go to the documentation of this file.

 
#pragma once
#include "catapult/model/NotificationPublisher.h"
#include "catapult/functions.h"
#include <zmq_addon.hpp>
 
namespace catapult {
    namespace model {
        struct BlockElement;
        struct Transaction;
        struct TransactionElement;
        struct TransactionInfo;
        class TransactionRegistry;
        struct TransactionStatus;
    }
}
 
namespace catapult { namespace zeromq {
 
    enum class BlockMarker : uint64_t {
        Block_Marker = 0x9FF2D8E480CA6A49,
 
        Drop_Blocks_Marker = 0x5C20D68AEE25B0B0
    };
 
    enum class TransactionMarker : uint8_t {
        Transaction_Marker = 0x61, // 'a'
 
        Unconfirmed_Transaction_Add_Marker = 0x75, // 'u'
 
        Unconfirmed_Transaction_Remove_Marker = 0x72, // 'r'
 
        Transaction_Status_Marker = 0x73, // 's'
 
        Partial_Transaction_Add_Marker = 0x70, // 'p'
 
        Partial_Transaction_Remove_Marker = 0x71, // 'q'
 
        Cosignature_Marker = 0x63 // 'c'
    };
 
    class ZeroMqEntityPublisher {
    public:
        explicit ZeroMqEntityPublisher(unsigned short port, std::unique_ptr<model::NotificationPublisher>&& pNotificationPublisher);
 
        ~ZeroMqEntityPublisher();
 
    public:
        void publishBlockHeader(const model::BlockElement& blockElement);
 
        void publishDropBlocks(Height height);
 
        void publishTransaction(TransactionMarker topicMarker, const model::TransactionElement& transactionElement, Height height);
 
        void publishTransaction(TransactionMarker topicMarker, const model::TransactionInfo& transactionInfo, Height height);
 
        void publishTransactionHash(TransactionMarker topicMarker, const model::TransactionInfo& transactionInfo);
 
        void publishTransactionStatus(const model::Transaction& transaction, const Hash256& hash, uint32_t status);
 
        void publishCosignature(const model::TransactionInfo& parentTransactionInfo, const Key& signer, const Signature& signature);
 
    private:
        struct WeakTransactionInfo;
        using MessagePayloadBuilder = consumer<zmq::multipart_t&>;
 
        void publishTransaction(TransactionMarker topicMarker, const WeakTransactionInfo& transactionInfo, Height height);
        void publish(
                const std::string& topicName,
                TransactionMarker topicMarker,
                const WeakTransactionInfo& transactionInfo,
                const MessagePayloadBuilder& payloadBuilder);
 
    private:
        class SynchronizedPublisher;
        std::unique_ptr<model::NotificationPublisher> m_pNotificationPublisher;
        std::unique_ptr<SynchronizedPublisher> m_pSynchronizedPublisher;
    };
}}