Inline symplify/easy-parallel into src/Parallel

The symplify/easy-parallel package is deprecated. Move its classes into
Rector\Parallel namespace under src/Parallel and drop the dependency.

The transitive deps it provided (fidry/cpu-core-counter, react/child-process)
are now required directly.

Claude-Session: https://claude.ai/code/session_01PMRRBcHZHHSXHYNMFbNAnF

Author: TomasVotruba

composer.json

@@ -19,11 +19,13 @@
         "composer/xdebug-handler": "^3.0.5",
         "doctrine/inflector": "^2.1",
         "entropy/entropy": "^0.4.12",
+        "fidry/cpu-core-counter": "^1.1",
         "nette/utils": "^4.1.4",
         "nikic/php-parser": "^5.8",
         "ondram/ci-detector": "^4.2",
         "phpstan/phpdoc-parser": "^2.3.3",
         "phpstan/phpstan": "^2.2.6",
+        "react/child-process": "^0.6.5",
         "react/event-loop": "^1.6",
         "react/promise": "^3.3",
         "react/socket": "^1.17",
@@ -37,7 +39,6 @@
         "symfony/filesystem": "^8.1",
         "symfony/finder": "^8.1",
         "symfony/process": "^8.1",
-        "symplify/easy-parallel": "^11.2.2",
         "symplify/rule-doc-generator-contracts": "^11.2",
         "webmozart/assert": "^2.4"
     },

src/Application/ApplicationFileProcessor.php

@@ -12,6 +12,9 @@
 use Rector\Configuration\Parameter\SimpleParameterProvider;
 use Rector\FileSystem\FilesFinder;
 use Rector\Parallel\Application\ParallelFileProcessor;
+use Rector\Parallel\CpuCoreCountProvider;
+use Rector\Parallel\Exception\ParallelShouldNotHappenException;
+use Rector\Parallel\ScheduleFactory;
 use Rector\PhpParser\Parser\ParserErrors;
 use Rector\Reporting\MissConfigurationReporter;
 use Rector\Skipper\Skipper\UsedSkipCollector;
@@ -25,9 +28,6 @@
 use Rector\ValueObject\Reporting\FileDiff;
 use Symfony\Component\Console\Input\InputInterface;
 use Symfony\Component\Console\Style\SymfonyStyle;
-use Symplify\EasyParallel\CpuCoreCountProvider;
-use Symplify\EasyParallel\Exception\ParallelShouldNotHappenException;
-use Symplify\EasyParallel\ScheduleFactory;
 use Throwable;
 
 final class ApplicationFileProcessor

src/ChangesReporting/ValueObject/RectorWithLineChange.php

@@ -5,8 +5,8 @@
 namespace Rector\ChangesReporting\ValueObject;
 
 use Rector\Contract\Rector\RectorInterface;
+use Rector\Parallel\Contract\SerializableInterface;
 use Rector\PostRector\Contract\Rector\PostRectorInterface;
-use Symplify\EasyParallel\Contract\SerializableInterface;
 use Webmozart\Assert\Assert;
 
 final readonly class RectorWithLineChange implements SerializableInterface

src/Console/Command/WorkerCommand.php

@@ -15,6 +15,9 @@
 use Rector\Configuration\ConfigurationRuleFilter;
 use Rector\Configuration\Option;
 use Rector\Console\ProcessConfigureDecorator;
+use Rector\Parallel\Enum\Action;
+use Rector\Parallel\Enum\ReactCommand;
+use Rector\Parallel\Enum\ReactEvent;
 use Rector\Parallel\ValueObject\Bridge;
 use Rector\StaticReflection\DynamicSourceLocatorDecorator;
 use Rector\Util\MemoryLimiter;
@@ -23,9 +26,6 @@
 use Symfony\Component\Console\Command\Command;
 use Symfony\Component\Console\Input\InputInterface;
 use Symfony\Component\Console\Output\OutputInterface;
-use Symplify\EasyParallel\Enum\Action;
-use Symplify\EasyParallel\Enum\ReactCommand;
-use Symplify\EasyParallel\Enum\ReactEvent;
 use Throwable;
 use Webmozart\Assert\Assert;
 
