JiraHandler::send() - Code Metrics - ARTACK/monolog-jira-handler - Measure and Improve Code Quality continuously with Scrutinizer

JiraHandler::send() B
last analyzed 2022-04-19 08:06 UTC

↳ Parent: JiraHandler

Complexity

Conditions	7
Paths	20

Size

Total Lines	104
Code Lines	71

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	67
CRAP Score	7

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
cc	7
eloc	71
c	1
b	0
f	0
nc	20
nop	2
dl	0
loc	104
ccs	67
cts	67
cp	1
crap	7
rs	7.6993

How to fix Long Method

<?php

declare(strict_types=1);

namespace Artack\Monolog\JiraHandler;

use Http\Client\Common\Plugin\AuthenticationPlugin;
use Http\Client\Common\Plugin\ContentLengthPlugin;
use Http\Client\Common\Plugin\HeaderDefaultsPlugin;
use Http\Client\Common\PluginClient;
use Http\Client\HttpClient;
use Http\Discovery\HttpClientDiscovery;
use Http\Discovery\Psr17FactoryDiscovery;
use Http\Message\Authentication\BasicAuth;
use Monolog\Logger;

class JiraHandler extends BatchHandler
{
    private $hostname;
    private $jql;
    private $hashFieldName;
    private $projectKey;
    private $issueTypeName;
    private $withComments;
    private $counterFieldName;

    private $requestFactory;
    private $urlFactory;
    private $streamFactory;
    private $httpClient;

    private $createdIssueId;

    public function __construct(string $hostname, string $username, string $password, string $jql, string $hashFieldName, string $projectKey, string $issueTypeName, bool $withComments = false, string $counterFieldName = null, HttpClient $httpClient = null, $level = Logger::DEBUG, $bubble = true)
    {
        parent::__construct($level, $bubble);

        $this->hostname = $hostname;
        $this->jql = $jql;
        $this->hashFieldName = $hashFieldName;
        $this->projectKey = $projectKey;
        $this->issueTypeName = $issueTypeName;
        $this->withComments = $withComments;
        $this->counterFieldName = $counterFieldName;

        $authentication = new BasicAuth($username, $password);
        $authenticationPlugin = new AuthenticationPlugin($authentication);

        $contentLengthPlugin = new ContentLengthPlugin();
        $headerDefaultsPlugin = new HeaderDefaultsPlugin([
            'Content-Type' => 'application/json',
        ]);

        $this->requestFactory = Psr17FactoryDiscovery::findRequestFactory();
        $this->urlFactory = Psr17FactoryDiscovery::findUrlFactory();
        $this->streamFactory = Psr17FactoryDiscovery::findStreamFactory();

        $this->httpClient = new PluginClient(
            $httpClient ?: HttpClientDiscovery::find(),
            [$authenticationPlugin, $headerDefaultsPlugin, $contentLengthPlugin]
        );
    }

