implementation

Author: Bartłomiej Nowak

extension.neon

@@ -8,6 +8,11 @@ parameters:
 		containerXmlPath: null
 		constantHassers: true
 		consoleApplicationLoader: null
+		messenger:
+			handleTraitWrappers:
+				# move that params to tests only
+				- MessengerHandleTrait\QueryBus::dispatch
+				- MessengerHandleTrait\QueryBus2::dispatch
 	stubFiles:
 		- stubs/Psr/Cache/CacheException.stub
 		- stubs/Psr/Cache/CacheItemInterface.stub
@@ -96,6 +101,9 @@ parametersSchema:
 		containerXmlPath: schema(string(), nullable())
 		constantHassers: bool()
 		consoleApplicationLoader: schema(string(), nullable())
+		messenger: structure([
+			handleTraitWrappers: listOf(string())
+		])
 	])
 
 services:
@@ -203,6 +211,11 @@ services:
 		class: PHPStan\Type\Symfony\MessengerHandleTraitReturnTypeExtension
 		tags: [phpstan.broker.expressionTypeResolverExtension]
 
+	# Messenger HandleTrait wrappers return type
+	-
+		class: PHPStan\Type\Symfony\MessengerHandleTraitWrapperReturnTypeExtension
+		tags: [phpstan.broker.expressionTypeResolverExtension]
+
 	# InputInterface::getArgument() return type
 	-
 		factory: PHPStan\Type\Symfony\InputInterfaceGetArgumentDynamicReturnTypeExtension

src/Type/Symfony/MessengerHandleTraitWrapperReturnTypeExtension.php

@@ -0,0 +1,107 @@
+<?php declare(strict_types = 1);
+
+namespace PHPStan\Type\Symfony;
+
+use PhpParser\Node\Expr;
+use PhpParser\Node\Expr\MethodCall;
+use PhpParser\Node\Identifier;
+use PHPStan\Analyser\Scope;
+use PHPStan\Symfony\MessageMap;
+use PHPStan\Symfony\MessageMapFactory;
+use PHPStan\Type\ExpressionTypeResolverExtension;
+use PHPStan\Type\Type;
+use function count;
+use function in_array;
+use function is_null;
+
+/**
+ * Configurable extension for resolving return types of methods that internally use HandleTrait.
+ *
+ * Configured via PHPStan parameters under symfony.messenger.handleTraitWrappers with
+ * "Class::method" patterns, e.g.:
+ * - App\Bus\QueryBus::dispatch
+ * - App\Bus\QueryBus::query
+ * - App\Bus\CommandBus::execute
+ * - App\Bus\CommandBus::handle
+ */
+final class MessengerHandleTraitWrapperReturnTypeExtension implements ExpressionTypeResolverExtension
+{
+
+	private MessageMapFactory $messageMapFactory;
+
+	private ?MessageMap $messageMap = null;
+
+	/** @var array<string> */
+	private array $wrappers;
+
+	/** @param array{handleTraitWrappers: array<string>}|null $messenger */
+	public function __construct(MessageMapFactory $messageMapFactory, ?array $messenger)
+	{
+		$this->messageMapFactory = $messageMapFactory;
+		$this->wrappers = $messenger['handleTraitWrappers'] ?? [];
+	}
+
+	public function getType(Expr $expr, Scope $scope): ?Type
+	{
+		if (!$this->isSupported($expr, $scope)) {
+			return null;
+		}
+
+		$args = $expr->getArgs();
+		if (count($args) !== 1) {
+			return null;
+		}
+
+		$arg = $args[0]->value;
+		$argClassNames = $scope->getType($arg)->getObjectClassNames();
+
+		if (count($argClassNames) === 1) {
+			$messageMap = $this->getMessageMap();
+			$returnType = $messageMap->getTypeForClass($argClassNames[0]);
+
+			if (!is_null($returnType)) {
+				return $returnType;
+			}
+		}
+
+		return null;
+	}
+
+	/**
+	 * @phpstan-assert-if-true =MethodCall $expr
+	 */
+	private function isSupported(Expr $expr, Scope $scope): bool
+	{
+		if ($this->wrappers === []) {
+			return false;
+		}
+
+		if (!($expr instanceof MethodCall) || !($expr->name instanceof Identifier)) {
+			return false;
+		}
+
+		$methodName = $expr->name->name;
+		$varType = $scope->getType($expr->var);
+		$classNames = $varType->getObjectClassNames();
+
+		if (count($classNames) !== 1) {
+			return false;
+		}
+
+		$className = $classNames[0];
+		$classMethodCombination = $className . '::' . $methodName;
+
+		// Check if this class::method combination is configured
+		return in_array($classMethodCombination, $this->wrappers, true);
+	}
+
+	private function getMessageMap(): MessageMap
+	{
+		if ($this->messageMap === null) {
+			$this->messageMap = $this->messageMapFactory->create();
+		}
+
+		return $this->messageMap;
+	}
+
+}

tests/Type/Symfony/data/messenger_handle_trait.php

@@ -64,6 +64,15 @@ public function dispatch(object $query): mixed
     }
 }
 
+class QueryBus2 {
+	use HandleTrait;
+
+	public function dispatch(object $query): mixed
+	{
+		return $this->handle($query);
+	}
+}
+
 class Controller {
     public function action()
     {
@@ -81,5 +90,8 @@ public function action()
         // HandleTrait will throw exception in fact due to multiple handle methods/handlers per single query
         assertType('mixed', $queryBus->dispatch(new MultiHandlesForInTheSameHandlerQuery()));
         assertType('mixed', $queryBus->dispatch(new MultiHandlersForTheSameMessageQuery()));
+
+		$queryBus2 = new QueryBus2();
+		assertType(TaggedResult::class, $queryBus2->dispatch(new TaggedQuery()));
     }
 }