austinheap / laravel-database-influxdb

src/InfluxDbFacade.php

Indentation +4 added lines, -4 removed lines

@@ -47,7 +47,7 @@ 
                 return static::$method(...$arguments);
             default:
                 return static::getFacadeRoot()
-                             ->$method(...$arguments);
+                                ->$method(...$arguments);
         }
     }
 
@@ -63,7 +63,7 @@ 
             Write::dispatch($parameters, $payload);
         } else {
             return static::getFacadeRoot()
-                         ->write($parameters, $payload);
+                            ->write($parameters, $payload);
         }
 
         return true;
@@ -85,7 +85,7 @@ 
             WritePayload::dispatch($payload, $precision, $retentionPolicy);
         } else {
             return static::getFacadeRoot()
-                         ->writePayload($payload, $precision, $retentionPolicy);
+                            ->writePayload($payload, $precision, $retentionPolicy);
         }
 
         return true;
@@ -107,7 +107,7 @@ 
             WritePoints::dispatch($points, $precision, $retentionPolicy);
         } else {
             return static::getFacadeRoot()
-                         ->writePoints($points, $precision, $retentionPolicy);
+                            ->writePoints($points, $precision, $retentionPolicy);
         }
 
         return true;

Spacing +4 added lines, -4 removed lines

