IBX-11780: Async content publishing spike

src/bundle/Core/DependencyInjection/Configuration/Parser/Repository/AsyncContentPublish.php

@@ -0,0 +1,24 @@
+<?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\Core\DependencyInjection\Configuration\Parser\Repository;
+
+use Ibexa\Bundle\Core\DependencyInjection\Configuration\RepositoryConfigParserInterface;
+use Symfony\Component\Config\Definition\Builder\NodeBuilder;
+
+final class AsyncContentPublish implements RepositoryConfigParserInterface
+{
+    public function addSemanticConfig(NodeBuilder $nodeBuilder): void
+    {
+        $nodeBuilder
+            ->booleanNode('async_content_publish')
+                ->defaultFalse()
+                ->info('Enables asynchronous content publishing.')
+            ->end();
+    }
+}

src/bundle/Core/IbexaCoreBundle.php

@@ -129,6 +129,7 @@ public function getContainerExtension(): ExtensionInterface
                     new ConfigParser\Embeddings(),
                 ],
                 [
+                    new RepositoryConfigParser\AsyncContentPublish(),
                     new RepositoryConfigParser\Storage(),
                     new RepositoryConfigParser\Search(),
                     new RepositoryConfigParser\FieldGroups(),

src/bundle/Core/Message/PublishContentAsync.php

@@ -0,0 +1,22 @@
+<?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\Core\Message;
+
+use Ibexa\Contracts\Core\Repository\Values\Content\Language;
+
+final readonly class PublishContentAsync
+{
+    public function __construct(
+        public int $contentId,
+        public int $versionNo,
+        /** @var list<string> */
+        public array $translations = Language::ALL,
+    ) {
+    }
+}

src/bundle/Core/Message/PublishContentAsyncHandler.php

@@ -0,0 +1,31 @@
+<?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\Core\Message;
+
+use Ibexa\Contracts\Core\Repository\ContentService;
+
+final class PublishContentAsyncHandler
+{
+    public function __construct(
+        private ContentService $contentService,
+    ) {
+    }
+
+    public function __invoke(PublishContentAsync $message): void
+    {
+        $versionInfo = $this->contentService->loadVersionInfoById($message->contentId, $message->versionNo);
+
+        $this->contentService->publishVersion(
+            $versionInfo,
+            [$versionInfo->getInitialLanguage()->getLanguageCode()],
+        );
+
+        // todo handle "publishing in progress" status
+    }
+}

src/bundle/Core/Messenger/MessageProvider.php

@@ -0,0 +1,21 @@
+<?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\Core\Messenger;
+
+use Ibexa\Bundle\Core\Message\PublishContentAsync;
+// TODO circular dependency on ibexa/messenger !!!
+use Ibexa\Contracts\Messenger\Transport\MessageProviderInterface;
+
+final class MessageProvider implements MessageProviderInterface
+{
+    public function getHandledClasses(): iterable
+    {
+        return [PublishContentAsync::class];
+    }
+}

src/bundle/Core/Resources/config/services.yml

@@ -372,3 +372,11 @@ services:
         arguments:
             $inner: '@.inner'
 
+    Ibexa\Bundle\Core\Message\PublishContentAsyncHandler:
+        autowire: true
+        tags:
+            - { name: messenger.message_handler, bus: ibexa.messenger.bus }
+
+    Ibexa\Bundle\Core\Messenger\MessageProvider:
+        tags:
+            - ibexa.messenger.sender_message_provider