view release on metacpan or  search on metacpan

t/63_async_adapter_promise_es6.t  view on Meta::CPAN

    my ($resolve, $reject);
    my $promise = Promise::ES6->new(sub { ($resolve, $reject) = @_ });
    return [ $promise, $resolve, $reject ];
  },
  all => sub { Promise::ES6->all($_[0]) },
);

my $resolve_pending;
my $schema = GraphQL::Houtou::Schema->new(
  query => GraphQL::Houtou::Type::Object->new(
    name => 'PromiseES6AdapterQuery',
    fields => {
      ready => {
        type => $String,
        resolve => sub { Promise::ES6->resolve('ready') },
      },
      items => {
        type => $String->list,
        resolve => sub {
          [ Promise::ES6->resolve('a'), 'b' ]
        },
      },
      pending => {
        type => $String,
        resolve => sub {
          return $pending_promise = Promise::ES6->new(sub { ($resolve_pending) = @_ });
        },
      },
    },
  ),
);

my $runtime = $schema->build_native_runtime(async_adapter => $adapter);
my $ready_value = $runtime->execute_document('{ ready items }');
my $ready = !blessed($ready_value);
if (!$ready) {
  $ready_value->then(sub { ($ready, $ready_value) = (1, $_[0]) });
}
ok $ready, 'Promise::ES6 pre-resolved response settles synchronously';
is_deeply $ready_value, {
  data => { ready => 'ready', items => [qw(a b)] },
}, 'external-style Promise::ES6 adapter completes values';

my $result = $runtime->execute_document('{ pending }');
my ($done, $value);
$result->then(sub { ($done, $value) = (1, $_[0]) });
ok !$done, 'Promise::ES6 response remains pending';
$resolve_pending->('later');
ok $done, 'Promise::ES6 response resumes after resolution';
is_deeply $value, { data => { pending => 'later' } },
  'Promise::ES6 pending response is correct';

{
  $pending_promise = undef;
  $resolve_pending = undef;
  my $owner_runtime = $schema->build_native_runtime(async_adapter => $adapter);
  my $weak_handle = $owner_runtime->_native_runtime_handle;
  weaken($weak_handle);
  my $owned_response = $owner_runtime->execute_document('{ pending }');
  undef $owner_runtime;
  ok defined($weak_handle), 'pending response keeps its native runtime alive';
  my $owned_value;
  $owned_response->then(sub { $owned_value = $_[0] });
  $resolve_pending->('owned');
  is_deeply $owned_value, { data => { pending => 'owned' } },
    'response settles after its Perl runtime is released';
  ($owned_response, $pending_promise, $resolve_pending) = (undef, undef, undef);
  ok !defined($weak_handle), 'native runtime is released with the response';
}

$then_error = 'adapter then failed';
eval {
  $runtime->_settle_result(Promise::ES6->resolve('unused'), sub { 0 });
};
my $error = $@;
like $error, qr/adapter then failed/, 'adapter then exceptions propagate';
unlike $error, qr/execution stalled/, 'adapter then exceptions are not reported as stalls';

$then_error = undef;
$only_outer_error = 0;
$pending_promise = undef;
$resolve_pending = undef;
my $pending_response = $runtime->execute_document('{ pending }');
$then_error = 'Perl driver outer then failed';
$only_outer_error = 1;
eval { $runtime->_settle_result($pending_response, sub { 0 }) };
like $@, qr/Perl driver outer then failed/,
  'Perl settlement propagates adapter then exceptions';
is_deeply GraphQL::Houtou::XS::VM::debug_frame_live_counts_xs(), {
  block_frame => 0,
  path_frame => 0,
  lazy_info => 0,
}, 'Perl settlement cancels the response after adapter then failure';

$then_error = 'outer adapter then failed';
$only_outer_error = 1;
$pending_promise = undef;
$resolve_pending = undef;
eval {
  $runtime->execute_document(
    '{ pending }',
    on_stall => sub { $resolve_pending->('unused'); 1 },
  );
};
$error = $@;
like $error, qr/outer adapter then failed/,
  'C on_stall driver propagates adapter then exceptions';
unlike $error, qr/execution stalled/,
  'C on_stall driver does not replace adapter exceptions with stalls';
is_deeply GraphQL::Houtou::XS::VM::debug_frame_live_counts_xs(), {
  block_frame => 0,
  path_frame => 0,
  lazy_info => 0,
}, 'adapter then failure cancels the pending response';

done_testing;