Allow new processors to be passed through configuration. (#11)

Author: fmizzell

src/FileFetcher.php

@@ -27,9 +27,9 @@ protected function __construct(string $identifier, $storage, array $config = nul
     {
         parent::__construct($identifier, $storage, $config);
 
-        $config = $this->validateConfig($config);
+        $this->setProcessors($config);
 
-        $this->processors = self::getProcessors();
+        $config = $this->validateConfig($config);
 
         // [State]
 
@@ -134,4 +134,38 @@ private function validateConfig($config): array
         }
         return $config;
     }
+
+    private function setProcessors($config)
+    {
+        $this->processors = self::getProcessors();
+
+        if (!isset($config['processors'])) {
+            return;
+        }
+
+        if (!is_array($config['processors'])) {
+            return;
+        }
+
+        foreach ($config['processors'] as $processorClass) {
+            $this->setProcessor($processorClass);
+        }
+
+        $this->processors = array_merge($this->processors, self::getProcessors());
+    }
+
+    private function setProcessor($processorClass)
+    {
+        if (!class_exists($processorClass)) {
+            return;
+        }
+
+        $classes = class_implements($processorClass);
+        if (!in_array(ProcessorInterface::class, $classes)) {
+            return;
+        }
+
+        $instance = new $processorClass();
+        $this->processors = array_merge([$processorClass => $instance], $this->processors);
+    }
 }

test/FileFetcherTest.php

@@ -4,6 +4,8 @@
 
 use Contracts\Mock\Storage\Memory;
 use FileFetcher\FileFetcher;
+use FileFetcher\Processor\Local;
+use PHPUnit\Framework\TestCase;
 use Procrastinator\Result;
 
 class FileFetcherTest extends \PHPUnit\Framework\TestCase
@@ -18,7 +20,8 @@ public function testRemote()
             "1",
             new Memory(),
             [
-            "filePath" => "http://samplecsvs.s3.amazonaws.com/Sacramentorealestatetransactions.csv"
+              "filePath" => "http://samplecsvs.s3.amazonaws.com/Sacramentorealestatetransactions.csv",
+              "processors" => [Local::class]
             ]
         );
 
@@ -36,12 +39,15 @@ public function testLocal()
     {
         $local_file = __DIR__ . "/files/tiny.csv";
 
+        $config = [
+          "filePath" => $local_file,
+          "processors" => [TestCase::class]
+        ];
+
         $fetcher = FileFetcher::get(
             "1",
             new Memory(),
-            [
-            "filePath" => $local_file
-            ]
+            $config
         );
 
         $fetcher->setTimeLimit(1);
@@ -64,7 +70,8 @@ public function testTimeOut()
     {
         $store = new Memory();
         $config = [
-          "filePath" => "https://dkan-default-content-files.s3.amazonaws.com/{$this->sampleCsvSize}_mb_sample.csv"
+          "filePath" => "https://dkan-default-content-files.s3.amazonaws.com/{$this->sampleCsvSize}_mb_sample.csv",
+          "processors" => "Bad"
         ];
 
         $fetcher = FileFetcher::get("1", $store, $config);
@@ -102,7 +109,8 @@ public function testIncompatibleServer()
             "1",
             new Memory(),
             [
-            "filePath" => $url
+              "filePath" => $url,
+              "processors" => ["Bad"]
             ]
         );
         $fetcher->setTimeLimit(1);