@@ -154,7 +154,7 @@ private function runWorker(
             );
 
             /**
-             * this invokes all listeners listening $decoder->on(...) @see \Symplify\EasyParallel\Enum\ReactEvent::DATA
+             * this invokes all listeners listening $decoder->on(...) @see \Rector\Parallel\Enum\ReactEvent::DATA
              */
             $encoder->write([
                 ReactCommand::ACTION => Action::RESULT,

src/Parallel/Application/ParallelFileProcessor.php

@@ -14,19 +14,19 @@
 use Rector\Configuration\Parameter\SimpleParameterProvider;
 use Rector\Console\Command\ProcessCommand;
 use Rector\Parallel\Command\WorkerCommandLineFactory;
+use Rector\Parallel\Enum\Action;
+use Rector\Parallel\Enum\Content;
+use Rector\Parallel\Enum\ReactCommand;
+use Rector\Parallel\Enum\ReactEvent;
 use Rector\Parallel\ValueObject\Bridge;
+use Rector\Parallel\ValueObject\ParallelProcess;
+use Rector\Parallel\ValueObject\ProcessPool;
+use Rector\Parallel\ValueObject\Schedule;
 use Rector\ValueObject\Error\SystemError;
 use Rector\ValueObject\ProcessResult;
 use Rector\ValueObject\Reporting\FileDiff;
 use Symfony\Component\Console\Command\Command;
 use Symfony\Component\Console\Input\InputInterface;
-use Symplify\EasyParallel\Enum\Action;
-use Symplify\EasyParallel\Enum\Content;
-use Symplify\EasyParallel\Enum\ReactCommand;
-use Symplify\EasyParallel\Enum\ReactEvent;
-use Symplify\EasyParallel\ValueObject\ParallelProcess;
-use Symplify\EasyParallel\ValueObject\ProcessPool;
-use Symplify\EasyParallel\ValueObject\Schedule;
 use Throwable;
 
 /**

src/Parallel/Command/WorkerCommandLineFactory.php

@@ -7,10 +7,10 @@
 use Rector\ChangesReporting\Output\JsonOutputFormatter;
 use Rector\Configuration\Option;
 use Rector\FileSystem\FilePathHelper;
+use Rector\Parallel\Exception\ParallelShouldNotHappenException;
+use Rector\Parallel\Reflection\CommandFromReflectionFactory;
 use Symfony\Component\Console\Command\Command;
 use Symfony\Component\Console\Input\InputInterface;
-use Symplify\EasyParallel\Exception\ParallelShouldNotHappenException;
-use Symplify\EasyParallel\Reflection\CommandFromReflectionFactory;
 
 /**
  * @see \Rector\Tests\Parallel\Command\WorkerCommandLineFactoryTest

src/Parallel/Contract/SerializableInterface.php

@@ -0,0 +1,15 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Rector\Parallel\Contract;
+
+use JsonSerializable;
+
+interface SerializableInterface extends JsonSerializable
+{
+    /**
+     * @param array<string, mixed> $json
+     */
+    public static function decode(array $json): self;
+}

src/Parallel/CpuCoreCountProvider.php

@@ -0,0 +1,22 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Rector\Parallel;
+
+use Fidry\CpuCoreCounter\CpuCoreCounter;
+use Fidry\CpuCoreCounter\NumberOfCpuCoreNotFound;
+
+final class CpuCoreCountProvider
+{
+    private const int DEFAULT_CORE_COUNT = 2;
+
+    public function provide(): int
+    {
+        try {
+            return (new CpuCoreCounter())->getCount();
+        } catch (NumberOfCpuCoreNotFound) {
+            return self::DEFAULT_CORE_COUNT;
+        }
+    }
+}

src/Parallel/Enum/Action.php

@@ -0,0 +1,14 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Rector\Parallel\Enum;
+
+final class Action
+{
+    public const string HELLO = 'hello';
+
+    public const string MAIN = 'main';
+
+    public const string RESULT = 'result';
+}

src/Parallel/Enum/Content.php

@@ -0,0 +1,12 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Rector\Parallel\Enum;
+
+final class Content
+{
+    public const string RESULT = 'result';
+
+    public const string FILES = 'files';
+}