Krenor\Prometheus\PushGateway

Complexity

Total Complexity

7

Size/Duplication

Total Lines	92
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	delete()	0	3	1
A	__construct()	0	4	1
A	request()	0	20	3
A	add()	0	3	1
A	replace()	0	3	1

<?php

namespace Krenor\Prometheus;

use GuzzleHttp\Client;
use GuzzleHttp\Psr7\Request;
use function GuzzleHttp\Psr7\stream_for;
use Krenor\Prometheus\Renderer\TextRenderer;

class PushGateway
{
    /**
     * @var Client
     */
    protected $client;

    /**
     * @var CollectorRegistry
     */
    protected $registry;

    /**
     * PushGateway constructor.
     *
     * @param Client $client
     * @param CollectorRegistry $registry
     */
    public function __construct(Client $client, CollectorRegistry $registry)
    {
        $this->client = $client;
        $this->registry = $registry;
    }

    /**
     * @param string $job
     * @param string|null $instance
     *
     * @throws \GuzzleHttp\Exception\GuzzleException
     *
     * @return bool
     */
    public function add(string $job, ?string $instance = null): bool
    {
        return $this->request('POST', ...func_get_args());

func_get_args() is expanded, but the parameter $job of Krenor\Prometheus\PushGateway::request() does not expect variable arguments.

    }

    /**
     * @param string $job
     * @param string|null $instance
     *
     * @throws \GuzzleHttp\Exception\GuzzleException
     *
     * @return bool
     */
    public function replace(string $job, ?string $instance = null): bool
    {
        return $this->request('PUT', ...func_get_args());

func_get_args() is expanded, but the parameter $job of Krenor\Prometheus\PushGateway::request() does not expect variable arguments.

    }

    /**
     * @param string $job
     * @param string|null $instance
     *
     * @throws \GuzzleHttp\Exception\GuzzleException
     *
     * @return bool
     */
    public function delete(string $job, ?string $instance = null): bool
    {
        return $this->request('DELETE', ...func_get_args());

func_get_args() is expanded, but the parameter $job of Krenor\Prometheus\PushGateway::request() does not expect variable arguments.

    }

    /**
     * @param string $method
     * @param string $job
     * @param string|null $instance
     *
     * @throws \GuzzleHttp\Exception\GuzzleException
     *
     * @return bool
     */
    protected function request(string $method, string $job, ?string $instance = null): bool
    {
        $request = new Request($method, $instance === null ? "job/{$job}" : "job/{$job}/instance/{$instance}");
        $options = [
            'headers' => [
                'Content-Type' => TextRenderer::CONTENT_TYPE,
            ],
        ];

        if ($method !== 'DELETE') {
            $options['body'] = stream_for(
                (new TextRenderer)
                    ->render($this->registry->collect())
            );
        }

        return $this
                ->client
                ->send($request, $options)
                ->getStatusCode() === 202;
    }
}