BPTproto / BPT-Multi

src/database/mysql.php

Spacing +27 added lines, -27 removed lines

@@ -27,7 +27,7 @@ 
     /**
      * @internal Only for BPT self usage , Don't use it in your source!
      */
-    public static function init (): void {
+    public static function init(): void {
         $host = settings::$db['host'] ?? 'localhost';
         $port = settings::$db['port'] ?? 3306;
         $user = settings::$db['user'] ?? settings::$db['username'] ?? 'unknown';
@@ -36,7 +36,7 @@ 
         $dbname = settings::$db['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')) {
@@ -44,7 +44,7 @@ 
         }
     }
 
-    private static function install (): void {
+    private static function install(): void {
         self::pureQuery("
 CREATE TABLE `users`
 (
@@ -65,7 +65,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);
@@ -85,7 +85,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;
@@ -111,7 +111,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;
@@ -121,7 +121,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;
@@ -131,7 +131,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) {
@@ -148,7 +148,7 @@ 
      *
      * @return mysqli
      */
-    public static function getMysqli (): mysqli {
+    public static function getMysqli(): mysqli {
         return self::$connection;
     }
 
@@ -157,7 +157,7 @@ 
      *
      * @return int|string
      */
-    public static function affected_rows (): int|string {
+    public static function affected_rows(): int | string {
         return self::$connection->affected_rows;
     }
 
@@ -166,7 +166,7 @@ 
      *
      * @return int|string
      */
-    public static function insert_id (): int|string {
+    public static function insert_id(): int | string {
         return self::$connection->insert_id;
     }
 
@@ -177,7 +177,7 @@ 
      *
      * @return string
      */
-    public static function escapeString (string $text): string {
+    public static function escapeString(string $text): string {
         return self::$connection->real_escape_string($text);
     }
 
@@ -192,7 +192,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);
     }
 
@@ -211,7 +211,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 {
         $prepare = self::$connection->prepare($query);
         $types = '';
         foreach ($vars as $var) {
@@ -225,7 +225,7 @@ 
                 $types .= 's';
             }
         }
-        $prepare->bind_param($types,...$vars);
+        $prepare->bind_param($types, ...$vars);
         if (!$prepare->execute()) {
             logger::write(loggerTypes::WARNING, $prepare->error);
             return false;
@@ -233,7 +233,7 @@ 
         return $need_result ? $prepare->get_result() : true;
     }
 
-    private static function makeArrayReady (string &$query, array $array, string $operator = ' AND '): array {
+    private static function makeArrayReady(string &$query, array $array, string $operator = ' AND '): array {
         $first = true;
         $values = [];
         foreach ($array as $name => $value) {
@@ -249,7 +249,7 @@ 
         return $values;
     }
 
-    private static function makeQueryReady (string &$query, array $where = null, int $count = null, int $offset = null): array {
+    private static function makeQueryReady(string &$query, array $where = null, int $count = null, int $offset = null): array {
         $values = [];
         if (!empty($where)) {
             $query .= " WHERE";
@@ -276,7 +276,7 @@ 
      *
      * @return mysqli_result|bool
      */
-    public static function delete (string $table, array $where = null, int $count = null, int $offset = null): mysqli_result|bool {
+    public static function delete(string $table, array $where = null, int $count = null, int $offset = null): mysqli_result | bool {
         $query = "DELETE FROM `$table`";
         $res = self::makeQueryReady($query, $where, $count, $offset);
         return self::query($query, $res, false);
@@ -295,7 +295,7 @@ 
      *
      * @return mysqli_result|bool
      */
-    public static function update (string $table, array $modify, array $where = null, int $count = null, int $offset = null): mysqli_result|bool {
+    public static function update(string $table, array $modify, array $where = null, int $count = null, int $offset = null): mysqli_result | bool {
         $query = "UPDATE `$table` SET";
         $values = self::makeArrayReady($query, $modify, ', ');
         $res = self::makeQueryReady($query, $where, $count, $offset);
@@ -313,11 +313,11 @@ 
      *
      * @return mysqli_result|bool
      */
-    public static function insert (string $table, string|array $columns, array|string $values): mysqli_result|bool {
+    public static function insert(string $table, string | array $columns, array | string $values): mysqli_result | bool {
         $query = "INSERT INTO `$table`(";
-        $query .= '`' . (is_string($columns) ? $columns : implode('`,`', $columns)) . '`) VALUES (';
+        $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 self::query($query, $values, false);
     }
 
@@ -336,13 +336,13 @@ 
      *
      * @return mysqli_result|bool
      */
-    public static function select (string $table, array|string $columns = '*', array $where = null, int $count = null, int $offset = null): mysqli_result|bool {
+    public static function select(string $table, array | string $columns = '*', array $where = null, int $count = null, int $offset = null): mysqli_result | bool {
         $query = "SELECT ";
         if ($columns == '*') {
             $query .= "* ";
         }
         else {
-            $query .= '`' . (is_string($columns) ? $columns : implode('`,`', $columns)) . '` ';
+            $query .= '`'.(is_string($columns) ? $columns : implode('`,`', $columns)).'` ';
         }
         $query .= "FROM `$table`";
         $res = self::makeQueryReady($query, $where, $count, $offset);
@@ -360,7 +360,7 @@ 
      *
      * @return null|bool|array
      */
-    public static function selectArray (string $table, array|string $columns = '*', array $where = null): bool|array|null {
+    public static function selectArray(string $table, array | string $columns = '*', array $where = null): bool | array | null {
         $res = self::select($table, $columns, $where, 1);
         if ($res) {
             return $res->fetch_assoc();
@@ -377,7 +377,7 @@ 
      * @param array|string $columns sets column that you want to retrieve , set '*' to retrieve all , default : '*'
      * @param array|null   $where   Set your ifs default : null
      */
-    public static function selectObject (string $table, array|string $columns = '*', array $where = null) {
+    public static function selectObject(string $table, array | string $columns = '*', array $where = null) {
         $res = self::select($table, $columns, $where, 1);
         if ($res) {
             return $res->fetch_object();
@@ -399,7 +399,7 @@ 
      *
      * @return bool|Generator
      */
-    public static function selectEach (string $table, array|string $columns = '*', array $where = null, int $count = null, int $offset = null): bool|Generator {
+    public static function selectEach(string $table, array | string $columns = '*', array $where = null, int $count = null, int $offset = null): bool | Generator {
         $res = self::select($table, $columns, $where, $count, $offset);
         if ($res) {
             while ($row = $res->fetch_assoc()) yield $row;

Braces +18 added lines, -23 removed lines

@@ -69,17 +69,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);
             }
         }
@@ -136,8 +132,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);
             }
         }
@@ -217,11 +212,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';
             }
         }
@@ -239,8 +232,7 @@ 
         foreach ($array as $name => $value) {
             if ($first) {
                 $first = false;
-            }
-            else {
+            } else {
                 $query .= $operator;
             }
             $query .= " `$name` = ?";
@@ -257,8 +249,7 @@ 
         }
         if (!empty($count)) {
             $query .= !empty($offset) ? " LIMIT $offset,$count" : " LIMIT $count";
-        }
-        elseif (!empty($offset)) {
+        } elseif (!empty($offset)) {
             $query .= " OFFSET $offset";
         }
         return $values;
@@ -316,7 +307,9 @@ 
     public static function insert (string $table, string|array $columns, array|string $values): mysqli_result|bool {
         $query = "INSERT INTO `$table`(";
         $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 self::query($query, $values, false);
     }
@@ -340,8 +333,7 @@ 
         $query = "SELECT ";
         if ($columns == '*') {
             $query .= "* ";
-        }
-        else {
+        } else {
             $query .= '`' . (is_string($columns) ? $columns : implode('`,`', $columns)) . '` ';
         }
         $query .= "FROM `$table`";
@@ -402,8 +394,11 @@ 
     public static function selectEach (string $table, array|string $columns = '*', array $where = null, int $count = null, int $offset = null): bool|Generator {
         $res = self::select($table, $columns, $where, $count, $offset);
         if ($res) {
-            while ($row = $res->fetch_assoc()) yield $row;
+            while ($row = $res->fetch_assoc()) {
+                yield $row;
+            }
+        } else {
+            return $res;
         }
-        else return $res;
     }
 }
\ No newline at end of file