WebHook::sendMessage() - Code Metrics - Inspection of "Update message send feature" - nguereza-tony/telegram-github-hook - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — develop ( fea4fb...2aff8d )

by nguereza

created 2025-10-05 04:07 UTC

WebHook::sendMessage() A

↳ Parent: WebHook

Complexity

Conditions	5
Paths	7

Size

Total Lines	37
Code Lines	23

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
cc	5
eloc	23
c	1
b	0
f	0
nc	7
nop	2
dl	0
loc	37
rs	9.2408

<?php

declare(strict_types=1);

namespace Quantum\Hub;

use DateTime;
use Exception;
use Platine\Config\Config;
use Platine\Http\Client\HttpClient;
use Platine\Http\ServerRequest;
use Platine\Http\ServerRequestInterface;
use Platine\Stdlib\Helper\Arr;
use Platine\Stdlib\Helper\Json;
use Platine\Stdlib\Helper\Str;
use Quantum\Hub\Entity\Commit;
use Quantum\Hub\Entity\Repository;
use Quantum\Hub\Entity\Sender;

/**
 * @class WebHook
 * @package Quantum\Hub
 * @template T
 */
class WebHook
{
    /**
     * The request instance to use
     * @var ServerRequestInterface
     */
    protected ServerRequestInterface $request;

    /**
     * The payload data
     * @var array<string, mixed>
     */
    protected array $payload = [];

    /**
     * Create new instance
     * @param Config<T> $config
     * @param ServerRequestInterface|null $request
     */
    public function __construct(
        protected Config $config,
        ?ServerRequestInterface $request = null,
    ) {
        if ($request === null) {
            $this->request = ServerRequest::createFromGlobals();
        }
    }


    /**
     * Handle the request
     * @return void
     */
    public function handle(): void
    {
        $this->processPayload();

        $repository = $this->getRepository();
        $commit = $this->getCommit();
        $disabledRepos = $this->getDisabledRepositories();
        if (
            $this->getEvent() !== 'push' ||
            $commit === null ||
            in_array(
                $repository->getFullName(),
                $disabledRepos
            )
        ) {
            return;
        }

        // Now send the message
        $this->sendMessage($commit, $repository);
    }

    /**
     * Return the commit branch
     * @return string
     */
    public function getBranch(): string
    {
        $value = $this->getPayloadValue('ref');
        return Arr::last(explode('/', $value));
    }

    /**
     * Return the GitHub Event. Currently only push is supported
     * @return string
     */
    public function getEvent(): string
    {
        return $this->request->getHeaderLine('X-GitHub-Event');
    }

    /**
     * Return the value of the payload
     * @param string $name
     * @param mixed $default
     * @return mixed
     */
    public function getPayloadValue(
        string $name,
        mixed $default = null
    ): mixed {
        return Arr::get(
            $this->payload,
            $name,
            $default
        );
    }

    /**
     * Return the repository info
     * @return Repository
     */
    public function getRepository(): Repository
    {
        $data = $this->getPayloadValue('repository', []);

        return new Repository($data);
    }

     /**
     * Return the sender (user who make push) info
     * @return Sender
     */
    public function getSender(): Sender
    {
        $data = $this->getPayloadValue('sender', []);

        return new Sender($data);
    }

    /**
     * Return the commit information if have
     * @return Commit
     */
    public function getCommit(): ?Commit
    {
        $data = $this->getPayloadValue('commits', []);
        if (count($data) === 0) {
            return null;
        }

        return new Commit($data[0]);
    }

    /**
     * Get message content
     * @param Commit $commit
     * @param Repository $repository
     * @return string
     */
    public function getMessageContent(
        Commit $commit,
        Repository $repository
    ): string {
        $sender = $this->getSender();

        $text = sprintf(
            "<a href = \"%s\"><b>@%s</b></a> just push to repository <a href = \"%s\"><b>%s</b></a>%s%s",
            $sender->getHtmlUrl(),
            $sender->getLogin(),
            $repository->getHtmlUrl(),
            $repository->getFullName(),
            PHP_EOL,
            PHP_EOL
        );

        $date = new DateTime($commit->getTimestamp());

        $text .= $this->buildMessageRow('Description', $commit->getMessage(), 2);
        $text .= $this->buildMessageRow('Date', $date->format('Y-m-d H:i:s'));
        $text .= $this->buildMessageRow('Branch/Tag', $this->getBranch());
        $text .= $this->buildMessageRow(
            'Commit ID',
            sprintf(
                '<a href = "%s"><b>%s</b></a>',
                $commit->getUrl(),
                $commit->getId()
            )
        );

        $text .= $this->getCommitFilesChangeMessage($commit->getAdded(), 'added');
        $text .= $this->getCommitFilesChangeMessage($commit->getModified(), 'modified');
        $text .= $this->getCommitFilesChangeMessage($commit->getRemoved(), 'deleted');


        return $text;
    }

