StreamWriterTest::setUp() - Code Metrics - graze/dog-statsd - Measure and Improve Code Quality continuously with Scrutinizer

StreamWriterTest::setUp() A
last analyzed 2021-04-14 20:29 UTC

↳ Parent: StreamWriterTest

Complexity

Conditions	1
Paths	1

Size

Total Lines	13
Code Lines	6

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
cc	1
eloc	6
c	1
b	0
f	0
nc	1
nop	0
dl	0
loc	13
rs	10

<?php

namespace Graze\DogStatsD\Test\Integration\Stream;

use Graze\DogStatsD\Stream\StreamWriter;
use Graze\DogStatsD\Test\TestCase;
use ReflectionProperty;

class StreamWriterTest extends TestCase
{
    /** @var StreamWriter */
    private $writer;
    /** @var resource */
    private $socket;

    public function setUp(): void
    {
        parent::setUp();

        $this->writer = new StreamWriter('test', 'python-echo');

        $this->writer->write('');

        // get the socket
        $reflector = new ReflectionProperty(StreamWriter::class, 'socket');
        $reflector->setAccessible(true);
        /** @var resource $socket */
        $this->socket = $reflector->getValue($this->writer);
    }

    /**
     * @param int $len
     *
     * @return string
     */
    private function readSocket($len)
    {
        $time = microtime(true);
        $out = '';
        do {
            $out .= fread($this->socket, $len);
        } while (strlen($out) < $len && microtime(true) < $time + 1);

        return $out;
    }

    public function testEcho()
    {
        $this->assertTrue($this->writer->write('echo'));
        $out = $this->readSocket(4);

        $this->assertEquals('echo', $out);
    }

    public function testLongMessage()
    {
        $this->assertTrue($this->writer->write(str_repeat('x', 10000)));
        $out = $this->readSocket(20000);

        $this->assertEquals(10000, strlen($out));
        $this->assertEquals(str_repeat('x', 10000), $out);
    }
}


1			<?php
2
3			namespace Graze\DogStatsD\Test\Integration\Stream;
4
5			use Graze\DogStatsD\Stream\StreamWriter;
6			use Graze\DogStatsD\Test\TestCase;
7			use ReflectionProperty;
8
9			class StreamWriterTest extends TestCase
10			{
11			/** @var StreamWriter */
12			private $writer;
13			/** @var resource */
14			private $socket;
15
16			public function setUp(): void
17			{
18			parent::setUp();
19
20			$this->writer = new StreamWriter('test', 'python-echo');
21
22			$this->writer->write('');
23
24			// get the socket
25			$reflector = new ReflectionProperty(StreamWriter::class, 'socket');
26			$reflector->setAccessible(true);
27			/** @var resource $socket */
28			$this->socket = $reflector->getValue($this->writer);
29			}
30
31			/**
32			* @param int $len
33			*
34			* @return string
35			*/
36			private function readSocket($len)
37			{
38			$time = microtime(true);
39			$out = '';
40			do {
41			$out .= fread($this->socket, $len);
42			} while (strlen($out) < $len && microtime(true) < $time + 1);
43
44			return $out;
45			}
46
47			public function testEcho()
48			{
49			$this->assertTrue($this->writer->write('echo'));
50			$out = $this->readSocket(4);
51
52			$this->assertEquals('echo', $out);
53			}
54
55			public function testLongMessage()
56			{
57			$this->assertTrue($this->writer->write(str_repeat('x', 10000)));
58			$out = $this->readSocket(20000);
59
60			$this->assertEquals(10000, strlen($out));
61			$this->assertEquals(str_repeat('x', 10000), $out);
62			}
63			}
64

graze / dog-statsd

StreamWriterTest::setUp() A last analyzed 2021-04-14 20:29 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

StreamWriterTest::setUp() A
last analyzed 2021-04-14 20:29 UTC