BPTproto / BPT-Multi

examples/messenger/bot.php

Spacing +20 added lines, -20 removed lines

@@ -19,7 +19,7 @@ 
     const ADMIN = 123456789;
     const SHOW_STATUS = true;
     const UNKNOWN = 'I didnt understand it, Please use commands or reply to a user message';
-    const HELP            = 'Hello dear admin 
+    const HELP = 'Hello dear admin 
 This is a simple messenger bot which also support reply for users and admin itself
 For answering an user message , You must reply on it
 If you want to reply , You must first use /reply_on command and this will apply on your next message
@@ -34,11 +34,11 @@ 
     const SEND_FAILED     = 'Failed!';
     const SEND_SUCCESSFUL = 'Done!';
 
-    public function __construct (array $settings) {
+    public function __construct(array $settings) {
         parent::__construct($settings);
     }
 
-    public function message (message $update) {
+    public function message(message $update) {
         $text = $update->text ?? '';
         $user_id = $update->from->id;
 
@@ -54,11 +54,11 @@ 
                 return $this->sendMessage(self::HELP, answer: true);
             }
             if ($text === '/reply_on') {
-                mysql::update('users',['value'=>'reply_on'],['id'=>$user_id],1);
+                mysql::update('users', ['value'=>'reply_on'], ['id'=>$user_id], 1);
                 return $this->sendMessage(self::REPLY_ON, answer: true);
             }
             if ($text === '/reply_off') {
-                mysql::update('users',['value'=>'reply_off'],['id'=>$user_id],1);
+                mysql::update('users', ['value'=>'reply_off'], ['id'=>$user_id], 1);
                 return $this->sendMessage(self::REPLY_OFF, answer: true);
             }
             if (!isset($update->reply_to_message)) {
@@ -68,10 +68,10 @@ 
             $reply_message_id = $update->reply_to_message->message_id;
 
             if ($update->reply_to_message->from->id === $user_id) {
-                $check_message = mysql::select('messages', ['receiver_message_id','receiver_id'], [
+                $check_message = mysql::select('messages', ['receiver_message_id', 'receiver_id'], [
                     'sender_message_id' => $reply_message_id,
                     'sender_id'         => $user_id
-                ],1);
+                ], 1);
 
                 if ($check_message->num_rows < 1) {
                     return $this->sendMessage(self::NOT_FOUND, answer: true);
@@ -81,19 +81,19 @@ 
                 $result = $this->copyMessage($receiver_id, reply_to_message_id: $data->receiver_message_id);
             }
             else {
-                $check_message = mysql::select('messages', ['sender_message_id','sender_id'], [
+                $check_message = mysql::select('messages', ['sender_message_id', 'sender_id'], [
                     'receiver_message_id' => $reply_message_id,
                     'receiver_id'         => $user_id
-                ],1);
+                ], 1);
 
                 if ($check_message->num_rows < 1) {
                     return $this->sendMessage(self::NOT_FOUND, answer: true);
                 }
                 $data = $check_message->fetch_object();
-                $value = mysql::select('users','value',['id'=>$user_id])->fetch_object()->value;
+                $value = mysql::select('users', 'value', ['id'=>$user_id])->fetch_object()->value;
                 $receiver_id = $data->sender_id;
                 if ($value === 'reply_on') {
-                    mysql::update('users',['value'=>''],['id'=>$user_id]);
+                    mysql::update('users', ['value'=>''], ['id'=>$user_id]);
                     $result = $this->copyMessage($receiver_id, reply_to_message_id: $data->sender_message_id);
                 }
                 else {
@@ -117,7 +117,7 @@ 
         }
         $username = $update->from->username;
         if (empty($username)) {
-            $name = $update->from->first_name . (!empty($update->from->last_name) ? (' ' . $update->from->last_name) : '');
+            $name = $update->from->first_name.(!empty($update->from->last_name) ? (' '.$update->from->last_name) : '');
             $keyboard = [
                 'inline_keyboard' => [
                     [
@@ -155,33 +155,33 @@ 
         }
         if (isset($update->reply_to_message)) {
             $reply_message_id = $update->reply_to_message->message_id;
-            if ($update->reply_to_message->from->id === $user_id){
+            if ($update->reply_to_message->from->id === $user_id) {
                 $check_message = mysql::select('messages', 'receiver_message_id', [
                     'sender_message_id' => $reply_message_id,
                     'sender_id'         => $user_id
-                ],1);
+                ], 1);
                 if ($check_message->num_rows > 0) {
-                    $result = $this->copyMessage(self::ADMIN, reply_to_message_id: $check_message->fetch_object()->receiver_message_id,reply_markup: $keyboard);
+                    $result = $this->copyMessage(self::ADMIN, reply_to_message_id: $check_message->fetch_object()->receiver_message_id, reply_markup: $keyboard);
                 }
                 else {
-                    $result = $this->copyMessage(self::ADMIN,reply_markup: $keyboard);
+                    $result = $this->copyMessage(self::ADMIN, reply_markup: $keyboard);
                 }
             }
             else {
                 $check_message = mysql::select('messages', 'sender_message_id', [
                     'receiver_message_id' => $reply_message_id,
                     'receiver_id'         => $user_id
-                ],1);
+                ], 1);
                 if ($check_message->num_rows > 0) {
-                    $result = $this->copyMessage(self::ADMIN, reply_to_message_id: $check_message->fetch_object()->sender_message_id,reply_markup: $keyboard);
+                    $result = $this->copyMessage(self::ADMIN, reply_to_message_id: $check_message->fetch_object()->sender_message_id, reply_markup: $keyboard);
                 }
                 else {
-                    $result = $this->copyMessage(self::ADMIN,reply_markup: $keyboard);
+                    $result = $this->copyMessage(self::ADMIN, reply_markup: $keyboard);
                 }
             }
         }
         else {
-            $result = $this->copyMessage(self::ADMIN,reply_markup: $keyboard);
+            $result = $this->copyMessage(self::ADMIN, reply_markup: $keyboard);
         }
 
         /**

Braces +8 added lines, -16 removed lines

@@ -7,8 +7,7 @@ 
 
 if (file_exists('vendor/autoload.php')) {
     require 'vendor/autoload.php';
-}
-else {
+} else {
     if (!file_exists('BPT.phar')) {
         copy('https://dl.bptlib.ir/BPT.phar', 'BPT.phar');
     }
@@ -79,8 +78,7 @@ 
                 $data = $check_message->fetch_object();
                 $receiver_id = $data->receiver_id;
                 $result = $this->copyMessage($receiver_id, reply_to_message_id: $data->receiver_message_id);
-            }
-            else {
+            } else {
                 $check_message = mysql::select('messages', ['sender_message_id','sender_id'], [
                     'receiver_message_id' => $reply_message_id,
                     'receiver_id'         => $user_id
@@ -95,8 +93,7 @@ 
                 if ($value === 'reply_on') {
                     mysql::update('users',['value'=>''],['id'=>$user_id]);
                     $result = $this->copyMessage($receiver_id, reply_to_message_id: $data->sender_message_id);
-                }
-                else {
+                } else {
                     $result = $this->copyMessage($receiver_id);
                 }
             }
@@ -138,8 +135,7 @@ 
                     ]
                 ]
             ];
-        }
-        else {
+        } else {
             $keyboard = [
                 'inline_keyboard' => [
                     [
@@ -162,25 +158,21 @@ 
                 ],1);
                 if ($check_message->num_rows > 0) {
                     $result = $this->copyMessage(self::ADMIN, reply_to_message_id: $check_message->fetch_object()->receiver_message_id,reply_markup: $keyboard);
-                }
-                else {
+                } else {
                     $result = $this->copyMessage(self::ADMIN,reply_markup: $keyboard);
                 }
-            }
-            else {
+            } else {
                 $check_message = mysql::select('messages', 'sender_message_id', [
                     'receiver_message_id' => $reply_message_id,
                     'receiver_id'         => $user_id
                 ],1);
                 if ($check_message->num_rows > 0) {
                     $result = $this->copyMessage(self::ADMIN, reply_to_message_id: $check_message->fetch_object()->sender_message_id,reply_markup: $keyboard);
-                }
-                else {
+                } else {
                     $result = $this->copyMessage(self::ADMIN,reply_markup: $keyboard);
                 }
             }
-        }
-        else {
+        } else {
             $result = $this->copyMessage(self::ADMIN,reply_markup: $keyboard);
         }
 

src/telegram/request.php

Spacing +25 added lines, -25 removed lines

@@ -825,30 +825,30 @@ 
         'getGameHighScores'               => ['BPT\types\gameHighScore']
     ];
 
-    public static function __callStatic (string $name, array $arguments) {
+    public static function __callStatic(string $name, array $arguments) {
         if (!$action = self::methodAction($name)) {
-            logger::write("$name method is not supported",loggerTypes::ERROR);
+            logger::write("$name method is not supported", loggerTypes::ERROR);
             throw new bptException('METHOD_NOT_FOUND');
         }
         self::checkArguments($arguments);
-        self::keysName($action,$arguments);
-        self::readyFile($action,$arguments);
+        self::keysName($action, $arguments);
+        self::readyFile($action, $arguments);
         self::cleanArguments($arguments);
-        self::setDefaults($action,$arguments);
+        self::setDefaults($action, $arguments);
 
         if (isset($arguments['answer']) && $arguments['answer'] === true) {
             unset($arguments['answer']);
             if (!answer::isAnswered()) {
-                return answer::init($action,$arguments);
+                return answer::init($action, $arguments);
             }
-            logger::write('you can use answer mode only once for each webhook update, Others will be called like normal',loggerTypes::WARNING);
+            logger::write('you can use answer mode only once for each webhook update, Others will be called like normal', loggerTypes::WARNING);
         }
-        $result = curl::init($action,$arguments);
+        $result = curl::init($action, $arguments);
         if (!is_object($result)) {
-            logger::write("Telegram $action method failed : " . $result, loggerTypes::WARNING);
+            logger::write("Telegram $action method failed : ".$result, loggerTypes::WARNING);
             return false;
         }
-        return self::processResponse($action,$result);
+        return self::processResponse($action, $result);
     }
 
     private static function checkArguments(array &$arguments): void {
@@ -857,7 +857,7 @@ 
         }
     }
 
-    private static function keysName (string $name, array &$arguments): void {
+    private static function keysName(string $name, array &$arguments): void {
         foreach ($arguments as $key => $argument) {
             if (is_numeric($key) && isset(self::METHODS_KEYS[$name][$key])) {
                 $arguments[self::METHODS_KEYS[$name][$key]] = $argument;
@@ -866,7 +866,7 @@ 
         }
     }
 
-    private static function methodAction(string $name): string|false {
+    private static function methodAction(string $name): string | false {
         return self::METHODS_ACTION[str_replace('_', '', strtolower($name))] ?? false;
     }
 
@@ -902,11 +902,11 @@ 
         }
     }
 
-    private static function methodFile(string $name): array|false {
+    private static function methodFile(string $name): array | false {
         return self::METHODS_WITH_FILE[$name] ?? false;
     }
 
-    private static function methodReturn(string $name,stdClass $response) {
+    private static function methodReturn(string $name, stdClass $response) {
         if (!isset(self::METHODS_RETURN[$name])) {
             return $response->result;
         }
@@ -925,13 +925,13 @@ 
         $defaults = self::METHODS_EXTRA_DEFAULTS[$name] ?? [];
         foreach ($defaults as $key => $default) {
             if (is_numeric($key)) {
-                if (!isset($arguments[$default])){
+                if (!isset($arguments[$default])) {
                     $arguments[$default] = self::catchFields($default);
                 }
             }
             elseif (isset(BPT::$update->$key) || $key === 'other') {
                 foreach ($default as $def) {
-                    if (!isset($arguments[$def])){
+                    if (!isset($arguments[$def])) {
                         $arguments[$def] = self::catchFields($def);
                     }
                 }
@@ -950,13 +950,13 @@ 
         self::$status = $response->ok;
         self::$pure_response = $response;
         if (!$response->ok) {
-            logger::write("Telegram $name method failed : " . json_encode($response), loggerTypes::WARNING);
+            logger::write("Telegram $name method failed : ".json_encode($response), loggerTypes::WARNING);
             return new responseError($response);
         }
-        return self::methodReturn($name,$response);
+        return self::methodReturn($name, $response);
     }
 
-    private static function cleanArguments (array &$arguments): void {
+    private static function cleanArguments(array &$arguments): void {
         foreach ($arguments as $key => $argument) {
             if ($argument == [] || $argument === null) {
                 unset($arguments[$key]);
@@ -971,7 +971,7 @@ 
      *
      * @return int|string|bool
      */
-    public static function catchFields (string $field): int|string|bool {
+    public static function catchFields(string $field): int | string | bool {
         switch ($field) {
             case fields::CHAT_ID :
             case fields::FROM_CHAT_ID :
@@ -1118,13 +1118,13 @@ 
                     default => false
                 };
             case fields::URL :
-                return 'https://' . $_SERVER['SERVER_NAME'] . $_SERVER['REQUEST_URI'];
+                return 'https://'.$_SERVER['SERVER_NAME'].$_SERVER['REQUEST_URI'];
             default:
                 return false;
         }
     }
 
-    public static function fileLink (string|null $file_id = null): bool|string {
+    public static function fileLink(string | null $file_id = null): bool | string {
         $file = request::getFile($file_id);
         if (!isset($file->file_path)) {
             return false;
@@ -1146,7 +1146,7 @@ 
      *
      * @return bool
      */
-    public static function downloadFile (string|null $destination = null, string|null $file_id = null): bool {
+    public static function downloadFile(string | null $destination = null, string | null $file_id = null): bool {
         return tools::downloadFile(self::fileLink($file_id), $destination);
     }
 
@@ -1164,10 +1164,10 @@ 
      *
      * @return message|bool|responseError
      */
-    public static function sendFile (string $file_id, int|string $chat_id = null, int $message_thread_id = null, string $caption = null, string $parse_mode = null, array $caption_entities = null, bool $disable_notification = null, bool $protect_content = null, int $reply_to_message_id = null, bool $allow_sending_without_reply = null, inlineKeyboardMarkup|replyKeyboardMarkup|replyKeyboardRemove|forceReply|stdClass|array $reply_markup = null, string $token = null, bool $forgot = null, bool $answer = null): message|bool|responseError {
+    public static function sendFile(string $file_id, int | string $chat_id = null, int $message_thread_id = null, string $caption = null, string $parse_mode = null, array $caption_entities = null, bool $disable_notification = null, bool $protect_content = null, int $reply_to_message_id = null, bool $allow_sending_without_reply = null, inlineKeyboardMarkup | replyKeyboardMarkup | replyKeyboardRemove | forceReply | stdClass | array $reply_markup = null, string $token = null, bool $forgot = null, bool $answer = null): message | bool | responseError {
         $type = tools::fileType($file_id);
         return match ($type) {
-            fileTypes::VIDEO => request::sendVideo($file_id, $chat_id, $message_thread_id, null, null, null, null, $caption, $parse_mode, $caption_entities, false,null, $disable_notification, $protect_content, $reply_to_message_id, $allow_sending_without_reply, $reply_markup, $token, $forgot, $answer),
+            fileTypes::VIDEO => request::sendVideo($file_id, $chat_id, $message_thread_id, null, null, null, null, $caption, $parse_mode, $caption_entities, false, null, $disable_notification, $protect_content, $reply_to_message_id, $allow_sending_without_reply, $reply_markup, $token, $forgot, $answer),
             fileTypes::VIDEO_NOTE => request::sendVideoNote($file_id, $chat_id, $message_thread_id, null, null, null, $disable_notification, $protect_content, $reply_to_message_id, $allow_sending_without_reply, $reply_markup, $token, $forgot, $answer),
             fileTypes::ANIMATION => request::sendAnimation($file_id, $chat_id, $message_thread_id, null, null, null, null, $caption, $parse_mode, $caption_entities, false, $disable_notification, $protect_content, $reply_to_message_id, $allow_sending_without_reply, $reply_markup, $token, $forgot, $answer),
             fileTypes::AUDIO => request::sendAudio($file_id, $chat_id, $message_thread_id, $caption, $parse_mode, $caption_entities, null, null, null, null, $disable_notification, $protect_content, $reply_to_message_id, $allow_sending_without_reply, $reply_markup, $token, $forgot, $answer),

src/database/mysql.php

Spacing +53 added lines, -53 removed lines

@@ -31,7 +31,7 @@ 
     /**
      * If you want to use it in standalone mode , you MUST set `auto_process` to `false`
      */
-    public static function init (string $host = 'localhost', string $username = 'root', string $password = '', string $dbname = '', bool $auto_process = null, int $port = 3306): void {
+    public static function init(string $host = 'localhost', string $username = 'root', string $password = '', string $dbname = '', bool $auto_process = null, int $port = 3306): void {
         $host = settings::$db['host'] ?? $host;
         $port = settings::$db['port'] ?? $port;
         $user = settings::$db['user'] ?? settings::$db['username'] ?? $username;
@@ -41,7 +41,7 @@ 
         self::$db_name = $dbname;
         self::$connection = new mysqli($host, $user, $pass, $dbname, $port);
         if (self::$connection->connect_errno) {
-            logger::write('SQL connection has problem : ' . self::$connection->connect_error, loggerTypes::ERROR);
+            logger::write('SQL connection has problem : '.self::$connection->connect_error, loggerTypes::ERROR);
             throw new bptException('SQL_CONNECTION_PROBLEM');
         }
         if (self::$auto_process && !lock::exist('BPT-MYSQL')) {
@@ -49,7 +49,7 @@ 
         }
     }
 
-    private static function install (): void {
+    private static function install(): void {
         self::pureQuery("
 CREATE TABLE `users`
 (
@@ -70,7 +70,7 @@ 
     /**
      * @internal Only for BPT self usage , Don't use it in your source!
      */
-    public static function process (): void {
+    public static function process(): void {
         if (self::$auto_process) {
             if (isset(BPT::$update->message)) {
                 self::processMessage(BPT::$update->message);
@@ -90,7 +90,7 @@ 
         }
     }
 
-    private static function processMessage (message $update): void {
+    private static function processMessage(message $update): void {
         $type = $update->chat->type;
         if ($type === chatType::PRIVATE) {
             $user_id = $update->from->id;
@@ -116,7 +116,7 @@ 
         }
     }
 
-    private static function processCallbackQuery (callbackQuery $update): void {
+    private static function processCallbackQuery(callbackQuery $update): void {
         $type = $update->message->chat->type;
         if ($type === chatType::PRIVATE) {
             $user_id = $update->from->id;
@@ -126,7 +126,7 @@ 
         }
     }
 
-    private static function processInlineQuery (inlineQuery $update): void {
+    private static function processInlineQuery(inlineQuery $update): void {
         $type = $update->chat_type;
         if ($type === chatType::PRIVATE || $type === chatType::SENDER) {
             $user_id = $update->from->id;
@@ -136,7 +136,7 @@ 
         }
     }
 
-    private static function processMyChatMember (chatMemberUpdated $update): void {
+    private static function processMyChatMember(chatMemberUpdated $update): void {
         $type = $update->chat->type;
         if ($type === chatType::PRIVATE) {
             if ($update->new_chat_member->status === chatMemberStatus::MEMBER) {
@@ -159,7 +159,7 @@ 
      *
      * @return bool
      */
-    public static function addDefaultWhere (array $where): bool {
+    public static function addDefaultWhere(array $where): bool {
         if (empty(self::$default_where)) {
             self::$default_where = $where;
         }
@@ -174,7 +174,7 @@ 
      *
      * @return mysqli
      */
-    public static function getMysqli (): mysqli {
+    public static function getMysqli(): mysqli {
         return self::$connection;
     }
 
@@ -185,7 +185,7 @@ 
      *
      * @return int|string
      */
-    public static function affected_rows (): int|string {
+    public static function affected_rows(): int | string {
         return self::$connection->affected_rows;
     }
 
@@ -196,7 +196,7 @@ 
      *
      * @return int|string
      */
-    public static function affectedRows (): int|string {
+    public static function affectedRows(): int | string {
         return self::$connection->affected_rows;
     }
 
@@ -207,7 +207,7 @@ 
      *
      * @return int|string
      */
-    public static function insert_id (): int|string {
+    public static function insert_id(): int | string {
         return self::$connection->insert_id;
     }
 
@@ -218,7 +218,7 @@ 
      *
      * @return int|string
      */
-    public static function insertId (): int|string {
+    public static function insertId(): int | string {
         return self::$connection->insert_id;
     }
 
@@ -229,7 +229,7 @@ 
      *
      * @return string
      */
-    public static function escapeString (string $text): string {
+    public static function escapeString(string $text): string {
         return self::$connection->real_escape_string($text);
     }
 
@@ -238,7 +238,7 @@ 
      *
      * @return string
      */
-    public static function error (): string {
+    public static function error(): string {
         return self::$connection->error;
     }
 
@@ -247,7 +247,7 @@ 
      *
      * @return int
      */
-    public static function errno (): int {
+    public static function errno(): int {
         return self::$connection->errno;
     }
 
@@ -258,7 +258,7 @@ 
      *
      * @return bool
      */
-    public static function setCharset (string $charset): bool {
+    public static function setCharset(string $charset): bool {
         return self::$connection->set_charset($charset);
     }
 
@@ -273,7 +273,7 @@ 
      *
      * @return mysqli_result|bool
      */
-    public static function pureQuery (string $query): mysqli_result|bool {
+    public static function pureQuery(string $query): mysqli_result | bool {
         return self::$connection->query($query);
     }
 
@@ -294,7 +294,7 @@ 
      *
      * @return mysqli_result|bool
      */
-    public static function query (string $query, array $vars = [], bool $need_result = true): mysqli_result|bool {
+    public static function query(string $query, array $vars = [], bool $need_result = true): mysqli_result | bool {
         if (empty($vars)) {
             return self::pureQuery($query);
         }
@@ -311,7 +311,7 @@ 
                 $types .= 's';
             }
         }
-        $prepare->bind_param($types,...$vars);
+        $prepare->bind_param($types, ...$vars);
         if (!$prepare->execute()) {
             logger::write(loggerTypes::WARNING, $prepare->error);
             return false;
@@ -358,8 +358,8 @@ 
                 else {
                     $query .= ' AND';
                 }
-                $operator = substr($sub_value,0,2);
-                $operator_value = substr($sub_value,2);
+                $operator = substr($sub_value, 0, 2);
+                $operator_value = substr($sub_value, 2);
                 switch ($operator) {
                     case '>=':
                         $query .= " `$name` >= ?";
@@ -386,8 +386,8 @@ 
                         $sub_value = $operator_value;
                         break;
                     case '##':
-                        $operator = substr($operator_value,0,2);
-                        $column = substr($operator_value,2);
+                        $operator = substr($operator_value, 0, 2);
+                        $column = substr($operator_value, 2);
                         $query .= match ($operator) {
                             '>=' => " `$name` >= `$column`",
                             '<=' => " `$name` <= `$column`",
@@ -411,17 +411,17 @@ 
         return $values;
     }
 
-    private static function groupByBuilder(string &$query, string|array $group_by = []): void {
+    private static function groupByBuilder(string &$query, string | array $group_by = []): void {
         if (empty($group_by)) {
             return;
         }
         if (is_string($group_by)) {
             $group_by = [$group_by];
         }
-        $query .= ' GROUP BY `' . implode('`, `',$group_by) . '`';
+        $query .= ' GROUP BY `'.implode('`, `', $group_by).'`';
     }
 
-    private static function orderByBuilder(string &$query, string|array $order_by = []): void {
+    private static function orderByBuilder(string &$query, string | array $order_by = []): void {
         if (empty($order_by)) {
             return;
         }
@@ -474,8 +474,8 @@ 
                 continue;
             }
 
-            $operator = substr($value,0,2);
-            $operator_value = substr($value,2);
+            $operator = substr($value, 0, 2);
+            $operator_value = substr($value, 2);
             switch ($operator) {
                 case '+=':
                     $query .= " `$name` = `$name` + ?";
@@ -508,14 +508,14 @@ 
         return $values;
     }
 
-    private static function insertBuilder(string &$query, string|array $columns, array|string $values): array {
-        $query .= '(`' . (is_string($columns) ? $columns : implode('`, `', $columns)) . '`) VALUES (';
+    private static function insertBuilder(string &$query, string | array $columns, array | string $values): array {
+        $query .= '(`'.(is_string($columns) ? $columns : implode('`, `', $columns)).'`) VALUES (';
         if (is_string($values)) $values = [$values];
-        $query .= '?' . str_repeat(', ?', count($values) - 1) . ')';
+        $query .= '?'.str_repeat(', ?', count($values) - 1).')';
         return $values;
     }
 
-    private static function selectBuilder (string &$query, string|array $columns): void {
+    private static function selectBuilder(string &$query, string | array $columns): void {
         if ($columns == '*') {
             $query .= ' * ';
             return;
@@ -534,7 +534,7 @@ 
                     $formatted = '*';
                     $column = 'all';
                 }
-                $query .= strtoupper($function) . "($formatted) as `{$function}_$column`";
+                $query .= strtoupper($function)."($formatted) as `{$function}_$column`";
             }
             else {
                 $query .= "`$column`";
@@ -559,7 +559,7 @@ 
      *
      * @return bool
      */
-    public static function delete (string $table, array $where = null, int $count = null, int $offset = null, bool $ignore_default_where = false): bool {
+    public static function delete(string $table, array $where = null, int $count = null, int $offset = null, bool $ignore_default_where = false): bool {
         $query = "DELETE FROM `$table`";
         $vars = self::whereBuilder($query, $where, $ignore_default_where);
         self::countBuilder($query, $count, $offset);
@@ -579,7 +579,7 @@ 
      *
      * @return bool
      */
-    public static function update (string $table, array $modify, array $where = null, int $count = null, int $offset = null, bool $ignore_default_where = false): bool {
+    public static function update(string $table, array $modify, array $where = null, int $count = null, int $offset = null, bool $ignore_default_where = false): bool {
         $query = "UPDATE `$table` SET";
         $modify_vars = self::updateBuilder($query, $modify);
         $where_vars = self::whereBuilder($query, $where, $ignore_default_where);
@@ -598,7 +598,7 @@ 
      *
      * @return bool
      */
-    public static function insert (string $table, string|array $columns, array|string $values): bool {
+    public static function insert(string $table, string | array $columns, array | string $values): bool {
         $query = "INSERT INTO `$table`";
         $values = self::insertBuilder($query, $columns, $values);
         return self::query($query, $values, false);
@@ -621,7 +621,7 @@ 
      *
      * @return bool
      */
-    public static function insertUpdate (string $table, string|array $columns, array|string $values, array $modify): bool {
+    public static function insertUpdate(string $table, string | array $columns, array | string $values, array $modify): bool {
         $query = "INSERT INTO `$table`";
         $values = self::insertBuilder($query, $columns, $values);
         $query .= ' ON DUPLICATE KEY UPDATE';
@@ -646,14 +646,14 @@ 
      *
      * @return mysqli_result|bool
      */
-    public static function select (string $table, array|string $columns = '*', array $where = null, int $count = null, int $offset = null, array|string $group_by = [], array|string $order_by = [], bool $ignore_default_where = false): mysqli_result|bool {
+    public static function select(string $table, array | string $columns = '*', array $where = null, int $count = null, int $offset = null, array | string $group_by = [], array | string $order_by = [], bool $ignore_default_where = false): mysqli_result | bool {
         $query = 'SELECT';
         self::selectBuilder($query, $columns);
         $query .= "FROM `$table`";
-        $var = self::whereBuilder($query,$where, $ignore_default_where);
+        $var = self::whereBuilder($query, $where, $ignore_default_where);
         self::groupByBuilder($query, $group_by);
         self::orderByBuilder($query, $order_by);
-        self::countBuilder($query,$count,$offset);
+        self::countBuilder($query, $count, $offset);
         return self::query($query, $var);
     }
 
@@ -670,7 +670,7 @@ 
      *
      * @return null|bool|array
      */
-    public static function selectArray (string $table, array|string $columns = '*', array $where = null, array|string $group_by = [], array|string $order_by = [], bool $ignore_default_where = false): bool|array|null {
+    public static function selectArray(string $table, array | string $columns = '*', array $where = null, array | string $group_by = [], array | string $order_by = [], bool $ignore_default_where = false): bool | array | null {
         $res = self::select($table, $columns, $where, 1, 0, $group_by, $order_by, ignore_default_where: $ignore_default_where);
         if ($res) {
             return $res->fetch_assoc();
@@ -689,7 +689,7 @@ 
      * @param array|string $group_by group result based on these columns
      * @param array|string $order_by order result based on these columns
      */
-    public static function selectObject (string $table, array|string $columns = '*', array $where = null, array|string $group_by = [], array|string $order_by = [], bool $ignore_default_where = false) {
+    public static function selectObject(string $table, array | string $columns = '*', array $where = null, array | string $group_by = [], array | string $order_by = [], bool $ignore_default_where = false) {
         $res = self::select($table, $columns, $where, 1, 0, $group_by, $order_by, ignore_default_where: $ignore_default_where);
         if ($res) {
             return $res->fetch_object();
@@ -713,7 +713,7 @@ 
      *
      * @return bool|Generator
      */
-    public static function selectEach (string $table, array|string $columns = '*', array $where = null, int $count = null, int $offset = null, array|string $group_by = [], array|string $order_by = [], bool $ignore_default_where = false): bool|Generator {
+    public static function selectEach(string $table, array | string $columns = '*', array $where = null, int $count = null, int $offset = null, array | string $group_by = [], array | string $order_by = [], bool $ignore_default_where = false): bool | Generator {
         $res = self::select($table, $columns, $where, $count, $offset, $group_by, $order_by, ignore_default_where: $ignore_default_where);
         if ($res) {
             while ($row = $res->fetch_assoc()) yield $row;
@@ -731,10 +731,10 @@ 
      *
      * @return string if save is true , return file name otherwise return sql data
      */
-    public static function backup (array $wanted_tables = null, bool $table_data = true, bool $save = true, string $file_name = ''): string {
+    public static function backup(array $wanted_tables = null, bool $table_data = true, bool $save = true, string $file_name = ''): string {
         self::setCharset('utf8mb4');
 
-        $tables = array_column(self::query('SHOW TABLES')->fetch_all(),0);
+        $tables = array_column(self::query('SHOW TABLES')->fetch_all(), 0);
         if (!empty($wanted_tables)) {
             $tables = array_intersect($tables, $wanted_tables);
         }
@@ -745,12 +745,12 @@ 
             logger::write('No table founded for backup, if your database has table : check $wanted_tables argument', loggerTypes::WARNING);
         }
         foreach ($tables as $table) {
-            $sql .= self::query("SHOW CREATE TABLE `$table`")->fetch_row()[1] . ";\n\n";
+            $sql .= self::query("SHOW CREATE TABLE `$table`")->fetch_row()[1].";\n\n";
             if ($table_data) {
                 $total_rows = self::query("SELECT COUNT(*) as `cnt` FROM `$table`")->fetch_object()->cnt;
                 for ($i = 0; $i < $total_rows; $i = $i + 1000) {
-                    $sql .= 'INSERT INTO ' . $table . ' VALUES';
-                    $result = self::select($table, '*' , null, 1000, $i);
+                    $sql .= 'INSERT INTO '.$table.' VALUES';
+                    $result = self::select($table, '*', null, 1000, $i);
                     $field_count = $result->field_count;
                     $affected_rows = self::affected_rows();
                     $counter = 1;
@@ -758,12 +758,12 @@ 
                         $sql .= "\n(";
                         for ($column = 0; $column < $field_count; $column++) {
                             $row[$column] = str_replace("\n", "\\n", addslashes($row[$column]));
-                            $sql .= !empty($row[$column]) ? '"' . $row[$column] . '"' : '""';
+                            $sql .= !empty($row[$column]) ? '"'.$row[$column].'"' : '""';
                             if ($column < $field_count - 1) {
                                 $sql .= ',';
                             }
                         }
-                        $sql .= ')' . ($counter == $affected_rows ? ';' : ',');
+                        $sql .= ')'.($counter == $affected_rows ? ';' : ',');
                         $counter++;
                     }
                 }
@@ -779,7 +779,7 @@ 
         }
 
         if (empty($file_name)) {
-            $file_name = self::$db_name . time() . '.sql';
+            $file_name = self::$db_name.time().'.sql';
         }
         file_put_contents($file_name, $sql);
         return $file_name;

Braces +22 added lines, -31 removed lines

@@ -74,17 +74,13 @@ 
         if (self::$auto_process) {
             if (isset(BPT::$update->message)) {
                 self::processMessage(BPT::$update->message);
-            }
-            elseif (isset(BPT::$update->edited_message)) {
+            } elseif (isset(BPT::$update->edited_message)) {
                 self::processMessage(BPT::$update->edited_message);
-            }
-            elseif (isset(BPT::$update->callback_query)) {
+            } elseif (isset(BPT::$update->callback_query)) {
                 self::processCallbackQuery(BPT::$update->callback_query);
-            }
-            elseif (isset(BPT::$update->inline_query)) {
+            } elseif (isset(BPT::$update->inline_query)) {
                 self::processInlineQuery(BPT::$update->inline_query);
-            }
-            elseif (isset(BPT::$update->my_chat_member)) {
+            } elseif (isset(BPT::$update->my_chat_member)) {
                 self::processMyChatMember(BPT::$update->my_chat_member);
             }
         }
@@ -141,8 +137,7 @@ 
         if ($type === chatType::PRIVATE) {
             if ($update->new_chat_member->status === chatMemberStatus::MEMBER) {
                 self::update('users', ['blocked' => false], ['id' => $update->from->id], 1);
-            }
-            else {
+            } else {
                 self::update('users', ['blocked' => true], ['id' => $update->from->id], 1);
             }
         }
@@ -162,8 +157,7 @@ 
     public static function addDefaultWhere (array $where): bool {
         if (empty(self::$default_where)) {
             self::$default_where = $where;
-        }
-        else {
+        } else {
             self::$default_where = array_merge(self::$default_where, $where);
         }
         return true;
@@ -303,11 +297,9 @@ 
         foreach ($vars as $var) {
             if (is_int($var)) {
                 $types .= 'i';
-            }
-            elseif (is_double($var)) {
+            } elseif (is_double($var)) {
                 $types .= 'd';
-            }
-            else {
+            } else {
                 $types .= 's';
             }
         }
@@ -335,8 +327,7 @@ 
         foreach ($where as $name => $value) {
             if ($first) {
                 $first = false;
-            }
-            else {
+            } else {
                 $query .= ' AND';
             }
 
@@ -354,8 +345,7 @@ 
             foreach ($value as $sub_value) {
                 if ($sub_first) {
                     $sub_first = false;
-                }
-                else {
+                } else {
                     $query .= ' AND';
                 }
                 $operator = substr($sub_value,0,2);
@@ -435,8 +425,7 @@ 
         foreach ($order_by as $key => $mode) {
             if ($first) {
                 $first = false;
-            }
-            else {
+            } else {
                 $query .= ', ';
             }
             if (is_numeric($key)) {
@@ -450,8 +439,7 @@ 
     private static function countBuilder(string &$query, int $count = null, int $offset = null): void {
         if (!empty($count)) {
             $query .= !empty($offset) ? " LIMIT $offset, $count" : " LIMIT $count";
-        }
-        elseif (!empty($offset)) {
+        } elseif (!empty($offset)) {
             $query .= " OFFSET $offset";
         }
     }
@@ -463,8 +451,7 @@ 
         foreach ($modify as $name => $value) {
             if ($first) {
                 $first = false;
-            }
-            else {
+            } else {
                 $query .= ',';
             }
 
@@ -510,7 +497,9 @@ 
 
     private static function insertBuilder(string &$query, string|array $columns, array|string $values): array {
         $query .= '(`' . (is_string($columns) ? $columns : implode('`, `', $columns)) . '`) VALUES (';
-        if (is_string($values)) $values = [$values];
+        if (is_string($values)) {
+            $values = [$values];
+        }
         $query .= '?' . str_repeat(', ?', count($values) - 1) . ')';
         return $values;
     }
@@ -535,8 +524,7 @@ 
                     $column = 'all';
                 }
                 $query .= strtoupper($function) . "($formatted) as `{$function}_$column`";
-            }
-            else {
+            } else {
                 $query .= "`$column`";
             }
 
@@ -716,9 +704,12 @@ 
     public static function selectEach (string $table, array|string $columns = '*', array $where = null, int $count = null, int $offset = null, array|string $group_by = [], array|string $order_by = [], bool $ignore_default_where = false): bool|Generator {
         $res = self::select($table, $columns, $where, $count, $offset, $group_by, $order_by, ignore_default_where: $ignore_default_where);
         if ($res) {
-            while ($row = $res->fetch_assoc()) yield $row;
+            while ($row = $res->fetch_assoc()) {
+                yield $row;
+            }
+        } else {
+            return $res;
         }
-        else return $res;
     }
 
     /**