BPTproto / BPT-Multi

receiver/multi/curl.php

Spacing +9 added lines, -9 removed lines

@@ -9,12 +9,12 @@ 
 use BPT\settings;

 

 class curl extends webhook {

-    public static function init (): string {

+    public static function init(): string {

         if (self::checkIP()) {

             return self::getUpdate();

         }

         else {

-            logger::write('not authorized access denied. IP : '. $_SERVER['REMOTE_ADDR'] ?? 'unknown','error');

+            logger::write('not authorized access denied. IP : '.$_SERVER['REMOTE_ADDR'] ?? 'unknown', 'error');

             BPT::exit();

         }

     }

@@ -23,7 +23,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'];

@@ -33,14 +33,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);

@@ -51,12 +51,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

@@ -12,8 +12,7 @@
     public static function init (): string {

         if (self::checkIP()) {

             return self::getUpdate();

-        }

-        else {

+        } else {

             logger::write('not authorized access denied. IP : '. $_SERVER['REMOTE_ADDR'] ?? 'unknown','error');

             BPT::exit();

         }

receiver/multi/exec.php

Spacing +4 added lines, -4 removed lines

@@ -13,7 +13,7 @@ 
         return self::getUpdate();

     }

 

-    private static function getUpdate (): string {

+    private static function getUpdate(): string {

         $up = glob('*.update');

         if (isset($up[0])) {

             $up = end($up);

@@ -24,7 +24,7 @@ 
             return $update;

         }

         else {

-            logger::write('not authorized access denied. IP : '. $_SERVER['REMOTE_ADDR'] ?? 'unknown','error');

+            logger::write('not authorized access denied. IP : '.$_SERVER['REMOTE_ADDR'] ?? 'unknown', 'error');

             BPT::exit();

         }

     }

@@ -44,11 +44,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'];

         $file = basename($_SERVER['REQUEST_URI']);

         return [

             'url'=>str_replace($file, 'receiver.php', $base_url),

Braces +1 added lines, -2 removed lines

@@ -22,8 +22,7 @@
             $update = file_get_contents($up);

             unlink($up);

             return $update;

-        }

-        else {

+        } else {

             logger::write('not authorized access denied. IP : '. $_SERVER['REMOTE_ADDR'] ?? 'unknown','error');

             BPT::exit();

         }

receiver/webhook.php

Spacing +6 added lines, -6 removed lines

@@ -10,7 +10,7 @@ 
 use CURLFile;

 

 class webhook extends receiver {

-    public static function init () {

+    public static function init() {

         if (settings::$multi) {

             multi::init();

         }

@@ -46,24 +46,24 @@ 
         $res = telegram::setWebhook($url, settings::$certificate, max_connections:settings::$max_connection, allowed_updates : settings::$allowed_updates);

         if ($res->ok) {

             lock::set('BPT');

-            logger::write('Webhook was set successfully','info');

+            logger::write('Webhook was set successfully', 'info');

             BPT::exit('Done');

         }

         else {

-            logger::write("There is some problem happened , telegram response : \n".json_encode($res),'error');

-            BPT::exit(print_r($res,true));

+            logger::write("There is some problem happened , telegram response : \n".json_encode($res), '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)','error');

+            logger::write('For using webhook receiver , you should open this file in your webserver(by domain)', 'error');

             BPT::exit();

         }

     }

 

     private static function setURL(): string {

-        return (isset(settings::$certificate) ? 'http://' : 'https://') . $_SERVER['SERVER_NAME'] . $_SERVER['REQUEST_URI'];

+        return (isset(settings::$certificate) ? 'http://' : 'https://').$_SERVER['SERVER_NAME'].$_SERVER['REQUEST_URI'];

     }

 

     protected static function setCertificate() {

Braces +4 added lines, -8 removed lines

@@ -13,14 +13,12 @@ 
     public static function init () {

         if (settings::$multi) {

             multi::init();

-        }

-        else {

+        } else {

             if (lock::exist('BPT-HOOK')) {

                 receiver::telegramVerify();

                 BPT::$update = receiver::processUpdate();

                 logger::write('Update received , lets process it ;)');

-            }

-            else {

+            } else {

                 self::deleteOldLocks();

                 self::checkURL();

                 self::setCertificate();

@@ -48,8 +46,7 @@ 
             lock::set('BPT');

             logger::write('Webhook was set successfully','info');

             BPT::exit('Done');

-        }

-        else {

+        } else {

             logger::write("There is some problem happened , telegram response : \n".json_encode($res),'error');

             BPT::exit(print_r($res,true));

         }

@@ -71,8 +68,7 @@ 
             if (is_string(settings::$certificate)) {

                 if (file_exists(settings::$certificate)) {

                     settings::$certificate = new CURLFile(settings::$certificate);

-                }

-                else {

+                } else {

                     settings::$certificate = null;

                 }

             }

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();

receiver/receiver.php

Spacing +2 added lines, -2 removed lines

@@ -12,7 +12,7 @@ 
     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','error');

+                logger::write('not authorized access denied. IP : '.$ip ?? $_SERVER['REMOTE_ADDR'] ?? 'unknown', 'error');

                 BPT::exit();

             }

         }

@@ -28,7 +28,7 @@ 
         return $update;

     }

 

-    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;