SeasX / seas-logger

example/logger.php

Spacing +8 added lines, -8 removed lines

@@ -1,6 +1,6 @@ 
 <?php
 
-require_once dirname(__DIR__) . '/vendor/autoload.php';
+require_once dirname(__DIR__).'/vendor/autoload.php';
 
 use Seasx\SeasLogger\ArrayHelper;
 use Seasx\SeasLogger\ConsoleColor;
@@ -15,11 +15,11 @@ 
 use Seasx\SeasLogger\Targets\KafkaTarget;
 use Seasx\SeasLogger\Targets\StyleTarget;
 
-\Co\Run(function () {
+\Co\Run(function() {
     $logger = new Logger(
         new LoggerConfig([
             'echo' => new StyleTarget([
-                'info',//过滤等级，默认为[]全部输出
+                'info', //过滤等级，默认为[]全部输出
             ]),
             'kafka' => new KafkaTarget(
                 new Producter(
@@ -36,16 +36,16 @@ 
                 [['task_id', 'string'], ['worker_id', 'string']]//自定义模板添加的处理字段，顺序需要按照日志记录中的template数组一致
             )
         ], [
-            'appName' => 'Seaslog',//应用名：远程发送日志的时候用于区分是哪个应用发送来的
-            'bufferSize' => 1,//定量：buffer>=时会输出，默认为1，每次记录都会输出
-            'tick' => 0,//定时：每tick秒输出，默认为0，不开启定时
-            'recall_depth' => 2,//与Seaslog配置参数一样，默认为0
+            'appName' => 'Seaslog', //应用名：远程发送日志的时候用于区分是哪个应用发送来的
+            'bufferSize' => 1, //定量：buffer>=时会输出，默认为1，每次记录都会输出
+            'tick' => 0, //定时：每tick秒输出，默认为0，不开启定时
+            'recall_depth' => 2, //与Seaslog配置参数一样，默认为0
         ]));
     /**
      * 这里可以注册两个回调函数，会在log方法前执行，可以用来处理RequestID,Request URI,Request Method,Client IP的值
      * 下面是示例代码，具体的设置根据自己需要
      */
-    $logger->getConfig()->registerTemplate(function () {
+    $logger->getConfig()->registerTemplate(function() {
         $possibleStyles = (new ConsoleColor())->getPossibleStyles();
         $htmlColors = HtmlColor::getPossibleColors();
         if (($requestVar = Context::get(Logger::CONTEXT_KEY)) === null) {

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/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, $packLen);
+        $data = ( string ) substr($data, $offset, $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);
         }
     }
 
@@ -354,7 +354,7 @@ 
         if (self::$isLittleEndianSystem === null) {
             [$endianTest] = array_values(unpack('L1L', pack('V', 1)));
 
-            self::$isLittleEndianSystem = (int)$endianTest === 1;
+            self::$isLittleEndianSystem = ( int ) $endianTest === 1;
         }
 
         return self::$isLittleEndianSystem;
@@ -369,7 +369,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;
@@ -395,7 +395,7 @@ 
         }
 
         if ($compression !== self::COMPRESSION_GZIP) {
-            throw new BadMethodCallException('Unknown compression flag: ' . $compression);
+            throw new BadMethodCallException('Unknown compression flag: '.$compression);
         }
 
         return gzdecode($string);
@@ -429,7 +429,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/Producter.php

Spacing +2 added lines, -2 removed lines

@@ -70,7 +70,7 @@ 
             ];
 
             $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));
@@ -93,7 +93,7 @@ 
     public function syncMeta(): void
     {
         $socket = $this->pool->getConnection();
-        rgo(function () use ($socket) {
+        rgo(function() use ($socket) {
             while (true) {
                 try {
                     $params = [];

src/Kafka/Produce.php

Spacing +11 added lines, -11 removed lines

@@ -52,15 +52,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);
     }
 
     /**
@@ -101,9 +101,9 @@ 
             throw new ProtocolException('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
         );
 
@@ -127,7 +127,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/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;
             }