view release on metacpan or  search on metacpan

t/emit-multi-json.t  view on Meta::CPAN

App::MultiModule::Test::begin();
App::MultiModule::Test::Runner::_begin();

my (undef, $errors_log) = tempfile();
my $args = "-q tqueue -p MultiModuleTest:: -o error:$errors_log";
ok my $daemon_pid = App::MultiModule::Test::run_program($args), 'run_program';
END { #just to be damn sure
    kill 9, $daemon_pid;
    unlink $errors_log;
};

my $config = {
    '.multimodule' => {
        config => {
            Runner => {
            },
            MultiModule => {
            },
            Router => {  #router config
                routes => [
                    {   match => {
                            source => 'Runner',
                            json => 'thing1'
                        },
                        forwards => [
                            {   qname => 'test_out' }
                        ],
                    },
                    {   match => {
                            source => 'Runner',
                            json => 'thing2'
                        },
                        forwards => [
                            {   qname => 'test_out' }
                        ],
                    }
                ],
            }
        },
    }
};
ok IPC::Transit::send(qname => 'tqueue', message => $config), 'sent config';

IPC::Transit::send(qname => 'Runner', message => {
    runner_program_prog => './emit-multi-json.sh',
    runner_program_args => [],
    runner_process_regex => './emit-multi-json.sh',
    runner_return_type => 'json',
});


eval {
    local $SIG{ALRM} = sub { die "timed out\n"; };
    alarm 5;
    ok my $ret = IPC::Transit::receive(qname => 'test_out');
    is $ret->{runner_message_type}, undef, 'first message correctly has no defined runner_message_type';
    is $ret->{json}, 'thing1', 'first message correctly had "json" set to "thing1"';
};
alarm 0;
ok !$@, 'no exception thrown for first message';

eval {
    local $SIG{ALRM} = sub { die "timed out\n"; };
    alarm 5;
    ok my $ret = IPC::Transit::receive(qname => 'test_out');
    is $ret->{runner_message_type}, undef, 'second message correctly has no defined runner_message_type';
    is $ret->{json}, 'thing2', 'second message correctly had "json" set to "thing2"';
};
alarm 0;
ok !$@, 'no exception thrown for second message';

ok IPC::Transit::send(qname => 'tqueue', message => {
    '.multimodule' => {
        control => [
            {   type => 'cleanly_exit',
                exit_externals => 1,
            }
        ],
    }
}), 'sent program exit request';

sleep 6;
ok waitpid($daemon_pid, WNOHANG) == $daemon_pid, 'waitpid';
ok !kill(9, $daemon_pid), 'program exited';

App::MultiModule::Test::finish();
App::MultiModule::Test::Runner::_finish();

done_testing();