BPTproto / BPT-Multi

lock.php

Spacing +3 added lines, -3 removed lines

@@ -11,16 +11,16 @@
         return touch("$name.lock");

     }

 

-    public static function save(string $name, string $data): bool|int {

+    public static function save(string $name, string $data): bool | int {

         return file_put_contents("$name.lock", $data);

 

     }

 

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

     }

 

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 {

logger.php

Spacing +3 added lines, -3 removed lines

@@ -10,7 +10,7 @@ 
     private static $handler;

 

 

-    public static function init (int $log_size = 10) {

+    public static function init(int $log_size = 10) {

         self::$log_size = $log_size;

         if (file_exists('BPT.log') && !(filesize('BPT.log') > self::$log_size * 1024 * 1024)) {

             $mode = 'a';

@@ -24,13 +24,13 @@ 
         self::$handler = fopen('BPT.log', $mode);

 

         if ($write) {

-            fwrite(self::$handler,"♥♥♥♥♥♥♥♥♥♥♥♥♥♥ BPT Library  ♥♥♥♥♥♥♥♥♥♥♥♥♥♥\nTnx for using our library\nSome information about us :\nAuthor : @Im_Miaad\nHelper : @A_LiReza_ME\nChannel : @BPT_CH\nOur Website : https://bptlib.ir\n\nIf you have any problem with our library\nContact to our supports\n♥♥♥♥♥♥♥♥♥♥♥♥♥♥ BPT Library  ♥♥♥♥♥♥♥♥♥♥♥♥♥♥\nINFO : BPT Library LOG STARTED ...\nwarning : this file automatically deleted when its size reached log_size setting, do not delete it manually\n\n");

+            fwrite(self::$handler, "♥♥♥♥♥♥♥♥♥♥♥♥♥♥ BPT Library  ♥♥♥♥♥♥♥♥♥♥♥♥♥♥\nTnx for using our library\nSome information about us :\nAuthor : @Im_Miaad\nHelper : @A_LiReza_ME\nChannel : @BPT_CH\nOur Website : https://bptlib.ir\n\nIf you have any problem with our library\nContact to our supports\n♥♥♥♥♥♥♥♥♥♥♥♥♥♥ BPT Library  ♥♥♥♥♥♥♥♥♥♥♥♥♥♥\nINFO : BPT Library LOG STARTED ...\nwarning : this file automatically deleted when its size reached log_size setting, do not delete it manually\n\n");

         }

     }

 

     public static function write(string $data, string $type = loggerTypes::NONE) {

         if (!is_null(self::$handler)) {

-            $text = date('Y/m/d H:i:s') . ( $type === loggerTypes::NONE ? " : $data\n\n" : " : ⤵\n$type : $data\n\n" );

+            $text = date('Y/m/d H:i:s').($type === loggerTypes::NONE ? " : $data\n\n" : " : ⤵\n$type : $data\n\n");

             fwrite(self::$handler, $text);

         }

     }

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),

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'])

api/request/answer.php

Spacing +10 added lines, -10 removed lines

@@ -12,32 +12,32 @@ 
 class answer {

     private static bool $is_answered = false;

 

-    public static function init(string $method,array $data) {

+    public static function init(string $method, array $data) {

         self::checkAnswered();

         self::checkWebhook();

         self::deleteAdditionalData($data);

         self::$is_answered = true;

         $data['method'] = $method;

         $payload = json_encode($data);

-        header('Content-Type: application/json;Content-Length: ' . strlen($payload));

+        header('Content-Type: application/json;Content-Length: '.strlen($payload));

         echo $payload;

         return true;

     }

 

     private static function checkAnswered() {

         if (self::$is_answered) {

-            logger::write('You can use answer mode only once for each webhook update , You already did it!',loggerTypes::ERROR);

+            logger::write('You can use answer mode only once for each webhook update , You already did it!', loggerTypes::ERROR);

             throw new bptException('ANSWER_MODE_USED');

         }

     }

 

     private static function checkWebhook() {

-        if(settings::$receiver === receiver::GETUPDATES) {

-            logger::write('Answer mode only work when receiver is webhook',loggerTypes::ERROR);

+        if (settings::$receiver === receiver::GETUPDATES) {

+            logger::write('Answer mode only work when receiver is webhook', loggerTypes::ERROR);

             throw new bptException('ANSWER_MODE_GETUPDATES');

         }

-        elseif(settings::$multi) {

-            logger::write('You can not use answer mode when multi setting is on',loggerTypes::ERROR);

+        elseif (settings::$multi) {

+            logger::write('You can not use answer mode when multi setting is on', loggerTypes::ERROR);

             throw new bptException('ANSWER_MODE_MULTI');

         }

     }

@@ -52,11 +52,11 @@ 
         if (isset($data['return_array'])) {

             unset($data['return_array']);

         }

-        foreach ($data as $key=>&$value){

-            if (!isset($value)){

+        foreach ($data as $key=>&$value) {

+            if (!isset($value)) {

                 unset($data[$key]);

             }

-            elseif (is_array($value) || (is_object($value) && !is_a($value,'CURLFile'))){

+            elseif (is_array($value) || (is_object($value) && !is_a($value, 'CURLFile'))) {

                 $value = json_encode($value);

             }

         }

api/request/curl.php

Spacing +10 added lines, -10 removed lines

@@ -10,17 +10,17 @@ 
 class curl {

     private static CurlHandle $curl_handler;

 

-    public static function init(string $method,array $data) {

+    public static function init(string $method, array $data) {

         $info = self::getInfo($data);

         $data = $info['data'];

         $handler = $info['handler'];

-        self::setTimeout($data,$handler,$method);

+        self::setTimeout($data, $handler, $method);

         self::setData($data);

         $data['method'] = $method;

         curl_setopt($handler, CURLOPT_POSTFIELDS, $data);

         $result = curl_exec($handler);

         if (curl_errno($handler)) {

-            logger::write(curl_error($handler),loggerTypes::WARNING);

+            logger::write(curl_error($handler), loggerTypes::WARNING);

         }

         if ($info['token'] != settings::$token) {

             curl_close($handler);

@@ -36,9 +36,9 @@ 
             curl_setopt($curl_handler, CURLOPT_RETURNTRANSFER, true);

             curl_setopt($curl_handler, CURLOPT_SSL_VERIFYPEER, false);

         }

-        else{

+        else {

             $token = settings::$token;

-            if (!isset(self::$curl_handler)){

+            if (!isset(self::$curl_handler)) {

                 self::$curl_handler = curl_init(settings::$base_url."$token/");

                 curl_setopt(self::$curl_handler, CURLOPT_RETURNTRANSFER, true);

                 curl_setopt(self::$curl_handler, CURLOPT_SSL_VERIFYPEER, false);

@@ -54,22 +54,22 @@ 
         ];

     }

 

-    private static function setTimeout(array &$data , CurlHandle $curl_handler,string $method) {

+    private static function setTimeout(array &$data, CurlHandle $curl_handler, string $method) {

         if (isset($data['forgot'])) {

             curl_setopt($curl_handler, CURLOPT_TIMEOUT_MS, settings::$forgot_time);

             unset($data['forgot']);

         }

-        elseif ($method === 'getUpdates'){

+        elseif ($method === 'getUpdates') {

             curl_setopt($curl_handler, CURLOPT_TIMEOUT_MS, 5000);

         }

-        else{

+        else {

             curl_setopt($curl_handler, CURLOPT_TIMEOUT_MS, 300);

         }

     }

 

     private static function setData(array &$data) {

-        foreach ($data as &$value){

-            if (is_array($value) || (is_object($value) && !is_a($value,'CURLFile'))){

+        foreach ($data as &$value) {

+            if (is_array($value) || (is_object($value) && !is_a($value, 'CURLFile'))) {

                 $value = json_encode($value);

             }

         }

api/telegram.php

Spacing +1 added lines, -1 removed lines

@@ -3,7 +3,7 @@
 namespace BPT\api;

 

 class telegram extends request {

-    public function __call (string $name, array $arguments) {

+    public function __call(string $name, array $arguments) {

         if (!isset($arguments[1]) && isset($arguments[0]) && is_array($arguments[0])) {

             return request::$name(...$arguments[0]);

         }

exception/bptException.php

Spacing +1 added lines, -1 removed lines

@@ -4,4 +4,4 @@
 

 use Exception;

 

-class bptException extends Exception{}
\ No newline at end of file
+class bptException extends Exception {}
\ No newline at end of file