Make legacy cutover compatible with current connector credential format

nc-connector-cutover-v2.php

@@ -34,31 +34,18 @@ function fail($message)
 
 function readKeyValueFile($path)
 {
-  if (!is_readable($path))
+  if (!is_readable($path)) fail('Konfiguration nicht lesbar: '.$path);
-  {
-    fail('Konfiguration nicht lesbar: '.$path);
-  }
   $result = array();
   foreach (file($path, FILE_IGNORE_NEW_LINES | FILE_SKIP_EMPTY_LINES) as $line)
   {
     $line = trim($line);
-    if ($line === '' || $line[0] === '#')
+    if ($line === '' || $line[0] === '#') continue;
-    {
+    if (!preg_match('/^([A-Z0-9_]+)=(.*)$/', $line, $matches)) continue;
-      continue;
-    }
-    if (!preg_match('/^([A-Z0-9_]+)=(.*)$/', $line, $matches))
-    {
-      continue;
-    }
     $value = trim($matches[2]);
     if (strlen($value) >= 2)
     {
-      $first = $value[0];
+      $first = $value[0]; $last = $value[strlen($value)-1];
-      $last = $value[strlen($value)-1];
+      if (($first === '"' && $last === '"') || ($first === "'" && $last === "'")) $value = substr($value, 1, -1);
-      if (($first === '"' && $last === '"') || ($first === "'" && $last === "'"))
-      {
-        $value = substr($value, 1, -1);
-      }
     }
     $result[$matches[1]] = $value;
   }
@@ -67,49 +54,42 @@ function readKeyValueFile($path)
 
 function runCommand(array $command, $allowFailure = false)
 {
-  $spec = array(
+  $spec = array(0=>array('file','/dev/null','r'),1=>array('pipe','w'),2=>array('pipe','w'));
-    0 => array('file', '/dev/null', 'r'),
-    1 => array('pipe', 'w'),
-    2 => array('pipe', 'w'),
-  );
   $process = proc_open($command, $spec, $pipes);
-  if (!is_resource($process))
+  if (!is_resource($process)) fail('Prozess konnte nicht gestartet werden: '.implode(' ', $command));
-  {
+  $stdout = stream_get_contents($pipes[1]); $stderr = stream_get_contents($pipes[2]);
-    fail('Prozess konnte nicht gestartet werden: '.implode(' ', $command));
+  fclose($pipes[1]); fclose($pipes[2]);
-  }
-  $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);
     fail('Befehl fehlgeschlagen ('.$exit.'): '.implode(' ', $command).($detail !== '' ? "\n".$detail : ''));
   }
-  return array('exit'=>$exit, 'stdout'=>(string)$stdout, 'stderr'=>(string)$stderr);
+  return array('exit'=>$exit,'stdout'=>(string)$stdout,'stderr'=>(string)$stderr);
 }
 
 function decryptConnectorSecret($blob, $hexKey)
 {
-  if (!preg_match('/^[a-f0-9]{64}$/', $hexKey))
+  if (!preg_match('/^[a-f0-9]{64}$/', $hexKey)) fail('Connector-Schluessel ist ungueltig.');
-  {
-    fail('Connector-Schluessel ist ungueltig.');
-  }
   $outer = base64_decode(trim((string)$blob), true);
   $payload = is_string($outer) ? json_decode($outer, true) : null;
-  if (!is_array($payload) || (int)($payload['v'] ?? 0) !== 1)
+  if (!is_array($payload) || (int)($payload['v'] ?? 0) !== 1) fail('Connector-Zugangsdaten haben ein unbekanntes Format.');
-  {
-    fail('Connector-Zugangsdaten haben ein unbekanntes Format.');
-  }
   $iv = base64_decode((string)($payload['iv'] ?? ''), true);
   $tag = base64_decode((string)($payload['tag'] ?? ''), true);
   $cipher = base64_decode((string)($payload['data'] ?? ''), true);
   $plain = openssl_decrypt($cipher, 'aes-256-gcm', hex2bin($hexKey), OPENSSL_RAW_DATA, $iv, $tag);
-  if ($plain === false || $plain === '')
+  if ($plain === false || $plain === '') fail('Connector-Zugangsdaten konnten nicht entschluesselt werden.');
+
+  $decoded = json_decode($plain, true);
+  if (is_array($decoded) && array_key_exists('db_password', $decoded))
   {
-    fail('Connector-Zugangsdaten konnten nicht entschluesselt werden.');
+    $password = (string)$decoded['db_password'];
+    if ($password === '') fail('Datenbankpasswort fehlt in den Connector-Zugangsdaten.');
+    return $password;
   }
+
+  // Backward compatibility for older imported connections that stored only
+  // the database password as plaintext inside the encrypted envelope.
   return (string)$plain;
 }
 
