platine-php / etl

src/EtlTool.php

Braces +1 added lines, -2 removed lines

@@ -47,8 +47,7 @@
  * @class EtlTool
  * @package Platine\Etl
  */
-class EtlTool
-{
+class EtlTool {
     /**
      * @var callable|null
      */

Spacing +19 added lines, -19 removed lines

@@ -102,9 +102,9 @@ 
      * @param DispatcherInterface|null $dispatcher
      */
     public function __construct(
-        ExtractorInterface|callable|null $extractor = null,
-        TransformerInterface|callable|null $transformer = null,
-        LoaderInterface|callable|null $loader = null,
+        ExtractorInterface | callable | null $extractor = null,
+        TransformerInterface | callable | null $transformer = null,
+        LoaderInterface | callable | null $loader = null,
         ?DispatcherInterface $dispatcher = null
     ) {
         if ($extractor !== null) {
@@ -126,7 +126,7 @@ 
      * @param ExtractorInterface|callable|null $extractor
      * @return $this
      */
-    public function extractor(ExtractorInterface|callable|null $extractor): self
+    public function extractor(ExtractorInterface | callable | null $extractor): self
     {
         if ($extractor instanceof ExtractorInterface) {
             $this->extractor = [$extractor, 'extract'];
@@ -145,7 +145,7 @@ 
      * @param TransformerInterface|callable|null $transformer
      * @return $this
      */
-    public function transformer(TransformerInterface|callable|null $transformer): self
+    public function transformer(TransformerInterface | callable | null $transformer): self
     {
         if ($transformer instanceof TransformerInterface) {
             $this->transformer = [$transformer, 'transform'];
@@ -163,7 +163,7 @@ 
      * @param LoaderInterface|callable $loader
      * @return $this
      */
-    public function loader(LoaderInterface|callable $loader): self
+    public function loader(LoaderInterface | callable $loader): self
     {
         if ($loader instanceof LoaderInterface) {
             $this->loader = [$loader, 'load'];
@@ -198,7 +198,7 @@ 
      * @return $this
      */
     public function onStart(
-        ListenerInterface|callable $listener,
+        ListenerInterface | callable $listener,
         int $priority = DispatcherInterface::PRIORITY_DEFAULT
     ): self {
         $this->dispatcher->addListener(BaseEvent::START, $listener, $priority);
@@ -214,7 +214,7 @@ 
      * @return $this
      */
     public function onExtract(
-        ListenerInterface|callable $listener,
+        ListenerInterface | callable $listener,
         int $priority = DispatcherInterface::PRIORITY_DEFAULT
     ): self {
         $this->dispatcher->addListener(BaseEvent::EXTRACT, $listener, $priority);
@@ -230,7 +230,7 @@ 
      * @return $this
      */
     public function onExtractException(
-        ListenerInterface|callable $listener,
+        ListenerInterface | callable $listener,
         int $priority = DispatcherInterface::PRIORITY_DEFAULT
     ): self {
         $this->dispatcher->addListener(BaseEvent::EXTRACT_EXCEPTION, $listener, $priority);
@@ -246,7 +246,7 @@ 
      * @return $this
      */
     public function onTransform(
-        ListenerInterface|callable $listener,
+        ListenerInterface | callable $listener,
         int $priority = DispatcherInterface::PRIORITY_DEFAULT
     ): self {
         $this->dispatcher->addListener(BaseEvent::TRANSFORM, $listener, $priority);
@@ -262,7 +262,7 @@ 
      * @return $this
      */
     public function onTransformException(
-        ListenerInterface|callable $listener,
+        ListenerInterface | callable $listener,
         int $priority = DispatcherInterface::PRIORITY_DEFAULT
     ): self {
         $this->dispatcher->addListener(BaseEvent::TRANSFORM_EXCEPTION, $listener, $priority);
@@ -278,7 +278,7 @@ 
      * @return $this
      */
     public function onLoaderInit(
-        ListenerInterface|callable $listener,
+        ListenerInterface | callable $listener,
         int $priority = DispatcherInterface::PRIORITY_DEFAULT
     ): self {
         $this->dispatcher->addListener(BaseEvent::LOADER_INIT, $listener, $priority);
@@ -294,7 +294,7 @@ 
      * @return $this
      */
     public function onLoad(
-        ListenerInterface|callable $listener,
+        ListenerInterface | callable $listener,
         int $priority = DispatcherInterface::PRIORITY_DEFAULT
     ): self {
         $this->dispatcher->addListener(BaseEvent::LOAD, $listener, $priority);
@@ -310,7 +310,7 @@ 
      * @return $this
      */
     public function onLoadException(
-        ListenerInterface|callable $listener,
+        ListenerInterface | callable $listener,
         int $priority = DispatcherInterface::PRIORITY_DEFAULT
     ): self {
         $this->dispatcher->addListener(BaseEvent::LOAD_EXCEPTION, $listener, $priority);
@@ -326,7 +326,7 @@ 
      * @return $this
      */
     public function onFlush(
-        ListenerInterface|callable $listener,
+        ListenerInterface | callable $listener,
         int $priority = DispatcherInterface::PRIORITY_DEFAULT
     ): self {
         $this->dispatcher->addListener(BaseEvent::FLUSH, $listener, $priority);
@@ -342,7 +342,7 @@ 
      * @return $this
      */
     public function onSkip(
-        ListenerInterface|callable $listener,
+        ListenerInterface | callable $listener,
         int $priority = DispatcherInterface::PRIORITY_DEFAULT
     ): self {
         $this->dispatcher->addListener(BaseEvent::SKIP, $listener, $priority);
@@ -358,7 +358,7 @@ 
      * @return $this
      */
     public function onStop(
-        ListenerInterface|callable $listener,
+        ListenerInterface | callable $listener,
         int $priority = DispatcherInterface::PRIORITY_DEFAULT
     ): self {
         $this->dispatcher->addListener(BaseEvent::STOP, $listener, $priority);
@@ -374,7 +374,7 @@ 
      * @return $this
      */
     public function onRollback(
-        ListenerInterface|callable $listener,
+        ListenerInterface | callable $listener,
         int $priority = DispatcherInterface::PRIORITY_DEFAULT
     ): self {
         $this->dispatcher->addListener(BaseEvent::ROLLBACK, $listener, $priority);
@@ -390,7 +390,7 @@ 
      * @return $this
      */
     public function onEnd(
-        ListenerInterface|callable $listener,
+        ListenerInterface | callable $listener,
         int $priority = DispatcherInterface::PRIORITY_DEFAULT
     ): self {
         $this->dispatcher->addListener(BaseEvent::END, $listener, $priority);

src/Loader/FileLoader.php

Indentation +2 added lines, -2 removed lines

@@ -70,8 +70,8 @@
     }
 
         /**
-     * {@inheritodc}
-     */
+         * {@inheritodc}
+         */
     public function init(array $options = []): void
     {
         if (isset($options['eol'])) {

Spacing +2 added lines, -2 removed lines

@@ -60,7 +60,7 @@ 
      * @param SplFileObject|string $file
      * @param string $eol
      */
-    public function __construct(SplFileObject|string $file, string $eol = PHP_EOL)
+    public function __construct(SplFileObject | string $file, string $eol = PHP_EOL)
     {
         if (is_string($file)) {
             $file = new SplFileObject($file, 'w');
@@ -83,7 +83,7 @@ 
     /**
      * {@inheritodc}
      */
-    public function load(Generator $items, int|string $key, Etl $etl): void
+    public function load(Generator $items, int | string $key, Etl $etl): void
     {
         foreach ($items as $value) {
             $this->file->fwrite($value . $this->eol);

Braces +2 added lines, -4 removed lines

@@ -41,8 +41,7 @@ 
  * @class FileLoader
  * @package Platine\Etl\Loader
  */
-class FileLoader implements LoaderInterface
-{
+class FileLoader implements LoaderInterface {
     /**
      * The file to be used
      * @var SplFileObject
@@ -60,8 +59,7 @@ 
      * @param SplFileObject|string $file
      * @param string $eol
      */
-    public function __construct(SplFileObject|string $file, string $eol = PHP_EOL)
-    {
+    public function __construct(SplFileObject|string $file, string $eol = PHP_EOL) {
         if (is_string($file)) {
             $file = new SplFileObject($file, 'w');
         }

src/Loader/LoaderInterface.php

Braces +1 added lines, -2 removed lines

@@ -42,8 +42,7 @@
  * @class LoaderInterface
  * @package Platine\Etl\Loader
  */
-interface LoaderInterface
-{
+interface LoaderInterface {
     /**
      * Init loader (start a transaction, if supported) and reset loader state.
      * @param array<string, mixed> $options additional options

Spacing +1 added lines, -1 removed lines

@@ -59,7 +59,7 @@
      * @param Etl $etl
      * @return void
      */
-    public function load(Generator $items, int|string $key, Etl $etl): void;
+    public function load(Generator $items, int | string $key, Etl $etl): void;
 
     /**
      * Flush elements (if supported).

src/Iterator/TextLineIterator.php

Braces +1 added lines, -2 removed lines

@@ -61,8 +61,7 @@
      * @param string $content
      * @param bool $skipEmptyLine
      */
-    public function __construct(string $content, bool $skipEmptyLine = true)
-    {
+    public function __construct(string $content, bool $skipEmptyLine = true) {
         $this->content = $content;
         $this->skipEmptyLine = $skipEmptyLine;
     }

src/Iterator/CsvFileIterator.php

Spacing +1 added lines, -1 removed lines

@@ -111,7 +111,7 @@
         return count(
             array_filter(
                 $current,
-                function ($cell) {
+                function($cell) {
                     return $cell !== null;
                 }
             )

src/Event/ItemExceptionEvent.php

Spacing +3 added lines, -3 removed lines

@@ -52,7 +52,7 @@ 
      * The key
      * @var int|string|null
      */
-    protected int|string|null $key;
+    protected int | string | null $key;
 
     /**
      * The exception that is raised
@@ -79,7 +79,7 @@ 
     public function __construct(
         string $name,
         mixed $item,
-        int|string|null $key,
+        int | string | null $key,
         Etl $etl,
         Throwable $exception
     ) {
@@ -102,7 +102,7 @@ 
      * Return the key
      * @return int|string|null
      */
-    public function getKey(): int|string|null
+    public function getKey(): int | string | null
     {
         return $this->key;
     }

Braces +1 added lines, -2 removed lines

@@ -40,8 +40,7 @@
  * @class ItemExceptionEvent
  * @package Platine\Etl\Event
  */
-class ItemExceptionEvent extends BaseEvent
-{
+class ItemExceptionEvent extends BaseEvent {
     /**
      * The item
      * @var mixed

src/Event/ItemEvent.php

Spacing +3 added lines, -3 removed lines

@@ -51,7 +51,7 @@ 
      * The key
      * @var int|string
      */
-    protected int|string $key;
+    protected int | string $key;
 
     /**
      * Create new instance
@@ -63,7 +63,7 @@ 
     public function __construct(
         string $name,
         mixed $item,
-        int|string $key,
+        int | string $key,
         Etl $etl
     ) {
         parent::__construct($name, $etl);
@@ -84,7 +84,7 @@ 
      * Return the key
      * @return int|string
      */
-    public function getKey(): int|string
+    public function getKey(): int | string
     {
         return $this->key;
     }

Braces +1 added lines, -2 removed lines

@@ -39,8 +39,7 @@
  * @class ItemEvent
  * @package Platine\Etl\Event
  */
-class ItemEvent extends BaseEvent
-{
+class ItemEvent extends BaseEvent {
     /**
      * The item
      * @var mixed