Catch CSV errorsv0.6.0

1 files changed, 11 insertions, 0 deletions

diff --git a/src/bdrem/Source/Csv.php b/src/bdrem/Source/Csv.php
index 62cf777..f1c4048 100644
--- a/src/bdrem/Source/Csv.php
+++ b/src/bdrem/Source/Csv.php
@@ -109,6 +109,7 @@ class Source_Csv
         }
 
         $first = true;
+        $arEvents = array();
         while (($row = fgetcsv($handle, 1000, $this->separator)) !== false) {
             if ($first && $this->firstLineIsHeader) {
                 $first = false;
@@ -118,9 +119,15 @@ class Source_Csv
             if ($this->columns['event'] === false) {
                 $eventType = $this->defaultEvent;
             } else {
+                if (!isset($row[$this->columns['event']])) {
+                    throw new \Exception('Event column does not exist in CSV');
+                }
                 $eventType = $row[$this->columns['event']];
             }
 
+            if (!isset($row[$this->columns['date']])) {
+                throw new \Exception('Date column does not exist in CSV');
+            }
             if ($row[$this->columns['date']] == '') {
                 continue;
             }
@@ -132,6 +139,10 @@ class Source_Csv
                 )
             );
 
+            if (!isset($row[$this->columns['name']])) {
+                throw new \Exception('Name column does not exist in CSV');
+            }
+
             $event = new Event(
                 (string) $row[$this->columns['name']],
                 $eventType,