PageIndexer::getSolrConnection() - Code Metrics - Inspection of "[BUGFIX] Remove eval int from port in site configu..." - TYPO3-Solr/ext-solr - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 1a818c...84aa0d )

by Timo

created 2020-05-05 17:34 UTC

PageIndexer::getSolrConnection() A

↳ Parent: PageIndexer

Complexity

Conditions	1
Paths	1

Size

Total Lines	11
Code Lines	5

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	6
CRAP Score	1.0156

Importance

Changes

Metric	Value
eloc	5
dl	0
loc	11
ccs	6
cts	8
cp	0.75
rs	10
c	0
b	0
f	0
cc	1
nc	1
nop	1
crap	1.0156

<?php
namespace ApacheSolrForTypo3\Solr\IndexQueue\FrontendHelper;

/***************************************************************
 *  Copyright notice
 *
 *  (c) 2011-2015 Ingo Renner <[email protected]>
 *  All rights reserved
 *
 *  This script is part of the TYPO3 project. The TYPO3 project 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 3 of the License, or
 *  (at your option) any later version.
 *
 *  The GNU General Public License can be found at
 *  http://www.gnu.org/copyleft/gpl.html.
 *
 *  This script 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.
 *
 *  This copyright notice MUST APPEAR in all copies of the script!
 ***************************************************************/

use ApacheSolrForTypo3\Solr\Access\Rootline;
use ApacheSolrForTypo3\Solr\ConnectionManager;
use ApacheSolrForTypo3\Solr\IndexQueue\Item;
use ApacheSolrForTypo3\Solr\IndexQueue\Queue;
use ApacheSolrForTypo3\Solr\System\Logging\SolrLogManager;
use ApacheSolrForTypo3\Solr\System\Solr\SolrConnection;
use ApacheSolrForTypo3\Solr\Typo3PageIndexer;
use ApacheSolrForTypo3\Solr\Util;
use TYPO3\CMS\Core\SingletonInterface;
use TYPO3\CMS\Core\Utility\ExtensionManagementUtility;
use TYPO3\CMS\Core\Utility\GeneralUtility;
use TYPO3\CMS\Frontend\ContentObject\ContentObjectRenderer;
use TYPO3\CMS\Frontend\Controller\TypoScriptFrontendController;

/**
 * Index Queue Page Indexer frontend helper to ask the frontend page indexer to
 * index the page.
 *
 * @author Ingo Renner <[email protected]>
 */
class PageIndexer extends AbstractFrontendHelper implements SingletonInterface
{

    /**
     * This frontend helper's executed action.
     *
     * @var string
     */
    protected $action = 'indexPage';

    /**
     * the page currently being indexed.
     *
     * @var TypoScriptFrontendController
     */
    protected $page;

    /**
     * Response data
     *
     * @var array
     */
    protected $responseData = [];

    /**
     * @var \TYPO3\CMS\Core\Log\Logger
     */
    protected $logger = null;

