You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
84 lines
1.6 KiB
84 lines
1.6 KiB
3 years ago
|
<?php
|
||
|
|
|
||
|
|
// Dependencies
|
||
|
|
require(dirname(dirname(__DIR__)) . '/src/config.php');
|
||
|
|
|
||
|
|
require(PROJECT_DIR . '/application/model/model.php');
|
||
|
|
require(PROJECT_DIR . '/application/model/user.php');
|
||
|
|
require(PROJECT_DIR . '/application/model/block.php');
|
||
|
|
|
||
|
|
require(PROJECT_DIR . '/system/curl.php');
|
||
|
|
require(PROJECT_DIR . '/system/twister.php');
|
||
|
|
|
||
|
|
// Init libraries
|
||
|
|
$_twister = new Twister(
|
||
|
|
new Curl(
|
||
|
|
TWISTER_PROTOCOL,
|
||
|
|
TWISTER_HOST,
|
||
|
|
TWISTER_PORT,
|
||
|
|
TWISTER_USER,
|
||
|
|
TWISTER_PASSWORD,
|
||
|
|
TWISTER_SSL
|
||
|
|
)
|
||
|
|
);
|
||
|
|
|
||
|
|
// Init models
|
||
|
|
$_modelUser = new ModelUser(
|
||
|
|
DB_DATABASE,
|
||
|
|
DB_HOST,
|
||
|
|
DB_PORT,
|
||
|
|
DB_USER,
|
||
|
|
DB_PASSWORD
|
||
|
|
);
|
||
|
|
|
||
|
|
$_modelBlock = new ModelBlock(
|
||
|
|
DB_DATABASE,
|
||
|
|
DB_HOST,
|
||
|
|
DB_PORT,
|
||
|
|
DB_USER,
|
||
|
|
DB_PASSWORD
|
||
|
|
);
|
||
|
|
|
||
|
|
print("import begin...\n");
|
||
|
|
|
||
|
|
$nextBlock = $_modelBlock->getNextBlock();
|
||
|
|
|
||
|
|
while (true) {
|
||
|
|
|
||
|
|
if (!$blockHash = $_twister->getBlockHash($nextBlock)) {
|
||
|
|
|
||
|
|
print("database up to date\n");
|
||
|
|
exit;
|
||
|
|
}
|
||
|
|
|
||
|
|
if (!$block = $_twister->getBlock($blockHash)) {
|
||
|
|
|
||
|
|
trigger_error(sprintf('could not receive block info on %s (%s)', $nextBlock, $blockHash));
|
||
|
|
exit;
|
||
|
|
}
|
||
|
|
|
||
|
|
// Add block
|
||
|
|
if ($blockId = $_modelBlock->addBlock($blockHash, time())) {
|
||
|
|
|
||
|
|
print(sprintf("add block %s\n", $blockId));
|
||
|
|
|
||
|
|
// Add users
|
||
|
|
foreach ($block['usernames'] as $userName) {
|
||
|
|
|
||
|
|
if (!$_modelUser->addUser($blockId, $userName)) {
|
||
|
|
trigger_error(sprintf('could not add user %s in block %s)', $userName, $blockId));
|
||
|
|
exit;
|
||
|
|
}
|
||
|
|
|
||
|
|
print(sprintf("add user %s\n", $userName));
|
||
|
|
}
|
||
|
|
|
||
|
|
// Update queue
|
||
|
|
$nextBlock++;
|
||
|
|
|
||
|
|
} else {
|
||
|
|
|
||
|
|
trigger_error(sprintf('could not add block %s (%s)', $nextBlock, $blockHash));
|
||
|
|
exit;
|
||
|
|
}
|
||
|
|
}
|