process_games_startup.cpp

Go to the documentation of this file.

#include <scorum/chain/database/block_tasks/process_games_startup.hpp>
 
#include <boost/range/adaptor/filtered.hpp>
 
#include <scorum/chain/schema/bet_objects.hpp>
 
#include <scorum/chain/services/dynamic_global_property.hpp>
#include <scorum/chain/services/game.hpp>
#include <scorum/chain/betting/betting_service.hpp>
 
namespace scorum {
namespace chain {
namespace database_ns {
 
process_games_startup::process_games_startup(betting_service_i& betting_service,
                                             database_virtual_operations_emmiter_i& virt_op_emitter)
    : _betting_svc(betting_service)
    , _virt_op_emitter(virt_op_emitter)
{
}
 
void process_games_startup::on_apply(block_task_context& ctx)
{
    using namespace boost::adaptors;
    debug_log(ctx.get_block_info(), "process_games_startup BEGIN");
 
    auto& dprops_service = ctx.services().dynamic_global_property_service();
    auto& game_service = ctx.services().game_service();
 
    auto games = game_service.get_games(dprops_service.head_block_time());
    for (const auto& game : filter(games, [](const auto& g) { return g.get().status == game_status::created; }))
    {
        game_service.update(game, [](game_object& o) { o.status = game_status::started; });
 
        _betting_svc.cancel_pending_bets(game.get().uuid, pending_bet_kind::non_live);
 
        _virt_op_emitter.push_virtual_operation(
            game_status_changed_operation(game.get().uuid, game_status::created, game_status::started));
    }
 
    debug_log(ctx.get_block_info(), "process_games_startup END");
}
}
}
}