proposal_executor.cpp

Go to the documentation of this file.

#include <scorum/chain/services/proposal_executor.hpp>
 
#include <scorum/chain/services/proposal.hpp>
 
#include <scorum/chain/evaluators/committee_accessor.hpp>
#include <scorum/chain/evaluators/proposal_evaluators.hpp>
 
#include <scorum/chain/data_service_factory.hpp>
#include <scorum/chain/schema/proposal_object.hpp>
 
#include <scorum/protocol/proposal_operations.hpp>
 
namespace scorum {
namespace chain {
 
dbs_proposal_executor::dbs_proposal_executor(database& s)
    : _base_type(s)
    , services(s)
    , proposal_service(services.proposal_service())
    , evaluators(services)
    , _db(s)
{
    evaluators.register_evaluator<registration_committee::proposal_add_member_evaluator>();
    evaluators.register_evaluator<registration_committee::proposal_change_quorum_evaluator>();
    evaluators.register_evaluator<registration_committee::proposal_exclude_member_evaluator>(
        new registration_committee::proposal_exclude_member_evaluator(services, removed_members));
 
    evaluators.register_evaluator<development_committee::proposal_add_member_evaluator>();
    evaluators.register_evaluator<development_committee::proposal_change_quorum_evaluator>();
    evaluators.register_evaluator<development_committee::proposal_exclude_member_evaluator>(
        new development_committee::proposal_exclude_member_evaluator(services, removed_members));
 
    evaluators.register_evaluator<development_committee::proposal_withdraw_vesting_evaluator>();
    evaluators.register_evaluator<development_committee::proposal_transfer_evaluator>();
 
    evaluators.register_evaluator<development_committee_empower_advertising_moderator_evaluator>();
    evaluators.register_evaluator<development_committee_empower_betting_moderator_evaluator>();
    evaluators.register_evaluator<development_committee_change_betting_resolve_delay_evaluator>();
 
    evaluators.register_evaluator<development_committee_change_top_post_budgets_amount_evaluator>();
    evaluators.register_evaluator<development_committee_change_top_banner_budgets_amount_evaluator>();
}
 
void dbs_proposal_executor::operator()(const proposal_object& proposal)
{
    execute_proposal(proposal);
    update_proposals_voting_list_and_execute();
}
 
bool dbs_proposal_executor::is_quorum(const proposal_object& proposal)
{
    auto committee = proposal.operation.visit(get_operation_committee_visitor(services));
    const size_t votes = proposal_service.get_votes(proposal);
    const size_t members_count = committee.as_committee_i().get_members_count();
 
    return utils::is_quorum(votes, members_count, proposal.quorum_percent);
}
 
void dbs_proposal_executor::execute_proposal(const proposal_object& proposal)
{
    if (is_quorum(proposal))
    {
        auto& evaluator = evaluators.get_evaluator(proposal.operation);
 
        auto note = _db.create_notification(proposal_virtual_operation(proposal.operation));
 
        _db.notify_pre_apply_operation(note);
        evaluator.apply(proposal.operation);
        _db.notify_post_apply_operation(note);
 
        proposal_service.remove(proposal);
    }
}
 
void dbs_proposal_executor::update_proposals_voting_list_and_execute()
{
    while (!removed_members.empty())
    {
        account_name_type member = *removed_members.begin();
 
        proposal_service.for_all_proposals_remove_from_voting_list(member);
 
        auto proposals = proposal_service.get_proposals();
 
        for (const auto& p : proposals)
        {
            execute_proposal(p);
        }
 
        removed_members.erase(member);
    }
}
 
} // namespace scorum
} // namespace chain