telegram-bot-php / core

src/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/Entities/UserProfilePhotos.php

Spacing +1 added lines, -1 removed lines

@@ -37,7 +37,7 @@
 
         if ($these_photos = $this->getProperty('photos')) {
             foreach ($these_photos as $photos) {
-                $all_photos[] = array_map(function ($photo) {
+                $all_photos[] = array_map(function($photo) {
                     return new PhotoSize($photo);
                 }, $photos);
             }

src/Traits/EnvironmentsTrait.php

Braces +3 added lines, -1 removed lines

@@ -50,7 +50,9 @@
      */
     protected function getEnvToken(string $file): string|null
     {
-        if (!file_exists($file)) return null;
+        if (!file_exists($file)) {
+            return null;
+        }
         return $_ENV['TELEGRAM_BOT_TOKEN'] ?? null;
     }
 

Indentation +4 added lines, -4 removed lines

@@ -27,7 +27,7 @@ 
      *
      * @return string|null
      */
-  protected static function guessEnvPath(): string|null
+    protected static function guessEnvPath(): string|null
     {
         $defaultEnvPaths = [
             getcwd() . '/.env',
@@ -45,10 +45,10 @@ 
     }
 
     protected static function tryAutoloadEnv(): void {
-      $envPath = static::guessEnvPath();
-      if ($envPath !== null) {
+        $envPath = static::guessEnvPath();
+        if ($envPath !== null) {
         (new Dotenv())->load($envPath);
-      }
+        }
     }
 
     /**

src/Telegram.php

Braces +6 added lines, -2 removed lines

@@ -107,7 +107,9 @@ 
     public function fetchWith(UpdateHandler $update_handler, Update|null $update = null): void
     {
         if (is_subclass_of($update_handler, UpdateHandler::class)) {
-            if ($update === null) $update = self::getUpdate();
+            if ($update === null) {
+                $update = self::getUpdate();
+            }
             $update_handler->resolve($update);
         }
     }
@@ -120,7 +122,9 @@ 
     public static function getUpdate(): Update|null
     {
         $input = self::getInput();
-        if (empty($input)) return null;
+        if (empty($input)) {
+            return null;
+        }
         return Telegram::processUpdate($input, self::getApiToken());
     }
 

src/TelegramLog.php

Spacing +1 added lines, -1 removed lines

@@ -115,7 +115,7 @@
     {
         // Get the correct logger instance.
         $logger = null;
-        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;

tests/WebhookTest.php

Indentation +32 added lines, -32 removed lines

@@ -10,57 +10,57 @@
 
 class WebhookTest extends \PHPUnit\Framework\TestCase {
 
-   public function testAnonymousPlugins() {
-      $plugin = new class($this) extends Plugin {
+    public function testAnonymousPlugins() {
+        $plugin = new class($this) extends Plugin {
 
-         private $testCase;
+            private $testCase;
 
-         public function __construct(TestCase $testCase) {
+            public function __construct(TestCase $testCase) {
             $this->testCase = $testCase;
-         }
+            }
 
-         public function onMessage(int $update_id, Message $message): \Generator {
+            public function onMessage(int $update_id, Message $message): \Generator {
             $this->testCase->assertEquals(1, $update_id);
             $this->testCase->assertEquals('Hello World!', $message->getText());
             yield;
-         }
+            }
 
-      };
+        };
 
-      $message = DummyUpdate::message();
-      $message->set('text', 'Hello World!');
+        $message = DummyUpdate::message();
+        $message->set('text', 'Hello World!');
 
-      (new UpdateHandler())->addPlugins($plugin)->resolve(new Update([
-         'update_id' => 1,
-         'message' => $message->getRawData(),
-      ]));
-   }
+        (new UpdateHandler())->addPlugins($plugin)->resolve(new Update([
+            'update_id' => 1,
+            'message' => $message->getRawData(),
+        ]));
+    }
 
-   public function testFilterIncomingUpdates() {
+    public function testFilterIncomingUpdates() {
 
-      $plugin = new class($this) extends Plugin {
+        $plugin = new class($this) extends Plugin {
 
-         public function __construct(TestCase $testCase) {
+            public function __construct(TestCase $testCase) {
             $this->testCase = $testCase;
-         }
+            }
 
-         public function __process(Update $update): void {
+            public function __process(Update $update): void {
             $this->testCase->fail('This should not be called');
-         }
-      };
+            }
+        };
 
-      $handler = (new UpdateHandler())->addPlugins($plugin);
+        $handler = (new UpdateHandler())->addPlugins($plugin);
 
-      $handler->filterIncomingUpdates([
-         Update::TYPE_MESSAGE
-      ]);
+        $handler->filterIncomingUpdates([
+            Update::TYPE_MESSAGE
+        ]);
 
-      $handler->resolve(new Update([
-         'update_id' => 1,
-         'message' => DummyUpdate::message()->getRawData(),
-      ]));
+        $handler->resolve(new Update([
+            'update_id' => 1,
+            'message' => DummyUpdate::message()->getRawData(),
+        ]));
 
-      $this->assertTrue(true);
-   }
+        $this->assertTrue(true);
+    }
 
 }
\ No newline at end of file

tests/DummyUpdate.php

Indentation +60 added lines, -60 removed lines

@@ -9,114 +9,114 @@
 class DummyUpdate {
 
 
-   private static function faker(): Generator {
-      return Factory::create();
-   }
+    private static function faker(): Generator {
+        return Factory::create();
+    }
 
-   public static function message(): Message {
-      return new Message([
-         'message_id' => self::faker()->randomNumber(),
-         'from' => [
+    public static function message(): Message {
+        return new Message([
+            'message_id' => self::faker()->randomNumber(),
+            'from' => [
             'id' => self::faker()->randomNumber(),
             'is_bot' => false,
             'first_name' => self::faker()->firstName(),
             'last_name' => self::faker()->lastName(),
             'username' => self::faker()->userName(),
             'language_code' => self::faker()->languageCode(),
-         ],
-         'chat' => [
+            ],
+            'chat' => [
             'id' => self::faker()->randomNumber(),
             'first_name' => self::faker()->firstName(),
             'last_name' => self::faker()->lastName(),
             'username' => self::faker()->userName(),
             'type' => 'private',
-         ],
-         'date' => self::faker()->unixTime(),
-         'text' => self::faker()->sentence(),
-      ]);
-   }
+            ],
+            'date' => self::faker()->unixTime(),
+            'text' => self::faker()->sentence(),
+        ]);
+    }
 
-   public static function messageWithEntities(): Message {
-      return new Message([
-         'message_id' => self::faker()->randomNumber(),
-         'from' => [
+    public static function messageWithEntities(): Message {
+        return new Message([
+            'message_id' => self::faker()->randomNumber(),
+            'from' => [
             'id' => self::faker()->randomNumber(),
             'is_bot' => false,
             'first_name' => self::faker()->firstName(),
             'last_name' => self::faker()->lastName(),
             'username' => self::faker()->userName(),
             'language_code' => self::faker()->languageCode(),
-         ],
-         'chat' => [
+            ],
+            'chat' => [
             'id' => self::faker()->randomNumber(),
             'first_name' => self::faker()->firstName(),
             'last_name' => self::faker()->lastName(),
             'username' => self::faker()->userName(),
             'type' => 'private',
-         ],
-         'date' => self::faker()->unixTime(),
-         'text' => self::faker()->sentence(),
-         'entities' => [
+            ],
+            'date' => self::faker()->unixTime(),
+            'text' => self::faker()->sentence(),
+            'entities' => [
             [
-               'offset' => 0,
-               'length' => 1,
-               'type' => 'bold',
+                'offset' => 0,
+                'length' => 1,
+                'type' => 'bold',
             ],
             [
-               'offset' => 2,
-               'length' => 3,
-               'type' => 'italic',
+                'offset' => 2,
+                'length' => 3,
+                'type' => 'italic',
             ],
             [
-               'offset' => 6,
-               'length' => 7,
-               'type' => 'code',
+                'offset' => 6,
+                'length' => 7,
+                'type' => 'code',
+            ]
             ]
-         ]
-      ]);
-   }
+        ]);
+    }
 
-   public static function messageWithReply(): Message {
-      return new Message([
-         'message_id' => self::faker()->randomNumber(),
-         'from' => [
+    public static function messageWithReply(): Message {
+        return new Message([
+            'message_id' => self::faker()->randomNumber(),
+            'from' => [
             'id' => self::faker()->randomNumber(),
             'is_bot' => false,
             'first_name' => self::faker()->firstName(),
             'last_name' => self::faker()->lastName(),
             'username' => self::faker()->userName(),
             'language_code' => self::faker()->languageCode(),
-         ],
-         'chat' => [
+            ],
+            'chat' => [
             'id' => self::faker()->randomNumber(),
             'first_name' => self::faker()->firstName(),
             'last_name' => self::faker()->lastName(),
             'username' => self::faker()->userName(),
             'type' => 'private',
-         ],
-         'date' => self::faker()->unixTime(),
-         'text' => self::faker()->sentence(),
-         'reply_to_message' => [
+            ],
+            'date' => self::faker()->unixTime(),
+            'text' => self::faker()->sentence(),
+            'reply_to_message' => [
             'message_id' => self::faker()->randomNumber(),
             'from' => [
-               'id' => self::faker()->randomNumber(),
-               'is_bot' => false,
-               'first_name' => self::faker()->firstName(),
-               'last_name' => self::faker()->lastName(),
-               'username' => self::faker()->userName(),
-               'language_code' => self::faker()->languageCode(),
+                'id' => self::faker()->randomNumber(),
+                'is_bot' => false,
+                'first_name' => self::faker()->firstName(),
+                'last_name' => self::faker()->lastName(),
+                'username' => self::faker()->userName(),
+                'language_code' => self::faker()->languageCode(),
             ],
             'chat' => [
-               'id' => self::faker()->randomNumber(),
-               'first_name' => self::faker()->firstName(),
-               'last_name' => self::faker()->lastName(),
-               'username' => self::faker()->userName(),
-               'type' => 'private',
+                'id' => self::faker()->randomNumber(),
+                'first_name' => self::faker()->firstName(),
+                'last_name' => self::faker()->lastName(),
+                'username' => self::faker()->userName(),
+                'type' => 'private',
             ],
             'date' => self::faker()->unixTime(),
             'text' => self::faker()->sentence(),
-         ]
-      ]);
-   }
+            ]
+        ]);
+    }
 
 }
\ No newline at end of file

src/UpdateHandler.php

Indentation +217 added lines, -217 removed lines

@@ -17,237 +17,237 @@
  */
 class UpdateHandler extends Telegram implements HandlerInterface {
 
-   use HandlerTrait;
-
-   /**
-    * @var ?Update
-    */
-   protected ?Update $update;
-
-   /**
-    * @var Plugin[]
-    */
-   private array $plugins = [];
-
-   /**
-    * @var bool
-    */
-   private bool $active_spreader = false;
-
-   /**
-    * The default configuration of the webhook.
-    *
-    * @var array
-    */
-   private array $config = [
-      'autoload_env_file' => false,
-      'env_file_path' => null,
-   ];
-
-   /**
-    * Filter incoming updates.
-    *
-    * @var array
-    */
-   private array $filterIncomingUpdates = [];
-
-   /**
-    * Webhook constructor.
-    *
-    * @param string $api_token The API key of the bot. Leave it blank for autoload from .env file.
-    */
-   public function __construct(string $api_token = '') {
-      parent::__construct($api_token);
-
-      if (!Telegram::validateToken(self::getApiToken())) {
-         throw new InvalidBotTokenException();
-      }
-   }
-
-   /**
-    * Resolve the request on single plugin.
-    *
-    * @param Plugin $plugin The plugin to work with
-    * @param ?Update $update The custom to work with
-    * @param array $config The configuration of the receiver
-    * @return void
-    */
-   public static function resolveOn(Plugin $plugin, Update $update = null, array $config = []): void {
-      // TODO: Implement resolveOn() method.
-   }
-
-   /**
-    * Add plugins to the receiver
-    *
-    * @param Plugin[]|array $plugins
-    * @retrun void
-    */
-   public function addPlugins(Plugin|array $plugins): UpdateHandler {
-      if (is_object($plugins)) {
-         $plugins = [$plugins];
-      }
-
-      foreach ($plugins as $plugin) {
-         if (!is_subclass_of($plugin, Plugin::class)) {
+    use HandlerTrait;
+
+    /**
+     * @var ?Update
+     */
+    protected ?Update $update;
+
+    /**
+     * @var Plugin[]
+     */
+    private array $plugins = [];
+
+    /**
+     * @var bool
+     */
+    private bool $active_spreader = false;
+
+    /**
+     * The default configuration of the webhook.
+     *
+     * @var array
+     */
+    private array $config = [
+        'autoload_env_file' => false,
+        'env_file_path' => null,
+    ];
+
+    /**
+     * Filter incoming updates.
+     *
+     * @var array
+     */
+    private array $filterIncomingUpdates = [];
+
+    /**
+     * Webhook constructor.
+     *
+     * @param string $api_token The API key of the bot. Leave it blank for autoload from .env file.
+     */
+    public function __construct(string $api_token = '') {
+        parent::__construct($api_token);
+
+        if (!Telegram::validateToken(self::getApiToken())) {
+            throw new InvalidBotTokenException();
+        }
+    }
+
+    /**
+     * Resolve the request on single plugin.
+     *
+     * @param Plugin $plugin The plugin to work with
+     * @param ?Update $update The custom to work with
+     * @param array $config The configuration of the receiver
+     * @return void
+     */
+    public static function resolveOn(Plugin $plugin, Update $update = null, array $config = []): void {
+        // TODO: Implement resolveOn() method.
+    }
+
+    /**
+     * Add plugins to the receiver
+     *
+     * @param Plugin[]|array $plugins
+     * @retrun void
+     */
+    public function addPlugins(Plugin|array $plugins): UpdateHandler {
+        if (is_object($plugins)) {
+            $plugins = [$plugins];
+        }
+
+        foreach ($plugins as $plugin) {
+            if (!is_subclass_of($plugin, Plugin::class)) {
             throw new \RuntimeException(
-               sprintf('The plugin %s must be an instance of %s', get_class($plugin), Plugin::class)
+                sprintf('The plugin %s must be an instance of %s', get_class($plugin), Plugin::class)
             );
-         }
+            }
 
-         $reflection = Toolkit::reflectionClass($plugin);
-         $this->plugins[] = [
+            $reflection = Toolkit::reflectionClass($plugin);
+            $this->plugins[] = [
             'class' => $plugin,
             'initialized' => is_object($plugin),
-         ];
-      }
-
-      return $this;
-   }
-
-   /**
-    * Updates the filter for incoming updates.
-    *
-    * @param array $filter
-    * @return void
-    */
-   public function filterIncomingUpdates(array $filter): void {
-      $this->filterIncomingUpdates = $filter;
-   }
-
-   /**
-    * Do not process updates that match the filter.
-    *
-    * @param Update $update
-    * @return bool
-    */
-   private function isFiltered(Update $update): bool {
-      if (empty($this->filterIncomingUpdates)) {
-         return false;
-      }
-
-      foreach ($this->filterIncomingUpdates as $type => $value) {
-         if (is_int($type)) {
+            ];
+        }
+
+        return $this;
+    }
+
+    /**
+     * Updates the filter for incoming updates.
+     *
+     * @param array $filter
+     * @return void
+     */
+    public function filterIncomingUpdates(array $filter): void {
+        $this->filterIncomingUpdates = $filter;
+    }
+
+    /**
+     * Do not process updates that match the filter.
+     *
+     * @param Update $update
+     * @return bool
+     */
+    private function isFiltered(Update $update): bool {
+        if (empty($this->filterIncomingUpdates)) {
+            return false;
+        }
+
+        foreach ($this->filterIncomingUpdates as $type => $value) {
+            if (is_int($type)) {
             if ($update->getUpdateType() === $value) {
-               return true;
+                return true;
             }
-         } elseif (is_string($type)) {
+            } elseif (is_string($type)) {
             if ($update->getUpdateType() === $type) {
-               if (is_callable($value)) {
-                  return $value($update);
-               } elseif (is_bool($value)) {
-                  return $value;
-               }
-               throw new \InvalidArgumentException('The value of the filter must be a callable or a boolean');
+                if (is_callable($value)) {
+                    return $value($update);
+                } elseif (is_bool($value)) {
+                    return $value;
+                }
+                throw new \InvalidArgumentException('The value of the filter must be a callable or a boolean');
+            }
             }
-         }
-         throw new \InvalidArgumentException('Invalid filter');
-      }
-
-      return false;
-   }
-
-   /**
-    * Resolve the request.
-    *
-    * @param ?Update $update The custom to work with
-    * @param array $config The configuration of the receiver
-    *
-    * @retrun void
-    */
-   public function resolve(Update|null $update = null, array $config = []): void {
-      $this->update = $update ?? Telegram::getUpdate();
-
-      if (empty($this->update)) {
-         TelegramLog::error('The update is empty, the request is not processed');
-         return;
-      }
-
-      if ($this->isFiltered($this->update)) {
-         TelegramLog::notice('The update is filtered, the request is not processed');
-         return;
-      }
-
-      if (!method_exists($this, '__process')) {
-         throw new \RuntimeException('The method __process does not exist');
-      }
-
-      if (is_array($config)) {
-         $this->updateConfiguration($config);
-      }
-
-      putenv('TG_CURRENT_UPDATE=' . $this->update->getRawData(false));
-
-      $this->__process($this->update);
-      $this->loadPlugins($this->plugins);
-   }
-
-   /**
-    * Update the configuration
-    *
-    * @param array $configuration
-    * @return void
-    */
-   public function updateConfiguration(array $configuration): void {
-      $this->config = array_merge($this->config, $configuration);
-   }
-
-   /**
-    * Match the update with the given plugins
-    *
-    * @param Plugin[]|array $plugins
-    * @return void
-    */
-   private function loadPlugins(array $plugins): void {
-      $update = $update ?? ($this->update ?? Telegram::getUpdate());
-
-      foreach ($plugins as $plugin) {
-         if (!is_subclass_of($plugin['class'], Plugin::class)) {
+            throw new \InvalidArgumentException('Invalid filter');
+        }
+
+        return false;
+    }
+
+    /**
+     * Resolve the request.
+     *
+     * @param ?Update $update The custom to work with
+     * @param array $config The configuration of the receiver
+     *
+     * @retrun void
+     */
+    public function resolve(Update|null $update = null, array $config = []): void {
+        $this->update = $update ?? Telegram::getUpdate();
+
+        if (empty($this->update)) {
+            TelegramLog::error('The update is empty, the request is not processed');
+            return;
+        }
+
+        if ($this->isFiltered($this->update)) {
+            TelegramLog::notice('The update is filtered, the request is not processed');
+            return;
+        }
+
+        if (!method_exists($this, '__process')) {
+            throw new \RuntimeException('The method __process does not exist');
+        }
+
+        if (is_array($config)) {
+            $this->updateConfiguration($config);
+        }
+
+        putenv('TG_CURRENT_UPDATE=' . $this->update->getRawData(false));
+
+        $this->__process($this->update);
+        $this->loadPlugins($this->plugins);
+    }
+
+    /**
+     * Update the configuration
+     *
+     * @param array $configuration
+     * @return void
+     */
+    public function updateConfiguration(array $configuration): void {
+        $this->config = array_merge($this->config, $configuration);
+    }
+
+    /**
+     * Match the update with the given plugins
+     *
+     * @param Plugin[]|array $plugins
+     * @return void
+     */
+    private function loadPlugins(array $plugins): void {
+        $update = $update ?? ($this->update ?? Telegram::getUpdate());
+
+        foreach ($plugins as $plugin) {
+            if (!is_subclass_of($plugin['class'], Plugin::class)) {
             throw new \InvalidArgumentException(sprintf(
-               'The plugin %s must be an instance of %s',
-               get_class($plugin['class']), Plugin::class
+                'The plugin %s must be an instance of %s',
+                get_class($plugin['class']), Plugin::class
             ));
-         }
-      }
+            }
+        }
 
-      if (!$update instanceof Update) {
-         throw new \InvalidArgumentException(sprintf(
+        if (!$update instanceof Update) {
+            throw new \InvalidArgumentException(sprintf(
             'The update must be an instance of %s. %s given',
             Update::class, gettype($update)
-         ));
-      }
-
-      $this->spreadUpdateWith($update, $plugins);
-   }
-
-   /**
-    * This function will get update and spread it to the plugins
-    *
-    * @param Update $update
-    * @param array<Plugin> $plugins
-    * @return void
-    */
-   private function spreadUpdateWith(Update $update, array $plugins): void {
-      $this->active_spreader = true;
-
-      foreach ($plugins as $plugin) {
-         if ($plugin['initialized'] === false) {
+            ));
+        }
+
+        $this->spreadUpdateWith($update, $plugins);
+    }
+
+    /**
+     * This function will get update and spread it to the plugins
+     *
+     * @param Update $update
+     * @param array<Plugin> $plugins
+     * @return void
+     */
+    private function spreadUpdateWith(Update $update, array $plugins): void {
+        $this->active_spreader = true;
+
+        foreach ($plugins as $plugin) {
+            if ($plugin['initialized'] === false) {
             $plugin['class'] = new $plugin['class']();
-         }
-
-         $plugin['class']->__execute($this, $update);
-         if ($this->active_spreader === false) break;
-      }
-
-      $this->active_spreader = false;
-   }
-
-   /**
-    * Stop the spreader process
-    *
-    * @return void
-    */
-   public function stop(): void {
-      $this->active_spreader = false;
-   }
+            }
+
+            $plugin['class']->__execute($this, $update);
+            if ($this->active_spreader === false) break;
+        }
+
+        $this->active_spreader = false;
+    }
+
+    /**
+     * Stop the spreader process
+     *
+     * @return void
+     */
+    public function stop(): void {
+        $this->active_spreader = false;
+    }
 
 }
\ No newline at end of file

Braces +3 added lines, -1 removed lines

@@ -235,7 +235,9 @@
          }
 
          $plugin['class']->__execute($this, $update);
-         if ($this->active_spreader === false) break;
+         if ($this->active_spreader === false) {
+             break;
+         }
       }
 
       $this->active_spreader = false;

src/Traits/PluginTrait.php

Indentation +91 added lines, -91 removed lines

@@ -16,98 +16,98 @@
  */
 trait PluginTrait {
 
-   /**
-    * @var UpdateHandler
-    */
-   protected UpdateHandler $hook;
-
-   /**
-    * This property is used to kill the plugin when you yield a Response object.
-    *
-    * @var bool
-    */
-   protected bool $KILL_ON_YIELD = true;
-
-   /**
-    * @var \Generator
-    */
-   private \Generator $returns;
-
-   /**
-    * Execute the plugin.
-    *
-    * @param UpdateHandler $receiver
-    * @param Update $update
-    * @return void
-    */
-   public function __execute(UpdateHandler $receiver, Update $update): void {
-      $this->hook = $receiver;
-
-      if (method_exists($this, '__process')) {
-         $this->__process($update);
-      }
-
-      if (method_exists($this, 'onReceivedUpdate')) {
-         $return = $this->onUpdate($update);
-         $this->__checkExit($return);
-      }
-
-      $type = $this->__identify($update);
-      if (method_exists($this, ($method = 'on' . $type)) && $type !== null) {
-         $this->__checkExit($this->__callEvent($method, $update));
-      }
-   }
-
-   /**
-    * Check for the exit of the plugin.
-    *
-    * @param \Generator $return
-    * @return void
-    */
-   private function __checkExit(\Generator $return): void {
-      if ($return->valid()) {
-         if ($return->current() !== null && $this->KILL_ON_YIELD === true) {
+    /**
+     * @var UpdateHandler
+     */
+    protected UpdateHandler $hook;
+
+    /**
+     * This property is used to kill the plugin when you yield a Response object.
+     *
+     * @var bool
+     */
+    protected bool $KILL_ON_YIELD = true;
+
+    /**
+     * @var \Generator
+     */
+    private \Generator $returns;
+
+    /**
+     * Execute the plugin.
+     *
+     * @param UpdateHandler $receiver
+     * @param Update $update
+     * @return void
+     */
+    public function __execute(UpdateHandler $receiver, Update $update): void {
+        $this->hook = $receiver;
+
+        if (method_exists($this, '__process')) {
+            $this->__process($update);
+        }
+
+        if (method_exists($this, 'onReceivedUpdate')) {
+            $return = $this->onUpdate($update);
+            $this->__checkExit($return);
+        }
+
+        $type = $this->__identify($update);
+        if (method_exists($this, ($method = 'on' . $type)) && $type !== null) {
+            $this->__checkExit($this->__callEvent($method, $update));
+        }
+    }
+
+    /**
+     * Check for the exit of the plugin.
+     *
+     * @param \Generator $return
+     * @return void
+     */
+    private function __checkExit(\Generator $return): void {
+        if ($return->valid()) {
+            if ($return->current() !== null && $this->KILL_ON_YIELD === true) {
             if ($return->current() instanceof Response) {
-               $this->stop();
+                $this->stop();
             }
-         }
-      }
-
-      if ($return->valid()) {
-         $return->next();
-         $this->__checkExit($return);
-      }
-   }
-
-   /**
-    * Identify the update type. e.g. Message, EditedMessage, etc.
-    *
-    * @param Update $update
-    * @return string|null
-    */
-   private function __identify(Update $update): ?string {
-      $type = $update->getUpdateType();
-
-      if ($type === null) {
-         return null;
-      }
-
-      return str_replace('_', '', ucwords($type, '_'));
-   }
-
-   /**
-    * Pass data to the method.
-    *
-    * @param string $method The method name.
-    * @param Update $update The update object.
-    * @return \Generator
-    */
-   private function __callEvent(string $method, Update $update): \Generator {
-      $upperName = 'get' . ucfirst(substr($method, 2));
-      return match ($method) {
-         'onWebAppData' => $this->onWebAppData($update->getWebAppData()),
-         default => $this->$method($update->getUpdateId(), $update->$upperName()),
-      };
-   }
+            }
+        }
+
+        if ($return->valid()) {
+            $return->next();
+            $this->__checkExit($return);
+        }
+    }
+
+    /**
+     * Identify the update type. e.g. Message, EditedMessage, etc.
+     *
+     * @param Update $update
+     * @return string|null
+     */
+    private function __identify(Update $update): ?string {
+        $type = $update->getUpdateType();
+
+        if ($type === null) {
+            return null;
+        }
+
+        return str_replace('_', '', ucwords($type, '_'));
+    }
+
+    /**
+     * Pass data to the method.
+     *
+     * @param string $method The method name.
+     * @param Update $update The update object.
+     * @return \Generator
+     */
+    private function __callEvent(string $method, Update $update): \Generator {
+        $upperName = 'get' . ucfirst(substr($method, 2));
+        return match ($method) {
+            'onWebAppData' => $this->onWebAppData($update->getWebAppData()),
+            default => $this->$method($update->getUpdateId(), $update->$upperName()),
+        };
+    }
 
 }
\ No newline at end of file