Complete NC connection wizard flow

include/nc_connector_wizard.inc.php

@@ -22,7 +22,23 @@ function bratonien_tools_nc_wizard_state()
     'users' => array(),
     'can_list_users' => false,
     'showcase_user' => '',
+    'connection_name' => '',
     'scan_message' => '',
+    'technical_source' => '',
+    'technical_complete' => false,
+    'db_host' => '',
+    'db_port' => '5432',
+    'db_database' => 'nextcloud',
+    'db_user' => '',
+    'db_password_set' => false,
+    'source_view' => 'piwigo_showcase_sources',
+    'activity_view' => 'piwigo_showcase_activity',
+    'gallery_root' => '',
+    'storages' => array(),
+    'storage_candidates' => array(),
+    'api_status' => 'pending',
+    'api_username' => '',
+    'api_error' => '',
   ), $state);
 }
 
@@ -104,7 +120,6 @@ function bratonien_tools_nc_wizard_http($url, $username = '', $password = '', ar
   $errno = curl_errno($ch);
   $error = curl_error($ch);
   $status = (int)curl_getinfo($ch, CURLINFO_HTTP_CODE);
-  $effective_url = (string)curl_getinfo($ch, CURLINFO_EFFECTIVE_URL);
   curl_close($ch);
 
   if ($body === false || $errno !== 0)
@@ -112,7 +127,7 @@ function bratonien_tools_nc_wizard_http($url, $username = '', $password = '', ar
     throw new RuntimeException('Nextcloud konnte nicht erreicht werden: '.$error);
   }
 
-  return array('status'=>$status, 'body'=>(string)$body, 'url'=>$effective_url);
+  return array('status'=>$status, 'body'=>(string)$body);
 }
 
 function bratonien_tools_nc_wizard_ocs_data($body)
@@ -132,6 +147,76 @@ function bratonien_tools_nc_wizard_ocs_data($body)
   return isset($decoded['ocs']['data']) && is_array($decoded['ocs']['data']) ? $decoded['ocs']['data'] : array();
 }
 
+function bratonien_tools_nc_wizard_fill_profile(array &$state)
+{
+  $url_host = strtolower((string)parse_url($state['base_url'], PHP_URL_HOST));
+  $state['db_host'] = $url_host;
+  $state['db_port'] = '5432';
+  $state['db_database'] = 'nextcloud';
+  $state['source_view'] = 'piwigo_showcase_sources';
+  $state['activity_view'] = 'piwigo_showcase_activity';
+  $state['gallery_root'] = rtrim(PHPWG_ROOT_PATH, '/').'/galleries/nextcloud';
+  $state['technical_source'] = 'Standardwerte vorbereitet';
+
+  foreach (bratonien_tools_nc_connector_connections() as $candidate)
+  {
+    $config = isset($candidate['config']) && is_array($candidate['config']) ? $candidate['config'] : array();
+    $candidate_url = trim((string)($config['nextcloud_url'] ?? ''));
+    $candidate_host = strtolower(trim((string)($config['host'] ?? '')));
+    $match = false;
+
+    if ($candidate_url !== '')
+    {
+      try
+      {
+        $match = bratonien_tools_nc_wizard_normalize_url($candidate_url) === $state['base_url'];
+      }
+      catch (Throwable $ignored)
+      {
+        $match = false;
+      }
+    }
+    if (!$match && $candidate_host !== '' && $candidate_host === $url_host)
+    {
+      $match = true;
+    }
+    if (!$match)
+    {
+      continue;
+    }
+
+    $full = bratonien_tools_nc_connector_connection((int)$candidate['id'], true);
+    if (!$full)
+    {
+      continue;
+    }
+    $credentials = bratonien_tools_nc_connector_credentials_from_blob($full['secret_blob'] ?? '');
+
+    $state['db_host'] = (string)($config['host'] ?? $state['db_host']);
+    $state['db_port'] = (string)($config['port'] ?? $state['db_port']);
+    $state['db_database'] = (string)($config['database'] ?? $state['db_database']);
+    $state['db_user'] = (string)($config['user'] ?? '');
+    $state['_db_password'] = (string)($credentials['db_password'] ?? '');
+    $state['db_password_set'] = $state['_db_password'] !== '';
+    $state['source_view'] = (string)($config['source_view'] ?? $state['source_view']);
+    $state['activity_view'] = (string)($config['activity_view'] ?? $state['activity_view']);
+    $state['gallery_root'] = (string)($config['gallery_root'] ?? $state['gallery_root']);
+    $state['storages'] = isset($config['storages']) && is_array($config['storages']) ? $config['storages'] : array();
+    $state['technical_source'] = 'Passende vorhandene Connector-Konfiguration erkannt';
+    break;
+  }
+
+  $state['technical_complete'] = $state['db_host'] !== ''
+    && $state['db_port'] !== ''
+    && $state['db_database'] !== ''
+    && $state['db_user'] !== ''
+    && !empty($state['db_password_set'])
+    && $state['source_view'] !== ''
+    && $state['activity_view'] !== ''
+    && $state['gallery_root'] !== ''
+    && !empty($state['storages']);
+}
+
 function bratonien_tools_nc_wizard_scan()
 {
   $host_input = trim((string)($_POST['nc_wizard_host'] ?? ''));
@@ -143,7 +228,6 @@ function bratonien_tools_nc_wizard_scan()
   }
 
   $base_url = bratonien_tools_nc_wizard_normalize_url($host_input);
