more testing for different @INC hook types

[scpubgit/Object-Remote.git] / t / sender.t

diff --git a/t/sender.t b/t/sender.t
index 02eb0d8..964673e 100644 (file)
--- a/t/sender.t
+++ b/t/sender.t
@@ -1,6 +1,8 @@
 use strictures 1;
 use Test::More;
 
+$ENV{OBJECT_REMOTE_TEST_LOGGER} = 1;
+
 use Object::Remote::Connector::Local;
 use Object::Remote;
 use Object::Remote::ModuleSender;
@@ -9,29 +11,93 @@ $ENV{PERL5LIB} = join(
   ':', ($ENV{PERL5LIB} ? $ENV{PERL5LIB} : ()), qw(lib)
 );
 
-my $connection = Object::Remote::Connector::Local->new->connect;
+my $mod_content = do {
+  open my $fh, '<', 't/lib/ORTestClass.pm'
+    or die "can't read ORTestClass.pm: $!";
+  local $/;
+  <$fh>
+};
+my $modules = {
+  'ORTestClass.pm' => $mod_content,
+};
 
-my $ms = Object::Remote::ModuleSender->new(
-  dir_list => [ 't/lib' ]
-);
+sub TestModuleProvider::INC {
+  my ($self, $module) = @_;
+  if (my $data = $self->{modules}{$module}) {
+    open my $fh, '<', \$data
+      or die "Unable to open in-memory file: $!";
+    return $fh;
+  }
+  return;
+}
 
-my $ml = Object::Remote->new(
-  connection => $connection,
-  class => 'Object::Remote::ModuleLoader',
-  args => { module_sender => $ms },
+my %sources = (
+  basic => [ 't/lib' ],
+  sub => [ sub {
+    if (my $data = $modules->{$_[1]}) {
+      open my $fh, '<', \$data
+        or die "Unable to open in-memory file: $!";
+      return $fh;
+    }
+    return;
+  } ],
+  dynamic_array => [ [ sub {
+    my $mods = $_[0][1];
+    if (my $data = $mods->{$_[1]}) {
+      open my $fh, '<', \$data
+        or die "Unable to open in-memory file: $!";
+      return $fh;
+    }
+    return;
+  }, $modules ] ],
+  object => [ bless { modules => $modules }, 'TestModuleProvider' ],
+  filter_sub => [ sub {
+    if (my $data = $modules->{$_[1]}) {
+      my @lines = split /\n/, $data;
+      my $read = join("\n", 0..$#lines);
+      open my $fh, '<', \$read
+        or die "welp $!";
+      return ($fh, sub {
+        chomp;
+        my $ret = $_ != $#lines ? 1 : 0;
+        $_ = $lines[$_];
+        return $ret;
+      });
+    }
+    return;
+  } ],
+  feed_sub => [ sub {
+    if (my $data = $modules->{$_[1]}) {
+      my @lines = split /(\n)/, $data;
+      return sub {
+        $_ = shift @lines;
+        return @lines ? 1 : 0;
+      };
+    }
+    return;
+  } ],
 );
 
-my $counter = Object::Remote->new(
-  connection => $connection,
-  class => 'ORTestClass'
-);
+for my $source (sort keys %sources) {
+  my $ms = Object::Remote::ModuleSender->new(
+    dir_list => $sources{$source},
+  );
+  my $connection = Object::Remote::Connector::Local->new(
+                  module_sender => $ms,
+                  )->connect;
+
+  my $counter = Object::Remote->new(
+    connection => $connection,
+    class => 'ORTestClass'
+  );
 
-isnt($$, $counter->pid, 'Different pid on the other side');
+  isnt($$, $counter->pid, "$source sender: Different pid on the other side");
 
-is($counter->counter, 0, 'Counter at 0');
+  is($counter->counter, 0, "$source sender: Counter at 0");
 
-is($counter->increment, 1, 'Increment to 1');
+  is($counter->increment, 1, "$source sender: Increment to 1");
 
-is($counter->counter, 1, 'Counter at 1');
+  is($counter->counter, 1, "$source sender: Counter at 1");
+}
 
 done_testing;