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 +5 added lines, -5 removed lines

@@ -5,7 +5,7 @@ 
  * @author      Austin Heap <me@austinheap.com>
  * @version     v0.1.2
  */
-declare(strict_types = 1);
+declare(strict_types=1);
 
 namespace AustinHeap\Database\InfluxDb;
 
@@ -78,8 +78,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);
@@ -100,8 +100,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/InfluxDbServiceProvider.php

Indentation +8 added lines, -8 removed lines

@@ -31,8 +31,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');
 
@@ -64,12 +64,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 +13 added lines, -13 removed lines

@@ -5,7 +5,7 @@ 
  * @author      Austin Heap <me@austinheap.com>
  * @version     v0.1.2
  */
-declare(strict_types = 1);
+declare(strict_types=1);
 
 namespace AustinHeap\Database\InfluxDb;
 
@@ -37,13 +37,13 @@ 
         $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);
         }
     }
@@ -53,17 +53,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'),
@@ -84,8 +84,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/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 +14 added lines, -14 removed lines

@@ -5,7 +5,7 @@ 
  * @author      Austin Heap <me@austinheap.com>
  * @version     v0.1.2
  */
-declare(strict_types = 1);
+declare(strict_types=1);
 
 namespace AustinHeap\Database\InfluxDb\Jobs;
 
@@ -21,47 +21,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 $payload
      */
-    public $payload = null;
+    public $payload=null;
 
     /**
      * @var string $precision
      */
-    public $precision = null;
+    public $precision=null;
 
     /**
      * @var string|null $retentionPolicy
      */
-    public $retentionPolicy = null;
+    public $retentionPolicy=null;
 
     /**
      * WritePayload constructor.
@@ -70,11 +70,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 +5 added lines, -5 removed lines

@@ -5,7 +5,7 @@ 
  * @author      Austin Heap <me@austinheap.com>
  * @version     v0.1.2
  */
-declare(strict_types = 1);
+declare(strict_types=1);
 
 namespace AustinHeap\Database\InfluxDb\Jobs;
 
@@ -21,12 +21,12 @@ 
     /**
      * @var string|array $payload
      */
-    public $payload = null;
+    public $payload=null;
 
     /**
      * @var array $parameters
      */
-    public $parameters = null;
+    public $parameters=null;
 
     /**
      * Write constructor.
@@ -36,8 +36,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 +14 added lines, -14 removed lines

@@ -5,7 +5,7 @@ 
  * @author      Austin Heap <me@austinheap.com>
  * @version     v0.1.2
  */
-declare(strict_types = 1);
+declare(strict_types=1);
 
 namespace AustinHeap\Database\InfluxDb\Jobs;
 
@@ -21,47 +21,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 $points
      */
-    public $points = null;
+    public $points=null;
 
     /**
      * @var string $precision
      */
-    public $precision = null;
+    public $precision=null;
 
     /**
      * @var string|null $precision
      */
-    public $retentionPolicy = null;
+    public $retentionPolicy=null;
 
     /**
      * WritePoints constructor.
@@ -70,11 +70,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/Logs/Formatter.php

Spacing +34 added lines, -34 removed lines

@@ -23,9 +23,9 @@ 
      */
     public function format(array $record)
     {
-        $record = parent::format($record);
+        $record=parent::format($record);
 
-        $message = $this->prepareMessage($record);
+        $message=$this->prepareMessage($record);
 
         return $message;
     }
@@ -37,43 +37,43 @@ 
      */
     protected function prepareMessage(array $record): array
     {
-        $message              = [];
-        $message['name']      = 'Error';
-        $message['value']     = 1;
-        $message['timestamp'] = exec('date +%s%N');
+        $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($_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;
                 }
             }
         }
@@ -81,15 +81,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;
@@ -102,7 +102,7 @@ 
      */
     private function rfc5424ToSeverity(int $level)
     {
-        $levels = [
+        $levels=[
             100 => 'Debugging',
             200 => 'Informational',
             250 => 'Notice',
@@ -113,7 +113,7 @@ 
             600 => 'Emergency',
         ];
 
-        $result = isset($levels[$level]) ? $levels[$level] : $levels[600];
+        $result=isset($levels[ $level ]) ? $levels[ $level ] : $levels[ 600 ];
 
         return $result;
     }
@@ -125,8 +125,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;
     }
@@ -138,13 +138,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));
             }
         }
 

src/Logs/MonologHandler.php

Spacing +2 added lines, -2 removed lines

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