view release on metacpan or  search on metacpan

t/10-kv.t  view on Meta::CPAN

#!perl

use warnings;
use strict;

use Test::More;
use Test::Exception;
use Test::Consul;

use AnyEvent;
use AnyEvent::Consul;

my $tc = eval { Test::Consul->start };

SKIP: {
    skip "consul test environment not available", 4 unless $tc;

    my $kv = AnyEvent::Consul->kv(port => $tc->port);
    ok $kv, "got KV API object";

    my $cv = AE::cv;

    $kv->put(foo => "bar", cb => sub {
        my ($r, $meta) = @_;
        ok $r, "key was updated";

        $kv->get("foo", cb => sub {
            my ($r, $meta) = @_;
            is $r->value, "bar", "returned KV has correct value";
            isa_ok $meta, 'Consul::Meta', "got server meta object";

            $cv->send;
        });
    });

    $cv->recv;
}

done_testing;