gplcart\modules\extractor\handlers\Extractor

Complexity

Total Complexity

13

Size/Duplication

Total Lines	91
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
B	process()	0	28	6
B	exists()	0	24	6

<?php

/**
 * @package Extractor
 * @author Iurii Makukh <gplcart.software@gmail.com>
 * @copyright Copyright (c) 2015, Iurii Makukh
 * @license https://www.gnu.org/licenses/gpl.html GNU/GPLv3
 */

namespace gplcart\modules\extractor\handlers;

use gplcart\core\models\Translation;
use gplcart\modules\extractor\models\Extractor as ExtractorModel;

/**
 * String extractor handler
 */
class Extractor
{

    /**
     * Translation UI model class instance
     * @var \gplcart\core\models\Translation $translation
     */
    protected $translation;

    /**
     * Extractor model instance
     * @var \gplcart\modules\extractor\models\Extractor $extractor
     */
    protected $extractor;

    /**
     * @param ExtractorModel $extractor
     * @param Translation $translation
     */
    public function __construct(ExtractorModel $extractor, Translation $translation)
    {
        $this->extractor = $extractor;
        $this->translation = $translation;
    }

    /**
     * Processes one extraction job iteration
     * @param array $job
     * @return array
     */
    public function process(array &$job)
    {
        if (!isset($job['context']['offset'])) {
            $job['context']['offset'] = 0;
        }

        $scanned = $this->extractor->scan(array('directory' => $job['data']['directory']));
        $files = array_slice($scanned, $job['context']['offset'], $job['data']['limit']);

        if (empty($files)) {
            $job['status'] = false;
            $job['done'] = $job['total'];
            return $job;
        }

        foreach ($files as $file) {
            foreach ($this->extractor->extractFromFile($file) as $string) {
                if (!$this->exists($string, $job)) {
                    $job['inserted']++;
                    gplcart_file_csv($job['data']['file'], array($string, ''));
                }
            }
        }

        $job['context']['offset'] += count($files);
        $job['done'] = $job['context']['offset'];
        return $job;
    }

    /**
     * Check if the string already exists in the file
     * @param string $string
     * @param array $job
     * @return boolean
     */
    protected function exists($string, array $job)
    {
        // Check core translation for dublicates
        if (!empty($job['data']['check_file'])) {
            $translations = $this->translation->loadTranslation($job['data']['check_file']);
            if (isset($translations[$string])) {
                return true;
            }
        }

        // Check the string already written
        $handle = fopen($job['data']['file'], 'r');

        $found = false;
        while (($data = fgetcsv($handle, 1000)) !== false) {
            if (isset($data[0]) && $data[0] === $string) {
                $found = true;
                break;
            }
        }

        fclose($handle);
        return $found;
    }

}