Merge branch 'release/5.0.0'

### Changed

- #12: Fix all phpstan errors and general typing improvements.

.gitattributes

@@ -7,3 +7,4 @@
 /phpstan.neon.dist export-ignore
 /phpunit.xml.dist export-ignore
 /tests export-ignore
+/phan export-ignore

.phan/config.php

@@ -49,7 +49,7 @@
     // (See `backward_compatibility_checks` for additional options)
     // Automatically inferred from composer.json requirement for "php" of
     // "^7.2.0"
-    'target_php_version' => '7.4',
+    'target_php_version' => '7.2',
 
     // If enabled, missing properties will be created when
     // they are first seen. If false, we'll report an
@@ -292,7 +292,10 @@
 
     // Add any issue types (such as `'PhanUndeclaredMethod'`)
     // to this black-list to inhibit them from being reported.
-    'suppress_issue_types' => [],
+    'suppress_issue_types' => [
+        'PhanUnreferencedPublicMethod',
+        'PhanUnreferencedClass',
+    ],
 
     // A regular expression to match files to be excluded
     // from parsing and analysis and will not be read at all.

CHANGELOG.md

@@ -7,6 +7,12 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## [Unreleased]
 
+## [5.0.0] - 2020-03-28
+
+### Changed
+
+- #12: Fix all phpstan errors and general typing improvements.
+
 ## [4.0.0] - 2020-02-09
 
 ### Changed
@@ -82,7 +88,8 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 - Added progress callbacks to Deferred.
 - Added serializable objects for exit and error messages.
 
-[Unreleased]: https://github.com/TheLevti/phpfork/compare/4.0.0...HEAD
+[Unreleased]: https://github.com/TheLevti/phpfork/compare/5.0.0...HEAD
+[5.0.0]: https://github.com/TheLevti/phpfork/releases/5.0.0
 [4.0.0]: https://github.com/TheLevti/phpfork/releases/4.0.0
 [3.0.0]: https://github.com/TheLevti/phpfork/releases/3.0.0
 [2.0.2]: https://github.com/TheLevti/phpfork/releases/2.0.2

composer.json

@@ -43,8 +43,8 @@
         "ext-posix": "*",
         "ext-shmop": "*",
         "friendsofphp/php-cs-fixer": "^2.16",
-        "phan/phan": "^2.4",
-        "phpstan/phpstan": "^0.12.4",
+        "phan/phan": "^2.6",
+        "phpstan/phpstan": "^0.12.18",
         "phpunit/phpunit": "^8.5",
         "squizlabs/php_codesniffer": "^3.5",
         "symfony/var-dumper": "^5.0"
@@ -74,7 +74,8 @@
             "/php_cs.dist",
             "/phpstan.neon.dist",
             "/phpunit.xml.dist",
-            "/tests"
+            "/tests",
+            "/phan"
         ]
     },
     "config": {
@@ -91,6 +92,7 @@
         "cs": "vendor/bin/phpcs --standard=PSR12 src/ tests/",
         "csf": "vendor/bin/php-cs-fixer fix",
         "static": "vendor/bin/phpstan analyse",
+        "phan": "vendor/bin/phan --no-progress-bar",
         "test": "vendor/bin/phpunit",
         "coverage": "vendor/bin/phpunit --coverage-html coverage"
     }

phpstan.neon.dist

@@ -1,6 +1,6 @@
 parameters:
-    level: 5
+    level: max
     paths:
         - src
-        - tests
     inferPrivatePropertyTypeFromConstructor: true
+    treatPhpDocTypesAsCertain: false

src/Batch/BatchJob.php

@@ -15,87 +15,121 @@
 
 use TheLevti\phpfork\Batch\Strategy\ChunkStrategy;
 use TheLevti\phpfork\Batch\Strategy\StrategyInterface;