    /**
     * Activates a frontend helper by registering for hooks and other
     * resources required by the frontend helper to work.
     */
    public function activate()
    {
        $pageIndexingHookRegistration = PageIndexer::class;

        $GLOBALS['TYPO3_CONF_VARS']['SC_OPTIONS']['tslib/class.tslib_fe.php']['initFEuser'][__CLASS__] = $pageIndexingHookRegistration . '->authorizeFrontendUser';
        // disable TSFE cache for TYPO3 v9
        $GLOBALS['TYPO3_CONF_VARS']['SC_OPTIONS']['tslib/class.tslib_fe.php']['tslib_fe-PostProc'][__CLASS__] = $pageIndexingHookRegistration . '->disableCaching';
        $GLOBALS['TYPO3_CONF_VARS']['SC_OPTIONS']['tslib/class.tslib_fe.php']['pageIndexing'][__CLASS__] = $pageIndexingHookRegistration;

        // indexes fields defined in plugin.tx_solr.index.queue.pages.fields
        $GLOBALS['TYPO3_CONF_VARS']['EXTCONF']['solr']['Indexer']['indexPageSubstitutePageDocument']['ApacheSolrForTypo3\\Solr\\IndexQueue\\FrontendHelper\\PageFieldMappingIndexer'] = PageFieldMappingIndexer::class;

        // making sure this instance is reused when called by the hooks registered before
        // \TYPO3\CMS\Core\Utility\GeneralUtility::callUserFunction() and \TYPO3\CMS\Core\Utility\GeneralUtility::getUserObj() use
        // these storages while the object was instantiated by
        // ApacheSolrForTypo3\Solr\IndexQueue\FrontendHelper\Manager before.
        // \TYPO3\CMS\Core\Utility\GeneralUtility::makeInstance() also uses a dedicated cache
        $GLOBALS['T3_VAR']['callUserFunction_classPool'][__CLASS__] = $this;
        //$GLOBALS['T3_VAR']['getUserObj'][$pageIndexingHookRegistration] = $this;

        $this->registerAuthorizationService();
    }

    /**
     * Returns the status of whether a page was indexed.
     *
     * @return array Page indexed status.
     */
    public function getData()
    {
        return $this->responseData;
    }

    #
    # Indexer authorisation for access restricted pages / content
    #

    /**
     * Fakes a logged in user to retrieve access restricted content.
     *
     * @return void
     */
    public function authorizeFrontendUser()
    {
        $accessRootline = $this->getAccessRootline();
        $stringAccessRootline = (string)$accessRootline;

        if (empty($stringAccessRootline)) {
            return;
        }

        if (!is_array($GLOBALS['TSFE']->fe_user->user)) {
            $GLOBALS['TSFE']->fe_user->user = [];
        }

        $groups = $accessRootline->getGroups();
        $groupList = implode(',', $groups);

        $GLOBALS['TSFE']->fe_user->user['username'] = AuthorizationService::SOLR_INDEXER_USERNAME;
        $GLOBALS['TSFE']->fe_user->user['usergroup'] = $groupList;

        $this->responseData['authorization'] = [
            'username' => $GLOBALS['TSFE']->fe_user->user['username'],
            'usergroups' => $GLOBALS['TSFE']->fe_user->user['usergroup']
        ];
    }

    /**
     * Gets the access rootline as defined by the request.
     *
     * @return Rootline The access rootline to use for indexing.
     */
    protected function getAccessRootline()
    {
        $stringAccessRootline = '';

        if ($this->request->getParameter('accessRootline')) {
            $stringAccessRootline = $this->request->getParameter('accessRootline');
        }

        $accessRootline = GeneralUtility::makeInstance(Rootline::class, /** @scrutinizer ignore-type */ $stringAccessRootline);
        return $accessRootline;
    }

    /**
     * Registers an authentication service to authorize / grant the indexer to
     * access protected pages.
     *
     * @return void
     */
    protected function registerAuthorizationService()
    {
        $overrulingPriority = $this->getHighestAuthenticationServicePriority() + 1;

        ExtensionManagementUtility::addService(
            'solr', // extension key
            'auth', // service type
            AuthorizationService::class,
            // service key
            [// service meta data
                'title' => 'Solr Indexer Authorization',
                'description' => 'Authorizes the Solr Index Queue indexer to access protected pages.',

                'subtype' => 'getUserFE,authUserFE,getGroupsFE',

                'available' => true,
                'priority' => $overrulingPriority,
                'quality' => 100,

                'os' => '',
                'exec' => '',

                'classFile' => ExtensionManagementUtility::extPath('solr') . 'Classes/IndexQueue/FrontendHelper/AuthorizationService.php',
                'className' => AuthorizationService::class,
            ]
        );
    }

