BPTproto / BPT-Multi

src/settings.php

Spacing +13 added lines, -13 removed lines

@@ -21,7 +21,7 @@ 
 
     public static int $log_size = 10;
 
-    public static string|CURLFile|null $certificate = null;
+    public static string | CURLFile | null $certificate = null;
 
     public static bool $handler = true;
 
@@ -45,10 +45,10 @@ 
 
     public static array $allowed_updates = ['message', 'edited_channel_post', 'callback_query', 'inline_query'];
 
-    public static array|mysqli|null $db = ['type' => 'json', 'file_name' => 'BPT-DB.json'];
+    public static array | mysqli | null $db = ['type' => 'json', 'file_name' => 'BPT-DB.json'];
 
 
-    public static function init (array|stdClass $settings) {
+    public static function init(array | stdClass $settings) {
         $settings = (array) $settings;
 
         if (!(isset($settings['logger']) && $settings['logger'] == false)) {
@@ -56,14 +56,14 @@ 
         }
 
         foreach ($settings as $setting => $value) {
-            try{
+            try {
                 self::$$setting = $value;
             }
-            catch (TypeError){
-                logger::write("$setting setting has wrong type , its set to default value",loggerTypes::WARNING);
+            catch (TypeError) {
+                logger::write("$setting setting has wrong type , its set to default value", loggerTypes::WARNING);
             }
-            catch (Error){
-                logger::write("$setting setting is not one of library settings",loggerTypes::WARNING);
+            catch (Error) {
+                logger::write("$setting setting is not one of library settings", loggerTypes::WARNING);
             }
         }
 
@@ -77,19 +77,19 @@ 
                 }
             }
             else {
-                logger::write('token format is not right, check it and try again',loggerTypes::ERROR);
+                logger::write('token format is not right, check it and try again', loggerTypes::ERROR);
                 throw new bptException('TOKEN_NOT_TRUE');
             }
         }
         else {
-            logger::write('You must specify token parameter in settings',loggerTypes::ERROR);
+            logger::write('You must specify token parameter in settings', loggerTypes::ERROR);
             throw new bptException('TOKEN_NOT_FOUND');
         }
     }
 
     public static function done() {
         if (self::$logger) {
-            $estimated = round((microtime(true)-$_SERVER['REQUEST_TIME_FLOAT'])*1000,2);
+            $estimated = round((microtime(true) - $_SERVER['REQUEST_TIME_FLOAT']) * 1000, 2);
             $status_message = match (true) {
                 $estimated < 100 => 'Excellent',
                 $estimated < 500 => 'Very good',
@@ -121,7 +121,7 @@ 
         if (self::$secure_folder) {
             $address = explode('/', $_SERVER['REQUEST_URI']);
             unset($address[count($address) - 1]);
-            $address = implode('/', $address) . '/BPT.php';
+            $address = implode('/', $address).'/BPT.php';
             $text = "ErrorDocument 404 $address\nErrorDocument 403 $address\n Options -Indexes\n  Order Deny,Allow\nDeny from all\nAllow from 127.0.0.1\n<Files *.php>\n    Order Allow,Deny\n    Allow from all\n</Files>";
             if (!file_exists('.htaccess') || filesize('.htaccess') != strlen($text)) {
                 file_put_contents('.htaccess', $text);
@@ -140,7 +140,7 @@ 
             getUpdates::init();
         }
         else {
-            logger::write('You can\'t use getUpdates receiver when handler is off , use webhook or use handler',loggerTypes::ERROR);
+            logger::write('You can\'t use getUpdates receiver when handler is off , use webhook or use handler', loggerTypes::ERROR);
             throw new bptException('GETUPDATE_NEED_HANDLER');
         }
     }

Braces +5 added lines, -10 removed lines

@@ -58,11 +58,9 @@ 
         foreach ($settings as $setting => $value) {
             try{
                 self::$$setting = $value;
-            }
-            catch (TypeError){
+            } catch (TypeError){
                 logger::write("$setting setting has wrong type , its set to default value",loggerTypes::WARNING);
-            }
-            catch (Error){
+            } catch (Error){
                 logger::write("$setting setting is not one of library settings",loggerTypes::WARNING);
             }
         }
@@ -75,13 +73,11 @@ 
                 if (!empty(self::$receiver)) {
                     self::$receiver !== receiver::GETUPDATES ? self::webhook() : self::getUpdates();
                 }
-            }
-            else {
+            } else {
                 logger::write('token format is not right, check it and try again',loggerTypes::ERROR);
                 throw new bptException('TOKEN_NOT_TRUE');
             }
-        }
-        else {
+        } else {
             logger::write('You must specify token parameter in settings',loggerTypes::ERROR);
             throw new bptException('TOKEN_NOT_FOUND');
         }
@@ -138,8 +134,7 @@ 
     private static function getUpdates() {
         if (self::$handler) {
             getUpdates::init();
-        }
-        else {
+        } else {
             logger::write('You can\'t use getUpdates receiver when handler is off , use webhook or use handler',loggerTypes::ERROR);
             throw new bptException('GETUPDATE_NEED_HANDLER');
         }

src/lock.php

Spacing +4 added lines, -4 removed lines

@@ -11,15 +11,15 @@
         return touch("$name.lock");
     }
 
-    public static function save(string $name, string $data): bool|int {
-        return file_put_contents("$name.lock", $data) && chmod("$name.lock",0640);
+    public static function save(string $name, string $data): bool | int {
+        return file_put_contents("$name.lock", $data) && chmod("$name.lock", 0640);
     }
 
-    public static function read(string $name): bool|string {
+    public static function read(string $name): bool | string {
         return file_get_contents("$name.lock");
     }
 
-    public static function mtime(string $name): bool|int {
+    public static function mtime(string $name): bool | int {
         return filemtime("$name.lock");
     }
 

src/receiver/multi/exec.php

Spacing +5 added lines, -5 removed lines

@@ -10,11 +10,11 @@ 
 use BPT\settings;
 
 class exec extends webhook {
-    public static function init(): string|null {
+    public static function init(): string | null {
         return self::getUpdate();
     }
 
-    private static function getUpdate (): string|null {
+    private static function getUpdate(): string | null {
         $up = glob('*.update');
         if (isset($up[0])) {
             $up = end($up);
@@ -25,7 +25,7 @@ 
             return $update;
         }
         else {
-            logger::write('not authorized access denied. IP : '. $_SERVER['REMOTE_ADDR'] ?? 'unknown',loggerTypes::WARNING);
+            logger::write('not authorized access denied. IP : '.$_SERVER['REMOTE_ADDR'] ?? 'unknown', loggerTypes::WARNING);
             BPT::exit();
         }
     }
@@ -45,11 +45,11 @@ 
     }
 
     private static function create($file) {
-        file_put_contents('receiver.php', '<?php $BPT = file_get_contents("php://input");$id = json_decode($BPT, true)[\'update_id\'];file_put_contents("{$_SERVER[\'REMOTE_ADDR\']}-$id.update",$BPT);exec("php ' . $file . ' > /dev/null &");');
+        file_put_contents('receiver.php', '<?php $BPT = file_get_contents("php://input");$id = json_decode($BPT, true)[\'update_id\'];file_put_contents("{$_SERVER[\'REMOTE_ADDR\']}-$id.update",$BPT);exec("php '.$file.' > /dev/null &");');
     }
 
     private static function setURLS(): array {
-        $base_url = (isset(settings::$certificate) ? 'http://' : 'https://') . $_SERVER['SERVER_NAME'] . $_SERVER['REQUEST_URI'];
+        $base_url = (isset(settings::$certificate) ? 'http://' : 'https://').$_SERVER['SERVER_NAME'].$_SERVER['REQUEST_URI'];
         return [
             'url'=>str_replace(basename($_SERVER['REQUEST_URI']), 'receiver.php', $base_url),
             'file'=>basename($_SERVER['SCRIPT_NAME'])

Braces +1 added lines, -2 removed lines

@@ -23,8 +23,7 @@
             $update = file_get_contents($up);
             unlink($up);
             return $update;
-        }
-        else {
+        } else {
             logger::write('not authorized access denied. IP : '. $_SERVER['REMOTE_ADDR'] ?? 'unknown',loggerTypes::WARNING);
             BPT::exit();
         }

src/receiver/multi/curl.php

Spacing +9 added lines, -9 removed lines

@@ -10,12 +10,12 @@ 
 use BPT\settings;
 
 class curl extends webhook {
-    public static function init (): string|null {
+    public static function init(): string | null {
         if (self::checkIP()) {
             return self::getUpdate();
         }
         else {
-            logger::write('not authorized access denied. IP : '. $_SERVER['REMOTE_ADDR'] ?? 'unknown',loggerTypes::WARNING);
+            logger::write('not authorized access denied. IP : '.$_SERVER['REMOTE_ADDR'] ?? 'unknown', loggerTypes::WARNING);
             BPT::exit();
         }
     }
@@ -24,7 +24,7 @@ 
         return $_SERVER['REMOTE_ADDR'] === $_SERVER['SERVER_ADDR'];
     }
 
-    private static function getUpdate (): string {
+    private static function getUpdate(): string {
         $input = json_decode(file_get_contents("php://input"), true);
         webhook::telegramVerify($input['ip']);
         return $input['update'];
@@ -34,14 +34,14 @@ 
         $urls = self::setURLS();
         $file = $urls['file'];
         $timeout = self::getTimeout($file);
-        self::create($file,$timeout);
+        self::create($file, $timeout);
         self::setWebhook($urls['url']);
         lock::set('BPT-MULTI-CURL');
     }
 
-    private static function getTimeout($url): float|int {
+    private static function getTimeout($url): float | int {
         $times = [];
-        for ($i = 0; $i < 10; $i ++) {
+        for ($i = 0; $i < 10; $i++) {
             $ch = curl_init($url);
             curl_setopt_array($ch, [CURLOPT_POSTFIELDS => json_encode([]), CURLOPT_TIMEOUT_MS => 100, CURLOPT_NOBODY => true, CURLOPT_RETURNTRANSFER => true, CURLOPT_SSL_VERIFYPEER => false, CURLOPT_SSL_VERIFYHOST => false, CURLOPT_CONNECTTIMEOUT_MS => 100, CURLOPT_HTTPHEADER => ['accept: application/json', 'content-type: application/json']]);
             $start = microtime(true);
@@ -52,12 +52,12 @@ 
         return $timeout > 50 ? $timeout + 10 : 50;
     }
 
-    private static function create($file,$timeout) {
-        file_put_contents('receiver.php', '<?php http_response_code(200);ignore_user_abort();$ch = curl_init(\'' . $file . '\');curl_setopt_array($ch, [CURLOPT_POSTFIELDS => json_encode([\'update\'=>file_get_contents(\'php://input\'),\'ip\'=>$_SERVER[\'REMOTE_ADDR\']]), CURLOPT_TIMEOUT_MS => ' . $timeout . ', CURLOPT_RETURNTRANSFER => true, CURLOPT_SSL_VERIFYPEER => false, CURLOPT_SSL_VERIFYHOST => false, CURLOPT_CONNECTTIMEOUT_MS => ' . $timeout . ', CURLOPT_HTTPHEADER => [\'accept: application/json\', \'content-type: application/json\']]);curl_exec($ch);curl_close($ch);?>');
+    private static function create($file, $timeout) {
+        file_put_contents('receiver.php', '<?php http_response_code(200);ignore_user_abort();$ch = curl_init(\''.$file.'\');curl_setopt_array($ch, [CURLOPT_POSTFIELDS => json_encode([\'update\'=>file_get_contents(\'php://input\'),\'ip\'=>$_SERVER[\'REMOTE_ADDR\']]), CURLOPT_TIMEOUT_MS => '.$timeout.', CURLOPT_RETURNTRANSFER => true, CURLOPT_SSL_VERIFYPEER => false, CURLOPT_SSL_VERIFYHOST => false, CURLOPT_CONNECTTIMEOUT_MS => '.$timeout.', CURLOPT_HTTPHEADER => [\'accept: application/json\', \'content-type: application/json\']]);curl_exec($ch);curl_close($ch);?>');
     }
 
     private static function setURLS(): array {
-        $base_url = (isset(settings::$certificate) ? 'http://' : 'https://') . $_SERVER['SERVER_NAME'] . $_SERVER['REQUEST_URI'];
+        $base_url = (isset(settings::$certificate) ? 'http://' : 'https://').$_SERVER['SERVER_NAME'].$_SERVER['REQUEST_URI'];
         $file = basename($_SERVER['REQUEST_URI']);
         return [
             'url'=>str_replace($file, 'receiver.php', $base_url),

Braces +1 added lines, -2 removed lines

@@ -13,8 +13,7 @@
     public static function init (): string|null {
         if (self::checkIP()) {
             return self::getUpdate();
-        }
-        else {
+        } else {
             logger::write('not authorized access denied. IP : '. $_SERVER['REMOTE_ADDR'] ?? 'unknown',loggerTypes::WARNING);
             BPT::exit();
         }

src/receiver/multi.php

Spacing +1 added lines, -1 removed lines

@@ -13,7 +13,7 @@
         if (lock::exist('BPT-MULTI-EXEC')) {
             self::setUpdate(exec::init());
         }
-        elseif(lock::exist('BPT-MULTI-CURL')) {
+        elseif (lock::exist('BPT-MULTI-CURL')) {
             self::setUpdate(curl::init());
         }
         else {

Braces +2 added lines, -4 removed lines

@@ -12,11 +12,9 @@
     public static function init() {
         if (lock::exist('BPT-MULTI-EXEC')) {
             self::setUpdate(exec::init());
-        }
-        elseif(lock::exist('BPT-MULTI-CURL')) {
+        } elseif(lock::exist('BPT-MULTI-CURL')) {
             self::setUpdate(curl::init());
-        }
-        else {
+        } else {
             self::deleteOldLocks();
             self::checkURL();
             self::setCertificate();

src/receiver/receiver.php

Spacing +5 added lines, -5 removed lines

@@ -22,20 +22,20 @@ 
     protected static function telegramVerify(string $ip = null) {
         if (settings::$telegram_verify) {
             if (!tools::isTelegram($ip ?? $_SERVER['REMOTE_ADDR'] ?? '')) {
-                logger::write('not authorized access denied. IP : '. $ip ?? $_SERVER['REMOTE_ADDR'] ?? 'unknown',loggerTypes::WARNING);
+                logger::write('not authorized access denied. IP : '.$ip ?? $_SERVER['REMOTE_ADDR'] ?? 'unknown', loggerTypes::WARNING);
                 BPT::exit();
             }
         }
     }
 
-    protected static function processUpdate(string|stdClass|update $update = null) {
+    protected static function processUpdate(string | stdClass | update $update = null) {
         if (!is_object($update)) {
             $update = json_decode($update ?? file_get_contents("php://input"));
             if (!$update) {
                 BPT::exit();
             }
         }
-        elseif (!is_a($update,'update')) {
+        elseif (!is_a($update, 'update')) {
             $update = new update($update);
         }
 
@@ -44,7 +44,7 @@ 
         self::processHandler();
     }
 
-    protected static function setMessageExtra (update &$update) {
+    protected static function setMessageExtra(update & $update) {
         if ((isset($update->message) && isset($update->message->text)) || (isset($update->edited_message) && isset($update->edited_message->text))) {
             $type = isset($update->message) ? 'message' : 'edited_message';
             $text = &$update->$type->text;
@@ -92,7 +92,7 @@ 
                 BPT::$handler->something_else(BPT::$update);
             }
             else {
-                logger::write('Update received but handlers does not set',loggerTypes::WARNING);
+                logger::write('Update received but handlers does not set', loggerTypes::WARNING);
             }
         }
     }

Braces +6 added lines, -12 removed lines

@@ -34,8 +34,7 @@ 
             if (!$update) {
                 BPT::exit();
             }
-        }
-        elseif (!is_a($update,'update')) {
+        } elseif (!is_a($update,'update')) {
             $update = new update($update);
         }
 
@@ -72,26 +71,21 @@ 
                 if (self::handlerExist('message')) {
                     BPT::$handler->message(BPT::$update->message);
                 }
-            }
-            elseif (isset(BPT::$update->callback_query)) {
+            } elseif (isset(BPT::$update->callback_query)) {
                 if (self::handlerExist('callback_query')) {
                     BPT::$handler->callback_query(BPT::$update->callback_query);
                 }
-            }
-            elseif (isset(BPT::$update->inline_query)) {
+            } elseif (isset(BPT::$update->inline_query)) {
                 if (self::handlerExist('inline_query')) {
                     BPT::$handler->inline_query(BPT::$update->inline_query);
                 }
-            }
-            elseif (isset(BPT::$update->edited_message)) {
+            } elseif (isset(BPT::$update->edited_message)) {
                 if (self::handlerExist('edited_message')) {
                     BPT::$handler->edited_message(BPT::$update->edited_message);
                 }
-            }
-            elseif (self::handlerExist('something_else')) {
+            } elseif (self::handlerExist('something_else')) {
                 BPT::$handler->something_else(BPT::$update);
-            }
-            else {
+            } else {
                 logger::write('Update received but handlers does not set',loggerTypes::WARNING);
             }
         }

src/receiver/getUpdates.php

Spacing +9 added lines, -9 removed lines

@@ -13,25 +13,25 @@ 
 use stdClass;
 
 class getUpdates extends receiver {
-    public static function init () {
+    public static function init() {
         $last_update_id = self::loadData();
-        while(true) {
+        while (true) {
             if (!lock::exist('getUpdate')) {
-                $updates = telegram::getUpdates($last_update_id,allowed_updates: settings::$allowed_updates);
+                $updates = telegram::getUpdates($last_update_id, allowed_updates: settings::$allowed_updates);
                 if (telegram::$status) {
                     self::handleUpdates($updates);
-                    lock::save('getUpdate',BPT::$update->update_id+1);
-                    $last_update_id = BPT::$update->update_id+1;
+                    lock::save('getUpdate', BPT::$update->update_id + 1);
+                    $last_update_id = BPT::$update->update_id + 1;
                 }
                 else {
-                    logger::write("There is some problem happened , telegram response : \n".json_encode($updates),loggerTypes::ERROR);
-                    BPT::exit(print_r($updates,true));
+                    logger::write("There is some problem happened , telegram response : \n".json_encode($updates), loggerTypes::ERROR);
+                    BPT::exit(print_r($updates, true));
                 }
             }
         }
     }
 
-    private static function loadData(): bool|int|string {
+    private static function loadData(): bool | int | string {
         if (lock::exist('getUpdate')) {
             $last_update_id = lock::read('getUpdate');
         }
@@ -39,7 +39,7 @@ 
             self::deleteOldLocks();
             telegram::deleteWebhook();
             $last_update_id = 0;
-            lock::save('getUpdate',0);
+            lock::save('getUpdate', 0);
         }
         return $last_update_id;
     }

Braces +2 added lines, -4 removed lines

@@ -22,8 +22,7 @@ 
                     self::handleUpdates($updates);
                     lock::save('getUpdate',BPT::$update->update_id+1);
                     $last_update_id = BPT::$update->update_id+1;
-                }
-                else {
+                } else {
                     logger::write("There is some problem happened , telegram response : \n".json_encode($updates),loggerTypes::ERROR);
                     BPT::exit(print_r($updates,true));
                 }
@@ -34,8 +33,7 @@ 
     private static function loadData(): bool|int|string {
         if (lock::exist('getUpdate')) {
             $last_update_id = lock::read('getUpdate');
-        }
-        else {
+        } else {
             self::deleteOldLocks();
             telegram::deleteWebhook();
             $last_update_id = 0;

src/receiver/webhook.php

Spacing +10 added lines, -10 removed lines

@@ -13,7 +13,7 @@ 
 use CURLFile;
 
 class webhook extends receiver {
-    public static function init () {
+    public static function init() {
         if (settings::$multi) {
             multi::init();
         }
@@ -42,26 +42,26 @@ 
         }
     }
 
-    protected static function setWebhook(string $url,string $secret = '') {
+    protected static function setWebhook(string $url, string $secret = '') {
         $res = telegram::setWebhook($url, settings::$certificate, max_connections:settings::$max_connection, allowed_updates : settings::$allowed_updates, secret_token: $secret);
         if (telegram::$status) {
-            logger::write('Webhook was set successfully',loggerTypes::INFO);
+            logger::write('Webhook was set successfully', loggerTypes::INFO);
         }
         else {
-            logger::write("There is some problem happened , telegram response : \n".json_encode($res),loggerTypes::ERROR);
-            BPT::exit(print_r($res,true));
+            logger::write("There is some problem happened , telegram response : \n".json_encode($res), loggerTypes::ERROR);
+            BPT::exit(print_r($res, true));
         }
     }
 
     protected static function checkURL() {
         if (!(isset($_SERVER['SERVER_NAME']) && isset($_SERVER['REQUEST_URI']))) {
-            logger::write('For using webhook receiver , you should open this file in your webserver(by domain)',loggerTypes::ERROR);
+            logger::write('For using webhook receiver , you should open this file in your webserver(by domain)', loggerTypes::ERROR);
             throw new bptException('WEBHOOK_NEED_URL');
         }
     }
 
     private static function setURL(): string {
-        return (isset(settings::$certificate) ? 'http://' : 'https://') . $_SERVER['SERVER_NAME'] . $_SERVER['SCRIPT_NAME'];
+        return (isset(settings::$certificate) ? 'http://' : 'https://').$_SERVER['SERVER_NAME'].$_SERVER['SCRIPT_NAME'];
     }
 
     protected static function setCertificate() {
@@ -83,15 +83,15 @@ 
         self::setCertificate();
         $url = self::setURL();
         $secret = tools::randomString(64);
-        self::setWebhook($url,$secret);
-        lock::save('BPT-HOOK',$secret);
+        self::setWebhook($url, $secret);
+        lock::save('BPT-HOOK', $secret);
         BPT::exit('Done');
     }
 
     private static function checkSecret() {
         $secret = lock::read('BPT-HOOK');
         if (!isset($_SERVER['HTTP_X_TELEGRAM_BOT_API_SECRET_TOKEN']) || $_SERVER['HTTP_X_TELEGRAM_BOT_API_SECRET_TOKEN'] != $secret) {
-            logger::write('This is not webhook set by BPT, webhook will reset',loggerTypes::WARNING);
+            logger::write('This is not webhook set by BPT, webhook will reset', loggerTypes::WARNING);
             self::processSetWebhook();
         }
     }

Braces +4 added lines, -8 removed lines

@@ -16,15 +16,13 @@ 
     public static function init () {
         if (settings::$multi) {
             multi::init();
-        }
-        else {
+        } else {
             if (lock::exist('BPT-HOOK')) {
                 receiver::telegramVerify();
                 self::checkSecret();
                 receiver::processUpdate();
                 logger::write('Update received , lets process it ;)');
-            }
-            else {
+            } else {
                 self::processSetWebhook();
             }
         }
@@ -46,8 +44,7 @@ 
         $res = telegram::setWebhook($url, settings::$certificate, max_connections:settings::$max_connection, allowed_updates : settings::$allowed_updates, secret_token: $secret);
         if (telegram::$status) {
             logger::write('Webhook was set successfully',loggerTypes::INFO);
-        }
-        else {
+        } else {
             logger::write("There is some problem happened , telegram response : \n".json_encode($res),loggerTypes::ERROR);
             BPT::exit(print_r($res,true));
         }
@@ -69,8 +66,7 @@ 
             if (is_string(settings::$certificate)) {
                 if (file_exists(settings::$certificate)) {
                     settings::$certificate = new CURLFile(settings::$certificate);
-                }
-                else {
+                } else {
                     settings::$certificate = null;
                 }
             }

src/tools.php

Spacing +2 added lines, -2 removed lines

@@ -2,9 +2,9 @@
 
 namespace BPT;
 
-use BPT\tools\{is,file,convert,generator,encrypt};
+use BPT\tools\{is, file, convert, generator, encrypt};
 
-class tools{
+class tools {
     use is;
     use file;
     use convert;