Messaging-Courier

 view release on metacpan or  search on metacpan

t/00_courier.t  view on Meta::CPAN

  my $f = Messaging::Courier->new(Peer => 'not-here.example.com');
} qr /could not connect to spread daemon/;

throws_ok { $c->receive('not_a_number') } qr/timeout must be a number/;
throws_ok { $c->receive(-1) } qr/timeout must be a positive number/;

# First a simple case

use_ok( 'Messaging::Courier::ExampleMessage' );
ok( my $m = Messaging::Courier::ExampleMessage->new() );
ok( $m->username( $ENV{USER} || getlogin || getpwuid($>) ) );
ok( $m->password( 'bar' ) );
ok( $c->send( $m ) );

{
  my $query;
  while(1) {
    ok( $query = $c->receive() );
    last if $query->username() eq ( $ENV{USER} || getlogin || getpwuid($>) );
  }

  my $reply = $query->reply->token( '42' );
  ok( $c->send( $reply ) );
}

my $response = $c->receive( 0, $m );
is( $response->token, '42' );
is( $response->frame->in_reply_to, $m->frame->id );
ok( $response->sent_by($c) );

t/01_auth_client.t  view on Meta::CPAN

  exec $^X, 't/bin/auth_server.pl';
}

sleep 1;

use_ok('Messaging::Courier');
ok( my $c = Messaging::Courier->new() );

use_ok( 'Messaging::Courier::ExampleMessage' );
ok( my $m = Messaging::Courier::ExampleMessage->new() );
ok( $m->username( $ENV{USER} || getlogin || getpwuid($>) ) );
ok( $m->password( 'bar' ) );
my $response = $c->ask( $m );
ok( $response );
is( $response->token, '42' );
is( $response->frame->in_reply_to, $m->frame->id );

t/03_structure.t  view on Meta::CPAN

$complicated, $not_utf8);

foreach my $data (@data) {
  test($data);
}

sub test {
  my $data = shift;

  ok( my $m = Messaging::Courier::ExampleMessage->new() );
  ok( $m->username( $ENV{USER} || getlogin || getpwuid($>) ) );
  ok( $m->password( $data ) );
  ok( $c->send( $m ) );

  {
    my $query;
    while(1) {
      ok( $query = $c->receive() );
      last if $query->username() eq ( $ENV{USER} || getlogin || getpwuid($>) );
    }
    is_deeply($query->password, clone($data));
    my $reply = $query->reply->token( '42' );
    ok( $c->send( $reply ) );
  }

  my $response = $c->receive( 0, $m );
  is( $response->token, '42' );
  is( $response->frame->in_reply_to, $m->frame->id );
  ok( $response->sent_by($c) );

t/04_wiretap.t  view on Meta::CPAN

use_ok('Messaging::Courier');
my $c = Messaging::Courier->new();

use_ok('Messaging::Courier::Wiretap');
my $w = Messaging::Courier::Wiretap->new();

throws_ok { $w->tap('not_a_number') } qr/timeout must be a number/;
throws_ok { $w->tap(-1) } qr/timeout must be a positive number/;

my $user = $ENV{USER} || getlogin || getpwuid($>);
ok($user, "user is set to something");

use_ok( 'Messaging::Courier::ExampleMessage' );
my $m = Messaging::Courier::ExampleMessage->new();
$m->username($user);
$m->password('bar');
$c->send($m);

my $xml;

t/05_floodtest.t  view on Meta::CPAN

use Test::Exception;
use Test::More tests => 3;
use Time::HiRes qw(time);
use lib 'lib';

use_ok('Messaging::Courier');
my $c = Messaging::Courier->new();

use_ok( 'Messaging::Courier::ExampleMessage' );
my $m = Messaging::Courier::ExampleMessage->new();
$m->username( $ENV{USER} || getlogin || getpwuid($>) );
$m->password('bar');
$c->send($m);

foreach (1..20) {
  my $m2 = Messaging::Courier::ExampleMessage->new();
  $m2->username( $ENV{USER} || getlogin || getpwuid($>) );
  $m2->password('bar');
  $c->send($m2);
}

my $m3 = Messaging::Courier::ExampleMessage->new();
$m3->username('back');
$m3->password('return');
$m3->in_reply_to($m);
$c->send($m3);

t/06_receive_many.t  view on Meta::CPAN

use Test::Exception;
use Test::More tests => 14;
use Time::HiRes qw(time);
use lib 'lib';

use_ok('Messaging::Courier');
my $c = Messaging::Courier->new();

use_ok( 'Messaging::Courier::ExampleMessage' );
my $m = Messaging::Courier::ExampleMessage->new();
$m->username( $ENV{USER} || getlogin || getpwuid($>) );
$m->password('bar');
$c->send($m);

foreach my $i (1..10) {
  my $m2 = Messaging::Courier::ExampleMessage->new();
  $m2->username( $ENV{USER} || getlogin || getpwuid($>) );
  $m2->password($i);
  $m2->in_reply_to($m);
  $c->send($m2);
}

my $time = time;
my @replies = $c->receive_many(1, $m);
is (scalar(@replies), 10);

my $diff = time - $time;