ExpiredLockInfoObserver.h

Go to the documentation of this file.

 
#pragma once
#include "catapult/cache_core/AccountStateCache.h"
 
namespace catapult { namespace observers {
 
    template<typename TLockInfoCache, typename TAccountIdSupplier>
    void ExpiredLockInfoObserver(const ObserverContext& context, TAccountIdSupplier ownerAccountIdSupplier) {
        auto& accountStateCache = context.Cache.sub<cache::AccountStateCache>();
        auto& lockInfoCache = context.Cache.template sub<TLockInfoCache>();
 
        lockInfoCache.processUnusedExpiredLocks(context.Height, [&context, &accountStateCache, ownerAccountIdSupplier](
                const auto& lockInfo) {
            auto accountStateIter = accountStateCache.find(ownerAccountIdSupplier(lockInfo));
            auto& accountState = accountStateIter.get();
            if (NotifyMode::Commit == context.Mode)
                accountState.Balances.credit(lockInfo.MosaicId, lockInfo.Amount);
            else
                accountState.Balances.debit(lockInfo.MosaicId, lockInfo.Amount);
        });
    }
}}