austinheap / laravel-database-influxdb

src/InfluxDbServiceProvider.php

Spacing +6 added lines, -6 removed lines

@@ -5,7 +5,7 @@ 
  * @author      Austin Heap <me@austinheap.com>
  * @version     v0.1.6
  */
-declare(strict_types=1);
+declare(strict_types = 1);
 
 namespace AustinHeap\Database\InfluxDb;
 
@@ -29,10 +29,10 @@ 
     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());
@@ -51,14 +51,14 @@ 
      */
     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';
 
-                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',

src/helpers.php

Spacing +2 added lines, -2 removed lines

@@ -5,9 +5,9 @@
  * @author      Austin Heap <me@austinheap.com>
  * @version     v0.1.6
  */
-declare(strict_types=1);
+declare(strict_types = 1);
 
-if (! function_exists('influxdb')) {
+if (!function_exists('influxdb')) {
     /**
      * @return \InfluxDB\Client|\InfluxDB\Database
      */

src/Logs/MonologHandler.php

Spacing +1 added lines, -1 removed lines

@@ -5,7 +5,7 @@
  * @author      Austin Heap <me@austinheap.com>
  * @version     v0.1.6
  */
-declare(strict_types=1);
+declare(strict_types = 1);
 
 namespace AustinHeap\Database\InfluxDb\Logs;
 

src/Logs/Formatter.php

Spacing +29 added lines, -29 removed lines

@@ -5,7 +5,7 @@ 
  * @author      Austin Heap <me@austinheap.com>
  * @version     v0.1.6
  */
-declare(strict_types=1);
+declare(strict_types = 1);
 
 namespace AustinHeap\Database\InfluxDb\Logs;
 
@@ -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;
@@ -112,7 +112,7 @@ 
             600 => 'Emergency',
         ];
 
-        $result = isset($levels[$level]) ? $levels[$level] : $levels[600];
+        $result = isset($levels[ $level ]) ? $levels[ $level ] : $levels[ 600 ];
 
         return $result;
     }

src/Jobs/WritePayload.php

Spacing +1 added lines, -1 removed lines

@@ -5,7 +5,7 @@
  * @author      Austin Heap <me@austinheap.com>
  * @version     v0.1.6
  */
-declare(strict_types=1);
+declare(strict_types = 1);
 
 namespace AustinHeap\Database\InfluxDb\Jobs;
 

src/Jobs/Job.php

Spacing +2 added lines, -2 removed lines

@@ -5,7 +5,7 @@ 
  * @author      Austin Heap <me@austinheap.com>
  * @version     v0.1.6
  */
-declare(strict_types=1);
+declare(strict_types = 1);
 
 namespace AustinHeap\Database\InfluxDb\Jobs;
 
@@ -42,7 +42,7 @@ 
      *
      * @param array $args
      */
-    public function __construct(array $args = [])
+    public function __construct(array $args = [ ])
     {
         $this->queue = config('influxdb.queue.name', 'default');
 

src/Jobs/WritePoints.php

Spacing +1 added lines, -1 removed lines

@@ -5,7 +5,7 @@
  * @author      Austin Heap <me@austinheap.com>
  * @version     v0.1.6
  */
-declare(strict_types=1);
+declare(strict_types = 1);
 
 namespace AustinHeap\Database\InfluxDb\Jobs;
 

src/Jobs/Write.php

Spacing +1 added lines, -1 removed lines

@@ -5,7 +5,7 @@
  * @author      Austin Heap <me@austinheap.com>
  * @version     v0.1.6
  */
-declare(strict_types=1);
+declare(strict_types = 1);
 
 namespace AustinHeap\Database\InfluxDb\Jobs;
 

src/InfluxDbFacade.php

Spacing +1 added lines, -1 removed lines

@@ -5,7 +5,7 @@
  * @author      Austin Heap <me@austinheap.com>
  * @version     v0.1.6
  */
-declare(strict_types=1);
+declare(strict_types = 1);
 
 namespace AustinHeap\Database\InfluxDb;