@@ -41,13 +41,13 @@ discard block |
||
| 41 | 41 | } |
| 42 | 42 | |
| 43 | 43 | if (!tools::isTelegram($ip ?? '')) { |
| 44 | - logger::write('not authorized access denied. IP : '. $ip ?? 'unknown',loggerTypes::WARNING); |
|
| 44 | + logger::write('not authorized access denied. IP : '.$ip ?? 'unknown', loggerTypes::WARNING); |
|
| 45 | 45 | BPT::exit(); |
| 46 | 46 | } |
| 47 | 47 | } |
| 48 | 48 | } |
| 49 | 49 | |
| 50 | - protected static function processUpdate(string|stdClass|update $update = null): void { |
|
| 50 | + protected static function processUpdate(string | stdClass | update $update = null): void { |
|
| 51 | 51 | if (!is_object($update)) { |
| 52 | 52 | $update = json_decode($update ?? file_get_contents("php://input")); |
| 53 | 53 | if (!$update) { |
@@ -55,7 +55,7 @@ discard block |
||
| 55 | 55 | } |
| 56 | 56 | } |
| 57 | 57 | |
| 58 | - if (!is_a($update,'update')) { |
|
| 58 | + if (!is_a($update, 'update')) { |
|
| 59 | 59 | $update = new update($update); |
| 60 | 60 | } |
| 61 | 61 | |
@@ -66,7 +66,7 @@ discard block |
||
| 66 | 66 | db::save(); |
| 67 | 67 | } |
| 68 | 68 | |
| 69 | - protected static function setMessageExtra (update &$update): void { |
|
| 69 | + protected static function setMessageExtra(update & $update): void { |
|
| 70 | 70 | if ((isset($update->message) && isset($update->message->text)) || (isset($update->edited_message) && isset($update->edited_message->text))) { |
| 71 | 71 | $type = isset($update->message) ? 'message' : 'edited_message'; |
| 72 | 72 | $text = &$update->$type->text; |
@@ -139,7 +139,7 @@ discard block |
||
| 139 | 139 | BPT::$handler->something_else(BPT::$update); |
| 140 | 140 | } |
| 141 | 141 | else { |
| 142 | - logger::write('Update received but handlers does not set',loggerTypes::WARNING); |
|
| 142 | + logger::write('Update received but handlers does not set', loggerTypes::WARNING); |
|
| 143 | 143 | } |
| 144 | 144 | } |
| 145 | 145 | } |
@@ -35,8 +35,7 @@ discard block |
||
| 35 | 35 | if (isset($_SERVER['HTTP_CF_CONNECTING_IP']) && tools::isCloudFlare($ip)) { |
| 36 | 36 | $ip = $_SERVER['HTTP_CF_CONNECTING_IP']; |
| 37 | 37 | } |
| 38 | - } |
|
| 39 | - elseif (settings::$arvancloud_verify && isset($_SERVER['HTTP_AR_REAL_IP']) && tools::isArvanCloud($ip)) { |
|
| 38 | + } elseif (settings::$arvancloud_verify && isset($_SERVER['HTTP_AR_REAL_IP']) && tools::isArvanCloud($ip)) { |
|
| 40 | 39 | $ip = $_SERVER['HTTP_AR_REAL_IP']; |
| 41 | 40 | } |
| 42 | 41 | |
@@ -94,51 +93,41 @@ discard block |
||
| 94 | 93 | if (self::handlerExist('message')) { |
| 95 | 94 | BPT::$handler->message(BPT::$update->message); |
| 96 | 95 | } |
| 97 | - } |
|
| 98 | - elseif (isset(BPT::$update->edited_message)) { |
|
| 96 | + } elseif (isset(BPT::$update->edited_message)) { |
|
| 99 | 97 | if (self::handlerExist('edited_message')) { |
| 100 | 98 | BPT::$handler->edited_message(BPT::$update->edited_message); |
| 101 | 99 | } |
| 102 | - } |
|
| 103 | - elseif (isset(BPT::$update->channel_post)) { |
|
| 100 | + } elseif (isset(BPT::$update->channel_post)) { |
|
| 104 | 101 | if (self::handlerExist('channel_post')) { |
| 105 | 102 | BPT::$handler->channel_post(BPT::$update->channel_post); |
| 106 | 103 | } |
| 107 | - } |
|
| 108 | - elseif (isset(BPT::$update->edited_channel_post)) { |
|
| 104 | + } elseif (isset(BPT::$update->edited_channel_post)) { |
|
| 109 | 105 | if (self::handlerExist('edited_channel_post')) { |
| 110 | 106 | BPT::$handler->edited_channel_post(BPT::$update->edited_channel_post); |
| 111 | 107 | } |
| 112 | - } |
|
| 113 | - elseif (isset(BPT::$update->inline_query)) { |
|
| 108 | + } elseif (isset(BPT::$update->inline_query)) { |
|
| 114 | 109 | if (self::handlerExist('inline_query')) { |
| 115 | 110 | BPT::$handler->inline_query(BPT::$update->inline_query); |
| 116 | 111 | } |
| 117 | - } |
|
| 118 | - elseif (isset(BPT::$update->callback_query)) { |
|
| 112 | + } elseif (isset(BPT::$update->callback_query)) { |
|
| 119 | 113 | if (self::handlerExist('callback_query')) { |
| 120 | 114 | BPT::$handler->callback_query(BPT::$update->callback_query); |
| 121 | 115 | } |
| 122 | - } |
|
| 123 | - elseif (isset(BPT::$update->my_chat_member)) { |
|
| 116 | + } elseif (isset(BPT::$update->my_chat_member)) { |
|
| 124 | 117 | if (self::handlerExist('my_chat_member')) { |
| 125 | 118 | BPT::$handler->my_chat_member(BPT::$update->my_chat_member); |
| 126 | 119 | } |
| 127 | - } |
|
| 128 | - elseif (isset(BPT::$update->chat_member)) { |
|
| 120 | + } elseif (isset(BPT::$update->chat_member)) { |
|
| 129 | 121 | if (self::handlerExist('chat_member')) { |
| 130 | 122 | BPT::$handler->chat_member(BPT::$update->chat_member); |
| 131 | 123 | } |
| 132 | - } |
|
| 133 | - elseif (isset(BPT::$update->chat_join_request)) { |
|
| 124 | + } elseif (isset(BPT::$update->chat_join_request)) { |
|
| 134 | 125 | if (self::handlerExist('chat_join_request')) { |
| 135 | 126 | BPT::$handler->chat_join_request(BPT::$update->chat_join_request); |
| 136 | 127 | } |
| 137 | - } |
|
| 138 | - elseif (self::handlerExist('something_else')) { |
|
| 128 | + } elseif (self::handlerExist('something_else')) { |
|
| 139 | 129 | BPT::$handler->something_else(BPT::$update); |
| 140 | - } |
|
| 141 | - else { |
|
| 130 | + } else { |
|
| 142 | 131 | logger::write('Update received but handlers does not set',loggerTypes::WARNING); |
| 143 | 132 | } |
| 144 | 133 | } |
@@ -35,8 +35,8 @@ discard block |
||
| 35 | 35 | * |
| 36 | 36 | * @return bool|int |
| 37 | 37 | */ |
| 38 | - public static function save(string $name, string $data): bool|int { |
|
| 39 | - return file_put_contents(settings::$name."$name.lock", $data) && chmod(settings::$name."$name.lock",0640); |
|
| 38 | + public static function save(string $name, string $data): bool | int { |
|
| 39 | + return file_put_contents(settings::$name."$name.lock", $data) && chmod(settings::$name."$name.lock", 0640); |
|
| 40 | 40 | } |
| 41 | 41 | |
| 42 | 42 | /** |
@@ -46,7 +46,7 @@ discard block |
||
| 46 | 46 | * |
| 47 | 47 | * @return bool|string |
| 48 | 48 | */ |
| 49 | - public static function read(string $name): bool|string { |
|
| 49 | + public static function read(string $name): bool | string { |
|
| 50 | 50 | return file_get_contents(settings::$name."$name.lock"); |
| 51 | 51 | } |
| 52 | 52 | |
@@ -57,7 +57,7 @@ discard block |
||
| 57 | 57 | * |
| 58 | 58 | * @return bool|int |
| 59 | 59 | */ |
| 60 | - public static function mtime(string $name): bool|int { |
|
| 60 | + public static function mtime(string $name): bool | int { |
|
| 61 | 61 | return filemtime(settings::$name."$name.lock"); |
| 62 | 62 | } |
| 63 | 63 | |
@@ -2,12 +2,12 @@ |
||
| 2 | 2 | |
| 3 | 3 | namespace BPT; |
| 4 | 4 | |
| 5 | -use BPT\tools\{is,file,convert,generator,encrypt}; |
|
| 5 | +use BPT\tools\{is, file, convert, generator, encrypt}; |
|
| 6 | 6 | |
| 7 | 7 | /** |
| 8 | 8 | * tools class , gather what ever you need |
| 9 | 9 | */ |
| 10 | -class tools{ |
|
| 10 | +class tools { |
|
| 11 | 11 | use is; |
| 12 | 12 | use file; |
| 13 | 13 | use convert; |
@@ -78,11 +78,9 @@ discard block |
||
| 78 | 78 | $value = 'bots_files/'.$value.'/'; |
| 79 | 79 | } |
| 80 | 80 | self::$$setting = $value; |
| 81 | - } |
|
| 82 | - catch (TypeError){ |
|
| 81 | + } catch (TypeError){ |
|
| 83 | 82 | logger::write("$setting setting has wrong type , its set to default value",loggerTypes::WARNING); |
| 84 | - } |
|
| 85 | - catch (Error){ |
|
| 83 | + } catch (Error){ |
|
| 86 | 84 | logger::write("$setting setting is not one of library settings",loggerTypes::WARNING); |
| 87 | 85 | } |
| 88 | 86 | } |
@@ -99,13 +97,11 @@ discard block |
||
| 99 | 97 | if (!empty(self::$receiver)) { |
| 100 | 98 | self::$receiver !== receiver::GETUPDATES ? webhook::init() : self::getUpdates(); |
| 101 | 99 | } |
| 102 | - } |
|
| 103 | - else { |
|
| 100 | + } else { |
|
| 104 | 101 | logger::write('token format is not right, check it and try again',loggerTypes::ERROR); |
| 105 | 102 | throw new bptException('TOKEN_NOT_TRUE'); |
| 106 | 103 | } |
| 107 | - } |
|
| 108 | - else { |
|
| 104 | + } else { |
|
| 109 | 105 | logger::write('You must specify token parameter in settings',loggerTypes::ERROR); |
| 110 | 106 | throw new bptException('TOKEN_NOT_FOUND'); |
| 111 | 107 | } |
@@ -159,8 +155,7 @@ discard block |
||
| 159 | 155 | private static function getUpdates(): void { |
| 160 | 156 | if (self::$handler) { |
| 161 | 157 | getUpdates::init(); |
| 162 | - } |
|
| 163 | - else { |
|
| 158 | + } else { |
|
| 164 | 159 | logger::write('You can\'t use getUpdates receiver when handler is off , use webhook or use handler',loggerTypes::ERROR); |
| 165 | 160 | throw new bptException('GETUPDATE_NEED_HANDLER'); |
| 166 | 161 | } |
@@ -25,7 +25,7 @@ discard block |
||
| 25 | 25 | |
| 26 | 26 | public static int $log_size = 10; |
| 27 | 27 | |
| 28 | - public static string|CURLFile|null $certificate = null; |
|
| 28 | + public static string | CURLFile | null $certificate = null; |
|
| 29 | 29 | |
| 30 | 30 | public static bool $handler = true; |
| 31 | 31 | |
@@ -58,16 +58,16 @@ discard block |
||
| 58 | 58 | |
| 59 | 59 | public static array $allowed_updates = ['message', 'edited_channel_post', 'callback_query', 'inline_query']; |
| 60 | 60 | |
| 61 | - public static array|null $db = ['type' => 'json']; |
|
| 61 | + public static array | null $db = ['type' => 'json']; |
|
| 62 | 62 | |
| 63 | 63 | /** |
| 64 | 64 | * @internal Only for BPT self usage , Don't use it in your source! |
| 65 | 65 | */ |
| 66 | - public static function init (array|stdClass $settings): void { |
|
| 66 | + public static function init(array | stdClass $settings): void { |
|
| 67 | 67 | $settings = (array) $settings; |
| 68 | 68 | |
| 69 | 69 | foreach ($settings as $setting => $value) { |
| 70 | - try{ |
|
| 70 | + try { |
|
| 71 | 71 | if ($setting === 'name') { |
| 72 | 72 | if (!is_dir('bots_files')) { |
| 73 | 73 | mkdir('bots_files'); |
@@ -79,11 +79,11 @@ discard block |
||
| 79 | 79 | } |
| 80 | 80 | self::$$setting = $value; |
| 81 | 81 | } |
| 82 | - catch (TypeError){ |
|
| 83 | - logger::write("$setting setting has wrong type , its set to default value",loggerTypes::WARNING); |
|
| 82 | + catch (TypeError) { |
|
| 83 | + logger::write("$setting setting has wrong type , its set to default value", loggerTypes::WARNING); |
|
| 84 | 84 | } |
| 85 | - catch (Error){ |
|
| 86 | - logger::write("$setting setting is not one of library settings",loggerTypes::WARNING); |
|
| 85 | + catch (Error) { |
|
| 86 | + logger::write("$setting setting is not one of library settings", loggerTypes::WARNING); |
|
| 87 | 87 | } |
| 88 | 88 | } |
| 89 | 89 | |
@@ -101,12 +101,12 @@ discard block |
||
| 101 | 101 | } |
| 102 | 102 | } |
| 103 | 103 | else { |
| 104 | - logger::write('token format is not right, check it and try again',loggerTypes::ERROR); |
|
| 104 | + logger::write('token format is not right, check it and try again', loggerTypes::ERROR); |
|
| 105 | 105 | throw new bptException('TOKEN_NOT_TRUE'); |
| 106 | 106 | } |
| 107 | 107 | } |
| 108 | 108 | else { |
| 109 | - logger::write('You must specify token parameter in settings',loggerTypes::ERROR); |
|
| 109 | + logger::write('You must specify token parameter in settings', loggerTypes::ERROR); |
|
| 110 | 110 | throw new bptException('TOKEN_NOT_FOUND'); |
| 111 | 111 | } |
| 112 | 112 | } |
@@ -116,7 +116,7 @@ discard block |
||
| 116 | 116 | */ |
| 117 | 117 | public static function done(): void { |
| 118 | 118 | if (self::$logger) { |
| 119 | - $estimated = round((microtime(true)-$_SERVER['REQUEST_TIME_FLOAT'])*1000,2); |
|
| 119 | + $estimated = round((microtime(true) - $_SERVER['REQUEST_TIME_FLOAT']) * 1000, 2); |
|
| 120 | 120 | $status_message = match (true) { |
| 121 | 121 | $estimated < 100 => 'Excellent', |
| 122 | 122 | $estimated < 500 => 'Very good', |
@@ -148,7 +148,7 @@ discard block |
||
| 148 | 148 | if (self::$secure_folder) { |
| 149 | 149 | $address = explode('/', $_SERVER['REQUEST_URI']); |
| 150 | 150 | unset($address[count($address) - 1]); |
| 151 | - $address = implode('/', $address) . '/BPT.php'; |
|
| 151 | + $address = implode('/', $address).'/BPT.php'; |
|
| 152 | 152 | $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>"; |
| 153 | 153 | if (!file_exists('.htaccess') || filesize('.htaccess') != strlen($text)) { |
| 154 | 154 | file_put_contents('.htaccess', $text); |
@@ -161,7 +161,7 @@ discard block |
||
| 161 | 161 | getUpdates::init(); |
| 162 | 162 | } |
| 163 | 163 | else { |
| 164 | - logger::write('You can\'t use getUpdates receiver when handler is off , use webhook or use handler',loggerTypes::ERROR); |
|
| 164 | + logger::write('You can\'t use getUpdates receiver when handler is off , use webhook or use handler', loggerTypes::ERROR); |
|
| 165 | 165 | throw new bptException('GETUPDATE_NEED_HANDLER'); |
| 166 | 166 | } |
| 167 | 167 | } |
@@ -17,7 +17,7 @@ |
||
| 17 | 17 | /** |
| 18 | 18 | * @internal Only for BPT self usage , Don't use it in your source! |
| 19 | 19 | */ |
| 20 | - public static function init (): void { |
|
| 20 | + public static function init(): void { |
|
| 21 | 21 | if (!empty(settings::$db)) { |
| 22 | 22 | if (!isset(settings::$db['type'])) { |
| 23 | 23 | settings::$db['type'] = dbTypes::JSON; |
@@ -103,7 +103,7 @@ discard block |
||
| 103 | 103 | /** |
| 104 | 104 | * @internal Only for BPT self usage , Don't use it in your source! |
| 105 | 105 | */ |
| 106 | - public static function init (): void { |
|
| 106 | + public static function init(): void { |
|
| 107 | 107 | self::$folder = settings::$name.'database'; |
| 108 | 108 | self::$global_default_data = settings::$db['global'] ?? self::$global_default_data; |
| 109 | 109 | self::setUserDefaultData(); |
@@ -115,7 +115,7 @@ discard block |
||
| 115 | 115 | self::load(); |
| 116 | 116 | } |
| 117 | 117 | |
| 118 | - private static function setUserDefaultData (): void { |
|
| 118 | + private static function setUserDefaultData(): void { |
|
| 119 | 119 | self::$user_default_data = settings::$db['user'] ?? self::$user_default_data; |
| 120 | 120 | if (!isset(self::$user_default_data['step'])) { |
| 121 | 121 | self::$user_default_data['step'] = 'none'; |
@@ -134,7 +134,7 @@ discard block |
||
| 134 | 134 | } |
| 135 | 135 | } |
| 136 | 136 | |
| 137 | - private static function setGroupUserDefaultData (): void { |
|
| 137 | + private static function setGroupUserDefaultData(): void { |
|
| 138 | 138 | self::$group_user_default_data = settings::$db['group_user'] ?? self::$group_user_default_data; |
| 139 | 139 | if (!isset(self::$group_user_default_data['step'])) { |
| 140 | 140 | self::$group_user_default_data['step'] = 'none'; |
@@ -162,10 +162,10 @@ discard block |
||
| 162 | 162 | } |
| 163 | 163 | |
| 164 | 164 | if (!file_exists(self::$folder.'/global.json')) { |
| 165 | - file_put_contents(self::$folder.'/global.json',self::$global_default_data); |
|
| 165 | + file_put_contents(self::$folder.'/global.json', self::$global_default_data); |
|
| 166 | 166 | } |
| 167 | 167 | if (!file_exists(self::$folder.'/ids.json')) { |
| 168 | - file_put_contents(self::$folder.'/ids.json',json_encode([ |
|
| 168 | + file_put_contents(self::$folder.'/ids.json', json_encode([ |
|
| 169 | 169 | 'privates' => [], |
| 170 | 170 | 'groups' => [], |
| 171 | 171 | 'supergroups' => [], |
@@ -174,25 +174,25 @@ discard block |
||
| 174 | 174 | } |
| 175 | 175 | } |
| 176 | 176 | |
| 177 | - private static function load (): void { |
|
| 177 | + private static function load(): void { |
|
| 178 | 178 | self::$global = json_decode(file_get_contents(self::$folder.'/global.json')); |
| 179 | 179 | self::$old_global = clone self::$global; |
| 180 | - self::$ids = json_decode(file_get_contents(self::$folder.'/ids.json'),true); |
|
| 180 | + self::$ids = json_decode(file_get_contents(self::$folder.'/ids.json'), true); |
|
| 181 | 181 | self::$old_ids = clone self::$ids; |
| 182 | 182 | } |
| 183 | 183 | |
| 184 | - private static function read (string $address) { |
|
| 184 | + private static function read(string $address) { |
|
| 185 | 185 | return file_exists(self::$folder.'/'.$address.'.json') ? json_decode(file_get_contents(self::$folder.'/'.$address.'.json'), false) : null; |
| 186 | 186 | } |
| 187 | 187 | |
| 188 | - private static function write (string $address,string $data): void { |
|
| 189 | - file_put_contents(self::$folder.'/'.$address.'.json',$data); |
|
| 188 | + private static function write(string $address, string $data): void { |
|
| 189 | + file_put_contents(self::$folder.'/'.$address.'.json', $data); |
|
| 190 | 190 | } |
| 191 | 191 | |
| 192 | 192 | /** |
| 193 | 193 | * @internal Only for BPT self usage , Don't use it in your source! |
| 194 | 194 | */ |
| 195 | - public static function process (): void { |
|
| 195 | + public static function process(): void { |
|
| 196 | 196 | if (isset(BPT::$update->message)) { |
| 197 | 197 | self::processMessage(BPT::$update->message); |
| 198 | 198 | } |
@@ -215,16 +215,16 @@ discard block |
||
| 215 | 215 | */ |
| 216 | 216 | public static function save(): void { |
| 217 | 217 | if (self::$user !== self::$old_user && !empty(self::$user_id)) { |
| 218 | - self::write('privates/' . self::$user_id,json_encode(self::$user)); |
|
| 218 | + self::write('privates/'.self::$user_id, json_encode(self::$user)); |
|
| 219 | 219 | } |
| 220 | 220 | if (self::$group !== self::$old_group && !empty(self::$group_id)) { |
| 221 | - self::write('groups/' . self::$group_id,json_encode(self::$group)); |
|
| 221 | + self::write('groups/'.self::$group_id, json_encode(self::$group)); |
|
| 222 | 222 | } |
| 223 | 223 | if (self::$supergroup !== self::$old_supergroup && !empty(self::$supergroup_id)) { |
| 224 | - self::write('supergroups/' . self::$supergroup_id,json_encode(self::$supergroup)); |
|
| 224 | + self::write('supergroups/'.self::$supergroup_id, json_encode(self::$supergroup)); |
|
| 225 | 225 | } |
| 226 | 226 | if (self::$channel !== self::$old_channel && !empty(self::$channel_id)) { |
| 227 | - self::write('channels/' . self::$channel_id,json_encode(self::$channel)); |
|
| 227 | + self::write('channels/'.self::$channel_id, json_encode(self::$channel)); |
|
| 228 | 228 | } |
| 229 | 229 | if (self::$group_user !== self::$old_group_user && !empty(self::$group_user_id)) { |
| 230 | 230 | if (empty(self::$group)) { |
@@ -235,13 +235,13 @@ discard block |
||
| 235 | 235 | $category = 'groups'; |
| 236 | 236 | $group_id = self::$group_id; |
| 237 | 237 | } |
| 238 | - self::write($category . '/' . $group_id . '/' . self::$group_user_id,json_encode(self::$group_user)); |
|
| 238 | + self::write($category.'/'.$group_id.'/'.self::$group_user_id, json_encode(self::$group_user)); |
|
| 239 | 239 | } |
| 240 | 240 | if (self::$ids !== self::$old_ids) { |
| 241 | - self::write('ids',json_encode(self::$ids)); |
|
| 241 | + self::write('ids', json_encode(self::$ids)); |
|
| 242 | 242 | } |
| 243 | 243 | if (self::$global !== self::$old_global) { |
| 244 | - self::write('global',json_encode(self::$global)); |
|
| 244 | + self::write('global', json_encode(self::$global)); |
|
| 245 | 245 | } |
| 246 | 246 | if (self::$group_ids !== self::$old_group_ids) { |
| 247 | 247 | if (empty(self::$group)) { |
@@ -252,17 +252,17 @@ discard block |
||
| 252 | 252 | $category = 'groups'; |
| 253 | 253 | $group_id = self::$group_id; |
| 254 | 254 | } |
| 255 | - self::write($category . '/' . $group_id . '/users',json_encode(self::$group_user)); |
|
| 255 | + self::write($category.'/'.$group_id.'/users', json_encode(self::$group_user)); |
|
| 256 | 256 | } |
| 257 | 257 | } |
| 258 | 258 | |
| 259 | 259 | private static function processMessage(message $update): void { |
| 260 | 260 | $type = $update->chat->type; |
| 261 | - $category = $type . 's'; |
|
| 261 | + $category = $type.'s'; |
|
| 262 | 262 | if ($type === chatType::PRIVATE) { |
| 263 | 263 | self::$user_id = $update->from->id; |
| 264 | - if (in_array(self::$user_id,self::$ids[$category])) { |
|
| 265 | - self::$user = self::read($category . '/' . self::$user_id); |
|
| 264 | + if (in_array(self::$user_id, self::$ids[$category])) { |
|
| 265 | + self::$user = self::read($category.'/'.self::$user_id); |
|
| 266 | 266 | self::$old_user = clone self::$user; |
| 267 | 267 | self::$user->last_active = time(); |
| 268 | 268 | } |
@@ -270,10 +270,10 @@ discard block |
||
| 270 | 270 | self::$ids[$category][] = self::$user_id; |
| 271 | 271 | self::$user = (object) self::$user_default_data; |
| 272 | 272 | self::$user->first_active = self::$user->last_active = time(); |
| 273 | - if (isset($update->commend) && isset($update->commend_payload) && $update->commend === 'start' && str_starts_with($update->commend_payload,'ref_')) { |
|
| 274 | - if (tools::isShorted(substr($update->commend_payload,4))) { |
|
| 275 | - $referral = tools::shortDecode(substr($update->commend_payload,4)); |
|
| 276 | - if (in_array($referral,self::$ids[$category])) { |
|
| 273 | + if (isset($update->commend) && isset($update->commend_payload) && $update->commend === 'start' && str_starts_with($update->commend_payload, 'ref_')) { |
|
| 274 | + if (tools::isShorted(substr($update->commend_payload, 4))) { |
|
| 275 | + $referral = tools::shortDecode(substr($update->commend_payload, 4)); |
|
| 276 | + if (in_array($referral, self::$ids[$category])) { |
|
| 277 | 277 | self::$user->referral = $referral; |
| 278 | 278 | } |
| 279 | 279 | } |
@@ -282,8 +282,8 @@ discard block |
||
| 282 | 282 | } |
| 283 | 283 | elseif ($type === chatType::CHANNEL) { |
| 284 | 284 | self::$channel_id = $update->chat->id; |
| 285 | - if (in_array(self::$channel_id,self::$ids[$category])) { |
|
| 286 | - self::$channel = self::read($category . '/' . self::$channel_id); |
|
| 285 | + if (in_array(self::$channel_id, self::$ids[$category])) { |
|
| 286 | + self::$channel = self::read($category.'/'.self::$channel_id); |
|
| 287 | 287 | self::$old_channel = clone self::$channel; |
| 288 | 288 | } |
| 289 | 289 | else { |
@@ -297,10 +297,10 @@ discard block |
||
| 297 | 297 | $chat_id = $update->chat->id; |
| 298 | 298 | if ($type === chatType::SUPERGROUP) { |
| 299 | 299 | self::$supergroup_id = $update->chat->id; |
| 300 | - if (in_array($chat_id,self::$ids[$category])) { |
|
| 301 | - self::$supergroup = self::read($category . '/' . $chat_id); |
|
| 300 | + if (in_array($chat_id, self::$ids[$category])) { |
|
| 301 | + self::$supergroup = self::read($category.'/'.$chat_id); |
|
| 302 | 302 | self::$old_supergroup = clone self::$supergroup; |
| 303 | - self::$group_ids = self::read($category . '/' . $chat_id . '/users'); |
|
| 303 | + self::$group_ids = self::read($category.'/'.$chat_id.'/users'); |
|
| 304 | 304 | self::$old_group_ids = clone self::$group_ids; |
| 305 | 305 | } |
| 306 | 306 | else { |
@@ -311,10 +311,10 @@ discard block |
||
| 311 | 311 | } |
| 312 | 312 | else { |
| 313 | 313 | self::$group_id = $update->chat->id; |
| 314 | - if (in_array($chat_id,self::$ids[$category])) { |
|
| 315 | - self::$group = self::read($category . '/' . $chat_id); |
|
| 314 | + if (in_array($chat_id, self::$ids[$category])) { |
|
| 315 | + self::$group = self::read($category.'/'.$chat_id); |
|
| 316 | 316 | self::$old_group = clone self::$group; |
| 317 | - self::$group_ids = self::read($category . '/' . $chat_id . '/users'); |
|
| 317 | + self::$group_ids = self::read($category.'/'.$chat_id.'/users'); |
|
| 318 | 318 | self::$old_group_ids = clone self::$group_ids; |
| 319 | 319 | } |
| 320 | 320 | else { |
@@ -324,8 +324,8 @@ discard block |
||
| 324 | 324 | } |
| 325 | 325 | } |
| 326 | 326 | |
| 327 | - if (in_array(self::$user_id,self::$group_ids)) { |
|
| 328 | - self::$group_user = self::read($category . '/' . $chat_id . '/' . self::$user_id); |
|
| 327 | + if (in_array(self::$user_id, self::$group_ids)) { |
|
| 328 | + self::$group_user = self::read($category.'/'.$chat_id.'/'.self::$user_id); |
|
| 329 | 329 | self::$old_group_user = clone self::$group_user; |
| 330 | 330 | } |
| 331 | 331 | else { |
@@ -341,42 +341,42 @@ discard block |
||
| 341 | 341 | |
| 342 | 342 | private static function processCallbackQuery(callbackQuery $update): void { |
| 343 | 343 | $type = $update->message->chat->type; |
| 344 | - $category = $type . 's'; |
|
| 344 | + $category = $type.'s'; |
|
| 345 | 345 | if ($type === chatType::PRIVATE) { |
| 346 | 346 | self::$user_id = $update->from->id; |
| 347 | - if (in_array(self::$user_id,self::$ids[$category])) { |
|
| 348 | - self::$user = self::read($category . '/' . self::$user_id); |
|
| 347 | + if (in_array(self::$user_id, self::$ids[$category])) { |
|
| 348 | + self::$user = self::read($category.'/'.self::$user_id); |
|
| 349 | 349 | self::$old_user = clone self::$user; |
| 350 | 350 | self::$user->last_active = time(); |
| 351 | 351 | } |
| 352 | 352 | } |
| 353 | 353 | elseif ($type === chatType::CHANNEL) { |
| 354 | 354 | self::$channel_id = $update->message->chat->id; |
| 355 | - if (in_array(self::$channel_id,self::$ids[$category])) { |
|
| 356 | - self::$channel = self::read($category . '/' . self::$channel_id); |
|
| 355 | + if (in_array(self::$channel_id, self::$ids[$category])) { |
|
| 356 | + self::$channel = self::read($category.'/'.self::$channel_id); |
|
| 357 | 357 | self::$old_channel = clone self::$channel; |
| 358 | 358 | } |
| 359 | 359 | } |
| 360 | 360 | else { |
| 361 | 361 | self::$user_id = $update->from->id; |
| 362 | 362 | $chat_id = $update->message->chat->id; |
| 363 | - if (in_array($chat_id,self::$ids[$category])) { |
|
| 363 | + if (in_array($chat_id, self::$ids[$category])) { |
|
| 364 | 364 | if ($type === chatType::SUPERGROUP) { |
| 365 | 365 | self::$supergroup_id = $update->message->chat->id; |
| 366 | - self::$supergroup = self::read($category . '/' . $chat_id); |
|
| 366 | + self::$supergroup = self::read($category.'/'.$chat_id); |
|
| 367 | 367 | self::$old_supergroup = clone self::$supergroup; |
| 368 | 368 | } |
| 369 | 369 | else { |
| 370 | 370 | self::$group_id = $update->message->chat->id; |
| 371 | - self::$group = self::read($category . '/' . $chat_id); |
|
| 371 | + self::$group = self::read($category.'/'.$chat_id); |
|
| 372 | 372 | self::$old_group = clone self::$group; |
| 373 | 373 | } |
| 374 | - self::$group_ids = self::read($category . '/' . $chat_id . '/users'); |
|
| 374 | + self::$group_ids = self::read($category.'/'.$chat_id.'/users'); |
|
| 375 | 375 | self::$old_group_ids = clone self::$group_ids; |
| 376 | 376 | } |
| 377 | 377 | |
| 378 | - if (in_array(self::$user_id,self::$group_ids)) { |
|
| 379 | - self::$group_user = self::read($category . '/' . $chat_id . '/' . self::$user_id); |
|
| 378 | + if (in_array(self::$user_id, self::$group_ids)) { |
|
| 379 | + self::$group_user = self::read($category.'/'.$chat_id.'/'.self::$user_id); |
|
| 380 | 380 | self::$group_user_id = self::$user_id; |
| 381 | 381 | self::$old_group_user = clone self::$group_user; |
| 382 | 382 | } |
@@ -390,10 +390,10 @@ discard block |
||
| 390 | 390 | private static function processInlineQuery(inlineQuery $update): void { |
| 391 | 391 | $type = $update->chat_type; |
| 392 | 392 | if ($type === chatType::PRIVATE || $type === chatType::SENDER) { |
| 393 | - $category = chatType::PRIVATE . 's'; |
|
| 393 | + $category = chatType::PRIVATE.'s'; |
|
| 394 | 394 | self::$user_id = $update->from->id; |
| 395 | - if (in_array(self::$user_id,self::$ids[$category])) { |
|
| 396 | - self::$user = self::read($category . '/' . self::$user_id); |
|
| 395 | + if (in_array(self::$user_id, self::$ids[$category])) { |
|
| 396 | + self::$user = self::read($category.'/'.self::$user_id); |
|
| 397 | 397 | self::$old_user = clone self::$user; |
| 398 | 398 | self::$user->last_active = time(); |
| 399 | 399 | } |
@@ -403,11 +403,11 @@ discard block |
||
| 403 | 403 | private static function processChatMember(chatMemberUpdated $update): void { |
| 404 | 404 | $type = $update->chat->type; |
| 405 | 405 | |
| 406 | - $category = $type . 's'; |
|
| 406 | + $category = $type.'s'; |
|
| 407 | 407 | if ($type === chatType::CHANNEL) { |
| 408 | 408 | self::$channel_id = $update->chat->id; |
| 409 | - if (in_array(self::$channel_id,self::$ids[$category])) { |
|
| 410 | - self::$channel = self::read($category . '/' . self::$channel_id); |
|
| 409 | + if (in_array(self::$channel_id, self::$ids[$category])) { |
|
| 410 | + self::$channel = self::read($category.'/'.self::$channel_id); |
|
| 411 | 411 | self::$old_channel = clone self::$channel; |
| 412 | 412 | } |
| 413 | 413 | else { |
@@ -426,10 +426,10 @@ discard block |
||
| 426 | 426 | |
| 427 | 427 | if ($type === chatType::SUPERGROUP) { |
| 428 | 428 | self::$supergroup_id = $chat_id; |
| 429 | - if (in_array($chat_id,self::$ids[$category])) { |
|
| 430 | - self::$supergroup = self::read($category . '/' . $chat_id); |
|
| 429 | + if (in_array($chat_id, self::$ids[$category])) { |
|
| 430 | + self::$supergroup = self::read($category.'/'.$chat_id); |
|
| 431 | 431 | self::$old_supergroup = clone self::$supergroup; |
| 432 | - self::$group_ids = self::read($category . '/' . $chat_id . '/users'); |
|
| 432 | + self::$group_ids = self::read($category.'/'.$chat_id.'/users'); |
|
| 433 | 433 | self::$old_group_ids = clone self::$group_ids; |
| 434 | 434 | } |
| 435 | 435 | else { |
@@ -440,10 +440,10 @@ discard block |
||
| 440 | 440 | } |
| 441 | 441 | elseif ($type === chatType::GROUP) { |
| 442 | 442 | self::$group_id = $chat_id; |
| 443 | - if (in_array($chat_id,self::$ids[$category])) { |
|
| 444 | - self::$group = self::read($category . '/' . $chat_id); |
|
| 443 | + if (in_array($chat_id, self::$ids[$category])) { |
|
| 444 | + self::$group = self::read($category.'/'.$chat_id); |
|
| 445 | 445 | self::$old_group = clone self::$group; |
| 446 | - self::$group_ids = self::read($category . '/' . $chat_id . '/users'); |
|
| 446 | + self::$group_ids = self::read($category.'/'.$chat_id.'/users'); |
|
| 447 | 447 | self::$old_group_ids = clone self::$group_ids; |
| 448 | 448 | } |
| 449 | 449 | else { |
@@ -453,13 +453,13 @@ discard block |
||
| 453 | 453 | } |
| 454 | 454 | } |
| 455 | 455 | |
| 456 | - if (!in_array($user_id,self::$group_ids)) { |
|
| 456 | + if (!in_array($user_id, self::$group_ids)) { |
|
| 457 | 457 | self::$group_ids[] = $user_id; |
| 458 | 458 | self::$group_user = (object) self::$group_user_default_data; |
| 459 | 459 | } |
| 460 | 460 | else { |
| 461 | 461 | self::$group_user_id = $by_id == $user_id ? $user_id : $by_id; |
| 462 | - self::$group_user = self::read($category . '/' . $chat_id . '/' . self::$group_user_id); |
|
| 462 | + self::$group_user = self::read($category.'/'.$chat_id.'/'.self::$group_user_id); |
|
| 463 | 463 | } |
| 464 | 464 | |
| 465 | 465 | if ($new_user->status === chatMemberStatus::LEFT || $new_user->status === chatMemberStatus::KICKED) { |
@@ -500,15 +500,15 @@ discard block |
||
| 500 | 500 | * @return bool |
| 501 | 501 | * @throws bptException |
| 502 | 502 | */ |
| 503 | - public static function deleteUser (int $user_id = null): bool { |
|
| 503 | + public static function deleteUser(int $user_id = null): bool { |
|
| 504 | 504 | if (empty($user_id)) $user_id = telegram::catchFields(fields::USER_ID); |
| 505 | - if (file_exists(self::$folder . '/privates/' . $user_id . '.json')) { |
|
| 505 | + if (file_exists(self::$folder.'/privates/'.$user_id.'.json')) { |
|
| 506 | 506 | unset(self::$ids['privates'][array_search($user_id, self::$ids['privates'])]); |
| 507 | 507 | sort(self::$ids['privates']); |
| 508 | 508 | if ($user_id === self::$user_id) { |
| 509 | 509 | self::$user = self::$old_user = null; |
| 510 | 510 | } |
| 511 | - return tools::delete(self::$folder . '/privates/' . $user_id . '.json'); |
|
| 511 | + return tools::delete(self::$folder.'/privates/'.$user_id.'.json'); |
|
| 512 | 512 | } |
| 513 | 513 | return false; |
| 514 | 514 | } |
@@ -521,16 +521,16 @@ discard block |
||
| 521 | 521 | * @return bool |
| 522 | 522 | * @throws bptException |
| 523 | 523 | */ |
| 524 | - public static function deleteGroup (int $group_id = null): bool { |
|
| 524 | + public static function deleteGroup(int $group_id = null): bool { |
|
| 525 | 525 | if (empty($group_id)) $group_id = telegram::catchFields(fields::CHAT_ID); |
| 526 | - if (file_exists(self::$folder . '/groups/' . $group_id . '.json')) { |
|
| 526 | + if (file_exists(self::$folder.'/groups/'.$group_id.'.json')) { |
|
| 527 | 527 | unset(self::$ids['groups'][array_search($group_id, self::$ids['groups'])]); |
| 528 | 528 | sort(self::$ids['groups']); |
| 529 | - tools::delete(self::$folder . '/groups/' . $group_id); |
|
| 529 | + tools::delete(self::$folder.'/groups/'.$group_id); |
|
| 530 | 530 | if ($group_id === self::$group_id) { |
| 531 | 531 | self::$group = self::$old_group = null; |
| 532 | 532 | } |
| 533 | - return tools::delete(self::$folder . '/groups/' . $group_id . '.json'); |
|
| 533 | + return tools::delete(self::$folder.'/groups/'.$group_id.'.json'); |
|
| 534 | 534 | } |
| 535 | 535 | return false; |
| 536 | 536 | } |
@@ -543,16 +543,16 @@ discard block |
||
| 543 | 543 | * @return bool |
| 544 | 544 | * @throws bptException |
| 545 | 545 | */ |
| 546 | - public static function deleteSuperGroup (int $group_id = null): bool { |
|
| 546 | + public static function deleteSuperGroup(int $group_id = null): bool { |
|
| 547 | 547 | if (empty($group_id)) $group_id = telegram::catchFields(fields::CHAT_ID); |
| 548 | - if (file_exists(self::$folder . '/supergroups/' . $group_id . '.json')) { |
|
| 548 | + if (file_exists(self::$folder.'/supergroups/'.$group_id.'.json')) { |
|
| 549 | 549 | unset(self::$ids['supergroups'][array_search($group_id, self::$ids['supergroups'])]); |
| 550 | 550 | sort(self::$ids['supergroups']); |
| 551 | - tools::delete(self::$folder . '/supergroups/' . $group_id); |
|
| 551 | + tools::delete(self::$folder.'/supergroups/'.$group_id); |
|
| 552 | 552 | if ($group_id === self::$supergroup_id) { |
| 553 | 553 | self::$supergroup = self::$old_supergroup = null; |
| 554 | 554 | } |
| 555 | - return tools::delete(self::$folder . '/supergroups/' . $group_id . '.json'); |
|
| 555 | + return tools::delete(self::$folder.'/supergroups/'.$group_id.'.json'); |
|
| 556 | 556 | } |
| 557 | 557 | return false; |
| 558 | 558 | } |
@@ -565,15 +565,15 @@ discard block |
||
| 565 | 565 | * @return bool |
| 566 | 566 | * @throws bptException |
| 567 | 567 | */ |
| 568 | - public static function deleteChannel (int $channel_id = null): bool { |
|
| 568 | + public static function deleteChannel(int $channel_id = null): bool { |
|
| 569 | 569 | if (empty($channel_id)) $channel_id = telegram::catchFields(fields::CHAT_ID); |
| 570 | - if (file_exists(self::$folder . '/channels/' . $channel_id . '.json')) { |
|
| 570 | + if (file_exists(self::$folder.'/channels/'.$channel_id.'.json')) { |
|
| 571 | 571 | unset(self::$ids['channels'][array_search($channel_id, self::$ids['channels'])]); |
| 572 | 572 | sort(self::$ids['channels']); |
| 573 | 573 | if ($channel_id === self::$channel_id) { |
| 574 | 574 | self::$channel = self::$old_channel = null; |
| 575 | 575 | } |
| 576 | - return tools::delete(self::$folder . '/channels/' . $channel_id . '.json'); |
|
| 576 | + return tools::delete(self::$folder.'/channels/'.$channel_id.'.json'); |
|
| 577 | 577 | } |
| 578 | 578 | return false; |
| 579 | 579 | } |
@@ -583,7 +583,7 @@ discard block |
||
| 583 | 583 | * |
| 584 | 584 | * @return int[] |
| 585 | 585 | */ |
| 586 | - public static function getUsers (): array { |
|
| 586 | + public static function getUsers(): array { |
|
| 587 | 587 | return self::$ids['privates'] ?? []; |
| 588 | 588 | } |
| 589 | 589 | |
@@ -592,7 +592,7 @@ discard block |
||
| 592 | 592 | * |
| 593 | 593 | * @return int[] |
| 594 | 594 | */ |
| 595 | - public static function getGroups (): array { |
|
| 595 | + public static function getGroups(): array { |
|
| 596 | 596 | return self::$ids['groups'] ?? []; |
| 597 | 597 | } |
| 598 | 598 | |
@@ -601,7 +601,7 @@ discard block |
||
| 601 | 601 | * |
| 602 | 602 | * @return int[] |
| 603 | 603 | */ |
| 604 | - public static function getSuperGroups (): array { |
|
| 604 | + public static function getSuperGroups(): array { |
|
| 605 | 605 | return self::$ids['supergroups'] ?? []; |
| 606 | 606 | } |
| 607 | 607 | |
@@ -610,7 +610,7 @@ discard block |
||
| 610 | 610 | * |
| 611 | 611 | * @return int[] |
| 612 | 612 | */ |
| 613 | - public static function getChannels (): array { |
|
| 613 | + public static function getChannels(): array { |
|
| 614 | 614 | return self::$ids['channels'] ?? []; |
| 615 | 615 | } |
| 616 | 616 | } |
@@ -195,17 +195,13 @@ discard block |
||
| 195 | 195 | public static function process (): void { |
| 196 | 196 | if (isset(BPT::$update->message)) { |
| 197 | 197 | self::processMessage(BPT::$update->message); |
| 198 | - } |
|
| 199 | - elseif (isset(BPT::$update->edited_message)) { |
|
| 198 | + } elseif (isset(BPT::$update->edited_message)) { |
|
| 200 | 199 | self::processMessage(BPT::$update->edited_message); |
| 201 | - } |
|
| 202 | - elseif (isset(BPT::$update->callback_query)) { |
|
| 200 | + } elseif (isset(BPT::$update->callback_query)) { |
|
| 203 | 201 | self::processCallbackQuery(BPT::$update->callback_query); |
| 204 | - } |
|
| 205 | - elseif (isset(BPT::$update->inline_query)) { |
|
| 202 | + } elseif (isset(BPT::$update->inline_query)) { |
|
| 206 | 203 | self::processInlineQuery(BPT::$update->inline_query); |
| 207 | - } |
|
| 208 | - elseif (isset(BPT::$update->chat_member)) { |
|
| 204 | + } elseif (isset(BPT::$update->chat_member)) { |
|
| 209 | 205 | self::processChatMember(BPT::$update->chat_member); |
| 210 | 206 | } |
| 211 | 207 | } |
@@ -230,8 +226,7 @@ discard block |
||
| 230 | 226 | if (empty(self::$group)) { |
| 231 | 227 | $category = 'supergroups'; |
| 232 | 228 | $group_id = self::$supergroup_id; |
| 233 | - } |
|
| 234 | - else { |
|
| 229 | + } else { |
|
| 235 | 230 | $category = 'groups'; |
| 236 | 231 | $group_id = self::$group_id; |
| 237 | 232 | } |
@@ -247,8 +242,7 @@ discard block |
||
| 247 | 242 | if (empty(self::$group)) { |
| 248 | 243 | $category = 'supergroups'; |
| 249 | 244 | $group_id = self::$supergroup_id; |
| 250 | - } |
|
| 251 | - else { |
|
| 245 | + } else { |
|
| 252 | 246 | $category = 'groups'; |
| 253 | 247 | $group_id = self::$group_id; |
| 254 | 248 | } |
@@ -265,8 +259,7 @@ discard block |
||
| 265 | 259 | self::$user = self::read($category . '/' . self::$user_id); |
| 266 | 260 | self::$old_user = clone self::$user; |
| 267 | 261 | self::$user->last_active = time(); |
| 268 | - } |
|
| 269 | - else { |
|
| 262 | + } else { |
|
| 270 | 263 | self::$ids[$category][] = self::$user_id; |
| 271 | 264 | self::$user = (object) self::$user_default_data; |
| 272 | 265 | self::$user->first_active = self::$user->last_active = time(); |
@@ -279,19 +272,16 @@ discard block |
||
| 279 | 272 | } |
| 280 | 273 | } |
| 281 | 274 | } |
| 282 | - } |
|
| 283 | - elseif ($type === chatType::CHANNEL) { |
|
| 275 | + } elseif ($type === chatType::CHANNEL) { |
|
| 284 | 276 | self::$channel_id = $update->chat->id; |
| 285 | 277 | if (in_array(self::$channel_id,self::$ids[$category])) { |
| 286 | 278 | self::$channel = self::read($category . '/' . self::$channel_id); |
| 287 | 279 | self::$old_channel = clone self::$channel; |
| 288 | - } |
|
| 289 | - else { |
|
| 280 | + } else { |
|
| 290 | 281 | self::$ids[$category][] = self::$channel_id; |
| 291 | 282 | self::$channel = (object) self::$channel_default_data; |
| 292 | 283 | } |
| 293 | - } |
|
| 294 | - else { |
|
| 284 | + } else { |
|
| 295 | 285 | self::$user_id = $update->from->id; |
| 296 | 286 | self::$group_user_id = self::$user_id; |
| 297 | 287 | $chat_id = $update->chat->id; |
@@ -302,22 +292,19 @@ discard block |
||
| 302 | 292 | self::$old_supergroup = clone self::$supergroup; |
| 303 | 293 | self::$group_ids = self::read($category . '/' . $chat_id . '/users'); |
| 304 | 294 | self::$old_group_ids = clone self::$group_ids; |
| 305 | - } |
|
| 306 | - else { |
|
| 295 | + } else { |
|
| 307 | 296 | self::$ids[$category][] = $chat_id; |
| 308 | 297 | self::$supergroup = (object) self::$supergroup_default_data; |
| 309 | 298 | self::$group_ids = []; |
| 310 | 299 | } |
| 311 | - } |
|
| 312 | - else { |
|
| 300 | + } else { |
|
| 313 | 301 | self::$group_id = $update->chat->id; |
| 314 | 302 | if (in_array($chat_id,self::$ids[$category])) { |
| 315 | 303 | self::$group = self::read($category . '/' . $chat_id); |
| 316 | 304 | self::$old_group = clone self::$group; |
| 317 | 305 | self::$group_ids = self::read($category . '/' . $chat_id . '/users'); |
| 318 | 306 | self::$old_group_ids = clone self::$group_ids; |
| 319 | - } |
|
| 320 | - else { |
|
| 307 | + } else { |
|
| 321 | 308 | self::$ids[$category][] = $chat_id; |
| 322 | 309 | self::$group = (object) self::$group_default_data; |
| 323 | 310 | self::$group_ids = []; |
@@ -327,15 +314,16 @@ discard block |
||
| 327 | 314 | if (in_array(self::$user_id,self::$group_ids)) { |
| 328 | 315 | self::$group_user = self::read($category . '/' . $chat_id . '/' . self::$user_id); |
| 329 | 316 | self::$old_group_user = clone self::$group_user; |
| 330 | - } |
|
| 331 | - else { |
|
| 317 | + } else { |
|
| 332 | 318 | self::$group_ids[] = self::$user_id; |
| 333 | 319 | self::$group_user = (object) self::$group_user_default_data; |
| 334 | 320 | } |
| 335 | 321 | |
| 336 | 322 | self::$user = self::read($category.'/'.self::$user_id); |
| 337 | 323 | self::$old_user = clone self::$user; |
| 338 | - if (!empty(self::$user)) self::$user->last_active = time(); |
|
| 324 | + if (!empty(self::$user)) { |
|
| 325 | + self::$user->last_active = time(); |
|
| 326 | + } |
|
| 339 | 327 | } |
| 340 | 328 | } |
| 341 | 329 | |
@@ -349,15 +337,13 @@ discard block |
||
| 349 | 337 | self::$old_user = clone self::$user; |
| 350 | 338 | self::$user->last_active = time(); |
| 351 | 339 | } |
| 352 | - } |
|
| 353 | - elseif ($type === chatType::CHANNEL) { |
|
| 340 | + } elseif ($type === chatType::CHANNEL) { |
|
| 354 | 341 | self::$channel_id = $update->message->chat->id; |
| 355 | 342 | if (in_array(self::$channel_id,self::$ids[$category])) { |
| 356 | 343 | self::$channel = self::read($category . '/' . self::$channel_id); |
| 357 | 344 | self::$old_channel = clone self::$channel; |
| 358 | 345 | } |
| 359 | - } |
|
| 360 | - else { |
|
| 346 | + } else { |
|
| 361 | 347 | self::$user_id = $update->from->id; |
| 362 | 348 | $chat_id = $update->message->chat->id; |
| 363 | 349 | if (in_array($chat_id,self::$ids[$category])) { |
@@ -365,8 +351,7 @@ discard block |
||
| 365 | 351 | self::$supergroup_id = $update->message->chat->id; |
| 366 | 352 | self::$supergroup = self::read($category . '/' . $chat_id); |
| 367 | 353 | self::$old_supergroup = clone self::$supergroup; |
| 368 | - } |
|
| 369 | - else { |
|
| 354 | + } else { |
|
| 370 | 355 | self::$group_id = $update->message->chat->id; |
| 371 | 356 | self::$group = self::read($category . '/' . $chat_id); |
| 372 | 357 | self::$old_group = clone self::$group; |
@@ -383,7 +368,9 @@ discard block |
||
| 383 | 368 | |
| 384 | 369 | self::$user = self::read($category.'/'.self::$user_id); |
| 385 | 370 | self::$old_user = clone self::$user; |
| 386 | - if (!empty(self::$user)) self::$user->last_active = time(); |
|
| 371 | + if (!empty(self::$user)) { |
|
| 372 | + self::$user->last_active = time(); |
|
| 373 | + } |
|
| 387 | 374 | } |
| 388 | 375 | } |
| 389 | 376 | |
@@ -409,13 +396,11 @@ discard block |
||
| 409 | 396 | if (in_array(self::$channel_id,self::$ids[$category])) { |
| 410 | 397 | self::$channel = self::read($category . '/' . self::$channel_id); |
| 411 | 398 | self::$old_channel = clone self::$channel; |
| 412 | - } |
|
| 413 | - else { |
|
| 399 | + } else { |
|
| 414 | 400 | self::$ids[$category][] = self::$channel_id; |
| 415 | 401 | self::$channel = (object) self::$channel_default_data; |
| 416 | 402 | } |
| 417 | - } |
|
| 418 | - else { |
|
| 403 | + } else { |
|
| 419 | 404 | $chat_id = $update->chat->id; |
| 420 | 405 | $by_id = $update->from->id; |
| 421 | 406 | $old_user = $update->old_chat_member; |
@@ -431,22 +416,19 @@ discard block |
||
| 431 | 416 | self::$old_supergroup = clone self::$supergroup; |
| 432 | 417 | self::$group_ids = self::read($category . '/' . $chat_id . '/users'); |
| 433 | 418 | self::$old_group_ids = clone self::$group_ids; |
| 434 | - } |
|
| 435 | - else { |
|
| 419 | + } else { |
|
| 436 | 420 | self::$ids[$category][] = $chat_id; |
| 437 | 421 | self::$supergroup = (object) self::$supergroup_default_data; |
| 438 | 422 | self::$group_ids = []; |
| 439 | 423 | } |
| 440 | - } |
|
| 441 | - elseif ($type === chatType::GROUP) { |
|
| 424 | + } elseif ($type === chatType::GROUP) { |
|
| 442 | 425 | self::$group_id = $chat_id; |
| 443 | 426 | if (in_array($chat_id,self::$ids[$category])) { |
| 444 | 427 | self::$group = self::read($category . '/' . $chat_id); |
| 445 | 428 | self::$old_group = clone self::$group; |
| 446 | 429 | self::$group_ids = self::read($category . '/' . $chat_id . '/users'); |
| 447 | 430 | self::$old_group_ids = clone self::$group_ids; |
| 448 | - } |
|
| 449 | - else { |
|
| 431 | + } else { |
|
| 450 | 432 | self::$ids[$category][] = $chat_id; |
| 451 | 433 | self::$group = (object) self::$group_default_data; |
| 452 | 434 | self::$group_ids = []; |
@@ -456,8 +438,7 @@ discard block |
||
| 456 | 438 | if (!in_array($user_id,self::$group_ids)) { |
| 457 | 439 | self::$group_ids[] = $user_id; |
| 458 | 440 | self::$group_user = (object) self::$group_user_default_data; |
| 459 | - } |
|
| 460 | - else { |
|
| 441 | + } else { |
|
| 461 | 442 | self::$group_user_id = $by_id == $user_id ? $user_id : $by_id; |
| 462 | 443 | self::$group_user = self::read($category . '/' . $chat_id . '/' . self::$group_user_id); |
| 463 | 444 | } |
@@ -470,8 +451,7 @@ discard block |
||
| 470 | 451 | self::$group_user->removed_by = $by_id; |
| 471 | 452 | } |
| 472 | 453 | } |
| 473 | - } |
|
| 474 | - else { |
|
| 454 | + } else { |
|
| 475 | 455 | if ($old_user->status === chatMemberStatus::LEFT || $old_user->status === chatMemberStatus::KICKED) { |
| 476 | 456 | self::$group_user->presence = true; |
| 477 | 457 | self::$group_user->removed = false; |
@@ -481,8 +461,7 @@ discard block |
||
| 481 | 461 | if (!empty($invite_link)) { |
| 482 | 462 | self::$group_user->accepted_by = $by_id; |
| 483 | 463 | self::$group_user->invited_by = null; |
| 484 | - } |
|
| 485 | - else { |
|
| 464 | + } else { |
|
| 486 | 465 | self::$group_user->invited_by = $by_id; |
| 487 | 466 | self::$group_user->accepted_by = null; |
| 488 | 467 | } |
@@ -501,7 +480,9 @@ discard block |
||
| 501 | 480 | * @throws bptException |
| 502 | 481 | */ |
| 503 | 482 | public static function deleteUser (int $user_id = null): bool { |
| 504 | - if (empty($user_id)) $user_id = telegram::catchFields(fields::USER_ID); |
|
| 483 | + if (empty($user_id)) { |
|
| 484 | + $user_id = telegram::catchFields(fields::USER_ID); |
|
| 485 | + } |
|
| 505 | 486 | if (file_exists(self::$folder . '/privates/' . $user_id . '.json')) { |
| 506 | 487 | unset(self::$ids['privates'][array_search($user_id, self::$ids['privates'])]); |
| 507 | 488 | sort(self::$ids['privates']); |
@@ -522,7 +503,9 @@ discard block |
||
| 522 | 503 | * @throws bptException |
| 523 | 504 | */ |
| 524 | 505 | public static function deleteGroup (int $group_id = null): bool { |
| 525 | - if (empty($group_id)) $group_id = telegram::catchFields(fields::CHAT_ID); |
|
| 506 | + if (empty($group_id)) { |
|
| 507 | + $group_id = telegram::catchFields(fields::CHAT_ID); |
|
| 508 | + } |
|
| 526 | 509 | if (file_exists(self::$folder . '/groups/' . $group_id . '.json')) { |
| 527 | 510 | unset(self::$ids['groups'][array_search($group_id, self::$ids['groups'])]); |
| 528 | 511 | sort(self::$ids['groups']); |
@@ -544,7 +527,9 @@ discard block |
||
| 544 | 527 | * @throws bptException |
| 545 | 528 | */ |
| 546 | 529 | public static function deleteSuperGroup (int $group_id = null): bool { |
| 547 | - if (empty($group_id)) $group_id = telegram::catchFields(fields::CHAT_ID); |
|
| 530 | + if (empty($group_id)) { |
|
| 531 | + $group_id = telegram::catchFields(fields::CHAT_ID); |
|
| 532 | + } |
|
| 548 | 533 | if (file_exists(self::$folder . '/supergroups/' . $group_id . '.json')) { |
| 549 | 534 | unset(self::$ids['supergroups'][array_search($group_id, self::$ids['supergroups'])]); |
| 550 | 535 | sort(self::$ids['supergroups']); |
@@ -566,7 +551,9 @@ discard block |
||
| 566 | 551 | * @throws bptException |
| 567 | 552 | */ |
| 568 | 553 | public static function deleteChannel (int $channel_id = null): bool { |
| 569 | - if (empty($channel_id)) $channel_id = telegram::catchFields(fields::CHAT_ID); |
|
| 554 | + if (empty($channel_id)) { |
|
| 555 | + $channel_id = telegram::catchFields(fields::CHAT_ID); |
|
| 556 | + } |
|
| 570 | 557 | if (file_exists(self::$folder . '/channels/' . $channel_id . '.json')) { |
| 571 | 558 | unset(self::$ids['channels'][array_search($channel_id, self::$ids['channels'])]); |
| 572 | 559 | sort(self::$ids['channels']); |
@@ -37,7 +37,7 @@ discard block |
||
| 37 | 37 | public string $big_file_unique_id; |
| 38 | 38 | |
| 39 | 39 | |
| 40 | - public function __construct(stdClass|null $object = null) { |
|
| 40 | + public function __construct(stdClass | null $object = null) { |
|
| 41 | 41 | if ($object != null) { |
| 42 | 42 | parent::__construct($object, self::subs); |
| 43 | 43 | } |
@@ -59,7 +59,7 @@ discard block |
||
| 59 | 59 | * |
| 60 | 60 | * @return bool|string string will be returned when destination doesn't set |
| 61 | 61 | */ |
| 62 | - public function download(string|null $destination = null,bool $big = true): bool|string { |
|
| 63 | - return telegram::downloadFile($destination ?? $this->file_name ?? 'unknown.mp4',$big ? $this->big_file_id : $this->small_file_id); |
|
| 62 | + public function download(string | null $destination = null, bool $big = true): bool | string { |
|
| 63 | + return telegram::downloadFile($destination ?? $this->file_name ?? 'unknown.mp4', $big ? $this->big_file_id : $this->small_file_id); |
|
| 64 | 64 | } |
| 65 | 65 | } |
@@ -26,7 +26,7 @@ discard block |
||
| 26 | 26 | * |
| 27 | 27 | * @return string|int|false string for formatted data , int for normal data , false when size can not be found(file not found or ...) |
| 28 | 28 | */ |
| 29 | - public static function size (string $path, bool $format = true): string|int|false { |
|
| 29 | + public static function size(string $path, bool $format = true): string | int | false { |
|
| 30 | 30 | if (filter_var($path, FILTER_VALIDATE_URL)) { |
| 31 | 31 | $ch = curl_init($path); |
| 32 | 32 | curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); |
@@ -58,7 +58,7 @@ discard block |
||
| 58 | 58 | * @return bool |
| 59 | 59 | * @throws bptException |
| 60 | 60 | */ |
| 61 | - public static function delete (string $path, bool $sub = true): bool { |
|
| 61 | + public static function delete(string $path, bool $sub = true): bool { |
|
| 62 | 62 | if (is_dir($path)) { |
| 63 | 63 | if (count(scandir($path)) > 2) { |
| 64 | 64 | if ($sub) { |
@@ -70,7 +70,7 @@ discard block |
||
| 70 | 70 | return rmdir($path); |
| 71 | 71 | } |
| 72 | 72 | else { |
| 73 | - logger::write("tools::delete function used\ndelete function cannot delete folder because its have subFiles and sub parameter haven't true value",loggerTypes::ERROR); |
|
| 73 | + logger::write("tools::delete function used\ndelete function cannot delete folder because its have subFiles and sub parameter haven't true value", loggerTypes::ERROR); |
|
| 74 | 74 | throw new bptException('DELETE_FOLDER_HAS_SUB'); |
| 75 | 75 | } |
| 76 | 76 | } |
@@ -90,7 +90,7 @@ discard block |
||
| 90 | 90 | * @return bool |
| 91 | 91 | * @throws bptException when zip extension not found |
| 92 | 92 | */ |
| 93 | - public static function zip (string $path, string $destination): bool { |
|
| 93 | + public static function zip(string $path, string $destination): bool { |
|
| 94 | 94 | if (extension_loaded('zip')) { |
| 95 | 95 | $rootPath = realpath($path); |
| 96 | 96 | $zip = new ZipArchive(); |
@@ -127,14 +127,14 @@ discard block |
||
| 127 | 127 | * |
| 128 | 128 | * @return bool true on success and false in failure |
| 129 | 129 | */ |
| 130 | - public static function downloadFile (string $url, string $path,int $chunk_size = 512): bool { |
|
| 130 | + public static function downloadFile(string $url, string $path, int $chunk_size = 512): bool { |
|
| 131 | 131 | $file = fopen($url, 'rb'); |
| 132 | 132 | if (!$file) return false; |
| 133 | 133 | $path = fopen($path, 'wb'); |
| 134 | 134 | if (!$path) return false; |
| 135 | 135 | |
| 136 | 136 | $length = $chunk_size * 1024; |
| 137 | - while (!feof($file)){ |
|
| 137 | + while (!feof($file)) { |
|
| 138 | 138 | fwrite($path, fread($file, $length), $length); |
| 139 | 139 | } |
| 140 | 140 | fclose($path); |
@@ -35,14 +35,14 @@ discard block |
||
| 35 | 35 | curl_exec($ch); |
| 36 | 36 | $size = curl_getinfo($ch, CURLINFO_CONTENT_LENGTH_DOWNLOAD); |
| 37 | 37 | curl_close($ch); |
| 38 | - } |
|
| 39 | - else { |
|
| 38 | + } else { |
|
| 40 | 39 | $size = file_exists($path) ? filesize($path) : false; |
| 41 | 40 | } |
| 42 | 41 | if (isset($size) && is_numeric($size)) { |
| 43 | 42 | return $format ? tools::byteFormat($size) : $size; |
| 43 | + } else { |
|
| 44 | + return false; |
|
| 44 | 45 | } |
| 45 | - else return false; |
|
| 46 | 46 | } |
| 47 | 47 | |
| 48 | 48 | /** |
@@ -68,15 +68,16 @@ discard block |
||
| 68 | 68 | $file->isDir() ? rmdir($file->getRealPath()) : unlink($file->getRealPath()); |
| 69 | 69 | } |
| 70 | 70 | return rmdir($path); |
| 71 | - } |
|
| 72 | - else { |
|
| 71 | + } else { |
|
| 73 | 72 | logger::write("tools::delete function used\ndelete function cannot delete folder because its have subFiles and sub parameter haven't true value",loggerTypes::ERROR); |
| 74 | 73 | throw new bptException('DELETE_FOLDER_HAS_SUB'); |
| 75 | 74 | } |
| 75 | + } else { |
|
| 76 | + return rmdir($path); |
|
| 76 | 77 | } |
| 77 | - else return rmdir($path); |
|
| 78 | + } else { |
|
| 79 | + return unlink($path); |
|
| 78 | 80 | } |
| 79 | - else return unlink($path); |
|
| 80 | 81 | } |
| 81 | 82 | |
| 82 | 83 | /** |
@@ -104,13 +105,11 @@ discard block |
||
| 104 | 105 | $zip->addFile($filePath, substr($filePath, $root_len)); |
| 105 | 106 | } |
| 106 | 107 | } |
| 107 | - } |
|
| 108 | - else { |
|
| 108 | + } else { |
|
| 109 | 109 | $zip->addFile($path, basename($path)); |
| 110 | 110 | } |
| 111 | 111 | return $zip->close(); |
| 112 | - } |
|
| 113 | - else { |
|
| 112 | + } else { |
|
| 114 | 113 | logger::write("tools::zip function used\nzip extension is not found , It may not be installed or enabled", loggerTypes::ERROR); |
| 115 | 114 | throw new bptException('ZIP_EXTENSION_MISSING'); |
| 116 | 115 | } |
@@ -129,9 +128,13 @@ discard block |
||
| 129 | 128 | */ |
| 130 | 129 | public static function downloadFile (string $url, string $path,int $chunk_size = 512): bool { |
| 131 | 130 | $file = fopen($url, 'rb'); |
| 132 | - if (!$file) return false; |
|
| 131 | + if (!$file) { |
|
| 132 | + return false; |
|
| 133 | + } |
|
| 133 | 134 | $path = fopen($path, 'wb'); |
| 134 | - if (!$path) return false; |
|
| 135 | + if (!$path) { |
|
| 136 | + return false; |
|
| 137 | + } |
|
| 135 | 138 | |
| 136 | 139 | $length = $chunk_size * 1024; |
| 137 | 140 | while (!feof($file)){ |
@@ -11,7 +11,7 @@ |
||
| 11 | 11 | /** Keep all of properties which has sub properties */ |
| 12 | 12 | private const subs = []; |
| 13 | 13 | |
| 14 | - public function __construct(stdClass|null $object = null) { |
|
| 14 | + public function __construct(stdClass | null $object = null) { |
|
| 15 | 15 | if ($object != null) { |
| 16 | 16 | parent::__construct($object, self::subs); |
| 17 | 17 | } |