#!/usr/bin/perl

BEGIN {
    $ENV{'PERL_ANYEVENT_STRICT'} = 1;
}

use strict;
use warnings;
use FindBin;
use Data::Dumper::Concise;

my %server = (
    product => undef,
    version => undef,
);

my %conf = (
    host  => 'localhost',
    port  => 5672,
    user  => 'guest',
    pass  => 'guest',
    vhost => q{/},
    verbose => 1,
);

eval {
    use IO::Socket::INET;

    my $socket = IO::Socket::INET->new(
        Proto    => 'tcp',
        PeerAddr => $conf{'host'},
        PeerPort => $conf{'port'},
        Timeout  => 1,
    ) or die 'Error connecting to AMQP Server!';

   close $socket;
};

use AnyEvent::RabbitMQ::Fork;

my $ar = AnyEvent::RabbitMQ::Fork->new(verbose => $conf{'verbose'});
$ar->load_xml_spec();

my $done = AnyEvent->condvar;
$ar->connect(
    (map {$_ => $conf{$_}} qw(host port user pass vhost)),
    tune       => { frame_max => 2**17 },
    timeout    => 1,
    on_success => sub {
        my $ar = shift;
        $server{product} = $ar->server_properties->{product};
        $server{version} = version->parse($ar->server_properties->{version});
        $done->send;
    },
    on_failure => failure_cb($done),
    on_return  => sub {
        my $method_frame = shift->method_frame;
        die "return: ", $method_frame->reply_code, $method_frame->reply_text
          if $method_frame->reply_code;
    },
    on_close   => sub {
        my $method_frame = shift->method_frame;
        Carp::confess "close: ", $method_frame->reply_code, $method_frame->reply_text
          if $method_frame->reply_code;
    },
);

sub failure_cb {
    my ($cv) = @_;
    return sub {
        $cv->send;
    };
}

AnyEvent->condvar->recv;