view release on metacpan or  search on metacpan

t/53-slots-active.t  view on Meta::CPAN

#!/usr/bin/env perl

use strict;
use warnings;
use AnyEvent::Impl::Perl;
use AnyEvent;
use AnyEvent::Socket;

use lib::abs '../lib';

use Test::More;
use AnyEvent::SMTP qw(smtp_server sendmail);

our $port = 1024 + $$ % (65535-1024) ;
our $ready = 0;
$SIG{INT} = $SIG{TERM} = sub { exit 0 };

our $child;
unless($child = fork) {
	# Start server and wait for connections
	my $cv = AnyEvent->condvar;
	my $req = 2;
	smtp_server undef, $port, sub { };
	$cv->recv;
} else {
	# Wait for server to start
	my $cv = AnyEvent->condvar;
	my ($conn,$cg);
	$cv->begin(sub {
		undef $conn;
		undef $cg;
		$cv->send;
	});
	$conn = sub {
		$cg = tcp_connect '127.0.0.1',$port, sub {
			return $cv->end if @_;
			$!{ENODATA} or $!{ECONNREFUSED} or plan skip_all => "Bad response from server connect: [".(0+$!)."] $!"; 
			my $t;$t = AnyEvent->timer( after => 0.05, cb => sub { undef $t; $conn->() } );
		};
	};
	$conn->();
	$cv->recv;
}

plan tests => 11;

my $cv = AnyEvent->condvar;
$cv->begin(sub { $cv->send; });

our (%ACTIVE);
*ACTIVE = \%AnyEvent::SMTP::Client::ACTIVE;

$AnyEvent::SMTP::Client::MAXCON = 0;

my $max = 0;

for (1..10) {
	sendmail
		# debug  => 1,
		host   => '127.0.0.1', port => $port,
		from   => 'test@test.test',
		to     => 'tset@tset.tset',
		data   => 'body',
		cv     => $cv,
		cb     => sub {
			$max = $ACTIVE{'127.0.0.1'}
				if $ACTIVE{'127.0.0.1'} and $ACTIVE{'127.0.0.1'} > $max;
			like $_[0], qr/^250 /, 'Response 250'
				or diag "  Error: $_[1]";