view release on metacpan or  search on metacpan

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

BEGIN { $ENV{PERL_DL_NONLAZY} = 0; } # XXX

use Test::More;
use Test::TCP;
use Test::Time; # to fix expiry

plan tests => 9;

use AnyEvent::APNS;
use AnyEvent::Socket;

my $port = empty_port;

my $apns; $apns = AnyEvent::APNS->new(
    debug_port  => $port,
    certificate => 'dummy',
    private_key => 'dummy',
    on_error    => sub { die $! },
    on_connect  => sub {
        my $identifier = $apns->send('d' x 32 => { foo => 'bar' });
        is( $identifier, 1, '1st identifier is 1' );
    },
);

my $cv = AnyEvent->condvar;

# test server
my $connect_state = 'initial';
tcp_server undef, $port, sub {
    my ($fh) = @_
        or die $!;

    $connect_state = 'connected';

    my $handle; $handle = AnyEvent::Handle->new(
        fh       => $fh,
        on_eof   => sub {
            $connect_state = 'disconnected';
        },
        on_error => sub {
            die $!;
            undef $handle;
        },
        on_read => sub {
            $_[0]->unshift_read( chunk => 1, sub {} );
        },
    );

    $handle->push_read( chunk => 1, sub {
        is($_[1], pack('C', 1), 'command ok');
    });

    $handle->push_read( chunk => 4, sub {
        is($_[1], pack('N', 1), 'identifier ok');
    });

    $handle->push_read( chunk => 4, sub {
        my $expiry = unpack('N', $_[1]);
        is( $expiry, time() + 3600 * 24, 'expiry ok');
    });

    $handle->push_read( chunk => 2, sub {
        is($_[1], pack('n', 32), 'token size ok');
    });

    $handle->push_read( chunk => 32, sub {
        is($_[1], 'd'x32, 'token ok');
    });

    $handle->push_read( chunk => 2, sub {
        my $payload_length = unpack('n', $_[1]);

        $handle->push_read( chunk => $payload_length, sub {
            my $payload = $_[1];
            is(length $payload, $payload_length, 'payload length ok');
            is($payload, '{"foo":"bar"}', 'payload ok');
        });