LogIO::send() - Code Metrics - carno-php/log - Measure and Improve Code Quality continuously with Scrutinizer

LogIO::send() A
last analyzed 2019-07-29 03:19 UTC

↳ Parent: LogIO

Complexity

Conditions	3
Paths	4

Size

Total Lines	21
Code Lines	13

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	1

Metric	Value
cc	3
eloc	13
c	1
b	0
f	1
nc	4
nop	4
dl	0
loc	21
rs	9.8333

<?php
/**
 * Replicating to log.io
 * User: moyo
 * Date: 2018/5/2
 * Time: 11:59 AM
 */

namespace Carno\Log\Replicator;

use Carno\Log\Connections;
use Carno\Log\Contracts\Outputter;
use Carno\Log\Contracts\Replicated;
use Carno\Log\Environment;
use Carno\Log\Outputter\TCP;
use Carno\Net\Address;

class LogIO implements Replicated
{
    /**
     * @var Environment
     */
    private $env = null;

    /**
     * @var Connections
     */
    private $cmg = null;

    /**
     * @var Address
     */
    private $recv = null;

    /**
     * @var Outputter
     */
    private $pipe = null;

    /**
     * @var array
     */
    private $assets = [];

    /**
     * LogIO constructor.
     * @param Environment $env
     * @param Connections $cmg
     * @param Address $recv
     */
    public function __construct(Environment $env, Connections $cmg, Address $recv)
    {
        $this->env = $env;
        $this->cmg = $cmg;
        $this->recv = $recv;

        $this->pipe = $cmg->hosting($recv, static function (Address $recv) {
            return new TCP($recv);
        });
    }

    /**
     */
    public function __destruct()
    {
        $this->cmg->close($this->recv);
    }

    /**
     * @param string $scene
     * @param string $level
     * @param string $message
     * @param array $context
     */
    public function send(string $scene, string $level, string $message, array $context) : void
    {
        $buf = '';

        $node = $this->env->app() . (($t = $this->env->tagged()) ? sprintf(':%s', $t) : '');
        $stream = $scene;

        if (!isset($this->assets[$node][$stream])) {
            $this->assets[$node][$stream] = true;
            $buf .= sprintf("+node|%s|%s\r\n", $node, $stream);
        }

        $buf .= sprintf(
            "+log|%s|%s|%s|%s\r\n",
            $stream,
            $node,
            $level,
            sprintf('%s > %s', $message, json_encode($context, JSON_UNESCAPED_SLASHES | JSON_UNESCAPED_UNICODE))
        );

        $this->pipe->write($buf);
    }
}


1			<?php
2			/**
3			* Replicating to log.io
4			* User: moyo
5			* Date: 2018/5/2
6			* Time: 11:59 AM
7			*/
8
9			namespace Carno\Log\Replicator;
10
11			use Carno\Log\Connections;
12			use Carno\Log\Contracts\Outputter;
13			use Carno\Log\Contracts\Replicated;
14			use Carno\Log\Environment;
15			use Carno\Log\Outputter\TCP;
16			use Carno\Net\Address;
17
18			class LogIO implements Replicated
19			{
20			/**
21			* @var Environment
22			*/
23			private $env = null;
24
25			/**
26			* @var Connections
27			*/
28			private $cmg = null;
29
30			/**
31			* @var Address
32			*/
33			private $recv = null;
34
35			/**
36			* @var Outputter
37			*/
38			private $pipe = null;
39
40			/**
41			* @var array
42			*/
43			private $assets = [];
44
45			/**
46			* LogIO constructor.
47			* @param Environment $env
48			* @param Connections $cmg
49			* @param Address $recv
50			*/
51			public function __construct(Environment $env, Connections $cmg, Address $recv)
52			{
53			$this->env = $env;
54			$this->cmg = $cmg;
55			$this->recv = $recv;
56
57			$this->pipe = $cmg->hosting($recv, static function (Address $recv) {
58			return new TCP($recv);
59			});
60			}
61
62			/**
63			*/
64			public function __destruct()
65			{
66			$this->cmg->close($this->recv);
67			}
68
69			/**
70			* @param string $scene
71			* @param string $level
72			* @param string $message
73			* @param array $context
74			*/
75			public function send(string $scene, string $level, string $message, array $context) : void
76			{
77			$buf = '';
78
79			$node = $this->env->app() . (($t = $this->env->tagged()) ? sprintf(':%s', $t) : '');
80			$stream = $scene;
81
82			if (!isset($this->assets[$node][$stream])) {
83			$this->assets[$node][$stream] = true;
84			$buf .= sprintf("+node\|%s\|%s\r\n", $node, $stream);
85			}
86
87			$buf .= sprintf(
88			"+log\|%s\|%s\|%s\|%s\r\n",
89			$stream,
90			$node,
91			$level,
92			sprintf('%s > %s', $message, json_encode($context, JSON_UNESCAPED_SLASHES \| JSON_UNESCAPED_UNICODE))
93			);
94
95			$this->pipe->write($buf);
96			}
97			}
98

carno-php / log

LogIO::send() A last analyzed 2019-07-29 03:19 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

LogIO::send() A
last analyzed 2019-07-29 03:19 UTC