#155 Implement InputFileReaderTask, InputLineReaderTask and LineReaderTask

Author: njoubert-cleverage

src/Task/File/InputFileReaderTask.php

@@ -0,0 +1,31 @@
+<?php
+
+declare(strict_types=1);
+
+namespace CleverAge\ProcessBundle\Task\File;
+
+use CleverAge\ProcessBundle\Model\AbstractConfigurableTask;
+use CleverAge\ProcessBundle\Model\ProcessState;
+use Symfony\Component\OptionsResolver\OptionsResolver;
+
+/**
+ * Reads the whole input file and outputs its content.
+ */
+class InputFileReaderTask extends FileReaderTask
+{
+    protected function getOptions(ProcessState $state): array
+    {
+        $options = parent::getOptions($state);
+        if (null !== $state->getInput()) {
+            $options['filename'] = $state->getInput();
+        }
+
+        return $options;
+    }
+
+    protected function configureOptions(OptionsResolver $resolver): void
+    {
+        parent::configureOptions($resolver);
+        $resolver->remove('filename');
+    }
+}

src/Task/File/InputLineReaderTask.php

@@ -0,0 +1,32 @@
+<?php
+
+declare(strict_types=1);
+
+namespace CleverAge\ProcessBundle\Task\File;
+
+use CleverAge\ProcessBundle\Model\AbstractConfigurableTask;
+use CleverAge\ProcessBundle\Model\IterableTaskInterface;
+use CleverAge\ProcessBundle\Model\ProcessState;
+use Symfony\Component\OptionsResolver\OptionsResolver;
+
+/**
+ * Reads an input file line by line and outputs each line.
+ */
+class InputLineReaderTask extends LineReaderTask
+{
+    protected function getOptions(ProcessState $state): array
+    {
+        $options = parent::getOptions($state);
+        if (null !== $state->getInput()) {
+            $options['filename'] = $state->getInput();
+        }
+
+        return $options;
+    }
+
+    protected function configureOptions(OptionsResolver $resolver): void
+    {
+        parent::configureOptions($resolver);
+        $resolver->remove('filename');
+    }
+}

src/Task/File/LineReaderTask.php

@@ -0,0 +1,62 @@
+<?php
+
+declare(strict_types=1);
+
+namespace CleverAge\ProcessBundle\Task\File;
+
+use CleverAge\ProcessBundle\Filesystem\CsvFile;
+use CleverAge\ProcessBundle\Model\AbstractConfigurableTask;
+use CleverAge\ProcessBundle\Model\IterableTaskInterface;
+use CleverAge\ProcessBundle\Model\ProcessState;
+use Symfony\Component\OptionsResolver\OptionsResolver;
+
+/**
+ * Reads a file line by line and outputs each line.
+ */
+class LineReaderTask extends AbstractConfigurableTask implements IterableTaskInterface
+{
+    protected ?\SplFileObject $file = null;
+
+    public function execute(ProcessState $state): void
+    {
+        $options = $this->getOptions($state);
+        $filename = $options['filename'];
+
+        if ($this->file instanceof \SplFileObject
+            && $this->file->getPathname() !== $filename) {
+            $this->file = null;
+        }
+
+        if (!$this->file instanceof \SplFileObject) {
+            if (!file_exists($filename)) {
+                throw new \UnexpectedValueException("File does not exist: '{$filename}'");
+            }
+
+            if (!is_readable($filename)) {
+                throw new \UnexpectedValueException("File is not readable: '{$filename}'");
+            }
+
+            $this->file = new \SplFileObject($filename);
+            $this->file->setFlags(\SplFileObject::READ_AHEAD | \SplFileObject::SKIP_EMPTY);
+            $this->file->rewind();
+        }
+
+        $state->setOutput($this->file->current());
+        $this->file->next();
+    }
+
+    public function next(ProcessState $state): bool
+    {
+        if (!$this->file instanceof \SplFileObject) {
+            throw new \LogicException('No File initialized');
+        }
+
+        return !$this->file->eof();
+    }
+
+    protected function configureOptions(OptionsResolver $resolver): void
+    {
+        $resolver->setRequired(['filename']);
+        $resolver->setAllowedTypes('filename', ['string']);
+    }
+}