TelegramBot\Plugin

Complexity

Total Complexity

14

Size/Duplication

Total Lines	126
Duplicated Lines	0 %

Importance

Changes	3
Bugs	1	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__execute()	0	13	4
A	__identify()	0	9	2
A	getCrossData()	0	3	1
A	__checkExit()	0	11	5
A	kill()	0	3	1
A	putCrossData()	0	3	1

<?php

namespace TelegramBot;

use TelegramBot\Entities\Update;
use TelegramBot\Util\CrossData;

/**
 * Class Plugin
 *
 * @link    https://github.com/telegram-bot-php/core
 * @author  Shahrad Elahi (https://github.com/shahradelahi)
 * @license https://github.com/telegram-bot-php/core/blob/master/LICENSE (MIT License)
 */
class Plugin
{

	/**
	 * The Update types
	 *
	 * @var array
	 */
	protected array $update_types = [
		'Message',
		'EditedMessage',
		'ChannelPost',
		'EditedChannelPost',
		'InlineQuery',
		'ChosenInlineResult',
		'CallbackQuery',
		'ShippingQuery',
		'PreCheckoutQuery',
	];

	/**
	 * @var WebhookHandler
	 */
	protected WebhookHandler $hook;

	/**
	 * @var \Generator
	 */
	protected \Generator $returns;

	/**
	 * @var bool
	 */
	protected bool $kill_on_yield = false;

	/**
	 * Check for the exit of the plugin.
	 *
	 * @param \Generator $return
	 * @return void
	 */
	public function __checkExit(\Generator $return): void
	{
		if ($return->valid()) {
			if ($return->current() !== null && $this->kill_on_yield === true) {
				$this->kill();
			}
		}

		if ($return->valid()) {
			$return->next();
			$this->__checkExit($return);
		}
	}

	/**
	 * Identify the update type. e.g. Message, EditedMessage, etc.
	 *
	 * @param Update $update
	 * @return string|null
	 */
	public function __identify(Update $update): ?string
	{
		$type = $update->getUpdateType();

		if ($type === null) {
			return null;
		}

		return str_replace('_', '', ucwords($type, '_'));
	}

	/**
	 * Execute the plugin.
	 *
	 * @param WebhookHandler $receiver
	 * @param Update $update
	 * @return void
	 */
	public function __execute(WebhookHandler $receiver, Update $update): void
	{
		$this->hook = $receiver;

		if (method_exists($this, 'onReceivedUpdate')) {
			$return = $this->onReceivedUpdate($update);
			$this->__checkExit($return);
		}

		$type = $this->__identify($update);
		if (method_exists($this, ($method = 'on' . $type)) && $type !== null) {
			$return = $this->$method($update);
			$this->__checkExit($return);
		}
	}

	/**
	 * Kill the plugin.
	 *
	 * @return void
	 */
	public function kill(): void
	{
		$this->hook->kill();
	}

	/**
	 * put CrossData into the plugins
	 *
	 * @param string $key
	 * @param mixed $value
	 * @return void
	 */
	public function putCrossData(string $key, mixed $value): void
	{
		CrossData::put($key, $value);
	}

	/**
	 * get CrossData from the plugins
	 *
	 * @param string $key
	 * @return string|array|bool|null
	 */
	public function getCrossData(string $key): string|array|bool|null
	{
		return CrossData::get($key);
	}

}