view release on metacpan or  search on metacpan

t/32-async-load-age.t  view on Meta::CPAN

#   * owner  = the composed SYNC Age storage (the Age storage LAYER over the PG
#     driver storage). It defines connect_call_load_age via the layer -- the
#     async layer deliberately does NOT;
#   * backend = a REAL composed Age async backend (the Age async LAYER over the
#     future_io transport) whose pool is swapped for a recording pool (no DBD::Pg
#     connect, no event loop);
#   * connect_info carries { on_connect_call => 'load_age' }.
#
# Acquiring a pool connection must record exactly the two statements
# connect_call_load_age emits, against that connection, before it is served.
# Mirrors core t/storage/pool_connect_actions.t.

BEGIN {
  eval { require DBIO::PostgreSQL::Storage::Async; 1 }
    or plan skip_all => 'future_io prerequisites (DBD::Pg/Future/Future::IO) not available';
}

use DBIO::Test;
use DBIO::Storage::Composed;
use DBIO::PostgreSQL::Storage;
use DBIO::PostgreSQL::Age::Storage;
use DBIO::PostgreSQL::Age::Storage::Async;

# --- Recording connection: the { dbh => $dbh } shape the default runner drives -
{
  package RecHandle;
  sub new { bless { log => $_[1] }, $_[0] }
  sub do  { my ($self, $sql) = @_; push @{ $self->{log} }, $sql; 1 }
}

{
  package RecPool;
  use base 'DBIO::Storage::PoolBase';

  my $NEXT = 0;
  sub _create_connection {
    my @log;
    return { id => ++$NEXT, log => \@log, dbh => RecHandle->new(\@log) };
  }
  sub _shutdown_connection { }   # keep the log alive for post-shutdown asserts
}

# --- The real Age async backend, with its pool swapped for the recorder -------
# The composed backend's ISA is (Age async layer, future_io transport); we
# reconstruct exactly that here and swap in the recording pool.
{
  package RecAgeBackend;
  use base qw( DBIO::PostgreSQL::Age::Storage::Async DBIO::PostgreSQL::Storage::Async );
  use mro 'c3';

  sub pool {
    my $self = shift;
    $self->{pool} ||= RecPool->new(
      storage  => $self,
      conninfo => 'fake',
      size     => $self->{_pool_size} || 2,
    );
  }
}

my $schema = DBIO::Test->init_schema;   # kept alive: storages weaken their refs

# The owning SYNC storage is the composed Age storage (Age LAYER over the PG
# driver) -- it carries connect_call_load_age via the layer.
my $owner_class = DBIO::Storage::Composed->compose(
  'DBIO::PostgreSQL::Storage', ['DBIO::PostgreSQL::Age::Storage'],
);
my $owner   = $owner_class->new($schema);
my $backend = RecAgeBackend->new($schema);

$owner->on_connect_call('load_age');
$backend->_owner_storage($owner);
$backend->connect_info([ { host => 'h', pool_size => 2 } ]);

my @expected = ( q{LOAD 'age'}, q{SET search_path = ag_catalog, "$user", public} );

# --- A freshly spawned connection replays load_age via the core seam ----------
{
  my $c1 = $backend->pool->acquire->get;
  is_deeply $c1->{log}, \@expected,
    q{connect_call_load_age replayed on the first pool connection: LOAD 'age' then the search_path SET};

  ok scalar(@{ $c1->{log} }),
    'the LOAD/SET are in place the moment the connection is handed out (spawn-time, pre-query)';

  # A second physical connection gets its OWN independent replay.
  my $c2 = $backend->pool->acquire->get;
  isnt $c1->{id}, $c2->{id}, 'two distinct physical connections spawned';
  is_deeply $c2->{log}, \@expected,
    'the second pool connection got its own full load_age replay';

  # Idle reuse must NOT re-run load_age (spawn-only, once per physical conn).
  $backend->pool->release($c1);
  my $reused = $backend->pool->acquire->get;
  is $reused->{id}, $c1->{id}, 'released connection is reused, not re-spawned';
  is_deeply $reused->{log}, \@expected,
    'reused idle connection did not replay load_age a second time';
}

# --- The adapter itself owns NO load_age logic (anti-hack guard) --------------
{
  ok( !DBIO::PostgreSQL::Age::Storage::Async->can('connect_call_load_age'),
    'the async adapter defines no connect_call_load_age of its own -- LOAD age '
    . q{comes only from the owning sync storage via the core seam (no per-adapter hack)} );

  ok( DBIO::PostgreSQL::Age::Storage->can('connect_call_load_age'),
    'the owning sync Age storage is where connect_call_load_age actually lives' );
}

done_testing;