    /**
     * Determines the highest priority of all registered authentication
     * services.
     *
     * @return int Highest priority of all registered authentication service
     */
    protected function getHighestAuthenticationServicePriority()
    {
        $highestPriority = 0;

        if (is_array($GLOBALS['T3_SERVICES']['auth'])) {
            foreach ($GLOBALS['T3_SERVICES']['auth'] as $service) {
                if ($service['priority'] > $highestPriority) {
                    $highestPriority = $service['priority'];
                }
            }
        }

        return $highestPriority;
    }

    #
    # Indexing
    #

    /**
     * Generates the current page's URL.
     *
     * Uses the provided GET parameters, page id and language id.
     *
     * @return string URL of the current page.
     */
    protected function generatePageUrl()
    {
        if ($this->request->getParameter('overridePageUrl')) {
            return $this->request->getParameter('overridePageUrl');
        }

            /** @var $contentObject ContentObjectRenderer */
        $contentObject = GeneralUtility::makeInstance(ContentObjectRenderer::class);

        $typolinkConfiguration = [
            'parameter' => intval($this->page->id),
            'linkAccessRestrictedPages' => '1'
        ];

        $language = GeneralUtility::_GET('L');
        if (!empty($language)) {
            $typolinkConfiguration['additionalParams'] = '&L=' . $language;
        }

        $url = $contentObject->typoLink_URL($typolinkConfiguration);

        // clean up
        if ($url == '') {
            $url = '/';
        }

        return $url;
    }

    /**
     * Handles the indexing of the page content during post processing of a
     * generated page.
     *
     * @param TypoScriptFrontendController $page TypoScript frontend
     */
    public function hook_indexContent(TypoScriptFrontendController $page)
    {
        $this->logger = GeneralUtility::makeInstance(SolrLogManager::class, /** @scrutinizer ignore-type */ __CLASS__);

        $this->page = $page;
        $configuration = Util::getSolrConfiguration();

        $logPageIndexed = $configuration->getLoggingIndexingPageIndexed();
        if (!$this->page->config['config']['index_enable']) {
            if ($logPageIndexed) {
                $this->logger->log(
                    SolrLogManager::ERROR,
                    'Indexing is disabled. Set config.index_enable = 1 .'
                );
            }
            return;
        }

        try {
            $indexQueueItem = $this->getIndexQueueItem();
            if (is_null($indexQueueItem)) {
                throw new \UnexpectedValueException('Can not get index queue item', 1482162337);
            }

            $solrConnection = $this->getSolrConnection($indexQueueItem);

            /** @var $indexer Typo3PageIndexer */
            $indexer = GeneralUtility::makeInstance(Typo3PageIndexer::class, /** @scrutinizer ignore-type */ $page);
            $indexer->setSolrConnection($solrConnection);
            $indexer->setPageAccessRootline($this->getAccessRootline());
            $indexer->setPageUrl($this->generatePageUrl());
            $indexer->setMountPointParameter($GLOBALS['TSFE']->MP);
            $indexer->setIndexQueueItem($indexQueueItem);

            $this->responseData['pageIndexed'] = (int)$indexer->indexPage();
            $this->responseData['originalPageDocument'] = (array)$indexer->getPageSolrDocument();
            $this->responseData['solrConnection'] = [
                'rootPage' => $indexQueueItem->getRootPageUid(),
                'sys_language_uid' => Util::getLanguageUid(),
                'solr' => (string)$solrConnection->getNode('write')
            ];

            $documentsSentToSolr = $indexer->getDocumentsSentToSolr();
            foreach ($documentsSentToSolr as $document) {
                $this->responseData['documentsSentToSolr'][] = (array)$document;
            }
        } catch (\Exception $e) {
            if ($configuration->getLoggingExceptions()) {
                $this->logger->log(
                    SolrLogManager::ERROR,
                    'Exception while trying to index page ' . $page->id,
                    [
                        $e->__toString()
                    ]
                );
            }
        }

        if ($logPageIndexed) {
            $success = $this->responseData['pageIndexed'] ? 'Success' : 'Failed';
            $severity = $this->responseData['pageIndexed'] ? SolrLogManager::NOTICE : SolrLogManager::ERROR;

            $this->logger->log(
                $severity,
                'Page indexed: ' . $success,
                $this->responseData
            );
        }
    }

