LogPrinter::write() - Code Metrics - Inspection of "[WIP] Implement pipelines" - facile-it/paraunit - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#94)

by Alessandro

created 2017-06-22 15:01 UTC

LogPrinter::write() A

↳ Parent: LogPrinter

Complexity

Conditions	3
Paths	2

Size

Total Lines	7
Code Lines	3

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	3
CRAP Score	3

Importance

Changes

Metric	Value
dl	0
loc	7
ccs	3
cts	3
cp	1
rs	9.4285
c	0
b	0
f	0
cc	3
eloc	3
nc	2
nop	1
crap	3

<?php
declare(strict_types=1);

namespace Paraunit\Parser\JSON;

use Paraunit\Configuration\EnvVariables;
use PHPUnit\Framework\AssertionFailedError;
use PHPUnit\Framework\Test;
use PHPUnit\Framework\TestCase;
use PHPUnit\Framework\TestFailure;
use PHPUnit\Framework\TestListener;
use PHPUnit\Framework\TestSuite;
use PHPUnit\Framework\Warning;
use PHPUnit\Util;

/**
 * This class comes from Util\Log_JSON.
 * It's copied and refactored here because it's deprecated in PHPUnit 5.7 and it will be dropped in PHPUnit 6
 *
 * Class LogPrinter
 * @package Paraunit\Parser\JSON
 */
class LogPrinter extends Util\Printer implements TestListener
{
    /** @var string */
    private $logDirectory;

    /** @var int */
    private $testSuiteLevel;

    /** @var string */
    private $currentTestSuiteName;

    /** @var string */
    private $currentTestName;

    /** @var bool */
    private $currentTestPass;

    public function __construct()
    {
        $this->testSuiteLevel = 0;
        $this->autoFlush = true;

        $logFilename = $this->getLogFilename();

        $logDir = $this->getLogDirectory();
        if (! @mkdir($logDir, 0777, true) && ! is_dir($logDir)) {

            throw new \RuntimeException('Cannot create folder for JSON logs');
        }

        $this->out = fopen($logDir . $logFilename, 'wt');
    }

    /**
     * An error occurred.
     *
     * @param Test $test
     * @param \Exception $e
     * @param float $time
     */
    public function addError(Test $test, \Exception $e, $time)

    {
        $this->writeCase(
            'error',
            $time,
            Util\Filter::getFilteredStacktrace($e, false),

            TestFailure::exceptionToString($e),
            $test
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
        );

        $this->currentTestPass = false;
    }

    /**
     * A warning occurred.
     *
     * @param Test $test
     * @param Warning $e
     * @param float $time
     */
    public function addWarning(Test $test, Warning $e, $time)

    {
        $this->writeCase(
            'warning',
            $time,
            Util\Filter::getFilteredStacktrace($e, false),

            TestFailure::exceptionToString($e),
            $test
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
        );

        $this->currentTestPass = false;
    }

    /**
     * A failure occurred.
     *
     * @param Test $test
     * @param AssertionFailedError $e
     * @param float $time
     */
    public function addFailure(Test $test, AssertionFailedError $e, $time)

    {
        $this->writeCase(
            'fail',
            $time,
            Util\Filter::getFilteredStacktrace($e, false),

            TestFailure::exceptionToString($e),
            $test
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
        );

        $this->currentTestPass = false;
    }

    /**
     * Incomplete test.
     *
     * @param Test $test
     * @param \Exception $e
     * @param float $time
     */
    public function addIncompleteTest(Test $test, \Exception $e, $time)

    {
        $this->writeCase(
            'error',
            $time,
            Util\Filter::getFilteredStacktrace($e, false),

            'Incomplete Test: ' . $e->getMessage(),
            $test
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
        );

        $this->currentTestPass = false;
    }

    /**
     * Risky test.
     *
     * @param Test $test
     * @param \Exception $e
     * @param float $time
     */
    public function addRiskyTest(Test $test, \Exception $e, $time)

    {
        $this->writeCase(
            'error',
            $time,
            Util\Filter::getFilteredStacktrace($e, false),

            'Risky Test: ' . $e->getMessage(),
            $test
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
        );

        $this->currentTestPass = false;
    }

    /**
     * Skipped test.
     *
     * @param Test $test
     * @param \Exception $e
     * @param float $time
     */
    public function addSkippedTest(Test $test, \Exception $e, $time)

    {
        $this->writeCase(
            'error',
            $time,
            Util\Filter::getFilteredStacktrace($e, false),

            'Skipped Test: ' . $e->getMessage(),
            $test
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
        );

        $this->currentTestPass = false;
    }

    /**
     * A testsuite started.
     *
     * @param TestSuite $suite
     * @throws \RuntimeException
     */
    public function startTestSuite(TestSuite $suite)
    {
        $this->testSuiteLevel++;
        $this->currentTestSuiteName = $suite->getName();
        $this->currentTestName = '';

        $this->writeArray([
            'event' => 'suiteStart',
            'suite' => $this->currentTestSuiteName,
            'tests' => count($suite)
        ]);
    }

