MongoErrorPolicy.h

Go to the documentation of this file.

 
#pragma once
#include "catapult/utils/NonCopyable.h"
#include <string>
 
namespace catapult { namespace mongo { struct BulkWriteResult; } }
 
namespace catapult { namespace mongo {
 
    class MongoErrorPolicy : utils::MoveOnly {
    public:
        enum class Mode {
            Strict,
 
            Idempotent
        };
 
    public:
        explicit MongoErrorPolicy(const std::string& collectionName, Mode mode);
 
    public:
        Mode mode() const;
 
    public:
        void checkDeleted(uint64_t numExpected, const BulkWriteResult& result, const std::string& itemsDescription) const;
 
        void checkDeletedAtLeast(uint64_t numExpected, const BulkWriteResult& result, const std::string& itemsDescription) const;
 
        void checkInserted(uint64_t numExpected, const BulkWriteResult& result, const std::string& itemsDescription) const;
 
        void checkUpserted(uint64_t numExpected, const BulkWriteResult& result, const std::string& itemsDescription) const;
 
    private:
        [[noreturn]]
        void formatMessageAndThrow(
                const char* operation,
                uint64_t numExpected,
                uint64_t numActual,
                const std::string& itemsDescription) const;
 
    private:
        std::string m_collectionName;
        Mode m_mode;
    };
}}