[cache] Cache unchanged files on --dry-run

Author: dorrogeray

packages/Parallel/ValueObject/ProcessFileResult.php

@@ -0,0 +1,33 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Rector\Parallel\ValueObject;
+
+use Rector\Core\ValueObject\Error\SystemError;
+use Rector\Core\ValueObject\Reporting\FileDiff;
+
+final class ProcessFileResult
+{
+    /**
+     * @param array{system_errors: SystemError[], file_diffs: FileDiff[]} $errorAndFileDiffs
+     */
+    public function __construct(
+        private readonly bool $isFileChanged,
+        private readonly array $errorAndFileDiffs
+    ) {
+    }
+
+    public function isFileChanged(): bool
+    {
+        return $this->isFileChanged;
+    }
+
+    /**
+     * @return array{system_errors: SystemError[], file_diffs: FileDiff[]}
+     */
+    public function getErrorAndFileDiffs(): array
+    {
+        return $this->errorAndFileDiffs;
+    }
+}

packages/Parallel/WorkerRunner.php

@@ -20,6 +20,7 @@
 use Rector\Core\ValueObject\Error\SystemError;
 use Rector\Core\ValueObject\Reporting\FileDiff;
 use Rector\Parallel\ValueObject\Bridge;
+use Rector\Parallel\ValueObject\ProcessFileResult;
 use Symplify\EasyParallel\Enum\Action;
 use Symplify\EasyParallel\Enum\ReactCommand;
 use Symplify\EasyParallel\Enum\ReactEvent;
@@ -93,11 +94,12 @@ public function run(Encoder $encoder, Decoder $decoder, Configuration $configura
                     $file = new File($filePath, FileSystem::read($filePath));
                     $this->currentFileProvider->setFile($file);
 
-                    $errorAndFileDiffs = $this->processFile($file, $configuration, $errorAndFileDiffs);
+                    $processFileResult = $this->processFile($file, $configuration, $errorAndFileDiffs);
+                    $errorAndFileDiffs = $processFileResult->getErrorAndFileDiffs();
 
                     if ($errorAndFileDiffs[Bridge::SYSTEM_ERRORS] !== []) {
                         $this->invalidateFile($file);
-                    } elseif (! $configuration->isDryRun()) {
+                    } elseif (! $configuration->isDryRun() || $processFileResult->isFileChanged()) {
                         $this->changedFilesDetector->cacheFileWithDependencies($file->getFilePath());
                     }
                 } catch (Throwable $throwable) {
@@ -129,23 +131,24 @@ public function run(Encoder $encoder, Decoder $decoder, Configuration $configura
 
     /**
      * @param array{system_errors: SystemError[], file_diffs: FileDiff[]}|mixed[] $errorAndFileDiffs
-     * @return array{system_errors: SystemError[], file_diffs: FileDiff[]}
      */
-    private function processFile(File $file, Configuration $configuration, array $errorAndFileDiffs): array
+    private function processFile(File $file, Configuration $configuration, array $errorAndFileDiffs): ProcessFileResult
     {
+        $wasFileChanged = false;
         foreach ($this->fileProcessors as $fileProcessor) {
             if (! $fileProcessor->supports($file, $configuration)) {
                 continue;
             }
 
             $currentErrorsAndFileDiffs = $fileProcessor->process($file, $configuration);
+            $wasFileChanged = $wasFileChanged || $currentErrorsAndFileDiffs[Bridge::FILE_DIFFS] !== [];
             $errorAndFileDiffs = $this->arrayParametersMerger->merge(
                 $errorAndFileDiffs,
                 $currentErrorsAndFileDiffs
             );
         }
 
-        return $errorAndFileDiffs;
+        return new ProcessFileResult($wasFileChanged, $errorAndFileDiffs);
     }
 
     /**