    /**
     * Return the list of repository that is disabled
     * @return array<string>
     */
    protected function getDisabledRepositories(): array
    {
        $params = $this->request->getQueryParams();
        $repositories = $params['disable_repos'] ?? '';
        if (empty($repositories)) {
            return [];
        }

        return explode(',', $repositories);
    }

    /**
     * Process the payload
     * @return void
     */
    protected function processPayload(): void
    {
        $body = $this->request->getBody()->getContents();
        if (!empty($body)) {
            $payload = Json::decode($body, true);

            $this->payload = $payload;
        }
    }

    /**
     * Return the commit message files changes (added/removed/modified)
     * @param array<string> $files
     * @param string $type
     * @return string
     */
    protected function getCommitFilesChangeMessage(array $files, string $type): string
    {
        if (count($files) === 0) {
            return '';
        }

        // Use double quote in order to format EOL
        $text = sprintf("%s<b>Files %s:</b>%s", PHP_EOL, $type, PHP_EOL);
        $text .= sprintf("- %s %s", implode(PHP_EOL . '- ', $files), PHP_EOL);

        return $text;
    }

    /**
     * Build the message row
     * @param string $label
     * @param string $value
     * @param int $eolCount
     * @return string
     */
    protected function buildMessageRow(
        string $label,
        string $value,
        int $eolCount = 1
    ): string {
        return sprintf(
            "<b>%s:</b> %s%s",
            $label,
            $value,
            Str::repeat(PHP_EOL, $eolCount)
        );
    }

    /**
     * Return the chat id and bot token to be used
     * @param Repository $repository
     * @return array{chat:string, token:string}|null
     */
    protected function getConfigInfo(Repository $repository): ?array
    {
        $organization = $repository->getOrganization();
        $repoName = $repository->getName();
        $configKey = 'config.organization.%s.%s';

        // Check for one repository configuration
        $repoConfig = $this->config->get(
            sprintf($configKey, $organization, $repoName),
            []
        );
        if (count($repoConfig) === 2) {
            return [
                'chat' => $repoConfig[0],
                'token' => $repoConfig[1],
            ];
        }

        // Default
        $allConfig = $this->config->get(
            sprintf($configKey, $organization, '*'),
            []
        );
        if (count($allConfig) === 2) {
            return [
                'chat' => $allConfig[0],
                'token' => $allConfig[1],
            ];
        }

        return null;
    }

    /**
     * Send the message
     * @param Commit $commit
     * @param Repository $repository
     * @return bool
     */
    protected function sendMessage(
        Commit $commit,
        Repository $repository
    ): bool {
        $config = $this->getConfigInfo($repository);
        if ($config === null) {
            return false;
        }

        $message = $this->getMessageContent($commit, $repository);
        if (empty($message)) {
            return false;
        }

        $url = sprintf('https://api.telegram.org/bot%s/sendMessage', $config['token']);
        $params = [
            'chat_id' => $config['chat'],
            'parse_mode' => 'HTML',
            'text' => $message,
        ];

        $client = new HttpClient($url);
        $client->json()
               ->verifySslCertificate(false);
        try {
            $response = $client->post('', $params);

            if ($response->isError()) {
                error_log($response->getError());

                return false;
            }

            return true;
        } catch (Exception $ex) {
            error_log($ex->getMessage());
            return false;
        }
    }
}


