Add filter and writer warning in step execution and update doExecute of

item step to allow to skip a line

Author: nidup

Entity/StepExecution.php

@@ -137,6 +137,20 @@ class StepExecution
      */
     private $readerWarnings = array();
 
+    /**
+     * @var array
+     *
+     * @ORM\Column(name="filter_warnings", type="array", nullable=true)
+     */
+    private $filterWarnings = array();
+
+    /**
+     * @var array
+     *
+     * @ORM\Column(name="writer_warnings", type="array", nullable=true)
+     */
+    private $writerWarnings = array();
+
     /**
      * Constructor with mandatory properties.
      *
@@ -310,6 +324,32 @@ public function incrementWriteCount()
         $this->writeCount++;
     }
 
+    /**
+     * Add a writer warning
+     *
+     * @param string $writer
+     * @param string $message
+     * @param mixed  $data
+     */
+    public function addWriterWarning($writer, $message, $data)
+    {
+        $this->writerWarnings[] = array(
+            'writer' => $writer,
+            'reason' => $message,
+            'data'   => $data,
+        );
+    }
+
+    /**
+     * Get the writer warnings
+     *
+     * @return array[]
+     */
+    public function getWriterWarnings()
+    {
+        return $this->writerWarnings;
+    }
+
     /**
      * Returns the current number of items filtered out of this execution
      *
@@ -320,6 +360,32 @@ public function getFilterCount()
         return $this->readCount - $this->writeCount;
     }
 
+    /**
+     * Add a filter warning
+     *
+     * @param string $filter
+     * @param string $message
+     * @param mixed  $data
+     */
+    public function addFilterWarning($filter, $message, $data)
+    {
+        $this->filterWarnings[] = array(
+            'filter' => $filter,
+            'reason' => $message,
+            'data'   => $data,
+        );
+    }
+
+    /**
+     * Get the filter warnings
+     *
+     * @return array[]
+     */
+    public function getFilterWarnings()
+    {
+        return $this->filterWarnings;
+    }
+
     /**
      * @return flag to indicate that an execution should halt
      */

Step/ItemStep.php

@@ -173,6 +173,9 @@ public function doExecute(StepExecution $stepExecution)
             }
 
             if (null !== $processedItem = $this->processor->process($item)) {
+                if (false === $processedItem) {
+                    continue;
+                }
                 $itemsToWrite[] = $processedItem;
                 $writeCount++;
                 if (0 === $writeCount % $this->batchSize) {