ezsystems / ezpublish-kernel

/**

 * A Search Engine slot handling CreateUserSignal.

 */

class CreateUser extends Slot

{

    /**

     * Receive the given $signal and react on it.

     *

     * @param \eZ\Publish\Core\SignalSlot\Signal $signal

     */

    public function receive(Signal $signal)

    {

        if (!$signal instanceof Signal\UserService\CreateUserSignal) {

            return;

        }

        $userContentInfo = $this->persistenceHandler->contentHandler()->loadContentInfo(

            $signal->userId

        );

        $this->searchHandler->indexContent(

            $this->persistenceHandler->contentHandler()->load(

                $userContentInfo->id,

                $userContentInfo->currentVersionNo

            )

        );

        $locations = $this->persistenceHandler->locationHandler()->loadLocationsByContent(

            $userContentInfo->id

        );

        foreach ($locations as $location) {

            $this->searchHandler->indexLocation($location);

        }

    }

}

/**

 * A Search Engine slot handling CreateUserGroupSignal.

 */

class CreateUserGroup extends Slot

{

    /**

     * Receive the given $signal and react on it.

     *

     * @param \eZ\Publish\Core\SignalSlot\Signal $signal

     */

    public function receive(Signal $signal)

    {

        if (!$signal instanceof Signal\UserService\CreateUserGroupSignal) {

            return;

        }

        $userGroupContentInfo = $this->persistenceHandler->contentHandler()->loadContentInfo(

            $signal->userGroupId

        );

        $this->searchHandler->indexContent(

            $this->persistenceHandler->contentHandler()->load(

                $userGroupContentInfo->id,

                $userGroupContentInfo->currentVersionNo

            )

        );

        $locations = $this->persistenceHandler->locationHandler()->loadLocationsByContent(

            $userGroupContentInfo->id

        );

        foreach ($locations as $location) {

            $this->searchHandler->indexLocation($location);

        }

    }

}

/**

 * A Search Engine slot handling RecoverSignal.

 */

class Recover extends Slot

{

    /**

     * Receive the given $signal and react on it.

     *

     * @param \eZ\Publish\Core\SignalSlot\Signal $signal

     */

    public function receive(Signal $signal)

    {

        if (!$signal instanceof Signal\TrashService\RecoverSignal) {

            return;

        }

        $contentHandler = $this->persistenceHandler->contentHandler();

        foreach ($this->persistenceHandler->locationHandler()->loadSubtreeIds($signal->newLocationId) as $contentId) {

            $contentInfo = $contentHandler->loadContentInfo($contentId);

            $this->searchHandler->indexContent(

                $contentHandler->load($contentInfo->id, $contentInfo->currentVersionNo)

            );

            $this->searchHandler->indexLocation(

                $this->persistenceHandler->locationHandler()->load($signal->newLocationId)

            );

        }

    }

}

/**

 * A Search Engine slot handling SetContentStateSignal.

 */

class SetContentState extends Slot

{

    /**

     * Receive the given $signal and react on it.

     *

     * @param \eZ\Publish\Core\SignalSlot\Signal $signal

     */

    public function receive(Signal $signal)

    {

        if (!$signal instanceof Signal\ObjectStateService\SetContentStateSignal) {

            return;

        }

        $contentInfo = $this->persistenceHandler->contentHandler()->loadContentInfo($signal->contentId);

        $this->searchHandler->indexContent(

            $this->persistenceHandler->contentHandler()->load(

                $contentInfo->id,

                $contentInfo->currentVersionNo

            )

        );

        $locations = $this->persistenceHandler->locationHandler()->loadLocationsByContent($contentInfo->id);

        foreach ($locations as $location) {

            $this->searchHandler->indexLocation($location);

        }

    }

}

/**

 * A Search Engine slot handling RemoveTranslationSignal.

 */

class RemoveTranslation extends Slot

{

    /**

     * Receive the given $signal and react on it.

     *

     * @param \eZ\Publish\Core\SignalSlot\Signal $signal

     */

    public function receive(Signal $signal)

    {

        if (!$signal instanceof Signal\ContentService\RemoveTranslationSignal) {

            return;

        }

        $contentInfo = $this->persistenceHandler->contentHandler()->loadContentInfo(

            $signal->contentId

        );

        if (!$contentInfo->isPublished) {

            return;

        }

        $this->searchHandler->indexContent(

            $this->persistenceHandler->contentHandler()->load(

                $contentInfo->id,

                $contentInfo->currentVersionNo

            )

        );

        $locations = $this->persistenceHandler->locationHandler()->loadLocationsByContent(

            $contentInfo->id

        );

        foreach ($locations as $location) {

            $this->searchHandler->indexLocation($location);

        }

    }

}