use strict;
use warnings;
use 5.010;
use Test::More;
use Tapper::Schema::TestTools;
use Test::Fixture::DBIC::Schema;
use Tapper::Model 'model';
BEGIN{use_ok('Tapper::MCP::State')}
######################################################################
#
# Test handling of keep-alive messages in Tapper::MCP::State
#
######################################################################
# -----------------------------------------------------------------------------------------------------------------
construct_fixture( schema => testrundb_schema, fixture => 't/fixtures/testrundb/testrun_with_preconditions.yml' );
# -----------------------------------------------------------------------------------------------------------------
my $testrun_id = 23;
my $state = Tapper::MCP::State->new($testrun_id);
isa_ok($state, 'Tapper::MCP::State');
sub message_create
{
my ($data) = @_;
my $message = model('TestrunDB')->resultset('Message')->new
({
message => $data,
testrun_id => $testrun_id,
});
$message->insert;
return $message;
}
my $timeout_span = 100;
my $initial_state = {
'keep_alive' => {timeout_span => 3, timeout_date => undef },
'current_state' => 'started',
'install' => {
'timeout_install_span' => '7200',
'timeout_boot_span' => '7200',
'timeout_current_date' => undef
},
'prcs' => [
{
'timeout_boot_span' => $timeout_span,
'timeout_current_date' => undef,
'results' => [],
'current_state' => 'preload'
},
{
'timeout_testprograms_span' => [ 5, 2],
'timeout_boot_span' => $timeout_span,
'timeout_current_date' => undef,
'results' => [],
'current_state' => 'preload'
},
{
'timeout_testprograms_span' => [ 5, 2],
'timeout_boot_span' => $timeout_span,
'timeout_current_date' => undef,
'results' => [],
'current_state' => 'preload'
},
{
'timeout_testprograms_span' => [ 5, 2],
'timeout_boot_span' => $timeout_span,
'timeout_current_date' => undef,
'results' => [],
'current_state' => 'preload'
}
],
'results' => []
};
my ($retval, $timeout, $db_state);
$retval = $state->state_init($initial_state);
($retval, $timeout) = $state->update_state(message_create({state => 'takeoff'}));
ok($timeout <= 3, 'Keep_alive timeout returned'); # This test depends on the fact that there is less than 2 hours between state_init and update_state. Probably a reasonable assumption
sleep(3);
($retval, $timeout) = $state->update_state();
my $result = $state->state_details->results();
is_deeply($result, [{
error => 1,
msg => "No plugin defined in keep_alive. I deactivate keep-alive for this testrun.",
}],
'Missing keepalive plugin detected'
);
my $cfg = {mcp_callback_handler => {plugin => 'Dummy'},
hostname => 'iring',
};
$state = Tapper::MCP::State->new(testrun_id => $testrun_id, cfg => $cfg);
isa_ok($state, 'Tapper::MCP::State');
$retval = $state->state_init($initial_state);
($retval, $timeout) = $state->update_state(message_create({state => 'takeoff'}));
ok($timeout <= 3, 'Keep_alive timeout returned'); # This test depends on the fact that there is less than 2 hours between state_init and update_state. Probably a reasonable assumption
sleep(3);
($retval, $timeout) = $state->update_state();
$result = $state->state_details->results();
is_deeply($result, [], 'No issues found for keep-alive');
done_testing();