SprykerEco\Zed\NewRelic\Business\Model\RecordDeployment

Complexity

Total Complexity

9

Size/Duplication

Total Lines	119
Duplicated Lines	0 %

Importance

Changes	3
Bugs	0	Features	1

4 Methods

Rating	Name	Duplication	Size	Complexity
A	recordSingleDeployment()	0	13	3
A	recordDeployment()	0	12	3
A	createRecordDeploymentRequest()	0	26	2
A	__construct()	0	8	1

<?php

/**
 * MIT License
 * For full license information, please view the LICENSE file that was distributed with this source code.
 */

namespace SprykerEco\Zed\NewRelic\Business\Model;

use GuzzleHttp\Client;
use Psr\Http\Message\ResponseInterface;
use SprykerEco\Zed\NewRelic\Business\Exception\RecordDeploymentException;

class RecordDeployment implements RecordDeploymentInterface
{
    /**
     * @var int
     */
    public const STATUS_CODE_SUCCESS = 200;

    /**
     * @var int
     */
    public const STATUS_CODE_REDIRECTION = 300;

    /**
     * @var string
     *
     * @example https://api.eu.newrelic.com/v2/applications/12345/deployments.json
     * @example https://api.eu.newrelic.com/v2/applications/%s/deployments.json
     *
     * @see https://docs.newrelic.com/docs/apm/new-relic-apm/maintenance/record-deployments
     */
    protected $newRelicDeploymentApiUrl;

    /**
     * @var string
     */
    protected $newRelicApiKey;

    /**
     * @var array
     */
    protected $newRelicApplicationIds;

    /**
     * @param string $newRelicDeploymentApiUrl
     * @param string $newRelicApiKey
     * @param array $newRelicApplicationIds
     */
    public function __construct(
        string $newRelicDeploymentApiUrl,
        string $newRelicApiKey,
        array $newRelicApplicationIds = []
    ) {
        $this->newRelicDeploymentApiUrl = $newRelicDeploymentApiUrl;
        $this->newRelicApiKey = $newRelicApiKey;
        $this->newRelicApplicationIds = $newRelicApplicationIds;
    }

    /**
     * @param array $arguments
     *
     * @return $this
     */
    public function recordDeployment(array $arguments = [])
    {
        if (!$this->newRelicApplicationIds) {

The expression $this->newRelicApplicationIds of type array is implicitly converted to a boolean; are you sure this is intended? If so, consider using empty($expr) instead to make it clear that you intend to check for an array without elements.

            return $this->recordSingleDeployment($arguments);
        }

        foreach ($this->newRelicApplicationIds as $singleApplicationId) {
            $arguments['application_id'] = $singleApplicationId;
            $this->recordSingleDeployment($arguments);
        }

        return $this;
    }

    /**
     * @param array $params
     *
     * @return \Psr\Http\Message\ResponseInterface
     */
    protected function createRecordDeploymentRequest(array $params): ResponseInterface
    {
        $applicationId = $params['application_id'] ?? null;

        unset($params['app_name']);
        unset($params['application_id']);

        $options = [
            'headers' => [
                'X-Api-Key' => $this->newRelicApiKey,
            ],
            'json' => [
                'deployment' => $params,
            ],
        ];

        $httpClient = new Client();

        $deploymentUrl = $this->newRelicDeploymentApiUrl;
        if ($applicationId) {
            $deploymentUrl = sprintf($this->newRelicDeploymentApiUrl, $applicationId);
        }

        $request = $httpClient->post($deploymentUrl, $options);

        return $request;
    }

    /**
     * @param array $arguments
     *
     * @throws \SprykerEco\Zed\NewRelic\Business\Exception\RecordDeploymentException
     *
     * @return $this
     */
    private function recordSingleDeployment(array $arguments = [])
    {
        $response = $this->createRecordDeploymentRequest($arguments);
        $statusCode = $response->getStatusCode();
        if ($statusCode < static::STATUS_CODE_SUCCESS || $statusCode >= static::STATUS_CODE_REDIRECTION) {
            throw new RecordDeploymentException(sprintf(
                'Record deployment to New Relic request failed with code %d. %s',
                $response->getStatusCode(),
                $response->getBody(),
            ));
        }

        return $this;
    }
}