    public function endTestSuite(TestSuite $suite)
    {
        $this->testSuiteLevel--;
        $this->currentTestSuiteName = '';
        $this->currentTestName = '';
    }

    public function startTest(Test $test)
    {
        $this->currentTestName = Util\Test::describe($test);
        $this->currentTestPass = true;

        $this->writeArray([
            'event' => 'testStart',
            'suite' => $this->currentTestSuiteName,
            'test' => $this->currentTestName
        ]);
    }

    /**
     * A test ended.
     *
     * @param Test $test
     * @param float $time
     */
    public function endTest(Test $test, $time)
    {
        if ($this->currentTestPass) {
            $this->writeCase('pass', $time, [], '', $test);
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
        }
    }

    /**
     * @param string $status
     * @param float $time
     * @param array $trace
     * @param string $message
     * @param TestCase|null $test
     */
    protected function writeCase($status, $time, array $trace = [], $message = '', $test = null)
    {
        $output = '';
        // take care of TestSuite producing error (e.g. by running into exception) as TestSuite doesn't have hasOutput
        if ($test !== null && method_exists($test, 'hasOutput') && $test->hasOutput()) {
            $output = $test->getActualOutput();
        }
        $this->writeArray([
            'event' => 'test',
            'suite' => $this->currentTestSuiteName,
            'test' => $this->currentTestName,
            'status' => $status,
            'time' => $time,
            'trace' => $trace,
            'message' => $this->convertToUtf8($message),
            'output' => $output,
        ]);
    }

    /**
     * @param array $buffer
     */
    public function writeArray($buffer)
    {
        array_walk_recursive($buffer, function (&$input) {
            if (is_string($input)) {
                $input = $this->convertToUtf8($input);
            }
        });

        $this->write(json_encode($buffer, JSON_PRETTY_PRINT));
    }

    public function write($buffer)
    {
        // ignore everything that is not a JSON object
        if ($buffer != '' && $buffer[0] === '{') {
            parent::write($buffer);
        }
    }

    /**
     * @return string
     * @throws \InvalidArgumentException
     */
    private function getLogFilename(): string
    {
        return getenv(EnvVariables::PROCESS_UNIQUE_ID) . '.json.log';
    }

    /**
     * @return string
     * @throws \InvalidArgumentException
     */
    private function getLogDirectory(): string
    {
        $this->logDirectory = getenv(EnvVariables::LOG_DIR);
        
        if ($this->logDirectory === false) {
            throw new \InvalidArgumentException('Log directory not received: environment variable not set');
        }
        
        if (substr($this->logDirectory, -1) !== DIRECTORY_SEPARATOR) {
            $this->logDirectory .= DIRECTORY_SEPARATOR;
        }

        return $this->logDirectory;
    }

    private function convertToUtf8($string): string
    {
        if (! $this->isUtf8($string)) {
            if (\function_exists('mb_convert_encoding')) {
                return \mb_convert_encoding($string, 'UTF-8');
            }

            return \utf8_encode($string);
        }

        return $string;
    }

    private function isUtf8(string $string): bool
    {
        $length = \strlen($string);

        for ($i = 0; $i < $length; $i++) {
            if (\ord($string[$i]) < 0x80) {
                $n = 0;
            } elseif ((\ord($string[$i]) & 0xE0) == 0xC0) {
                $n = 1;
            } elseif ((\ord($string[$i]) & 0xF0) == 0xE0) {
                $n = 2;
            } elseif ((\ord($string[$i]) & 0xF0) == 0xF0) {
                $n = 3;
            } else {
                return false;
            }

            for ($j = 0; $j < $n; $j++) {
                if ((++$i == $length) || ((\ord($string[$i]) & 0xC0) != 0x80)) {
                    return false;
                }
            }
        }

        return true;
    }
}


1		<?php
2		declare(strict_types=1);
3
4		namespace Paraunit\Parser\JSON;
5
6		use Paraunit\Configuration\EnvVariables;
7		use PHPUnit\Framework\AssertionFailedError;
8		use PHPUnit\Framework\Test;
9		use PHPUnit\Framework\TestCase;
10		use PHPUnit\Framework\TestFailure;
11		use PHPUnit\Framework\TestListener;
12		use PHPUnit\Framework\TestSuite;
13		use PHPUnit\Framework\Warning;
14		use PHPUnit\Util;
15
16		/**
17		* This class comes from Util\Log_JSON.
18		* It's copied and refactored here because it's deprecated in PHPUnit 5.7 and it will be dropped in PHPUnit 6
19		*
20		* Class LogPrinter
21		* @package Paraunit\Parser\JSON
22		*/
23		class LogPrinter extends Util\Printer implements TestListener
24		{
25		/** @var string */
26		private $logDirectory;
27
28		/** @var int */
29		private $testSuiteLevel;
30
31		/** @var string */
32		private $currentTestSuiteName;
33
34		/** @var string */
35		private $currentTestName;
36
37		/** @var bool */
38		private $currentTestPass;
39
40	9	public function __construct()

facile-it / paraunit

Pull Request — master (#94)

LogPrinter::write() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like