Paraunit\Parser\JSON\LogFetcher

Complexity

Total Complexity

5

Size/Duplication

Total Lines	56
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

100%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	fetch()	0	16	2
A	cleanLog()	0	6	1
A	createLogEnding()	0	7	1

<?php

declare(strict_types=1);

namespace Paraunit\Parser\JSON;

use Paraunit\Configuration\TempFilenameFactory;
use Paraunit\Process\AbstractParaunitProcess;

/**
 * Class LogFetcher
 * @package Paraunit\Parser\JSON
 */
class LogFetcher
{
    const LOG_ENDING_STATUS = 'paraunitEnd';

    /** @var TempFilenameFactory */
    private $fileName;

    /**
     * LogFetcher constructor.
     * @param TempFilenameFactory $fileName
     */
    public function __construct(TempFilenameFactory $fileName)
    {
        $this->fileName = $fileName;
    }

    /**
     * @param AbstractParaunitProcess $process
     * @return \stdClass[]
     */
    public function fetch(AbstractParaunitProcess $process): array
    {
        $filePath = $this->fileName->getFilenameForLog($process->getUniqueId());
        $fileContent = '';

        if (file_exists($filePath)) {
            /** @var string $fileContent */
            $fileContent = file_get_contents($filePath);
            unlink($filePath);
        }

        $logs = json_decode(self::cleanLog($fileContent));
        $logs[] = $this->createLogEnding();

        return $logs;
    }

    /**
     * @param string $jsonString The dirty output
     * @return string            The normalized log, as an array of JSON objects
     */
    private static function cleanLog(string $jsonString): string
    {
        $splitted = preg_replace('/\}\{/', '},{', $jsonString);

        return '[' . $splitted . ']';
    }

    private function createLogEnding(): \stdClass
    {
        $logEnding = new \stdClass();
        $logEnding->status = self::LOG_ENDING_STATUS;

        return $logEnding;
    }
}