carno-php / log

src/Formatter/Text.php

Spacing +6 added lines, -6 removed lines

@@ -58,10 +58,10 @@ 
     {
         return sprintf(
             "[%s] [%s] [%s] : %s ~ %s\n",
-            $this->colorSignBGN . $this->colors[$level] . strtoupper($level) . $this->colorSignEND,
+            $this->colorSignBGN.$this->colors[$level].strtoupper($level).$this->colorSignEND,
             date('Y-m-d H:i:s'),
             strtoupper($scene),
-            $this->colorSignBGN . $this->colorMessage . $message . $this->colorSignEND,
+            $this->colorSignBGN.$this->colorMessage.$message.$this->colorSignEND,
             $this->context($context)
         );
     }
@@ -74,16 +74,16 @@ 
     {
         $print = '[';
 
-        array_walk($context, function ($item, $key) use (&$print) {
-            $ctx = $this->colorSignBGN . $this->colorCtxKey . $key . $this->colorSignEND . '=';
+        array_walk($context, function($item, $key) use (&$print) {
+            $ctx = $this->colorSignBGN.$this->colorCtxKey.$key.$this->colorSignEND.'=';
             if (is_array($item)) {
                 $ctx .= json_encode($item, JSON_UNESCAPED_SLASHES | JSON_UNESCAPED_UNICODE);
             } else {
                 $ctx .= $item;
             }
-            $print .= $ctx . ',';
+            $print .= $ctx.',';
         });
 
-        return rtrim($print, ',') . ']';
+        return rtrim($print, ',').']';
     }
 }

src/Formatter/JSON.php

Spacing +1 added lines, -1 removed lines

@@ -48,6 +48,6 @@
                 $context
             ),
             JSON_UNESCAPED_SLASHES | JSON_UNESCAPED_UNICODE
-        ) . "\n";
+        )."\n";
     }
 }

src/Logger.php

Spacing +4 added lines, -4 removed lines

