library\search\indexer\TermCount

Complexity

Total Complexity

16

Size/Duplication

Total Lines	112
Duplicated Lines	12.5 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes	4
Bugs	0	Features	1

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	execute()	0	4	1
A	applyFilters()	9	9	2
B	storeDocumentTermCount()	0	27	5
A	createTermCountForDocument()	0	7	1
A	iterateDocumentsAndCreateTermCount()	0	10	3
A	executeStoreDocumentTermCount()	5	10	3

<?php
/**
 * User: jensk
 * Date: 1-3-2017
 * Time: 10:22
 */

namespace library\search\indexer;


use library\search\DocumentTokenizer;
use library\search\Indexer;
use library\storage\Storage;

class TermCount
{
	/**
	 * @var \PDO
	 */
	protected $dbHandle;
	protected $documents;
	protected $filters;
	protected $storage;

	/**
	 * TermCount constructor.
	 *
	 * @param \PDO    $dbHandle
	 * @param array   $documents
	 * @param array   $filters
	 * @param Storage $jsonStorage
	 */
	public function __construct($dbHandle, $documents, $filters, $jsonStorage)
	{
		$this->dbHandle = $dbHandle;
		$this->documents = $documents;
		$this->filters = $filters;
		$this->storage = $jsonStorage;
	}

	public function execute()
	{
		$this->iterateDocumentsAndCreateTermCount($this->documents);
	}

	protected function applyFilters($tokens)

This method seems to be duplicated in your project.

	{
		foreach ($this->filters as $filterName) {
			$filterClassName = '\library\search\filters\\' . $filterName;
			$filter = new $filterClassName($tokens);
			$tokens = $filter->getFilterResults();
		}
		return $tokens;
	}

	protected function storeDocumentTermCount($document, $documentTermCount)
	{
		$db = $this->dbHandle;
		$sqlStart = '
			INSERT INTO `term_count` (`documentPath`, `term`, `count`, `field`)
				 VALUES ';
		$sql = $sqlStart;
		$values = array();
		$quotedDocumentPath = $db->quote($document->path);
		$i = 0;
		foreach ($documentTermCount as $field => $countArray) {
			$quotedField = $db->quote($field);
			foreach ($countArray as $term => $count) {
				$values[] = $quotedDocumentPath . ', ' . $db->quote($term) . ', ' . $db->quote($count) . ', ' . $quotedField;
				$i += 1;
				if ($i >= Indexer::SQLITE_MAX_COMPOUND_SELECT) {
					$this->executeStoreDocumentTermCount($values, $sql, $db);
					$values = array();
					$sql = $sqlStart;
					$i = 0;
				}
			}
		}
		if (count($values) != 0) {
			$this->executeStoreDocumentTermCount($values, $sql, $db);
		}
	}

	/**
	 * @param $values
	 * @param $sql
	 * @param $db
	 *
	 * @throws \Exception
	 */
	protected function executeStoreDocumentTermCount($values, $sql, $db)
	{
		$sql .= '(' . implode('),' . PHP_EOL . '(', $values) . ');';
		$stmt = $db->prepare($sql);
		if ($stmt === false || !$stmt->execute()) {

This code seems to be duplicated across your project.

			$errorInfo = $db->errorInfo();
			$errorMsg = $errorInfo[2];
			throw new \Exception('SQLite Exception: ' . $errorMsg . ' in SQL: <br /><pre>' . $sql . '</pre>');
		}
	}

	/**
	 * @param $document
	 */
	private function createTermCountForDocument($document)
	{
		$tokenizer = new DocumentTokenizer($document, $this->storage);
		$tokens = $tokenizer->getTokens();
		$documentTermCount = $this->applyFilters($tokens);
		$this->storeDocumentTermCount($document, $documentTermCount);
	}

	/**
	 * @param $documents
	 */
	private function iterateDocumentsAndCreateTermCount($documents)
	{
		foreach ($documents as $document) {
			if ($document->type === 'folder') {
				$this->iterateDocumentsAndCreateTermCount($document->content);
			} else {
				$this->createTermCountForDocument($document);
			}
		}
	}
}