Skip to content
Draft
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
18 changes: 0 additions & 18 deletions phpstan-baseline.neon
Original file line number Diff line number Diff line change
Expand Up @@ -48,24 +48,6 @@ parameters:
count: 1
path: src/bundle/Lock/Store/DoctrineDbalStore.php

-
message: '#^Parameter \#1 \$data \(array\{key\: mixed, ttl\?\: float\|null, only_deduplicate_in_queue\?\: bool\|null\}\) of method Ibexa\\Bundle\\Messenger\\Serializer\\Normalizer\\DeduplicateStampNormalizer\:\:denormalize\(\) should be contravariant with parameter \$data \(mixed\) of method Symfony\\Component\\Serializer\\Normalizer\\DenormalizerInterface\:\:denormalize\(\)$#'
identifier: method.childParameterType
count: 1
path: src/bundle/Serializer/Normalizer/DeduplicateStampNormalizer.php

-
message: '#^Cannot access offset string on mixed\.$#'
identifier: offsetAccess.nonOffsetAccessible
count: 1
path: src/bundle/Serializer/Normalizer/LockKeyNormalizer.php

-
message: '#^Variable property access on Symfony\\Component\\Lock\\Key\.$#'
identifier: property.dynamicName
count: 1
path: src/bundle/Serializer/Normalizer/LockKeyNormalizer.php

-
message: '#^Method Ibexa\\Bundle\\Messenger\\Transport\\Sender\\SendersLocator\:\:listTypes\(\) should return array\<class\-string\> but returns array\.$#'
identifier: return.type
Expand Down
19 changes: 2 additions & 17 deletions src/bundle/DependencyInjection/IbexaMessengerExtension.php
Original file line number Diff line number Diff line change
Expand Up @@ -8,9 +8,7 @@

namespace Ibexa\Bundle\Messenger\DependencyInjection;

use Ibexa\Bundle\Messenger\Middleware\DeduplicateMiddleware;
use Ibexa\Bundle\Messenger\Middleware\SudoMiddleware;
use Ibexa\Bundle\Messenger\Serializer\Normalizer\LockKeyNormalizer;
use Ibexa\Contracts\Messenger\Transport\MessageProviderInterface;
use LogicException;
use Symfony\Component\Config\FileLocator;
Expand All @@ -21,7 +19,6 @@
use Symfony\Component\DependencyInjection\Reference;
use Symfony\Component\HttpKernel\DependencyInjection\ConfigurableExtension;
use Symfony\Component\Lock\PersistingStoreInterface;
use Symfony\Component\Lock\Serializer\LockNormalizer as SymfonyLockNormalizer;
use Symfony\Component\Lock\Store\StoreFactory;
use Symfony\Component\Stopwatch\Stopwatch;

