CacheChangesStorageAdapter.h

Go to the documentation of this file.

 
#pragma once
#include "CacheChangesSerializer.h"
#include "CacheChangesStorage.h"
 
namespace catapult { namespace cache {
 
    template<typename TCache, typename TStorageTraits>
    class CacheChangesStorageAdapter : public CacheChangesStorage {
    public:
        explicit CacheChangesStorageAdapter(TCache& cache) : m_cache(cache)
        {}
 
    public:
        void saveAll(const CacheChanges& changes, io::OutputStream& output) const override {
            WriteCacheChanges<TStorageTraits>(changes.sub<TCache>(), output);
        }
 
        std::unique_ptr<const MemoryCacheChanges> loadAll(io::InputStream& input) const override {
            auto pMemoryCacheChanges = std::make_unique<MemoryCacheChangesT<typename TCache::CacheValueType>>();
            ReadCacheChanges<TStorageTraits>(input, *pMemoryCacheChanges);
            return std::move(pMemoryCacheChanges);
        }
 
        void apply(const CacheChanges& changes) const override {
            auto delta = m_cache.createDelta();
 
            auto subCacheChanges = changes.sub<TCache>();
            for (const auto* pAdded : subCacheChanges.addedElements()) {
                TStorageTraits::Purge(*pAdded, *delta);
                TStorageTraits::LoadInto(*pAdded, *delta);
            }
 
            for (const auto* pModified : subCacheChanges.modifiedElements()) {
                TStorageTraits::Purge(*pModified, *delta);
                TStorageTraits::LoadInto(*pModified, *delta);
            }
 
            for (const auto* pRemoved : subCacheChanges.removedElements())
                TStorageTraits::Purge(*pRemoved, *delta);
 
            m_cache.commit();
        }
 
    private:
        TCache& m_cache;
    };
}}