IBX-11780: Async content publishing spike

src/bundle/DependencyInjection/IbexaMessengerExtension.php

@@ -10,6 +10,7 @@
 
 use Ibexa\Bundle\Messenger\Middleware\DeduplicateMiddleware;
 use Ibexa\Bundle\Messenger\Middleware\SudoMiddleware;
+use Ibexa\Bundle\Messenger\Middleware\UserPermissionMiddleware;
 use Ibexa\Bundle\Messenger\Serializer\Normalizer\LockKeyNormalizer;
 use Ibexa\Contracts\Messenger\Transport\MessageProviderInterface;
 use LogicException;
@@ -121,6 +122,7 @@ private function registerMessengerConfiguration(
 
         $middleware = [
             ['id' => SudoMiddleware::class],
+            ['id' => UserPermissionMiddleware::class],
         ];
 
         if ($mergedConfig['deduplication_lock_storage']['enabled'] === true) {

src/bundle/Middleware/SudoMiddleware.php

@@ -28,6 +28,14 @@ public function handle(Envelope $envelope, StackInterface $stack): Envelope
     {
         $stamp = $envelope->last(SudoStamp::class);
         if ($stamp === null) {
+            // todo add this deprecation in 5.0.x release
+            trigger_deprecation(
+                'ibexa/messenger',
+                '5.0.x',
+                'Since 6.0.0, %s will not be attached automatically to all messages. You will need to add the stamp explicitly when dispatching the message.',
+                SudoStamp::class,
+            );
+
             $envelope = $envelope->with(new SudoStamp());
 
             $envelope = $this->repository->sudo(

src/bundle/Middleware/UserPermissionMiddleware.php

@@ -0,0 +1,43 @@
+<?php
+
+/**
+ * @copyright Copyright (C) Ibexa AS. All rights reserved.
+ * @license For full copyright and license information view LICENSE file distributed with this source code.
+ */
+declare(strict_types=1);
+
+namespace Ibexa\Bundle\Messenger\Middleware;
+
+use Ibexa\Bundle\Messenger\Stamp\UserPermissionStamp;
+use Ibexa\Contracts\Core\Repository\PermissionResolver;
+use Ibexa\Core\Repository\Values\User\UserReference;
+use Symfony\Component\Messenger\Envelope;
+use Symfony\Component\Messenger\Middleware\MiddlewareInterface;
+use Symfony\Component\Messenger\Middleware\StackInterface;
+
+final class UserPermissionMiddleware implements MiddlewareInterface
+{
+    public function __construct(
+        private PermissionResolver $permissionResolver
+    ) {
+    }
+
+    public function handle(Envelope $envelope, StackInterface $stack): Envelope
+    {
+        $stamp = $envelope->last(UserPermissionStamp::class);
+        if ($stamp === null) {
+            return $stack->next()->handle($envelope, $stack);
+        }
+
+        $previousUserReference = $this->permissionResolver->getCurrentUserReference();
+        $this->permissionResolver->setCurrentUserReference(
+            new UserReference($stamp->userId)
+        );
+
+        try {
+            return $stack->next()->handle($envelope, $stack);
+        } finally {
+            $this->permissionResolver->setCurrentUserReference($previousUserReference);
+        }
+    }
+}

src/bundle/Resources/config/services/buses.yaml

@@ -25,6 +25,8 @@ services:
 
     Ibexa\Bundle\Messenger\Middleware\SudoMiddleware: ~
 
+    Ibexa\Bundle\Messenger\Middleware\UserPermissionMiddleware: ~
+
     Ibexa\Bundle\Messenger\Middleware\DeduplicateMiddleware:
         arguments:
             - '@ibexa.messenger.lock_factory'

src/bundle/Stamp/UserPermissionStamp.php

@@ -0,0 +1,19 @@
+<?php
+
+/**
+ * @copyright Copyright (C) Ibexa AS. All rights reserved.
+ * @license For full copyright and license information view LICENSE file distributed with this source code.
+ */
+declare(strict_types=1);
+
+namespace Ibexa\Bundle\Messenger\Stamp;
+
+use Symfony\Component\Messenger\Stamp\StampInterface;
+
+final readonly class UserPermissionStamp implements StampInterface
+{
+    public function __construct(
+        public int $userId
+    ) {
+    }
+}