khanat-code-old/code/web/private_php/ams/autoload/sync.php

98 lines
4.8 KiB
PHP
Raw Normal View History

<?php
/**
* handler for performing changes when shard is back online after being offline.
* the sync class is responsible for the syncdata function, which will synchronise the website with the shard
* (when the shard is offline, users can still change their password, email or even register)
* @author Daan Janssens, mentored by Matthew Lagoe
*/
class Sync{
/**
* performs the actions listed in the querycache.
* All entries in the querycache will be read and performed depending on their type.
* This is done because the shard could have been offline and we want changes made on the website (which is still online) to eventually hit the shard.
* These changes are: createPermissions, createUser, change_pass, change_mail
*/
2014-09-05 09:21:00 +00:00
static public function syncdata ($display = false) {
if (function_exists('pcntl_fork')) {
$pid = pcntl_fork();
}
2014-09-05 09:10:09 +00:00
global $AMS_TMPDIR;
$pidfile = $AMS_TMPDIR.'/ams_cron_pid';
2013-10-24 00:08:27 +00:00
2014-09-05 09:10:09 +00:00
if(isset($pid) and function_exists('pcntl_fork') ) {
2013-10-24 00:08:27 +00:00
// We're the main process.
} else {
if(!file_exists($pidfile)) {
$pid = getmypid();
2014-09-05 09:10:09 +00:00
$file = fopen($pidfile, 'w+');
2014-09-06 02:26:12 +00:00
if (!$file)
echo $pidfile.' is not writeable.';
error_log($pidfile.' is not writeable.');
throw new SystemExit();
}
2013-10-24 00:08:27 +00:00
fwrite($file, $pid);
fclose($file);
try {
$dbl = new DBLayer("lib");
$statement = $dbl->executeWithoutParams("SELECT * FROM ams_querycache");
$rows = $statement->fetchAll();
foreach ($rows as $record) {
$db = new DBLayer($record['db']);
switch($record['type']) {
case 'createPermissions':
$decode = json_decode($record['query']);
$values = array('username' => $decode[0]);
//make connection with and put into shard db & delete from the lib
$sth=$db->selectWithParameter("UId", "user", $values, "Login= :username" );
2013-10-24 00:08:27 +00:00
$result = $sth->fetchAll();
foreach ($result as $UId) {
$ins_values = array('UId' => $UId['UId']);
$ins_values['ClientApplication'] = "r2";
$ins_values['AccessPrivilege'] = "OPEN";
$db->insert("permission", $ins_values);
$ins_values['ClientApplication'] = 'ryzom_open';
$db->insert("permission",$ins_values);
2013-10-24 00:08:27 +00:00
}
break;
case 'change_pass':
$decode = json_decode($record['query']);
$values = array('Password' => $decode[1]);
2013-10-24 00:08:27 +00:00
//make connection with and put into shard db & delete from the lib
2014-09-05 09:10:09 +00:00
$db->update("user", $values, "Login = '$decode[0]'");
2013-10-24 00:08:27 +00:00
break;
case 'change_mail':
$decode = json_decode($record['query']);
$values = array('Email' => $decode[1]);
2013-10-24 00:08:27 +00:00
//make connection with and put into shard db & delete from the lib
2014-09-05 09:10:09 +00:00
$db->update("user", $values, "Login = '$decode[0]'");
2013-10-24 00:08:27 +00:00
break;
case 'createUser':
$decode = json_decode($record['query']);
$values = array('Login' => $decode[0], 'Password' => $decode[1], 'Email' => $decode[2] );
2013-10-24 00:08:27 +00:00
//make connection with and put into shard db & delete from the lib
$db->insert("user", $values);
2013-10-24 00:08:27 +00:00
break;
}
$dbl->delete("ams_querycache", array('SID' => $record['SID']), "SID=:SID");
2013-10-24 00:08:27 +00:00
}
if ($display == true) {
print('Syncing completed');
}
}
2013-10-24 00:08:27 +00:00
catch (PDOException $e) {
if ($display == true) {
print('Something went wrong! The shard is probably still offline!');
print_r($e);
}
}
2013-10-24 00:08:27 +00:00
unlink($pidfile);
}
2013-10-24 00:08:27 +00:00
}
}
}