Asynchronous tests

MANIFEST

@@ -19,6 +19,8 @@ lib/Couchbase/Client/Async/Request.pm
 lib/Couchbase/MockServer.pm
 lib/Couchbase/Test/ClientSync.pm
 lib/Couchbase/Test/Common.pm
+lib/Couchbase/Test/Async.pm
+lib/Couchbase/Test/Async/Loop.pm
 
 Client.xs
 Async.xs

lib/Couchbase/Test/Async.pm

@@ -0,0 +1,101 @@
+package Couchbase::Test::Async;
+use strict;
+use warnings;
+
+use base qw(Couchbase::Test::Common);
+use base qw(POE::Sugar::Attributes);
+use POE::Kernel;
+use Test::More;
+use Couchbase::Client::Async;
+use Couchbase::Client::Errors;
+use Couchbase::Client::IDXConst;
+use Couchbase::Test::Async::Loop;
+use Array::Assign;
+use Data::Dumper;
+use Log::Fu;
+
+my $loop_session = "cbc_test_async";
+my $client_session = 'our_client';
+
+my $poe_kernel = 'POE::Kernel';
+$poe_kernel->run();
+
+my $ReadyReceived = 0;
+my $Return = undef;
+
+sub setup_async :Test(startup) {
+    my $self = shift;
+    $self->mock_init();
+    Couchbase::Test::Async::Loop->spawn($loop_session,
+        on_ready => \&loop_ready,
+        %{$self->common_options}
+    );
+}
+
+sub loop_ready {
+    $ReadyReceived = 1;
+}
+
+sub _run_poe {
+    $poe_kernel->run_one_timeslice() while ($ReadyReceived == 0);
+}
+
+sub cb_result_single {
+    my ($key,$return,$errnum) = @_;
+    is($return->errnum, $errnum, "Got return for key $key ($errnum)");
+    $Return = $return;
+}
+
+sub reset_vars :Test(setup) {
+    $ReadyReceived = 0;
+    $Return = undef;
+}
+
+sub post_to_loop {
+    my ($self,$command,$opargs,$errnum) = @_;
+    reset_vars();
+    $poe_kernel->post($loop_session, $command, $opargs,
+                      {callback => \&cb_result_single, arg => $errnum });
+    _run_poe();
+    ok($Return, "Have return object");
+    return $Return;
+}
+
+sub T10_connect :Test(no_plan) {
+    $poe_kernel->run_one_timeslice() while ($ReadyReceived == 0);
+    ok($ReadyReceived, "Eventually connected..");
+}
+
+sub T11_set :Test(no_plan) {
+    my $self = shift;
+    my $key = "async_key";
+    my $value = $self->k2v($key);
+    $self->post_to_loop(set => [ $key, $value ], COUCHBASE_SUCCESS);
+}
+
+sub T12_get :Test(no_plan) {
+    my $self = shift;
+    my $key = "async_key";
+
+    my $ret = $self->post_to_loop(get => "async_key", COUCHBASE_SUCCESS);
+    is($ret->value, $self->k2v($key), "Got expected value");
+}
+
+sub T13_arith_ext :Test(no_plan) {
+    my $self = shift;
+    my $key = "arith";
+
+    my $ret;
+
+    $ret = $self->post_to_loop(
+        arithmetic => [ $key, 42, undef ], COUCHBASE_KEY_ENOENT);
+    is($ret->value, undef, "Didn't get value for missing initial value");
+
+    $ret = $self->post_to_loop(
+        arithmetic => [ $key, 9999, 42 ], COUCHBASE_SUCCESS);
+
+    is($Return->value, 42, "Initial value set via arithmetic");
+
+}
+
+1;