Add PreInvoke and PostInvoke events

composer.json

@@ -43,9 +43,10 @@
         "ext-json": "*",
         "google/common-protos": "^3.1|^4.0",
         "google/protobuf": "^3.7",
-        "spiral/roadrunner-worker": "^3.0",
+        "psr/event-dispatcher": "^1.0",
         "spiral/goridge": "^4.0",
-        "spiral/roadrunner": "^2023.1 || ^2024.1"
+        "spiral/roadrunner": "^2023.1 || ^2024.1",
+        "spiral/roadrunner-worker": "^3.0"
     },
     "require-dev": {
         "jetbrains/phpstorm-attributes": "^1.0",

psalm.xml

@@ -20,6 +20,7 @@
         <InvalidAttribute errorLevel="suppress" />
         <UndefinedAttributeClass errorLevel="suppress" />
         <DocblockTypeContradiction errorLevel="suppress" />
+        <MissingClassConstType errorLevel="suppress" />
     </issueHandlers>
     <projectFiles>
         <directory name="src" />

src/Event/Event.php

@@ -0,0 +1,32 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Spiral\RoadRunner\GRPC\Event;
+
+use Psr\EventDispatcher\StoppableEventInterface;
+
+class Event implements StoppableEventInterface
+{
+    private bool $propagationStopped = false;
+
+    /**
+     * {@inheritdoc}
+     */
+    public function isPropagationStopped(): bool
+    {
+        return $this->propagationStopped;
+    }
+
+    /**
+     * Stops the propagation of the event to further event listeners.
+     *
+     * If multiple event listeners are connected to the same event, no
+     * further event listener will be triggered once any trigger calls
+     * stopPropagation().
+     */
+    public function stopPropagation(): void
+    {
+        $this->propagationStopped = true;
+    }
+}

src/Event/PostInvokeEvent.php

@@ -0,0 +1,20 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Spiral\RoadRunner\GRPC\Event;
+
+use Google\Protobuf\Internal\Message;
+
+final class PostInvokeEvent extends Event
+{
+    public function __construct(
+        private readonly Message $output,
+    ) {
+    }
+
+    public function getOutput(): Message
+    {
+        return $this->output;
+    }
+}

src/Event/PreInvokeEvent.php

@@ -0,0 +1,27 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Spiral\RoadRunner\GRPC\Event;
+
+use Google\Protobuf\Internal\Message;
+use Spiral\RoadRunner\GRPC\ContextInterface;
+
+final class PreInvokeEvent extends Event
+{
+    public function __construct(
+        private readonly ContextInterface $ctx,
+        private readonly Message $input,
+    ) {
+    }
+
+    public function getContext(): ContextInterface
+    {
+        return $this->ctx;
+    }
+
+    public function getInput(): Message
+    {
+        return $this->input;
+    }
+}

src/Invoker.php

@@ -5,6 +5,9 @@
 namespace Spiral\RoadRunner\GRPC;
 
 use Google\Protobuf\Internal\Message;
+use Psr\EventDispatcher\EventDispatcherInterface;
+use Spiral\RoadRunner\GRPC\Event\PostInvokeEvent;
+use Spiral\RoadRunner\GRPC\Event\PreInvokeEvent;
 use Spiral\RoadRunner\GRPC\Exception\InvokeException;
 
 final class Invoker implements InvokerInterface
@@ -17,6 +20,11 @@ final class Invoker implements InvokerInterface
         'Method %s input type must be an instance of %s, ' .
         'but the input is type of %s';
 
+    public function __construct(
+        private readonly ?EventDispatcherInterface $dispatcher = null
+    ) {
+    }
+
     public function invoke(
         ServiceInterface $service,
         Method $method,
@@ -28,11 +36,15 @@ public function invoke(
 
         $input = $input instanceof Message ? $input : $this->makeInput($method, $input);
 
+        $this->dispatcher?->dispatch(new PreInvokeEvent($ctx, $input));
+
         /** @var Message $message */
         $message = $callable($ctx, $input);
 
         \assert($this->assertResultType($method, $message));
 
+        $this->dispatcher?->dispatch(new PostInvokeEvent($message));
+
         try {
             return $message->serializeToString();
         } catch (\Throwable $e) {