Page MenuHomePhabricator (Chris)
Files F632527

importFromLog.php
No OneTemporary
Actions

Authored By
Unknown
Size
1 KB
Referenced Files
None
Subscribers
None

importFromLog.php
View Options

<?php
/**
* Import all updates from a raw updates log file into the database.
* Works for both webhook and getUpdates.
*
* Modify $updates_log_file_path and $mysql_credentials below!
*
* Requires PHP7+
*
* @todo Move to dedicated CLI tool.
*/
use Longman\TelegramBot\DB;
use Longman\TelegramBot\Entities\Update;
use Longman\TelegramBot\Telegram;
require __DIR__ . '/../vendor/autoload.php';
// This is the file that contains the raw updates.
$updates_log_file_path = __DIR__ . '/updates.log';
// Credentials of the database to import updates to.
$mysql_credentials = [
'host' => 'localhost',
'port' => 3306, // optional
'user' => 'dbuser',
'password' => 'dbpass',
'database' => 'dbname',
];
try {
// Create dummy Telegram API object and connect to MySQL database.
(new Telegram('1:A'))->enableMySql($mysql_credentials);
// Load the updates log file to iterate over.
$updates_log_file = new SplFileObject($updates_log_file_path);
$updates_log_file->setFlags(SplFileObject::DROP_NEW_LINE | SplFileObject::READ_AHEAD | SplFileObject::SKIP_EMPTY);
foreach ($updates_log_file as $update_json) {
if ($update_arr = json_decode($update_json, true)) {
echo $update_json . PHP_EOL;
// Get all updates on this line.
$updates_data = array_filter($update_arr['result'] ?? [$update_arr]);
foreach ($updates_data as $update_data) {
$update = new Update($update_data);
printf(
'Update ID %d %s' . PHP_EOL,
$update->getUpdateId(),
DB::insertRequest($update) ? '(success)' : '(failed) ' . implode(' ', DB::getPdo()->errorInfo())
);
}
}
}
} catch (Throwable $e) {
// Output any errors.
echo $e;
}

File Metadata

Mime Type
text/x-php
Expires
Sun, Nov 15, 2:36 PM (1 d, 1 h)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
131505
Default Alt Text
importFromLog.php (1 KB)

Event Timeline