Initial commit of the Temporal plugins set

1 files changed, 48 insertions, 14 deletions

diff --git a/tests/psr-worker-bench.php b/tests/psr-worker-bench.php
index d382098a..ef741a61 100644
--- a/tests/psr-worker-bench.php
+++ b/tests/psr-worker-bench.php
@@ -1,24 +1,58 @@
 <?php
 
+declare(strict_types=1);
+
 use Spiral\RoadRunner;
 use Nyholm\Psr7\Factory;
 
 ini_set('display_errors', 'stderr');
 include "vendor/autoload.php";
 
-$worker = new RoadRunner\Http\PSR7Worker(
-    RoadRunner\Worker::create(),
-    new Factory\Psr17Factory(),
-    new Factory\Psr17Factory(),
-    new Factory\Psr17Factory()
-);
-
-while ($req = $worker->waitRequest()) {
-    try {
-        $rsp = new \Nyholm\Psr7\Response();
-        $rsp->getBody()->write("hello world");
-        $worker->respond($rsp);
-    } catch (\Throwable $e) {
-        $worker->getWorker()->error((string)$e);
+$env = \Spiral\RoadRunner\Environment::fromGlobals();
+
+if ($env->getMode() === 'http') {
+    $worker = new RoadRunner\Http\PSR7Worker(
+        RoadRunner\Worker::create(),
+        new Factory\Psr17Factory(),
+        new Factory\Psr17Factory(),
+        new Factory\Psr17Factory()
+    );
+
+    while ($req = $worker->waitRequest()) {
+        try {
+            $rsp = new \Nyholm\Psr7\Response();
+            $rsp->getBody()->write("hello world");
+            $worker->respond($rsp);
+        } catch (\Throwable $e) {
+            $worker->getWorker()->error((string)$e);
+        }
     }
+} else {
+    /**
+     * @param string $dir
+     * @return array<string>
+     */
+    $getClasses = static function (string $dir): iterable {
+        $files = glob($dir . '/*.php');
+
+        foreach ($files as $file) {
+            yield substr(basename($file), 0, -4);
+        }
+    };
+
+    $factory = \Temporal\WorkerFactory::create();
+
+    $worker = $factory->newWorker('default');
+
+    // register all workflows
+    foreach ($getClasses(__DIR__ . '/../temporal/Workflow') as $name) {
+        $worker->registerWorkflowType('Temporal\\Tests\\Workflow\\' . $name);
+    }
+
+    // register all activity
+    foreach ($getClasses(__DIR__ . '/../temporal/Activity') as $name) {
+        $worker->registerActivityType('Temporal\\Tests\\Activity\\' . $name);
+    }
+
+    $factory->run();
 }
\ No newline at end of file