-
   $status_response = bratonien_tools_nc_wizard_http($base_url.'/status.php');
   if ($status_response['status'] < 200 || $status_response['status'] >= 300)
   {
@@ -198,6 +282,7 @@ function bratonien_tools_nc_wizard_scan()
     $can_list_users = false;
   }
 
+  $url_host = (string)parse_url($base_url, PHP_URL_HOST);
   $state = array(
     'step' => 2,
     'scan_ok' => true,
@@ -210,12 +295,158 @@ function bratonien_tools_nc_wizard_scan()
     'users' => $users,
     'can_list_users' => $can_list_users,
     'showcase_user' => '',
+    'connection_name' => $url_host !== '' ? $url_host : 'Nextcloud',
     'scan_message' => 'Nextcloud wurde erkannt und der Benutzerzugriff wurde bestätigt.',
     '_password' => $password,
+    'api_status' => 'pending',
+    'api_username' => '',
+    'api_error' => '',
   );
+  bratonien_tools_nc_wizard_fill_profile($state);
   bratonien_tools_nc_wizard_store($state);
 
-  return array('message'=>'Nextcloud-Scan erfolgreich. Die erkannten Angaben können jetzt geprüft werden.');
+  return array('message'=>'Nextcloud-Scan erfolgreich. Erkannte Werte wurden übernommen; fehlende Angaben werden jetzt gezielt abgefragt.');
+}
+
+function bratonien_tools_nc_wizard_save_technical()
+{
+  $state = bratonien_tools_nc_wizard_state();
+  if (empty($state['scan_ok']))
+  {
+    throw new RuntimeException('Bitte zuerst Nextcloud erfolgreich scannen.');
+  }
+
+  $state['connection_name'] = trim((string)($_POST['nc_wizard_connection_name'] ?? $state['connection_name']));
+  $state['db_host'] = trim((string)($_POST['nc_wizard_db_host'] ?? $state['db_host']));
+  $state['db_port'] = (string)max(1, min(65535, (int)($_POST['nc_wizard_db_port'] ?? $state['db_port'])));
+  $state['db_database'] = trim((string)($_POST['nc_wizard_db_database'] ?? $state['db_database']));
+  $state['db_user'] = trim((string)($_POST['nc_wizard_db_user'] ?? $state['db_user']));
+  $db_password = (string)($_POST['nc_wizard_db_password'] ?? '');
+  if ($db_password !== '')
+  {
+    $state['_db_password'] = $db_password;
+    $state['db_password_set'] = true;
+  }
+
+  if ($state['connection_name'] === '' || $state['db_host'] === '' || $state['db_database'] === '' || $state['db_user'] === '' || empty($state['db_password_set']))
+  {
+    bratonien_tools_nc_wizard_store($state);
+    throw new RuntimeException('Die noch fehlenden Datenbankangaben müssen vollständig angegeben werden.');
+  }
+
+  $config = array(
+    'host'=>$state['db_host'],
+    'port'=>$state['db_port'],
+    'database'=>$state['db_database'],
+    'user'=>$state['db_user'],
+  );
+  $password = (string)($state['_db_password'] ?? '');
+  bratonien_tools_nc_connector_psql($config, $password, 'SELECT 1');
+
+  $source_view = bratonien_tools_nc_connector_view_name($state['source_view']);
+  $activity_view = bratonien_tools_nc_connector_view_name($state['activity_view']);
+  bratonien_tools_nc_connector_psql($config, $password, 'SELECT COUNT(*) FROM '.$source_view);
+  bratonien_tools_nc_connector_psql($config, $password, 'SELECT 1 FROM '.$activity_view.' LIMIT 1');
+
+  $rows = bratonien_tools_nc_connector_psql(
+    $config,
+    $password,
+    "SELECT DISTINCT storage_id::text || E'\\t' || source_path FROM ".$source_view." ORDER BY 1"
+  );
+  $candidates = array();
+  foreach (preg_split('/\r\n|\r|\n/', trim($rows)) as $line)
+  {
+    if ($line === '') continue;
+    $parts = explode("\t", $line, 2);
+    if (count($parts) !== 2) continue;
+    $storage_id = trim($parts[0]);
+    $source_path = trim($parts[1], '/');
+    $prefix = $source_path;
+    if (strpos($source_path, '/') !== false)
+    {
+      $prefix = substr($source_path, 0, strpos($source_path, '/'));
+    }
+    if ($storage_id === '') continue;
+    if (!isset($candidates[$storage_id]))
+    {
+      $candidates[$storage_id] = array('storage_id'=>$storage_id, 'source_prefix'=>$prefix, 'local_mount'=>'');
+    }
+  }
+
+  if (!$candidates)
+  {
+    throw new RuntimeException('Die Source-View ist erreichbar, liefert aber keine Storage-Zuordnung.');
+  }
+
+  $known = array();
+  foreach (bratonien_tools_nc_connector_connections() as $connection)
+  {
+    foreach (($connection['config']['storages'] ?? array()) as $storage)
+    {
+      $key = (string)($storage['storage_id'] ?? '').'|'.(string)($storage['source_prefix'] ?? '');
+      if ($key !== '|') $known[$key] = (string)($storage['local_mount'] ?? '');
+    }
+  }
+  foreach ($candidates as &$candidate)
+  {
+    $key = $candidate['storage_id'].'|'.$candidate['source_prefix'];
+    if (!empty($known[$key]))
+    {
+      $candidate['local_mount'] = $known[$key];
+    }
+  }
+  unset($candidate);
+
+  $state['storage_candidates'] = array_values($candidates);
+  $state['storages'] = array_values(array_filter($state['storage_candidates'], function($storage)
+  {
+    return trim((string)($storage['local_mount'] ?? '')) !== '';
+  }));
+  $state['technical_source'] = 'Datenbank und Views erfolgreich geprüft';
+  $state['technical_complete'] = count($state['storages']) === count($state['storage_candidates']);
+  bratonien_tools_nc_wizard_store($state);
+
+  return array('message'=>$state['technical_complete']
+    ? 'Technische Verbindung wurde automatisch vervollständigt.'
+    : 'Datenbank und Views wurden erkannt. Für nicht erkannte Storages wird nur noch der lokale Mount abgefragt.');
+}
+
+function bratonien_tools_nc_wizard_save_mounts()
+{
+  $state = bratonien_tools_nc_wizard_state();
+  $candidates = isset($state['storage_candidates']) && is_array($state['storage_candidates']) ? $state['storage_candidates'] : array();
+  $mounts = isset($_POST['nc_wizard_storage_mount']) && is_array($_POST['nc_wizard_storage_mount']) ? $_POST['nc_wizard_storage_mount'] : array();
+  if (!$candidates)
+  {
+    throw new RuntimeException('Es wurden noch keine Storages erkannt.');
+  }
+
+  $storages = array();
+  foreach ($candidates as $index => $candidate)
+  {
+    $mount = trim((string)($candidate['local_mount'] ?? ''));
+    if ($mount === '')
+    {
+      $mount = trim((string)($mounts[$index] ?? ''));
+    }
+    if ($mount === '' || $mount[0] !== '/')
+    {
+      throw new RuntimeException('Für Storage '.(string)$candidate['storage_id'].' fehlt ein absoluter lokaler Mount-Pfad.');
+    }
+    $mount = rtrim($mount, '/');
+    if (!is_dir($mount) || !is_readable($mount))
+    {
+      throw new RuntimeException('Storage-Mount '.$mount.' ist nicht vorhanden oder nicht lesbar.');
+    }
+    $candidate['local_mount'] = $mount;
+    $storages[] = $candidate;
+  }
+
+  $state['storages'] = $storages;
+  $state['storage_candidates'] = $storages;
+  $state['technical_complete'] = true;
+  bratonien_tools_nc_wizard_store($state);
+  return array('message'=>'Storage-Zuordnung ist vollständig.');
 }
 
 function bratonien_tools_nc_wizard_select_user()
