Switch to monorepo

Author: yann-eugone

LICENSE

@@ -0,0 +1,19 @@
+Copyright (c) 2019 Yann Eugoné
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is furnished
+to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
+THE SOFTWARE.

README.md

@@ -0,0 +1,23 @@
+# Yokai Batch
+
+[![Latest Stable Version](https://img.shields.io/packagist/v/yokai/batch-symfony-validator?style=flat-square)](https://packagist.org/packages/yokai/batch-symfony-validator)
+[![Downloads Monthly](https://img.shields.io/packagist/dm/yokai/batch-symfony-validator?style=flat-square)](https://packagist.org/packages/yokai/batch-symfony-validator)
+
+Bridge of [`symfony/validator`](https://github.com/symfony/validator) for [Batch](https://github.com/yokai-php/batch-src).
+
+
+## Documentation
+
+Please refer to [main repository](https://github.com/yokai-php/batch-src) documentation.
+
+
+## Contribution
+
+Please feel free to open an [issue](https://github.com/yokai-php/batch-src/issues)
+or a [pull request](https://github.com/yokai-php/batch-src/pulls)
+in the [main repository](https://github.com/yokai-php/batch-src).
+
+
+## MIT License
+
+License can be found [here](LICENSE).

composer.json

@@ -0,0 +1,21 @@
+{
+  "name": "yokai/batch-symfony-validator",
+  "description": "Bridge of symfony/validator for yokai/batch",
+  "type": "library",
+  "license": "MIT",
+  "authors": [
+    {
+      "name": "Yann Eugoné",
+      "email": "eugone.yann@gmail.com"
+    }
+  ],
+  "require": {
+    "php": "^7.2",
+    "symfony/validator": "^4.4"
+  },
+  "autoload": {
+    "psr-4": {
+      "Yokai\\Batch\\Bridge\\Symfony\\Validator\\": "src/"
+    }
+  }
+}

src/SkipInvalidItemProcessor.php

@@ -0,0 +1,95 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Yokai\Batch\Bridge\Symfony\Validator;
+
+use DateTimeInterface;
+use Symfony\Component\Validator\ConstraintViolationInterface;
+use Symfony\Component\Validator\Validator\ValidatorInterface;
+use Yokai\Batch\Job\Item\InvalidItemException;
+use Yokai\Batch\Job\Item\ItemProcessorInterface;
+
+final class SkipInvalidItemProcessor implements ItemProcessorInterface
+{
+    /**
+     * @var ValidatorInterface
+     */
+    private $validator;
+
+    /**
+     * @var array|null
+     */
+    private $groups;
+
+    public function __construct(ValidatorInterface $validator, array $groups = null)
+    {
+        $this->validator = $validator;
+        $this->groups = $groups;
+    }
+
+    /**
+     * @inheritDoc
+     */
+    public function process($item)
+    {
+        $violations = $this->validator->validate($item, null, $this->groups);
+        if (count($violations) === 0) {
+            return $item;
+        }
+
+        $issues = [];
+        /** @var ConstraintViolationInterface $violation */
+        foreach ($violations as $violation) {
+            $issues[] = sprintf(
+                '%s: %s: %s',
+                $violation->getPropertyPath(),
+                $violation->getMessage(),
+                $this->normalizeInvalidValue($violation->getInvalidValue())
+            );
+        }
+
+        throw new InvalidItemException(implode(PHP_EOL, $issues));
+    }
+
+    /**
+     * @param mixed $invalidValue
+     *
+     * @return integer|float|string|boolean
+     */
+    private function normalizeInvalidValue($invalidValue)
+    {
+        if ($invalidValue === '') {
+            return '""';
+        }
+        if ($invalidValue === null) {
+            return 'NULL';
+        }
+        if (is_scalar($invalidValue)) {
+            return $invalidValue;
+        }
+
+        if (is_iterable($invalidValue)) {
+            $invalidValues = [];
+            foreach ($invalidValue as $value) {
+                $invalidValues[] = $this->normalizeInvalidValue($value);
+            }
+
+            return implode(', ', $invalidValues);
+        }
+
+        if (is_object($invalidValue)) {
+            if ($invalidValue instanceof DateTimeInterface) {
+                return $invalidValue->format(DateTimeInterface::ISO8601);
+            }
+
+            if (method_exists($invalidValue, '__toString')) {
+                return (string)$invalidValue;
+            }
+
+            return sprintf('%s:%s', get_class($invalidValue), spl_object_hash($invalidValue));
+        }
+
+        return gettype($invalidValue);
+    }
+}