@@ -76,8 +76,8 @@ 
      */
     public static function writePayload(
         $payload,
-        $precision = WritePayload::PRECISION_NANOSECONDS,
-        $retentionPolicy = null
+        $precision=WritePayload::PRECISION_NANOSECONDS,
+        $retentionPolicy=null
     ): bool {
         if (config('influxdb.queue.enable', false) === true) {
             WritePayload::dispatch($payload, $precision, $retentionPolicy);
@@ -98,8 +98,8 @@ 
      */
     public static function writePoints(
         array $points,
-        $precision = WritePoints::PRECISION_NANOSECONDS,
-        $retentionPolicy = null
+        $precision=WritePoints::PRECISION_NANOSECONDS,
+        $retentionPolicy=null
     ): bool {
         if (config('influxdb.queue.enable', false) === true) {
             WritePoints::dispatch($points, $precision, $retentionPolicy);

src/Jobs/WritePayload.php

Indentation +5 added lines, -5 removed lines

@@ -91,10 +91,10 @@
     public function handle()
     {
         InfluxDbServiceProvider::getInstance()
-                               ->writePayload(
-                                   $this->payload,
-                                   $this->precision,
-                                   $this->retentionPolicy
-                               );
+                                ->writePayload(
+                                    $this->payload,
+                                    $this->precision,
+                                    $this->retentionPolicy
+                                );
     }
 }

Spacing +13 added lines, -13 removed lines

@@ -19,47 +19,47 @@ 
     /**
      * @var string PRECISION_NANOSECONDS
      */
-    const PRECISION_NANOSECONDS = 'n';
+    const PRECISION_NANOSECONDS='n';
 
     /**
      * @var string PRECISION_MICROSECONDS
      */
-    const PRECISION_MICROSECONDS = 'u';
+    const PRECISION_MICROSECONDS='u';
 
     /**
      * @var string PRECISION_MILLISECONDS
      */
-    const PRECISION_MILLISECONDS = 'ms';
+    const PRECISION_MILLISECONDS='ms';
 
     /**
      * @var string PRECISION_SECONDS
      */
-    const PRECISION_SECONDS = 's';
+    const PRECISION_SECONDS='s';
 
     /**
      * @var string PRECISION_MINUTES
      */
-    const PRECISION_MINUTES = 'm';
+    const PRECISION_MINUTES='m';
 
     /**
      * @var string PRECISION_HOURS
      */
-    const PRECISION_HOURS = 'h';
+    const PRECISION_HOURS='h';
 
     /**
      * @var string|array
      */
-    public $payload = null;
+    public $payload=null;
 
     /**
      * @var string
      */
-    public $precision = null;
+    public $precision=null;
 
     /**
      * @var string|null
      */
-    public $retentionPolicy = null;
+    public $retentionPolicy=null;
 
     /**
      * WritePayload constructor.
@@ -68,11 +68,11 @@ 
      * @param  string       $precision
      * @param  string|null  $retentionPolicy
      */
-    public function __construct($payload, $precision = self::PRECISION_NANOSECONDS, $retentionPolicy = null)
+    public function __construct($payload, $precision=self::PRECISION_NANOSECONDS, $retentionPolicy=null)
     {
-        $this->payload = $payload;
-        $this->precision = $precision;
-        $this->retentionPolicy = $retentionPolicy;
+        $this->payload=$payload;
+        $this->precision=$precision;
+        $this->retentionPolicy=$retentionPolicy;
 
         parent::__construct(
             [

src/Jobs/Write.php

Indentation +4 added lines, -4 removed lines

@@ -53,9 +53,9 @@
     public function handle()
     {
         InfluxDbServiceProvider::getInstance()
-                               ->write(
-                                   $this->parameters,
-                                   $this->payload
-                               );
+                                ->write(
+                                    $this->parameters,
+                                    $this->payload
+                                );
     }
 }

Spacing +4 added lines, -4 removed lines

@@ -19,12 +19,12 @@ 
     /**
      * @var string|array
      */
-    public $payload = null;
+    public $payload=null;
 
     /**
      * @var array
      */
-    public $parameters = null;
+    public $parameters=null;
 
     /**
      * Write constructor.
@@ -34,8 +34,8 @@ 
      */
     public function __construct(array $parameters, $payload)
     {
-        $this->parameters = $parameters;
-        $this->payload = $payload;
+        $this->parameters=$parameters;
+        $this->payload=$payload;
 
         parent::__construct(
             [

src/Jobs/WritePoints.php

Indentation +5 added lines, -5 removed lines

@@ -91,10 +91,10 @@
     public function handle()
     {
         InfluxDbServiceProvider::getInstance()
-                               ->writePoints(
-                                   $this->points,
-                                   $this->precision,
-                                   $this->retentionPolicy
-                               );
+                                ->writePoints(
+                                    $this->points,
+                                    $this->precision,
+                                    $this->retentionPolicy
+                                );
     }
 }

Spacing +13 added lines, -13 removed lines

@@ -19,47 +19,47 @@ 
     /**
      * @var string PRECISION_NANOSECONDS
      */
-    const PRECISION_NANOSECONDS = 'n';
+    const PRECISION_NANOSECONDS='n';
 
     /**
      * @var string PRECISION_MICROSECONDS
      */
-    const PRECISION_MICROSECONDS = 'u';
+    const PRECISION_MICROSECONDS='u';
 
     /**
      * @var string PRECISION_MILLISECONDS
      */
-    const PRECISION_MILLISECONDS = 'ms';
+    const PRECISION_MILLISECONDS='ms';
 
     /**
      * @var string PRECISION_SECONDS
      */
-    const PRECISION_SECONDS = 's';
+    const PRECISION_SECONDS='s';
 
     /**
      * @var string PRECISION_MINUTES
      */
-    const PRECISION_MINUTES = 'm';
+    const PRECISION_MINUTES='m';
 
     /**
      * @var string PRECISION_HOURS
      */
-    const PRECISION_HOURS = 'h';
+    const PRECISION_HOURS='h';
 
     /**
      * @var array
      */
-    public $points = null;
+    public $points=null;
 
     /**
      * @var string
      */
-    public $precision = null;
+    public $precision=null;
 
     /**
      * @var string|null
      */
-    public $retentionPolicy = null;
+    public $retentionPolicy=null;
 
     /**
      * WritePoints constructor.
@@ -68,11 +68,11 @@ 
      * @param  string            $precision
      * @param  string|null       $retentionPolicy
      */
-    public function __construct(array $points, $precision = self::PRECISION_NANOSECONDS, $retentionPolicy = null)
+    public function __construct(array $points, $precision=self::PRECISION_NANOSECONDS, $retentionPolicy=null)
     {
-        $this->points = $points;
-        $this->precision = $precision;
-        $this->retentionPolicy = $retentionPolicy;
+        $this->points=$points;
+        $this->precision=$precision;
+        $this->retentionPolicy=$retentionPolicy;
 
         parent::__construct(
             [

src/Jobs/Job.php

Spacing +2 added lines, -2 removed lines

@@ -41,10 +41,10 @@
      *
      * @param array $args
      */
-    public function __construct(array $args = [])
+    public function __construct(array $args=[ ])
     {
         if (count($args)) {
-            $this->args = $args;
+            $this->args=$args;
         }
     }
 }

src/Logs/MonologHandler.php

Spacing +1 added lines, -1 removed lines

@@ -23,7 +23,7 @@
      * @param int  $level
      * @param bool $bubble
      */
-    public function __construct($level = Logger::DEBUG, $bubble = true)
+    public function __construct($level=Logger::DEBUG, $bubble=true)
     {
         parent::__construct($level, $bubble);
     }

src/InfluxDbServiceProvider.php

Indentation +8 added lines, -8 removed lines

@@ -29,8 +29,8 @@ 
     public function boot(): void
     {
         $this->publishes([
-                             __DIR__.'/config/influxdb.php' => config_path('influxdb.php'),
-                         ]);
+                                __DIR__.'/config/influxdb.php' => config_path('influxdb.php'),
+                            ]);
 
         $this->mergeConfigFrom(__DIR__.'/config/influxdb.php', 'influxdb');
 
@@ -62,12 +62,12 @@ 
                 }
 
                 $dsn = sprintf('%s://%s:%s@%s:%s/%s',
-                               $protocol,
-                               config('influxdb.user'),
-                               config('influxdb.pass'),
-                               config('influxdb.host'),
-                               config('influxdb.port'),
-                               config('influxdb.database')
+                                $protocol,
+                                config('influxdb.user'),
+                                config('influxdb.pass'),
+                                config('influxdb.host'),
+                                config('influxdb.port'),
+                                config('influxdb.database')
                 );
 
                 return InfluxClient::fromDSN($dsn, $timeout, $verifySsl);

Spacing +14 added lines, -14 removed lines

@@ -29,19 +29,19 @@ 
     public function boot(): void
     {
         $this->publishes([
-                             __DIR__.'/config/influxdb.php' => config_path('influxdb.php'),
+                             __DIR__ . '/config/influxdb.php' => config_path('influxdb.php'),
                          ]);
 
-        $this->mergeConfigFrom(__DIR__.'/config/influxdb.php', 'influxdb');
+        $this->mergeConfigFrom(__DIR__ . '/config/influxdb.php', 'influxdb');
 
         if (config('influxdb.log.monolog', false) === true) {
-            $handler = new MonologHandler($this->getLoggingLevel());
+            $handler=new MonologHandler($this->getLoggingLevel());
             $handler->setFormatter(new Formatter());
 
-            $monolog = Log::getMonolog();
+            $monolog=Log::getMonolog();
             $monolog->pushHandler($handler);
 
-            $new_log = new Writer($monolog, Log::getEventDispatcher());
+            $new_log=new Writer($monolog, Log::getEventDispatcher());
             Log::swap($new_log);
         }
     }
@@ -51,17 +51,17 @@ 
      */
     public function register(): void
     {
-        $this->app->singleton('InfluxDb', function ($app) {
+        $this->app->singleton('InfluxDb', function($app) {
             try {
-                $timeout = is_int(config('influxdb.timeout', null)) ? config('influxdb.timeout') : 5;
-                $verifySsl = is_bool(config('influxdb.verify_ssl', null)) ? config('influxdb.verify_ssl') : true;
-                $protocol = 'influxdb';
+                $timeout=is_int(config('influxdb.timeout', null)) ? config('influxdb.timeout') : 5;
+                $verifySsl=is_bool(config('influxdb.verify_ssl', null)) ? config('influxdb.verify_ssl') : true;
+                $protocol='influxdb';
 
-                if (in_array(config('influxdb.protocol'), ['https', 'udp'])) {
-                    $protocol = config('influxdb.protocol').'+'.$protocol;
+                if (in_array(config('influxdb.protocol'), [ 'https', 'udp' ])) {
+                    $protocol=config('influxdb.protocol') . '+' . $protocol;
                 }
 
-                $dsn = sprintf('%s://%s:%s@%s:%s/%s',
+                $dsn=sprintf('%s://%s:%s@%s:%s/%s',
                                $protocol,
                                config('influxdb.user'),
                                config('influxdb.pass'),
@@ -82,8 +82,8 @@ 
      */
     private function getLoggingLevel()
     {
-        $level = config('influxdb.log.level', 'DEBUG');
-        $level = empty($level) ? 'DEBUG' : $level;
+        $level=config('influxdb.log.level', 'DEBUG');
+        $level=empty($level) ? 'DEBUG' : $level;
 
         return in_array($level, [
             'DEBUG',

src/helpers.php

Spacing +1 added lines, -1 removed lines

@@ -7,7 +7,7 @@
  */
 declare(strict_types=1);
 
-if (! function_exists('influxdb')) {
+if (!function_exists('influxdb')) {
     /**
      * @return \InfluxDB\Client|\InfluxDB\Database
      */

src/Logs/Formatter.php

Spacing +36 added lines, -36 removed lines

@@ -21,9 +21,9 @@ 
      */
     public function format(array $record)
     {
-        $record = parent::format($record);
+        $record=parent::format($record);
 
-        $message = $this->prepareMessage($record);
+        $message=$this->prepareMessage($record);
 
         return $message;
     }
@@ -35,44 +35,44 @@ 
      */
     protected function prepareMessage(array $record): array
     {
-        $tags = [];
-        $message = [];
-        $message['name'] = 'Error';
-        $message['value'] = 1;
-        $message['timestamp'] = exec('date +%s%N');
-
-        if (isset($_SERVER['REMOTE_ADDR'])) {
-            $tags['serverName'] = $_SERVER['REMOTE_ADDR'];
+        $tags=[ ];
+        $message=[ ];
+        $message[ 'name' ]='Error';
+        $message[ 'value' ]=1;
+        $message[ 'timestamp' ]=exec('date +%s%N');
+
+        if (isset($_SERVER[ 'REMOTE_ADDR' ])) {
+            $tags[ 'serverName' ]=$_SERVER[ 'REMOTE_ADDR' ];
         }
 
-        if (isset($record['level'])) {
-            $tags['severity'] = $this->rfc5424ToSeverity($record['level']);
+        if (isset($record[ 'level' ])) {
+            $tags[ 'severity' ]=$this->rfc5424ToSeverity($record[ 'level' ]);
         }
 
-        if (isset($_SERVER['REQUEST_URI'])) {
-            $tags['endpoint_url'] = $_SERVER['REQUEST_URI'];
+        if (isset($_SERVER[ 'REQUEST_URI' ])) {
+            $tags[ 'endpoint_url' ]=$_SERVER[ 'REQUEST_URI' ];
         }
 
-        if (isset($_SERVER['REQUEST_METHOD'])) {
-            $tags['method'] = $_SERVER['REQUEST_METHOD'];
+        if (isset($_SERVER[ 'REQUEST_METHOD' ])) {
+            $tags[ 'method' ]=$_SERVER[ 'REQUEST_METHOD' ];
         }
 
-        if (isset($record['context']['user_id'])) {
-            $tags['user_id'] = $record['context']['user_id'];
+        if (isset($record[ 'context' ][ 'user_id' ])) {
+            $tags[ 'user_id' ]=$record[ 'context' ][ 'user_id' ];
         }
 
-        if (isset($record['context']['project_id'])) {
-            $tags['project_id'] = $record['context']['project_id'];
+        if (isset($record[ 'context' ][ 'project_id' ])) {
+            $tags[ 'project_id' ]=$record[ 'context' ][ 'project_id' ];
         }
 
-        if (isset($record['context']['file'])) {
-            $tags['file'] = $this->replaceDigitData($record['context']['file']);
+        if (isset($record[ 'context' ][ 'file' ])) {
+            $tags[ 'file' ]=$this->replaceDigitData($record[ 'context' ][ 'file' ]);
         }
 
-        if (isset($record['context']['event']['api_stats'][0])) {
-            foreach ($record['context']['event']['api_stats'][0] as $k => $v) {
+        if (isset($record[ 'context' ][ 'event' ][ 'api_stats' ][ 0 ])) {
+            foreach ($record[ 'context' ][ 'event' ][ 'api_stats' ][ 0 ] as $k => $v) {
                 if (is_string($v) || is_int($v)) {
-                    $tags[$k] = $v;
+                    $tags[ $k ]=$v;
                 }
             }
         }
@@ -80,15 +80,15 @@ 
         if (isset($tags) && count($tags)) {
             foreach ($tags as $k => $v) {
                 if (is_numeric($v)) {
-                    $message['fields'][$k] = (int) $v;
+                    $message[ 'fields' ][ $k ]=(int) $v;
                 }
             }
 
-            $message['tags'] = $tags;
+            $message[ 'tags' ]=$tags;
         }
 
-        if (isset($message['fields']['Debug']['message'])) {
-            $message['fields']['Debug']['message'] = $this->trimLines($message['fields']['Debug']['message']);
+        if (isset($message[ 'fields' ][ 'Debug' ][ 'message' ])) {
+            $message[ 'fields' ][ 'Debug' ][ 'message' ]=$this->trimLines($message[ 'fields' ][ 'Debug' ][ 'message' ]);
         }
 
         return $message;
@@ -101,7 +101,7 @@ 
      */
     private function rfc5424ToSeverity(int $level)
     {
-        $levels = [
+        $levels=[
             100 => 'Debugging',
             200 => 'Informational',
             250 => 'Notice',
@@ -112,7 +112,7 @@ 
             600 => 'Emergency',
         ];
 
-        $result = isset($levels[$level]) ? $levels[$level] : $levels[600];
+        $result=isset($levels[ $level ]) ? $levels[ $level ] : $levels[ 600 ];
 
         return $result;
     }
@@ -124,8 +124,8 @@ 
      */
     private function replaceDigitData(string $string): string
     {
-        $string = preg_replace('~\/[0-9]+~', '/*', $string);
-        $string = preg_replace('~\=[0-9]+~', '=*', $string);
+        $string=preg_replace('~\/[0-9]+~', '/*', $string);
+        $string=preg_replace('~\=[0-9]+~', '=*', $string);
 
         return $string;
     }
@@ -137,13 +137,13 @@ 
      */
     private function trimLines($message): string
     {
-        $limit = config('influxdb.log.limit');
+        $limit=config('influxdb.log.limit');
 
         if ($limit) {
-            $message_array = explode(PHP_EOL, $message);
+            $message_array=explode(PHP_EOL, $message);
 
             if ($limit < count($message_array)) {
-                $message = implode(PHP_EOL, array_slice($message_array, 0, $limit));
+                $message=implode(PHP_EOL, array_slice($message_array, 0, $limit));
             }
         }