@@ -58,11 +58,9 @@ discard block |
||
| 58 | 58 | foreach ($settings as $setting => $value) { |
| 59 | 59 | try{ |
| 60 | 60 | self::$$setting = $value; |
| 61 | - } |
|
| 62 | - catch (TypeError){ |
|
| 61 | + } catch (TypeError){ |
|
| 63 | 62 | logger::write("$setting setting has wrong type , its set to default value",loggerTypes::WARNING); |
| 64 | - } |
|
| 65 | - catch (Error){ |
|
| 63 | + } catch (Error){ |
|
| 66 | 64 | logger::write("$setting setting is not one of library settings",loggerTypes::WARNING); |
| 67 | 65 | } |
| 68 | 66 | } |
@@ -75,13 +73,11 @@ discard block |
||
| 75 | 73 | if (!empty(self::$receiver)) { |
| 76 | 74 | self::$receiver !== receiver::GETUPDATES ? self::webhook() : self::getUpdates(); |
| 77 | 75 | } |
| 78 | - } |
|
| 79 | - else { |
|
| 76 | + } else { |
|
| 80 | 77 | logger::write('token format is not right, check it and try again',loggerTypes::ERROR); |
| 81 | 78 | throw new bptException('TOKEN_NOT_TRUE'); |
| 82 | 79 | } |
| 83 | - } |
|
| 84 | - else { |
|
| 80 | + } else { |
|
| 85 | 81 | logger::write('You must specify token parameter in settings',loggerTypes::ERROR); |
| 86 | 82 | throw new bptException('TOKEN_NOT_FOUND'); |
| 87 | 83 | } |
@@ -138,8 +134,7 @@ discard block |
||
| 138 | 134 | private static function getUpdates() { |
| 139 | 135 | if (self::$handler) { |
| 140 | 136 | getUpdates::init(); |
| 141 | - } |
|
| 142 | - else { |
|
| 137 | + } else { |
|
| 143 | 138 | logger::write('You can\'t use getUpdates receiver when handler is off , use webhook or use handler',loggerTypes::ERROR); |
| 144 | 139 | throw new bptException('GETUPDATE_NEED_HANDLER'); |
| 145 | 140 | } |
@@ -23,8 +23,7 @@ |
||
| 23 | 23 | $update = file_get_contents($up); |
| 24 | 24 | unlink($up); |
| 25 | 25 | return $update; |
| 26 | - } |
|
| 27 | - else { |
|
| 26 | + } else { |
|
| 28 | 27 | logger::write('not authorized access denied. IP : '. $_SERVER['REMOTE_ADDR'] ?? 'unknown',loggerTypes::WARNING); |
| 29 | 28 | BPT::exit(); |
| 30 | 29 | } |
@@ -13,8 +13,7 @@ |
||
| 13 | 13 | public static function init (): string|null { |
| 14 | 14 | if (self::checkIP()) { |
| 15 | 15 | return self::getUpdate(); |
| 16 | - } |
|
| 17 | - else { |
|
| 16 | + } else { |
|
| 18 | 17 | logger::write('not authorized access denied. IP : '. $_SERVER['REMOTE_ADDR'] ?? 'unknown',loggerTypes::WARNING); |
| 19 | 18 | BPT::exit(); |
| 20 | 19 | } |
@@ -12,11 +12,9 @@ |
||
| 12 | 12 | public static function init() { |
| 13 | 13 | if (lock::exist('BPT-MULTI-EXEC')) { |
| 14 | 14 | self::setUpdate(exec::init()); |
| 15 | - } |
|
| 16 | - elseif(lock::exist('BPT-MULTI-CURL')) { |
|
| 15 | + } elseif(lock::exist('BPT-MULTI-CURL')) { |
|
| 17 | 16 | self::setUpdate(curl::init()); |
| 18 | - } |
|
| 19 | - else { |
|
| 17 | + } else { |
|
| 20 | 18 | self::deleteOldLocks(); |
| 21 | 19 | self::checkURL(); |
| 22 | 20 | self::setCertificate(); |
@@ -34,8 +34,7 @@ discard block |
||
| 34 | 34 | if (!$update) { |
| 35 | 35 | BPT::exit(); |
| 36 | 36 | } |
| 37 | - } |
|
| 38 | - elseif (!is_a($update,'update')) { |
|
| 37 | + } elseif (!is_a($update,'update')) { |
|
| 39 | 38 | $update = new update($update); |
| 40 | 39 | } |
| 41 | 40 | |
@@ -72,26 +71,21 @@ discard block |
||
| 72 | 71 | if (self::handlerExist('message')) { |
| 73 | 72 | BPT::$handler->message(BPT::$update->message); |
| 74 | 73 | } |
| 75 | - } |
|
| 76 | - elseif (isset(BPT::$update->callback_query)) { |
|
| 74 | + } elseif (isset(BPT::$update->callback_query)) { |
|
| 77 | 75 | if (self::handlerExist('callback_query')) { |
| 78 | 76 | BPT::$handler->callback_query(BPT::$update->callback_query); |
| 79 | 77 | } |
| 80 | - } |
|
| 81 | - elseif (isset(BPT::$update->inline_query)) { |
|
| 78 | + } elseif (isset(BPT::$update->inline_query)) { |
|
| 82 | 79 | if (self::handlerExist('inline_query')) { |
| 83 | 80 | BPT::$handler->inline_query(BPT::$update->inline_query); |
| 84 | 81 | } |
| 85 | - } |
|
| 86 | - elseif (isset(BPT::$update->edited_message)) { |
|
| 82 | + } elseif (isset(BPT::$update->edited_message)) { |
|
| 87 | 83 | if (self::handlerExist('edited_message')) { |
| 88 | 84 | BPT::$handler->edited_message(BPT::$update->edited_message); |
| 89 | 85 | } |
| 90 | - } |
|
| 91 | - elseif (self::handlerExist('something_else')) { |
|
| 86 | + } elseif (self::handlerExist('something_else')) { |
|
| 92 | 87 | BPT::$handler->something_else(BPT::$update); |
| 93 | - } |
|
| 94 | - else { |
|
| 88 | + } else { |
|
| 95 | 89 | logger::write('Update received but handlers does not set',loggerTypes::WARNING); |
| 96 | 90 | } |
| 97 | 91 | } |
@@ -22,8 +22,7 @@ discard block |
||
| 22 | 22 | self::handleUpdates($updates); |
| 23 | 23 | lock::save('getUpdate',BPT::$update->update_id+1); |
| 24 | 24 | $last_update_id = BPT::$update->update_id+1; |
| 25 | - } |
|
| 26 | - else { |
|
| 25 | + } else { |
|
| 27 | 26 | logger::write("There is some problem happened , telegram response : \n".json_encode($updates),loggerTypes::ERROR); |
| 28 | 27 | BPT::exit(print_r($updates,true)); |
| 29 | 28 | } |
@@ -34,8 +33,7 @@ discard block |
||
| 34 | 33 | private static function loadData(): bool|int|string { |
| 35 | 34 | if (lock::exist('getUpdate')) { |
| 36 | 35 | $last_update_id = lock::read('getUpdate'); |
| 37 | - } |
|
| 38 | - else { |
|
| 36 | + } else { |
|
| 39 | 37 | self::deleteOldLocks(); |
| 40 | 38 | telegram::deleteWebhook(); |
| 41 | 39 | $last_update_id = 0; |
@@ -16,15 +16,13 @@ discard block |
||
| 16 | 16 | public static function init () { |
| 17 | 17 | if (settings::$multi) { |
| 18 | 18 | multi::init(); |
| 19 | - } |
|
| 20 | - else { |
|
| 19 | + } else { |
|
| 21 | 20 | if (lock::exist('BPT-HOOK')) { |
| 22 | 21 | receiver::telegramVerify(); |
| 23 | 22 | self::checkSecret(); |
| 24 | 23 | receiver::processUpdate(); |
| 25 | 24 | logger::write('Update received , lets process it ;)'); |
| 26 | - } |
|
| 27 | - else { |
|
| 25 | + } else { |
|
| 28 | 26 | self::processSetWebhook(); |
| 29 | 27 | } |
| 30 | 28 | } |
@@ -46,8 +44,7 @@ discard block |
||
| 46 | 44 | $res = telegram::setWebhook($url, settings::$certificate, max_connections:settings::$max_connection, allowed_updates : settings::$allowed_updates, secret_token: $secret); |
| 47 | 45 | if (telegram::$status) { |
| 48 | 46 | logger::write('Webhook was set successfully',loggerTypes::INFO); |
| 49 | - } |
|
| 50 | - else { |
|
| 47 | + } else { |
|
| 51 | 48 | logger::write("There is some problem happened , telegram response : \n".json_encode($res),loggerTypes::ERROR); |
| 52 | 49 | BPT::exit(print_r($res,true)); |
| 53 | 50 | } |
@@ -69,8 +66,7 @@ discard block |
||
| 69 | 66 | if (is_string(settings::$certificate)) { |
| 70 | 67 | if (file_exists(settings::$certificate)) { |
| 71 | 68 | settings::$certificate = new CURLFile(settings::$certificate); |
| 72 | - } |
|
| 73 | - else { |
|
| 69 | + } else { |
|
| 74 | 70 | settings::$certificate = null; |
| 75 | 71 | } |
| 76 | 72 | } |
@@ -35,8 +35,7 @@ discard block |
||
| 35 | 35 | $curl_handler = curl_init(settings::$base_url."$token/"); |
| 36 | 36 | curl_setopt($curl_handler, CURLOPT_RETURNTRANSFER, true); |
| 37 | 37 | curl_setopt($curl_handler, CURLOPT_SSL_VERIFYPEER, false); |
| 38 | - } |
|
| 39 | - else{ |
|
| 38 | + } else{ |
|
| 40 | 39 | $token = settings::$token; |
| 41 | 40 | if (!isset(self::$curl_handler)){ |
| 42 | 41 | self::$curl_handler = curl_init(settings::$base_url."$token/"); |
@@ -58,11 +57,9 @@ discard block |
||
| 58 | 57 | if (isset($data['forgot'])) { |
| 59 | 58 | curl_setopt($curl_handler, CURLOPT_TIMEOUT_MS, settings::$forgot_time); |
| 60 | 59 | unset($data['forgot']); |
| 61 | - } |
|
| 62 | - elseif ($method === 'getUpdates'){ |
|
| 60 | + } elseif ($method === 'getUpdates'){ |
|
| 63 | 61 | curl_setopt($curl_handler, CURLOPT_TIMEOUT_MS, 5000); |
| 64 | - } |
|
| 65 | - else{ |
|
| 62 | + } else{ |
|
| 66 | 63 | curl_setopt($curl_handler, CURLOPT_TIMEOUT_MS, 300); |
| 67 | 64 | } |
| 68 | 65 | } |
@@ -34,8 +34,7 @@ discard block |
||
| 34 | 34 | if(settings::$receiver === receiver::GETUPDATES) { |
| 35 | 35 | logger::write('Answer mode only work when receiver is webhook',loggerTypes::ERROR); |
| 36 | 36 | throw new bptException('ANSWER_MODE_GETUPDATES'); |
| 37 | - } |
|
| 38 | - elseif(settings::$multi) { |
|
| 37 | + } elseif(settings::$multi) { |
|
| 39 | 38 | logger::write('You can not use answer mode when multi setting is on',loggerTypes::ERROR); |
| 40 | 39 | throw new bptException('ANSWER_MODE_MULTI'); |
| 41 | 40 | } |
@@ -49,8 +48,7 @@ discard block |
||
| 49 | 48 | foreach ($data as $key=>&$value){ |
| 50 | 49 | if (!isset($value)){ |
| 51 | 50 | unset($data[$key]); |
| 52 | - } |
|
| 53 | - elseif (is_array($value) || is_object($value)){ |
|
| 51 | + } elseif (is_array($value) || is_object($value)){ |
|
| 54 | 52 | $value = json_encode($value); |
| 55 | 53 | } |
| 56 | 54 | } |