    /**
     * Gets the solr connection to use for indexing the page based on the
     * Index Queue item's properties.
     *
     * @param Item $indexQueueItem
     * @return SolrConnection Solr server connection
     */
    protected function getSolrConnection(Item $indexQueueItem)
    {
        /** @var $connectionManager ConnectionManager */
        $connectionManager = GeneralUtility::makeInstance(ConnectionManager::class);

        $solrConnection = $connectionManager->getConnectionByRootPageId(
            $indexQueueItem->getRootPageUid(),
            Util::getLanguageUid()
        );

        return $solrConnection;
    }

    /**
     * This method retrieves the item from the index queue, that is indexed in this request.
     *
     * @return \ApacheSolrForTypo3\Solr\IndexQueue\Item
     */
    protected function getIndexQueueItem()
    {
        /** @var $indexQueue Queue */
        $indexQueue = GeneralUtility::makeInstance(Queue::class);
        $indexQueueItem = $indexQueue->getItem($this->request->getParameter('item'));
        return $indexQueueItem;
    }
}


1		<?php
2		namespace ApacheSolrForTypo3\Solr\IndexQueue\FrontendHelper;
3
4		/***************************************************************
5		* Copyright notice
6		*
7		* (c) 2011-2015 Ingo Renner <[email protected]>
8		* All rights reserved
9		*
10		* This script is part of the TYPO3 project. The TYPO3 project is
11		* free software; you can redistribute it and/or modify
12		* it under the terms of the GNU General Public License as published by
13		* the Free Software Foundation; either version 3 of the License, or
14		* (at your option) any later version.
15		*
16		* The GNU General Public License can be found at
17		* http://www.gnu.org/copyleft/gpl.html.
18		*
19		* This script is distributed in the hope that it will be useful,
20		* but WITHOUT ANY WARRANTY; without even the implied warranty of
21		* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
22		* GNU General Public License for more details.
23		*
24		* This copyright notice MUST APPEAR in all copies of the script!
25		***************************************************************/
26
27		use ApacheSolrForTypo3\Solr\Access\Rootline;
28		use ApacheSolrForTypo3\Solr\ConnectionManager;
29		use ApacheSolrForTypo3\Solr\IndexQueue\Item;
30		use ApacheSolrForTypo3\Solr\IndexQueue\Queue;
31		use ApacheSolrForTypo3\Solr\System\Logging\SolrLogManager;
32		use ApacheSolrForTypo3\Solr\System\Solr\SolrConnection;
33		use ApacheSolrForTypo3\Solr\Typo3PageIndexer;
34		use ApacheSolrForTypo3\Solr\Util;
35		use TYPO3\CMS\Core\SingletonInterface;
36		use TYPO3\CMS\Core\Utility\ExtensionManagementUtility;
37		use TYPO3\CMS\Core\Utility\GeneralUtility;
38		use TYPO3\CMS\Frontend\ContentObject\ContentObjectRenderer;
39		use TYPO3\CMS\Frontend\Controller\TypoScriptFrontendController;
40
41		/**
42		* Index Queue Page Indexer frontend helper to ask the frontend page indexer to
43		* index the page.
44		*
45		* @author Ingo Renner <[email protected]>
46		*/
47		class PageIndexer extends AbstractFrontendHelper implements SingletonInterface
48		{
49
50		/**
51		* This frontend helper's executed action.
52		*
53		* @var string
54		*/
55		protected $action = 'indexPage';
56
57		/**
58		* the page currently being indexed.
59		*
60		* @var TypoScriptFrontendController
61		*/
62		protected $page;
63
64		/**
65		* Response data
66		*
67		* @var array
68		*/
69		protected $responseData = [];
70
71		/**
72		* @var \TYPO3\CMS\Core\Log\Logger
73		*/
74		protected $logger = null;
75
76		/**
77		* Activates a frontend helper by registering for hooks and other
78		* resources required by the frontend helper to work.
79		*/
80	10	public function activate()
81		{
82	10	$pageIndexingHookRegistration = PageIndexer::class;
83
84	10	$GLOBALS['TYPO3_CONF_VARS']['SC_OPTIONS']['tslib/class.tslib_fe.php']['initFEuser'][__CLASS__] = $pageIndexingHookRegistration . '->authorizeFrontendUser';
85		// disable TSFE cache for TYPO3 v9
86	10	$GLOBALS['TYPO3_CONF_VARS']['SC_OPTIONS']['tslib/class.tslib_fe.php']['tslib_fe-PostProc'][__CLASS__] = $pageIndexingHookRegistration . '->disableCaching';
87	10	$GLOBALS['TYPO3_CONF_VARS']['SC_OPTIONS']['tslib/class.tslib_fe.php']['pageIndexing'][__CLASS__] = $pageIndexingHookRegistration;
88
89		// indexes fields defined in plugin.tx_solr.index.queue.pages.fields
90	10	$GLOBALS['TYPO3_CONF_VARS']['EXTCONF']['solr']['Indexer']['indexPageSubstitutePageDocument']['ApacheSolrForTypo3\\Solr\\IndexQueue\\FrontendHelper\\PageFieldMappingIndexer'] = PageFieldMappingIndexer::class;
91
92		// making sure this instance is reused when called by the hooks registered before
93		// \TYPO3\CMS\Core\Utility\GeneralUtility::callUserFunction() and \TYPO3\CMS\Core\Utility\GeneralUtility::getUserObj() use
94		// these storages while the object was instantiated by
95		// ApacheSolrForTypo3\Solr\IndexQueue\FrontendHelper\Manager before.
96		// \TYPO3\CMS\Core\Utility\GeneralUtility::makeInstance() also uses a dedicated cache
97	10	$GLOBALS['T3_VAR']['callUserFunction_classPool'][__CLASS__] = $this;
98		//$GLOBALS['T3_VAR']['getUserObj'][$pageIndexingHookRegistration] = $this;
99
100	10	$this->registerAuthorizationService();
101	10	}
102
103		/**
104		* Returns the status of whether a page was indexed.
105		*
106		* @return array Page indexed status.
107		*/
108		public function getData()
109		{
110		return $this->responseData;
111		}
112
113		#
114		# Indexer authorisation for access restricted pages / content
115		#
116
117		/**
118		* Fakes a logged in user to retrieve access restricted content.
119		*
120		* @return void
121		*/
122		public function authorizeFrontendUser()
123		{
124		$accessRootline = $this->getAccessRootline();
125		$stringAccessRootline = (string)$accessRootline;
126
127		if (empty($stringAccessRootline)) {
128		return;
129		}
130
131		if (!is_array($GLOBALS['TSFE']->fe_user->user)) {
132		$GLOBALS['TSFE']->fe_user->user = [];
133		}
134
135		$groups = $accessRootline->getGroups();
136		$groupList = implode(',', $groups);
137
138		$GLOBALS['TSFE']->fe_user->user['username'] = AuthorizationService::SOLR_INDEXER_USERNAME;
139		$GLOBALS['TSFE']->fe_user->user['usergroup'] = $groupList;
140
141		$this->responseData['authorization'] = [
142		'username' => $GLOBALS['TSFE']->fe_user->user['username'],
143		'usergroups' => $GLOBALS['TSFE']->fe_user->user['usergroup']
144		];
145		}
146
147		/**
148		* Gets the access rootline as defined by the request.
149		*
150		* @return Rootline The access rootline to use for indexing.
151		*/
152	10	protected function getAccessRootline()
153		{
154	10	$stringAccessRootline = '';
155
156	10	if ($this->request->getParameter('accessRootline')) {
157		$stringAccessRootline = $this->request->getParameter('accessRootline');
158		}
159
160	10	$accessRootline = GeneralUtility::makeInstance(Rootline::class, /** @scrutinizer ignore-type */ $stringAccessRootline);
161	10	return $accessRootline;
162		}
163
164		/**
165		* Registers an authentication service to authorize / grant the indexer to
166		* access protected pages.
167		*
168		* @return void
169		*/
170	10	protected function registerAuthorizationService()
171		{
172	10	$overrulingPriority = $this->getHighestAuthenticationServicePriority() + 1;
173
174	10	ExtensionManagementUtility::addService(
175	10	'solr', // extension key
176	10	'auth', // service type
177	10	AuthorizationService::class,
178		// service key
179		[// service meta data
180	10	'title' => 'Solr Indexer Authorization',
181	10	'description' => 'Authorizes the Solr Index Queue indexer to access protected pages.',
182
183	10	'subtype' => 'getUserFE,authUserFE,getGroupsFE',
184
185		'available' => true,
186	10	'priority' => $overrulingPriority,
187	10	'quality' => 100,
188
189	10	'os' => '',
190	10	'exec' => '',
191
192	10	'classFile' => ExtensionManagementUtility::extPath('solr') . 'Classes/IndexQueue/FrontendHelper/AuthorizationService.php',
193		'className' => AuthorizationService::class,
194		]
195		);
196	10	}
197
198		/**
199		* Determines the highest priority of all registered authentication
200		* services.
201		*
202		* @return int Highest priority of all registered authentication service
203		*/
204	10	protected function getHighestAuthenticationServicePriority()
205		{
206	10	$highestPriority = 0;
207
208	10	if (is_array($GLOBALS['T3_SERVICES']['auth'])) {
209	10	foreach ($GLOBALS['T3_SERVICES']['auth'] as $service) {
210	10	if ($service['priority'] > $highestPriority) {
211	10	$highestPriority = $service['priority'];
212		}
213		}
214		}
215
216	10	return $highestPriority;
217		}
218
219		#
220		# Indexing
221		#
222
223		/**
224		* Generates the current page's URL.
225		*
226		* Uses the provided GET parameters, page id and language id.
227		*
228		* @return string URL of the current page.
229		*/
230	10	protected function generatePageUrl()
231		{
232	10	if ($this->request->getParameter('overridePageUrl')) {
233		return $this->request->getParameter('overridePageUrl');
234		}
235
236		/** @var $contentObject ContentObjectRenderer */
237	10	$contentObject = GeneralUtility::makeInstance(ContentObjectRenderer::class);
238
239		$typolinkConfiguration = [
240	10	'parameter' => intval($this->page->id),
241	10	'linkAccessRestrictedPages' => '1'
242		];
243
244	10	$language = GeneralUtility::_GET('L');
245	10	if (!empty($language)) {
246		$typolinkConfiguration['additionalParams'] = '&L=' . $language;
247		}
248
249	10	$url = $contentObject->typoLink_URL($typolinkConfiguration);
250
251		// clean up
252	10	if ($url == '') {
253		$url = '/';
254		}
255
256	10	return $url;
257		}
258
259		/**
260		* Handles the indexing of the page content during post processing of a
261		* generated page.
262		*
263		* @param TypoScriptFrontendController $page TypoScript frontend
264		*/
265	10	public function hook_indexContent(TypoScriptFrontendController $page)
266		{
267	10	$this->logger = GeneralUtility::makeInstance(SolrLogManager::class, /** @scrutinizer ignore-type */ __CLASS__);
268
269	10	$this->page = $page;
270	10	$configuration = Util::getSolrConfiguration();
271
272	10	$logPageIndexed = $configuration->getLoggingIndexingPageIndexed();
273	10	if (!$this->page->config['config']['index_enable']) {
274		if ($logPageIndexed) {
275		$this->logger->log(
276		SolrLogManager::ERROR,
277		'Indexing is disabled. Set config.index_enable = 1 .'
278		);
279		}
280		return;
281		}
282
283		try {
284	10	$indexQueueItem = $this->getIndexQueueItem();
285	10	if (is_null($indexQueueItem)) {
286		throw new \UnexpectedValueException('Can not get index queue item', 1482162337);
287		}
288
289	10	$solrConnection = $this->getSolrConnection($indexQueueItem);
290
291		/** @var $indexer Typo3PageIndexer */
292	10	$indexer = GeneralUtility::makeInstance(Typo3PageIndexer::class, /** @scrutinizer ignore-type */ $page);
293	10	$indexer->setSolrConnection($solrConnection);
294	10	$indexer->setPageAccessRootline($this->getAccessRootline());
295	10	$indexer->setPageUrl($this->generatePageUrl());
296	10	$indexer->setMountPointParameter($GLOBALS['TSFE']->MP);
297	10	$indexer->setIndexQueueItem($indexQueueItem);
298
299	10	$this->responseData['pageIndexed'] = (int)$indexer->indexPage();
300	10	$this->responseData['originalPageDocument'] = (array)$indexer->getPageSolrDocument();
301	10	$this->responseData['solrConnection'] = [
302	10	'rootPage' => $indexQueueItem->getRootPageUid(),
303	10	'sys_language_uid' => Util::getLanguageUid(),
304	10	'solr' => (string)$solrConnection->getNode('write')
305		];
306
307	10	$documentsSentToSolr = $indexer->getDocumentsSentToSolr();
308	10	foreach ($documentsSentToSolr as $document) {
309	10	$this->responseData['documentsSentToSolr'][] = (array)$document;
310		}
311		} catch (\Exception $e) {
312		if ($configuration->getLoggingExceptions()) {
313		$this->logger->log(
314		SolrLogManager::ERROR,
315		'Exception while trying to index page ' . $page->id,
316		[
317		$e->__toString()
318		]
319		);
320		}
321		}
322
323	10	if ($logPageIndexed) {
324		$success = $this->responseData['pageIndexed'] ? 'Success' : 'Failed';
325		$severity = $this->responseData['pageIndexed'] ? SolrLogManager::NOTICE : SolrLogManager::ERROR;
326
327		$this->logger->log(
328		$severity,
329		'Page indexed: ' . $success,
330		$this->responseData
331		);
332		}
333	10	}
334
335		/**
336		* Gets the solr connection to use for indexing the page based on the
337		* Index Queue item's properties.
338		*
339		* @param Item $indexQueueItem
340		* @return SolrConnection Solr server connection
341		*/
342	10	protected function getSolrConnection(Item $indexQueueItem)
343		{
344		/** @var $connectionManager ConnectionManager */
345	10	$connectionManager = GeneralUtility::makeInstance(ConnectionManager::class);
346
347	10	$solrConnection = $connectionManager->getConnectionByRootPageId(
348	10	$indexQueueItem->getRootPageUid(),
349	10	Util::getLanguageUid()
350		);
351
352	10	return $solrConnection;
353		}
354
355		/**
356		* This method retrieves the item from the index queue, that is indexed in this request.
357		*
358		* @return \ApacheSolrForTypo3\Solr\IndexQueue\Item
359		*/
360	10	protected function getIndexQueueItem()
361		{
362		/** @var $indexQueue Queue */
363	10	$indexQueue = GeneralUtility::makeInstance(Queue::class);
364	10	$indexQueueItem = $indexQueue->getItem($this->request->getParameter('item'));
365	10	return $indexQueueItem;
366		}
367		}
368

TYPO3-Solr / ext-solr

Push — master ( 1a818c...84aa0d )

PageIndexer::getSolrConnection() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like