Expand Down Expand Up @@ -57,7 +54,6 @@ protected function loadInternal(array $mergedConfig, ContainerBuilder $container
$loader->load('services.yaml');

$this->configureLockStorage($mergedConfig['deduplication_lock_storage'], $container);
$this->configureLockNormalizerBackport($container);
$this->registerMessengerConfiguration($mergedConfig, $container);

if ($this->shouldLoadTestServices($container)) {
Expand Down Expand Up @@ -124,7 +120,7 @@ private function registerMessengerConfiguration(
];

if ($mergedConfig['deduplication_lock_storage']['enabled'] === true) {
$middleware[] = ['id' => DeduplicateMiddleware::class];
$middleware[] = ['id' => 'ibexa.messenger.middleware.deduplicate_middleware'];
}

$middleware = array_merge(
Expand All @@ -147,7 +143,7 @@ private function registerMessengerConfiguration(
private function configureLockStorage(array $lockStorageConfig, ContainerBuilder $container): void
{
if ($lockStorageConfig['enabled'] === false) {
$container->removeDefinition(DeduplicateMiddleware::class);
$container->removeDefinition('ibexa.messenger.middleware.deduplicate_middleware');
$container->removeDefinition('ibexa.messenger.lock_factory');
$container->removeDefinition('ibexa.messenger.lock_store.dbal');

Expand Down Expand Up @@ -193,15 +189,4 @@ private function configureLockStorage(array $lockStorageConfig, ContainerBuilder
$lockStorageType,
));
}

private function configureLockNormalizerBackport(ContainerBuilder $container): void
{
// Symfony 7.4 contains proper implementation
if (class_exists(SymfonyLockNormalizer::class)) {
$container->removeDefinition(LockKeyNormalizer::class);
$definition = new Definition(SymfonyLockNormalizer::class);
$definition->addTag('ibexa.messenger.serializer.normalizer', ['priority' => -60]);
$container->setDefinition('ibexa.messenger.lock_normalizer', $definition);
}
}
}
65 changes: 0 additions & 65 deletions src/bundle/Middleware/DeduplicateMiddleware.php

This file was deleted.

3 changes: 2 additions & 1 deletion src/bundle/Resources/config/services/buses.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,8 @@ services:

Ibexa\Bundle\Messenger\Middleware\SudoMiddleware: ~

Ibexa\Bundle\Messenger\Middleware\DeduplicateMiddleware:
ibexa.messenger.middleware.deduplicate_middleware:
class: Symfony\Component\Messenger\Middleware\DeduplicateMiddleware
arguments:
- '@ibexa.messenger.lock_factory'

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -4,11 +4,8 @@ services:
autoconfigure: false
public: false

Ibexa\Bundle\Messenger\Serializer\Normalizer\DeduplicateStampNormalizer:
tags:
- { name: ibexa.messenger.serializer.normalizer, priority: -60 }

Ibexa\Bundle\Messenger\Serializer\Normalizer\LockKeyNormalizer:
ibexa.messenger.serializer.normalizer.lock_key_normalizer:
class: Symfony\Component\Lock\Serializer\LockKeyNormalizer
tags:
- { name: ibexa.messenger.serializer.normalizer, priority: -60 }

Expand Down
85 changes: 0 additions & 85 deletions src/bundle/Serializer/Normalizer/DeduplicateStampNormalizer.php

This file was deleted.

68 changes: 0 additions & 68 deletions src/bundle/Serializer/Normalizer/LockKeyNormalizer.php

This file was deleted.

1 change: 0 additions & 1 deletion src/bundle/Serializer/SerializerFactory.php
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,6 @@

namespace Ibexa\Bundle\Messenger\Serializer;

use function Ibexa\PolyfillPhp82\iterator_to_array;
use Symfony\Component\Messenger\Transport\Serialization\Serializer;
use Symfony\Component\Serializer\Encoder\JsonEncoder;
use Symfony\Component\Serializer\Encoder\XmlEncoder;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,6 @@
namespace Ibexa\Tests\Bundle\Messenger\DependencyInjection;

use Ibexa\Bundle\Messenger\DependencyInjection\IbexaMessengerExtension;
use Ibexa\Bundle\Messenger\Middleware\DeduplicateMiddleware;
use Matthias\SymfonyDependencyInjectionTest\PhpUnit\AbstractExtensionTestCase;

final class IbexaMessengerExtensionTest extends AbstractExtensionTestCase
Expand All @@ -33,7 +32,7 @@ public function testConfigurationDefaults(): void
{
$this->load();

self::assertTrue($this->container->hasDefinition(DeduplicateMiddleware::class));
self::assertTrue($this->container->hasDefinition('ibexa.messenger.middleware.deduplicate_middleware'));
self::assertTrue($this->container->hasDefinition('ibexa.messenger.lock_factory'));
self::assertTrue($this->container->hasDefinition('ibexa.messenger.lock_store.dbal'));
}
Expand All @@ -46,7 +45,7 @@ public function testConfigurationWithDisabledLocks(): void
],
]);

self::assertFalse($this->container->hasDefinition(DeduplicateMiddleware::class));
self::assertFalse($this->container->hasDefinition('ibexa.messenger.middleware.deduplicate_middleware'));
self::assertFalse($this->container->hasDefinition('ibexa.messenger.lock_factory'));
self::assertFalse($this->container->hasDefinition('ibexa.messenger.lock_store.dbal'));
}
Expand Down
Loading
Loading