Checks if an incompatible expression is used in output or concatination.
1 | <?php |
||
2 | |||
3 | /** |
||
4 | * Import all updates from a raw updates log file into the database. |
||
5 | * Works for both webhook and getUpdates. |
||
6 | * |
||
7 | * Modify $updates_log_file_path and $mysql_credentials below! |
||
8 | * |
||
9 | * Requires PHP7+ |
||
10 | * |
||
11 | * @todo Move to dedicated CLI tool. |
||
12 | */ |
||
13 | |||
14 | use Longman\TelegramBot\DB; |
||
15 | use Longman\TelegramBot\Entities\Update; |
||
16 | use Longman\TelegramBot\Telegram; |
||
17 | |||
18 | require __DIR__ . '/../vendor/autoload.php'; |
||
19 | |||
20 | // This is the file that contains the raw updates. |
||
21 | $updates_log_file_path = __DIR__ . '/updates.log'; |
||
22 | |||
23 | // Credentials of the database to import updates to. |
||
24 | $mysql_credentials = [ |
||
25 | 'host' => 'localhost', |
||
26 | 'port' => 3306, // optional |
||
27 | 'user' => 'dbuser', |
||
28 | 'password' => 'dbpass', |
||
29 | 'database' => 'dbname', |
||
30 | ]; |
||
31 | |||
32 | try { |
||
33 | // Create dummy Telegram API object and connect to MySQL database. |
||
34 | (new Telegram('1:A'))->enableMySql($mysql_credentials); |
||
35 | |||
36 | // Load the updates log file to iterate over. |
||
37 | $updates_log_file = new SplFileObject($updates_log_file_path); |
||
38 | $updates_log_file->setFlags(SplFileObject::DROP_NEW_LINE | SplFileObject::READ_AHEAD | SplFileObject::SKIP_EMPTY); |
||
39 | |||
40 | foreach ($updates_log_file as $update_json) { |
||
41 | if ($update_arr = json_decode($update_json, true)) { |
||
42 | echo $update_json . PHP_EOL; |
||
0 ignored issues
–
show
Bug
introduced
by
![]() |
|||
43 | |||
44 | // Get all updates on this line. |
||
45 | $updates_data = array_filter($update_arr['result'] ?? [$update_arr]); |
||
46 | foreach ($updates_data as $update_data) { |
||
47 | $update = new Update($update_data); |
||
48 | printf( |
||
49 | 'Update ID %d %s' . PHP_EOL, |
||
50 | $update->getUpdateId(), |
||
51 | DB::insertRequest($update) ? '(success)' : '(failed) ' . implode(' ', DB::getPdo()->errorInfo()) |
||
52 | ); |
||
53 | } |
||
54 | } |
||
55 | } |
||
56 | } catch (Throwable $e) { |
||
57 | // Output any errors. |
||
58 | echo $e; |
||
59 | } |
||
60 |