view release on metacpan or  search on metacpan

t/02_trim.t  view on Meta::CPAN

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

use utf8;
use Test::Base;
use Test::TCP;
use Test::Time; # to fix expiry

plan tests => 16;

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

my $port = empty_port;

my $payloads = [
    { aps => { alert => 'こんにちは'x100, } },
    { aps => { alert => { body => 'こんにちは'x100, } } },
];

for my $payload (@$payloads) {

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

    my $cv = AnyEvent->condvar;

    # test server
    my $connect_state = 'initial';
    my $server = 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]);
            like($payload_length, qr/^25[0-6]$/, 'truncate $payload->{alert} ok');

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

            $apns->clear_handler;