SeasX / seas-logger

src/Kafka/Metadata.php

Spacing +1 added lines, -1 removed lines

@@ -24,7 +24,7 @@
 
         $header = $this->requestHeader('seaslog-kafka', self::METADATA_REQUEST, self::METADATA_REQUEST);
         $data = self::encodeArray($payloads, [$this, 'encodeString'], self::PACK_INT16);
-        $data = self::encodeString($header . $data, self::PACK_INT32);
+        $data = self::encodeString($header.$data, self::PACK_INT32);
 
         return $data;
     }

src/Kafka/Config.php

Spacing +2 added lines, -2 removed lines

@@ -64,7 +64,7 @@ 
     public function __construct(array $configs)
     {
         foreach ($configs as $name => $value) {
-            $method = 'set' . ucfirst($name);
+            $method = 'set'.ucfirst($name);
             $this->$method($value);
         }
     }
@@ -152,7 +152,7 @@ 
 
         $brokers = array_filter(
             explode(',', $brokerList),
-            function (string $broker): bool {
+            function(string $broker): bool {
                 return preg_match('/^(.*:[\d]+)$/', $broker) === 1;
             }
         );

src/Kafka/Socket/SocketIO.php

Spacing +2 added lines, -2 removed lines

@@ -60,8 +60,8 @@
         $maxRetry = $this->config['retry'];
         $reconnectCount = 0;
         while (true) {
-            $isConnect = $this->config['timeout'] ? $client->connect($host, (int)$port,
-                $this->config['timeout']) : $client->connect($host, (int)$port);
+            $isConnect = $this->config['timeout'] ? $client->connect($host, ( int ) $port,
+                $this->config['timeout']) : $client->connect($host, ( int ) $port);
             if (!$isConnect) {
                 $reconnectCount++;
                 if ($maxRetry > 0 && $reconnectCount >= $maxRetry) {

src/Kafka/ProtocolTool.php

Spacing +2 added lines, -2 removed lines

@@ -43,7 +43,7 @@ 
     public static function encode(int $key, array $payloads): string
     {
         if (!isset(self::$objects[$key])) {
-            throw new NotSupportedException('Not support api key, key:' . $key);
+            throw new NotSupportedException('Not support api key, key:'.$key);
         }
 
         return self::$objects[$key]->encode($payloads);
@@ -58,7 +58,7 @@ 
     public static function decode(int $key, string $data): array
     {
         if (!isset(self::$objects[$key])) {
-            throw new NotSupportedException('Not support api key, key:' . $key);
+            throw new NotSupportedException('Not support api key, key:'.$key);
         }
 
         return self::$objects[$key]->decode($data);

src/Kafka/Broker.php

Spacing +2 added lines, -2 removed lines

@@ -57,7 +57,7 @@ 
         $brokers = [];
 
         foreach ($brokersResult as $value) {
-            $brokers[$value['nodeId']] = $value['host'] . ':' . $value['port'];
+            $brokers[$value['nodeId']] = $value['host'].':'.$value['port'];
         }
 
         $changed = false;
@@ -70,7 +70,7 @@ 
 
         $newTopics = [];
         foreach ($topics as $topic) {
-            if ((int)$topic['errorCode'] !== Protocol::NO_ERROR) {
+            if (( int ) $topic['errorCode'] !== Protocol::NO_ERROR) {
                 continue;
             }
 

src/LoggerConfig.php

Spacing +6 added lines, -6 removed lines

@@ -127,9 +127,9 @@ 
                         $milliseconds = 0;
                     }
                     if ($tmp === '%T') {
-                        $msg[] = date($this->datetime_format, (int)$timestamp) . '.' . (int)$milliseconds;
+                        $msg[] = date($this->datetime_format, ( int ) $timestamp).'.'.( int ) $milliseconds;
                     } else {
-                        $msg[] = date($this->datetime_format, (int)$timestamp);
+                        $msg[] = date($this->datetime_format, ( int ) $timestamp);
                     }
                     break;
                 case '%Q':
@@ -160,10 +160,10 @@ 
                         $this->recall_depth + 2);
                     if ($tmp === '%F') {
                         $trace = $trace[$this->recall_depth];
-                        $msg[] = $this->useBasename ? basename($trace['file']) . ':' . $trace['line'] : $trace['file'] . ':' . $trace['line'];
+                        $msg[] = $this->useBasename ? basename($trace['file']).':'.$trace['line'] : $trace['file'].':'.$trace['line'];
                     } else {
                         $trace = $trace[$this->recall_depth + 1];
-                        $msg[] = $trace['class'] . $trace['type'] . $trace['function'];
+                        $msg[] = $trace['class'].$trace['type'].$trace['function'];
                     }
                     break;
                 case '%U':
@@ -189,7 +189,7 @@ 
         }
         $color = ArrayHelper::getValue($template, '%c');
         $color && $msg['%c'] = $color;
-        $key = $this->appName . ($module ? '_' . $module : '');
+        $key = $this->appName.($module ? '_'.$module : '');
         $this->buffer[$key][] = $msg;
         $this->flush();
     }
@@ -202,7 +202,7 @@ 
     {
         if (!empty($this->buffer) && $flush || ($this->bufferSize !== 0 && $this->bufferSize <= count($this->buffer))) {
             foreach ($this->targetList as $index => $target) {
-                rgo(function () use ($target, $flush) {
+                rgo(function() use ($target, $flush) {
                     $target->export($this->buffer);
                 });
             }

src/HtmlColor.php

Spacing +1 added lines, -1 removed lines

@@ -157,7 +157,7 @@
      */
     public static function getColor(string $color): string
     {
-        return (string)ArrayHelper::getValue(static::$colors, $color, '');
+        return ( string ) ArrayHelper::getValue(static::$colors, $color, '');
     }
 
     /**

src/AbstractConfig.php

Spacing +1 added lines, -1 removed lines

@@ -54,7 +54,7 @@
         foreach ($this->targetList as $target) {
             $target->setTemplate($this->template)->setCustomerFieldType($this->customerType)->setSplit($this->split);
         }
-        register_shutdown_function(function () {
+        register_shutdown_function(function() {
             $this->flush(true);
         });
         $this->tick > 0 && Timer::tick($this->tick * 1000, [$this, 'flush'], [true]);

src/Logger.php

Spacing +3 added lines, -3 removed lines

@@ -217,7 +217,7 @@ 
      */
     public static function analyzerCount($level = 'all', $log_path = '*', $key_word = null)
     {
-        return SeasLog::analyzerCount($level, $log_path, (string)$key_word);
+        return SeasLog::analyzerCount($level, $log_path, ( string ) $key_word);
     }
 
     /**
@@ -243,7 +243,7 @@ 
         return SeasLog::analyzerDetail(
             $level,
             $log_path,
-            (string)$key_word,
+            ( string ) $key_word,
             $start,
             $limit,
             $order
@@ -335,7 +335,7 @@ 
      */
     public function log($level, $message, array $context = array())
     {
-        if ((int)$level < self::$RequestLevel) {
+        if (( int ) $level < self::$RequestLevel) {
             return;
         }