MongoTransactionPlugin.h

Go to the documentation of this file.

 
#pragma once
#include "MongoTransactionMetadata.h"
#include "catapult/model/TransactionRegistry.h"
#include "catapult/plugins.h"
#include <bsoncxx/builder/stream/document.hpp>
#include <mongocxx/client.hpp>
 
namespace catapult {
    namespace model {
        struct EmbeddedTransaction;
        struct Transaction;
    }
}
 
namespace catapult { namespace mongo {
 
    template<typename TTransaction>
    class MongoTransactionPluginT {
    public:
        virtual ~MongoTransactionPluginT() = default;
 
    public:
        virtual model::EntityType type() const = 0;
 
        virtual void streamTransaction(bsoncxx::builder::stream::document& builder, const TTransaction& transaction) const = 0;
    };
 
    class EmbeddedMongoTransactionPlugin : public MongoTransactionPluginT<model::EmbeddedTransaction> {};
 
    class MongoTransactionPlugin : public MongoTransactionPluginT<model::Transaction> {
    public:
        virtual std::vector<bsoncxx::document::value> extractDependentDocuments(
                const model::Transaction& transaction,
                const MongoTransactionMetadata& metadata) const = 0;
 
        virtual bool supportsEmbedding() const = 0;
 
        virtual const EmbeddedMongoTransactionPlugin& embeddedPlugin() const = 0;
    };
 
    class MongoTransactionRegistry : public model::TransactionRegistryT<MongoTransactionPlugin> {};
}}