Added resource type parameter to Provider::getConnector

src/Collection/RecordCollection.php

@@ -10,7 +10,7 @@ abstract class RecordCollection implements \Iterator
 
     private $previousCollection;
 
-    public function __construct(\Iterator $records, RecordCollection $previousCollection = null)
+    public function __construct(\Iterator $records, self $previousCollection = null)
     {
         $this->records = $records;
         $this->previousCollection = $previousCollection;

src/Connector/CachingConnector.php

@@ -39,6 +39,7 @@ public function __construct(
     }
 
     /**
+     * @param ConnectionContext $context
      * @param string $source
      * @param EncapsulatedOptions|null $options
      *

src/Porter.php

@@ -110,7 +110,7 @@ private function fetch(ProviderResource $resource, $providerName, ConnectionCont
         }
 
         $records = $resource->fetch(
-            new ImportConnector($provider->getConnector(), $context),
+            new ImportConnector($provider->getConnector(get_class($resource)), $context),
             $provider instanceof ProviderOptions ? clone $provider->getOptions() : null
         );
 

src/Provider/Provider.php

@@ -4,14 +4,16 @@
 use ScriptFUSION\Porter\Connector\Connector;
 
 /**
- * Provides a method for accessing a connector.
+ * Provides a method for getting a connector.
  */
 interface Provider
 {
     /**
-     * Gets a connector for accessing resource data.
+     * Gets a connector for fetching resource data.
+     *
+     * @param string $resourceType The resource type from which data will be fetched.
      *
      * @return Connector
      */
-    public function getConnector();
+    public function getConnector($resourceType);
 }

src/Provider/StaticDataProvider.php

@@ -12,7 +12,7 @@ public function __construct()
         $this->connector = new NullConnector;
     }
 
-    public function getConnector()
+    public function getConnector($resourceType)
     {
         return $this->connector;
     }

test/Integration/Porter/PorterTest.php

@@ -68,7 +68,7 @@ protected function setUp()
         $this->porter = new Porter($this->container = \Mockery::spy(ContainerInterface::class));
 
         $this->registerProvider($this->provider = MockFactory::mockProvider());
-        $this->connector = $this->provider->getConnector();
+        $this->connector = $this->provider->getConnector('');
         $this->resource = MockFactory::mockResource($this->provider);
         $this->specification = new ImportSpecification($this->resource);
     }

test/MockFactory.php

@@ -20,12 +20,13 @@ public static function mockProvider()
     {
         return \Mockery::namedMock(uniqid(Provider::class, false), Provider::class)
             ->shouldReceive('getConnector')
+                ->with(\Mockery::type('string'))
                 ->andReturn(
                     \Mockery::mock(Connector::class)
                         ->shouldReceive('fetch')
                         ->andReturn('foo')
-                        ->getMock()
                         ->byDefault()
+                        ->getMock()
                 )
             ->getMock()
         ;