rpc.pre_execute

The most important event: on it the bundle validates and converts parameters, acquires the lock and executes the method itself. Your listener becomes part of this pipeline — exactly where is determined by its priority.

When it is dispatched

Once per method execution: after a cache miss and after the method has been found. For any request source — HTTP, console, batch, Messenger, deferred execution of notifications/callback, cache warm-up.

Not dispatched for a cached response, an unknown method and the receipt of notifications/callback (the method runs later, and the event is dispatched then).

Built-in listeners

What can be changed

$event->params are exactly the arguments the method will be called with. The effect depends on the priority:

• The cache key is computed from the raw request parameters, so changes to $params do not affect it.
• You should not replace $event->rpcRequest — it desynchronizes the server.

Stopping propagation skips the method call. Only the error scenario is supported: dispatch rpc.error and stop the event — this is what the built-in listeners do. There is no standard way to return a successful result without calling the method.

public function __construct(private RpcEventFactory $events) {}

// ...
$this->events->fireError($event->rpcRequest, new RpcLogicException('Not allowed'));
$event->stopPropagation();

Usage examples

Parameter value from context

Substitute the current client's ID for the one the client passed (protection against spoofing):

#[AsEventListener(RpcEvent::PRE_EXECUTE, priority: 1001)]
final class TenantParamListener
{
    public function __construct(private TenantResolver $tenants) {}

    public function __invoke(RpcPreExecuteEvent $event): void
    {
        if (array_key_exists('tenantId', $event->params)) {
            $event->params['tenantId'] = $this->tenants->current();
        }
    }
}

Priority 1001: after the argument list is built (1002), but before conversion (1000).

Method access check

#[AsEventListener(RpcEvent::PRE_EXECUTE, priority: 999)]
final class AccessListener
{
    public function __construct(private RpcEventFactory $events, private Acl $acl) {}

    public function __invoke(RpcPreExecuteEvent $event): void
    {
        if (!$this->acl->canCall($event->service->name)) {
            $this->events->fireError($event->rpcRequest, new RpcLogicException('Access denied'));
            $event->stopPropagation();
        }
    }
}

Other ideas

• measuring execution time (start here, finish on rpc.post_execute / rpc.error);
• opening a Doctrine transaction before the method runs;
• change auditing: storing parameters of methods that modify data.