Add workflow options support (#64)

Author: SerafimArts

src/Internal/ServiceContainer.php

@@ -112,28 +112,29 @@ final class ServiceContainer
      * @param ClientInterface $client
      * @param ReaderInterface $reader
      * @param QueueInterface $queue
+     * @param MarshallerInterface $marshaller
      * @param DataConverterInterface $dataConverter
      */
     public function __construct(
         LoopInterface $loop,
         ClientInterface $client,
         ReaderInterface $reader,
         QueueInterface $queue,
+        MarshallerInterface $marshaller,
         DataConverterInterface $dataConverter
     ) {
         $this->loop = $loop;
         $this->client = $client;
         $this->reader = $reader;
         $this->queue = $queue;
+        $this->marshaller = $marshaller;
+        $this->dataConverter = $dataConverter;
 
         $this->env = new Environment();
         $this->workflows = new WorkflowCollection();
         $this->activities = new ActivityCollection();
         $this->running = new ProcessCollection($client);
 
-        $this->dataConverter = $dataConverter;
-        $this->marshaller = new Marshaller(new AttributeMapperFactory($this->reader));
-
         $this->workflowsReader = new WorkflowReader($this->reader);
         $this->activitiesReader = new ActivityReader($this->reader);
     }
@@ -149,6 +150,7 @@ public static function fromWorker(WorkerFactory $worker): self
             $worker->getClient(),
             $worker->getReader(),
             $worker->getQueue(),
+            $worker->getMarshaller(),
             $worker->getDataConverter()
         );
     }

src/Internal/Transport/Router/GetWorkerInfo.php

@@ -15,20 +15,31 @@
 use Temporal\DataConverter\EncodedValues;
 use Temporal\Internal\Declaration\Prototype\ActivityPrototype;
 use Temporal\Internal\Declaration\Prototype\WorkflowPrototype;
+use Temporal\Internal\Marshaller\MarshallerInterface;
 use Temporal\Internal\Repository\RepositoryInterface;
 use Temporal\Worker\WorkerInterface;
 use Temporal\Worker\Transport\Command\RequestInterface;
 
 final class GetWorkerInfo extends Route
 {
+    /**
+     * @var RepositoryInterface
+     */
     private RepositoryInterface $queues;
 
+    /**
+     * @var MarshallerInterface
+     */
+    private MarshallerInterface $marshaller;
+
     /**
      * @param RepositoryInterface $queues
+     * @param MarshallerInterface $marshaller
      */
-    public function __construct(RepositoryInterface $queues)
+    public function __construct(RepositoryInterface $queues, MarshallerInterface $marshaller)
     {
         $this->queues = $queues;
+        $this->marshaller = $marshaller;
     }
 
     /**
@@ -37,6 +48,7 @@ public function __construct(RepositoryInterface $queues)
     public function handle(RequestInterface $request, array $headers, Deferred $resolver): void
     {
         $result = [];
+
         foreach ($this->queues as $taskQueue) {
             $result[] = $this->workerToArray($taskQueue);
         }
@@ -45,28 +57,28 @@ public function handle(RequestInterface $request, array $headers, Deferred $reso
     }
 
     /**
-     * @param WorkerInterface $taskQueue
+     * @param WorkerInterface $worker
      * @return array
      */
-    private function workerToArray(WorkerInterface $taskQueue): array
+    private function workerToArray(WorkerInterface $worker): array
     {
+        $workflowMap = function (WorkflowPrototype $workflow) {
+            return [
+                'Name'    => $workflow->getID(),
+                'Queries' => $this->keys($workflow->getQueryHandlers()),
+                'Signals' => $this->keys($workflow->getSignalHandlers()),
+            ];
+        };
+
+        $activityMap = static fn (ActivityPrototype $activity) => [
+            'Name' => $activity->getID(),
+        ];
+
         return [
-            'TaskQueue' => $taskQueue->getID(),
-            'Options' => new \stdClass(), // todo: set options
-            'Workflows' => $this->map(
-                $taskQueue->getWorkflows(),
-                function (WorkflowPrototype $workflow) {
-                    return [
-                        'Name' => $workflow->getID(),
-                        'Queries' => $this->keys($workflow->getQueryHandlers()),
-                        'Signals' => $this->keys($workflow->getSignalHandlers()),
-                    ];
-                }
-            ),
-            'Activities' => $this->map(
-                $taskQueue->getActivities(),
-                fn(ActivityPrototype $activity) => ['Name' => $activity->getID()]
-            ),
+            'TaskQueue'  => $worker->getID(),
+            'Options'    => $this->marshaller->marshal($worker->getOptions()),
+            'Workflows'  => $this->map($worker->getWorkflows(), $workflowMap),
+            'Activities' => $this->map($worker->getActivities(), $activityMap),
         ];
     }
 

src/Worker/Worker.php

@@ -71,6 +71,14 @@ public function __construct(
         $this->router = $this->createRouter();
     }
 
+    /**
+     * @return WorkerOptions
+     */
+    public function getOptions(): WorkerOptions
+    {
+        return $this->options;
+    }
+
     /**
      * @param RequestInterface $request
      * @param array $headers

src/Worker/WorkerInterface.php

@@ -16,6 +16,13 @@
 
 interface WorkerInterface
 {
+    /**
+     * Returns info about worker
+     *
+     * @return WorkerOptions
+     */
+    public function getOptions(): WorkerOptions;
+
     /**
      * @param class-string ...$class
      * @return $this