mirror of
https://github.com/Codappix/search_core.git
synced 2024-11-14 19:56:12 +01:00
Daniel Siepmann
432335c80d
Adjust code to use defined indexer as FQCN, to allow any class to be used as indexer. Also classes defined by user.
141 lines
3.9 KiB
PHP
141 lines
3.9 KiB
PHP
<?php
|
|
namespace Leonmrni\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 Leonmrni\SearchCore\Configuration\ConfigurationContainerInterface;
|
|
use Leonmrni\SearchCore\Domain\Index\IndexerFactory;
|
|
use Leonmrni\SearchCore\Domain\Index\NoMatchingIndexerException;
|
|
use Leonmrni\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 \Leonmrni\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
|
|
* @param array $record
|
|
*/
|
|
public function add($table, array $record)
|
|
{
|
|
$this->logger->debug('Record received for add.', [$table, $record]);
|
|
$this->getIndexer($table)->indexDocument($record['uid']);
|
|
}
|
|
|
|
/**
|
|
* @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;
|
|
}
|
|
}
|