Added Transformer support to Porter::import and ImportSpecification.

Added Transformer interface. Refactored filter code into FilterTransformer. Removed filters and mappings from Porter and ImportSpecification. Updated tests.
ScriptFUSION · Dec 18, 2016 · ca03a92 · ca03a92
1 parent ac2ffb6
commit ca03a92
Show file tree

Hide file tree

Showing 16 changed files with 180 additions and 460 deletions.
diff --git a/.travis.yml b/.travis.yml
@@ -19,11 +19,6 @@ install:
 script:
   - bin/test --coverage-clover=build/logs/clover.xml
 
-  # Remove mapper and run all non-Mapper tests again.
-  - composer --dev --no-update-with-dependencies remove scriptfusion/mapper
-  - '! composer info | grep ^scriptfusion/mapper\\b'
-  - bin/test --exclude-group Mapper
-
 after_success:
   - composer --prefer-source require satooshi/php-coveralls
   - vendor/bin/coveralls -v
diff --git a/src/Collection/CountableMappedRecords.php b/src/Collection/CountableMappedRecords.php
diff --git a/src/Collection/MappedRecords.php b/src/Collection/MappedRecords.php
diff --git a/src/Mapper/PorterMapper.php b/src/Mapper/PorterMapper.php
diff --git a/src/Mapper/Strategy/InvalidCallbackResultException.php b/src/Mapper/Strategy/InvalidCallbackResultException.php
diff --git a/src/Mapper/Strategy/SubImport.php b/src/Mapper/Strategy/SubImport.php
diff --git a/src/Porter.php b/src/Porter.php
@@ -1,21 +1,15 @@
 <?php
 namespace ScriptFUSION\Porter;
 
-use ScriptFUSION\Mapper\CollectionMapper;
-use ScriptFUSION\Mapper\Mapping;
 use ScriptFUSION\Porter\Cache\CacheAdvice;
 use ScriptFUSION\Porter\Cache\CacheToggle;
 use ScriptFUSION\Porter\Cache\CacheUnavailableException;
-use ScriptFUSION\Porter\Collection\CountableMappedRecords;
 use ScriptFUSION\Porter\Collection\CountablePorterRecords;
 use ScriptFUSION\Porter\Collection\CountableProviderRecords;
-use ScriptFUSION\Porter\Collection\FilteredRecords;
-use ScriptFUSION\Porter\Collection\MappedRecords;
 use ScriptFUSION\Porter\Collection\PorterRecords;
 use ScriptFUSION\Porter\Collection\ProviderRecords;
 use ScriptFUSION\Porter\Collection\RecordCollection;
 use ScriptFUSION\Porter\Connector\RecoverableConnectorException;
-use ScriptFUSION\Porter\Mapper\PorterMapper;
 use ScriptFUSION\Porter\Provider\ObjectNotCreatedException;
 use ScriptFUSION\Porter\Provider\Provider;
 use ScriptFUSION\Porter\Provider\ProviderFactory;
@@ -40,11 +34,6 @@ class Porter
      */
     private $providerFactory;
 
-    /**
-     * @var CollectionMapper
-     */
-    private $mapper;
-
     /**
      * @var CacheAdvice
      */
@@ -63,7 +52,6 @@ class Porter
     public function __construct()
     {
         $this->defaultCacheAdvice = CacheAdvice::SHOULD_NOT_CACHE();
-        $this->fetchExceptionHandler = new ExponentialBackoffExceptionHandler;
     }
 
     /**
@@ -84,12 +72,12 @@ public function import(ImportSpecification $specification)
             $records = $this->createProviderRecords($records, $specification->getResource());
         }
 
-        if ($specification->getFilter()) {
-            $records = $this->filter($records, $specification->getFilter(), $specification->getContext());
-        }
+        foreach ($specification->getTransformers() as $transformer) {
+            if ($transformer instanceof PorterAware) {
+                $transformer->setPorter($this);
+            }
 
-        if ($specification->getMapping()) {
-            $records = $this->map($records, $specification->getMapping(), $specification->getContext());
+            $records = $transformer->transform($records, $specification->getContext());
         }
 
         return $this->createPorterRecords($records, $specification);
@@ -164,37 +152,6 @@ function (\Exception $exception) {
         throw new ImportException(get_class($provider) . '::fetch() did not return an Iterator.');
     }
 
-    private function filter(ProviderRecords $records, callable $predicate, $context)
-    {
-        $filter = function () use ($records, $predicate, $context) {
-            foreach ($records as $record) {
-                if ($predicate($record, $context)) {
-                    yield $record;
-                }
-            }
-        };
-
-        return new FilteredRecords($filter(), $records, $filter);
-    }
-
-    private function map(RecordCollection $records, Mapping $mapping, $context)
-    {
-        return $this->createMappedRecords(
-            $this->getOrCreateMapper()->mapCollection($records, $mapping, $context),
-            $records,
-            $mapping
-        );
-    }
-
-    private function createMappedRecords(\Iterator $records, RecordCollection $previous, Mapping $mapping)
-    {
-        if ($previous instanceof \Countable) {
-            return new CountableMappedRecords($records, count($previous), $previous, $mapping);
-        }
-
-        return new MappedRecords($records, $previous, $mapping);
-    }
-
     private function applyCacheAdvice(Provider $provider, CacheAdvice $cacheAdvice)
     {
         try {
@@ -304,26 +261,6 @@ private function getOrCreateProviderFactory()
         return $this->providerFactory ?: $this->providerFactory = new ProviderFactory;
     }
 
-    /**
-     * @return CollectionMapper
-     */
-    private function getOrCreateMapper()
-    {
-        return $this->mapper ?: $this->mapper = new PorterMapper($this);
-    }
-
-    /**
-     * @param CollectionMapper $mapper
-     *
-     * @return $this
-     */
-    public function setMapper(CollectionMapper $mapper)
-    {
-        $this->mapper = $mapper;
-
-        return $this;
-    }
-
     /**
      * Gets the maximum number of fetch attempts per import.
      *
@@ -353,7 +290,7 @@ public function setMaxFetchAttempts($attempts)
      */
     private function getFetchExceptionHandler()
     {
-        return $this->fetchExceptionHandler;
+        return $this->fetchExceptionHandler ?: $this->fetchExceptionHandler = new ExponentialBackoffExceptionHandler;
     }
 
     /**

diff --git a/src/Specification/DuplicateTransformerException.php b/src/Specification/DuplicateTransformerException.php
@@ -0,0 +1,10 @@
+<?php
+namespace ScriptFUSION\Porter\Specification;
+
+/**
+ * The exception that is thrown when a transformer already exists at the target site.
+ */
+class DuplicateTransformerException extends \RuntimeException
+{
+    // Intentionally empty.
+}