rewards_initializator.cpp

Go to the documentation of this file.

#include <scorum/chain/genesis/initializators/rewards_initializator.hpp>
#include <scorum/chain/data_service_factory.hpp>
#include <scorum/chain/dba/db_accessor_factory.hpp>
 
#include <scorum/chain/dba/db_accessor.hpp>
#include <scorum/chain/services/dynamic_global_property.hpp>
#include <scorum/chain/services/reward_funds.hpp>
#include <scorum/chain/services/reward_balancer.hpp>
#include <scorum/chain/services/budgets.hpp>
#include <scorum/chain/services/witness_reward_in_sp_migration.hpp>
 
#include <scorum/chain/schema/chain_property_object.hpp>
#include <scorum/chain/schema/scorum_objects.hpp>
#include <scorum/chain/schema/budget_objects.hpp>
#include <scorum/chain/schema/witness_objects.hpp>
 
#include <scorum/chain/genesis/genesis_state.hpp>
 
namespace scorum {
namespace chain {
namespace genesis {
 
void rewards_initializator_impl::on_apply(initializator_context& ctx)
{
    FC_ASSERT(ctx.genesis_state().rewards_supply.symbol() == SCORUM_SYMBOL);
 
    create_scr_reward_fund(ctx);
    create_sp_reward_fund(ctx);
    create_balancers(ctx);
    create_fund_budget(ctx);
    create_witness_reward_in_sp_migration(ctx);
}
 
void rewards_initializator_impl::create_scr_reward_fund(initializator_context& ctx)
{
    content_reward_fund_scr_service_i& reward_fund_service = ctx.services().content_reward_fund_scr_service();
    dynamic_global_property_service_i& dgp_service = ctx.services().dynamic_global_property_service();
 
    FC_ASSERT(!reward_fund_service.is_exists());
 
    reward_fund_service.create([&](content_reward_fund_scr_object& rfo) {
        rfo.last_update = dgp_service.head_block_time();
        rfo.author_reward_curve = curve_id::linear;
        rfo.curation_reward_curve = curve_id::square_root;
    });
}
 
void rewards_initializator_impl::create_sp_reward_fund(initializator_context& ctx)
{
    content_reward_fund_sp_service_i& reward_fund_service = ctx.services().content_reward_fund_sp_service();
    dynamic_global_property_service_i& dgp_service = ctx.services().dynamic_global_property_service();
 
    FC_ASSERT(!reward_fund_service.is_exists());
 
    reward_fund_service.create([&](content_reward_fund_sp_object& rfo) {
        rfo.last_update = dgp_service.head_block_time();
        rfo.author_reward_curve = curve_id::linear;
        rfo.curation_reward_curve = curve_id::square_root;
    });
}
 
void rewards_initializator_impl::create_balancers(initializator_context& ctx)
{
    content_reward_scr_service_i& content_reward_service = ctx.services().content_reward_scr_service();
    voters_reward_scr_service_i& voters_reward_scr_service = ctx.services().voters_reward_scr_service();
    voters_reward_sp_service_i& voters_reward_sp_service = ctx.services().voters_reward_sp_service();
 
    FC_ASSERT(!content_reward_service.is_exists());
    FC_ASSERT(!voters_reward_scr_service.is_exists());
    FC_ASSERT(!voters_reward_sp_service.is_exists());
 
    content_reward_service.create([&](content_reward_balancer_scr_object&) {});
    voters_reward_scr_service.create([&](voters_reward_balancer_scr_object&) {});
    voters_reward_sp_service.create([&](voters_reward_balancer_sp_object&) {});
}
 
void rewards_initializator_impl::create_fund_budget(initializator_context& ctx)
{
    fund_budget_service_i& budget_service = ctx.services().fund_budget_service();
    dba::db_accessor<chain_property_object>& chain_dba = ctx.dba_factory().get_dba<chain_property_object>();
 
    FC_ASSERT(!budget_service.is_exists());
 
    auto balance = asset(ctx.genesis_state().rewards_supply.amount, SP_SYMBOL);
 
    time_point_sec start_date = chain_dba.get().genesis_time;
    fc::time_point deadline = start_date + fc::days(SCORUM_REWARDS_INITIAL_SUPPLY_PERIOD_IN_DAYS);
 
    budget_service.create_budget(balance, start_date, deadline);
}
 
void rewards_initializator_impl::create_witness_reward_in_sp_migration(initializator_context& ctx)
{
    witness_reward_in_sp_migration_service_i& witness_reward_in_sp_migration_service
        = ctx.services().witness_reward_in_sp_migration_service();
 
    FC_ASSERT(!witness_reward_in_sp_migration_service.is_exists());
 
    witness_reward_in_sp_migration_service.create([&](witness_reward_in_sp_migration_object&) {});
}
}
}
}