1414use ScriptFUSION \Porter \Collection \ProviderRecords ;
1515use ScriptFUSION \Porter \Collection \RecordCollection ;
1616use ScriptFUSION \Porter \Mapper \PorterMapper ;
17- use ScriptFUSION \Porter \Provider \DataSource \ProviderDataSource ;
1817use ScriptFUSION \Porter \Provider \ObjectNotCreatedException ;
1918use ScriptFUSION \Porter \Provider \Provider ;
2019use ScriptFUSION \Porter \Provider \ProviderFactory ;
20+ use ScriptFUSION \Porter \Provider \Resource \ProviderResource ;
2121use ScriptFUSION \Porter \Specification \ImportSpecification ;
2222
2323class Porter
@@ -44,11 +44,11 @@ public function __construct()
4444 */
4545 public function import (ImportSpecification $ specification )
4646 {
47- $ records = $ this ->fetch ($ specification ->getDataSource (), $ specification ->getCacheAdvice ());
47+ $ records = $ this ->fetch ($ specification ->getResource (), $ specification ->getCacheAdvice ());
4848
4949 if (!$ records instanceof ProviderRecords) {
5050 // Wrap Iterator in ProviderRecords.
51- $ records = new ProviderRecords ($ records , $ specification ->getDataSource ());
51+ $ records = new ProviderRecords ($ records , $ specification ->getResource ());
5252 }
5353
5454 if ($ specification ->getFilter ()) {
@@ -71,12 +71,12 @@ private function createPorterRecords(RecordCollection $records, ImportSpecificat
7171 return new PorterRecords ($ records , $ specification );
7272 }
7373
74- private function fetch (ProviderDataSource $ dataSource , CacheAdvice $ cacheAdvice = null )
74+ private function fetch (ProviderResource $ resource , CacheAdvice $ cacheAdvice = null )
7575 {
76- $ provider = $ this ->getProvider ($ dataSource ->getProviderClassName (), $ dataSource ->getProviderTag ());
76+ $ provider = $ this ->getProvider ($ resource ->getProviderClassName (), $ resource ->getProviderTag ());
7777 $ this ->applyCacheAdvice ($ provider , $ cacheAdvice ?: $ this ->defaultCacheAdvice );
7878
79- return $ provider ->fetch ($ dataSource );
79+ return $ provider ->fetch ($ resource );
8080 }
8181
8282 private function filter (ProviderRecords $ records , callable $ predicate , $ context )
0 commit comments