@@ -121,16 +101,10 @@ function sqlEscape(mysqli $db, $value)
 function saveTakeoverResult(mysqli $db, $table, $connectionId, array $config, $state, $enabled)
 {
   $json = json_encode($config, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES);
-  if (!is_string($json))
+  if (!is_string($json)) fail('Connector-Status konnte nicht serialisiert werden.');
-  {
-    fail('Connector-Status konnte nicht serialisiert werden.');
-  }
   $now = date('Y-m-d H:i:s');
   $sql = "UPDATE `".$table."` SET takeover_state='".sqlEscape($db, $state)."', enabled=".($enabled ? 1 : 0).", config_json='".sqlEscape($db, $json)."', updated='".sqlEscape($db, $now)."' WHERE id=".(int)$connectionId;
-  if (!$db->query($sql))
+  if (!$db->query($sql)) fail('Connector-Status konnte nicht gespeichert werden: '.$db->error);
-  {
-    fail('Connector-Status konnte nicht gespeichert werden: '.$db->error);
-  }
 }
 
 $legacyTimerWasEnabled = false;
@@ -141,84 +115,43 @@ $config = array();
 
 try
 {
-  if (!is_readable($dbConfig))
+  if (!is_readable($dbConfig)) fail('Piwigo-Datenbankkonfiguration nicht lesbar: '.$dbConfig);
-  {
+  if (!is_executable($legacyRuntime)) fail('Bestehende Sync-Runtime fehlt: '.$legacyRuntime);
-    fail('Piwigo-Datenbankkonfiguration nicht lesbar: '.$dbConfig);
-  }
-  if (!is_executable($legacyRuntime))
-  {
-    fail('Bestehende Sync-Runtime fehlt: '.$legacyRuntime);
-  }
 
-  $conf = array();
+  $conf = array(); $prefixeTable = 'piwigo_'; require $dbConfig;
-  $prefixeTable = 'piwigo_';
+  foreach (array('db_host','db_user','db_password','db_base') as $key) if (!isset($conf[$key])) fail('Piwigo-Datenbankkonfiguration enthaelt '.$key.' nicht.');
-  require $dbConfig;
-  foreach (array('db_host','db_user','db_password','db_base') as $key)
-  {
-    if (!isset($conf[$key]))
-    {
-      fail('Piwigo-Datenbankkonfiguration enthaelt '.$key.' nicht.');
-    }
-  }
 
   $db = new mysqli($conf['db_host'], $conf['db_user'], $conf['db_password'], $conf['db_base']);
-  if ($db->connect_errno)
+  if ($db->connect_errno) fail('Piwigo-Datenbank nicht erreichbar: '.$db->connect_error);
-  {
-    fail('Piwigo-Datenbank nicht erreichbar: '.$db->connect_error);
-  }
   $db->set_charset('utf8mb4');
 
   $table = $prefixeTable.'bratonien_tools_nc_connections';
   $result = $db->query("SELECT id, takeover_state, enabled, config_json, secret_blob FROM `".$table."` WHERE id=".$connectionId." LIMIT 1");
-  if (!$result || !$result->num_rows)
+  if (!$result || !$result->num_rows) fail('Connector-Verbindung #'.$connectionId.' wurde nicht gefunden.');
-  {
-    fail('Connector-Verbindung #'.$connectionId.' wurde nicht gefunden.');
-  }
   $row = $result->fetch_assoc();
-  if ((string)$row['takeover_state'] !== 'ready' || (int)$row['enabled'] !== 0)
+  if ((string)$row['takeover_state'] !== 'ready' || (int)$row['enabled'] !== 0) fail('Connector-Verbindung muss im Zustand ready und deaktiviert sein.');
-  {
-    fail('Connector-Verbindung muss im Zustand ready und deaktiviert sein.');
-  }
   $config = json_decode((string)$row['config_json'], true);
-  if (!is_array($config) || empty($config['verification']['ok']))
+  if (!is_array($config) || empty($config['verification']['ok'])) fail('Connector-Verbindung besitzt keine erfolgreiche Verifikation.');
-  {
-    fail('Connector-Verbindung besitzt keine erfolgreiche Verifikation.');
-  }
 
   $keyResult = $db->query("SELECT value FROM `".$prefixeTable."config` WHERE param='bratonien_nc_connector_secret' LIMIT 1");
-  if (!$keyResult || !$keyResult->num_rows)
+  if (!$keyResult || !$keyResult->num_rows) fail('Connector-Schluessel wurde in Piwigo nicht gefunden.');
-  {
-    fail('Connector-Schluessel wurde in Piwigo nicht gefunden.');
-  }
   $keyRow = $keyResult->fetch_assoc();
   $dbPassword = decryptConnectorSecret($row['secret_blob'], (string)$keyRow['value']);
 
   $legacy = readKeyValueFile($legacyConfig);
   $piwigoUser = trim((string)($legacy['PIWIGO_SYNC_USER'] ?? ''));
   $piwigoPasswordFile = trim((string)($legacy['PIWIGO_SYNC_PASSWORD_FILE'] ?? '/etc/piwigo-sync/piwigo-password'));
-  if ($piwigoUser === '' || !is_readable($piwigoPasswordFile))
+  if ($piwigoUser === '' || !is_readable($piwigoPasswordFile)) fail('Legacy-Piwigo-Sync-Zugangsdaten konnten fuer den einmaligen Cutover nicht gelesen werden.');
-  {
-    fail('Legacy-Piwigo-Sync-Zugangsdaten konnten fuer den einmaligen Cutover nicht gelesen werden.');
-  }
   $piwigoPassword = trim((string)file_get_contents($piwigoPasswordFile));
-  if ($piwigoPassword === '')
+  if ($piwigoPassword === '') fail('Legacy-Piwigo-Sync-Passwort ist leer.');
-  {
-    fail('Legacy-Piwigo-Sync-Passwort ist leer.');
-  }
 
   foreach (array('host','port','database','user','source_view','gallery_root','state_dir') as $key)
   {
-    if (!isset($config[$key]) || trim((string)$config[$key]) === '')
+    if (!isset($config[$key]) || trim((string)$config[$key]) === '') fail('Connector-Konfiguration ist unvollstaendig: '.$key.' fehlt.');
-    {
-      fail('Connector-Konfiguration ist unvollstaendig: '.$key.' fehlt.');
-    }
   }
 
   $runtimeDir = '/etc/bratonien-tools/nc-connector';
-  if (!is_dir($runtimeDir) && !mkdir($runtimeDir, 0700, true))
+  if (!is_dir($runtimeDir) && !mkdir($runtimeDir, 0700, true)) fail('Connector-Laufzeitverzeichnis konnte nicht angelegt werden.');
-  {
-    fail('Connector-Laufzeitverzeichnis konnte nicht angelegt werden.');
-  }
   chmod($runtimeDir, 0700);
 
   $base = $runtimeDir.'/connection-'.$connectionId;
@@ -230,16 +163,14 @@ try
 
   file_put_contents($dbPasswordPath, $dbPassword."\n", LOCK_EX);
   file_put_contents($piwigoPasswordPath, $piwigoPassword."\n", LOCK_EX);
-  chmod($dbPasswordPath, 0600);
+  chmod($dbPasswordPath, 0600); chmod($piwigoPasswordPath, 0600);
-  chmod($piwigoPasswordPath, 0600);
 
   $storageLines = array('# storage_id<TAB>source_prefix<TAB>local_mount');
   foreach ((array)($config['storages'] ?? array()) as $storage)
   {
-    $storageLines[] = (string)($storage['storage_id'] ?? '')."\t".(string)($storage['source_prefix'] ?? '')."\t".(string)($storage['local_mount'] ?? '');
+    $storageLines[] = (string)($storage['storage_id'] ?? '')."\t".trim((string)($storage['source_prefix'] ?? ''), '/')."\t".(string)($storage['local_mount'] ?? '');
   }
-  file_put_contents($storagePath, implode("\n", $storageLines)."\n", LOCK_EX);
+  file_put_contents($storagePath, implode("\n", $storageLines)."\n", LOCK_EX); chmod($storagePath, 0600);
-  chmod($storagePath, 0600);
 
   $piwigoRootConfigured = isset($legacy['PIWIGO_ROOT']) && trim((string)$legacy['PIWIGO_ROOT']) !== '' ? trim((string)$legacy['PIWIGO_ROOT']) : $piwigoRoot;
   $lines = array(
@@ -261,8 +192,7 @@ try
     'PIWIGO_SYNC_USER='.$piwigoUser,
     'PIWIGO_SYNC_PASSWORD_FILE='.$piwigoPasswordPath,
   );
-  file_put_contents($configPath, implode("\n", $lines)."\n", LOCK_EX);
+  file_put_contents($configPath, implode("\n", $lines)."\n", LOCK_EX); chmod($configPath, 0600);
-  chmod($configPath, 0600);
 
   $enabledCheck = runCommand(array('systemctl', 'is-enabled', $legacyTimer), true);
   $legacyTimerWasEnabled = $enabledCheck['exit'] === 0;
@@ -274,14 +204,8 @@ try
   do
   {
     $active = runCommand(array('systemctl', 'is-active', '--quiet', 'piwigo-sync.service'), true);
-    if ($active['exit'] !== 0)
+    if ($active['exit'] !== 0) break;
-    {
+    if (time() >= $deadline) fail('Ein laufender Legacy-Sync wurde nach 120 Sekunden nicht beendet.');
-      break;
-    }
-    if (time() >= $deadline)
-    {
-      fail('Ein laufender Legacy-Sync wurde nach 120 Sekunden nicht beendet.');
-    }
     sleep(2);
   }
   while (true);
@@ -295,9 +219,7 @@ try
     fail('Erster Connector-Lauf ist technisch fehlgeschlagen'.($detail !== '' ? ': '.$detail : '.'));
   }
 
