platine-php / etl

src/EtlTool.php

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/Extractor/JsonExtractor.php

Spacing +2 added lines, -2 removed lines

@@ -122,7 +122,7 @@ 
      * @param SplFileObject|string $file
      * @return iterable<int|string, mixed>
      */
-    protected function extractFromFile(SplFileObject|string $file): iterable
+    protected function extractFromFile(SplFileObject | string $file): iterable
     {
         if ($file instanceof SplFileObject) {
             $file = $file->getPathname();
@@ -143,7 +143,7 @@ 
      * @param array<mixed>|string $data
      * @return iterable<int|string, mixed>
      */
-    protected function extractAuto(array|string $data): iterable
+    protected function extractAuto(array | string $data): iterable
     {
         if (is_array($data)) {
             return $this->extractFromArray($data);

src/Extractor/CsvExtractor.php

Spacing +1 added lines, -1 removed lines

@@ -154,7 +154,7 @@
      * @param SplFileObject|string $file
      * @return iterable<int|string, mixed>
      */
-    protected function extractFromFile(SplFileObject|string $file): iterable
+    protected function extractFromFile(SplFileObject | string $file): iterable
     {
         if ($file instanceof SplFileObject) {
             return new CsvFileIterator(

src/Loader/LoaderInterface.php

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/Loader/FileLoader.php

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);

src/Loader/JsonFileLoader.php

Spacing +2 added lines, -2 removed lines

@@ -77,7 +77,7 @@ 
      * @param int $depth
      */
     public function __construct(
-        SplFileObject|string $file,
+        SplFileObject | string $file,
         int $options = 0,
         int $depth = 512
     ) {
@@ -108,7 +108,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 $k => $v) {
             $this->data[$k] = $v;

src/Loader/NullLoader.php

Spacing +1 added lines, -1 removed lines

@@ -53,7 +53,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) {
             continue;

src/Loader/CsvFileLoader.php

Spacing +2 added lines, -2 removed lines

@@ -83,7 +83,7 @@ 
      * @param string $escapeString
      */
     public function __construct(
-        SplFileObject|string $file,
+        SplFileObject | string $file,
         array $keys = [],
         string $delimiter = ',',
         string $enclosure = '"',
@@ -140,7 +140,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->fputcsv(

src/Loader/ArrayLoader.php

Spacing +1 added lines, -1 removed lines

@@ -79,7 +79,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) {
             if ($this->preserveKeys) {