Merge pull request #62 from reactphp-parallel/2.x-switch-to-stubs-package

[2.x] Switch to stubs package

Author: WyriHaximus

composer.json

@@ -19,6 +19,7 @@
         "wyrihaximus/metrics": "^2.1"
     },
     "require-dev": {
+        "react-parallel/stubs": "^1.1",
         "wyrihaximus/async-test-utilities": "^5.0.25 || ^8.0.5"
     },
     "autoload": {

composer.lock

@@ -1,21 +1,32 @@
 parameters:
 	level: max
 	ignoreErrors:
+		-
+			message: '#Control structures using switch should not be used.#'
+			path: ../../src/EventLoopBridge.php
+		-
+			message: '#Language construct isset\(\) should not be used.#'
+			path: ../../src/EventLoopBridge.php
+		-
+			message: '#Property ReactParallel\\EventLoop\\Stream<T>::\$wait \(React\\Promise\\Deferred<ReactParallel\\EventLoop\\Done\|ReactParallel\\EventLoop\\Value>\) does not accept React\\Promise\\Deferred<mixed>.#'
+			path: ../../src/Stream.php
 		-
 			message: '#Result of method ReactParallel\\EventLoop\\EventLoopBridge::await\(\) \(void\) is used.#'
 			path: ../../tests/Types.php
-#	ergebnis:
-#		noExtends:
-#			classesAllowedToBeExtended:
-#				- ReactParallel\EventLoop\CancelledException
-#				- ReactParallel\EventLoop\CanceledFuture
-#				- ReactParallel\EventLoop\KilledRuntime
-	stubFiles:
-		- ../../stubs/Event.stub
-#		- ../../stubs/Events.stub
-		- ../../stubs/Future.stub
-		- ../../stubs/Channel.stub
-		- ../../stubs/functions.stub
+		-
+			message: '#usleep blocks the event loop, use React\\Promise\\Timer\\sleep#'
+			path: ../../tests/EventLoopBridgeTest.php
+		-
+			message: '#sleep blocks the event loop, use React\\Promise\\Timer\\sleep#'
+			path: ../../tests/EventLoopBridgeTest.php
+	ergebnis:
+		noExtends:
+			classesAllowedToBeExtended:
+				- Exception
+				- ReactParallel\EventLoop\CancelledException
+				- ReactParallel\EventLoop\CanceledFuture
+				- ReactParallel\EventLoop\KilledRuntime
 
-#includes:
-#	- ../../vendor/wyrihaximus/async-test-utilities/rules.neon
+includes:
+	- ../../vendor/wyrihaximus/async-test-utilities/rules.neon
+	- ../../vendor/react-parallel/stubs/extension.neon

etc/qa/phpstan.neon

@@ -12,10 +12,11 @@
         </ignoreFiles>
     </projectFiles>
     <stubs>
-        <file name="../../stubs/Channel.stub" />
-        <file name="../../stubs/Event.stub" />
-        <file name="../../stubs/functions.stub" />
-        <file name="../../stubs/Future.stub" />
+        <file name="../../vendor/react-parallel/stubs/stubs/Channel.stub" />
+        <file name="../../vendor/react-parallel/stubs/stubs/Event.stub" />
+        <file name="../../vendor/react-parallel/stubs/stubs/functions.stub" />
+        <file name="../../vendor/react-parallel/stubs/stubs/Future.stub" />
+        <file name="../../vendor/react-parallel/stubs/stubs/Runtime.stub" />
     </stubs>
     <issueHandlers>
 

etc/qa/psalm.xml

@@ -19,11 +19,13 @@
         "@default": true,
         "InstanceOf_": {
             "ignore": [
+                "ReactParallel\\EventLoop\\EventLoopBridge::handleFutureReadEvent",
                 "ReactParallel\\EventLoop\\EventLoopBridge::handleCancelEvent"
             ]
         },
         "LogicalNot": {
             "ignore": [
+                "ReactParallel\\EventLoop\\EventLoopBridge::handleFutureReadEvent",
                 "ReactParallel\\EventLoop\\EventLoopBridge::handleCancelEvent"
             ]
         },

infection.json.dist

@@ -5,7 +5,6 @@
 namespace ReactParallel\Tests\EventLoop;
 
 use parallel\Channel;
-use parallel\Future;
 use parallel\Runtime;
 use React\EventLoop\Loop;
 use ReactParallel\EventLoop\CanceledFuture;
@@ -16,7 +15,6 @@
 use WyriHaximus\Metrics\Configuration;
 use WyriHaximus\Metrics\InMemory\Registry;
 
-use function assert;
 use function bin2hex;
 use function dirname;
 use function parallel\run;
@@ -27,7 +25,6 @@
 use function React\Promise\all;
 use function React\Promise\resolve;
 use function sleep;
-use function time;
 use function usleep;
 
 final class EventLoopBridgeTest extends AsyncTestCase
@@ -60,7 +57,6 @@ public function read(): void
 
             return 'Elmo';
         });
-        assert($future instanceof Future);
 
         $promises = [];
         foreach ($channels as $channel) {
@@ -113,7 +109,6 @@ public function cancel(): void
         self::expectException(CanceledFuture::class);
 
         $future = run(static fn () => sleep(3));
-        assert($future instanceof Future);
 
         $eventLoopBridge = (new EventLoopBridge())->withMetrics(Metrics::create(new Registry(Configuration::create())));
 
@@ -129,14 +124,12 @@ public function kill(): void
         self::expectException(KilledRuntime::class);
 
         $runtime = new Runtime();
-        $future  = $runtime->run(static function (): int {
+        $future  = $runtime->run(static function (): string {
             sleep(3);
 
-            return time();
+            return 'hammer';
         });
 
-        assert($future instanceof Future);
-
         $eventLoopBridge = (new EventLoopBridge())->withMetrics(Metrics::create(new Registry(Configuration::create())));
 
         Loop::addTimer(1, static function () use ($runtime): void {
@@ -158,7 +151,6 @@ public function futureError(): void
 
             throw new CookieMonsterException('Cookie Monster');
         });
-        assert($future instanceof Future);
 
         $eventLoopBridge = (new EventLoopBridge())->withMetrics(Metrics::create(new Registry(Configuration::create())));