[open-ils-commits] r11939 - in trunk/Open-ILS/src/perlmods/OpenILS/Application: . Trigger

[svn at svn.open-ils.org]

Author: miker
Date: 2009-01-23 16:06:27 -0500 (Fri, 23 Jan 2009)
New Revision: 11939

Added:
   trunk/Open-ILS/src/perlmods/OpenILS/Application/Trigger/
   trunk/Open-ILS/src/perlmods/OpenILS/Application/Trigger/ModRunner.pm
Log:
initial cut of some scaffolding which will load and run Collector, Validator, Reactor and Cleanup handlers

Added: trunk/Open-ILS/src/perlmods/OpenILS/Application/Trigger/ModRunner.pm
===================================================================
--- trunk/Open-ILS/src/perlmods/OpenILS/Application/Trigger/ModRunner.pm	                        (rev 0)
+++ trunk/Open-ILS/src/perlmods/OpenILS/Application/Trigger/ModRunner.pm	2009-01-23 21:06:27 UTC (rev 11939)
@@ -0,0 +1,212 @@
+package OpenILS::Application::Trigger::ModLoader;
+use UNIVERSAL::require;
+
+sub new {
+    my $class = shift;
+    $class = ref($class) || $class;
+
+    my $mod_thing = shift;
+    return undef unless ($mod_thing);
+
+    my $self = bless {
+        mod_thing => $mod_thing,
+        module => $mod_thing->module(),
+        handler => 'handler'
+    } => $class;
+
+    return $self->load;
+}
+
+sub loaded {
+    my $self = shift;
+    return undef unless (ref $self);
+
+    my $l = shift;
+    $self->{loaded} = $l if (defined $l);
+    return $self->{loaded};
+}
+
+sub handler {
+    my $self = shift;
+    return undef unless (ref $self);
+
+    my $h = shift;
+    $self->{handler} = $h if $h;
+    return $self->{handler};
+}
+
+sub module {
+    my $self = shift;
+    return undef unless (ref $self);
+
+    my $m = shift;
+    $self->{module} = $m if $m;
+    return $self->{module};
+}
+
+sub load {
+    my $self = shift;
+    return undef unless (ref $self);
+
+    my $m = shift || $self->module;
+    my $h = shift || $self->handler;
+    return 1 unless $m;
+
+    my $loaded = $m->use;
+
+    if (!$loaded) {
+        $builtin_m = "OpenILS::Application::Trigger::$m";
+        $loaded = $builtin_m->use;
+
+        if (!$loaded) {
+            if ($m =~ /::/o) {
+                ($h = $m) =~ s/^.+::([^:]+)$/$1/o;
+                $m =~ s/^(.+)::[^:]+$/$1/o;
+
+                $loaded = $m->use;
+
+                if (!$loaded) {
+                    $h =  $self->handler;
+                    my $builtin_m = "OpenILS::Application::Trigger::$m";
+                    $loaded = $m->use;
+
+                    $m = $builtin_m if ($loaded);
+                }
+            } else {
+                $loaded = $m->use;
+            }
+        } else {
+            $m = $builtin_m;
+        }
+    }
+
+    if ($loaded) {
+        $self->module( $m );
+        $self->handler( $h );
+    }
+
+    $self->loaded($loaded);
+    return $self;
+}
+
+package OpenILS::Application::Trigger::ModRunner;
+use base 'OpenILS::Application::Trigger::ModLoader';
+
+sub new {
+    my $class = shift;
+    $class = ref($class) || $class;
+
+    my $m = shift;
+    my $e = shift || {};
+
+    my $self = $class->SUPER::new( $m );
+    return undef unless ($self && $self->loaded);
+
+    $self->environment( $e );
+    return $self;
+}
+
+sub pass {
+    my $old = shift;
+    return undef unless (ref $old);
+
+    my $class = ref($old);
+    my $m = shift;
+
+    my $self = $class->SUPER::new( $m );
+    return undef unless ($self && $self->loaded);
+
+    $self->environment( $old->environment );
+    return $self;
+}
+
+sub environment {
+    my $self = shift;
+    return undef unless (ref $self);
+
+    my $e = shift;
+    $self->{environment} = $e if (defined $e);
+    return $self->{environment};
+}
+
+sub final_result {
+    my $self = shift;
+    return undef unless (ref $self);
+
+    my $r = shift;
+    $self->{final_result} = $r if (defined $r);
+    return $self->{final_result};
+}
+
+sub run {
+    my $self = shift;
+    return undef unless (ref $self && $self->loaded);
+
+    $self->environment( shift );
+
+    my $m = $self->module;
+    my $h = $self->handler;
+    my $e = $self->environment;
+    $self->final_result( $m->$h( $e ) );
+
+    return $self;
+};
+
+package OpenILS::Application::Trigger::ModStackRunner;
+use base 'OpenILS::Application::Trigger::ModRunner';
+
+sub new {
+    my $class = shift;
+    $class = ref($class) || $class;
+
+    my $m = shift;
+    $m = [$m] unless (ref($m) =~ /ARRAY/o);
+
+    my $e = shift || {};
+
+    my $self = bless {
+        runners => []
+    } => $class;
+
+    for my $mod ( @$m ) {
+        my $r = $self->SUPER::new( $m );
+        return undef unless ($r && $r->loaded);
+        push @{$self->{runners}}, $r;
+    }
+
+    $self->loaded(1);
+
+    return $self;
+}
+
+sub pass {
+    my $old = shift;
+    return undef unless (ref $old);
+
+    my $class = ref($old);
+    my $m = shift;
+
+    my $self = $class->new( $m );
+    return undef unless ($self && $self->loaded);
+
+    $self->environment( $old->environment );
+    return $self;
+}
+
+sub run {
+    my $self = shift;
+    return undef unless (ref $self && $self->loaded);
+
+    $self->environment( shift );
+    my $e = $self->environment;
+
+    for my $r (@{$self->{runners}}) {
+        my $m = $r->module;
+        my $h = $r->handler;
+        $r->final_result( $m->$h( $e ) );
+    }
+
+    return $self;
+};
+
+1;