    protected function send($content, array $records): void
    {
        $countFieldId = null;
        $highestRecord = $this->getHighestRecord($records);

        $recordForHash = $highestRecord;
        unset($recordForHash['datetime'], $recordForHash['formatted'], $recordForHash['context']);
        $hash = md5(serialize($recordForHash));

        $uri = $this->urlFactory->createUri(sprintf('https://%s/rest/api/2/customFields', $this->hostname));
        $request = $this->requestFactory->createRequest('GET', $uri);
        $response = $this->httpClient->sendRequest($request);
        $data = json_decode($response->getBody()->getContents(), true);
        $hashFieldId = $this->parseCustomFieldId($data, 'values', $this->hashFieldName);

        if ($this->counterFieldName) {
            $countFieldId = $this->parseCustomFieldId($data, 'values', $this->counterFieldName);
        }

        $jql = sprintf('%s AND %s ~ \'%s\'', $this->jql, $this->hashFieldName, $hash);

        $fields = [
            'issuetype',
            'status',
            'summary',
            $hashFieldId,
            $this->counterFieldName,
        ];

        if ($countFieldId) {
            $fields[] = $countFieldId;
        }

        $body = json_encode([
            'jql' => $jql,
            'fields' => $fields,
        ]);

        $uri = $this->urlFactory->createUri(sprintf('https://%s/rest/api/2/search', $this->hostname));
        $request = $this->requestFactory->createRequest('POST', $uri)->withBody($this->streamFactory->createStream($body));
        $response = $this->httpClient->sendRequest($request);
        $data = json_decode($response->getBody()->getContents(), true);

        if ($data['total'] > 0) {
            $issueId = $data['issues'][0]['id'];

            if ($this->counterFieldName) {
                $countFieldValue = $data['issues'][0]['fields'][$countFieldId];

                $uri = $this->urlFactory->createUri(sprintf('https://%s/rest/api/2/issue/%d', $this->hostname, $issueId).'?'.http_build_query([
                    'notifyUsers' => false,
                ]));
                $rawBody = [
                    'fields' => [
                        $countFieldId => ++$countFieldValue,
                    ],
                ];
                $body = json_encode($rawBody);
                $request = $this->requestFactory->createRequest('PUT', $uri)->withBody($this->streamFactory->createStream($body));
                $this->httpClient->sendRequest($request);
            }

            if ($this->withComments) {
                $uri = $this->urlFactory->createUri(sprintf('https://%s/rest/api/2/issue/%d/comment', $this->hostname, $issueId));
                $body = json_encode([
                    'body' => $content,
                ]);
                $request = $this->requestFactory->createRequest('POST', $uri)->withBody($this->streamFactory->createStream($body));
                $this->httpClient->sendRequest($request);
            }

            return;
        }

        $uri = $this->urlFactory->createUri(sprintf('https://%s/rest/api/2/issue/createmeta', $this->hostname).'?'.http_build_query([
            'projectKeys' => $this->projectKey,
            'expand' => 'projects.issuetypes.fields',
        ]));
        $request = $this->requestFactory->createRequest('GET', $uri);
        $response = $this->httpClient->sendRequest($request);
        $data = json_decode($response->getBody()->getContents(), true);

        $projectId = $this->parseProjectId($data);
        $issueType = $this->parseIssueType($data, $this->issueTypeName);
        $issueTypeId = (int) $issueType['id'];
        $summary = sprintf('%s: %s', $highestRecord['level_name'], $highestRecord['message']);

        $body = json_encode([
            'fields' => [
                'project' => [
                    'id' => $projectId,
                ],
                'issuetype' => ['id' => $issueTypeId],
                'summary' => strlen($summary) > 255 ? substr($summary, 0, 252).'...' : $summary,
                'description' => $content,
                $hashFieldId => $hash,
                $countFieldId => 1,
            ],
        ]);
        $uri = $this->urlFactory->createUri(sprintf('https://%s/rest/api/2/issue', $this->hostname));
        $request = $this->requestFactory->createRequest('POST', $uri)->withBody($this->streamFactory->createStream($body));
        $response = $this->httpClient->sendRequest($request);
        $data = json_decode($response->getBody()->getContents(), true);
        $this->createdIssueId = $data['id'];
    }

    protected function parseProjectId(array $data): int
    {
        return (int) $data['projects'][0]['id'];
    }

    protected function parseIssueType(array $data, string $issueTypeName): array
    {
        return array_values(array_filter($data['projects'][0]['issuetypes'], function ($data) use ($issueTypeName) {
            return $data['name'] === $issueTypeName;
        }))[0];
    }

    protected function parseCustomFieldId(array $data, string $part, string $fieldName): string
    {
        return array_values(array_filter($data[$part], function ($item) use ($fieldName) {
            return $item['name'] === $fieldName;
        }))[0]['id'];
    }

    public function getCreatedIssueId()
    {
        return $this->createdIssueId;
    }
}