@@ -225,18 +456,151 @@ function bratonien_tools_nc_wizard_select_user()
   {
     throw new RuntimeException('Bitte zuerst Nextcloud erfolgreich scannen.');
   }
+  if (empty($state['technical_complete']))
+  {
+    throw new RuntimeException('Die automatische technische Erkennung ist noch nicht vollständig. Bitte nur die noch fehlenden Angaben ergänzen.');
+  }
 
   $showcase_user = trim((string)($_POST['nc_wizard_showcase_user'] ?? ''));
   if ($showcase_user === '')
   {
     throw new RuntimeException('Bitte einen Nextcloud-Benutzer für die Showcase-Freigaben auswählen.');
   }
+  $connection_name = trim((string)($_POST['nc_wizard_connection_name'] ?? $state['connection_name']));
+  if ($connection_name === '')
+  {
+    throw new RuntimeException('Bitte einen Namen für die Verbindung angeben.');
+  }
 
+  $state['connection_name'] = $connection_name;
   $state['showcase_user'] = $showcase_user;
   $state['step'] = 3;
+  $state['api_error'] = '';
   bratonien_tools_nc_wizard_store($state);
 
-  return array('message'=>'Showcase-Benutzer übernommen. Als Nächstes wird der Piwigo-API-Zugang geprüft.');
+  return array('message'=>'Showcase-Benutzer übernommen. Jetzt folgt der Piwigo-API-Zugang.');
+}
+
+function bratonien_tools_nc_wizard_api_test()
+{
+  $state = bratonien_tools_nc_wizard_state();
+  if ((int)$state['step'] !== 3)
+  {
+    throw new RuntimeException('Der API-Test ist in diesem Assistentenschritt nicht verfügbar.');
+  }
+
+  $key_id = trim((string)($_POST['nc_wizard_api_key_id'] ?? ''));
+  $secret = trim((string)($_POST['nc_wizard_api_key_secret'] ?? ''));
+  if ($key_id === '' && $secret === '')
+  {
+    $stored = bratonien_tools_nc_api_credentials();
+    $key_id = trim((string)($stored['key_id'] ?? ''));
+    $secret = trim((string)($stored['key_secret'] ?? ''));
+  }
+  if ($key_id === '' || $secret === '')
+  {
+    throw new RuntimeException('API-Schlüssel-ID und API-Geheimnis fehlen.');
+  }
+
+  try
+  {
+    $status = bratonien_tools_nc_connector_piwigo_api_request($key_id, $secret, 'pwg.session.getStatus');
+    $user_status = strtolower((string)($status['status'] ?? ''));
+    if (!in_array($user_status, array('admin','webmaster'), true))
+    {
+      throw new RuntimeException('Der API-Key gehört keinem Piwigo-Administrator/Webmaster.');
+    }
+
+    $method_result = bratonien_tools_nc_connector_piwigo_api_request($key_id, $secret, 'reflection.getMethodList');
+    $method_map = array();
+    bratonien_tools_nc_connector_collect_method_names($method_result, $method_map);
+    $missing = array_values(array_diff(array('bratonien.nc.syncProductive','bratonien.nc.syncOrphans'), array_keys($method_map)));
+    if ($missing)
+    {
+      throw new RuntimeException('Benötigte Bratonien-Sync-Methoden fehlen: '.implode(', ', $missing).'.');
+    }
+
+    bratonien_tools_nc_api_credentials_store($key_id, $secret);
+    $state['api_status'] = 'ok';
+    $state['api_username'] = (string)($status['username'] ?? $status['user'] ?? '');
+    $state['api_error'] = '';
+    $state['step'] = 4;
+    bratonien_tools_nc_wizard_store($state);
+    return array('message'=>'Piwigo-API erfolgreich geprüft. Zum Abschluss kann jetzt der Fallback festgelegt werden.');
+  }
+  catch (Throwable $e)
+  {
+    $state['api_status'] = 'error';
+    $state['api_error'] = $e->getMessage();
+    bratonien_tools_nc_wizard_store($state);
+    throw $e;
+  }
+}
+
+function bratonien_tools_nc_wizard_api_skip()
+{
+  $state = bratonien_tools_nc_wizard_state();
+  if ((int)$state['step'] !== 3)
+  {
+    throw new RuntimeException('Die API kann in diesem Assistentenschritt nicht übersprungen werden.');
+  }
+  $state['api_status'] = 'skipped';
+  $state['api_error'] = '';
+  $state['step'] = 4;
+  bratonien_tools_nc_wizard_store($state);
+  return array('message'=>'Piwigo-API wurde übersprungen. Für diese Verbindung ist deshalb ein Fallback-Zugang erforderlich.');
+}
+
+function bratonien_tools_nc_wizard_finish()
+{
+  $state = bratonien_tools_nc_wizard_state();
+  if ((int)$state['step'] !== 4 || empty($state['technical_complete']) || trim((string)$state['showcase_user']) === '')
+  {
+    throw new RuntimeException('Der Assistent ist noch nicht vollständig.');
+  }
+
+  $fallback_user = trim((string)($_POST['nc_wizard_fallback_user'] ?? ''));
+  $fallback_password = (string)($_POST['nc_wizard_fallback_password'] ?? '');
+  if (($fallback_user === '') !== ($fallback_password === ''))
+  {
+    throw new RuntimeException('Fallback-Benutzer und Fallback-Passwort müssen entweder beide angegeben oder beide leer gelassen werden.');
+  }
+  if ($state['api_status'] !== 'ok' && $fallback_user === '')
+  {
+    throw new RuntimeException('Da die Piwigo-API übersprungen wurde, ist ein Fallback-Zugang erforderlich.');
+  }
+
+  $storage_lines = array();
+  foreach ($state['storages'] as $storage)
+  {
+    $storage_lines[] = (string)$storage['storage_id'].' | '.(string)$storage['source_prefix'].' | '.(string)$storage['local_mount'];
+  }
+
+  $_POST['nc_name'] = (string)$state['connection_name'];
+  $_POST['nc_host'] = (string)$state['db_host'];
+  $_POST['nc_port'] = (string)$state['db_port'];
+  $_POST['nc_database'] = (string)$state['db_database'];
+  $_POST['nc_user'] = (string)$state['db_user'];
+  $_POST['nc_db_password'] = (string)($state['_db_password'] ?? '');
+  $_POST['nc_source_view'] = (string)$state['source_view'];
+  $_POST['nc_activity_view'] = (string)$state['activity_view'];
+  $_POST['nc_gallery_root'] = (string)$state['gallery_root'];
+  $_POST['nc_storages'] = implode("\n", $storage_lines);
+  $_POST['nc_quiet_seconds'] = '120';
+  $_POST['nc_max_wait_seconds'] = '900';
+  $_POST['nc_full_sync_seconds'] = '86400';
+  $_POST['nc_piwigo_user'] = $fallback_user;
+  $_POST['nc_piwigo_password'] = $fallback_password;
+  $_POST['nc_nextcloud_url'] = (string)$state['base_url'];
+  $_POST['nc_showcase_user'] = (string)$state['showcase_user'];
+  $_POST['nc_access_user'] = (string)$state['username'];
+  $_POST['nc_product'] = (string)$state['product'];
+  $_POST['nc_version'] = (string)$state['version'];
+
+  $result = bratonien_tools_nc_connector_create_local_api_first();
+  unset($_SESSION['bratonien_nc_wizard']);
+  $result['message'] = 'Verbindung wurde vollständig durch den Assistenten angelegt. '.$result['message'];
+  return $result;
 }
 
 function bratonien_tools_nc_connector_update_name()