view release on metacpan or  search on metacpan

t/040-live-console.t  view on Meta::CPAN

use strict;
use warnings;
use Test::More tests => 60;
use Test::Differences;
use FindBin;
use lib "$FindBin::Bin/lib";
use Gearman::Driver::Test;
use Data::Dumper;
$Data::Dumper::Sortkeys = 1;

my $test = Gearman::Driver::Test->new();

$test->prepare('Gearman::Driver::Test::Live::Console');

my $gc     = $test->gearman_client;
my $telnet = $test->telnet_client;

{
    $telnet->print("asdf");
    is( $telnet->getline(), "ERR unknown_command: asdf\n" );
    is( $telnet->getline(), ".\n" );

    $telnet->print("set_min_processes asdf 5");
    is( $telnet->getline(), "ERR invalid_job_name: asdf\n" );
    is( $telnet->getline(), ".\n" );

    $telnet->print("set_min_processes Gearman::Driver::Test::Live::Console::ping ten");
    is( $telnet->getline(), "ERR invalid_value: min_processes must be >= 0\n" );
    is( $telnet->getline(), ".\n" );

    $telnet->print("set_min_processes Gearman::Driver::Test::Live::Console::ping 10");
    is( $telnet->getline(), "ERR invalid_value: min_processes must be smaller than max_processes\n" );
    is( $telnet->getline(), ".\n" );

    $telnet->print("set_max_processes asdf 5");
    is( $telnet->getline(), "ERR invalid_job_name: asdf\n" );
    is( $telnet->getline(), ".\n" );

    $telnet->print("set_max_processes Gearman::Driver::Test::Live::Console::ping ten");
    is( $telnet->getline(), "ERR invalid_value: max_processes must be >= 0\n" );
    is( $telnet->getline(), ".\n" );

    $telnet->print("set_max_processes Gearman::Driver::Test::Live::Console::ping 5");
    is( $telnet->getline(), "OK\n" );
    is( $telnet->getline(), ".\n" );
    $telnet->print("set_min_processes Gearman::Driver::Test::Live::Console::ping 5");
    is( $telnet->getline(), "OK\n" );
    is( $telnet->getline(), ".\n" );

    $telnet->print("set_max_processes Gearman::Driver::Test::Live::Console::ping 4");
    is( $telnet->getline(), "ERR invalid_value: max_processes must be greater than min_processes\n" );
    is( $telnet->getline(), ".\n" );

    $telnet->print("set_processes asdf 1 1");
    is( $telnet->getline(), "ERR invalid_job_name: asdf\n" );
    is( $telnet->getline(), ".\n" );

    $telnet->print("set_processes Gearman::Driver::Test::Live::Console::ping ten ten");
    is( $telnet->getline(), "ERR invalid_value: min_processes must be >= 0\n" );
    is( $telnet->getline(), ".\n" );

    $telnet->print("set_processes Gearman::Driver::Test::Live::Console::ping 1 ten");
    is( $telnet->getline(), "ERR invalid_value: max_processes must be >= 0\n" );
    is( $telnet->getline(), ".\n" );