-  $runResult = 'no_changes';
+  $runResult = 'no_changes'; $statusState = ''; $statusMessage = '';
-  $statusState = '';
-  $statusMessage = '';
   if (is_readable($statusPath))
   {
     $status = json_decode((string)file_get_contents($statusPath), true);
@@ -306,16 +228,9 @@ try
       $statusState = trim((string)($status['state'] ?? ''));
       $statusMessage = trim((string)($status['message'] ?? ''));
     }
-
     $legacyNoChangeMessage = 'Synchronisierung fehlgeschlagen; bestehende Galerie blieb unverändert';
-    if ($statusState === 'error' && $statusMessage !== $legacyNoChangeMessage)
+    if ($statusState === 'error' && $statusMessage !== $legacyNoChangeMessage) fail('Erster Connector-Lauf meldete einen technischen Fehler'.($statusMessage !== '' ? ': '.$statusMessage : '.'));
-    {
+    if ($statusState === 'ok') $runResult = 'changed';
-      fail('Erster Connector-Lauf meldete einen technischen Fehler'.($statusMessage !== '' ? ': '.$statusMessage : '.'));
-    }
-    if ($statusState === 'ok')
-    {
-      $runResult = 'changed';
-    }
     elseif ($statusState === 'error' && $statusMessage === $legacyNoChangeMessage)
     {
       $runResult = 'no_changes';
@@ -331,28 +246,18 @@ try
   $timerPath = '/etc/systemd/system/'.$newTimer;
   $service = "[Unit]\nDescription=Bratonien NC Connector Sync\nAfter=network-online.target\nWants=network-online.target\n\n[Service]\nType=oneshot\nEnvironment=PIWIGO_CONFIG=".$configPath."\nExecStart=".$legacyRuntime."\n\n";
   $timer = "[Unit]\nDescription=Bratonien NC Connector regelmaessig pruefen\n\n[Timer]\nOnBootSec=3min\nOnUnitActiveSec=1min\nRandomizedDelaySec=15s\nPersistent=true\n\n[Install]\nWantedBy=timers.target\n";
-  file_put_contents($servicePath, $service, LOCK_EX);
+  file_put_contents($servicePath, $service, LOCK_EX); file_put_contents($timerPath, $timer, LOCK_EX); chmod($servicePath,0644); chmod($timerPath,0644); $newTimerInstalled=true;
-  file_put_contents($timerPath, $timer, LOCK_EX);
-  chmod($servicePath, 0644);
-  chmod($timerPath, 0644);
-  $newTimerInstalled = true;
 
-  runCommand(array('systemctl', 'daemon-reload'));
+  runCommand(array('systemctl','daemon-reload'));
-  runCommand(array('systemctl', 'disable', $legacyTimer), true);
+  runCommand(array('systemctl','disable',$legacyTimer),true);
-  runCommand(array('systemctl', 'enable', '--now', $newTimer));
+  runCommand(array('systemctl','enable','--now',$newTimer));
 
-  $config['takeover']['cutover_at'] = date('Y-m-d H:i:s');
+  $config['takeover']['cutover_at']=date('Y-m-d H:i:s');
-  $config['takeover']['legacy_timer_disabled'] = true;
+  $config['takeover']['legacy_timer_disabled']=true;
-  $config['takeover']['connector_timer'] = $newTimer;
+  $config['takeover']['connector_timer']=$newTimer;
-  $config['takeover']['runtime'] = 'legacy-runtime-transition';
+  $config['takeover']['runtime']='legacy-runtime-transition';
-  $config['takeover']['first_run'] = array(
+  $config['takeover']['first_run']=array('state'=>'success','result'=>$runResult,'status_state'=>$statusState,'status_message'=>$statusMessage,'checked_at'=>date('Y-m-d H:i:s'));
-    'state' => 'success',
+  saveTakeoverResult($db,$table,$connectionId,$config,'active',true);
-    'result' => $runResult,
-    'status_state' => $statusState,
-    'status_message' => $statusMessage,
-    'checked_at' => date('Y-m-d H:i:s'),
-  );
-  saveTakeoverResult($db, $table, $connectionId, $config, 'active', true);
 
   echo "Cutover erfolgreich.\n";
   echo "Erster Connector-Lauf: ".$runResult."\n";
@@ -365,32 +270,14 @@ catch (Throwable $e)
   {
     try
     {
-      $config['takeover']['first_run'] = array(
+      $config['takeover']['first_run']=array('state'=>'error','result'=>'error','checked_at'=>date('Y-m-d H:i:s'),'message'=>substr($e->getMessage(),0,500));
-        'state' => 'error',
+      saveTakeoverResult($db,$table,$connectionId,$config,'ready',false);
-        'result' => 'error',
-        'checked_at' => date('Y-m-d H:i:s'),
-        'message' => substr($e->getMessage(), 0, 500),
-      );
-      saveTakeoverResult($db, $table, $connectionId, $config, 'ready', false);
     }
-    catch (Throwable $ignored)
+    catch (Throwable $ignored){}
-    {
   }
-  }
+  if ($newTimerInstalled) runCommand(array('systemctl','disable','--now',$newTimer),true);
-
+  if ($legacyTimerWasEnabled) runCommand(array('systemctl','enable','--now',$legacyTimer),true);
-  if ($newTimerInstalled)
+  else runCommand(array('systemctl','start',$legacyTimer),true);
-  {
-    runCommand(array('systemctl', 'disable', '--now', $newTimer), true);
-  }
-  if ($legacyTimerWasEnabled)
-  {
-    runCommand(array('systemctl', 'enable', '--now', $legacyTimer), true);
-  }
-  else
-  {
-    runCommand(array('systemctl', 'start', $legacyTimer), true);
-  }
-
   fwrite(STDERR, "Cutover fehlgeschlagen: ".$e->getMessage()."\n");
   fwrite(STDERR, "Legacy-Timer wurde wieder aktiviert/gestartet.\n");
   exit(1);