| @@ -91,10 +91,10 @@ | ||
| 91 | 91 | public function handle() | 
| 92 | 92 |      { | 
| 93 | 93 | InfluxDbServiceProvider::getInstance() | 
| 94 | - ->writePayload( | |
| 95 | - $this->payload, | |
| 96 | - $this->precision, | |
| 97 | - $this->retentionPolicy | |
| 98 | - ); | |
| 94 | + ->writePayload( | |
| 95 | + $this->payload, | |
| 96 | + $this->precision, | |
| 97 | + $this->retentionPolicy | |
| 98 | + ); | |
| 99 | 99 | } | 
| 100 | 100 | } | 
| @@ -5,7 +5,7 @@ | ||
| 5 | 5 | * @author Austin Heap <[email protected]> | 
| 6 | 6 | * @version v0.1.6 | 
| 7 | 7 | */ | 
| 8 | -declare(strict_types=1); | |
| 8 | +declare(strict_types = 1); | |
| 9 | 9 | |
| 10 | 10 | namespace AustinHeap\Database\InfluxDb\Jobs; | 
| 11 | 11 | |
| @@ -53,9 +53,9 @@ | ||
| 53 | 53 | public function handle() | 
| 54 | 54 |      { | 
| 55 | 55 | InfluxDbServiceProvider::getInstance() | 
| 56 | - ->write( | |
| 57 | - $this->parameters, | |
| 58 | - $this->payload | |
| 59 | - ); | |
| 56 | + ->write( | |
| 57 | + $this->parameters, | |
| 58 | + $this->payload | |
| 59 | + ); | |
| 60 | 60 | } | 
| 61 | 61 | } | 
| @@ -5,7 +5,7 @@ | ||
| 5 | 5 | * @author Austin Heap <[email protected]> | 
| 6 | 6 | * @version v0.1.6 | 
| 7 | 7 | */ | 
| 8 | -declare(strict_types=1); | |
| 8 | +declare(strict_types = 1); | |
| 9 | 9 | |
| 10 | 10 | namespace AustinHeap\Database\InfluxDb\Jobs; | 
| 11 | 11 | |
| @@ -91,10 +91,10 @@ | ||
| 91 | 91 | public function handle() | 
| 92 | 92 |      { | 
| 93 | 93 | InfluxDbServiceProvider::getInstance() | 
| 94 | - ->writePoints( | |
| 95 | - $this->points, | |
| 96 | - $this->precision, | |
| 97 | - $this->retentionPolicy | |
| 98 | - ); | |
| 94 | + ->writePoints( | |
| 95 | + $this->points, | |
| 96 | + $this->precision, | |
| 97 | + $this->retentionPolicy | |
| 98 | + ); | |
| 99 | 99 | } | 
| 100 | 100 | } | 
| @@ -5,7 +5,7 @@ | ||
| 5 | 5 | * @author Austin Heap <[email protected]> | 
| 6 | 6 | * @version v0.1.6 | 
| 7 | 7 | */ | 
| 8 | -declare(strict_types=1); | |
| 8 | +declare(strict_types = 1); | |
| 9 | 9 | |
| 10 | 10 | namespace AustinHeap\Database\InfluxDb\Jobs; | 
| 11 | 11 | |
| @@ -29,8 +29,8 @@ discard block | ||
| 29 | 29 | public function boot(): void | 
| 30 | 30 |      { | 
| 31 | 31 | $this->publishes([ | 
| 32 | -                             __DIR__.'/config/influxdb.php' => config_path('influxdb.php'), | |
| 33 | - ]); | |
| 32 | +                                __DIR__.'/config/influxdb.php' => config_path('influxdb.php'), | |
| 33 | + ]); | |
| 34 | 34 | |
| 35 | 35 | $this->mergeConfigFrom(__DIR__.'/config/influxdb.php', 'influxdb'); | 
| 36 | 36 | |
| @@ -62,12 +62,12 @@ discard block | ||
| 62 | 62 | } | 
| 63 | 63 | |
| 64 | 64 |                  $dsn = sprintf('%s://%s:%s@%s:%s/%s', | 
| 65 | - $protocol, | |
| 66 | -                               config('influxdb.user'), | |
| 67 | -                               config('influxdb.pass'), | |
| 68 | -                               config('influxdb.host'), | |
| 69 | -                               config('influxdb.port'), | |
| 70 | -                               config('influxdb.database') | |
| 65 | + $protocol, | |
| 66 | +                                config('influxdb.user'), | |
| 67 | +                                config('influxdb.pass'), | |
| 68 | +                                config('influxdb.host'), | |
| 69 | +                                config('influxdb.port'), | |
| 70 | +                                config('influxdb.database') | |
| 71 | 71 | ); | 
| 72 | 72 | |
| 73 | 73 | return InfluxClient::fromDSN($dsn, $timeout, $verifySsl); | 
| @@ -5,7 +5,7 @@ discard block | ||
| 5 | 5 | * @author Austin Heap <[email protected]> | 
| 6 | 6 | * @version v0.1.6 | 
| 7 | 7 | */ | 
| 8 | -declare(strict_types=1); | |
| 8 | +declare(strict_types = 1); | |
| 9 | 9 | |
| 10 | 10 | namespace AustinHeap\Database\InfluxDb; | 
| 11 | 11 | |
| @@ -29,10 +29,10 @@ discard block | ||
| 29 | 29 | public function boot(): void | 
| 30 | 30 |      { | 
| 31 | 31 | $this->publishes([ | 
| 32 | -                             __DIR__.'/config/influxdb.php' => config_path('influxdb.php'), | |
| 32 | +                             __DIR__ . '/config/influxdb.php' => config_path('influxdb.php'), | |
| 33 | 33 | ]); | 
| 34 | 34 | |
| 35 | - $this->mergeConfigFrom(__DIR__.'/config/influxdb.php', 'influxdb'); | |
| 35 | + $this->mergeConfigFrom(__DIR__ . '/config/influxdb.php', 'influxdb'); | |
| 36 | 36 | |
| 37 | 37 |          if (config('influxdb.log.monolog', false) === true) { | 
| 38 | 38 | $handler = new MonologHandler($this->getLoggingLevel()); | 
| @@ -51,14 +51,14 @@ discard block | ||
| 51 | 51 | */ | 
| 52 | 52 | public function register(): void | 
| 53 | 53 |      { | 
| 54 | -        $this->app->singleton('InfluxDb', function ($app) { | |
| 54 | +        $this->app->singleton('InfluxDb', function($app) { | |
| 55 | 55 |              try { | 
| 56 | 56 |                  $timeout = is_int(config('influxdb.timeout', null)) ? config('influxdb.timeout') : 5; | 
| 57 | 57 |                  $verifySsl = is_bool(config('influxdb.verify_ssl', null)) ? config('influxdb.verify_ssl') : true; | 
| 58 | 58 | $protocol = 'influxdb'; | 
| 59 | 59 | |
| 60 | -                if (in_array(config('influxdb.protocol'), ['https', 'udp'])) { | |
| 61 | -                    $protocol = config('influxdb.protocol').'+'.$protocol; | |
| 60 | +                if (in_array(config('influxdb.protocol'), [ 'https', 'udp' ])) { | |
| 61 | +                    $protocol = config('influxdb.protocol') . '+' . $protocol; | |
| 62 | 62 | } | 
| 63 | 63 | |
| 64 | 64 |                  $dsn = sprintf('%s://%s:%s@%s:%s/%s', | 
| @@ -5,9 +5,9 @@ | ||
| 5 | 5 | * @author Austin Heap <[email protected]> | 
| 6 | 6 | * @version v0.1.6 | 
| 7 | 7 | */ | 
| 8 | -declare(strict_types=1); | |
| 8 | +declare(strict_types = 1); | |
| 9 | 9 | |
| 10 | -if (! function_exists('influxdb')) { | |
| 10 | +if (!function_exists('influxdb')) { | |
| 11 | 11 | /** | 
| 12 | 12 | * @return \InfluxDB\Client|\InfluxDB\Database | 
| 13 | 13 | */ | 
| @@ -5,7 +5,7 @@ | ||
| 5 | 5 | * @author Austin Heap <[email protected]> | 
| 6 | 6 | * @version v0.1.6 | 
| 7 | 7 | */ | 
| 8 | -declare(strict_types=1); | |
| 8 | +declare(strict_types = 1); | |
| 9 | 9 | |
| 10 | 10 | namespace AustinHeap\Database\InfluxDb\Logs; | 
| 11 | 11 | |
| @@ -5,7 +5,7 @@ | ||
| 5 | 5 | * @author Austin Heap <[email protected]> | 
| 6 | 6 | * @version v0.1.6 | 
| 7 | 7 | */ | 
| 8 | -declare(strict_types=1); | |
| 8 | +declare(strict_types = 1); | |
| 9 | 9 | |
| 10 | 10 | namespace AustinHeap\Database\InfluxDb; | 
| 11 | 11 | |
| @@ -45,7 +45,7 @@ discard block | ||
| 45 | 45 | return static::$method(...$arguments); | 
| 46 | 46 | default: | 
| 47 | 47 | return static::getFacadeRoot() | 
| 48 | - ->$method(...$arguments); | |
| 48 | + ->$method(...$arguments); | |
| 49 | 49 | } | 
| 50 | 50 | } | 
| 51 | 51 | |
| @@ -59,10 +59,10 @@ discard block | ||
| 59 | 59 |      { | 
| 60 | 60 |          if (config('influxdb.queue.enable', false) === true) { | 
| 61 | 61 | Write::dispatch($parameters, $payload) | 
| 62 | -                 ->onQueue(config('influxdb.queue.name', 'default')); | |
| 62 | +                    ->onQueue(config('influxdb.queue.name', 'default')); | |
| 63 | 63 |          } else { | 
| 64 | 64 | return static::getFacadeRoot() | 
| 65 | - ->write($parameters, $payload); | |
| 65 | + ->write($parameters, $payload); | |
| 66 | 66 | } | 
| 67 | 67 | |
| 68 | 68 | return true; | 
| @@ -85,7 +85,7 @@ discard block | ||
| 85 | 85 |                          ->onQueue(config('influxdb.queue.name', 'default')); | 
| 86 | 86 |          } else { | 
| 87 | 87 | return static::getFacadeRoot() | 
| 88 | - ->writePayload($payload, $precision, $retentionPolicy); | |
| 88 | + ->writePayload($payload, $precision, $retentionPolicy); | |
| 89 | 89 | } | 
| 90 | 90 | |
| 91 | 91 | return true; | 
| @@ -105,10 +105,10 @@ discard block | ||
| 105 | 105 |      ): bool { | 
| 106 | 106 |          if (config('influxdb.queue.enable', false) === true) { | 
| 107 | 107 | WritePoints::dispatch($points, $precision, $retentionPolicy) | 
| 108 | -                       ->onQueue(config('influxdb.queue.name', 'default')); | |
| 108 | +                        ->onQueue(config('influxdb.queue.name', 'default')); | |
| 109 | 109 |          } else { | 
| 110 | 110 | return static::getFacadeRoot() | 
| 111 | - ->writePoints($points, $precision, $retentionPolicy); | |
| 111 | + ->writePoints($points, $precision, $retentionPolicy); | |
| 112 | 112 | } | 
| 113 | 113 | |
| 114 | 114 | return true; | 
| @@ -5,7 +5,7 @@ discard block | ||
| 5 | 5 | * @author Austin Heap <[email protected]> | 
| 6 | 6 | * @version v0.1.6 | 
| 7 | 7 | */ | 
| 8 | -declare(strict_types=1); | |
| 8 | +declare(strict_types = 1); | |
| 9 | 9 | |
| 10 | 10 | namespace AustinHeap\Database\InfluxDb\Logs; | 
| 11 | 11 | |
| @@ -33,40 +33,40 @@ discard block | ||
| 33 | 33 | */ | 
| 34 | 34 | protected function prepareTags(array $record): array | 
| 35 | 35 |      { | 
| 36 | - $tags = []; | |
| 36 | + $tags = [ ]; | |
| 37 | 37 | |
| 38 | -        if (isset($_SERVER['REMOTE_ADDR'])) { | |
| 39 | - $tags['serverName'] = $_SERVER['REMOTE_ADDR']; | |
| 38 | +        if (isset($_SERVER[ 'REMOTE_ADDR' ])) { | |
| 39 | + $tags[ 'serverName' ] = $_SERVER[ 'REMOTE_ADDR' ]; | |
| 40 | 40 | } | 
| 41 | 41 | |
| 42 | -        if (isset($record['level'])) { | |
| 43 | - $tags['severity'] = $this->rfc5424ToSeverity($record['level']); | |
| 42 | +        if (isset($record[ 'level' ])) { | |
| 43 | + $tags[ 'severity' ] = $this->rfc5424ToSeverity($record[ 'level' ]); | |
| 44 | 44 | } | 
| 45 | 45 | |
| 46 | -        if (isset($_SERVER['REQUEST_URI'])) { | |
| 47 | - $tags['endpoint_url'] = $_SERVER['REQUEST_URI']; | |
| 46 | +        if (isset($_SERVER[ 'REQUEST_URI' ])) { | |
| 47 | + $tags[ 'endpoint_url' ] = $_SERVER[ 'REQUEST_URI' ]; | |
| 48 | 48 | } | 
| 49 | 49 | |
| 50 | -        if (isset($_SERVER['REQUEST_METHOD'])) { | |
| 51 | - $tags['method'] = $_SERVER['REQUEST_METHOD']; | |
| 50 | +        if (isset($_SERVER[ 'REQUEST_METHOD' ])) { | |
| 51 | + $tags[ 'method' ] = $_SERVER[ 'REQUEST_METHOD' ]; | |
| 52 | 52 | } | 
| 53 | 53 | |
| 54 | -        if (isset($record['context']['user_id'])) { | |
| 55 | - $tags['user_id'] = $record['context']['user_id']; | |
| 54 | +        if (isset($record[ 'context' ][ 'user_id' ])) { | |
| 55 | + $tags[ 'user_id' ] = $record[ 'context' ][ 'user_id' ]; | |
| 56 | 56 | } | 
| 57 | 57 | |
| 58 | -        if (isset($record['context']['project_id'])) { | |
| 59 | - $tags['project_id'] = $record['context']['project_id']; | |
| 58 | +        if (isset($record[ 'context' ][ 'project_id' ])) { | |
| 59 | + $tags[ 'project_id' ] = $record[ 'context' ][ 'project_id' ]; | |
| 60 | 60 | } | 
| 61 | 61 | |
| 62 | -        if (isset($record['context']['file'])) { | |
| 63 | - $tags['file'] = $this->replaceDigitData($record['context']['file']); | |
| 62 | +        if (isset($record[ 'context' ][ 'file' ])) { | |
| 63 | + $tags[ 'file' ] = $this->replaceDigitData($record[ 'context' ][ 'file' ]); | |
| 64 | 64 | } | 
| 65 | 65 | |
| 66 | -        if (isset($record['context']['event']['api_stats'][0])) { | |
| 67 | -            foreach ($record['context']['event']['api_stats'][0] as $key => $value) { | |
| 66 | +        if (isset($record[ 'context' ][ 'event' ][ 'api_stats' ][ 0 ])) { | |
| 67 | +            foreach ($record[ 'context' ][ 'event' ][ 'api_stats' ][ 0 ] as $key => $value) { | |
| 68 | 68 |                  if (is_string($value) || is_int($value)) { | 
| 69 | - $tags[$key] = $value; | |
| 69 | + $tags[ $key ] = $value; | |
| 70 | 70 | } | 
| 71 | 71 | } | 
| 72 | 72 | } | 
| @@ -91,15 +91,15 @@ discard block | ||
| 91 | 91 |          if (count($tags)) { | 
| 92 | 92 |              foreach ($tags as $key => $value) { | 
| 93 | 93 |                  if (is_numeric($value)) { | 
| 94 | - $message['fields'][$key] = (int) $value; | |
| 94 | + $message[ 'fields' ][ $key ] = (int) $value; | |
| 95 | 95 | } | 
| 96 | 96 | } | 
| 97 | 97 | |
| 98 | - $message['tags'] = $tags; | |
| 98 | + $message[ 'tags' ] = $tags; | |
| 99 | 99 | } | 
| 100 | 100 | |
| 101 | -        if (isset($message['fields']['Debug']['message'])) { | |
| 102 | - $message['fields']['Debug']['message'] = $this->trimLines($message['fields']['Debug']['message']); | |
| 101 | +        if (isset($message[ 'fields' ][ 'Debug' ][ 'message' ])) { | |
| 102 | + $message[ 'fields' ][ 'Debug' ][ 'message' ] = $this->trimLines($message[ 'fields' ][ 'Debug' ][ 'message' ]); | |
| 103 | 103 | } | 
| 104 | 104 | |
| 105 | 105 | return $message; | 
| @@ -123,7 +123,7 @@ discard block | ||
| 123 | 123 | 600 => 'Emergency', | 
| 124 | 124 | ]; | 
| 125 | 125 | |
| 126 | - $result = isset($levels[$level]) ? $levels[$level] : $levels[600]; | |
| 126 | + $result = isset($levels[ $level ]) ? $levels[ $level ] : $levels[ 600 ]; | |
| 127 | 127 | |
| 128 | 128 | return $result; | 
| 129 | 129 | } | 
| @@ -5,7 +5,7 @@ discard block | ||
| 5 | 5 | * @author Austin Heap <[email protected]> | 
| 6 | 6 | * @version v0.1.6 | 
| 7 | 7 | */ | 
| 8 | -declare(strict_types=1); | |
| 8 | +declare(strict_types = 1); | |
| 9 | 9 | |
| 10 | 10 | namespace AustinHeap\Database\InfluxDb\Jobs; | 
| 11 | 11 | |
| @@ -35,7 +35,7 @@ discard block | ||
| 35 | 35 | * | 
| 36 | 36 | * @param array $args | 
| 37 | 37 | */ | 
| 38 | - public function __construct(array $args = []) | |
| 38 | + public function __construct(array $args = [ ]) | |
| 39 | 39 |      { | 
| 40 | 40 |          if (count($args)) { | 
| 41 | 41 | $this->args = $args; |