mirror of
https://github.com/Terranom674/Piwigo_Bratonien_Tools.git
synced 2026-09-19 16:24:33 +00:00
Add migration-to-native NC Connector normalizer
This commit is contained in:
Terranom674
149
nc-connector-normalize.php
Normal file
149
nc-connector-normalize.php
Normal file
@@ -0,0 +1,149 @@
|
||||
#!/usr/bin/env php
|
||||
<?php
|
||||
if (PHP_SAPI !== 'cli')
|
||||
{
|
||||
fwrite(STDERR, "Dieses Hilfsprogramm darf nur auf der Kommandozeile ausgefuehrt werden.\n");
|
||||
exit(1);
|
||||
}
|
||||
if (function_exists('posix_geteuid') && posix_geteuid() !== 0)
|
||||
{
|
||||
fwrite(STDERR, "Bitte als root ausfuehren.\n");
|
||||
exit(1);
|
||||
}
|
||||
if ($argc !== 2 || !preg_match('/^[1-9][0-9]*$/', $argv[1]))
|
||||
{
|
||||
fwrite(STDERR, "Aufruf: php nc-connector-normalize.php <connection-id>\n");
|
||||
exit(1);
|
||||
}
|
||||
|
||||
$id = (int)$argv[1];
|
||||
$pluginRoot = __DIR__;
|
||||
$piwigoRoot = dirname(__DIR__, 2);
|
||||
$dbConfig = $piwigoRoot.'/local/config/database.inc.php';
|
||||
$configPath = '/etc/bratonien-tools/nc-connector/connection-'.$id.'.conf';
|
||||
$newState = '/var/lib/bratonien-tools/nc-connector/connection-'.$id;
|
||||
$servicePath = '/etc/systemd/system/bratonien-nc-connector.service';
|
||||
$timer = 'bratonien-nc-connector.timer';
|
||||
$service = 'bratonien-nc-connector.service';
|
||||
|
||||
function normalize_run(array $command, $allowFailure = false)
|
||||
{
|
||||
$spec = array(0=>array('file','/dev/null','r'), 1=>array('pipe','w'), 2=>array('pipe','w'));
|
||||
$process = proc_open($command, $spec, $pipes);
|
||||
if (!is_resource($process)) throw new RuntimeException('Prozess konnte nicht gestartet werden.');
|
||||
$stdout = stream_get_contents($pipes[1]);
|
||||
$stderr = stream_get_contents($pipes[2]);
|
||||
fclose($pipes[1]); fclose($pipes[2]);
|
||||
$exit = proc_close($process);
|
||||
if ($exit !== 0 && !$allowFailure)
|
||||
{
|
||||
$detail = trim($stderr) !== '' ? trim($stderr) : trim($stdout);
|
||||
throw new RuntimeException('Befehl fehlgeschlagen ('.$exit.'): '.implode(' ', $command).($detail !== '' ? "\n".$detail : ''));
|
||||
}
|
||||
return array('exit'=>$exit, 'stdout'=>$stdout, 'stderr'=>$stderr);
|
||||
}
|
||||
|
||||
function remove_tree($path)
|
||||
{
|
||||
if (!is_dir($path)) return;
|
||||
$items = new RecursiveIteratorIterator(
|
||||
new RecursiveDirectoryIterator($path, FilesystemIterator::SKIP_DOTS),
|
||||
RecursiveIteratorIterator::CHILD_FIRST
|
||||
);
|
||||
foreach ($items as $item)
|
||||
{
|
||||
if ($item->isDir()) @rmdir($item->getPathname()); else @unlink($item->getPathname());
|
||||
}
|
||||
@rmdir($path);
|
||||
}
|
||||
|
||||
try
|
||||
{
|
||||
$conf = array();
|
||||
$prefixeTable = 'piwigo_';
|
||||
if (!is_readable($dbConfig)) throw new RuntimeException('Piwigo-Datenbankkonfiguration nicht lesbar.');
|
||||
require $dbConfig;
|
||||
$db = new mysqli($conf['db_host'], $conf['db_user'], $conf['db_password'], $conf['db_base']);
|
||||
if ($db->connect_errno) throw new RuntimeException('Piwigo-Datenbank nicht erreichbar: '.$db->connect_error);
|
||||
$db->set_charset('utf8mb4');
|
||||
$table = $prefixeTable.'bratonien_tools_nc_connections';
|
||||
$result = $db->query("SELECT id, enabled, takeover_state, config_json FROM `".$table."` WHERE id=".$id." LIMIT 1");
|
||||
if (!$result || !$result->num_rows) throw new RuntimeException('Connector-Verbindung #'.$id.' wurde nicht gefunden.');
|
||||
$row = $result->fetch_assoc();
|
||||
if ((int)$row['enabled'] !== 1 || (string)$row['takeover_state'] !== 'active') throw new RuntimeException('Die Verbindung muss aktiv sein.');
|
||||
$config = json_decode((string)$row['config_json'], true);
|
||||
if (!is_array($config)) throw new RuntimeException('Connector-Konfiguration ist ungueltig.');
|
||||
$oldState = rtrim((string)($config['state_dir'] ?? ''), '/');
|
||||
if ($oldState === '') throw new RuntimeException('Bisheriger State-Pfad fehlt.');
|
||||
if ($oldState === $newState)
|
||||
{
|
||||
echo "Verbindung #".$id." verwendet bereits den nativen State-Pfad.\n";
|
||||
exit(0);
|
||||
}
|
||||
if (!is_readable($configPath)) throw new RuntimeException('Aktive Runtime-Konfiguration fehlt: '.$configPath);
|
||||
|
||||
echo "Stoppe Connector-Timer...\n";
|
||||
normalize_run(array('systemctl','stop',$timer));
|
||||
$deadline = time() + 120;
|
||||
while (normalize_run(array('systemctl','is-active','--quiet',$service), true)['exit'] === 0)
|
||||
{
|
||||
if (time() >= $deadline) throw new RuntimeException('Laufender Connector-Lauf wurde nach 120 Sekunden nicht beendet.');
|
||||
sleep(2);
|
||||
}
|
||||
|
||||
if (!is_dir(dirname($newState)) && !mkdir(dirname($newState), 0750, true)) throw new RuntimeException('Neues State-Wurzelverzeichnis konnte nicht angelegt werden.');
|
||||
if (!is_dir($newState) && !mkdir($newState, 0750, true)) throw new RuntimeException('Neues State-Verzeichnis konnte nicht angelegt werden.');
|
||||
if (is_dir($oldState)) normalize_run(array('cp','-a',$oldState.'/.',$newState.'/'));
|
||||
chmod($newState, 0750);
|
||||
|
||||
$originalConfig = file_get_contents($configPath);
|
||||
if (!is_string($originalConfig)) throw new RuntimeException('Runtime-Konfiguration konnte nicht gelesen werden.');
|
||||
$newStatus = $newState.'/connector-status.json';
|
||||
$updatedConfig = preg_replace('/^STATE_DIR=.*$/m', 'STATE_DIR='.$newState, $originalConfig, 1);
|
||||
$updatedConfig = preg_replace('/^STATUS_FILE=.*$/m', 'STATUS_FILE='.$newStatus, $updatedConfig, 1);
|
||||
if (!is_string($updatedConfig) || $updatedConfig === $originalConfig) throw new RuntimeException('Runtime-Konfiguration konnte nicht auf nativen State umgestellt werden.');
|
||||
file_put_contents($configPath, $updatedConfig, LOCK_EX);
|
||||
chmod($configPath, 0600);
|
||||
|
||||
echo "Teste Plugin-Runtime mit neuem State...\n";
|
||||
$test = normalize_run(array('env','PIWIGO_CONFIG='.$configPath,'bash',$pluginRoot.'/runtime/sync.sh'), true);
|
||||
if ($test['exit'] !== 0)
|
||||
{
|
||||
file_put_contents($configPath, $originalConfig, LOCK_EX);
|
||||
remove_tree($newState);
|
||||
normalize_run(array('systemctl','start',$timer), true);
|
||||
$detail = trim($test['stderr']) !== '' ? trim($test['stderr']) : trim($test['stdout']);
|
||||
throw new RuntimeException('Normalisierung abgebrochen; alter Zustand wiederhergestellt'.($detail !== '' ? ': '.$detail : '.'));
|
||||
}
|
||||
|
||||
$serviceContent = "[Unit]\nDescription=Bratonien NC Connector Sync\nAfter=network-online.target\nWants=network-online.target\n\n[Service]\nType=oneshot\nExecStart=/usr/bin/env bash ".$pluginRoot."/runtime/run-all.sh\n\n";
|
||||
file_put_contents($servicePath, $serviceContent, LOCK_EX);
|
||||
chmod($servicePath, 0644);
|
||||
|
||||
$config['state_dir'] = $newState;
|
||||
$config['status_file'] = $newStatus;
|
||||
$config['origin'] = 'native';
|
||||
$config['runtime'] = array('mode'=>'plugin-runtime', 'config'=>$configPath);
|
||||
if (isset($config['takeover']) && is_array($config['takeover'])) $config['takeover']['runtime'] = 'plugin-runtime';
|
||||
$json = json_encode($config, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES);
|
||||
$jsonEsc = $db->real_escape_string((string)$json);
|
||||
$nowEsc = $db->real_escape_string(date('Y-m-d H:i:s'));
|
||||
if (!$db->query("UPDATE `".$table."` SET config_json='".$jsonEsc."', updated='".$nowEsc."' WHERE id=".$id)) throw new RuntimeException('Connector-Datenbankstatus konnte nicht aktualisiert werden: '.$db->error);
|
||||
|
||||
normalize_run(array('systemctl','daemon-reload'));
|
||||
normalize_run(array('systemctl','enable','--now',$timer));
|
||||
|
||||
if ($oldState !== '/var/lib' && $oldState !== '/' && strpos($oldState, '/var/lib/') === 0)
|
||||
{
|
||||
remove_tree($oldState);
|
||||
}
|
||||
|
||||
echo "Normalisierung erfolgreich.\n";
|
||||
echo "State: ".$newState."\n";
|
||||
echo "Service: gemeinsamer Multi-Connection-Runner aus Bratonien Tools.\n";
|
||||
}
|
||||
catch (Throwable $e)
|
||||
{
|
||||
fwrite(STDERR, $e->getMessage()."\n");
|
||||
exit(1);
|
||||
}
|
||||
Reference in New Issue
Block a user