diff --git a/README.md b/README.md index 6d597a9c..da72a41a 100644 --- a/README.md +++ b/README.md @@ -99,12 +99,14 @@ for more details on specific ones. ## Installation +### 1. To install Ibexa Search Extra first add it as a dependency to your project: ```sh composer require netgen/ibexa-search-extra:^3.0 ``` +### 2. Once the added dependency is installed, activate the bundle in `config/bundles.php` file by adding it to the returned array, together with other required bundles: ```php @@ -116,3 +118,43 @@ return [ Netgen\Bundle\IbexaSearchExtraBundle\NetgenIbexaSearchExtraBundle::class => ['all' => true], } ``` + + +### 3. +Routing needs to be setup in project. It maps message to the queue/queues it needs to go in. +If you want async indexing for all events, just add this routing: + +```yaml +messenger: + routing: + 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\Content\CopyContent': netgen_ibexa_search_extra_asynchronous_indexing + 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\Content\DeleteContent': netgen_ibexa_search_extra_asynchronous_indexing + 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\Content\DeleteTranslation': netgen_ibexa_search_extra_asynchronous_indexing + 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\Content\HideContent': netgen_ibexa_search_extra_asynchronous_indexing + 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\Content\PublishVersion': netgen_ibexa_search_extra_asynchronous_indexing + 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\Content\RevealContent': netgen_ibexa_search_extra_asynchronous_indexing + 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\Content\UpdateContentMetadata': netgen_ibexa_search_extra_asynchronous_indexing + 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\Location\AssignSectionToSubtree': netgen_ibexa_search_extra_asynchronous_indexing + 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\Location\CopySubtree': netgen_ibexa_search_extra_asynchronous_indexing + 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\Location\CreateLocation': netgen_ibexa_search_extra_asynchronous_indexing + 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\Location\DeleteLocation': netgen_ibexa_search_extra_asynchronous_indexing + 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\Location\HideLocation': netgen_ibexa_search_extra_asynchronous_indexing + 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\Location\MoveSubtree': netgen_ibexa_search_extra_asynchronous_indexing + 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\Location\SwapLocation': netgen_ibexa_search_extra_asynchronous_indexing + 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\Location\UnhideLocation': netgen_ibexa_search_extra_asynchronous_indexing + 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\Location\UpdateLocation': netgen_ibexa_search_extra_asynchronous_indexing + 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\ObjectState\SetContentState': netgen_ibexa_search_extra_asynchronous_indexing + 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\Section\AssignSection': netgen_ibexa_search_extra_asynchronous_indexing + 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\Trash\Recover': netgen_ibexa_search_extra_asynchronous_indexing + 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\Trash\Trash': netgen_ibexa_search_extra_asynchronous_indexing + 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\User\AssignUserToUserGroup': netgen_ibexa_search_extra_asynchronous_indexing + 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\User\BeforeUnAssignUserFromUserGroup': netgen_ibexa_search_extra_asynchronous_indexing + 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\User\CreateUserGroup': netgen_ibexa_search_extra_asynchronous_indexing + 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\User\CreateUser': netgen_ibexa_search_extra_asynchronous_indexing + 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\User\DeleteUserGroup': netgen_ibexa_search_extra_asynchronous_indexing + 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\User\DeleteUser': netgen_ibexa_search_extra_asynchronous_indexing + 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\User\MoveUserGroup': netgen_ibexa_search_extra_asynchronous_indexing + 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\User\UnAssignUserFromUserGroup': netgen_ibexa_search_extra_asynchronous_indexing + 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\User\UpdateUserGroup': netgen_ibexa_search_extra_asynchronous_indexing + 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\User\UpdateUser': netgen_ibexa_search_extra_asynchronous_indexing +``` \ No newline at end of file diff --git a/bundle/Resources/config/messenger.yaml b/bundle/Resources/config/messenger.yaml index cf818449..774c1ed5 100644 --- a/bundle/Resources/config/messenger.yaml +++ b/bundle/Resources/config/messenger.yaml @@ -12,37 +12,6 @@ messenger: redeliver_timeout: 300 queue_name: netgen_ibexa_search_extra_asynchronous_indexing netgen_ibexa_search_extra_asynchronous_indexing_failed: "doctrine://default?queue_name=netgen_ibexa_search_extra_asynchronous_indexing_failed" - routing: - 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\Content\CopyContent': netgen_ibexa_search_extra_asynchronous_indexing - 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\Content\DeleteContent': netgen_ibexa_search_extra_asynchronous_indexing - 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\Content\DeleteTranslation': netgen_ibexa_search_extra_asynchronous_indexing - 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\Content\HideContent': netgen_ibexa_search_extra_asynchronous_indexing - 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\Content\PublishVersion': netgen_ibexa_search_extra_asynchronous_indexing - 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\Content\RevealContent': netgen_ibexa_search_extra_asynchronous_indexing - 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\Content\UpdateContentMetadata': netgen_ibexa_search_extra_asynchronous_indexing - 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\Location\AssignSectionToSubtree': netgen_ibexa_search_extra_asynchronous_indexing - 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\Location\CopySubtree': netgen_ibexa_search_extra_asynchronous_indexing - 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\Location\CreateLocation': netgen_ibexa_search_extra_asynchronous_indexing - 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\Location\DeleteLocation': netgen_ibexa_search_extra_asynchronous_indexing - 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\Location\HideLocation': netgen_ibexa_search_extra_asynchronous_indexing - 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\Location\MoveSubtree': netgen_ibexa_search_extra_asynchronous_indexing - 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\Location\SwapLocation': netgen_ibexa_search_extra_asynchronous_indexing - 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\Location\UnhideLocation': netgen_ibexa_search_extra_asynchronous_indexing - 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\Location\UpdateLocation': netgen_ibexa_search_extra_asynchronous_indexing - 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\ObjectState\SetContentState': netgen_ibexa_search_extra_asynchronous_indexing - 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\Section\AssignSection': netgen_ibexa_search_extra_asynchronous_indexing - 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\Trash\Recover': netgen_ibexa_search_extra_asynchronous_indexing - 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\Trash\Trash': netgen_ibexa_search_extra_asynchronous_indexing - 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\User\AssignUserToUserGroup': netgen_ibexa_search_extra_asynchronous_indexing - 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\User\BeforeUnAssignUserFromUserGroup': netgen_ibexa_search_extra_asynchronous_indexing - 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\User\CreateUserGroup': netgen_ibexa_search_extra_asynchronous_indexing - 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\User\CreateUser': netgen_ibexa_search_extra_asynchronous_indexing - 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\User\DeleteUserGroup': netgen_ibexa_search_extra_asynchronous_indexing - 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\User\DeleteUser': netgen_ibexa_search_extra_asynchronous_indexing - 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\User\MoveUserGroup': netgen_ibexa_search_extra_asynchronous_indexing - 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\User\UnAssignUserFromUserGroup': netgen_ibexa_search_extra_asynchronous_indexing - 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\User\UpdateUserGroup': netgen_ibexa_search_extra_asynchronous_indexing - 'Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\Message\Search\User\UpdateUser': netgen_ibexa_search_extra_asynchronous_indexing default_bus: messenger.bus.default buses: messenger.bus.default: ~ diff --git a/lib/Resources/config/search/common/asynchronous_indexing/common.yaml b/lib/Resources/config/search/common/asynchronous_indexing/common.yaml index b02b4075..ad925007 100644 --- a/lib/Resources/config/search/common/asynchronous_indexing/common.yaml +++ b/lib/Resources/config/search/common/asynchronous_indexing/common.yaml @@ -1,5 +1,6 @@ services: - Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\SubtreeIndexer: + netgen.search_extra.message_handler.subtree_index: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\SubtreeIndexer arguments: - '@Ibexa\Contracts\Core\Persistence\Content\Handler' - '@Ibexa\Contracts\Core\Persistence\Content\Location\Handler' @@ -8,7 +9,8 @@ services: tags: - { name: monolog.logger, channel: ngsearchextra } - Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\UserContentWithLocationIndexer: + netgen.search_extra.message_handler.user_content_with_location_indexer: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\UserContentWithLocationIndexer arguments: - '@Ibexa\Contracts\Core\Persistence\Content\Handler' - '@Ibexa\Contracts\Core\Persistence\Content\Location\Handler' diff --git a/lib/Resources/config/search/common/asynchronous_indexing/content.yaml b/lib/Resources/config/search/common/asynchronous_indexing/content.yaml index ea303fb8..cafe00bb 100644 --- a/lib/Resources/config/search/common/asynchronous_indexing/content.yaml +++ b/lib/Resources/config/search/common/asynchronous_indexing/content.yaml @@ -1,60 +1,135 @@ services: - Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Content\CopyContentHandler: + netgen.search_extra.message_handler.copy_content: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Content\CopyContentHandler arguments: - '@Ibexa\Contracts\Core\Persistence\Content\Handler' - '@Ibexa\Contracts\Core\Persistence\Content\Location\Handler' - '@ibexa.spi.search' - '@?logger' tags: - - { name: messenger.message_handler } + - { name: messenger.message_handler, from_transport: netgen_ibexa_search_extra_asynchronous_indexing} - { name: monolog.logger, channel: ngsearchextra } - Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Content\DeleteContentHandler: + netgen.search_extra.message_handler.copy_content_sync: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Content\CopyContentHandler + arguments: + - '@Ibexa\Contracts\Core\Persistence\Content\Handler' + - '@Ibexa\Contracts\Core\Persistence\Content\Location\Handler' + - '@ibexa.spi.search' + - '@?logger' + tags: + - { name: messenger.message_handler, from_transport: sync } + - { name: monolog.logger, channel: ngsearchextra } + + netgen.search_extra.message_handler.delete_content: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Content\DeleteContentHandler arguments: - '@ibexa.spi.search' tags: - - { name: messenger.message_handler } + - { name: messenger.message_handler, from_transport: netgen_ibexa_search_extra_asynchronous_indexing} - Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Content\DeleteTranslationHandler: + netgen.search_extra.message_handler.delete_content_sync: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Content\DeleteContentHandler + arguments: + - '@ibexa.spi.search' + tags: + - { name: messenger.message_handler, from_transport: sync } + + + netgen.search_extra.message_handler.delete_translation: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Content\DeleteTranslationHandler arguments: - '@Ibexa\Contracts\Core\Persistence\Content\Handler' - '@Ibexa\Contracts\Core\Persistence\Content\Location\Handler' - '@ibexa.spi.search' - '@?logger' tags: - - { name: messenger.message_handler } + - { name: messenger.message_handler, from_transport: netgen_ibexa_search_extra_asynchronous_indexing} - { name: monolog.logger, channel: ngsearchextra } - Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Content\HideContentHandler: + netgen.search_extra.message_handler.delete_translation_sync: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Content\DeleteTranslationHandler arguments: + - '@Ibexa\Contracts\Core\Persistence\Content\Handler' - '@Ibexa\Contracts\Core\Persistence\Content\Location\Handler' - - '@Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\SubtreeIndexer' + - '@ibexa.spi.search' + - '@?logger' tags: - - { name: messenger.message_handler } + - { name: messenger.message_handler, from_transport: sync} + - { name: monolog.logger, channel: ngsearchextra } - Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Content\PublishVersionHandler: + netgen.search_extra.message_handler.hide_content: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Content\HideContentHandler + arguments: + - '@Ibexa\Contracts\Core\Persistence\Content\Location\Handler' + - '@netgen.search_extra.message_handler.subtree_index' + tags: + - { name: messenger.message_handler, from_transport: netgen_ibexa_search_extra_asynchronous_indexing} + + netgen.search_extra.message_handler.hide_content_sync: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Content\HideContentHandler + arguments: + - '@Ibexa\Contracts\Core\Persistence\Content\Location\Handler' + - '@netgen.search_extra.message_handler.subtree_index' + tags: + - { name: messenger.message_handler, from_transport: sync } + + netgen.search_extra.message_handler.publish_version: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Content\PublishVersionHandler arguments: - '@Ibexa\Contracts\Core\Persistence\Content\Handler' - '@Ibexa\Contracts\Core\Persistence\Content\Location\Handler' - '@ibexa.spi.search' - '@?logger' tags: - - { name: messenger.message_handler } + - { name: messenger.message_handler, from_transport: netgen_ibexa_search_extra_asynchronous_indexing } - { name: monolog.logger, channel: ngsearchextra } - Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Content\RevealContentHandler: + netgen.search_extra.message_handler.publish_version_sync: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Content\PublishVersionHandler + arguments: + - '@Ibexa\Contracts\Core\Persistence\Content\Handler' + - '@Ibexa\Contracts\Core\Persistence\Content\Location\Handler' + - '@ibexa.spi.search' + - '@?logger' + tags: + - { name: messenger.message_handler, from_transport: sync } + - { name: monolog.logger, channel: ngsearchextra } + + netgen.search_extra.message_handler.reveal_content: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Content\RevealContentHandler + arguments: + - '@Ibexa\Contracts\Core\Persistence\Content\Location\Handler' + - '@netgen.search_extra.message_handler.subtree_index' + tags: + - { name: messenger.message_handler, from_transport: netgen_ibexa_search_extra_asynchronous_indexing } + + netgen.search_extra.message_handler.reveal_content_sync: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Content\RevealContentHandler arguments: - '@Ibexa\Contracts\Core\Persistence\Content\Location\Handler' - - '@Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\SubtreeIndexer' + - '@netgen.search_extra.message_handler.subtree_index' tags: - - { name: messenger.message_handler } + - { name: messenger.message_handler, from_transport: sync } + + netgen.search_extra.message_handler.update_content: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Content\UpdateContentMetadataHandler + arguments: + - '@Ibexa\Contracts\Core\Persistence\Content\Handler' + - '@Ibexa\Contracts\Core\Persistence\Content\Location\Handler' + - '@ibexa.spi.search' + - '@?logger' + tags: + - { name: messenger.message_handler, from_transport: netgen_ibexa_search_extra_asynchronous_indexing } + - { name: monolog.logger, channel: ngsearchextra } - Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Content\UpdateContentMetadataHandler: + netgen.search_extra.message_handler.update_content_sync: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Content\UpdateContentMetadataHandler arguments: - '@Ibexa\Contracts\Core\Persistence\Content\Handler' - '@Ibexa\Contracts\Core\Persistence\Content\Location\Handler' - '@ibexa.spi.search' - '@?logger' tags: - - { name: messenger.message_handler } + - { name: messenger.message_handler, from_transport: sync } - { name: monolog.logger, channel: ngsearchextra } diff --git a/lib/Resources/config/search/common/asynchronous_indexing/location.yaml b/lib/Resources/config/search/common/asynchronous_indexing/location.yaml index 287eb478..20e4bd7f 100644 --- a/lib/Resources/config/search/common/asynchronous_indexing/location.yaml +++ b/lib/Resources/config/search/common/asynchronous_indexing/location.yaml @@ -1,67 +1,152 @@ services: - Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Location\AssignSectionToSubtreeHandler: + netgen.search_extra.message_handler.location_assign_section_to_subtree: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Location\AssignSectionToSubtreeHandler arguments: - - '@Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\SubtreeIndexer' + - '@netgen.search_extra.message_handler.subtree_index' tags: - - { name: messenger.message_handler } + - { name: messenger.message_handler, from_transport: netgen_ibexa_search_extra_asynchronous_indexing } - Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Location\CopySubtreeHandler: + netgen.search_extra.message_handler.location_assign_section_to_subtree_sync: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Location\AssignSectionToSubtreeHandler arguments: - - '@Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\SubtreeIndexer' + - '@netgen.search_extra.message_handler.subtree_index' tags: - - { name: messenger.message_handler } + - { name: messenger.message_handler, from_transport: sync } - Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Location\CreateLocationHandler: + netgen.search_extra.message_handler.location_copy_subtree: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Location\CopySubtreeHandler + arguments: + - '@netgen.search_extra.message_handler.subtree_index' + tags: + - { name: messenger.message_handler, from_transport: netgen_ibexa_search_extra_asynchronous_indexing } + + netgen.search_extra.message_handler.location_copy_subtree_sync: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Location\CopySubtreeHandler + arguments: + - '@netgen.search_extra.message_handler.subtree_index' + tags: + - { name: messenger.message_handler, from_transport: sync } + + netgen.search_extra.message_handler.create_location: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Location\CreateLocationHandler + arguments: + - '@Ibexa\Contracts\Core\Persistence\Content\Handler' + - '@Ibexa\Contracts\Core\Persistence\Content\Location\Handler' + - '@ibexa.spi.search' + - '@?logger' + tags: + - { name: messenger.message_handler, from_transport: netgen_ibexa_search_extra_asynchronous_indexing } + - { name: monolog.logger, channel: ngsearchextra } + + netgen.search_extra.message_handler.create_location_sync: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Location\CreateLocationHandler arguments: - '@Ibexa\Contracts\Core\Persistence\Content\Handler' - '@Ibexa\Contracts\Core\Persistence\Content\Location\Handler' - '@ibexa.spi.search' - '@?logger' tags: - - { name: messenger.message_handler } + - { name: messenger.message_handler, from_transport: sync } - { name: monolog.logger, channel: ngsearchextra } - Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Location\DeleteLocationHandler: + netgen.search_extra.message_handler.delete_location: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Location\DeleteLocationHandler arguments: - '@ibexa.spi.search' tags: - - { name: messenger.message_handler } + - { name: messenger.message_handler, from_transport: netgen_ibexa_search_extra_asynchronous_indexing} + + netgen.search_extra.message_handler.delete_location_sync: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Location\DeleteLocationHandler + arguments: + - '@ibexa.spi.search' + tags: + - { name: messenger.message_handler, from_transport: sync } + + netgen.search_extra.message_handler.hide_location: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Location\HideLocationHandler + arguments: + - '@netgen.search_extra.message_handler.subtree_index' + tags: + - { name: messenger.message_handler, from_transport: netgen_ibexa_search_extra_asynchronous_indexing} + + netgen.search_extra.message_handler.hide_location_sync: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Location\HideLocationHandler + arguments: + - '@netgen.search_extra.message_handler.subtree_index' + tags: + - { name: messenger.message_handler, from_transport: sync } - Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Location\HideLocationHandler: + netgen.search_extra.message_handler.location_move_subtree: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Location\MoveSubtreeHandler arguments: - - '@Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\SubtreeIndexer' + - '@netgen.search_extra.message_handler.subtree_index' tags: - - { name: messenger.message_handler } + - { name: messenger.message_handler, from_transport: netgen_ibexa_search_extra_asynchronous_indexing } - Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Location\MoveSubtreeHandler: + netgen.search_extra.message_handler.location_move_subtree_sync: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Location\MoveSubtreeHandler arguments: - - '@Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\SubtreeIndexer' + - '@netgen.search_extra.message_handler.subtree_index' tags: - - { name: messenger.message_handler } + - { name: messenger.message_handler, from_transport: sync } - Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Location\SwapLocationHandler: + netgen.search_extra.message_handler.swap_location: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Location\SwapLocationHandler arguments: - '@Ibexa\Contracts\Core\Persistence\Content\Handler' - '@Ibexa\Contracts\Core\Persistence\Content\Location\Handler' - '@ibexa.spi.search' - '@?logger' tags: - - { name: messenger.message_handler } + - { name: messenger.message_handler, from_transport: netgen_ibexa_search_extra_asynchronous_indexing } - { name: monolog.logger, channel: ngsearchextra } - Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Location\UnhideLocationHandler: + netgen.search_extra.message_handler.swap_location_sync: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Location\SwapLocationHandler + arguments: + - '@Ibexa\Contracts\Core\Persistence\Content\Handler' + - '@Ibexa\Contracts\Core\Persistence\Content\Location\Handler' + - '@ibexa.spi.search' + - '@?logger' + tags: + - { name: messenger.message_handler, from_transport: sync } + - { name: monolog.logger, channel: ngsearchextra } + + netgen.search_extra.message_handler.unhide_location: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Location\UnhideLocationHandler + arguments: + - '@netgen.search_extra.message_handler.subtree_index' + - '@ibexa.spi.search' + tags: + - { name: messenger.message_handler, from_transport: netgen_ibexa_search_extra_asynchronous_indexing } + + netgen.search_extra.message_handler.unhide_location_sync: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Location\UnhideLocationHandler arguments: - - '@Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\SubtreeIndexer' + - '@netgen.search_extra.message_handler.subtree_index' - '@ibexa.spi.search' tags: - - { name: messenger.message_handler } + - { name: messenger.message_handler, from_transport: sync } + + netgen.search_extra.message_handler.update_location: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Location\UpdateLocationHandler + arguments: + - '@Ibexa\Contracts\Core\Persistence\Content\Handler' + - '@Ibexa\Contracts\Core\Persistence\Content\Location\Handler' + - '@ibexa.spi.search' + - '@?logger' + tags: + - { name: messenger.message_handler, from_transport: netgen_ibexa_search_extra_asynchronous_indexing } + - { name: monolog.logger, channel: ngsearchextra } - Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Location\UpdateLocationHandler: + netgen.search_extra.message_handler.update_location_sync: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Location\UpdateLocationHandler arguments: - '@Ibexa\Contracts\Core\Persistence\Content\Handler' - '@Ibexa\Contracts\Core\Persistence\Content\Location\Handler' - '@ibexa.spi.search' - '@?logger' tags: - - { name: messenger.message_handler } + - { name: messenger.message_handler, from_transport: sync } - { name: monolog.logger, channel: ngsearchextra } diff --git a/lib/Resources/config/search/common/asynchronous_indexing/object_state.yaml b/lib/Resources/config/search/common/asynchronous_indexing/object_state.yaml index b0b32e7c..bf902d2a 100644 --- a/lib/Resources/config/search/common/asynchronous_indexing/object_state.yaml +++ b/lib/Resources/config/search/common/asynchronous_indexing/object_state.yaml @@ -1,10 +1,23 @@ services: - Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\ObjectState\SetContentStateHandler: + netgen.search_extra.message_handler.set_content_state: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\ObjectState\SetContentStateHandler arguments: - '@Ibexa\Contracts\Core\Persistence\Content\Handler' - '@Ibexa\Contracts\Core\Persistence\Content\Location\Handler' - '@ibexa.spi.search' - '@?logger' tags: - - { name: messenger.message_handler } + - { name: messenger.message_handler, from_transport: netgen_ibexa_search_extra_asynchronous_indexing } + - { name: monolog.logger, channel: ngsearchextra } + + + netgen.search_extra.message_handler.set_content_state_sync: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\ObjectState\SetContentStateHandler + arguments: + - '@Ibexa\Contracts\Core\Persistence\Content\Handler' + - '@Ibexa\Contracts\Core\Persistence\Content\Location\Handler' + - '@ibexa.spi.search' + - '@?logger' + tags: + - { name: messenger.message_handler, from_transport: sync } - { name: monolog.logger, channel: ngsearchextra } diff --git a/lib/Resources/config/search/common/asynchronous_indexing/section.yaml b/lib/Resources/config/search/common/asynchronous_indexing/section.yaml index 8a7c330e..4115c130 100644 --- a/lib/Resources/config/search/common/asynchronous_indexing/section.yaml +++ b/lib/Resources/config/search/common/asynchronous_indexing/section.yaml @@ -1,9 +1,20 @@ services: - Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Section\AssignSectionHandler: + netgen.search_extra.message_handler.assign_section: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Section\AssignSectionHandler arguments: - '@Ibexa\Contracts\Core\Persistence\Content\Handler' - '@ibexa.spi.search' - '@?logger' tags: - - { name: messenger.message_handler } + - { name: messenger.message_handler, from_transport: netgen_ibexa_search_extra_asynchronous_indexing } + - { name: monolog.logger, channel: ngsearchextra } + + netgen.search_extra.message_handler.assign_section_sync: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Section\AssignSectionHandler + arguments: + - '@Ibexa\Contracts\Core\Persistence\Content\Handler' + - '@ibexa.spi.search' + - '@?logger' + tags: + - { name: messenger.message_handler, from_transport: sync } - { name: monolog.logger, channel: ngsearchextra } diff --git a/lib/Resources/config/search/common/asynchronous_indexing/trash.yaml b/lib/Resources/config/search/common/asynchronous_indexing/trash.yaml index fc3d7813..cb69eaf2 100644 --- a/lib/Resources/config/search/common/asynchronous_indexing/trash.yaml +++ b/lib/Resources/config/search/common/asynchronous_indexing/trash.yaml @@ -1,13 +1,30 @@ services: - Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Trash\RecoverHandler: + netgen.search_extra.message_handler.recover_trash: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Trash\RecoverHandler arguments: - - '@Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\SubtreeIndexer' + - '@netgen.search_extra.message_handler.subtree_index' - '@ibexa.spi.search' tags: - - { name: messenger.message_handler } + - { name: messenger.message_handler, from_transport: netgen_ibexa_search_extra_asynchronous_indexing } - Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Trash\TrashHandler: + netgen.search_extra.message_handler.recover_trash_sync: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Trash\RecoverHandler arguments: + - '@netgen.search_extra.message_handler.subtree_index' - '@ibexa.spi.search' tags: - - { name: messenger.message_handler } + - { name: messenger.message_handler, from_transport: sync } + + netgen.search_extra.message_handler.trash: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Trash\TrashHandler + arguments: + - '@ibexa.spi.search' + tags: + - { name: messenger.message_handler, from_transport: netgen_ibexa_search_extra_asynchronous_indexing } + + netgen.search_extra.message_handler.trash_sync: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\Trash\TrashHandler + arguments: + - '@ibexa.spi.search' + tags: + - { name: messenger.message_handler, from_transport: sync } diff --git a/lib/Resources/config/search/common/asynchronous_indexing/user.yaml b/lib/Resources/config/search/common/asynchronous_indexing/user.yaml index ca054664..62c25574 100644 --- a/lib/Resources/config/search/common/asynchronous_indexing/user.yaml +++ b/lib/Resources/config/search/common/asynchronous_indexing/user.yaml @@ -1,77 +1,175 @@ services: - Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\User\AssignUserToUserGroupHandler: + netgen.search_extra.message_handler.assign_user_to_group: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\User\AssignUserToUserGroupHandler arguments: - - '@Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\UserContentWithLocationIndexer' + - '@netgen.search_extra.message_handler.user_content_with_location_indexer' tags: - - { name: messenger.message_handler } + - { name: messenger.message_handler, from_transport: netgen_ibexa_search_extra_asynchronous_indexing } - Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\User\BeforeUnAssignUserFromUserGroupHandler: + netgen.search_extra.message_handler.assign_user_to_group_sync: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\User\AssignUserToUserGroupHandler + arguments: + - '@netgen.search_extra.message_handler.user_content_with_location_indexer' + tags: + - { name: messenger.message_handler, from_transport: sync } + + netgen.search_extra.message_handler.before_unassign_user_from_group: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\User\BeforeUnAssignUserFromUserGroupHandler + arguments: + - '@Ibexa\Contracts\Core\Persistence\Content\Location\Handler' + - '@ibexa.spi.search' + tags: + - { name: messenger.message_handler, from_transport: netgen_ibexa_search_extra_asynchronous_indexing } + + netgen.search_extra.message_handler.before_unassign_user_from_group_sync: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\User\BeforeUnAssignUserFromUserGroupHandler arguments: - '@Ibexa\Contracts\Core\Persistence\Content\Location\Handler' - '@ibexa.spi.search' tags: - - { name: messenger.message_handler } + - { name: messenger.message_handler, from_transport: sync } - Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\User\CreateUserGroupHandler: + netgen.search_extra.message_handler.create_user_group: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\User\CreateUserGroupHandler arguments: - '@Ibexa\Contracts\Core\Persistence\Content\Handler' - '@Ibexa\Contracts\Core\Persistence\Content\Location\Handler' - '@ibexa.spi.search' tags: - - { name: messenger.message_handler } + - { name: messenger.message_handler, from_transport: netgen_ibexa_search_extra_asynchronous_indexing } - { name: monolog.logger, channel: ngsearchextra } - Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\User\CreateUserHandler: + netgen.search_extra.message_handler.create_user_group_sync: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\User\CreateUserGroupHandler + arguments: + - '@Ibexa\Contracts\Core\Persistence\Content\Handler' + - '@Ibexa\Contracts\Core\Persistence\Content\Location\Handler' + - '@ibexa.spi.search' + tags: + - { name: messenger.message_handler, from_transport: sync } + - { name: monolog.logger, channel: ngsearchextra } + + netgen.search_extra.message_handler.create_user: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\User\CreateUserHandler arguments: - '@Ibexa\Contracts\Core\Persistence\Content\Handler' - '@Ibexa\Contracts\Core\Persistence\Content\Location\Handler' - '@ibexa.spi.search' - '@?logger' tags: - - { name: messenger.message_handler } + - { name: messenger.message_handler, from_transport: netgen_ibexa_search_extra_asynchronous_indexing } - { name: monolog.logger, channel: ngsearchextra } - Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\User\DeleteUserGroupHandler: + netgen.search_extra.message_handler.create_user_sync: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\User\CreateUserHandler + arguments: + - '@Ibexa\Contracts\Core\Persistence\Content\Handler' + - '@Ibexa\Contracts\Core\Persistence\Content\Location\Handler' + - '@ibexa.spi.search' + - '@?logger' + tags: + - { name: messenger.message_handler, from_transport: sync } + - { name: monolog.logger, channel: ngsearchextra } + + netgen.search_extra.message_handler.delete_user_group: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\User\DeleteUserGroupHandler + arguments: + - '@ibexa.spi.search' + tags: + - { name: messenger.message_handler, from_transport: netgen_ibexa_search_extra_asynchronous_indexing } + + netgen.search_extra.message_handler.delete_user_group_sync: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\User\DeleteUserGroupHandler arguments: - '@ibexa.spi.search' tags: - - { name: messenger.message_handler } + - { name: messenger.message_handler, , from_transport: sync } - Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\User\DeleteUserHandler: + netgen.search_extra.message_handler.delete_user: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\User\DeleteUserHandler arguments: - '@ibexa.spi.search' tags: - - { name: messenger.message_handler } + - { name: messenger.message_handler, from_transport: netgen_ibexa_search_extra_asynchronous_indexing } - Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\User\MoveUserGroupHandler: + netgen.search_extra.message_handler.delete_user_sync: + class: + Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\User\DeleteUserHandler + arguments: + - '@ibexa.spi.search' + tags: + - { name: messenger.message_handler, from_transport: sync } + + netgen.search_extra.message_handler.move_user_group: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\User\MoveUserGroupHandler + arguments: + - '@Ibexa\Contracts\Core\Persistence\Content\Handler' + - '@netgen.search_extra.message_handler.subtree_index' + tags: + - { name: messenger.message_handler, from_transport: netgen_ibexa_search_extra_asynchronous_indexing } + + netgen.search_extra.message_handler.move_user_group_sync: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\User\MoveUserGroupHandler arguments: - '@Ibexa\Contracts\Core\Persistence\Content\Handler' - - '@Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\SubtreeIndexer' + - '@netgen.search_extra.message_handler.subtree_index' + tags: + - { name: messenger.message_handler, from_transport: sync } + + netgen.search_extra.message_handler.unassign_user_from_user_group: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\User\UnAssignUserFromUserGroupHandler + arguments: + - '@netgen.search_extra.message_handler.user_content_with_location_indexer' tags: - - { name: messenger.message_handler } + - { name: messenger.message_handler, from_transport: netgen_ibexa_search_extra_asynchronous_indexing } - Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\User\UnAssignUserFromUserGroupHandler: + netgen.search_extra.message_handler.unassign_user_from_user_group_sync: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\User\UnAssignUserFromUserGroupHandler arguments: - - '@Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\UserContentWithLocationIndexer' + - '@netgen.search_extra.message_handler.user_content_with_location_indexer' tags: - - { name: messenger.message_handler } + - { name: messenger.message_handler, from_transport: sync } + + netgen.search_extra.message_handler.update_user_group: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\User\UpdateUserGroupHandler + arguments: + - '@Ibexa\Contracts\Core\Persistence\Content\Handler' + - '@Ibexa\Contracts\Core\Persistence\Content\Location\Handler' + - '@ibexa.spi.search' + - '@?logger' + tags: + - { name: messenger.message_handler, from_transport: netgen_ibexa_search_extra_asynchronous_indexing } + - { name: monolog.logger, channel: ngsearchextra } + + netgen.search_extra.message_handler.update_user_group_sync: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\User\UpdateUserGroupHandler + arguments: + - '@Ibexa\Contracts\Core\Persistence\Content\Handler' + - '@Ibexa\Contracts\Core\Persistence\Content\Location\Handler' + - '@ibexa.spi.search' + - '@?logger' + tags: + - { name: messenger.message_handler, from_transport: sync } + - { name: monolog.logger, channel: ngsearchextra } - Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\User\UpdateUserGroupHandler: + netgen.search_extra.message_handler.update_user: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\User\UpdateUserHandler arguments: - '@Ibexa\Contracts\Core\Persistence\Content\Handler' - '@Ibexa\Contracts\Core\Persistence\Content\Location\Handler' - '@ibexa.spi.search' - '@?logger' tags: - - { name: messenger.message_handler } + - { name: messenger.message_handler, from_transport: netgen_ibexa_search_extra_asynchronous_indexing } - { name: monolog.logger, channel: ngsearchextra } - Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\User\UpdateUserHandler: + netgen.search_extra.message_handler.update_user_sync: + class: Netgen\IbexaSearchExtra\Core\Search\Common\Messenger\MessageHandler\Search\User\UpdateUserHandler arguments: - '@Ibexa\Contracts\Core\Persistence\Content\Handler' - '@Ibexa\Contracts\Core\Persistence\Content\Location\Handler' - '@ibexa.spi.search' - '@?logger' tags: - - { name: messenger.message_handler } + - { name: messenger.message_handler, from_transport: sync } - { name: monolog.logger, channel: ngsearchextra }