Umbrellio\TableSync\Integration\Laravel\InfluxDBServiceProvider

Complexity

Total Complexity

8

Size/Duplication

Total Lines	62
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	provides()	0	3	1
A	influxdbConfigPath()	0	3	1
A	telegrafConfigPath()	0	3	1
A	register()	0	20	3
A	boot()	0	17	2

<?php

declare(strict_types=1);

namespace Umbrellio\TableSync\Integration\Laravel;

use Illuminate\Log\LogManager;
use Illuminate\Support\ServiceProvider;
use InfluxDB\Client as InfluxClient;
use InfluxDB\Client\Exception as ClientException;
use InfluxDB\Database as InfluxDB;
use InfluxDB\Driver\UDP;

class InfluxDBServiceProvider extends ServiceProvider
{
    protected $defer = true;

    public function boot()
    {
        $this->publishes([
            $this->influxdbConfigPath() => config_path('influxdb.php'),
            $this->telegrafConfigPath() => config_path('telegraf.php'),
        ]);

        $this->mergeConfigFrom($this->influxdbConfigPath(), 'influxdb');
        $this->mergeConfigFrom($this->telegrafConfigPath(), 'telegraf');

        if (($logManager = $this->app->make('log')) instanceof LogManager) {

$logManager = $this->app->make('log') is always a sub-type of Illuminate\Log\LogManager.

            $logManager->extend('influxdb', function ($app, array $config) {
                return (new InfluxDBLogChannel($app))($config);
            });

            $logManager->extend('telegraf', function ($app, array $config) {
                return (new TelegrafLogChannel($app))($config);
            });
        }
    }

    public function register()
    {
        $this->app->singleton(InfluxDB::class, function ($app) {

The parameter $app is not used and could be removed.

            try {
                $client = new InfluxClient(
                    config('influxdb.host'),
                    config('influxdb.port'),
                    config('influxdb.username'),
                    config('influxdb.password'),
                    config('influxdb.ssl'),
                    config('influxdb.verifySSL'),
                    config('influxdb.timeout')
                );
                if (config('influxdb.udp.enabled') === true) {
                    $client->setDriver(new UDP($client->getHost(), config('influxdb.udp.port')));
                }

                return $client->selectDB(config('influxdb.dbname'));
            } catch (ClientException $clientException) {
                return null;
            }
        });
    }

    public function provides(): array
    {
        return [InfluxDB::class];
    }

    protected function influxdbConfigPath(): string
    {
        return __DIR__ . '/config/influxdb.php';
    }

    protected function telegrafConfigPath(): string
    {
        return __DIR__ . '/config/telegraf.php';
    }
}