Merge da0c1b0 into acb218b

README.md

@@ -2,4 +2,8 @@
 
 [![Build Status](https://travis-ci.org/courtney-miles/slurp.svg?branch=master)](https://travis-ci.org/courtney-miles/slurp) [![Coverage Status](https://coveralls.io/repos/github/courtney-miles/slurp/badge.svg?branch=master)](https://coveralls.io/github/courtney-miles/slurp?branch=master)
 
-Slurp is a simple PHP ETL (extract, transform, load) tool that can validate prior to loading source data
+Slurp is a simple PHP ETL (extract, transform, load) tool that can validate prior to loading source data.
+
+## Known limitations
+
+* A CSV file with an inconsistent number of values per row will be silently handled, where it would be preferable to raise an exception.

composer.json

@@ -14,7 +14,8 @@
     "require": {
         "php": "7.1 - 7.2",
         "symfony/validator": "^4.1.0",
-        "ext-PDO": "*"
+        "ext-PDO": "*",
+        "league/csv": "^9.0"
     },
     "require-dev": {
         "phpunit/phpunit": "^6",

src/Extract/CsvFileExtractor/CsvFileExtractor.php

@@ -0,0 +1,45 @@
+<?php
+/**
+ * Author: Courtney Miles
+ * Date: 15/08/18
+ * Time: 7:08 PM
+ */
+
+namespace MilesAsylum\Slurp\Extract\CsvFileExtractor;
+
+use League\Csv\Reader;
+use MilesAsylum\Slurp\Extract\ExtractorInterface;
+
+class CsvFileExtractor implements ExtractorInterface
+{
+    /**
+     * @var Reader
+     */
+    private $csvReader;
+
+    private $headers = [];
+
+    public function __construct(Reader $csvReader)
+    {
+        $this->csvReader = $csvReader;
+    }
+
+    /**
+     * Loads the first row in the CSV file as the headers.
+     * @throws \League\Csv\Exception
+     */
+    public function loadHeadersFromFile() : void
+    {
+        $this->csvReader->setHeaderOffset(0);
+    }
+
+    public function setHeaders(array $headers) : void
+    {
+        $this->headers = $headers;
+    }
+
+    public function getIterator() : \Iterator
+    {
+        return $this->csvReader->getRecords($this->headers);
+    }
+}

src/Extract/ExtractorInterface.php

@@ -8,6 +8,6 @@
 namespace MilesAsylum\Slurp\Extract;
 
 
-interface ExtractorInterface extends \Iterator
+interface ExtractorInterface extends \IteratorAggregate
 {
 }