mirror of
https://github.com/Codappix/search_core.git
synced 2024-11-25 11:36:11 +01:00
Daniel Siepmann
47b3282034
Relations were inserted by TYPO3's DataHandler after indexing and were therefore not indexed. We now use a later hook after DataHandler has finished everything, so we know that we can index. As it's not relevant, we do not differentiate between add and update anymore, as both trigger "indexDocument" internal. Resolves: #112
131 lines
3.6 KiB
PHP
131 lines
3.6 KiB
PHP
<?php
|
|
namespace Codappix\SearchCore\Domain\Service;
|
|
|
|
/*
|
|
* Copyright (C) 2016 Daniel Siepmann <coding@daniel-siepmann.de>
|
|
*
|
|
* This program is free software; you can redistribute it and/or
|
|
* modify it under the terms of the GNU General Public License
|
|
* as published by the Free Software Foundation; either version 2
|
|
* of the License, or (at your option) any later version.
|
|
*
|
|
* This program is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
* GNU General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU General Public License
|
|
* along with this program; if not, write to the Free Software
|
|
* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
|
|
* 02110-1301, USA.
|
|
*/
|
|
|
|
use Codappix\SearchCore\Configuration\ConfigurationContainerInterface;
|
|
use Codappix\SearchCore\Domain\Index\IndexerFactory;
|
|
use Codappix\SearchCore\Domain\Index\NoMatchingIndexerException;
|
|
use Codappix\SearchCore\Domain\Index\TcaIndexer;
|
|
use TYPO3\CMS\Core\SingletonInterface as Singleton;
|
|
use TYPO3\CMS\Core\Utility\GeneralUtility;
|
|
|
|
/**
|
|
* Handles all data related things like updates, deletes and inserts.
|
|
*
|
|
* This is the place to add mappings of further parts to adjust the data before
|
|
* sending ot to connection.
|
|
*
|
|
* TODO: Probably a candidate for deletion. Currently this class makes use of
|
|
* extbase DI. We have to resolve this somehow.
|
|
*
|
|
* I think we keep it for easier testing and DI.
|
|
*/
|
|
class DataHandler implements Singleton
|
|
{
|
|
/**
|
|
* TODO: Only inject on first use?!
|
|
*
|
|
* @var \Codappix\SearchCore\Connection\ConnectionInterface
|
|
* @inject
|
|
*/
|
|
protected $connection;
|
|
|
|
/**
|
|
* @var IndexerFactory
|
|
*/
|
|
protected $indexerFactory;
|
|
|
|
/**
|
|
* @var ConfigurationContainerInterface
|
|
*/
|
|
protected $configuration;
|
|
|
|
/**
|
|
* @var \TYPO3\CMS\Core\Log\Logger
|
|
*/
|
|
protected $logger;
|
|
|
|
/**
|
|
* Inject log manager to get concrete logger from it.
|
|
*
|
|
* @param \TYPO3\CMS\Core\Log\LogManager $logManager
|
|
*/
|
|
public function injectLogger(\TYPO3\CMS\Core\Log\LogManager $logManager)
|
|
{
|
|
$this->logger = $logManager->getLogger(__CLASS__);
|
|
}
|
|
|
|
/**
|
|
* @param ConfigurationContainerInterface $configuration
|
|
* @param IndexerFactory $indexerFactory
|
|
*/
|
|
public function __construct(ConfigurationContainerInterface $configuration, IndexerFactory $indexerFactory)
|
|
{
|
|
$this->configuration = $configuration;
|
|
$this->indexerFactory = $indexerFactory;
|
|
}
|
|
|
|
/**
|
|
* @param string $table
|
|
*/
|
|
public function update($table, array $record)
|
|
{
|
|
$this->logger->debug('Record received for update.', [$table, $record]);
|
|
$this->getIndexer($table)->indexDocument($record['uid']);
|
|
}
|
|
|
|
/**
|
|
* @param string $table
|
|
* @param int $identifier
|
|
*/
|
|
public function delete($table, $identifier)
|
|
{
|
|
$this->logger->debug('Record received for delete.', [$table, $identifier]);
|
|
$this->connection->deleteDocument($table, $identifier);
|
|
}
|
|
|
|
/**
|
|
* @param string $table
|
|
* @return IndexerInterface
|
|
*
|
|
* @throws NoMatchingIndexerException
|
|
*/
|
|
protected function getIndexer($table)
|
|
{
|
|
return $this->indexerFactory->getIndexer($table);
|
|
}
|
|
|
|
/**
|
|
* @param string $table
|
|
* @return bool
|
|
*/
|
|
public function canHandle($table)
|
|
{
|
|
try {
|
|
$this->getIndexer($table);
|
|
return true;
|
|
} catch (NoMatchingIndexerException $e) {
|
|
return false;
|
|
}
|
|
|
|
return false;
|
|
}
|
|
}
|