1			<?php
2
3			declare(strict_types=1);
4
5			namespace Quantum\Hub;
6
7			use DateTime;
8			use Exception;
9			use Platine\Config\Config;
10			use Platine\Http\Client\HttpClient;
11			use Platine\Http\ServerRequest;
12			use Platine\Http\ServerRequestInterface;
13			use Platine\Stdlib\Helper\Arr;
14			use Platine\Stdlib\Helper\Json;
15			use Platine\Stdlib\Helper\Str;
16			use Quantum\Hub\Entity\Commit;
17			use Quantum\Hub\Entity\Repository;
18			use Quantum\Hub\Entity\Sender;
19
20			/**
21			* @class WebHook
22			* @package Quantum\Hub
23			* @template T
24			*/
25			class WebHook
26			{
27			/**
28			* The request instance to use
29			* @var ServerRequestInterface
30			*/
31			protected ServerRequestInterface $request;
32
33			/**
34			* The payload data
35			* @var array<string, mixed>
36			*/
37			protected array $payload = [];
38
39			/**
40			* Create new instance
41			* @param Config<T> $config
42			* @param ServerRequestInterface\|null $request
43			*/
44			public function __construct(
45			protected Config $config,
46			?ServerRequestInterface $request = null,
47			) {
48			if ($request === null) {
49			$this->request = ServerRequest::createFromGlobals();
50			}
51			}
52
53
54			/**
55			* Handle the request
56			* @return void
57			*/
58			public function handle(): void
59			{
60			$this->processPayload();
61
62			$repository = $this->getRepository();
63			$commit = $this->getCommit();
64			$disabledRepos = $this->getDisabledRepositories();
65			if (
66			$this->getEvent() !== 'push' \|\|
67			$commit === null \|\|
68			in_array(
69			$repository->getFullName(),
70			$disabledRepos
71			)
72			) {
73			return;
74			}
75
76			// Now send the message
77			$this->sendMessage($commit, $repository);
78			}
79
80			/**
81			* Return the commit branch
82			* @return string
83			*/
84			public function getBranch(): string
85			{
86			$value = $this->getPayloadValue('ref');
87			return Arr::last(explode('/', $value));
88			}
89
90			/**
91			* Return the GitHub Event. Currently only push is supported
92			* @return string
93			*/
94			public function getEvent(): string
95			{
96			return $this->request->getHeaderLine('X-GitHub-Event');
97			}
98
99			/**
100			* Return the value of the payload
101			* @param string $name
102			* @param mixed $default
103			* @return mixed
104			*/
105			public function getPayloadValue(
106			string $name,
107			mixed $default = null
108			): mixed {
109			return Arr::get(
110			$this->payload,
111			$name,
112			$default
113			);
114			}
115
116			/**
117			* Return the repository info
118			* @return Repository
119			*/
120			public function getRepository(): Repository
121			{
122			$data = $this->getPayloadValue('repository', []);
123
124			return new Repository($data);
125			}
126
127			/**
128			* Return the sender (user who make push) info
129			* @return Sender
130			*/
131			public function getSender(): Sender
132			{
133			$data = $this->getPayloadValue('sender', []);
134
135			return new Sender($data);
136			}
137
138			/**
139			* Return the commit information if have
140			* @return Commit
141			*/
142			public function getCommit(): ?Commit
143			{
144			$data = $this->getPayloadValue('commits', []);
145			if (count($data) === 0) {
146			return null;
147			}
148
149			return new Commit($data[0]);
150			}
151
152			/**
153			* Get message content
154			* @param Commit $commit
155			* @param Repository $repository
156			* @return string
157			*/
158			public function getMessageContent(
159			Commit $commit,
160			Repository $repository
161			): string {
162			$sender = $this->getSender();
163
164			$text = sprintf(
165			"<a href = \"%s\"><b>@%s</b></a> just push to repository <a href = \"%s\"><b>%s</b></a>%s%s",
166			$sender->getHtmlUrl(),
167			$sender->getLogin(),
168			$repository->getHtmlUrl(),
169			$repository->getFullName(),
170			PHP_EOL,
171			PHP_EOL
172			);
173
174			$date = new DateTime($commit->getTimestamp());
175
176			$text .= $this->buildMessageRow('Description', $commit->getMessage(), 2);
177			$text .= $this->buildMessageRow('Date', $date->format('Y-m-d H:i:s'));
178			$text .= $this->buildMessageRow('Branch/Tag', $this->getBranch());
179			$text .= $this->buildMessageRow(
180			'Commit ID',
181			sprintf(
182			'<a href = "%s"><b>%s</b></a>',
183			$commit->getUrl(),
184			$commit->getId()
185			)
186			);
187
188			$text .= $this->getCommitFilesChangeMessage($commit->getAdded(), 'added');
189			$text .= $this->getCommitFilesChangeMessage($commit->getModified(), 'modified');
190			$text .= $this->getCommitFilesChangeMessage($commit->getRemoved(), 'deleted');
191
192
193			return $text;
194			}
195
196			/**
197			* Return the list of repository that is disabled
198			* @return array<string>
199			*/
200			protected function getDisabledRepositories(): array
201			{
202			$params = $this->request->getQueryParams();
203			$repositories = $params['disable_repos'] ?? '';
204			if (empty($repositories)) {
205			return [];
206			}
207
208			return explode(',', $repositories);
209			}
210
211			/**
212			* Process the payload
213			* @return void
214			*/
215			protected function processPayload(): void
216			{
217			$body = $this->request->getBody()->getContents();
218			if (!empty($body)) {
219			$payload = Json::decode($body, true);
220
221			$this->payload = $payload;
222			}
223			}
224
225			/**
226			* Return the commit message files changes (added/removed/modified)
227			* @param array<string> $files
228			* @param string $type
229			* @return string
230			*/
231			protected function getCommitFilesChangeMessage(array $files, string $type): string
232			{
233			if (count($files) === 0) {
234			return '';
235			}
236
237			// Use double quote in order to format EOL
238			$text = sprintf("%s<b>Files %s:</b>%s", PHP_EOL, $type, PHP_EOL);
239			$text .= sprintf("- %s %s", implode(PHP_EOL . '- ', $files), PHP_EOL);
240
241			return $text;
242			}
243
244			/**
245			* Build the message row
246			* @param string $label
247			* @param string $value
248			* @param int $eolCount
249			* @return string
250			*/
251			protected function buildMessageRow(
252			string $label,
253			string $value,
254			int $eolCount = 1
255			): string {
256			return sprintf(
257			"<b>%s:</b> %s%s",
258			$label,
259			$value,
260			Str::repeat(PHP_EOL, $eolCount)
261			);
262			}
263
264			/**
265			* Return the chat id and bot token to be used
266			* @param Repository $repository
267			* @return array{chat:string, token:string}\|null
268			*/
269			protected function getConfigInfo(Repository $repository): ?array
270			{
271			$organization = $repository->getOrganization();
272			$repoName = $repository->getName();
273			$configKey = 'config.organization.%s.%s';
274
275			// Check for one repository configuration
276			$repoConfig = $this->config->get(
277			sprintf($configKey, $organization, $repoName),
278			[]
279			);
280			if (count($repoConfig) === 2) {
281			return [
282			'chat' => $repoConfig[0],
283			'token' => $repoConfig[1],
284			];
285			}
286
287			// Default
288			$allConfig = $this->config->get(
289			sprintf($configKey, $organization, '*'),
290			[]
291			);
292			if (count($allConfig) === 2) {
293			return [
294			'chat' => $allConfig[0],
295			'token' => $allConfig[1],
296			];
297			}
298
299			return null;
300			}
301
302			/**
303			* Send the message
304			* @param Commit $commit
305			* @param Repository $repository
306			* @return bool
307			*/
308			protected function sendMessage(
309			Commit $commit,
310			Repository $repository
311			): bool {
312			$config = $this->getConfigInfo($repository);
313			if ($config === null) {
314			return false;
315			}
316
317			$message = $this->getMessageContent($commit, $repository);
318			if (empty($message)) {
319			return false;
320			}
321
322			$url = sprintf('https://api.telegram.org/bot%s/sendMessage', $config['token']);
323			$params = [
324			'chat_id' => $config['chat'],
325			'parse_mode' => 'HTML',
326			'text' => $message,
327			];
328
329			$client = new HttpClient($url);
330			$client->json()
331			->verifySslCertificate(false);
332			try {
333			$response = $client->post('', $params);
334
335			if ($response->isError()) {
336			error_log($response->getError());
337
338			return false;
339			}
340
341			return true;
342			} catch (Exception $ex) {
343			error_log($ex->getMessage());
344			return false;
345			}
346			}
347			}
348

nguereza-tony / telegram-github-hook

Push — develop ( fea4fb...2aff8d )

WebHook::sendMessage() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like