From a8c58a7b05da86caf3c913d55c99936e174bfc5a Mon Sep 17 00:00:00 2001
From: Oliver Gorwits <oliver@cpan.org>
Date: Sun, 3 Sep 2017 22:30:28 +0100
Subject: [PATCH] initial broken implementation of the runner

---
 Build.PL                           |  5 ++--
 lib/App/Netdisco/Backend/Runner.pm | 42 ++++++++++++++++++++++++++++--
 lib/App/Netdisco/Worker/Plugin.pm  |  7 ++---
 lib/App/Netdisco/Worker/Status.pm  | 10 +++++++
 4 files changed, 57 insertions(+), 7 deletions(-)

diff --git a/Build.PL b/Build.PL
index bc418d15..e12ef0c4 100644
--- a/Build.PL
+++ b/Build.PL
@@ -13,6 +13,9 @@ Module::Build->new(
   build_requires => {
   },
   requires => {
+    'aliased' => '0',
+    'namespace::clean' => '0.24',
+    'version' => '0.9902',
     'Algorithm::Cron' => '0.07',
     'AnyEvent' => '7.05',
     'AnyEvent::DNS::EtcHosts' => '0',
@@ -71,8 +74,6 @@ Module::Build->new(
     'URL::Encode' => '0.01',
     'YAML' => '0.84',
     'YAML::XS' => '0.41',
-    'namespace::clean' => '0.24',
-    'version' => '0.9902',
   },
   recommends => {
     'Graph' => '0',
diff --git a/lib/App/Netdisco/Backend/Runner.pm b/lib/App/Netdisco/Backend/Runner.pm
index 42443947..f2150edd 100644
--- a/lib/App/Netdisco/Backend/Runner.pm
+++ b/lib/App/Netdisco/Backend/Runner.pm
@@ -1,7 +1,8 @@
 package App::Netdisco::Backend::Runner;
 
 use Dancer ':moose :syntax';
-use App::Netdisco::Worker::Status;
+use Dancer::Factory::Hook;
+use aliased 'App::Netdisco::Worker::Status';
 
 use Try::Tiny;
 use Role::Tiny;
@@ -9,7 +10,44 @@ use namespace::clean;
 
 # mixin code to run workers loaded via plugins
 sub run {
-  return App::Netdisco::Worker::Status->new({done => true, message => 'ok'});
+  my ($self, $job) = @_;
+  die 'bad job to run()' unless ref $job eq 'App::Netdisco::Backend::Job';
+
+  my $action = $job->action;
+  my @phase_hooks = @{ (setting('_nd2worker_hooks') || []) };
+
+  # run 00init primary
+  my $status = _run_first("nd2worker_${action}_00init_primary", $job);
+  return $status if $status->not_ok;
+
+  # run each 00init worker
+  _run_all("nd2worker_${action}_00init", $job);
+
+  # run primary
+  _run_first($_.'_primary', $job)
+    for (grep { m/^nd2worker_${action}_/ } @phase_hooks);
+
+  # run each worker
+  _run_all($_, $job)
+    for (grep { m/^nd2worker_${action}_/ } @phase_hooks);
+
+  return true;
+}
+
+sub _run_first {
+  my $hook = shift or return Status->error('missing hook param');
+  my $job  = shift or return Status->error('missing job param');
+
+  my $store = Dancer::Factory::Hook->instance();
+  $store->hook_is_registered($hook)
+    or return Status->error("no such hook: $hook");
+
+  foreach my $worker (@{ $store->get_hooks_for($hook) }) {
+    my $status = $worker->($job);
+    return $status if $status->ok;
+  }
+
+  return Status->error('no worker was successful');
 }
 
 true;
diff --git a/lib/App/Netdisco/Worker/Plugin.pm b/lib/App/Netdisco/Worker/Plugin.pm
index 49409894..75ce45fc 100644
--- a/lib/App/Netdisco/Worker/Plugin.pm
+++ b/lib/App/Netdisco/Worker/Plugin.pm
@@ -67,15 +67,16 @@ register 'register_worker' => sub {
 
   my $primary = ($workerconf->{primary} ? '_primary' : '');
   my $hook = 'nd2worker_'. $action .'_'. $phase . $primary;
+  my $store = Dancer::Factory::Hook->instance();
 
-  if (not Dancer::Factory::Hook->instance->hook_is_registered($hook)) {
-    Dancer::Factory::Hook->instance->install_hooks($hook);
+  if (not $store->hook_is_registered($hook)) {
+    $store->install_hooks($hook);
     # track just the basic phase names which are used
     push @{ setting('_nd2worker_hooks') }, $hook
       if $phase ne '00init' and 0 == length($primary);
   }
 
-  Dancer::Factory::Hook->instance->register_hook($hook, $worker);
+  $store->register_hook($hook, $worker);
 };
 
 register_plugin;
diff --git a/lib/App/Netdisco/Worker/Status.pm b/lib/App/Netdisco/Worker/Status.pm
index 495bf900..335d9aaf 100644
--- a/lib/App/Netdisco/Worker/Status.pm
+++ b/lib/App/Netdisco/Worker/Status.pm
@@ -25,6 +25,16 @@ has 'log' => (
 
 =head1 METHODS
 
+=head2 done, error, defer
+
+Shorthand for new() with setting param, accepts log as arg.
+
+=cut
+
+sub done  { return (shift)->new({done  => 1, log => shift}) }
+sub error { return (shift)->new({error => 1, log => shift}) }
+sub defer { return (shift)->new({defer => 1, log => shift}) }
+
 =head2 ok
 
 Returns true if C<done> is true and C<error> and C<defer> have not been set.