SeasX / seas-logger

src/Targets/KafkaTarget.php

Spacing +1 added lines, -1 removed lines

@@ -129,7 +129,7 @@
                 $log[$name] = $value ? strtotime(explode('.', $value)[0]) : 0;
                 break;
             case "int":
-                $log[$name] = $value ? (int)$value : 0;
+                $log[$name] = $value ? ( int ) $value : 0;
                 break;
             case "string":
                 $log[$name] = $value ? trim($value) : '';

src/Targets/EchoTarget.php

Spacing +1 added lines, -1 removed lines

@@ -25,7 +25,7 @@
                     continue;
                 }
                 ArrayHelper::remove($msg, '%c');
-                echo implode($this->split, $msg) . PHP_EOL;
+                echo implode($this->split, $msg).PHP_EOL;
             }
         }
     }

src/functions.php

Spacing +1 added lines, -1 removed lines

@@ -10,7 +10,7 @@
      */
     function rgo(Closure $function, ?Closure $defer = null): int
     {
-        $cid = go(function () use ($function, $defer): int {
+        $cid = go(function() use ($function, $defer) : int {
             try {
                 if (is_callable($defer)) {
                     defer($defer);

src/SeaslogConfig.php

Spacing +4 added lines, -4 removed lines

@@ -20,7 +20,7 @@ 
     public function __construct(array $target, array $configs = [])
     {
         $this->template = explode($this->split, ini_get('seaslog.default_template'));
-        ini_set('seaslog.recall_depth', (string)$this->recall_depth);
+        ini_set('seaslog.recall_depth', ( string ) $this->recall_depth);
         parent::__construct($target, $configs);
     }
 
@@ -55,7 +55,7 @@ 
         $template = $this->getUserTemplate();
         $module = ArrayHelper::remove($context, 'module');
         if ($module !== null) {
-            Seaslog::setLogger($this->appName . '_' . $module);
+            Seaslog::setLogger($this->appName.'_'.$module);
         }
         isset($template['%Q']) && Seaslog::setRequestID($template['%Q']);
         foreach (array_filter([
@@ -75,7 +75,7 @@ 
                 case AbstractConfig::TYPE_FIELD:
                     $template = implode($this->split, $template);
             }
-            $message = $template . $this->split . $message;
+            $message = $template.$this->split.$message;
         }
         Seaslog::$level($message);
         $this->flush();
@@ -91,7 +91,7 @@ 
             if (($flush || Seaslog::getBufferCount() >= $this->bufferSize) && ($buffer = Seaslog::getBuffer()) !== false) {
                 Seaslog::flushBuffer(0);
                 foreach ($this->targetList as $index => $target) {
-                    rgo(function () use ($target, $buffer) {
+                    rgo(function() use ($target, $buffer) {
                         $target->export($buffer);
                     });
                 }

src/Kafka/Produce.php

Spacing +11 added lines, -11 removed lines

@@ -50,15 +50,15 @@ 
         }
 
         $header = $this->requestHeader('seaslog-kafka', 0, self::PRODUCE_REQUEST);
-        $data = self::pack(self::BIT_B16, (string)($payloads['required_ack'] ?? 0));
-        $data .= self::pack(self::BIT_B32, (string)($payloads['timeout'] ?? 100));
+        $data = self::pack(self::BIT_B16, ( string ) ($payloads['required_ack'] ?? 0));
+        $data .= self::pack(self::BIT_B32, ( string ) ($payloads['timeout'] ?? 100));
         $data .= self::encodeArray(
             $payloads['data'],
             [$this, 'encodeProduceTopic'],
             $payloads['compression'] ?? self::COMPRESSION_NONE
         );
 
-        return self::encodeString($header . $data, self::PACK_INT32);
+        return self::encodeString($header.$data, self::PACK_INT32);
     }
 
     /**
@@ -99,9 +99,9 @@ 
             throw new InvalidArgumentException('given produce data invalid. `messages` is undefined.');
         }
 
-        $data = self::pack(self::BIT_B32, (string)$values['partition_id']);
+        $data = self::pack(self::BIT_B32, ( string ) $values['partition_id']);
         $data .= self::encodeString(
-            $this->encodeMessageSet((array)$values['messages'], $compression),
+            $this->encodeMessageSet(( array ) $values['messages'], $compression),
             self::PACK_INT32
         );
 
@@ -126,7 +126,7 @@ 
         foreach ($messages as $message) {
             $encodedMessage = $this->encodeMessage($message);
 
-            $data .= self::pack(self::BIT_B64, (string)$next)
+            $data .= self::pack(self::BIT_B64, ( string ) $next)
                 . self::encodeString($encodedMessage, self::PACK_INT32);
 
             ++$next;
@@ -151,8 +151,8 @@ 
         $magic = $this->computeMagicByte();
         $attributes = $this->computeAttributes($magic, $compression, $this->computeTimestampType($magic));
 
-        $data = self::pack(self::BIT_B8, (string)$magic);
-        $data .= self::pack(self::BIT_B8, (string)$attributes);
+        $data = self::pack(self::BIT_B8, ( string ) $magic);
+        $data .= self::pack(self::BIT_B8, ( string ) $attributes);
 
         if ($magic >= self::MESSAGE_MAGIC_VERSION1) {
             $data .= self::pack(self::BIT_B64, $this->clock->now()->format('Uv'));
@@ -171,10 +171,10 @@ 
         // message value
         $data .= self::encodeString($message, self::PACK_INT32, $compression);
 
-        $crc = (string)crc32($data);
+        $crc = ( string ) crc32($data);
 
         // int32 -- crc code  string data
-        $message = self::pack(self::BIT_B32, $crc) . $data;
+        $message = self::pack(self::BIT_B32, $crc).$data;
 
         return $message;
     }
@@ -237,7 +237,7 @@ 
         $topic = self::encodeString($values['topic_name'], self::PACK_INT16);
         $partitions = self::encodeArray($values['partitions'], [$this, 'encodeProducePartition'], $compression);
 
-        return $topic . $partitions;
+        return $topic.$partitions;
     }
 
     /**

src/Kafka/Protocol.php

Spacing +14 added lines, -14 removed lines

@@ -129,7 +129,7 @@ 
             $body .= $options !== null ? $func($value, $options) : $func($value);
         }
 
-        return self::pack(self::BIT_B32, (string)$arrayCount) . $body;
+        return self::pack(self::BIT_B32, ( string ) $arrayCount).$body;
     }
 
     public static function pack(string $type, string $data): string
@@ -138,11 +138,11 @@ 
             return pack($type, $data);
         }
 
-        if ((int)$data === -1) { // -1L
+        if (( int ) $data === -1) { // -1L
             return hex2bin('ffffffffffffffff');
         }
 
-        if ((int)$data === -2) { // -2L
+        if (( int ) $data === -2) { // -2L
             return hex2bin('fffffffffffffffe');
         }
 
@@ -179,9 +179,9 @@ 
     public function requestHeader(string $clientId, int $correlationId, int $apiKey): string
     {
         // int16 -- apiKey int16 -- apiVersion int32 correlationId
-        $binData = self::pack(self::BIT_B16, (string)$apiKey);
-        $binData .= self::pack(self::BIT_B16, (string)$this->getApiVersion($apiKey));
-        $binData .= self::pack(self::BIT_B32, (string)$correlationId);
+        $binData = self::pack(self::BIT_B16, ( string ) $apiKey);
+        $binData .= self::pack(self::BIT_B16, ( string ) $this->getApiVersion($apiKey));
+        $binData .= self::pack(self::BIT_B32, ( string ) $correlationId);
 
         // concat client id
         $binData .= self::encodeString($clientId, self::PACK_INT16);
@@ -226,7 +226,7 @@ 
         $packLen = $bytes === self::PACK_INT32 ? self::BIT_B32 : self::BIT_B16;
         $string = self::compress($string, $compression);
 
-        return self::pack($packLen, (string)strlen($string)) . $string;
+        return self::pack($packLen, ( string ) strlen($string)).$string;
     }
 
     /**
@@ -245,7 +245,7 @@ 
         }
 
         if ($compression !== self::COMPRESSION_GZIP) {
-            throw new BadMethodCallException('Unknown compression flag: ' . $compression);
+            throw new BadMethodCallException('Unknown compression flag: '.$compression);
         }
 
         return gzencode($string);
@@ -272,7 +272,7 @@ 
             return ['length' => $offset, 'data' => ''];
         }
 
-        $data = (string)substr($data, $offset, (int)$packLen);
+        $data = ( string ) substr($data, $offset, ( int ) $packLen);
         $offset += $packLen;
 
         return ['length' => $offset, 'data' => self::decompress($data, $compression)];
@@ -341,7 +341,7 @@ 
         $length = strlen($bytes);
 
         if ($length !== $expectedLength) {
-            throw new Exception('unpack failed. string(raw) length is ' . $length . ' , TO ' . $type);
+            throw new Exception('unpack failed. string(raw) length is '.$length.' , TO '.$type);
         }
     }
 
@@ -358,7 +358,7 @@ 
             } else {
                 [$endianTest] = array_values($value);
 
-                self::$isLittleEndianSystem = (int)$endianTest === 1;
+                self::$isLittleEndianSystem = ( int ) $endianTest === 1;
             }
         }
 
@@ -374,7 +374,7 @@ 
      */
     public static function convertSignedShortFromLittleEndianToBigEndian(array $bits): array
     {
-        $convert = function (int $bit): int {
+        $convert = function(int $bit): int {
             $lsb = $bit & 0xff;
             $msb = $bit >> 8 & 0xff;
             $bit = $lsb << 8 | $msb;
@@ -400,7 +400,7 @@ 
         }
 
         if ($compression !== self::COMPRESSION_GZIP) {
-            throw new BadMethodCallException('Unknown compression flag: ' . $compression);
+            throw new BadMethodCallException('Unknown compression flag: '.$compression);
         }
 
         return gzdecode($string);
@@ -434,7 +434,7 @@ 
             if (!isset($ret['length'], $ret['data'])) {
                 throw new Exception('Decode array failed, given function return format is invalid');
             }
-            if ((int)$ret['length'] === 0) {
+            if (( int ) $ret['length'] === 0) {
                 continue;
             }
 

src/Kafka/Socket/Pool.php

Spacing +1 added lines, -1 removed lines

@@ -77,7 +77,7 @@
             if ($this->maxWait > 0 && $this->waitStack->count() > $this->maxWait) {
                 throw new Exception('Connection pool queue is full');
             }
-            $this->waitStack->push((int)Co::getCid());
+            $this->waitStack->push(( int ) Co::getCid());
             Co::yield();
             return $this->queue->shift();
         }

src/Kafka/Producter.php

Spacing +4 added lines, -4 removed lines

@@ -70,11 +70,11 @@ 
             ];
 
             $requestData = ProtocolTool::encode(ProtocolTool::PRODUCE_REQUEST, $params);
-            rgo(function () use ($connect, $requestData, $requiredAck, $callback) {
+            rgo(function() use ($connect, $requestData, $requiredAck, $callback) {
                 if ($requiredAck !== 0) {
                     $connect->send($requestData);
                     $dataLen = Protocol::unpack(Protocol::BIT_B32, $connect->recv(4));
-                    $recordSet = $connect->recv((int)$dataLen);
+                    $recordSet = $connect->recv(( int ) $dataLen);
                     $this->pool->release($connect);
                     Protocol::unpack(Protocol::BIT_B32, substr($recordSet, 0, 4));
                     $callback && $callback(ProtocolTool::decode(ProtocolTool::PRODUCE_REQUEST,
@@ -93,14 +93,14 @@ 
     public function syncMeta(): void
     {
         $socket = $this->pool->getConnection();
-        rgo(function () use ($socket) {
+        rgo(function() use ($socket) {
             while (true) {
                 try {
                     $params = [];
                     $requestData = ProtocolTool::encode(ProtocolTool::METADATA_REQUEST, $params);
                     $socket->send($requestData);
                     $dataLen = Protocol::unpack(Protocol::BIT_B32, $socket->recv(4));
-                    $data = $socket->recv((int)$dataLen);
+                    $data = $socket->recv(( int ) $dataLen);
                     Protocol::unpack(Protocol::BIT_B32, substr($data, 0, 4));
                     $result = ProtocolTool::decode(ProtocolTool::METADATA_REQUEST, substr($data, 4));
                     if (!isset($result['brokers'], $result['topics'])) {

src/Targets/StyleTarget.php

Spacing +3 added lines, -3 removed lines

@@ -82,7 +82,7 @@ 
                     $level = $this->getLevelColor(trim($msg[$this->levelIndex]));
                     if (isset($this->colorTemplate[$index])) {
                         $color = $this->colorTemplate[$index];
-                        $msgValue = is_string($msgValue) ? trim($msgValue) : (string)$msgValue;
+                        $msgValue = is_string($msgValue) ? trim($msgValue) : ( string ) $msgValue;
                         switch ($color) {
                             case self::COLOR_LEVEL:
                                 $context[] = $this->color->getColoredString($msgValue, $level);
@@ -101,8 +101,8 @@ 
                     }
                 }
                 if (isset($context)) {
-                    echo implode(' ' . $this->color->getColoredString('|', $this->splitColor) . ' ',
-                            $context) . PHP_EOL;
+                    echo implode(' '.$this->color->getColoredString('|', $this->splitColor).' ',
+                            $context).PHP_EOL;
                 }
             }
         }