diff --git a/acp-toolbox b/acp-toolbox index 4e14666f74..5d3835c200 160000 --- a/acp-toolbox +++ b/acp-toolbox @@ -1 +1 @@ -Subproject commit 4e14666f74d5b6794f21bd13a9862dffa9cbad23 +Subproject commit 5d3835c200c8f0fd5eb5ab3b00fe8a5c3a00e6ae diff --git a/data/import/common/common/marketplace/product_stock.csv b/data/import/common/common/marketplace/product_stock.csv index b64e57d1d1..bfa8a86476 100644 --- a/data/import/common/common/marketplace/product_stock.csv +++ b/data/import/common/common/marketplace/product_stock.csv @@ -278,7 +278,7 @@ concrete_sku,name,quantity,is_never_out_of_stock,is_bundle 195_25904159,Video King MER000002 Warehouse 1,10,0,0 196_23120327,Video King MER000002 Warehouse 1,10,0,0 196_23120327,Spryker MER000001 Warehouse 1,10,0,0 -197_21421718,Video King MER000002 Warehouse 1,10,0,0 +197_21421718,Video King MER000002 Warehouse 1,10,1,0 198_19692589,Video King MER000002 Warehouse 1,10,0,0 199_7016823,Video King MER000002 Warehouse 1,10,0,0 199_24788780,Video King MER000002 Warehouse 1,10,0,0 diff --git a/deploy.acp-dev.franken.dms.yml b/deploy.acp-dev.franken.dms.yml index dc8dbea4cd..3b59bbbf25 100644 --- a/deploy.acp-dev.franken.dms.yml +++ b/deploy.acp-dev.franken.dms.yml @@ -32,11 +32,11 @@ image: "APP_DOMAINS": ["apps.spryker.local", "*.bazaarvoice.com"], "STORE_NAME_REFERENCE_MAP": {}, "APP_CATALOG_SCRIPT_URL": "", - "PAYONE_APP_IDENTIFIER": "app-098aa300-2e3d-5a32-89c6-d79c45f15cd4", - "BAZAARVOICE_APP_IDENTIFIER": "app-b72fa702-7d8e-5d14-92b9-b8c9ad9c7066", - "USERCENTRICS_APP_IDENTIFIER": "app-804ebe5b-00f5-5121-9f90-29301d033dbb", - "ALGOLIA_APP_IDENTIFIER": "app-12470c65-13c1-4e1f-b48a-711196a22511", - "VERTEX_APP_IDENTIFIER": "app-7ff8d24e-4ea1-4440-b760-0aa92e60405b" + "PAYONE_APP_IDENTIFIER": "098aa300-2e3d-5a32-89c6-d79c45f15cd4", + "BAZAARVOICE_APP_IDENTIFIER": "b72fa702-7d8e-5d14-92b9-b8c9ad9c7066", + "USERCENTRICS_APP_IDENTIFIER": "804ebe5b-00f5-5121-9f90-29301d033dbb", + "ALGOLIA_APP_IDENTIFIER": "12470c65-13c1-4e1f-b48a-711196a22511", + "VERTEX_APP_IDENTIFIER": "7ff8d24e-4ea1-4440-b760-0aa92e60405b" }' SPRYKER_AOP_AUTHENTICATION: '{ "AUTH0_CUSTOM_DOMAIN": "", diff --git a/deploy.acp-dev.franken.mb1.yml b/deploy.acp-dev.franken.mb1.yml index 34c2202b0a..1c9b434c88 100644 --- a/deploy.acp-dev.franken.mb1.yml +++ b/deploy.acp-dev.franken.mb1.yml @@ -25,11 +25,11 @@ image: "APP_DOMAINS": ["apps.spryker.local", "*.bazaarvoice.com"], "STORE_NAME_REFERENCE_MAP": {}, "APP_CATALOG_SCRIPT_URL": "", - "PAYONE_APP_IDENTIFIER": "app-098aa300-2e3d-5a32-89c6-d79c45f15cd4", - "BAZAARVOICE_APP_IDENTIFIER": "app-b72fa702-7d8e-5d14-92b9-b8c9ad9c7066", - "USERCENTRICS_APP_IDENTIFIER": "app-804ebe5b-00f5-5121-9f90-29301d033dbb", - "ALGOLIA_APP_IDENTIFIER": "app-12470c65-13c1-4e1f-b48a-711196a22511", - "VERTEX_APP_IDENTIFIER": "app-7ff8d24e-4ea1-4440-b760-0aa92e60405b" + "PAYONE_APP_IDENTIFIER": "098aa300-2e3d-5a32-89c6-d79c45f15cd4", + "BAZAARVOICE_APP_IDENTIFIER": "b72fa702-7d8e-5d14-92b9-b8c9ad9c7066", + "USERCENTRICS_APP_IDENTIFIER": "804ebe5b-00f5-5121-9f90-29301d033dbb", + "ALGOLIA_APP_IDENTIFIER": "12470c65-13c1-4e1f-b48a-711196a22511", + "VERTEX_APP_IDENTIFIER": "7ff8d24e-4ea1-4440-b760-0aa92e60405b" }' SPRYKER_AOP_AUTHENTICATION: '{ "AUTH0_CUSTOM_DOMAIN": "", diff --git a/deploy.acp-dev.franken.mb2.yml b/deploy.acp-dev.franken.mb2.yml index 427780a65f..b6ee169d55 100644 --- a/deploy.acp-dev.franken.mb2.yml +++ b/deploy.acp-dev.franken.mb2.yml @@ -23,11 +23,11 @@ image: "APP_DOMAINS": ["apps.spryker.local", "*.bazaarvoice.com"], "STORE_NAME_REFERENCE_MAP": {}, "APP_CATALOG_SCRIPT_URL": "", - "PAYONE_APP_IDENTIFIER": "app-098aa300-2e3d-5a32-89c6-d79c45f15cd4", - "BAZAARVOICE_APP_IDENTIFIER": "app-b72fa702-7d8e-5d14-92b9-b8c9ad9c7066", - "USERCENTRICS_APP_IDENTIFIER": "app-804ebe5b-00f5-5121-9f90-29301d033dbb", - "ALGOLIA_APP_IDENTIFIER": "app-12470c65-13c1-4e1f-b48a-711196a22511", - "VERTEX_APP_IDENTIFIER": "app-7ff8d24e-4ea1-4440-b760-0aa92e60405b" + "PAYONE_APP_IDENTIFIER": "098aa300-2e3d-5a32-89c6-d79c45f15cd4", + "BAZAARVOICE_APP_IDENTIFIER": "b72fa702-7d8e-5d14-92b9-b8c9ad9c7066", + "USERCENTRICS_APP_IDENTIFIER": "804ebe5b-00f5-5121-9f90-29301d033dbb", + "ALGOLIA_APP_IDENTIFIER": "12470c65-13c1-4e1f-b48a-711196a22511", + "VERTEX_APP_IDENTIFIER": "7ff8d24e-4ea1-4440-b760-0aa92e60405b" }' SPRYKER_AOP_AUTHENTICATION: '{ "AUTH0_CUSTOM_DOMAIN": "", diff --git a/deploy.acp-dev.standalone.yml b/deploy.acp-dev.standalone.yml index 12519d25c9..475ac89f01 100644 --- a/deploy.acp-dev.standalone.yml +++ b/deploy.acp-dev.standalone.yml @@ -25,11 +25,11 @@ image: "APP_DOMAINS": ["apps.spryker.local", "*.bazaarvoice.com"], "STORE_NAME_REFERENCE_MAP": {}, "APP_CATALOG_SCRIPT_URL": "", - "PAYONE_APP_IDENTIFIER": "app-098aa300-2e3d-5a32-89c6-d79c45f15cd4", - "BAZAARVOICE_APP_IDENTIFIER": "app-b72fa702-7d8e-5d14-92b9-b8c9ad9c7066", - "USERCENTRICS_APP_IDENTIFIER": "app-804ebe5b-00f5-5121-9f90-29301d033dbb", - "ALGOLIA_APP_IDENTIFIER": "app-12470c65-13c1-4e1f-b48a-711196a22511", - "VERTEX_APP_IDENTIFIER": "app-7ff8d24e-4ea1-4440-b760-0aa92e60405b" + "PAYONE_APP_IDENTIFIER": "098aa300-2e3d-5a32-89c6-d79c45f15cd4", + "BAZAARVOICE_APP_IDENTIFIER": "b72fa702-7d8e-5d14-92b9-b8c9ad9c7066", + "USERCENTRICS_APP_IDENTIFIER": "804ebe5b-00f5-5121-9f90-29301d033dbb", + "ALGOLIA_APP_IDENTIFIER": "12470c65-13c1-4e1f-b48a-711196a22511", + "VERTEX_APP_IDENTIFIER": "7ff8d24e-4ea1-4440-b760-0aa92e60405b" }' SPRYKER_AOP_AUTHENTICATION: '{ "AUTH0_CUSTOM_DOMAIN": "", diff --git a/src/Pyz/Zed/MessageBroker/MessageBrokerConfig.php b/src/Pyz/Zed/MessageBroker/MessageBrokerConfig.php index 92a7283158..db664e5957 100644 --- a/src/Pyz/Zed/MessageBroker/MessageBrokerConfig.php +++ b/src/Pyz/Zed/MessageBroker/MessageBrokerConfig.php @@ -33,6 +33,21 @@ public function getDefaultWorkerChannels(): array ]; } + /** + * {@inheritDoc} + * - The list below is used strictly recommended to leave as is. + * + * @api + * + * @return list + */ + public function getSystemWorkerChannels(): array + { + return [ + 'app-events', + ]; + } + /** * {@inheritDoc} * diff --git a/src/Pyz/Zed/MessageBroker/MessageBrokerDependencyProvider.php b/src/Pyz/Zed/MessageBroker/MessageBrokerDependencyProvider.php index 4f32a25ee2..7daa164a23 100644 --- a/src/Pyz/Zed/MessageBroker/MessageBrokerDependencyProvider.php +++ b/src/Pyz/Zed/MessageBroker/MessageBrokerDependencyProvider.php @@ -10,6 +10,7 @@ namespace Pyz\Zed\MessageBroker; use Spryker\Zed\Asset\Communication\Plugin\MessageBroker\AssetMessageHandlerPlugin; +use Spryker\Zed\KernelApp\Communication\Plugin\MessageBroker\ActiveAppFilterMessageChannelPlugin; use Spryker\Zed\KernelApp\Communication\Plugin\MessageBroker\AppConfigMessageHandlerPlugin; use Spryker\Zed\MerchantApp\Communication\Plugin\MessageBroker\MerchantAppOnboardingMessageHandlerPlugin; use Spryker\Zed\MessageBroker\Communication\Plugin\MessageBroker\CorrelationIdMessageAttributeProviderPlugin; @@ -133,4 +134,14 @@ public function getExternalValidatorPlugins(): array new StoreReferenceMessageValidatorPlugin(), ]; } + + /** + * @return array<\Spryker\Zed\MessageBrokerExtension\Dependency\Plugin\FilterMessageChannelPluginInterface> + */ + public function getFilterMessageChannelPlugins(): array + { + return [ + new ActiveAppFilterMessageChannelPlugin(), + ]; + } } diff --git a/tests/PyzTest/Zed/MessageBroker/Business/SendMessageTest.php b/tests/PyzTest/Zed/MessageBroker/Business/SendMessageTest.php index f9c01fe1c0..fa078d31c8 100644 --- a/tests/PyzTest/Zed/MessageBroker/Business/SendMessageTest.php +++ b/tests/PyzTest/Zed/MessageBroker/Business/SendMessageTest.php @@ -52,7 +52,7 @@ public function testCheckAttributesBeforeSendingMessage(): void // Arrange $messageSenderPlugin = $this->createMock(MessageSenderPluginInterface::class); - $this->tester->setupMessageBrokerValidationPlugins(); + $this->tester->setupMessageBrokerPlugins(); $this->tester->setMessageToSenderChannelNameMap(MessageBrokerTestMessageTransfer::class, static::CHANNEL_NAME); $this->tester->setChannelToTransportMap(static::CHANNEL_NAME, $messageSenderPlugin->getTransportName()); diff --git a/tests/PyzTest/Zed/MessageBroker/MessageHandlers/Asset/Communication/AssetMessageTest.php b/tests/PyzTest/Zed/MessageBroker/MessageHandlers/Asset/Communication/AssetMessageTest.php index e8fbd951c7..6981a32574 100644 --- a/tests/PyzTest/Zed/MessageBroker/MessageHandlers/Asset/Communication/AssetMessageTest.php +++ b/tests/PyzTest/Zed/MessageBroker/MessageHandlers/Asset/Communication/AssetMessageTest.php @@ -52,7 +52,7 @@ public function testAssetAddedMessageIsSuccessfullyHandled(): void // Act $this->tester->setupMessageBroker($assetAddedTransfer::class, $channelName); - $this->tester->setupMessageBrokerValidationPlugins(); + $this->tester->setupMessageBrokerPlugins(); $messageBrokerFacade = $this->tester->getLocator()->messageBroker()->facade(); $messageBrokerFacade->sendMessage($assetAddedTransfer); $messageBrokerFacade->startWorker($this->tester->buildMessageBrokerWorkerConfigTransfer([$channelName], 1)); @@ -74,7 +74,7 @@ public function testAssetUpdatedMessageIsSuccessfullyHandled(): void $slotName = 'header-top'; $this->tester->setupMessageBroker(AssetAddedTransfer::class, $channelName); - $this->tester->setupMessageBrokerValidationPlugins(); + $this->tester->setupMessageBrokerPlugins(); $messageBrokerFacade = $this->tester->getLocator()->messageBroker()->facade(); $messageBrokerWorkerConfigTransfer = $this->tester->buildMessageBrokerWorkerConfigTransfer([$channelName], 1); $messageBrokerFacade->sendMessage( @@ -112,7 +112,7 @@ public function testAssetDeletedMessageIsSuccessfullyHandled(): void $assetUuid = Uuid::uuid4()->toString(); $this->tester->setupMessageBroker(AssetAddedTransfer::class, $channelName); - $this->tester->setupMessageBrokerValidationPlugins(); + $this->tester->setupMessageBrokerPlugins(); $messageBrokerFacade = $this->tester->getLocator()->messageBroker()->facade(); $messageBrokerWorkerConfigTransfer = $this->tester->buildMessageBrokerWorkerConfigTransfer([$channelName], 1); $messageBrokerFacade->sendMessage( diff --git a/tests/PyzTest/Zed/MessageBroker/MessageHandlers/PaymentMethod/Presentation/PaymentMethodMessageCest.php b/tests/PyzTest/Zed/MessageBroker/MessageHandlers/PaymentMethod/Presentation/PaymentMethodMessageCest.php index ab01efc394..839fc8d465 100644 --- a/tests/PyzTest/Zed/MessageBroker/MessageHandlers/PaymentMethod/Presentation/PaymentMethodMessageCest.php +++ b/tests/PyzTest/Zed/MessageBroker/MessageHandlers/PaymentMethod/Presentation/PaymentMethodMessageCest.php @@ -58,6 +58,7 @@ public function testAddPaymentMethodMessageIsSuccessfullyHandled(PaymentMethodPr $channelName = 'payment-method-commands'; $I->setupMessageBroker(AddPaymentMethodTransfer::class, $channelName); $I->setDependency(MessageBrokerDependencyProvider::PLUGINS_EXTERNAL_VALIDATOR, []); + $I->setDependency(MessageBrokerDependencyProvider::PLUGINS_FILTER_MESSAGE_CHANNEL, []); $messageBrokerFacade->sendMessage( $I->haveAddPaymentMethodTransfer( [ @@ -100,6 +101,7 @@ public function testPaymentMethodRemovedMessageIsSuccessfullyHandled(PaymentMeth $channelName = 'payment-method-commands'; $I->setupMessageBroker(AddPaymentMethodTransfer::class, $channelName); $I->setDependency(MessageBrokerDependencyProvider::PLUGINS_EXTERNAL_VALIDATOR, []); + $I->setDependency(MessageBrokerDependencyProvider::PLUGINS_FILTER_MESSAGE_CHANNEL, []); $messageBrokerFacade->sendMessage( $I->haveAddPaymentMethodTransfer( [ diff --git a/tests/PyzTest/Zed/MessageBroker/MessageHandlers/Product/Communication/InitializeProductExportMessageTest.php b/tests/PyzTest/Zed/MessageBroker/MessageHandlers/Product/Communication/InitializeProductExportMessageTest.php index ae77cc25f0..27e2109dae 100644 --- a/tests/PyzTest/Zed/MessageBroker/MessageHandlers/Product/Communication/InitializeProductExportMessageTest.php +++ b/tests/PyzTest/Zed/MessageBroker/MessageHandlers/Product/Communication/InitializeProductExportMessageTest.php @@ -66,7 +66,7 @@ public function testInitializeProductExportMessageIsSuccessfullyHandled(): void // Act $this->tester->setupMessageBroker(InitializeProductExportTransfer::class, $channelName); - $this->tester->setupMessageBrokerValidationPlugins(); + $this->tester->setupMessageBrokerPlugins(); $messageBrokerFacade = $this->tester->getLocator()->messageBroker()->facade(); $messageBrokerFacade->sendMessage( $this->tester->buildInitializeProductExportTransfer(), diff --git a/tests/PyzTest/Zed/MessageBroker/MessageHandlers/ProductReview/Communication/AddReviewsMessageTest.php b/tests/PyzTest/Zed/MessageBroker/MessageHandlers/ProductReview/Communication/AddReviewsMessageTest.php index b40e75686a..4153e3dfdb 100644 --- a/tests/PyzTest/Zed/MessageBroker/MessageHandlers/ProductReview/Communication/AddReviewsMessageTest.php +++ b/tests/PyzTest/Zed/MessageBroker/MessageHandlers/ProductReview/Communication/AddReviewsMessageTest.php @@ -44,7 +44,7 @@ public function testAddReviewsMessageIsSuccessfullyHandled(): void // Act $this->tester->setupMessageBroker($addReviewsTransfer::class, $channelName); - $this->tester->setupMessageBrokerValidationPlugins(); + $this->tester->setupMessageBrokerPlugins(); $messageBrokerFacade = $this->tester->getLocator()->messageBroker()->facade(); $messageBrokerFacade->sendMessage($addReviewsTransfer); $messageBrokerFacade->startWorker($this->tester->buildMessageBrokerWorkerConfigTransfer([$channelName], 1)); diff --git a/tests/PyzTest/Zed/MessageBroker/_support/Helper/MessageBrokerHelper.php b/tests/PyzTest/Zed/MessageBroker/_support/Helper/MessageBrokerHelper.php index f73e866798..7b8e8998f6 100644 --- a/tests/PyzTest/Zed/MessageBroker/_support/Helper/MessageBrokerHelper.php +++ b/tests/PyzTest/Zed/MessageBroker/_support/Helper/MessageBrokerHelper.php @@ -20,8 +20,9 @@ class MessageBrokerHelper extends Module /** * @return void */ - public function setupMessageBrokerValidationPlugins(): void + public function setupMessageBrokerPlugins(): void { $this->getDependencyProviderHelper()->setDependency(MessageBrokerDependencyProvider::PLUGINS_EXTERNAL_VALIDATOR, []); + $this->getDependencyProviderHelper()->setDependency(MessageBrokerDependencyProvider::PLUGINS_FILTER_MESSAGE_CHANNEL, []); } } diff --git a/tests/PyzTest/Zed/MessageBroker/_support/PaymentPresentationTester.php b/tests/PyzTest/Zed/MessageBroker/_support/PaymentPresentationTester.php index e6db8d3799..903a421195 100644 --- a/tests/PyzTest/Zed/MessageBroker/_support/PaymentPresentationTester.php +++ b/tests/PyzTest/Zed/MessageBroker/_support/PaymentPresentationTester.php @@ -94,7 +94,7 @@ public function handlePaymentMessageTransfer(TransferInterface $paymentMessageTr { $channelName = 'payment-commands'; $this->setupMessageBroker($paymentMessageTransfer::class, $channelName); - $this->setupMessageBrokerValidationPlugins(); + $this->setupMessageBrokerPlugins(); $messageBrokerFacade = $this->getLocator()->messageBroker()->facade(); $messageBrokerFacade->sendMessage($paymentMessageTransfer); $messageBrokerFacade->startWorker( diff --git a/tests/PyzTest/Zed/MessageBroker/_support/SearchHttpCommunicationTester.php b/tests/PyzTest/Zed/MessageBroker/_support/SearchHttpCommunicationTester.php index 5c509b1b84..ed99d13a6a 100644 --- a/tests/PyzTest/Zed/MessageBroker/_support/SearchHttpCommunicationTester.php +++ b/tests/PyzTest/Zed/MessageBroker/_support/SearchHttpCommunicationTester.php @@ -99,7 +99,7 @@ public function handleSearchMessage(TransferInterface $searchMessageTransfer): v { $channelName = 'search-commands'; $this->setupMessageBroker($searchMessageTransfer::class, $channelName); - $this->setupMessageBrokerValidationPlugins(); + $this->setupMessageBrokerPlugins(); $messageBrokerFacade = $this->getLocator()->messageBroker()->facade(); $messageBrokerFacade->sendMessage($searchMessageTransfer); $messageBrokerFacade->startWorker( diff --git a/tests/PyzTest/Zed/MessageBroker/_support/TaxAppCommunicationTester.php b/tests/PyzTest/Zed/MessageBroker/_support/TaxAppCommunicationTester.php index bc9cad40a8..463d67c9e1 100644 --- a/tests/PyzTest/Zed/MessageBroker/_support/TaxAppCommunicationTester.php +++ b/tests/PyzTest/Zed/MessageBroker/_support/TaxAppCommunicationTester.php @@ -119,7 +119,7 @@ public function handleTaxAppMessage(TransferInterface $configureTaxAppMessage): { $channelName = 'tax-commands'; $this->setupMessageBroker($configureTaxAppMessage::class, $channelName); - $this->setupMessageBrokerValidationPlugins(); + $this->setupMessageBrokerPlugins(); $messageBrokerFacade = $this->getLocator()->messageBroker()->facade(); $messageBrokerFacade->sendMessage($configureTaxAppMessage); $messageBrokerFacade->startWorker( diff --git a/tests/PyzTest/Zed/TaxApp/_support/TaxAppTester.php b/tests/PyzTest/Zed/TaxApp/_support/TaxAppTester.php index c17abd88ab..e0dfc36ba1 100644 --- a/tests/PyzTest/Zed/TaxApp/_support/TaxAppTester.php +++ b/tests/PyzTest/Zed/TaxApp/_support/TaxAppTester.php @@ -117,7 +117,7 @@ public function handleTaxAppMessage(TransferInterface $configureTaxAppMessage): { $channelName = 'tax-commands'; $this->setupMessageBroker($configureTaxAppMessage::class, $channelName); - $this->setupMessageBrokerValidationPlugins(); + $this->setupMessageBrokerPlugins(); $messageBrokerFacade = $this->getLocator()->messageBroker()->facade(); $messageBrokerFacade->sendMessage($configureTaxAppMessage); $messageBrokerFacade->startWorker(