-use TheLevti\phpfork\Exception\UnexpectedTypeException;
+use TheLevti\phpfork\Fork;
 use TheLevti\phpfork\ProcessManager;
 
 class BatchJob
 {
-    private $manager;
+    /**
+     * @var \TheLevti\phpfork\ProcessManager $processManager
+     */
+    protected $processManager;
+
+    /**
+     * @var mixed $data
+     */
     private $data;
+
+    /**
+     * @var \TheLevti\phpfork\Batch\Strategy\StrategyInterface $strategy
+     */
     private $strategy;
+
+    /**
+     * @var string $name
+     */
     private $name;
+
+    /**
+     * @var callable $callback
+     */
     private $callback;
 
-    public function __construct(ProcessManager $manager, $data = null, StrategyInterface $strategy = null)
+    /**
+     * @param \TheLevti\phpfork\ProcessManager $processManager
+     * @param mixed|null $data
+     * @param \TheLevti\phpfork\Batch\Strategy\StrategyInterface|null $strategy
+     * @return void
+     */
+    public function __construct(ProcessManager $processManager, $data = null, StrategyInterface $strategy = null)
     {
-        $this->manager = $manager;
+        $this->processManager = $processManager;
         $this->data = $data;
         $this->strategy = $strategy ?: new ChunkStrategy();
         $this->name = '<anonymous>';
     }
 
-    public function setName($name)
+    public function setName(string $name): self
     {
         $this->name = $name;
 
         return $this;
     }
 
-    public function setStrategy(StrategyInterface $strategy)
+    public function setStrategy(StrategyInterface $strategy): self
     {
         $this->strategy = $strategy;
 
         return $this;
     }
 
-    public function setData($data)
+    /**
+     * @param mixed $data
+     * @return \TheLevti\phpfork\Batch\BatchJob
+     */
+    public function setData($data): self
     {
         $this->data = $data;
 
         return $this;
     }
 
-    public function setCallback($callback)
+    public function setCallback(callable $callback): self
     {
-        if (!is_callable($callback)) {
-            throw new UnexpectedTypeException($callback, 'callable');
-        }
-
         $this->callback = $callback;
 
         return $this;
     }
 
-    public function execute($callback = null)
+    public function execute(?callable $callback = null): Fork
     {
         if (null !== $callback) {
             $this->setCallback($callback);
         }
 
-        return $this->manager->fork($this)->setName($this->name . ' batch');
+        return $this->processManager->fork($this)->setName($this->name . ' batch');
     }
 
     /**
      * Runs in a child process.
      *
-     * @see execute()
+     * @see \TheLevti\phpfork\Batch\BatchJob::execute()
+     *
+     * @return array<mixed> Result from the batch job.
      */
-    public function __invoke()
+    public function __invoke(): array
     {
+        /** @var array<int,\TheLevti\phpfork\Fork> $forks */
         $forks = [];
         foreach ($this->strategy->createBatches($this->data) as $index => $batch) {
-            $forks[] = $this->manager
+            $forks[] = $this->processManager
                 ->fork($this->strategy->createRunner($batch, $this->callback))
                 ->setName(sprintf('%s batch #%d', $this->name, $index))
             ;
         }
 
-        // block until all forks have exited
-        $this->manager->wait();
+        $this->processManager->wait();
 
+        /** @var array<int,mixed> $results */
         $results = [];
         foreach ($forks as $fork) {
-            $results = array_merge($results, $fork->getResult());
+            $batchResult = $fork->getResult();
+
+            if (is_array($batchResult)) {
+                $results = array_merge($results, $batchResult);
+            } else {
+                $results[] = $batchResult;
+            }
         }
 
         return $results;

src/Batch/BatchRunner.php

@@ -13,12 +13,19 @@
 
 namespace TheLevti\phpfork\Batch;
 
-use TheLevti\phpfork\Exception\UnexpectedTypeException;
 use TheLevti\phpfork\SharedMemory;
+use UnexpectedValueException;
 
 class BatchRunner
 {
+    /**
+     * @var array<int|string,mixed>|callable $batch
+     */
     private $batch;
+
+    /**
+     * @var callable $callback
+     */
     private $callback;
 
     /**
@@ -28,28 +35,36 @@ class BatchRunner
      *
      *     function($item, $index, $batch, $sharedMem)
      *
-     * @param mixed    $batch    The batch
-     * @param callable $callback The callback
+     * @param array<int|string,mixed>|callable $batch
+     * @param callable $callback
      */
-    public function __construct($batch, $callback)
+    public function __construct($batch, callable $callback)
     {
-        if (!is_callable($callback)) {
-            throw new UnexpectedTypeException($callback, 'callable');
-        }
-
         $this->batch = $batch;
         $this->callback = $callback;
     }
 
-    public function __invoke(SharedMemory $shm)
+    /**
+     * @param \TheLevti\phpfork\SharedMemory $shm
+     * @throws \UnexpectedValueException
+     * @return array<int|string,mixed>
+     */
+    public function __invoke(SharedMemory $shm): array
     {
         // lazy batch...
-        if ($this->batch instanceof \Closure) {
-            $this->batch = call_user_func($this->batch);
+        if (is_callable($this->batch)) {
+            /** @var array<mixed> $batchArray */
+            $batchArray = call_user_func($this->batch);
+        } elseif (is_array($this->batch)) {
+            /** @var array<mixed> $batchArray */
+            $batchArray = $this->batch;
+        } else {
+            throw new UnexpectedValueException('Batch is not an array nor a callable.');
         }
 
+        /** @var array<int|string,mixed> $results */
         $results = [];
-        foreach ($this->batch as $index => $item) {
+        foreach ($batchArray as $index => $item) {
             $results[$index] = call_user_func($this->callback, $item, $index, $this->batch, $shm);
         }
 

src/Batch/Strategy/AbstractStrategy.php

@@ -17,7 +17,7 @@
 
 abstract class AbstractStrategy implements StrategyInterface
 {
-    public function createRunner($batch, $callback)
+    public function createRunner($batch, $callback): callable
     {
         return new BatchRunner($batch, $callback);
     }

src/Batch/Strategy/CallbackStrategy.php

@@ -13,22 +13,19 @@
 
 namespace TheLevti\phpfork\Batch\Strategy;
 
-use TheLevti\phpfork\Exception\UnexpectedTypeException;
-
 class CallbackStrategy extends AbstractStrategy
 {
+    /**
+     * @var callable $callback
+     */
     private $callback;
 
-    public function __construct($callback)
+    public function __construct(callable $callback)
     {
-        if (!is_callable($callback)) {
-            throw new UnexpectedTypeException($callback, 'callable');
-        }
-
         $this->callback = $callback;
     }
 
-    public function createBatches($data)
+    public function createBatches($data): iterable
     {
         return call_user_func($this->callback, $data);
     }

src/Batch/Strategy/ChunkStrategy.php

@@ -20,16 +20,23 @@
  */
 class ChunkStrategy extends AbstractStrategy
 {
+    /**
+     * @var int $forks
+     */
     private $forks;
+
+    /**
+     * @var bool $preserveKeys
+     */
     private $preserveKeys;
 
-    public function __construct($forks = 3, $preserveKeys = false)
+    public function __construct(int $forks = 3, bool $preserveKeys = false)
     {
         $this->forks = $forks;
         $this->preserveKeys = $preserveKeys;
     }
 
-    public function createBatches($data)
+    public function createBatches($data): iterable
     {
         if (!is_array($data) && !$data instanceof \Traversable) {
             throw new UnexpectedTypeException($data, 'array or Traversable');

src/Batch/Strategy/StrategyInterface.php

@@ -23,20 +23,20 @@ interface StrategyInterface
      *
      * @param mixed $data The raw batch data
      *
-     * @return array|\Traversable An iterator of batches
+     * @return iterable<int|string,mixed> An iterator of batches
      */
-    public function createBatches($data);
+    public function createBatches($data): iterable;
 
     /**
      * Creates a batch runner for the supplied list.
      *
      * A batch runner is a callable that is passed to ProcessManager::fork()
      * that should run each item in the supplied batch through a callable.
      *
-     * @param mixed    $batch    A batch of items
+     * @param array<int|string,mixed>|callable $batch A batch of items
      * @param callable $callback The batch callback
      *
      * @return callable A callable for the child process
      */
-    public function createRunner($batch, $callback);
+    public function createRunner($batch, $callback): callable;
 }