Added dataset import

Author: mikoweb

composer.json

@@ -16,6 +16,7 @@
         "symfony/flex": "^2",
         "symfony/framework-bundle": "7.1.*",
         "symfony/runtime": "7.1.*",
+        "symfony/validator": "7.1.*",
         "symfony/yaml": "7.1.*"
     },
     "require-dev": {

composer.lock

@@ -0,0 +1,11 @@
+framework:
+    validation:
+        # Enables validator auto-mapping support.
+        # For instance, basic validation constraints will be inferred from Doctrine's metadata.
+        #auto_mapping:
+        #    App\Entity\: []
+
+when@test:
+    framework:
+        validation:
+            not_compromised_password: false

config/packages/validator.yaml

@@ -0,0 +1,27 @@
+<?php
+
+namespace App\Domain;
+
+use Symfony\Component\Validator\Constraints as Assert;
+
+readonly class PowerStation
+{
+    public function __construct(
+        #[Assert\Range(min: -98.6, max: 56.7)]
+        public float $temperature,
+
+        #[Assert\GreaterThan(value: 0)]
+        public float $fumes,
+
+        #[Assert\Range(min: 870, max: 1084)]
+        public float $pressure,
+
+        #[Assert\GreaterThan(value: 0)]
+        #[Assert\LessThanOrEqual(value: 100)]
+        public float $humidity,
+
+        #[Assert\GreaterThan(value: 0)]
+        public float $power,
+    ) {
+    }
+}

src/Domain/PowerStation.php

@@ -0,0 +1,67 @@
+<?php
+
+namespace App\Infrastructure\Reader;
+
+use App\Application\Cache\DatasetCacheInterface;
+use App\Application\Path\AppPathResolver;
+use App\Domain\PowerStation;
+use Doctrine\Common\Collections\ArrayCollection;
+use League\Csv\Reader;
+use Symfony\Component\Validator\Validator\ValidatorInterface;
+
+readonly class PowerStationDatasetReader
+{
+    public function __construct(
+        private AppPathResolver $appPathResolver,
+        private DatasetCacheInterface $datasetCache,
+        private ValidatorInterface $validator,
+    ) {
+    }
+
+    /**
+     * @return ArrayCollection<string, ArrayCollection<int, PowerStation>>
+     */
+    public function read(): ArrayCollection
+    {
+        return $this->datasetCache->get(
+            sprintf('%s_dataset', self::class),
+            function () {
+                $dataset = new ArrayCollection();
+                $valid = new ArrayCollection();
+                $invalid = new ArrayCollection();
+                $dataset->set('valid', $valid);
+                $dataset->set('invalid', $invalid);
+
+                $data = Reader::createFromPath($this->appPathResolver->getResourcesPath('elektrownia.csv'));
+                $data->setHeaderOffset(0);
+
+                foreach ($data as $row) {
+                    $powerStation = $this->createPowerStation($row);
+                    $errors = $this->validator->validate($powerStation);
+
+                    if ($errors->count() === 0) {
+                        $valid->add($powerStation);
+                    } else {
+                        $invalid->add($powerStation);
+                    }
+                }
+
+                return $dataset;
+            }
+        );
+    }
+
+    /**
+     * @param array<string, string> $data
+     */
+    private function createPowerStation(array $data): PowerStation
+    {
+        return new PowerStation(
+            temperature: round((float) ($data['Temperatura'] ?? 0.0), 2),
+            fumes: round((float) ($data['Spaliny'] ?? 0.0), 2),
+            pressure: round((float) ($data['Ciśnienie'] ?? 0.0), 2),
+            humidity: round((float) ($data['Wilgotność'] ?? 0.0), 2),
+            power: round((float) ($data['Moc'] ?? 0.0), 2),
+        );
+    }
+}

src/Infrastructure/Reader/PowerStationDatasetReader.php

@@ -0,0 +1,56 @@
+<?php
+
+namespace App\UI\CLI;
+
+use App\Infrastructure\Reader\PowerStationDatasetReader;
+use Symfony\Component\Console\Attribute\AsCommand;
+use Symfony\Component\Console\Command\Command;
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Output\OutputInterface;
+use Symfony\Component\Console\Style\SymfonyStyle;
+use Symfony\Component\Validator\Validator\ValidatorInterface;
+
+#[AsCommand(
+    name: 'app:solve-task',
+)]
+class SolveTaskCommand extends Command
+{
+    public function __construct(
+        private readonly PowerStationDatasetReader $datasetReader,
+        private readonly ValidatorInterface $validator,
+    ) {
+        parent::__construct();
+    }
+
+    protected function execute(InputInterface $input, OutputInterface $output): int
+    {
+        $io = new SymfonyStyle($input, $output);
+
+        $io->info('Dataset reading...');
+        $dataset = $this->datasetReader->read();
+
+        $io->block([
+            sprintf('Valid rows: %d', $dataset->get('valid')->count()),
+            sprintf('Invalid rows: %d', $dataset->get('invalid')->count()),
+        ]);
+
+        if (!$dataset->get('invalid')->isEmpty()) {
+            foreach ($dataset->get('invalid') as $invalid) {
+                $firstError = $this->validator->validate($invalid)->get(0);
+
+                $io->warning(sprintf(
+                    'Invalid %s: %f - %s',
+                    $firstError->getPropertyPath(),
+                    $invalid->{$firstError->getPropertyPath()},
+                    $firstError->getMessage(),
+                ));
+            }
+        }
+
+        // TODO rest of task
+
+        $io->success('OK');
+
+        return Command::SUCCESS;
+    }
+}

src/UI/CLI/SolveTaskCommand.php

@@ -100,5 +100,17 @@
             "config/packages/routing.yaml",
             "config/routes.yaml"
         ]
+    },
+    "symfony/validator": {
+        "version": "7.1",
+        "recipe": {
+            "repo": "github.com/symfony/recipes",
+            "branch": "main",
+            "version": "7.0",
+            "ref": "8c1c4e28d26a124b0bb273f537ca8ce443472bfd"
+        },
+        "files": [
+            "config/packages/validator.yaml"
+        ]
     }
 }