Fabrica\Tools\Plugin\Telegram

Complexity

Total Complexity

16

Size/Duplication

Total Lines	131
Duplicated Lines	3.82 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	pluginName()	0	4	1
B	__construct()	5	31	7
A	execute()	0	40	3
A	buildMessage()	0	23	5

<?php

namespace Fabrica\Tools\Plugin;

use Fabrica\Tools\Builder;
use Fabrica\Models\Infra\Ci\Build;
use GuzzleHttp\Client;

/**
 * Telegram Plugin
 *
 * @author LEXASOFT <lexasoft83@gmail.com>
 */
class Telegram extends \PHPCensor\Plugin
{
    protected $apiKey;
    protected $message;
    protected $buildMsg;
    protected $recipients;
    protected $sendLog;

    /**
     * @return string
     */
    public static function pluginName()
    {
        return 'telegram';
    }

    /**
     * Standard Constructor
     *
     * @param  Builder $builder
     * @param  Build   $build
     * @param  array   $options
     * @throws \Exception
     */
    public function __construct(Builder $builder, Build $build, array $options = [])
    {
        parent::__construct($builder, $build, $options);

        if (empty($options['api_key'])) {
            throw new \Exception("Not setting telegram api_key");
        }

        if (empty($options['recipients'])) {
            throw new \Exception("Not setting recipients");
        }

        $this->apiKey  = $options['api_key'];
        $this->message = '[%ICON_BUILD%] [%PROJECT_TITLE%](%PROJECT_URI%)' .
            ' - [Build #%BUILD%](%BUILD_URI%) has finished ' .
            'for commit [%SHORT_COMMIT% (%COMMIT_EMAIL%)](%COMMIT_URI%) ' .
            'on branch [%BRANCH%](%BRANCH_URI%)';

        if (isset($options['message'])) {
            $this->message = $options['message'];
        }

        $this->recipients = [];
        if (is_string($options['recipients'])) {

This code seems to be duplicated across your project.

            $this->recipients = [$options['recipients']];
        } elseif (is_array($options['recipients'])) {
            $this->recipients = $options['recipients'];
        }

        $this->sendLog = isset($options['send_log']) && ((bool) $options['send_log'] !== false);
    }

    /**
     * Run Telegram plugin.
     *
     * @return bool
     */
    public function execute()
    {
        $message = $this->buildMessage();
        $client  = new Client();
        $url     = '/bot'. $this->apiKey . '/sendMessage';

        foreach ($this->recipients as $chatId) {
            $params = [
                'chat_id'    => $chatId,
                'text'       => $message,
                'parse_mode' => 'Markdown',
            ];
            $client->post(
                ('https://api.telegram.org' . $url), [
                'headers' => [
                    'Content-Type' => 'application/json',
                ],
                'json' => $params,
                ]
            );

            if ($this->sendLog) {
                $params = [
                    'chat_id'    => $chatId,
                    'text'       => $this->buildMsg,
                    'parse_mode' => 'Markdown',
                ];
                $client->post(
                    ('https://api.telegram.org' . $url), [
                    'headers' => [
                        'Content-Type' => 'application/json',
                    ],
                    'json' => $params,
                    ]
                );
            }
        }

        return true;
    }

    /**
     * Build message.
     *
     * @return string
     */
    private function buildMessage()
    {
        $this->buildMsg = '';
        $buildIcon      = $this->build->isSuccessful() ? '✅' : '❌';
        $buildLog       = $this->build->getLog();
        $buildLog       = str_replace(['[0;32m', '[0;31m', '[0m', '/[0m'], '', $buildLog);
        $buildMessages  = explode('RUNNING PLUGIN: ', $buildLog);

        foreach ($buildMessages as $bm) {
            $pos      = mb_strpos($bm, "\n");
            $firstRow = mb_substr($bm, 0, $pos);

            //skip long outputs
            if (in_array($firstRow, ['slack_notify', 'php_loc', 'telegram'])) {
                continue;
            }

            $this->buildMsg .= '*RUNNING PLUGIN: ' . $firstRow . "*\n";
            $this->buildMsg .= $firstRow == 'composer' ? '' : ('```' . mb_substr($bm, $pos) . '```');
        }

        return $this->builder->interpolate(str_replace(['%ICON_BUILD%'], [$buildIcon], $this->message));
    }
}