Added: Datahub::Factory::FixFileNotFound error.

Author: netsensei

Changes

@@ -2,6 +2,7 @@ Revision history for Datahub-Factory
 
 {{$NEXT}}
 
+    - Added: Datahub::Factory::FixFileNotFound error.
     - Added: Datahub::Factory::InvalidCondition error.
     - Fixed: fixes #62 fixer Fix throws an error file_name is undefined
     - Added: fixes #61 break after finite number of records in transport.

lib/Datahub/Factory/Command/transport.pm

@@ -150,6 +150,12 @@ sub execute {
                 $logger->fatal($error);
                 exit 1;
             }
+            elsif (is_instance $_, 'Datahub::Factory::FixFileNotFound') {
+                # Throw a fatal error if the pipeline configuration was invalid
+                $self->error($msg);
+                $logger->fatal($error);
+                exit 1;
+            }
             elsif (is_instance $_, 'Datahub::Factory::ModuleNotFound') {
                 # Throw a fatal error if we couldn't load a fix module
                 $logger->fatal($error);

lib/Datahub/Factory/Error.pm

@@ -43,6 +43,15 @@ use namespace::clean;
 
 extends 'Datahub::Factory::Error';
 
+package Datahub::Factory::FixFileNotFound;
+
+use Datahub::Factory::Sane;
+
+use Moo;
+use namespace::clean;
+
+extends 'Datahub::Factory::Error';
+
 package Datahub::Factory::ModuleNotFound;
 
 use Datahub::Factory::Sane;

lib/Datahub/Factory/Fixer/Fix.pm

@@ -6,6 +6,7 @@ our $VERSION = '1.73';
 
 use Moo;
 use Catmandu;
+use Datahub::Factory;
 use namespace::clean;
 
 has file_name     => (is => 'ro', required => 1, isa => sub {
@@ -14,6 +15,12 @@ has file_name     => (is => 'ro', required => 1, isa => sub {
             message => 'Required argument "file_name" undefined'
         );
     }
+
+    if (! -e $_[0]) {
+        Datahub::Factory::FixFileNotFound->throw(
+            message => sprintf('Fix file %s could not be found on the filesystem.', $_[0])
+        );
+    }
  });
 
 with 'Datahub::Factory::Fixer';