AOE\Crawler\Domain\Repository\ProcessRepository

Complexity

Total Complexity

11

Size/Duplication

Total Lines	128
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	5

Test Coverage

Coverage

76.09%

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	findAll()	0	35	5
A	findByProcessId()	0	10	1
A	countAll()	0	4	1
A	countActive()	0	4	1
A	countNotTimeouted()	0	4	1
A	getLimitFromItemCountAndOffset()	0	8	1
A	deleteProcessesMarkedAsDeleted()	0	4	1

<?php
namespace AOE\Crawler\Domain\Repository;

/***************************************************************
 *  Copyright notice
 *
 *  (c) 2017 AOE GmbH <dev@aoe.com>
 *
 *  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 AOE\Crawler\Domain\Model\Process;
use AOE\Crawler\Domain\Model\ProcessCollection;
use TYPO3\CMS\Core\Utility\GeneralUtility;

/**
 * Class ProcessRepository
 *
 * @package AOE\Crawler\Domain\Repository
 */
class ProcessRepository extends AbstractRepository
{
    /**
     * @var string
     */
    protected $tableName = 'tx_crawler_process';

    /**
     * This method is used to find all cli processes within a limit.
     *
     * @param  string $orderField
     * @param  string $orderDirection
     * @param  integer $itemCount
     * @param  integer $offset
     * @param  string $where
     *
     * @return ProcessCollection
     */
    public function findAll($orderField = '', $orderDirection = 'DESC', $itemCount = null, $offset = null, $where = '')
    {
        /** @var ProcessCollection $collection */
        $collection = GeneralUtility::makeInstance(ProcessCollection::class);

        $orderField = trim($orderField);
        $orderField = empty($orderField) ? 'process_id' : $orderField;

        $orderDirection = strtoupper(trim($orderDirection));
        $orderDirection = in_array($orderDirection, ['ASC', 'DESC']) ? $orderDirection : 'DESC';

        $rows = $this->getDB()->exec_SELECTgetRows(

The method AOE\Crawler\Domain\Repository\AbstractRepository::getDB() has been deprecated with message: since crawler v6.5.1, will be removed in crawler v9.0.0.

            '*',
            $this->tableName,
            $where,
            '',
            htmlspecialchars($orderField) . ' ' . htmlspecialchars($orderDirection),
            self::getLimitFromItemCountAndOffset($itemCount, $offset)
        );

        if (is_array($rows)) {
            foreach ($rows as $row) {
                $process = new Process();
                $process->setProcessId($row['process_id']);
                $process->setActive($row['active']);
                $process->setTtl($row['ttl']);
                $process->setAssignedItemsCount($row['assigned_items_count']);
                $process->setDeleted($row['deleted']);
                $process->setSystemProcessId($row['system_process_id']);
                $collection->append($process);
            }
        }

        return $collection;

The return type of return $collection; (AOE\Crawler\Domain\Model\ProcessCollection) is incompatible with the return type declared by the interface TYPO3\CMS\Extbase\Persistence\RepositoryInterface::findAll of type TYPO3\CMS\Extbase\Persistence\QueryResultInterface|array.

    }

    /**
     * @param $processId
     * @return array
     */
    public function findByProcessId($processId): array
    {
        $query = $this->createQuery();
        $querySettings = $query->getQuerySettings();
        $querySettings->setRespectStoragePage(false);
        $querySettings->setIgnoreEnableFields(false);
        $query->setQuerySettings($querySettings);
        $query->matching($query->equals('process_id', $processId));
        return $query->execute(true);
    }

    /**
     * This method is used to count all processes in the process table.
     *
     * @param  string $where Where clause
     *
     * @return integer
     */
    public function countAll($where = '1 = 1')
    {
        return $this->countByWhere($where);
    }

    /**
     * Returns the number of active processes.
     *
     * @return integer
     */
    public function countActive()
    {
        return $this->countByWhere('active = 1 AND deleted = 0');
    }

    /**
     * Returns the number of processes that live longer than the given timestamp.
     *
     * @param  integer $ttl
     *
     * @return integer
     */
    public function countNotTimeouted($ttl)
    {
        return $this->countByWhere('deleted = 0 AND ttl > ' . intval($ttl));
    }

    /**
     * Get limit clause
     *
     * @param  integer $itemCount
     * @param  integer $offset
     *
     * @return string
     */
    public static function getLimitFromItemCountAndOffset($itemCount, $offset)
    {
        $itemCount = filter_var($itemCount, FILTER_VALIDATE_INT, ['options' => ['min_range' => 1, 'default' => 20]]);
        $offset = filter_var($offset, FILTER_VALIDATE_INT, ['options' => ['min_range' => 0, 'default' => 0]]);
        $limit = $offset . ', ' . $itemCount;

        return $limit;
    }

    /**
     * @return void
     */
    public function deleteProcessesMarkedAsDeleted()
    {
        $this->getDB()->exec_DELETEquery('tx_crawler_process', 'deleted = 1');

The method AOE\Crawler\Domain\Repository\AbstractRepository::getDB() has been deprecated with message: since crawler v6.5.1, will be removed in crawler v9.0.0.

    }
}