telegram-bot-php / core

src/lib/Entities/Response.php

Spacing +1 added lines, -1 removed lines

@@ -42,7 +42,7 @@
         $data['raw_data'] = $data;
         $this->response = $data;
 
-        $is_ok = (bool)($data['ok'] ?? false);
+        $is_ok = (bool) ($data['ok'] ?? false);
         $result = $data['result'] ?? null;
 
         if ($is_ok) {

src/lib/Util/DotEnv.php

Spacing +1 added lines, -1 removed lines

@@ -24,7 +24,7 @@
             return [];
         }
         $data = file_get_contents($path);
-        return array_map(function ($item) {
+        return array_map(function($item) {
             return explode('=', $item);
         }, explode("\n", $data));
     }

Braces +8 added lines, -3 removed lines

@@ -37,8 +37,11 @@ 
      */
     public static function load(string $path = null): self
     {
-        if (empty($path)) $data = self::read(getcwd() . '/.env');
-        else $data = self::read($path);
+        if (empty($path)) {
+            $data = self::read(getcwd() . '/.env');
+        } else {
+            $data = self::read($path);
+        }
         foreach ($data as $item) {
             [$key, $value] = $item;
             if (count($item) == 2) {
@@ -73,7 +76,9 @@ 
     public static function put(string $key, string $value, bool $save = false): void
     {
         putenv($key . '=' . $value);
-        if ($save) self::saveTo($_SERVER['DOCUMENT_ROOT'] . '/.env', [$key => $value]);
+        if ($save) {
+            self::saveTo($_SERVER['DOCUMENT_ROOT'] . '/.env', [$key => $value]);
+        }
     }
 
     /**

src/lib/Entities/MenuButton/Factory.php

Spacing +1 added lines, -1 removed lines

@@ -14,7 +14,7 @@
             'default'  => MenuButtonDefault::class,
         ];
 
-        if (! isset($type[$data['type'] ?? ''])) {
+        if (!isset($type[$data['type'] ?? ''])) {
             return new MenuButtonNotImplemented($data);
         }
 

src/lib/Entities/InlineKeyboard.php

Indentation +9 added lines, -9 removed lines

@@ -10,14 +10,14 @@
 class InlineKeyboard extends Keyboard
 {
 
-	/**
-	 * Creates instance of Keyboard
-	 *
-	 * @return InlineKeyboard
-	 */
-	public static function make(): InlineKeyboard
-	{
-		return new self();
-	}
+    /**
+     * Creates instance of Keyboard
+     *
+     * @return InlineKeyboard
+     */
+    public static function make(): InlineKeyboard
+    {
+        return new self();
+    }
 
 }

src/lib/Entities/KeyboardButton.php

Indentation +69 added lines, -69 removed lines

@@ -34,83 +34,83 @@
 class KeyboardButton extends Entity
 {
 
-	/**
-	 * @param array|string $data
-	 */
-	public function __construct($data)
-	{
-		if (is_string($data)) {
-			$data = ['text' => $data];
-		}
+    /**
+     * @param array|string $data
+     */
+    public function __construct($data)
+    {
+        if (is_string($data)) {
+            $data = ['text' => $data];
+        }
 
-		parent::__construct($data);
-	}
+        parent::__construct($data);
+    }
 
-	/**
-	 * Creates instance of KeyboardButton
-	 *
-	 * @param string $string
-	 * @return KeyboardButton
-	 */
-	public static function make(string $string): KeyboardButton
-	{
-		return new self($string);
-	}
+    /**
+     * Creates instance of KeyboardButton
+     *
+     * @param string $string
+     * @return KeyboardButton
+     */
+    public static function make(string $string): KeyboardButton
+    {
+        return new self($string);
+    }
 
-	/**
-	 * @param string $url
-	 * @return $this
-	 */
-	public function WebApp(string $url): KeyboardButton
-	{
-		$this->raw_data['web_app'] = new WebAppInfo(['url' => $url]);
+    /**
+     * @param string $url
+     * @return $this
+     */
+    public function WebApp(string $url): KeyboardButton
+    {
+        $this->raw_data['web_app'] = new WebAppInfo(['url' => $url]);
 
-		return $this;
-	}
+        return $this;
+    }
 
-	/**
-	 * @inheritDoc
-	 */
-	protected function subEntities(): array
-	{
-		return [
-			'request_poll' => KeyboardButtonPollType::class,
-			'web_app' => WebAppInfo::class,
-		];
-	}
+    /**
+     * @inheritDoc
+     */
+    protected function subEntities(): array
+    {
+        return [
+            'request_poll' => KeyboardButtonPollType::class,
+            'web_app' => WebAppInfo::class,
+        ];
+    }
 
-	/**
-	 * Check if the passed data array could be a KeyboardButton.
-	 *
-	 * @param array $data
-	 *
-	 * @return bool
-	 */
-	public static function couldBe(array $data): bool
-	{
-		return array_key_exists('text', $data);
-	}
+    /**
+     * Check if the passed data array could be a KeyboardButton.
+     *
+     * @param array $data
+     *
+     * @return bool
+     */
+    public static function couldBe(array $data): bool
+    {
+        return array_key_exists('text', $data);
+    }
 
-	/**
-	 * {@inheritdoc}
-	 */
-	protected function validate(): void
-	{
-		if ($this->getProperty('text', '') === '') {
-			throw new TelegramException('You must add some text to the button!');
-		}
-	}
+    /**
+     * {@inheritdoc}
+     */
+    protected function validate(): void
+    {
+        if ($this->getProperty('text', '') === '') {
+            throw new TelegramException('You must add some text to the button!');
+        }
+    }
 
-	/**
-	 * {@inheritdoc}
-	 */
-	public function __call(string $name, array $arguments): mixed
-	{
-		if (in_array($name, ['setRequestContact', 'setRequestLocation', 'setRequestPoll', 'setWebApp'], true)) {
-			unset($this->request_contact, $this->request_location, $this->request_poll, $this->web_app);
-		}
+    /**
+     * {@inheritdoc}
+     */
+    public function __call(string $name, array $arguments): mixed
+    {
+        if (in_array($name, ['setRequestContact', 'setRequestLocation', 'setRequestPoll', 'setWebApp'], true)) {
+            unset($this->request_contact, $this->request_location, $this->request_poll, $this->web_app);
+        }
 
-		return parent::__call($name, $arguments);
-	}
+        return parent::__call($name, $arguments);
+    }
 
 }

src/lib/Entities/WebAppInfo.php

Indentation +7 added lines, -7 removed lines

@@ -19,13 +19,13 @@
 class WebAppInfo extends Entity
 {
 
-	public function __construct($data)
-	{
-		if (is_string($data)) {
-			$data = ['url' => $data];
-		}
+    public function __construct($data)
+    {
+        if (is_string($data)) {
+            $data = ['url' => $data];
+        }
 
-		parent::__construct($data);
-	}
+        parent::__construct($data);
+    }
 
 }
\ No newline at end of file

src/lib/Entity.php

Spacing +2 added lines, -2 removed lines

@@ -141,8 +141,8 @@
 	public static function escapeMarkdown(string $string): string
 	{
 		return str_replace(
-			['[', '`', '*', '_',],
-			['\[', '\`', '\*', '\_',],
+			['[', '`', '*', '_', ],
+			['\[', '\`', '\*', '\_', ],
 			$string
 		);
 	}

Indentation +150 added lines, -150 removed lines

@@ -12,155 +12,155 @@
 abstract class Entity
 {
 
-	/**
-	 * @var array The raw data passed to this entity
-	 */
-	protected array $raw_data = [];
-
-	/**
-	 * Entity constructor.
-	 *
-	 * @param ?array $data The raw data passed to this entity
-	 */
-	public function __construct(?array $data)
-	{
-		if (!empty($data)) {
-			$this->assignMemberVariables(($this->raw_data = $data));
-			$this->validate();
-		}
-	}
-
-	/**
-	 * Get the raw data passed to this entity
-	 *
-	 * @param bool $associated
-	 * @return array|string
-	 */
-	public function getRawData(bool $associated = true): array|string
-	{
-		return $associated ? $this->raw_data : json_encode($this->raw_data);
-	}
-
-	/**
-	 * Helper to set member variables
-	 *
-	 * @param array $data
-	 * @return void
-	 */
-	protected function assignMemberVariables(array $data): void
-	{
-		foreach ($data as $key => $value) {
-			$this->$key = $value;
-		}
-	}
-
-	/**
-	 * Get a property from the current Entity
-	 *
-	 * @param string $property
-	 * @param mixed $default
-	 *
-	 * @return mixed
-	 */
-	public function getProperty(string $property, mixed $default = null): mixed
-	{
-		return $this->raw_data[$property] ?? $default;
-	}
-
-	/**
-	 * Get the list of the properties that are themselves Entities
-	 *
-	 * @return array
-	 */
-	protected function subEntities(): array
-	{
-		return [];
-	}
-
-	/**
-	 * Perform any special entity validation
-	 *
-	 * @return void
-	 */
-	protected function validate(): void
-	{
-		// Do nothing by default
-	}
-
-	/**
-	 * @param string $name The name of the property
-	 * @param array $arguments The arguments passed to the method
-	 * @return mixed
-	 */
-	public function __call(string $name, array $arguments): mixed
-	{
-		if (method_exists($this, $name)) {
-			return $this->{$name}(...$arguments);
-		}
-
-		if (str_starts_with($name, 'get')) {
-			$property_name = strtolower(ltrim(preg_replace('/[A-Z]/', '_$0', substr($name, 3)), '_'));
-
-			$property = $this->getProperty($property_name);
-			$sub_entities = $this->subEntities() ?? [];
-
-			if (isset($sub_entities[$property_name])) {
-				$class_name = $sub_entities[$property_name];
-				return Factory::resolveEntityClass($class_name, $property);
-			}
-
-			return $property ?? null;
-		}
-
-		if (str_starts_with($name, 'set')) {
-			$property_name = strtolower(ltrim(preg_replace('/[A-Z]/', '_$0', substr($name, 3)), '_'));
-
-			if (property_exists($this, $property_name)) {
-				$this->{$property_name} = $arguments[0];
-				$this->raw_data[$property_name] = $arguments[0];
-
-				return $this;
-			}
-
-		}
-
-		throw new \BadMethodCallException("Method '$name' does not exist");
-	}
-
-	/**
-	 * Escape markdown (v1) special characters
-	 *
-	 * @see https://core.telegram.org/bots/api#markdown-style
-	 *
-	 * @param string $string
-	 *
-	 * @return string
-	 */
-	public static function escapeMarkdown(string $string): string
-	{
-		return str_replace(
-			['[', '`', '*', '_',],
-			['\[', '\`', '\*', '\_',],
-			$string
-		);
-	}
-
-	/**
-	 * Escape markdown (v2) special characters
-	 *
-	 * @see https://core.telegram.org/bots/api#markdownv2-style
-	 *
-	 * @param string $string
-	 *
-	 * @return string
-	 */
-	public static function escapeMarkdownV2(string $string): string
-	{
-		return str_replace(
-			['_', '*', '[', ']', '(', ')', '~', '`', '>', '#', '+', '-', '=', '|', '{', '}', '.', '!'],
-			['\_', '\*', '\[', '\]', '\(', '\)', '\~', '\`', '\>', '\#', '\+', '\-', '\=', '\|', '\{', '\}', '\.', '\!'],
-			$string
-		);
-	}
+    /**
+     * @var array The raw data passed to this entity
+     */
+    protected array $raw_data = [];
+
+    /**
+     * Entity constructor.
+     *
+     * @param ?array $data The raw data passed to this entity
+     */
+    public function __construct(?array $data)
+    {
+        if (!empty($data)) {
+            $this->assignMemberVariables(($this->raw_data = $data));
+            $this->validate();
+        }
+    }
+
+    /**
+     * Get the raw data passed to this entity
+     *
+     * @param bool $associated
+     * @return array|string
+     */
+    public function getRawData(bool $associated = true): array|string
+    {
+        return $associated ? $this->raw_data : json_encode($this->raw_data);
+    }
+
+    /**
+     * Helper to set member variables
+     *
+     * @param array $data
+     * @return void
+     */
+    protected function assignMemberVariables(array $data): void
+    {
+        foreach ($data as $key => $value) {
+            $this->$key = $value;
+        }
+    }
+
+    /**
+     * Get a property from the current Entity
+     *
+     * @param string $property
+     * @param mixed $default
+     *
+     * @return mixed
+     */
+    public function getProperty(string $property, mixed $default = null): mixed
+    {
+        return $this->raw_data[$property] ?? $default;
+    }
+
+    /**
+     * Get the list of the properties that are themselves Entities
+     *
+     * @return array
+     */
+    protected function subEntities(): array
+    {
+        return [];
+    }
+
+    /**
+     * Perform any special entity validation
+     *
+     * @return void
+     */
+    protected function validate(): void
+    {
+        // Do nothing by default
+    }
+
+    /**
+     * @param string $name The name of the property
+     * @param array $arguments The arguments passed to the method
+     * @return mixed
+     */
+    public function __call(string $name, array $arguments): mixed
+    {
+        if (method_exists($this, $name)) {
+            return $this->{$name}(...$arguments);
+        }
+
+        if (str_starts_with($name, 'get')) {
+            $property_name = strtolower(ltrim(preg_replace('/[A-Z]/', '_$0', substr($name, 3)), '_'));
+
+            $property = $this->getProperty($property_name);
+            $sub_entities = $this->subEntities() ?? [];
+
+            if (isset($sub_entities[$property_name])) {
+                $class_name = $sub_entities[$property_name];
+                return Factory::resolveEntityClass($class_name, $property);
+            }
+
+            return $property ?? null;
+        }
+
+        if (str_starts_with($name, 'set')) {
+            $property_name = strtolower(ltrim(preg_replace('/[A-Z]/', '_$0', substr($name, 3)), '_'));
+
+            if (property_exists($this, $property_name)) {
+                $this->{$property_name} = $arguments[0];
+                $this->raw_data[$property_name] = $arguments[0];
+
+                return $this;
+            }
+
+        }
+
+        throw new \BadMethodCallException("Method '$name' does not exist");
+    }
+
+    /**
+     * Escape markdown (v1) special characters
+     *
+     * @see https://core.telegram.org/bots/api#markdown-style
+     *
+     * @param string $string
+     *
+     * @return string
+     */
+    public static function escapeMarkdown(string $string): string
+    {
+        return str_replace(
+            ['[', '`', '*', '_',],
+            ['\[', '\`', '\*', '\_',],
+            $string
+        );
+    }
+
+    /**
+     * Escape markdown (v2) special characters
+     *
+     * @see https://core.telegram.org/bots/api#markdownv2-style
+     *
+     * @param string $string
+     *
+     * @return string
+     */
+    public static function escapeMarkdownV2(string $string): string
+    {
+        return str_replace(
+            ['_', '*', '[', ']', '(', ')', '~', '`', '>', '#', '+', '-', '=', '|', '{', '}', '.', '!'],
+            ['\_', '\*', '\[', '\]', '\(', '\)', '\~', '\`', '\>', '\#', '\+', '\-', '\=', '\|', '\{', '\}', '\.', '\!'],
+            $string
+        );
+    }
 
 }
\ No newline at end of file

src/lib/Telegram.php

Braces +9 added lines, -3 removed lines

@@ -258,7 +258,9 @@ 
 	public static function getUpdate(): Update|false
 	{
 		$input = self::getInput();
-		if (empty($input)) return false;
+		if (empty($input)) {
+		    return false;
+		}
 		return Telegram::processUpdate($input, self::getApiKey());
 	}
 
@@ -284,7 +286,9 @@ 
 	public function fetchWith(WebhookHandler $webhook_handler, ?Update $update = null): void
 	{
 		if (is_subclass_of($webhook_handler, WebhookHandler::class)) {
-			if ($update === null) $update = self::getUpdate();
+			if ($update === null) {
+			    $update = self::getUpdate();
+			}
 			$webhook_handler->resolve($update);
 		}
 	}
@@ -297,7 +301,9 @@ 
 	 */
 	protected function getTokenFromEnvFile(string $file): ?string
 	{
-		if (!file_exists($file)) return null;
+		if (!file_exists($file)) {
+		    return null;
+		}
 		return DotEnv::load($file)::get('TELEGRAM_API_KEY');
 	}
 

Spacing +1 added lines, -1 removed lines

@@ -326,7 +326,7 @@
 			defined('TG_ADMIN_ID') or define('TG_ADMIN_ID', $admin_id);
 		}
 
-		set_exception_handler(function ($exception) {
+		set_exception_handler(function($exception) {
 
 			if (defined('DEBUG_MODE') && DEBUG_MODE) {
 

Indentation +361 added lines, -361 removed lines

@@ -18,366 +18,366 @@
 class Telegram
 {
 
-	/**
-	 * @var string
-	 */
-	private string $api_key;
-
-	/**
-	 * @var string
-	 */
-	public static string $VERSION = 'v1.0.0';
-
-	/**
-	 * Telegram constructor.
-	 *
-	 * @param string $api_key
-	 */
-	public function __construct(string $api_key = '')
-	{
-		if ($api_key === '') {
-			$env_file = $this->getEnvFilePath();
-			$api_key = DotEnv::load($env_file)->get('TELEGRAM_API_KEY');
-		}
-
-		if (empty($api_key) || !is_string($api_key)) {
-			throw new TelegramException('API Key is required');
-		}
-
-		DotEnv::put('TG_CURRENT_KEY', ($this->api_key = $api_key));
-		DotEnv::put('TELEGRAM_API_KEY', ($this->api_key = $api_key));
-	}
-
-	/**
-	 * Get env file path and return it
-	 *
-	 * @return string
-	 */
-	private function getEnvFilePath(): string
-	{
-		$defaultEnvPaths = [
-			$_SERVER['DOCUMENT_ROOT'] . '/.env',
-			getcwd() . '/../.env',
-			getcwd() . '/.env',
-		];
-
-		foreach ($defaultEnvPaths as $path) {
-			if (file_exists($path)) {
-				return $path;
-			}
-		}
-
-		return '';
-	}
-
-	/**
-	 * Get API key from temporary ENV variable
-	 *
-	 * @return ?string
-	 */
-	public static function getApiKey(): ?string
-	{
-		return DotEnv::get('TG_CURRENT_KEY');
-	}
-
-	/**
-	 * Get bot info from given API key
-	 *
-	 * @return Response
-	 * @throws TelegramException
-	 */
-	public function getInfo(): Response
-	{
-		$result = Request::getMe();
-
-		if (!$result->isOk()) {
-			throw new TelegramException($result->getErrorCode() . ': ' . $result->getDescription());
-		}
-
-		return $result;
-	}
-
-	/**
-	 * Set Webhook for bot
-	 *
-	 * @param string $url
-	 * @param array $data Optional parameters.
-	 * @return Response
-	 * @throws TelegramException
-	 */
-	public function setWebhook(string $url, array $data = []): Response
-	{
-		if ($url === '') {
-			throw new TelegramException('Hook url is empty!');
-		}
-
-		if (!str_starts_with($url, 'https://')) {
-			throw new TelegramException('Hook url must start with https://');
-		}
-
-		$data = array_intersect_key($data, array_flip([
-			'certificate',
-			'ip_address',
-			'max_connections',
-			'allowed_updates',
-			'drop_pending_updates',
-		]));
-		$data['url'] = $url;
-
-		$result = Request::setWebhook($data);
-
-		if (!$result->isOk()) {
-			throw new TelegramException(
-				'Webhook was not set! Error: ' . $result->getErrorCode() . ' ' . $result->getDescription()
-			);
-		}
-
-		return $result;
-	}
-
-	/**
-	 * Delete any assigned webhook
-	 *
-	 * @param array $data
-	 * @return Response
-	 * @throws TelegramException
-	 */
-	public function deleteWebhook(array $data = []): Response
-	{
-		$result = Request::deleteWebhook($data);
-
-		if (!$result->isOk()) {
-			throw new TelegramException(
-				'Webhook was not deleted! Error: ' . $result->getErrorCode() . ' ' . $result->getDescription()
-			);
-		}
-
-		return $result;
-	}
-
-	/**
-	 * This method sets the admin username. and will be used to send you a message if the bot is not working.
-	 *
-	 * @param int $chat_id
-	 * @return void
-	 */
-	public function setAdmin(int $chat_id): void
-	{
-		defined('TG_ADMIN_ID') or define('TG_ADMIN_ID', $chat_id);
-	}
-
-	/**
-	 * Get input from stdin and return it
-	 *
-	 * @return ?string
-	 */
-	public static function getInput(): ?string
-	{
-		return file_get_contents('php://input') ?? null;
-	}
-
-	/**
-	 * This method will convert a string to an update object
-	 *
-	 * @param string $input The input string
-	 * @param string $apiKey The API key
-	 * @return Update|false
-	 */
-	public static function processUpdate(string $input, string $apiKey): Update|false
-	{
-		if (empty($input)) {
-			throw new TelegramException(
-				'Input is empty! Please check your code and try again.'
-			);
-		}
-
-		if (!self::validateToken($apiKey)) {
-			throw new TelegramException(
-				'Invalid token! Please check your code and try again.'
-			);
-		}
-
-		if (self::validateWebData($apiKey, $input)) {
-			if (Common::isUrlEncode($input)) {
-				$web_data = Common::urlDecode($input);
-			}
-
-			if (Common::isJson($input)) {
-				$web_data = json_decode($input, true);
-			}
-
-			$input = json_encode([
-				'web_data' => $web_data,
-			]);
-		}
-
-		if (!Common::isJson($input)) {
-			throw new TelegramException(
-				'Input is not a valid JSON string! Please check your code and try again.'
-			);
-		}
-
-		$input = json_decode($input, true);
-
-		return new Update($input);
-	}
-
-	/**
-	 * Validate webapp data from is from Telegram
-	 *
-	 * @link https://core.telegram.org/bots/webapps#validating-data-received-via-the-web-app
-	 *
-	 * @param string $token The bot token
-	 * @param string $body The message body from getInput()
-	 * @return bool
-	 */
-	public static function validateWebData(string $token, string $body): bool
-	{
-		if (!Common::isJson($body)) {
-			$raw_data = rawurldecode(str_replace('_auth=', '', $body));
-			$data = Common::urlDecode($raw_data);
-
-			if (empty($data['user'])) {
-				return false;
-			}
-
-			$data['user'] = urldecode($data['user']);
-
-		} else {
-			$data = json_decode($body, true);
-
-			if (empty($data['user'])) {
-				return false;
-			}
-
-			$data['user'] = json_encode($data['user']);
-		}
-
-		$data_check_string = "auth_date={$data['auth_date']}\nquery_id={$data['query_id']}\nuser={$data['user']}";
-		$secret_key = hash_hmac('sha256', $token, "WebAppData", true);
-
-		return hash_hmac('sha256', $data_check_string, $secret_key) == $data['hash'];
-	}
-
-	/**
-	 * Get the update from input
-	 *
-	 * @return Update|false
-	 */
-	public static function getUpdate(): Update|false
-	{
-		$input = self::getInput();
-		if (empty($input)) return false;
-		return Telegram::processUpdate($input, self::getApiKey());
-	}
-
-	/**
-	 * Validate the token
-	 *
-	 * @param string $token (e.g. 123456789:ABC-DEF1234ghIkl-zyx57W2v1u123ew11) {digit}:{alphanumeric[34]}
-	 * @return bool
-	 */
-	public static function validateToken(string $token): bool
-	{
-		preg_match_all('/([0-9]+:[a-zA-Z0-9-_]+)/', $token, $matches);
-		return count($matches[0]) == 1;
-	}
-
-	/**
-	 * Pass the update to the given webhook handler
-	 *
-	 * @param WebhookHandler $webhook_handler The webhook handler
-	 * @param ?Update $update By default, it will get the update from input
-	 * @return void
-	 */
-	public function fetchWith(WebhookHandler $webhook_handler, ?Update $update = null): void
-	{
-		if (is_subclass_of($webhook_handler, WebhookHandler::class)) {
-			if ($update === null) $update = self::getUpdate();
-			$webhook_handler->resolve($update);
-		}
-	}
-
-	/**
-	 * Get token from env file.
-	 *
-	 * @param string $file
-	 * @return ?string
-	 */
-	protected function getTokenFromEnvFile(string $file): ?string
-	{
-		if (!file_exists($file)) return null;
-		return DotEnv::load($file)::get('TELEGRAM_API_KEY');
-	}
-
-	/**
-	 * Debug mode
-	 *
-	 * @param ?int $admin_id Fill this or use setAdmin()
-	 * @return void
-	 */
-	public static function setDebugMode(?int $admin_id = null): void
-	{
-		error_reporting(E_ALL);
-		ini_set('display_errors', 1);
-
-		defined('DEBUG_MODE') or define('DEBUG_MODE', true);
-		if ($admin_id) {
-			defined('TG_ADMIN_ID') or define('TG_ADMIN_ID', $admin_id);
-		}
-
-		set_exception_handler(function ($exception) {
-
-			if (defined('DEBUG_MODE') && DEBUG_MODE) {
-
-				TelegramLog::error(($message = sprintf(
-					"%s(%d): %s\n%s",
-					$exception->getFile(),
-					$exception->getLine(),
-					$exception->getMessage(),
-					$exception->getTraceAsString()
-				)));
-
-				echo '<b>TelegramError:</b> ' . $message;
-
-				if (defined('TG_ADMIN_ID') && TG_ADMIN_ID) {
-					$input = getenv('TG_CURRENT_UPDATE') ?? self::getInput();
-					$update = self::processUpdate($input, self::getApiKey());
-
-					file_put_contents(
-						($file = getcwd() . '/' . uniqid('error_') . '.log'),
-						$message . PHP_EOL . PHP_EOL . $update->getRawData(false)
-					);
-
-					Request::sendMessage([
-						'chat_id' => TG_ADMIN_ID,
-						'text' => $message,
-					]);
-
-					Request::sendDocument([
-						'chat_id' => TG_ADMIN_ID,
-						'document' => $file,
-					]);
-
-					unlink($file);
-				}
-
-			} else {
-				throw $exception;
-			}
-
-		});
-	}
-
-	/**
-	 * Just another echo
-	 *
-	 * @param string $text
-	 * @return void
-	 */
-	public static function echo(string $text): void
-	{
-		echo $text;
-	}
+    /**
+     * @var string
+     */
+    private string $api_key;
+
+    /**
+     * @var string
+     */
+    public static string $VERSION = 'v1.0.0';
+
+    /**
+     * Telegram constructor.
+     *
+     * @param string $api_key
+     */
+    public function __construct(string $api_key = '')
+    {
+        if ($api_key === '') {
+            $env_file = $this->getEnvFilePath();
+            $api_key = DotEnv::load($env_file)->get('TELEGRAM_API_KEY');
+        }
+
+        if (empty($api_key) || !is_string($api_key)) {
+            throw new TelegramException('API Key is required');
+        }
+
+        DotEnv::put('TG_CURRENT_KEY', ($this->api_key = $api_key));
+        DotEnv::put('TELEGRAM_API_KEY', ($this->api_key = $api_key));
+    }
+
+    /**
+     * Get env file path and return it
+     *
+     * @return string
+     */
+    private function getEnvFilePath(): string
+    {
+        $defaultEnvPaths = [
+            $_SERVER['DOCUMENT_ROOT'] . '/.env',
+            getcwd() . '/../.env',
+            getcwd() . '/.env',
+        ];
+
+        foreach ($defaultEnvPaths as $path) {
+            if (file_exists($path)) {
+                return $path;
+            }
+        }
+
+        return '';
+    }
+
+    /**
+     * Get API key from temporary ENV variable
+     *
+     * @return ?string
+     */
+    public static function getApiKey(): ?string
+    {
+        return DotEnv::get('TG_CURRENT_KEY');
+    }
+
+    /**
+     * Get bot info from given API key
+     *
+     * @return Response
+     * @throws TelegramException
+     */
+    public function getInfo(): Response
+    {
+        $result = Request::getMe();
+
+        if (!$result->isOk()) {
+            throw new TelegramException($result->getErrorCode() . ': ' . $result->getDescription());
+        }
+
+        return $result;
+    }
+
+    /**
+     * Set Webhook for bot
+     *
+     * @param string $url
+     * @param array $data Optional parameters.
+     * @return Response
+     * @throws TelegramException
+     */
+    public function setWebhook(string $url, array $data = []): Response
+    {
+        if ($url === '') {
+            throw new TelegramException('Hook url is empty!');
+        }
+
+        if (!str_starts_with($url, 'https://')) {
+            throw new TelegramException('Hook url must start with https://');
+        }
+
+        $data = array_intersect_key($data, array_flip([
+            'certificate',
+            'ip_address',
+            'max_connections',
+            'allowed_updates',
+            'drop_pending_updates',
+        ]));
+        $data['url'] = $url;
+
+        $result = Request::setWebhook($data);
+
+        if (!$result->isOk()) {
+            throw new TelegramException(
+                'Webhook was not set! Error: ' . $result->getErrorCode() . ' ' . $result->getDescription()
+            );
+        }
+
+        return $result;
+    }
+
+    /**
+     * Delete any assigned webhook
+     *
+     * @param array $data
+     * @return Response
+     * @throws TelegramException
+     */
+    public function deleteWebhook(array $data = []): Response
+    {
+        $result = Request::deleteWebhook($data);
+
+        if (!$result->isOk()) {
+            throw new TelegramException(
+                'Webhook was not deleted! Error: ' . $result->getErrorCode() . ' ' . $result->getDescription()
+            );
+        }
+
+        return $result;
+    }
+
+    /**
+     * This method sets the admin username. and will be used to send you a message if the bot is not working.
+     *
+     * @param int $chat_id
+     * @return void
+     */
+    public function setAdmin(int $chat_id): void
+    {
+        defined('TG_ADMIN_ID') or define('TG_ADMIN_ID', $chat_id);
+    }
+
+    /**
+     * Get input from stdin and return it
+     *
+     * @return ?string
+     */
+    public static function getInput(): ?string
+    {
+        return file_get_contents('php://input') ?? null;
+    }
+
+    /**
+     * This method will convert a string to an update object
+     *
+     * @param string $input The input string
+     * @param string $apiKey The API key
+     * @return Update|false
+     */
+    public static function processUpdate(string $input, string $apiKey): Update|false
+    {
+        if (empty($input)) {
+            throw new TelegramException(
+                'Input is empty! Please check your code and try again.'
+            );
+        }
+
+        if (!self::validateToken($apiKey)) {
+            throw new TelegramException(
+                'Invalid token! Please check your code and try again.'
+            );
+        }
+
+        if (self::validateWebData($apiKey, $input)) {
+            if (Common::isUrlEncode($input)) {
+                $web_data = Common::urlDecode($input);
+            }
+
+            if (Common::isJson($input)) {
+                $web_data = json_decode($input, true);
+            }
+
+            $input = json_encode([
+                'web_data' => $web_data,
+            ]);
+        }
+
+        if (!Common::isJson($input)) {
+            throw new TelegramException(
+                'Input is not a valid JSON string! Please check your code and try again.'
+            );
+        }
+
+        $input = json_decode($input, true);
+
+        return new Update($input);
+    }
+
+    /**
+     * Validate webapp data from is from Telegram
+     *
+     * @link https://core.telegram.org/bots/webapps#validating-data-received-via-the-web-app
+     *
+     * @param string $token The bot token
+     * @param string $body The message body from getInput()
+     * @return bool
+     */
+    public static function validateWebData(string $token, string $body): bool
+    {
+        if (!Common::isJson($body)) {
+            $raw_data = rawurldecode(str_replace('_auth=', '', $body));
+            $data = Common::urlDecode($raw_data);
+
+            if (empty($data['user'])) {
+                return false;
+            }
+
+            $data['user'] = urldecode($data['user']);
+
+        } else {
+            $data = json_decode($body, true);
+
+            if (empty($data['user'])) {
+                return false;
+            }
+
+            $data['user'] = json_encode($data['user']);
+        }
+
+        $data_check_string = "auth_date={$data['auth_date']}\nquery_id={$data['query_id']}\nuser={$data['user']}";
+        $secret_key = hash_hmac('sha256', $token, "WebAppData", true);
+
+        return hash_hmac('sha256', $data_check_string, $secret_key) == $data['hash'];
+    }
+
+    /**
+     * Get the update from input
+     *
+     * @return Update|false
+     */
+    public static function getUpdate(): Update|false
+    {
+        $input = self::getInput();
+        if (empty($input)) return false;
+        return Telegram::processUpdate($input, self::getApiKey());
+    }
+
+    /**
+     * Validate the token
+     *
+     * @param string $token (e.g. 123456789:ABC-DEF1234ghIkl-zyx57W2v1u123ew11) {digit}:{alphanumeric[34]}
+     * @return bool
+     */
+    public static function validateToken(string $token): bool
+    {
+        preg_match_all('/([0-9]+:[a-zA-Z0-9-_]+)/', $token, $matches);
+        return count($matches[0]) == 1;
+    }
+
+    /**
+     * Pass the update to the given webhook handler
+     *
+     * @param WebhookHandler $webhook_handler The webhook handler
+     * @param ?Update $update By default, it will get the update from input
+     * @return void
+     */
+    public function fetchWith(WebhookHandler $webhook_handler, ?Update $update = null): void
+    {
+        if (is_subclass_of($webhook_handler, WebhookHandler::class)) {
+            if ($update === null) $update = self::getUpdate();
+            $webhook_handler->resolve($update);
+        }
+    }
+
+    /**
+     * Get token from env file.
+     *
+     * @param string $file
+     * @return ?string
+     */
+    protected function getTokenFromEnvFile(string $file): ?string
+    {
+        if (!file_exists($file)) return null;
+        return DotEnv::load($file)::get('TELEGRAM_API_KEY');
+    }
+
+    /**
+     * Debug mode
+     *
+     * @param ?int $admin_id Fill this or use setAdmin()
+     * @return void
+     */
+    public static function setDebugMode(?int $admin_id = null): void
+    {
+        error_reporting(E_ALL);
+        ini_set('display_errors', 1);
+
+        defined('DEBUG_MODE') or define('DEBUG_MODE', true);
+        if ($admin_id) {
+            defined('TG_ADMIN_ID') or define('TG_ADMIN_ID', $admin_id);
+        }
+
+        set_exception_handler(function ($exception) {
+
+            if (defined('DEBUG_MODE') && DEBUG_MODE) {
+
+                TelegramLog::error(($message = sprintf(
+                    "%s(%d): %s\n%s",
+                    $exception->getFile(),
+                    $exception->getLine(),
+                    $exception->getMessage(),
+                    $exception->getTraceAsString()
+                )));
+
+                echo '<b>TelegramError:</b> ' . $message;
+
+                if (defined('TG_ADMIN_ID') && TG_ADMIN_ID) {
+                    $input = getenv('TG_CURRENT_UPDATE') ?? self::getInput();
+                    $update = self::processUpdate($input, self::getApiKey());
+
+                    file_put_contents(
+                        ($file = getcwd() . '/' . uniqid('error_') . '.log'),
+                        $message . PHP_EOL . PHP_EOL . $update->getRawData(false)
+                    );
+
+                    Request::sendMessage([
+                        'chat_id' => TG_ADMIN_ID,
+                        'text' => $message,
+                    ]);
+
+                    Request::sendDocument([
+                        'chat_id' => TG_ADMIN_ID,
+                        'document' => $file,
+                    ]);
+
+                    unlink($file);
+                }
+
+            } else {
+                throw $exception;
+            }
+
+        });
+    }
+
+    /**
+     * Just another echo
+     *
+     * @param string $text
+     * @return void
+     */
+    public static function echo(string $text): void
+    {
+        echo $text;
+    }
 
 }
\ No newline at end of file

src/lib/TelegramLog.php

Indentation +137 added lines, -137 removed lines

@@ -25,142 +25,142 @@
 class TelegramLog
 {
 
-	/**
-	 * Logger instance
-	 *
-	 * @var LoggerInterface
-	 */
-	protected static LoggerInterface $logger;
-
-	/**
-	 * Logger instance for update
-	 *
-	 * @var LoggerInterface
-	 */
-	protected static LoggerInterface $update_logger;
-
-	/**
-	 * Always log the request and response data to the debug log, also for successful requests
-	 *
-	 * @var bool
-	 */
-	public static bool $always_log_request_and_response = false;
-
-	/**
-	 * Temporary stream handle for debug log
-	 *
-	 * @var resource|null
-	 */
-	protected static $debug_log_temp_stream_handle;
-
-	/**
-	 * Remove bot token from debug stream
-	 *
-	 * @var bool
-	 */
-	public static bool $remove_bot_token = true;
-
-	/**
-	 * Initialise logging.
-	 *
-	 * @param LoggerInterface|null $logger
-	 * @param LoggerInterface|null $update_logger
-	 */
-	public static function initialize(LoggerInterface $logger = null, LoggerInterface $update_logger = null): void
-	{
-		self::$logger = $logger ?: new NullLogger();
-		self::$update_logger = $update_logger ?: new NullLogger();
-	}
-
-	/**
-	 * Get the stream handle of the temporary debug output
-	 *
-	 * @return mixed The stream if debug is active, else false
-	 */
-	public static function getDebugLogTempStream(): mixed
-	{
-		if ((self::$debug_log_temp_stream_handle === null) && $temp_stream_handle = fopen('php://temp', 'wb+')) {
-			self::$debug_log_temp_stream_handle = $temp_stream_handle;
-		}
-
-		return self::$debug_log_temp_stream_handle;
-	}
-
-	/**
-	 * Write the temporary debug stream to log and close the stream handle
-	 *
-	 * @param string $message Message (with placeholder) to write to the debug log
-	 */
-	public static function endDebugLogTempStream(string $message = '%s'): void
-	{
-		if (is_resource(self::$debug_log_temp_stream_handle)) {
-			rewind(self::$debug_log_temp_stream_handle);
-			$stream_contents = stream_get_contents(self::$debug_log_temp_stream_handle);
-
-			if (self::$remove_bot_token) {
-				$stream_contents = preg_replace('/\/bot(\d+):[\w\-]+\//', '/botBOT_TOKEN_REMOVED/', $stream_contents);
-			}
-
-			self::debug(sprintf($message, $stream_contents));
-			fclose(self::$debug_log_temp_stream_handle);
-			self::$debug_log_temp_stream_handle = null;
-		}
-	}
-
-	/**
-	 * Handle any logging method call.
-	 *
-	 * @param string $name
-	 * @param array $arguments
-	 */
-	public static function __callStatic(string $name, array $arguments)
-	{
-		// Get the correct logger instance.
-		$logger = null;
-		self::initialize();
-		if (in_array($name, ['emergency', 'alert', 'critical', 'error', 'warning', 'notice', 'info', 'debug',], true)) {
-			$logger = self::$logger;
-		} elseif ($name === 'update') {
-			$logger = self::$update_logger;
-			$name = 'info';
-		}
-
-		// Clearly we have no logging enabled.
-		if ($logger === null) {
-			return;
-		}
-
-		// Replace any placeholders from the passed context.
-		if (count($arguments) >= 2) {
-			$arguments[0] = self::interpolate($arguments[0], $arguments[1]);
-		}
-
-		call_user_func_array([$logger, $name], $arguments);
-	}
-
-	/**
-	 * Interpolates context values into the message placeholders.
-	 *
-	 * @see https://www.php-fig.org/psr/psr-3/#12-message
-	 *
-	 * @param string $message
-	 * @param array $context
-	 *
-	 * @return string
-	 */
-	protected static function interpolate(string $message, array $context = []): string
-	{
-		// Build a replacement array with braces around the context keys.
-		$replace = [];
-		foreach ($context as $key => $val) {
-			// check that the value can be cast to string
-			if (!is_array($val) && (!is_object($val) || method_exists($val, '__toString'))) {
-				$replace["{{$key}}"] = $val;
-			}
-		}
-
-		// Interpolate replacement values into the message and return.
-		return strtr($message, $replace);
-	}
+    /**
+     * Logger instance
+     *
+     * @var LoggerInterface
+     */
+    protected static LoggerInterface $logger;
+
+    /**
+     * Logger instance for update
+     *
+     * @var LoggerInterface
+     */
+    protected static LoggerInterface $update_logger;
+
+    /**
+     * Always log the request and response data to the debug log, also for successful requests
+     *
+     * @var bool
+     */
+    public static bool $always_log_request_and_response = false;
+
+    /**
+     * Temporary stream handle for debug log
+     *
+     * @var resource|null
+     */
+    protected static $debug_log_temp_stream_handle;
+
+    /**
+     * Remove bot token from debug stream
+     *
+     * @var bool
+     */
+    public static bool $remove_bot_token = true;
+
+    /**
+     * Initialise logging.
+     *
+     * @param LoggerInterface|null $logger
+     * @param LoggerInterface|null $update_logger
+     */
+    public static function initialize(LoggerInterface $logger = null, LoggerInterface $update_logger = null): void
+    {
+        self::$logger = $logger ?: new NullLogger();
+        self::$update_logger = $update_logger ?: new NullLogger();
+    }
+
+    /**
+     * Get the stream handle of the temporary debug output
+     *
+     * @return mixed The stream if debug is active, else false
+     */
+    public static function getDebugLogTempStream(): mixed
+    {
+        if ((self::$debug_log_temp_stream_handle === null) && $temp_stream_handle = fopen('php://temp', 'wb+')) {
+            self::$debug_log_temp_stream_handle = $temp_stream_handle;
+        }
+
+        return self::$debug_log_temp_stream_handle;
+    }
+
+    /**
+     * Write the temporary debug stream to log and close the stream handle
+     *
+     * @param string $message Message (with placeholder) to write to the debug log
+     */
+    public static function endDebugLogTempStream(string $message = '%s'): void
+    {
+        if (is_resource(self::$debug_log_temp_stream_handle)) {
+            rewind(self::$debug_log_temp_stream_handle);
+            $stream_contents = stream_get_contents(self::$debug_log_temp_stream_handle);
+
+            if (self::$remove_bot_token) {
+                $stream_contents = preg_replace('/\/bot(\d+):[\w\-]+\//', '/botBOT_TOKEN_REMOVED/', $stream_contents);
+            }
+
+            self::debug(sprintf($message, $stream_contents));
+            fclose(self::$debug_log_temp_stream_handle);
+            self::$debug_log_temp_stream_handle = null;
+        }
+    }
+
+    /**
+     * Handle any logging method call.
+     *
+     * @param string $name
+     * @param array $arguments
+     */
+    public static function __callStatic(string $name, array $arguments)
+    {
+        // Get the correct logger instance.
+        $logger = null;
+        self::initialize();
+        if (in_array($name, ['emergency', 'alert', 'critical', 'error', 'warning', 'notice', 'info', 'debug',], true)) {
+            $logger = self::$logger;
+        } elseif ($name === 'update') {
+            $logger = self::$update_logger;
+            $name = 'info';
+        }
+
+        // Clearly we have no logging enabled.
+        if ($logger === null) {
+            return;
+        }
+
+        // Replace any placeholders from the passed context.
+        if (count($arguments) >= 2) {
+            $arguments[0] = self::interpolate($arguments[0], $arguments[1]);
+        }
+
+        call_user_func_array([$logger, $name], $arguments);
+    }
+
+    /**
+     * Interpolates context values into the message placeholders.
+     *
+     * @see https://www.php-fig.org/psr/psr-3/#12-message
+     *
+     * @param string $message
+     * @param array $context
+     *
+     * @return string
+     */
+    protected static function interpolate(string $message, array $context = []): string
+    {
+        // Build a replacement array with braces around the context keys.
+        $replace = [];
+        foreach ($context as $key => $val) {
+            // check that the value can be cast to string
+            if (!is_array($val) && (!is_object($val) || method_exists($val, '__toString'))) {
+                $replace["{{$key}}"] = $val;
+            }
+        }
+
+        // Interpolate replacement values into the message and return.
+        return strtr($message, $replace);
+    }
 
 }

Spacing +1 added lines, -1 removed lines

@@ -118,7 +118,7 @@
 		// Get the correct logger instance.
 		$logger = null;
 		self::initialize();
-		if (in_array($name, ['emergency', 'alert', 'critical', 'error', 'warning', 'notice', 'info', 'debug',], true)) {
+		if (in_array($name, ['emergency', 'alert', 'critical', 'error', 'warning', 'notice', 'info', 'debug', ], true)) {
 			$logger = self::$logger;
 		} elseif ($name === 'update') {
 			$logger = self::$update_logger;