@@ -71,19 +71,19 @@
      */
     public function reconfigure(Configure $configure) : void
     {
-        $configure->syncLevel($this->scene, function (string $level) {
+        $configure->syncLevel($this->scene, function(string $level) {
             $this->allows = array_slice($this->levels, 0, array_search($level, $this->levels, true) + 1);
         });
 
-        $configure->syncFormatter($this->scene, function (Formatter $formatter) {
+        $configure->syncFormatter($this->scene, function(Formatter $formatter) {
             $this->formatter = $formatter;
         });
 
-        $configure->syncOutputter($this->scene, function (Outputter $outputter) {
+        $configure->syncOutputter($this->scene, function(Outputter $outputter) {
             $this->outputter = $outputter;
         });
 
-        $configure->syncReplicator($this->scene, function (Replicated $replicated = null) {
+        $configure->syncReplicator($this->scene, function(Replicated $replicated = null) {
             $this->replicator = $replicated;
         });
     }

src/Connections.php

Spacing +3 added lines, -3 removed lines

@@ -30,7 +30,7 @@ 
     public function hosting(Address $address, Closure $connector) : Outputter
     {
         return
-            $this->connected[$cid = (string)$address] ??
+            $this->connected[$cid = (string) $address] ??
             $this->connected[$cid] = $this->watch($cid, $connector($address))
         ;
     }
@@ -42,7 +42,7 @@ 
      */
     private function watch(string $cid, Closeable $conn) : Closeable
     {
-        $conn->closed()->then(function () use ($cid) {
+        $conn->closed()->then(function() use ($cid) {
             unset($this->connected[$cid]);
         });
 
@@ -55,7 +55,7 @@ 
      */
     public function close(Address $address) : Promised
     {
-        return ($c = $this->connected[(string)$address] ?? null) ? $c->close() : Promise::resolved();
+        return ($c = $this->connected[(string) $address] ?? null) ? $c->close() : Promise::resolved();
     }
 
     /**

src/Configure.php

Spacing +9 added lines, -9 removed lines

@@ -65,9 +65,9 @@ 
     {
         $sync(debug() ? LogLevel::DEBUG : LogLevel::INFO);
 
-        $this->watched[] = $this->cfg->overrides(static function (string $level) use ($sync) {
+        $this->watched[] = $this->cfg->overrides(static function(string $level) use ($sync) {
             debug() || $sync($level);
-        }, 'log.level', $scene . '.log.level');
+        }, 'log.level', $scene.'.log.level');
     }
 
     /**
@@ -78,9 +78,9 @@ 
     {
         $sync($this->getFormatter('text'));
 
-        $this->watched[] = $this->cfg->overrides(function (string $type) use ($sync) {
+        $this->watched[] = $this->cfg->overrides(function(string $type) use ($sync) {
             debug() || $sync($this->getFormatter($type));
-        }, 'log.format', $scene . '.log.format');
+        }, 'log.format', $scene.'.log.format');
     }
 
     /**
@@ -91,9 +91,9 @@ 
     {
         $sync($this->getOutputter('stdout://'));
 
-        $this->watched[] = $this->cfg->overrides(function (string $dsn) use ($sync) {
+        $this->watched[] = $this->cfg->overrides(function(string $dsn) use ($sync) {
             debug() || $sync($this->getOutputter($dsn));
-        }, 'log.addr', $scene . '.log.addr');
+        }, 'log.addr', $scene.'.log.addr');
     }
 
     /**
@@ -102,9 +102,9 @@ 
      */
     public function syncReplicator(string $scene, Closure $sync) : void
     {
-        $this->watched[] = $this->cfg->overrides(function (string $dsn = null) use ($sync) {
+        $this->watched[] = $this->cfg->overrides(function(string $dsn = null) use ($sync) {
             debug() || $sync($this->getReplicator($dsn));
-        }, 'log.replica', $scene . '.log.replica');
+        }, 'log.replica', $scene.'.log.replica');
     }
 
     /**
@@ -143,7 +143,7 @@ 
                 if ($this->cmg) {
                     return $this->cmg->hosting(
                         new Address($parsed['host'], $parsed['port'] ?? 80),
-                        static function (Address $address) {
+                        static function(Address $address) {
                             return new TCP($address);
                         }
                     );

src/Outputter/TCP.php

Spacing +4 added lines, -4 removed lines

@@ -80,14 +80,14 @@
         $this->endpoint = $endpoint;
 
         $this->events = (new Events())
-            ->attach(Events\Socket::CONNECTED, function () {
+            ->attach(Events\Socket::CONNECTED, function() {
                 $this->connected();
             })
-            ->attach(Events\Socket::CLOSED, function () {
+            ->attach(Events\Socket::CLOSED, function() {
                 $this->connecting();
             })
-            ->attach(Events\Socket::ERROR, function () {
-                Timer::after(self::RETRY_WAIT, function () {
+            ->attach(Events\Socket::ERROR, function() {
+                Timer::after(self::RETRY_WAIT, function() {
                     $this->connecting();
                 });
             })

src/Replicator/LogIO.php

Spacing +2 added lines, -2 removed lines

@@ -54,7 +54,7 @@ 
         $this->cmg = $cmg;
         $this->recv = $recv;
 
-        $this->pipe = $cmg->hosting($recv, static function (Address $recv) {
+        $this->pipe = $cmg->hosting($recv, static function(Address $recv) {
             return new TCP($recv);
         });
     }
@@ -76,7 +76,7 @@ 
     {
         $buf = '';
 
-        $node = $this->env->app() . (($t = $this->env->tagged()) ? sprintf(':%s', $t) : '');
+        $node = $this->env->app().(($t = $this->env->tagged()) ? sprintf(':%s', $t) : '');
         $stream = $scene;
 
         if (!isset($this->assets[$node][$stream])) {