1		<?php
2
3		declare(strict_types=1);
4
5		namespace Artack\Monolog\JiraHandler;
6
7		use Http\Client\Common\Plugin\AuthenticationPlugin;
8		use Http\Client\Common\Plugin\ContentLengthPlugin;
9		use Http\Client\Common\Plugin\HeaderDefaultsPlugin;
10		use Http\Client\Common\PluginClient;
11		use Http\Client\HttpClient;
12		use Http\Discovery\HttpClientDiscovery;
13		use Http\Discovery\Psr17FactoryDiscovery;
14		use Http\Message\Authentication\BasicAuth;
15		use Monolog\Logger;
16
17		class JiraHandler extends BatchHandler
18		{
19		private $hostname;
20		private $jql;
21		private $hashFieldName;
22		private $projectKey;
23		private $issueTypeName;
24		private $withComments;
25		private $counterFieldName;
26
27		private $requestFactory;
28		private $urlFactory;
29		private $streamFactory;
30		private $httpClient;
31
32		private $createdIssueId;
33
34	2	public function __construct(string $hostname, string $username, string $password, string $jql, string $hashFieldName, string $projectKey, string $issueTypeName, bool $withComments = false, string $counterFieldName = null, HttpClient $httpClient = null, $level = Logger::DEBUG, $bubble = true)
35		{
36	2	parent::__construct($level, $bubble);
37
38	2	$this->hostname = $hostname;
39	2	$this->jql = $jql;
40	2	$this->hashFieldName = $hashFieldName;
41	2	$this->projectKey = $projectKey;
42	2	$this->issueTypeName = $issueTypeName;
43	2	$this->withComments = $withComments;
44	2	$this->counterFieldName = $counterFieldName;
45
46	2	$authentication = new BasicAuth($username, $password);
47	2	$authenticationPlugin = new AuthenticationPlugin($authentication);
48
49	2	$contentLengthPlugin = new ContentLengthPlugin();
50	2	$headerDefaultsPlugin = new HeaderDefaultsPlugin([
51	2	'Content-Type' => 'application/json',
52		]);
53
54	2	$this->requestFactory = Psr17FactoryDiscovery::findRequestFactory();
55	2	$this->urlFactory = Psr17FactoryDiscovery::findUrlFactory();
56	2	$this->streamFactory = Psr17FactoryDiscovery::findStreamFactory();
57
58	2	$this->httpClient = new PluginClient(
59	2	$httpClient ?: HttpClientDiscovery::find(),
60	2	[$authenticationPlugin, $headerDefaultsPlugin, $contentLengthPlugin]
61		);
62	2	}
63
64	2	protected function send($content, array $records): void
65		{
66	2	$countFieldId = null;
67	2	$highestRecord = $this->getHighestRecord($records);
68
69	2	$recordForHash = $highestRecord;
70	2	unset($recordForHash['datetime'], $recordForHash['formatted'], $recordForHash['context']);
71	2	$hash = md5(serialize($recordForHash));
72
73	2	$uri = $this->urlFactory->createUri(sprintf('https://%s/rest/api/2/customFields', $this->hostname));
74	2	$request = $this->requestFactory->createRequest('GET', $uri);
75	2	$response = $this->httpClient->sendRequest($request);
76	2	$data = json_decode($response->getBody()->getContents(), true);
77	2	$hashFieldId = $this->parseCustomFieldId($data, 'values', $this->hashFieldName);
78
79	2	if ($this->counterFieldName) {
80	2	$countFieldId = $this->parseCustomFieldId($data, 'values', $this->counterFieldName);
81		}
82
83	2	$jql = sprintf('%s AND %s ~ \'%s\'', $this->jql, $this->hashFieldName, $hash);
84
85		$fields = [
86	2	'issuetype',
87	2	'status',
88	2	'summary',
89	2	$hashFieldId,
90	2	$this->counterFieldName,
91		];
92
93	2	if ($countFieldId) {
94	2	$fields[] = $countFieldId;
95		}
96
97	2	$body = json_encode([
98	2	'jql' => $jql,
99	2	'fields' => $fields,
100		]);
101
102	2	$uri = $this->urlFactory->createUri(sprintf('https://%s/rest/api/2/search', $this->hostname));
103	2	$request = $this->requestFactory->createRequest('POST', $uri)->withBody($this->streamFactory->createStream($body));
104	2	$response = $this->httpClient->sendRequest($request);
105	2	$data = json_decode($response->getBody()->getContents(), true);
106
107	2	if ($data['total'] > 0) {
108	1	$issueId = $data['issues'][0]['id'];
109
110	1	if ($this->counterFieldName) {
111	1	$countFieldValue = $data['issues'][0]['fields'][$countFieldId];
112
113	1	$uri = $this->urlFactory->createUri(sprintf('https://%s/rest/api/2/issue/%d', $this->hostname, $issueId).'?'.http_build_query([
114	1	'notifyUsers' => false,
115		]));
116		$rawBody = [
117		'fields' => [
118	1	$countFieldId => ++$countFieldValue,
119		],
120		];
121	1	$body = json_encode($rawBody);
122	1	$request = $this->requestFactory->createRequest('PUT', $uri)->withBody($this->streamFactory->createStream($body));
123	1	$this->httpClient->sendRequest($request);
124		}
125
126	1	if ($this->withComments) {
127	1	$uri = $this->urlFactory->createUri(sprintf('https://%s/rest/api/2/issue/%d/comment', $this->hostname, $issueId));
128	1	$body = json_encode([
129	1	'body' => $content,
130		]);
131	1	$request = $this->requestFactory->createRequest('POST', $uri)->withBody($this->streamFactory->createStream($body));
132	1	$this->httpClient->sendRequest($request);
133		}
134
135	1	return;
136		}
137
138	1	$uri = $this->urlFactory->createUri(sprintf('https://%s/rest/api/2/issue/createmeta', $this->hostname).'?'.http_build_query([
139	1	'projectKeys' => $this->projectKey,
140	1	'expand' => 'projects.issuetypes.fields',
141		]));
142	1	$request = $this->requestFactory->createRequest('GET', $uri);
143	1	$response = $this->httpClient->sendRequest($request);
144	1	$data = json_decode($response->getBody()->getContents(), true);
145
146	1	$projectId = $this->parseProjectId($data);
147	1	$issueType = $this->parseIssueType($data, $this->issueTypeName);
148	1	$issueTypeId = (int) $issueType['id'];
149	1	$summary = sprintf('%s: %s', $highestRecord['level_name'], $highestRecord['message']);
150
151	1	$body = json_encode([
152		'fields' => [
153		'project' => [
154	1	'id' => $projectId,
155		],
156	1	'issuetype' => ['id' => $issueTypeId],
157	1	'summary' => strlen($summary) > 255 ? substr($summary, 0, 252).'...' : $summary,
158	1	'description' => $content,
159	1	$hashFieldId => $hash,
160	1	$countFieldId => 1,
161		],
162		]);
163	1	$uri = $this->urlFactory->createUri(sprintf('https://%s/rest/api/2/issue', $this->hostname));
164	1	$request = $this->requestFactory->createRequest('POST', $uri)->withBody($this->streamFactory->createStream($body));
165	1	$response = $this->httpClient->sendRequest($request);
166	1	$data = json_decode($response->getBody()->getContents(), true);
167	1	$this->createdIssueId = $data['id'];
168	1	}
169
170	1	protected function parseProjectId(array $data): int
171		{
172	1	return (int) $data['projects'][0]['id'];
173		}
174
175	1	protected function parseIssueType(array $data, string $issueTypeName): array
176		{
177		return array_values(array_filter($data['projects'][0]['issuetypes'], function ($data) use ($issueTypeName) {
178	1	return $data['name'] === $issueTypeName;
179	1	}))[0];
180		}
181
182	2	protected function parseCustomFieldId(array $data, string $part, string $fieldName): string
183		{
184		return array_values(array_filter($data[$part], function ($item) use ($fieldName) {
185	2	return $item['name'] === $fieldName;
186	2	}))[0]['id'];
187		}
188
189	1	public function getCreatedIssueId()
190		{
191	1	return $this->createdIssueId;
192		}
193		}
194

ARTACK / monolog-jira-handler

JiraHandler::send() B last analyzed 2022-04-19 08:06 UTC

Complexity

Size

Duplication

Code Coverage

Importance

How to fix Long Method

Long Method

Duplication Side-by-Side

Filter issues like

JiraHandler::send() B
last analyzed 2022-04-19 08:06 UTC