spip / SPIP

ecrire/base/abstract_sql.php

Indentation +687 added lines, -687 removed lines

@@ -24,7 +24,7 @@ 
  */
 
 if (!defined('_ECRIRE_INC_VERSION')) {
-	return;
+    return;
 }
 
 /** Version de l'API SQL */
@@ -44,37 +44,37 @@ 
  *     contexte de l'erreur
  **/
 function sql_error_backtrace($compil_info = false) {
-	$trace = debug_backtrace();
-	$caller = array_shift($trace);
-	while (count($trace) && (empty($trace[0]['file']) || $trace[0]['file'] === $caller['file'] || $trace[0]['file'] === __FILE__)) {
-		array_shift($trace);
-	}
-
-	if ($compil_info) {
-		return [
-			$trace[0]['file'],// sourcefile
-			'', //nom
-			(isset($trace[1]) ? $trace[1]['function'] . "(){\n" : '')
-			. $trace[0]['function'] . '();'
-			. (isset($trace[1]) ? "\n}" : ''), //id_boucle
-			$trace[0]['line'], // ligne
-			$GLOBALS['spip_lang'], // lang
-		];
-	}
-
-	$message = count($trace) ? $trace[0]['file'] . ' L' . $trace[0]['line'] : '';
-	$f = [];
-	while (count($trace) && ($t = array_shift($trace))) {
-		if (in_array($t['function'], ['include_once', 'include_spip', 'find_in_path'])) {
-			break;
-		}
-		$f[] = $t['function'];
-	}
-	if ($f !== []) {
-		$message .= ' [' . implode('(),', $f) . '()]';
-	}
-
-	return $message;
+    $trace = debug_backtrace();
+    $caller = array_shift($trace);
+    while (count($trace) && (empty($trace[0]['file']) || $trace[0]['file'] === $caller['file'] || $trace[0]['file'] === __FILE__)) {
+        array_shift($trace);
+    }
+
+    if ($compil_info) {
+        return [
+            $trace[0]['file'],// sourcefile
+            '', //nom
+            (isset($trace[1]) ? $trace[1]['function'] . "(){\n" : '')
+            . $trace[0]['function'] . '();'
+            . (isset($trace[1]) ? "\n}" : ''), //id_boucle
+            $trace[0]['line'], // ligne
+            $GLOBALS['spip_lang'], // lang
+        ];
+    }
+
+    $message = count($trace) ? $trace[0]['file'] . ' L' . $trace[0]['line'] : '';
+    $f = [];
+    while (count($trace) && ($t = array_shift($trace))) {
+        if (in_array($t['function'], ['include_once', 'include_spip', 'find_in_path'])) {
+            break;
+        }
+        $f[] = $t['function'];
+    }
+    if ($f !== []) {
+        $message .= ' [' . implode('(),', $f) . '()]';
+    }
+
+    return $message;
 }
 
 
@@ -99,16 +99,16 @@ 
  *
  **/
 function sql_serveur($ins_sql = '', $serveur = '', $continue = false) {
-	static $sql_serveur = [];
-	if (!isset($sql_serveur[$serveur][$ins_sql])) {
-		$f = spip_connect_sql(\SQL_ABSTRACT_VERSION, $ins_sql, $serveur, $continue);
-		if (!is_string($f) || !$f) {
-			return $f;
-		}
-		$sql_serveur[$serveur][$ins_sql] = $f;
-	}
-
-	return $sql_serveur[$serveur][$ins_sql];
+    static $sql_serveur = [];
+    if (!isset($sql_serveur[$serveur][$ins_sql])) {
+        $f = spip_connect_sql(\SQL_ABSTRACT_VERSION, $ins_sql, $serveur, $continue);
+        if (!is_string($f) || !$f) {
+            return $f;
+        }
+        $sql_serveur[$serveur][$ins_sql] = $f;
+    }
+
+    return $sql_serveur[$serveur][$ins_sql];
 }
 
 /**
@@ -130,22 +130,22 @@ 
  *     Retourne le nom du charset si effectivement trouvé, sinon false.
  **/
 function sql_get_charset($charset, $serveur = '', $option = true) {
-	// le nom http du charset differe parfois du nom SQL utf-8 ==> utf8 etc.
-	$desc = sql_serveur('', $serveur, true);
-	$desc = $desc[\SQL_ABSTRACT_VERSION];
-	$c = $desc['charsets'][$charset];
-	if (
-		$c
-		&& function_exists($f = @$desc['get_charset'])
-		&& $f($c, $serveur, $option)
-	) {
-		return $c;
-	}
-	spip_logger()->warning(
-		"SPIP ne connait pas les Charsets disponibles sur le serveur $serveur. Le serveur choisira seul."
-	);
-
-	return false;
+    // le nom http du charset differe parfois du nom SQL utf-8 ==> utf8 etc.
+    $desc = sql_serveur('', $serveur, true);
+    $desc = $desc[\SQL_ABSTRACT_VERSION];
+    $c = $desc['charsets'][$charset];
+    if (
+        $c
+        && function_exists($f = @$desc['get_charset'])
+        && $f($c, $serveur, $option)
+    ) {
+        return $c;
+    }
+    spip_logger()->warning(
+        "SPIP ne connait pas les Charsets disponibles sur le serveur $serveur. Le serveur choisira seul."
+    );
+
+    return false;
 }
 
 
@@ -171,12 +171,12 @@ 
  *    Retourne true si elle reussie.
  **/
 function sql_set_charset($charset, $serveur = '', $option = true) {
-	$f = sql_serveur('set_charset', $serveur, $option === 'continue' || $option === false);
-	if (!is_string($f) || !$f) {
-		return false;
-	}
+    $f = sql_serveur('set_charset', $serveur, $option === 'continue' || $option === false);
+    if (!is_string($f) || !$f) {
+        return false;
+    }
 
-	return $f($charset, $serveur, $option !== false);
+    return $f($charset, $serveur, $option !== false);
 }
 
 
@@ -227,59 +227,59 @@ 
  *
  **/
 function sql_select(
-	$select = [],
-	$from = [],
-	$where = [],
-	$groupby = [],
-	$orderby = [],
-	$limit = '',
-	$having = [],
-	$serveur = '',
-	$option = true
+    $select = [],
+    $from = [],
+    $where = [],
+    $groupby = [],
+    $orderby = [],
+    $limit = '',
+    $having = [],
+    $serveur = '',
+    $option = true
 ) {
-	$f = sql_serveur('select', $serveur, $option === 'continue' || $option === false);
-	if (!is_string($f) || !$f) {
-		return false;
-	}
-
-	$debug = (defined('_VAR_MODE') && _VAR_MODE == 'debug');
-	if ($option !== false && !$debug) {
-		$res = $f(
-			$select,
-			$from,
-			$where,
-			$groupby,
-			$orderby,
-			$limit,
-			$having,
-			$serveur,
-			is_array($option) ? true : $option
-		);
-	} else {
-		$query = $f($select, $from, $where, $groupby, $orderby, $limit, $having, $serveur, false);
-		if (!$option) {
-			return $query;
-		}
-		// le debug, c'est pour ce qui a ete produit par le compilateur
-		if (isset($GLOBALS['debug']['aucasou'])) {
-			[$table, $id, ] = $GLOBALS['debug']['aucasou'];
-			$nom = $GLOBALS['debug_objets']['courant'] . $id;
-			$GLOBALS['debug_objets']['requete'][$nom] = $query;
-		}
-		$res = $f($select, $from, $where, $groupby, $orderby, $limit, $having, $serveur, true);
-	}
-
-	// en cas d'erreur
-	if (!is_string($res)) {
-		return $res;
-	}
-	// denoncer l'erreur SQL dans sa version brute
-	spip_sql_erreur($serveur);
-	// idem dans sa version squelette (prefixe des tables non substitue)
-	$contexte_compil = sql_error_backtrace(true);
-	erreur_squelette([sql_errno($serveur), sql_error($serveur), $res], $contexte_compil);
-
-	return false;
+    $f = sql_serveur('select', $serveur, $option === 'continue' || $option === false);
+    if (!is_string($f) || !$f) {
+        return false;
+    }
+
+    $debug = (defined('_VAR_MODE') && _VAR_MODE == 'debug');
+    if ($option !== false && !$debug) {
+        $res = $f(
+            $select,
+            $from,
+            $where,
+            $groupby,
+            $orderby,
+            $limit,
+            $having,
+            $serveur,
+            is_array($option) ? true : $option
+        );
+    } else {
+        $query = $f($select, $from, $where, $groupby, $orderby, $limit, $having, $serveur, false);
+        if (!$option) {
+            return $query;
+        }
+        // le debug, c'est pour ce qui a ete produit par le compilateur
+        if (isset($GLOBALS['debug']['aucasou'])) {
+            [$table, $id, ] = $GLOBALS['debug']['aucasou'];
+            $nom = $GLOBALS['debug_objets']['courant'] . $id;
+            $GLOBALS['debug_objets']['requete'][$nom] = $query;
+        }
+        $res = $f($select, $from, $where, $groupby, $orderby, $limit, $having, $serveur, true);
+    }
+
+    // en cas d'erreur
+    if (!is_string($res)) {
+        return $res;
+    }
+    // denoncer l'erreur SQL dans sa version brute
+    spip_sql_erreur($serveur);
+    // idem dans sa version squelette (prefixe des tables non substitue)
+    $contexte_compil = sql_error_backtrace(true);
+    erreur_squelette([sql_errno($serveur), sql_error($serveur), $res], $contexte_compil);
+
+    return false;
 }
 
 
@@ -316,16 +316,16 @@ 
  *
  **/
 function sql_get_select(
-	$select = [],
-	$from = [],
-	$where = [],
-	$groupby = [],
-	$orderby = [],
-	$limit = '',
-	$having = [],
-	$serveur = ''
+    $select = [],
+    $from = [],
+    $where = [],
+    $groupby = [],
+    $orderby = [],
+    $limit = '',
+    $having = [],
+    $serveur = ''
 ) {
-	return sql_select($select, $from, $where, $groupby, $orderby, $limit, $having, $serveur, false);
+    return sql_select($select, $from, $where, $groupby, $orderby, $limit, $having, $serveur, false);
 }
 
 
@@ -369,23 +369,23 @@ 
  *
  **/
 function sql_countsel(
-	$from = [],
-	$where = [],
-	$groupby = [],
-	$having = [],
-	$serveur = '',
-	$option = true
+    $from = [],
+    $where = [],
+    $groupby = [],
+    $having = [],
+    $serveur = '',
+    $option = true
 ) {
-	$f = sql_serveur('countsel', $serveur, $option === 'continue' || $option === false);
-	if (!is_string($f) || !$f) {
-		return false;
-	}
-	$r = $f($from, $where, $groupby, $having, $serveur, $option !== false);
-	if ($r === false) {
-		spip_sql_erreur($serveur);
-	}
-
-	return $r;
+    $f = sql_serveur('countsel', $serveur, $option === 'continue' || $option === false);
+    if (!is_string($f) || !$f) {
+        return false;
+    }
+    $r = $f($from, $where, $groupby, $having, $serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 /**
@@ -417,16 +417,16 @@ 
  *     Ce retour n'est pas pertinent pour savoir si l'opération est correctement réalisée.
  **/
 function sql_alter($q, $serveur = '', $option = true) {
-	$f = sql_serveur('alter', $serveur, $option === 'continue' || $option === false);
-	if (!is_string($f) || !$f) {
-		return false;
-	}
-	$r = $f($q, $serveur, $option !== false);
-	if ($r === false) {
-		spip_sql_erreur($serveur);
-	}
-
-	return $r;
+    $f = sql_serveur('alter', $serveur, $option === 'continue' || $option === false);
+    if (!is_string($f) || !$f) {
+        return false;
+    }
+    $r = $f($q, $serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 /**
@@ -449,12 +449,12 @@ 
  *    presentant une ligne de resultat d'une selection
  */
 function sql_fetch(mixed $res, $serveur = '', $option = true) {
-	$f = sql_serveur('fetch', $serveur, $option === 'continue' || $option === false);
-	if (!is_string($f) || !$f) {
-		return false;
-	}
+    $f = sql_serveur('fetch', $serveur, $option === 'continue' || $option === false);
+    if (!is_string($f) || !$f) {
+        return false;
+    }
 
-	return $f($res, null, $serveur, $option !== false);
+    return $f($res, null, $serveur, $option !== false);
 }
 
 
@@ -481,20 +481,20 @@ 
  *    presentant une ligne de resultat d'une selection
  */
 function sql_fetch_all(mixed $res, $serveur = '', $option = true) {
-	$rows = [];
-	if (!$res) {
-		return $rows;
-	}
-	$f = sql_serveur('fetch', $serveur, $option === 'continue' || $option === false);
-	if (!is_string($f) || !$f) {
-		return [];
-	}
-	while ($r = $f($res, null, $serveur, $option !== false)) {
-		$rows[] = $r;
-	}
-	sql_free($res, $serveur);
-
-	return $rows;
+    $rows = [];
+    if (!$res) {
+        return $rows;
+    }
+    $f = sql_serveur('fetch', $serveur, $option === 'continue' || $option === false);
+    if (!is_string($f) || !$f) {
+        return [];
+    }
+    while ($r = $f($res, null, $serveur, $option !== false)) {
+        $rows[] = $r;
+    }
+    sql_free($res, $serveur);
+
+    return $rows;
 }
 
 /**
@@ -522,16 +522,16 @@ 
  *    Operation effectuée (true), sinon false.
  **/
 function sql_seek(mixed $res, $row_number, $serveur = '', $option = true) {
-	$f = sql_serveur('seek', $serveur, $option === 'continue' || $option === false);
-	if (!is_string($f) || !$f) {
-		return false;
-	}
-	$r = $f($res, $row_number, $serveur, $option !== false);
-	if ($r === false) {
-		spip_sql_erreur($serveur);
-	}
-
-	return $r;
+    $f = sql_serveur('seek', $serveur, $option === 'continue' || $option === false);
+    if (!is_string($f) || !$f) {
+        return false;
+    }
+    $r = $f($res, $row_number, $serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 
@@ -556,16 +556,16 @@ 
  *    False en cas d'erreur.
  **/
 function sql_listdbs($serveur = '', $option = true) {
-	$f = sql_serveur('listdbs', $serveur, $option === 'continue' || $option === false);
-	if (!is_string($f) || !$f) {
-		return false;
-	}
-	$r = $f($serveur);
-	if ($r === false) {
-		spip_sql_erreur($serveur);
-	}
-
-	return $r;
+    $f = sql_serveur('listdbs', $serveur, $option === 'continue' || $option === false);
+    if (!is_string($f) || !$f) {
+        return false;
+    }
+    $r = $f($serveur);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 
@@ -588,16 +588,16 @@ 
  *     - False en cas d'erreur.
  **/
 function sql_selectdb($nom, $serveur = '', $option = true) {
-	$f = sql_serveur('selectdb', $serveur, $option === 'continue' || $option === false);
-	if (!is_string($f) || !$f) {
-		return false;
-	}
-	$r = $f($nom, $serveur, $option !== false);
-	if ($r === false) {
-		spip_sql_erreur($serveur);
-	}
-
-	return $r;
+    $f = sql_serveur('selectdb', $serveur, $option === 'continue' || $option === false);
+    if (!is_string($f) || !$f) {
+        return false;
+    }
+    $r = $f($nom, $serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 /**
@@ -622,16 +622,16 @@ 
  *     - false en cas d'erreur.
  **/
 function sql_count($res, $serveur = '', $option = true) {
-	$f = sql_serveur('count', $serveur, $option === 'continue' || $option === false);
-	if (!is_string($f) || !$f) {
-		return false;
-	}
-	$r = $f($res, $serveur, $option !== false);
-	if ($r === false) {
-		spip_sql_erreur($serveur);
-	}
-
-	return $r;
+    $f = sql_serveur('count', $serveur, $option === 'continue' || $option === false);
+    if (!is_string($f) || !$f) {
+        return false;
+    }
+    $r = $f($res, $serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 /**
@@ -653,12 +653,12 @@ 
  *     True si réussi
  */
 function sql_free($res, $serveur = '', $option = true) {
-	$f = sql_serveur('free', $serveur, $option === 'continue' || $option === false);
-	if (!is_string($f) || !$f) {
-		return false;
-	}
+    $f = sql_serveur('free', $serveur, $option === 'continue' || $option === false);
+    if (!is_string($f) || !$f) {
+        return false;
+    }
 
-	return $f($res);
+    return $f($res);
 }
 
 
@@ -696,17 +696,17 @@ 
  *     - False en cas d'erreur.
  **/
 function sql_insert($table, $noms, $valeurs, $desc = [], $serveur = '', $option = true) {
-	$f = sql_serveur('insert', $serveur, $option === 'continue' || $option === false);
-	if (!is_string($f) || !$f) {
-		return false;
-	}
-	$r = $f($table, $noms, $valeurs, $desc, $serveur, $option !== false);
-	if ($r === false || $r === null) {
-		spip_sql_erreur($serveur);
-		$r = false;
-	}
-
-	return $r;
+    $f = sql_serveur('insert', $serveur, $option === 'continue' || $option === false);
+    if (!is_string($f) || !$f) {
+        return false;
+    }
+    $r = $f($table, $noms, $valeurs, $desc, $serveur, $option !== false);
+    if ($r === false || $r === null) {
+        spip_sql_erreur($serveur);
+        $r = false;
+    }
+
+    return $r;
 }
 
 /**
@@ -747,17 +747,17 @@ 
  *     - False en cas d'erreur.
  **/
 function sql_insertq($table, $couples = [], $desc = [], $serveur = '', $option = true) {
-	$f = sql_serveur('insertq', $serveur, $option === 'continue' || $option === false);
-	if (!is_string($f) || !$f) {
-		return false;
-	}
-	$r = $f($table, $couples, $desc, $serveur, $option !== false);
-	if ($r === false || $r === null) {
-		spip_sql_erreur($serveur);
-		$r = false;
-	}
-
-	return $r;
+    $f = sql_serveur('insertq', $serveur, $option === 'continue' || $option === false);
+    if (!is_string($f) || !$f) {
+        return false;
+    }
+    $r = $f($table, $couples, $desc, $serveur, $option !== false);
+    if ($r === false || $r === null) {
+        spip_sql_erreur($serveur);
+        $r = false;
+    }
+
+    return $r;
 }
 
 /**
@@ -792,17 +792,17 @@ 
  *     - false en cas d'erreur.
  **/
 function sql_insertq_multi($table, $couples = [], $desc = [], $serveur = '', $option = true) {
-	$f = sql_serveur('insertq_multi', $serveur, $option === 'continue' || $option === false);
-	if (!is_string($f) || !$f) {
-		return false;
-	}
-	$r = $f($table, $couples, $desc, $serveur, $option !== false);
-	if ($r === false || $r === null) {
-		spip_sql_erreur($serveur);
-		$r = false;
-	}
-
-	return $r;
+    $f = sql_serveur('insertq_multi', $serveur, $option === 'continue' || $option === false);
+    if (!is_string($f) || !$f) {
+        return false;
+    }
+    $r = $f($table, $couples, $desc, $serveur, $option !== false);
+    if ($r === false || $r === null) {
+        spip_sql_erreur($serveur);
+        $r = false;
+    }
+
+    return $r;
 }
 
 /**
@@ -842,16 +842,16 @@ 
  *     - array Tableau décrivant la requête et son temps d'exécution si var_profile est actif
  */
 function sql_update($table, $exp, $where = '', $desc = [], $serveur = '', $option = true) {
-	$f = sql_serveur('update', $serveur, $option === 'continue' || $option === false);
-	if (!is_string($f) || !$f) {
-		return false;
-	}
-	$r = $f($table, $exp, $where, $desc, $serveur, $option !== false);
-	if ($r === false) {
-		spip_sql_erreur($serveur);
-	}
-
-	return $r;
+    $f = sql_serveur('update', $serveur, $option === 'continue' || $option === false);
+    if (!is_string($f) || !$f) {
+        return false;
+    }
+    $r = $f($table, $exp, $where, $desc, $serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 
@@ -897,16 +897,16 @@ 
  *     - false en cas d'erreur.
  **/
 function sql_updateq($table, $exp, $where = '', $desc = [], $serveur = '', $option = true) {
-	$f = sql_serveur('updateq', $serveur, $option === 'continue' || $option === false);
-	if (!is_string($f) || !$f) {
-		return false;
-	}
-	$r = $f($table, $exp, $where, $desc, $serveur, $option !== false);
-	if ($r === false) {
-		spip_sql_erreur($serveur);
-	}
-
-	return $r;
+    $f = sql_serveur('updateq', $serveur, $option === 'continue' || $option === false);
+    if (!is_string($f) || !$f) {
+        return false;
+    }
+    $r = $f($table, $exp, $where, $desc, $serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 /**
@@ -937,16 +937,16 @@ 
  *     - false en cas d'erreur.
  **/
 function sql_delete($table, $where = '', $serveur = '', $option = true) {
-	$f = sql_serveur('delete', $serveur, $option === 'continue' || $option === false);
-	if (!is_string($f) || !$f) {
-		return false;
-	}
-	$r = $f($table, $where, $serveur, $option !== false);
-	if ($r === false) {
-		spip_sql_erreur($serveur);
-	}
-
-	return $r;
+    $f = sql_serveur('delete', $serveur, $option === 'continue' || $option === false);
+    if (!is_string($f) || !$f) {
+        return false;
+    }
+    $r = $f($table, $where, $serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 /**
@@ -982,16 +982,16 @@ 
  *     - false en cas d'erreur.
  **/
 function sql_replace($table, $couples, $desc = [], $serveur = '', $option = true) {
-	$f = sql_serveur('replace', $serveur, $option === 'continue' || $option === false);
-	if (!is_string($f) || !$f) {
-		return false;
-	}
-	$r = $f($table, $couples, $desc, $serveur, $option !== false);
-	if ($r === false) {
-		spip_sql_erreur($serveur);
-	}
-
-	return $r;
+    $f = sql_serveur('replace', $serveur, $option === 'continue' || $option === false);
+    if (!is_string($f) || !$f) {
+        return false;
+    }
+    $r = $f($table, $couples, $desc, $serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 
@@ -1029,16 +1029,16 @@ 
  *     - false en cas d'erreur.
  **/
 function sql_replace_multi($table, $tab_couples, $desc = [], $serveur = '', $option = true) {
-	$f = sql_serveur('replace_multi', $serveur, $option === 'continue' || $option === false);
-	if (!is_string($f) || !$f) {
-		return false;
-	}
-	$r = $f($table, $tab_couples, $desc, $serveur, $option !== false);
-	if ($r === false) {
-		spip_sql_erreur($serveur);
-	}
-
-	return $r;
+    $f = sql_serveur('replace_multi', $serveur, $option === 'continue' || $option === false);
+    if (!is_string($f) || !$f) {
+        return false;
+    }
+    $r = $f($table, $tab_couples, $desc, $serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 /**
@@ -1066,16 +1066,16 @@ 
  *     - false en cas d'erreur.
  **/
 function sql_drop_table($table, $exist = false, $serveur = '', $option = true) {
-	$f = sql_serveur('drop_table', $serveur, $option === 'continue' || $option === false);
-	if (!is_string($f) || !$f) {
-		return false;
-	}
-	$r = $f($table, $exist, $serveur, $option !== false);
-	if ($r === false) {
-		spip_sql_erreur($serveur);
-	}
-
-	return $r;
+    $f = sql_serveur('drop_table', $serveur, $option === 'continue' || $option === false);
+    if (!is_string($f) || !$f) {
+        return false;
+    }
+    $r = $f($table, $exist, $serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 /**
@@ -1099,16 +1099,16 @@ 
  *     - true si la requête a réussie, false sinon
  */
 function sql_drop_view($table, $exist = false, $serveur = '', $option = true) {
-	$f = sql_serveur('drop_view', $serveur, $option === 'continue' || $option === false);
-	if (!is_string($f) || !$f) {
-		return false;
-	}
-	$r = $f($table, $exist, $serveur, $option !== false);
-	if ($r === false) {
-		spip_sql_erreur($serveur);
-	}
-
-	return $r;
+    $f = sql_serveur('drop_view', $serveur, $option === 'continue' || $option === false);
+    if (!is_string($f) || !$f) {
+        return false;
+    }
+    $r = $f($table, $exist, $serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 /**
@@ -1132,18 +1132,18 @@ 
  *     Ressource à utiliser avec sql_fetch()
  **/
 function sql_showbase($spip = null, $serveur = '', $option = true) {
-	$f = sql_serveur('showbase', $serveur, $option === 'continue' || $option === false);
-	if (!is_string($f) || !$f) {
-		return false;
-	}
-
-	// la globale n'est remplie qu'apres l'appel de sql_serveur.
-	if ($spip == null) {
-		$connexion = $GLOBALS['connexions'][$serveur ? strtolower($serveur) : 0];
-		$spip = $connexion['prefixe'] . '\_%';
-	}
-
-	return $f($spip, $serveur, $option !== false);
+    $f = sql_serveur('showbase', $serveur, $option === 'continue' || $option === false);
+    if (!is_string($f) || !$f) {
+        return false;
+    }
+
+    // la globale n'est remplie qu'apres l'appel de sql_serveur.
+    if ($spip == null) {
+        $connexion = $GLOBALS['connexions'][$serveur ? strtolower($serveur) : 0];
+        $spip = $connexion['prefixe'] . '\_%';
+    }
+
+    return $f($spip, $serveur, $option !== false);
 }
 
 /**
@@ -1166,15 +1166,15 @@ 
  *     Liste des tables SQL
  **/
 function sql_alltable($spip = null, $serveur = '', $option = true) {
-	$q = sql_showbase($spip, $serveur, $option);
-	$r = [];
-	if ($q) {
-		while ($t = sql_fetch($q, $serveur)) {
-			$r[] = array_shift($t);
-		}
-	}
-
-	return $r;
+    $q = sql_showbase($spip, $serveur, $option);
+    $r = [];
+    if ($q) {
+        while ($t = sql_fetch($q, $serveur)) {
+            $r[] = array_shift($t);
+        }
+    }
+
+    return $r;
 }
 
 /**
@@ -1207,31 +1207,31 @@ 
  *       - 'join' => array() // jointures, si déclarées.
  **/
 function sql_showtable($table, $table_spip = false, $serveur = '', $option = true) {
-	$f = sql_serveur('showtable', $serveur, $option === 'continue' || $option === false);
-	if (!is_string($f) || !$f) {
-		return false;
-	}
-
-	// la globale n'est remplie qu'apres l'appel de sql_serveur.
-	if ($table_spip) {
-		$connexion = $GLOBALS['connexions'][$serveur ? strtolower($serveur) : 0];
-		$prefixe = $connexion['prefixe'];
-		$vraie_table = prefixer_table_spip($table, $prefixe);
-	} else {
-		$vraie_table = $table;
-	}
-
-	$f = $f($vraie_table, $serveur, $option !== false);
-	if (!$f) {
-		return [];
-	}
-	if (isset($GLOBALS['tables_principales'][$table]['join'])) {
-		$f['join'] = $GLOBALS['tables_principales'][$table]['join'];
-	} elseif (isset($GLOBALS['tables_auxiliaires'][$table]['join'])) {
-		$f['join'] = $GLOBALS['tables_auxiliaires'][$table]['join'];
-	}
-
-	return $f;
+    $f = sql_serveur('showtable', $serveur, $option === 'continue' || $option === false);
+    if (!is_string($f) || !$f) {
+        return false;
+    }
+
+    // la globale n'est remplie qu'apres l'appel de sql_serveur.
+    if ($table_spip) {
+        $connexion = $GLOBALS['connexions'][$serveur ? strtolower($serveur) : 0];
+        $prefixe = $connexion['prefixe'];
+        $vraie_table = prefixer_table_spip($table, $prefixe);
+    } else {
+        $vraie_table = $table;
+    }
+
+    $f = $f($vraie_table, $serveur, $option !== false);
+    if (!$f) {
+        return [];
+    }
+    if (isset($GLOBALS['tables_principales'][$table]['join'])) {
+        $f['join'] = $GLOBALS['tables_principales'][$table]['join'];
+    } elseif (isset($GLOBALS['tables_auxiliaires'][$table]['join'])) {
+        $f['join'] = $GLOBALS['tables_auxiliaires'][$table]['join'];
+    }
+
+    return $f;
 }
 
 
@@ -1258,21 +1258,21 @@ 
  *     - false en cas d'erreur.
  **/
 function sql_table_exists(string $table, bool $table_spip = true, $serveur = '', $option = true) {
-	$f = sql_serveur('table_exists', $serveur, $option === 'continue' || $option === false);
-	if (!is_string($f) || !$f) {
-		return false;
-	}
-
-	// la globale n'est remplie qu'apres l'appel de sql_serveur.
-	if ($table_spip) {
-		$connexion = $GLOBALS['connexions'][$serveur ? strtolower($serveur) : 0];
-		$prefixe = $connexion['prefixe'];
-		$vraie_table = prefixer_table_spip($table, $prefixe);
-	} else {
-		$vraie_table = $table;
-	}
-
-	return $f($vraie_table, $serveur, $option !== false);
+    $f = sql_serveur('table_exists', $serveur, $option === 'continue' || $option === false);
+    if (!is_string($f) || !$f) {
+        return false;
+    }
+
+    // la globale n'est remplie qu'apres l'appel de sql_serveur.
+    if ($table_spip) {
+        $connexion = $GLOBALS['connexions'][$serveur ? strtolower($serveur) : 0];
+        $prefixe = $connexion['prefixe'];
+        $vraie_table = prefixer_table_spip($table, $prefixe);
+    } else {
+        $vraie_table = $table;
+    }
+
+    return $f($vraie_table, $serveur, $option !== false);
 }
 
 
@@ -1318,24 +1318,24 @@ 
  *     true si succès, false en cas d'echec
  **/
 function sql_create(
-	$nom,
-	$champs,
-	$cles = [],
-	$autoinc = false,
-	$temporary = false,
-	$serveur = '',
-	$option = true
+    $nom,
+    $champs,
+    $cles = [],
+    $autoinc = false,
+    $temporary = false,
+    $serveur = '',
+    $option = true
 ) {
-	$f = sql_serveur('create', $serveur, $option === 'continue' || $option === false);
-	if (!is_string($f) || !$f) {
-		return false;
-	}
-	$r = $f($nom, $champs, $cles, $autoinc, $temporary, $serveur, $option !== false);
-	if ($r === false) {
-		spip_sql_erreur($serveur);
-	}
-
-	return $r;
+    $f = sql_serveur('create', $serveur, $option === 'continue' || $option === false);
+    if (!is_string($f) || !$f) {
+        return false;
+    }
+    $r = $f($nom, $champs, $cles, $autoinc, $temporary, $serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 /**
@@ -1353,16 +1353,16 @@ 
  * @return bool true si la base est créee.
  **/
 function sql_create_base($nom, $serveur = '', $option = true) {
-	$f = sql_serveur('create_base', $serveur, $option === 'continue' || $option === false);
-	if (!is_string($f) || !$f) {
-		return false;
-	}
-	$r = $f($nom, $serveur, $option !== false);
-	if ($r === false) {
-		spip_sql_erreur($serveur);
-	}
-
-	return $r;
+    $f = sql_serveur('create_base', $serveur, $option === 'continue' || $option === false);
+    if (!is_string($f) || !$f) {
+        return false;
+    }
+    $r = $f($nom, $serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 
@@ -1392,16 +1392,16 @@ 
  *     - false en cas d'échec.
  **/
 function sql_create_view($nom, $select_query, $serveur = '', $option = true) {
-	$f = sql_serveur('create_view', $serveur, $option === 'continue' || $option === false);
-	if (!is_string($f) || !$f) {
-		return false;
-	}
-	$r = $f($nom, $select_query, $serveur, $option !== false);
-	if ($r === false) {
-		spip_sql_erreur($serveur);
-	}
-
-	return $r;
+    $f = sql_serveur('create_view', $serveur, $option === 'continue' || $option === false);
+    if (!is_string($f) || !$f) {
+        return false;
+    }
+    $r = $f($nom, $select_query, $serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 /**
@@ -1430,12 +1430,12 @@ 
  *     texte de sélection pour la requête
  */
 function sql_multi($sel, $lang, $serveur = '', $option = true) {
-	$f = sql_serveur('multi', $serveur, $option === 'continue' || $option === false);
-	if (!is_string($f) || !$f) {
-		return false;
-	}
+    $f = sql_serveur('multi', $serveur, $option === 'continue' || $option === false);
+    if (!is_string($f) || !$f) {
+        return false;
+    }
 
-	return $f($sel, $lang);
+    return $f($sel, $lang);
 }
 
 
@@ -1450,12 +1450,12 @@ 
  *      False si le serveur est indisponible
  */
 function sql_error($serveur = '') {
-	$f = sql_serveur('error', $serveur, true);
-	if (!is_string($f) || !$f) {
-		return false;
-	}
+    $f = sql_serveur('error', $serveur, true);
+    if (!is_string($f) || !$f) {
+        return false;
+    }
 
-	return $f('query inconnue', $serveur);
+    return $f('query inconnue', $serveur);
 }
 
 /**
@@ -1469,12 +1469,12 @@ 
  *      False si le serveur est indisponible
  */
 function sql_errno($serveur = '') {
-	$f = sql_serveur('errno', $serveur, true);
-	if (!is_string($f) || !$f) {
-		return false;
-	}
+    $f = sql_serveur('errno', $serveur, true);
+    if (!is_string($f) || !$f) {
+        return false;
+    }
 
-	return $f($serveur);
+    return $f($serveur);
 }
 
 /**
@@ -1492,16 +1492,16 @@ 
  * @return array|false   Tableau de l'explication
  */
 function sql_explain($q, $serveur = '', $option = true) {
-	$f = sql_serveur('explain', $serveur, true);
-	if (!is_string($f) || !$f) {
-		return false;
-	}
-	$r = $f($q, $serveur, $option !== false);
-	if ($r === false) {
-		spip_sql_erreur($serveur);
-	}
-
-	return $r;
+    $f = sql_serveur('explain', $serveur, true);
+    if (!is_string($f) || !$f) {
+        return false;
+    }
+    $r = $f($q, $serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 /**
@@ -1519,16 +1519,16 @@ 
  * @return bool            Toujours true
  */
 function sql_optimize($table, $serveur = '', $option = true) {
-	$f = sql_serveur('optimize', $serveur, $option === 'continue' || $option === false);
-	if (!is_string($f) || !$f) {
-		return false;
-	}
-	$r = $f($table, $serveur, $option);
-	if ($r === false) {
-		spip_sql_erreur($serveur);
-	}
-
-	return $r;
+    $f = sql_serveur('optimize', $serveur, $option === 'continue' || $option === false);
+    if (!is_string($f) || !$f) {
+        return false;
+    }
+    $r = $f($table, $serveur, $option);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 /**
@@ -1548,16 +1548,16 @@ 
  *     - true si la requête a réussie, false sinon
  */
 function sql_repair($table, $serveur = '', $option = true) {
-	$f = sql_serveur('repair', $serveur, $option === 'continue' || $option === false);
-	if (!is_string($f) || !$f) {
-		return false;
-	}
-	$r = $f($table, $serveur, $option !== false);
-	if ($r === false) {
-		spip_sql_erreur($serveur);
-	}
-
-	return $r;
+    $f = sql_serveur('repair', $serveur, $option === 'continue' || $option === false);
+    if (!is_string($f) || !$f) {
+        return false;
+    }
+    $r = $f($table, $serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 
@@ -1582,16 +1582,16 @@ 
  *     - array : Tableau décrivant requête et temps d'exécution si var_profile actif pour tracer.
  */
 function sql_query($ins, $serveur = '', $option = true) {
-	$f = sql_serveur('query', $serveur, $option === 'continue' || $option === false);
-	if (!is_string($f) || !$f) {
-		return false;
-	}
-	$r = $f($ins, $serveur, $option !== false);
-	if ($r === false) {
-		spip_sql_erreur($serveur);
-	}
-
-	return $r;
+    $f = sql_serveur('query', $serveur, $option === 'continue' || $option === false);
+    if (!is_string($f) || !$f) {
+        return false;
+    }
+    $r = $f($ins, $serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 /**
@@ -1639,27 +1639,27 @@ 
  *
  **/
 function sql_fetsel(
-	$select = [],
-	$from = [],
-	$where = [],
-	$groupby = [],
-	$orderby = [],
-	$limit = '',
-	$having = [],
-	$serveur = '',
-	$option = true
+    $select = [],
+    $from = [],
+    $where = [],
+    $groupby = [],
+    $orderby = [],
+    $limit = '',
+    $having = [],
+    $serveur = '',
+    $option = true
 ) {
-	$q = sql_select($select, $from, $where, $groupby, $orderby, $limit, $having, $serveur, $option);
-	if ($option === false) {
-		return $q;
-	}
-	if (!$q) {
-		return [];
-	}
-	$r = sql_fetch($q, $serveur, $option);
-	sql_free($q, $serveur, $option);
-
-	return $r;
+    $q = sql_select($select, $from, $where, $groupby, $orderby, $limit, $having, $serveur, $option);
+    if ($option === false) {
+        return $q;
+    }
+    if (!$q) {
+        return [];
+    }
+    $r = sql_fetch($q, $serveur, $option);
+    sql_free($q, $serveur, $option);
+
+    return $r;
 }
 
 
@@ -1716,22 +1716,22 @@ 
  *
  **/
 function sql_allfetsel(
-	$select = [],
-	$from = [],
-	$where = [],
-	$groupby = [],
-	$orderby = [],
-	$limit = '',
-	$having = [],
-	$serveur = '',
-	$option = true
+    $select = [],
+    $from = [],
+    $where = [],
+    $groupby = [],
+    $orderby = [],
+    $limit = '',
+    $having = [],
+    $serveur = '',
+    $option = true
 ) {
-	$q = sql_select($select, $from, $where, $groupby, $orderby, $limit, $having, $serveur, $option);
-	if ($option === false) {
-		return $q;
-	}
+    $q = sql_select($select, $from, $where, $groupby, $orderby, $limit, $having, $serveur, $option);
+    if ($option === false) {
+        return $q;
+    }
 
-	return sql_fetch_all($q, $serveur, $option);
+    return sql_fetch_all($q, $serveur, $option);
 }
 
 
@@ -1778,33 +1778,33 @@ 
  *
  **/
 function sql_getfetsel(
-	$select,
-	$from = [],
-	$where = [],
-	$groupby = [],
-	$orderby = [],
-	$limit = '',
-	$having = [],
-	$serveur = '',
-	$option = true
+    $select,
+    $from = [],
+    $where = [],
+    $groupby = [],
+    $orderby = [],
+    $limit = '',
+    $having = [],
+    $serveur = '',
+    $option = true
 ) {
-	if (preg_match('/\s+as\s+(\w+)$/i', $select, $c)) {
-		$id = $c[1];
-	} elseif (!preg_match('/\W/', $select)) {
-		$id = $select;
-	} else {
-		$id = 'n';
-		$select .= ' AS n';
-	}
-	$r = sql_fetsel($select, $from, $where, $groupby, $orderby, $limit, $having, $serveur, $option);
-	if ($option === false) {
-		return $r;
-	}
-	if (!$r) {
-		return null;
-	}
-
-	return $r[$id];
+    if (preg_match('/\s+as\s+(\w+)$/i', $select, $c)) {
+        $id = $c[1];
+    } elseif (!preg_match('/\W/', $select)) {
+        $id = $select;
+    } else {
+        $id = 'n';
+        $select .= ' AS n';
+    }
+    $r = sql_fetsel($select, $from, $where, $groupby, $orderby, $limit, $having, $serveur, $option);
+    if ($option === false) {
+        return $r;
+    }
+    if (!$r) {
+        return null;
+    }
+
+    return $r[$id];
 }
 
 /**
@@ -1822,9 +1822,9 @@ 
  *    Numero de version du serveur SQL
  **/
 function sql_version($serveur = '', $option = true) {
-	$row = sql_fetsel('version() AS n', '', '', '', '', '', '', $serveur);
+    $row = sql_fetsel('version() AS n', '', '', '', '', '', '', $serveur);
 
-	return ($row['n']);
+    return ($row['n']);
 }
 
 /**
@@ -1860,16 +1860,16 @@ 
  *    Le serveur SQL prefere t'il des transactions pour les insertions multiples ?
  **/
 function sql_preferer_transaction($serveur = '', $option = true) {
-	$f = sql_serveur('preferer_transaction', $serveur, true);
-	if (!is_string($f) || !$f) {
-		return false;
-	}
-	$r = $f($serveur, $option !== false);
-	if ($r === false) {
-		spip_sql_erreur($serveur);
-	}
-
-	return $r;
+    $f = sql_serveur('preferer_transaction', $serveur, true);
+    if (!is_string($f) || !$f) {
+        return false;
+    }
+    $r = $f($serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 ;
@@ -1894,16 +1894,16 @@ 
  *      false en cas d'erreur
  **/
 function sql_demarrer_transaction($serveur = '', $option = true) {
-	$f = sql_serveur('demarrer_transaction', $serveur, true);
-	if (!is_string($f) || !$f) {
-		return false;
-	}
-	$r = $f($serveur, $option !== false);
-	if ($r === false) {
-		spip_sql_erreur($serveur);
-	}
-
-	return $r;
+    $f = sql_serveur('demarrer_transaction', $serveur, true);
+    if (!is_string($f) || !$f) {
+        return false;
+    }
+    $r = $f($serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 ;
@@ -1928,16 +1928,16 @@ 
  *      false en cas d'erreur
  **/
 function sql_terminer_transaction($serveur = '', $option = true) {
-	$f = sql_serveur('terminer_transaction', $serveur, true);
-	if (!is_string($f) || !$f) {
-		return false;
-	}
-	$r = $f($serveur, $option !== false);
-	if ($r === false) {
-		spip_sql_erreur($serveur);
-	}
-
-	return $r;
+    $f = sql_serveur('terminer_transaction', $serveur, true);
+    if (!is_string($f) || !$f) {
+        return false;
+    }
+    $r = $f($serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 ;
@@ -1964,12 +1964,12 @@ 
  *     Valeur hexadécimale attendue par le serveur SQL
  **/
 function sql_hex($val, $serveur = '', $option = true) {
-	$f = sql_serveur('hex', $serveur, $option === 'continue' || $option === false);
-	if (!is_string($f) || !$f) {
-		return false;
-	}
+    $f = sql_serveur('hex', $serveur, $option === 'continue' || $option === false);
+    if (!is_string($f) || !$f) {
+        return false;
+    }
 
-	return $f($val);
+    return $f($val);
 }
 
 /**
@@ -1995,12 +1995,12 @@ 
  *     La chaine echappee
  **/
 function sql_quote($val, $serveur = '', $type = '') {
-	$f = sql_serveur('quote', $serveur, true);
-	if (!is_string($f) || !$f) {
-		$f = '_q';
-	}
+    $f = sql_serveur('quote', $serveur, true);
+    if (!is_string($f) || !$f) {
+        $f = '_q';
+    }
 
-	return $f($val, $type);
+    return $f($val, $type);
 }
 
 /**
@@ -2025,12 +2025,12 @@ 
  *     - false si le serveur SQL est indisponible
  **/
 function sql_date_proche($champ, $interval, $unite, $serveur = '', $option = true) {
-	$f = sql_serveur('date_proche', $serveur, true);
-	if (!is_string($f) || !$f) {
-		return false;
-	}
+    $f = sql_serveur('date_proche', $serveur, true);
+    if (!is_string($f) || !$f) {
+        return false;
+    }
 
-	return $f($champ, $interval, $unite);
+    return $f($champ, $interval, $unite);
 }
 
 /**
@@ -2066,26 +2066,26 @@ 
  *     Expression de requête SQL
  **/
 function sql_in_quote($champ, $valeurs, $not = '', $serveur = '', $type = '', $option = true) {
-	$quote = sql_serveur('quote', $serveur, true);
-	if (!is_string($quote) || !$quote) {
-		return false;
-	}
-
-	// sql_quote produit une chaine dans tous les cas
-	$valeurs = array_filter($valeurs, fn($v) => !is_array($v));
-	$valeurs = array_unique($valeurs);
-	$valeurs = $quote($valeurs, $type);
-
-	if (!strlen(trim((string) $valeurs))) {
-		return ($not ? '0=0' : '0=1');
-	}
-
-	$f = sql_serveur('in', $serveur, $option === 'continue' || $option === false);
-	if (!is_string($f) || !$f) {
-		return false;
-	}
-
-	return $f($champ, $valeurs, $not ? 'NOT' : '', $serveur, $option !== false);
+    $quote = sql_serveur('quote', $serveur, true);
+    if (!is_string($quote) || !$quote) {
+        return false;
+    }
+
+    // sql_quote produit une chaine dans tous les cas
+    $valeurs = array_filter($valeurs, fn($v) => !is_array($v));
+    $valeurs = array_unique($valeurs);
+    $valeurs = $quote($valeurs, $type);
+
+    if (!strlen(trim((string) $valeurs))) {
+        return ($not ? '0=0' : '0=1');
+    }
+
+    $f = sql_serveur('in', $serveur, $option === 'continue' || $option === false);
+    if (!is_string($f) || !$f) {
+        return false;
+    }
+
+    return $f($champ, $valeurs, $not ? 'NOT' : '', $serveur, $option !== false);
 }
 
 /**
@@ -2102,19 +2102,19 @@ 
  * @param bool $option
  */
 function sql_in($champ, $valeurs, $not = '', $serveur = '', $option = true) {
-	$type = '';
-	if (!is_array($valeurs)) {
-		$valeurs = (string) $valeurs;
-		if (isset($valeurs[0]) && $valeurs[0] === ',') {
-			$valeurs = substr($valeurs, 1);
-		}
-		// on explode en tableau pour pouvoir securiser le contenu
-		$valeurs = explode(',', $valeurs);
-		// et on force un cast de type int donc
-		$type = 'int';
-	}
-
-	return sql_in_quote($champ, $valeurs, $not, $serveur, $type, $option);
+    $type = '';
+    if (!is_array($valeurs)) {
+        $valeurs = (string) $valeurs;
+        if (isset($valeurs[0]) && $valeurs[0] === ',') {
+            $valeurs = substr($valeurs, 1);
+        }
+        // on explode en tableau pour pouvoir securiser le contenu
+        $valeurs = explode(',', $valeurs);
+        // et on force un cast de type int donc
+        $type = 'int';
+    }
+
+    return sql_in_quote($champ, $valeurs, $not, $serveur, $type, $option);
 }
 
 
@@ -2155,24 +2155,24 @@ 
  *     Expression de requête SQL
  **/
 function sql_in_select(
-	$in,
-	$select,
-	$from = [],
-	$where = [],
-	$groupby = [],
-	$orderby = [],
-	$limit = '',
-	$having = [],
-	$serveur = ''
+    $in,
+    $select,
+    $from = [],
+    $where = [],
+    $groupby = [],
+    $orderby = [],
+    $limit = '',
+    $having = [],
+    $serveur = ''
 ) {
-	$liste = [];
-	$res = sql_select($select, $from, $where, $groupby, $orderby, $limit, $having, $serveur);
-	while ($r = sql_fetch($res)) {
-		$liste[] = array_shift($r);
-	}
-	sql_free($res);
-
-	return sql_in($in, $liste);
+    $liste = [];
+    $res = sql_select($select, $from, $where, $groupby, $orderby, $limit, $having, $serveur);
+    while ($r = sql_fetch($res)) {
+        $liste[] = array_shift($r);
+    }
+    sql_free($res);
+
+    return sql_in($in, $liste);
 }
 
 /**
@@ -2204,29 +2204,29 @@ 
  *    Position apres le saut.
  */
 function sql_skip($res, $pos, $saut, $count, $serveur = '', $option = true) {
-	// pas de saut en arriere qu'on ne sait pas faire sans sql_seek
-	if (($saut = (int) $saut) <= 0) {
-		return $pos;
-	}
-
-	$seek = $pos + $saut;
-	// si le saut fait depasser le maxi, on libere la resource
-	// et on sort
-	if ($seek >= $count) {
-		sql_free($res, $serveur, $option);
-
-		return $count;
-	}
-
-	if (sql_seek($res, $seek)) {
-		$pos = $seek;
-	} else {
-		while ($pos < $seek && sql_fetch($res, $serveur, $option)) {
-			$pos++;
-		}
-	}
-
-	return $pos;
+    // pas de saut en arriere qu'on ne sait pas faire sans sql_seek
+    if (($saut = (int) $saut) <= 0) {
+        return $pos;
+    }
+
+    $seek = $pos + $saut;
+    // si le saut fait depasser le maxi, on libere la resource
+    // et on sort
+    if ($seek >= $count) {
+        sql_free($res, $serveur, $option);
+
+        return $count;
+    }
+
+    if (sql_seek($res, $seek)) {
+        $pos = $seek;
+    } else {
+        while ($pos < $seek && sql_fetch($res, $serveur, $option)) {
+            $pos++;
+        }
+    }
+
+    return $pos;
 }
 
 
@@ -2246,7 +2246,7 @@ 
  *     True si le champ est de type entier
  */
 function sql_test_int($type, $serveur = '', $option = true) {
-	return preg_match('/^(TINYINT|SMALLINT|MEDIUMINT|INT|INTEGER|BIGINT)/i', trim($type));
+    return preg_match('/^(TINYINT|SMALLINT|MEDIUMINT|INT|INTEGER|BIGINT)/i', trim($type));
 }
 
 /**
@@ -2265,7 +2265,7 @@ 
  *     True si le champ est de type entier
  */
 function sql_test_date($type, $serveur = '', $option = true) {
-	return preg_match('/^(DATE|DATETIME|TIMESTAMP|TIME)/i', trim($type));
+    return preg_match('/^(DATE|DATETIME|TIMESTAMP|TIME)/i', trim($type));
 }
 
 /**
@@ -2287,19 +2287,19 @@ 
  *     La date formatee
  */
 function sql_format_date($annee = 0, $mois = 0, $jour = 0, $h = 0, $m = 0, $s = 0, $serveur = '') {
-	$annee = sprintf('%04s', $annee);
-	$mois = sprintf('%02s', $mois);
-
-	if ($annee == '0000') {
-		$mois = 0;
-	}
-	if ($mois == '00') {
-		$jour = 0;
-	}
-
-	return sprintf('%04u', $annee) . '-' . sprintf('%02u', $mois) . '-'
-	. sprintf('%02u', $jour) . ' ' . sprintf('%02u', $h) . ':'
-	. sprintf('%02u', $m) . ':' . sprintf('%02u', $s);
+    $annee = sprintf('%04s', $annee);
+    $mois = sprintf('%02s', $mois);
+
+    if ($annee == '0000') {
+        $mois = 0;
+    }
+    if ($mois == '00') {
+        $jour = 0;
+    }
+
+    return sprintf('%04u', $annee) . '-' . sprintf('%02u', $mois) . '-'
+    . sprintf('%02u', $jour) . ' ' . sprintf('%02u', $h) . ':'
+    . sprintf('%02u', $m) . ':' . sprintf('%02u', $s);
 }
 
 
@@ -2322,29 +2322,29 @@ 
  **/
 function description_table($nom, $serveur = '') {
 
-	static $trouver_table;
+    static $trouver_table;
 
-	/* toujours utiliser trouver_table
+    /* toujours utiliser trouver_table
 	 qui renverra la description theorique
 	 car sinon on va se comporter differement selon que la table est declaree
 	 ou non
 	 */
-	if (!$trouver_table) {
-		$trouver_table = charger_fonction('trouver_table', 'base');
-	}
-	if ($desc = $trouver_table($nom, $serveur)) {
-		return $desc;
-	}
-
-	// sauf a l'installation :
-	include_spip('base/serial');
-	if (isset($GLOBALS['tables_principales'][$nom])) {
-		return $GLOBALS['tables_principales'][$nom];
-	}
-
-	include_spip('base/auxiliaires');
-
-	return $GLOBALS['tables_auxiliaires'][$nom] ?? false;
+    if (!$trouver_table) {
+        $trouver_table = charger_fonction('trouver_table', 'base');
+    }
+    if ($desc = $trouver_table($nom, $serveur)) {
+        return $desc;
+    }
+
+    // sauf a l'installation :
+    include_spip('base/serial');
+    if (isset($GLOBALS['tables_principales'][$nom])) {
+        return $GLOBALS['tables_principales'][$nom];
+    }
+
+    include_spip('base/auxiliaires');
+
+    return $GLOBALS['tables_auxiliaires'][$nom] ?? false;
 }
 
 /**
@@ -2357,8 +2357,8 @@ 
  * @return string Table sql éventuellement renommée
  */
 function prefixer_table_spip($table, $prefixe) {
-	if ($prefixe) {
-		$table = preg_replace('/^spip_/', $prefixe . '_', $table);
-	}
-	return $table;
+    if ($prefixe) {
+        $table = preg_replace('/^spip_/', $prefixe . '_', $table);
+    }
+    return $table;
 }

ecrire/base/connect_sql.php

Indentation +318 added lines, -318 removed lines

@@ -15,7 +15,7 @@ 
  * @package SPIP\Core\SQL
  **/
 if (!defined('_ECRIRE_INC_VERSION')) {
-	return;
+    return;
 }
 require_once _ROOT_RESTREINT . 'base/objets.php';
 
@@ -41,124 +41,124 @@ 
  **/
 function spip_connect($serveur = '', $version = '') {
 
-	$serveur = is_string($serveur) ? strtolower($serveur) : '';
-	$index = $serveur ?: 0;
-	if (!$version) {
-		$version = $GLOBALS['spip_sql_version'];
-	}
-	if (isset($GLOBALS['connexions'][$index][$version])) {
-		return $GLOBALS['connexions'][$index];
-	}
-
-	include_spip('base/abstract_sql');
-	$install = (_request('exec') == 'install');
-
-	// Premiere connexion ?
-	if (!($old = isset($GLOBALS['connexions'][$index]))) {
-		$f = '';
-		if ($serveur) {
-			// serveur externe et nom de serveur bien ecrit ?
-			if (
-				defined('_DIR_CONNECT')
-				&& preg_match('/^[\w\.]*$/', $serveur)
-			) {
-				$f = _DIR_CONNECT . $serveur . '.php';
-				if (!is_readable($f) && !$install) {
-					// chercher une declaration de serveur dans le path
-					// qui peut servir à des plugins à declarer des connexions à une base sqlite
-					// Ex: sert aux boucles POUR et au plugin-dist dump pour se connecter sur le sqlite du dump
-					$f = find_in_path("$serveur.php", 'connect/');
-				}
-			}
-		} else {
-			if (defined('_FILE_CONNECT') && _FILE_CONNECT) {
-				// init du serveur principal
-				$f = _FILE_CONNECT;
-			} elseif ($install && defined('_FILE_CONNECT_TMP')) {
-				// installation en cours
-				$f = _FILE_CONNECT_TMP;
-			}
-		}
-
-		unset($GLOBALS['db_ok']);
-		unset($GLOBALS['spip_connect_version']);
-		if ($f && is_readable($f)) {
-			include($f);
-			if (!isset($GLOBALS['db_ok'])) {
-				spip_logger()->emergency("spip_connect: fichier de connexion '$f' OK mais echec connexion au serveur");
-			}
-		} else {
-			spip_logger()->emergency("spip_connect: fichier de connexion '$f' non trouve, pas de connexion serveur");
-		}
-		if (!isset($GLOBALS['db_ok'])) {
-			// fera mieux la prochaine fois
-			if ($install) {
-				return false;
-			}
-			// ne plus reessayer si ce n'est pas l'install
-			return $GLOBALS['connexions'][$index] = false;
-		}
-		$GLOBALS['connexions'][$index] = $GLOBALS['db_ok'];
-	}
-	// si la connexion a deja ete tentee mais a echoue, le dire!
-	if (!$GLOBALS['connexions'][$index]) {
-		return false;
-	}
-
-	// la connexion a reussi ou etait deja faite.
-	// chargement de la version du jeu de fonctions
-	// si pas dans le fichier par defaut
-	$type = $GLOBALS['db_ok']['type'];
-	$jeu = 'spip_' . $type . '_functions_' . $version;
-	if (!isset($GLOBALS[$jeu]) && !find_in_path($type . '_' . $version . '.php', 'req/', true)) {
-		spip_logger()->emergency("spip_connect: serveur $index version '$version' non defini pour '$type'");
-		// ne plus reessayer
-		return $GLOBALS['connexions'][$index][$version] = [];
-	}
-	$GLOBALS['connexions'][$index][$version] = $GLOBALS[$jeu];
-	if ($old) {
-		return $GLOBALS['connexions'][$index];
-	}
-
-	$GLOBALS['connexions'][$index]['spip_connect_version'] = $GLOBALS['spip_connect_version'] ?? 0;
-
-	// initialisation de l'alphabet utilise dans les connexions SQL
-	// si l'installation l'a determine.
-	// Celui du serveur principal l'impose aux serveurs secondaires
-	// s'ils le connaissent
-
-	if (!$serveur) {
-		$charset = spip_connect_main($GLOBALS[$jeu], $GLOBALS['db_ok']['charset']);
-		if (!$charset) {
-			unset($GLOBALS['connexions'][$index]);
-			spip_logger()->warning('spip_connect: absence de charset');
-
-			return false;
-		}
-	} else {
-		if ($GLOBALS['db_ok']['charset']) {
-			$charset = $GLOBALS['db_ok']['charset'];
-		}
-		// spip_meta n'existe pas toujours dans la base
-		// C'est le cas d'un dump sqlite par exemple
-		elseif (
-			$GLOBALS['connexions'][$index]['spip_connect_version']
-			&& sql_showtable('spip_meta', true, $serveur)
-			&& ($r = sql_getfetsel('valeur', 'spip_meta', "nom='charset_sql_connexion'", '', '', '', '', $serveur))
-		) {
-			$charset = $r;
-		} else {
-			$charset = -1;
-		}
-	}
-	if ($charset != -1) {
-		$f = $GLOBALS[$jeu]['set_charset'];
-		if (function_exists($f)) {
-			$f($charset, $serveur);
-		}
-	}
-
-	return $GLOBALS['connexions'][$index];
+    $serveur = is_string($serveur) ? strtolower($serveur) : '';
+    $index = $serveur ?: 0;
+    if (!$version) {
+        $version = $GLOBALS['spip_sql_version'];
+    }
+    if (isset($GLOBALS['connexions'][$index][$version])) {
+        return $GLOBALS['connexions'][$index];
+    }
+
+    include_spip('base/abstract_sql');
+    $install = (_request('exec') == 'install');
+
+    // Premiere connexion ?
+    if (!($old = isset($GLOBALS['connexions'][$index]))) {
+        $f = '';
+        if ($serveur) {
+            // serveur externe et nom de serveur bien ecrit ?
+            if (
+                defined('_DIR_CONNECT')
+                && preg_match('/^[\w\.]*$/', $serveur)
+            ) {
+                $f = _DIR_CONNECT . $serveur . '.php';
+                if (!is_readable($f) && !$install) {
+                    // chercher une declaration de serveur dans le path
+                    // qui peut servir à des plugins à declarer des connexions à une base sqlite
+                    // Ex: sert aux boucles POUR et au plugin-dist dump pour se connecter sur le sqlite du dump
+                    $f = find_in_path("$serveur.php", 'connect/');
+                }
+            }
+        } else {
+            if (defined('_FILE_CONNECT') && _FILE_CONNECT) {
+                // init du serveur principal
+                $f = _FILE_CONNECT;
+            } elseif ($install && defined('_FILE_CONNECT_TMP')) {
+                // installation en cours
+                $f = _FILE_CONNECT_TMP;
+            }
+        }
+
+        unset($GLOBALS['db_ok']);
+        unset($GLOBALS['spip_connect_version']);
+        if ($f && is_readable($f)) {
+            include($f);
+            if (!isset($GLOBALS['db_ok'])) {
+                spip_logger()->emergency("spip_connect: fichier de connexion '$f' OK mais echec connexion au serveur");
+            }
+        } else {
+            spip_logger()->emergency("spip_connect: fichier de connexion '$f' non trouve, pas de connexion serveur");
+        }
+        if (!isset($GLOBALS['db_ok'])) {
+            // fera mieux la prochaine fois
+            if ($install) {
+                return false;
+            }
+            // ne plus reessayer si ce n'est pas l'install
+            return $GLOBALS['connexions'][$index] = false;
+        }
+        $GLOBALS['connexions'][$index] = $GLOBALS['db_ok'];
+    }
+    // si la connexion a deja ete tentee mais a echoue, le dire!
+    if (!$GLOBALS['connexions'][$index]) {
+        return false;
+    }
+
+    // la connexion a reussi ou etait deja faite.
+    // chargement de la version du jeu de fonctions
+    // si pas dans le fichier par defaut
+    $type = $GLOBALS['db_ok']['type'];
+    $jeu = 'spip_' . $type . '_functions_' . $version;
+    if (!isset($GLOBALS[$jeu]) && !find_in_path($type . '_' . $version . '.php', 'req/', true)) {
+        spip_logger()->emergency("spip_connect: serveur $index version '$version' non defini pour '$type'");
+        // ne plus reessayer
+        return $GLOBALS['connexions'][$index][$version] = [];
+    }
+    $GLOBALS['connexions'][$index][$version] = $GLOBALS[$jeu];
+    if ($old) {
+        return $GLOBALS['connexions'][$index];
+    }
+
+    $GLOBALS['connexions'][$index]['spip_connect_version'] = $GLOBALS['spip_connect_version'] ?? 0;
+
+    // initialisation de l'alphabet utilise dans les connexions SQL
+    // si l'installation l'a determine.
+    // Celui du serveur principal l'impose aux serveurs secondaires
+    // s'ils le connaissent
+
+    if (!$serveur) {
+        $charset = spip_connect_main($GLOBALS[$jeu], $GLOBALS['db_ok']['charset']);
+        if (!$charset) {
+            unset($GLOBALS['connexions'][$index]);
+            spip_logger()->warning('spip_connect: absence de charset');
+
+            return false;
+        }
+    } else {
+        if ($GLOBALS['db_ok']['charset']) {
+            $charset = $GLOBALS['db_ok']['charset'];
+        }
+        // spip_meta n'existe pas toujours dans la base
+        // C'est le cas d'un dump sqlite par exemple
+        elseif (
+            $GLOBALS['connexions'][$index]['spip_connect_version']
+            && sql_showtable('spip_meta', true, $serveur)
+            && ($r = sql_getfetsel('valeur', 'spip_meta', "nom='charset_sql_connexion'", '', '', '', '', $serveur))
+        ) {
+            $charset = $r;
+        } else {
+            $charset = -1;
+        }
+    }
+    if ($charset != -1) {
+        $f = $GLOBALS[$jeu]['set_charset'];
+        if (function_exists($f)) {
+            $f($charset, $serveur);
+        }
+    }
+
+    return $GLOBALS['connexions'][$index];
 }
 
 /**
@@ -167,12 +167,12 @@ 
  * @param string $serveur Nom du connecteur de bdd utilisé
  **/
 function spip_sql_erreur($serveur = '') {
-	$connexion = spip_connect($serveur);
-	$e = sql_errno($serveur);
-	$t = ($connexion['type'] ?? 'sql');
-	$m = "Erreur $e de $t: " . sql_error($serveur) . "\nin " . sql_error_backtrace() . "\n" . trim((string) $connexion['last']);
-	$f = $t . $serveur;
-	spip_logger($f)->error($m);
+    $connexion = spip_connect($serveur);
+    $e = sql_errno($serveur);
+    $t = ($connexion['type'] ?? 'sql');
+    $m = "Erreur $e de $t: " . sql_error($serveur) . "\nin " . sql_error_backtrace() . "\n" . trim((string) $connexion['last']);
+    $f = $t . $serveur;
+    spip_logger($f)->error($m);
 }
 
 /**
@@ -194,23 +194,23 @@ 
  *     - array : description de la connexion, si l'instruction sql est indisponible pour cette connexion
  **/
 function spip_connect_sql($version, $ins = '', $serveur = '', $continue = false) {
-	$desc = spip_connect($serveur, $version);
-	if (
-		$desc
-		&& ($f = ($desc[$version][$ins] ?? ''))
-		&& function_exists($f)
-	) {
-		return $f;
-	}
-	if ($continue) {
-		return $desc;
-	}
-	if ($ins) {
-		spip_logger()->error("Le serveur '$serveur' version $version n'a pas '$ins'");
-	}
-	include_spip('inc/minipres');
-	echo minipres(_T('info_travaux_titre'), _T('titre_probleme_technique'), ['status' => 503]);
-	exit;
+    $desc = spip_connect($serveur, $version);
+    if (
+        $desc
+        && ($f = ($desc[$version][$ins] ?? ''))
+        && function_exists($f)
+    ) {
+        return $f;
+    }
+    if ($continue) {
+        return $desc;
+    }
+    if ($ins) {
+        spip_logger()->error("Le serveur '$serveur' version $version n'a pas '$ins'");
+    }
+    include_spip('inc/minipres');
+    echo minipres(_T('info_travaux_titre'), _T('titre_probleme_technique'), ['status' => 503]);
+    exit;
 }
 
 /**
@@ -236,70 +236,70 @@ 
  * @return array|null Description de la connexion
  */
 function spip_connect_db(
-	$host,
-	$port,
-	$login,
-	#[\SensitiveParameter] $pass,
-	$db = '',
-	$type = 'mysql',
-	$prefixe = '',
-	$auth = '',
-	$charset = ''
+    $host,
+    $port,
+    $login,
+    #[\SensitiveParameter] $pass,
+    $db = '',
+    $type = 'mysql',
+    $prefixe = '',
+    $auth = '',
+    $charset = ''
 ) {
-	// temps avant nouvelle tentative de connexion
-	// suite a une connection echouee
-	if (!defined('_CONNECT_RETRY_DELAY')) {
-		define('_CONNECT_RETRY_DELAY', 30);
-	}
-
-	$f = '';
-	// un fichier de identifiant par combinaison (type,host,port,db)
-	// pour ne pas declarer tout indisponible d'un coup
-	// si en cours d'installation ou si db=@test@ on ne pose rien
-	// car c'est un test de connexion
-	if (!defined('_ECRIRE_INSTALL') && $db !== '@test@') {
-		$f = _DIR_TMP . $type . '.' . substr(md5($host . $port . $db), 0, 8) . '.out';
-	} elseif ($db == '@test@') {
-		$db = '';
-	}
-
-	if (
-		$f
-		&& @file_exists($f)
-		&& (time() - @filemtime($f) < _CONNECT_RETRY_DELAY)
-	) {
-		spip_logger()->emergency("Echec : $f recent. Pas de tentative de connexion");
-
-		return null;
-	}
-
-	if (!$prefixe) {
-		$prefixe = $GLOBALS['table_prefix'] ?? $db;
-	}
-	$h = charger_fonction($type, 'req', true);
-	if (!$h) {
-		spip_logger()->emergency("les requetes $type ne sont pas fournies");
-
-		return null;
-	}
-	if ($g = $h($host, $port, $login, $pass, $db, $prefixe)) {
-		if (!is_array($auth)) {
-			// compatibilite version 0.7 initiale
-			$g['ldap'] = $auth;
-			$auth = ['ldap' => $auth];
-		}
-		$g['authentification'] = $auth;
-		$g['type'] = $type;
-		$g['charset'] = $charset;
-
-		return $GLOBALS['db_ok'] = $g;
-	}
-	// En cas d'indisponibilite du serveur, eviter de le bombarder
-	if ($f) {
-		@touch($f);
-		spip_logger($type)->emergency("Echec connexion serveur $type : host[$host] port[$port] login[$login] base[$db]");
-	}
-	return null;
+    // temps avant nouvelle tentative de connexion
+    // suite a une connection echouee
+    if (!defined('_CONNECT_RETRY_DELAY')) {
+        define('_CONNECT_RETRY_DELAY', 30);
+    }
+
+    $f = '';
+    // un fichier de identifiant par combinaison (type,host,port,db)
+    // pour ne pas declarer tout indisponible d'un coup
+    // si en cours d'installation ou si db=@test@ on ne pose rien
+    // car c'est un test de connexion
+    if (!defined('_ECRIRE_INSTALL') && $db !== '@test@') {
+        $f = _DIR_TMP . $type . '.' . substr(md5($host . $port . $db), 0, 8) . '.out';
+    } elseif ($db == '@test@') {
+        $db = '';
+    }
+
+    if (
+        $f
+        && @file_exists($f)
+        && (time() - @filemtime($f) < _CONNECT_RETRY_DELAY)
+    ) {
+        spip_logger()->emergency("Echec : $f recent. Pas de tentative de connexion");
+
+        return null;
+    }
+
+    if (!$prefixe) {
+        $prefixe = $GLOBALS['table_prefix'] ?? $db;
+    }
+    $h = charger_fonction($type, 'req', true);
+    if (!$h) {
+        spip_logger()->emergency("les requetes $type ne sont pas fournies");
+
+        return null;
+    }
+    if ($g = $h($host, $port, $login, $pass, $db, $prefixe)) {
+        if (!is_array($auth)) {
+            // compatibilite version 0.7 initiale
+            $g['ldap'] = $auth;
+            $auth = ['ldap' => $auth];
+        }
+        $g['authentification'] = $auth;
+        $g['type'] = $type;
+        $g['charset'] = $charset;
+
+        return $GLOBALS['db_ok'] = $g;
+    }
+    // En cas d'indisponibilite du serveur, eviter de le bombarder
+    if ($f) {
+        @touch($f);
+        spip_logger($type)->emergency("Echec connexion serveur $type : host[$host] port[$port] login[$login] base[$db]");
+    }
+    return null;
 }
 
 
@@ -331,32 +331,32 @@ 
  *     - nom du charset sinon
  **/
 function spip_connect_main($connexion, $charset_sql_connexion = '') {
-	if ($GLOBALS['spip_connect_version'] < 0.1 && _DIR_RESTREINT) {
-		include_spip('inc/headers');
-		redirige_url_ecrire('upgrade', 'reinstall=oui');
-	}
-
-	if (!($f = $connexion['select'])) {
-		return false;
-	}
-	// si le charset est fourni, l'utiliser
-	if ($charset_sql_connexion) {
-		return $charset_sql_connexion;
-	}
-	// sinon on regarde la table spip_meta
-	// en cas d'erreur select retourne la requette (is_string=true donc)
-	if (
-		!($r = $f('valeur', 'spip_meta', "nom='charset_sql_connexion'"))
-		|| is_string($r)
-	) {
-		return false;
-	}
-	if (!($f = $connexion['fetch'])) {
-		return false;
-	}
-	$r = $f($r);
-
-	return (isset($r['valeur']) && $r['valeur']) ? $r['valeur'] : -1;
+    if ($GLOBALS['spip_connect_version'] < 0.1 && _DIR_RESTREINT) {
+        include_spip('inc/headers');
+        redirige_url_ecrire('upgrade', 'reinstall=oui');
+    }
+
+    if (!($f = $connexion['select'])) {
+        return false;
+    }
+    // si le charset est fourni, l'utiliser
+    if ($charset_sql_connexion) {
+        return $charset_sql_connexion;
+    }
+    // sinon on regarde la table spip_meta
+    // en cas d'erreur select retourne la requette (is_string=true donc)
+    if (
+        !($r = $f('valeur', 'spip_meta', "nom='charset_sql_connexion'"))
+        || is_string($r)
+    ) {
+        return false;
+    }
+    if (!($f = $connexion['fetch'])) {
+        return false;
+    }
+    $r = $f($r);
+
+    return (isset($r['valeur']) && $r['valeur']) ? $r['valeur'] : -1;
 }
 
 /**
@@ -372,16 +372,16 @@ 
  * @return string Valeur échappée.
  **/
 function _q($a): string {
-	if (is_numeric($a)) {
-		return (string) $a;
-	} elseif (is_array($a)) {
-		return implode(',', array_map('_q', $a));
-	} elseif (is_scalar($a)) {
-		return ("'" . addslashes($a) . "'");
-	} elseif ($a === null) {
-		return "''";
-	}
-	throw new \RuntimeException('Can’t use _q with ' . gettype($a));
+    if (is_numeric($a)) {
+        return (string) $a;
+    } elseif (is_array($a)) {
+        return implode(',', array_map('_q', $a));
+    } elseif (is_scalar($a)) {
+        return ("'" . addslashes($a) . "'");
+    } elseif ($a === null) {
+        return "''";
+    }
+    throw new \RuntimeException('Can’t use _q with ' . gettype($a));
 }
 
 /**
@@ -397,75 +397,75 @@ 
  * @return array
  */
 function query_echappe_textes($query, $uniqid = null) {
-	static $codeEchappements = null;
-	if (is_null($codeEchappements) || $uniqid) {
-		if (is_null($uniqid)) {
-			$uniqid = uniqid();
-		}
-		$uniqid = substr(md5((string) $uniqid), 0, 4);
-		$codeEchappements = ['\\\\' => "\x1@#{$uniqid}#@\x1", "\\'" => "\x2@#{$uniqid}#@\x2", '\\"' => "\x3@#{$uniqid}#@\x3", '%' => "\x4@#{$uniqid}#@\x4"];
-	}
-	if ($query === null) {
-		return $codeEchappements;
-	}
-
-	// si la query contient deja des codes d'echappement on va s'emmeler les pinceaux et donc on ne touche a rien
-	// ce n'est pas un cas legitime
-	foreach ($codeEchappements as $codeEchappement) {
-		if (str_contains($query, (string) $codeEchappement)) {
-			return [$query, []];
-		}
-	}
-
-	$query_echappees = str_replace(array_keys($codeEchappements), array_values($codeEchappements), $query);
-	if (preg_match_all("/('[^']*')|(\"[^\"]*\")/S", $query_echappees, $textes)) {
-		$textes = reset($textes);
-
-		$parts = [];
-		$currentpos = 0;
-		$k = 0;
-		while (count($textes)) {
-			$part = array_shift($textes);
-			$nextpos = strpos($query_echappees, (string) $part, $currentpos);
-			// si besoin recoller ensemble les doubles '' de sqlite (echappement des ')
-			while (count($textes) && str_ends_with((string) $part, "'")) {
-				$next = reset($textes);
-				if (
-					str_starts_with((string) $next, "'")
-					&& strpos($query_echappees, $part . $next, $currentpos) === $nextpos
-				) {
-					$part .= array_shift($textes);
-				}
-				else {
-					break;
-				}
-			}
-			$k++;
-			$parts[$k] = [
-				'texte' => $part,
-				'position' => $nextpos,
-				'placeholder' => '%' . $k . '$s',
-			];
-			$currentpos = $nextpos + strlen((string) $part);
-		}
-
-		// et on replace les parts une par une en commencant par la fin
-		while ($k > 0) {
-			$query_echappees = substr_replace($query_echappees, $parts[$k]['placeholder'], $parts[$k]['position'], strlen((string) $parts[$k]['texte']));
-			$k--;
-		}
-		$textes = array_column($parts, 'texte');
-	} else {
-		$textes = [];
-	}
-
-	// si il reste des quotes simples ou doubles, c'est qu'on s'est emmelle les pinceaux
-	// dans le doute on ne touche a rien
-	if (strpbrk($query_echappees, "'\"") !== false) {
-		return [$query, []];
-	}
-
-	return [$query_echappees, $textes];
+    static $codeEchappements = null;
+    if (is_null($codeEchappements) || $uniqid) {
+        if (is_null($uniqid)) {
+            $uniqid = uniqid();
+        }
+        $uniqid = substr(md5((string) $uniqid), 0, 4);
+        $codeEchappements = ['\\\\' => "\x1@#{$uniqid}#@\x1", "\\'" => "\x2@#{$uniqid}#@\x2", '\\"' => "\x3@#{$uniqid}#@\x3", '%' => "\x4@#{$uniqid}#@\x4"];
+    }
+    if ($query === null) {
+        return $codeEchappements;
+    }
+
+    // si la query contient deja des codes d'echappement on va s'emmeler les pinceaux et donc on ne touche a rien
+    // ce n'est pas un cas legitime
+    foreach ($codeEchappements as $codeEchappement) {
+        if (str_contains($query, (string) $codeEchappement)) {
+            return [$query, []];
+        }
+    }
+
+    $query_echappees = str_replace(array_keys($codeEchappements), array_values($codeEchappements), $query);
+    if (preg_match_all("/('[^']*')|(\"[^\"]*\")/S", $query_echappees, $textes)) {
+        $textes = reset($textes);
+
+        $parts = [];
+        $currentpos = 0;
+        $k = 0;
+        while (count($textes)) {
+            $part = array_shift($textes);
+            $nextpos = strpos($query_echappees, (string) $part, $currentpos);
+            // si besoin recoller ensemble les doubles '' de sqlite (echappement des ')
+            while (count($textes) && str_ends_with((string) $part, "'")) {
+                $next = reset($textes);
+                if (
+                    str_starts_with((string) $next, "'")
+                    && strpos($query_echappees, $part . $next, $currentpos) === $nextpos
+                ) {
+                    $part .= array_shift($textes);
+                }
+                else {
+                    break;
+                }
+            }
+            $k++;
+            $parts[$k] = [
+                'texte' => $part,
+                'position' => $nextpos,
+                'placeholder' => '%' . $k . '$s',
+            ];
+            $currentpos = $nextpos + strlen((string) $part);
+        }
+
+        // et on replace les parts une par une en commencant par la fin
+        while ($k > 0) {
+            $query_echappees = substr_replace($query_echappees, $parts[$k]['placeholder'], $parts[$k]['position'], strlen((string) $parts[$k]['texte']));
+            $k--;
+        }
+        $textes = array_column($parts, 'texte');
+    } else {
+        $textes = [];
+    }
+
+    // si il reste des quotes simples ou doubles, c'est qu'on s'est emmelle les pinceaux
+    // dans le doute on ne touche a rien
+    if (strpbrk($query_echappees, "'\"") !== false) {
+        return [$query, []];
+    }
+
+    return [$query_echappees, $textes];
 }
 
 /**
@@ -479,14 +479,14 @@ 
  * @return string
  */
 function query_reinjecte_textes($query, $textes) {
-	// recuperer les codes echappements
-	$codeEchappements = query_echappe_textes(null);
+    // recuperer les codes echappements
+    $codeEchappements = query_echappe_textes(null);
 
-	if (!empty($textes)) {
-		$query = sprintf($query, ...$textes);
-	}
+    if (!empty($textes)) {
+        $query = sprintf($query, ...$textes);
+    }
 
-	return str_replace(array_values($codeEchappements), array_keys($codeEchappements), $query);
+    return str_replace(array_values($codeEchappements), array_keys($codeEchappements), $query);
 }
 
 
@@ -505,7 +505,7 @@ 
  **/
 function spip_query($query, $serveur = '') {
 
-	$f = spip_connect_sql($GLOBALS['spip_sql_version'], 'query', $serveur, true);
+    $f = spip_connect_sql($GLOBALS['spip_sql_version'], 'query', $serveur, true);
 
-	return function_exists($f) ? $f($query, $serveur) : false;
+    return function_exists($f) ? $f($query, $serveur) : false;
 }

Spacing +11 added lines, -11 removed lines

@@ -17,7 +17,7 @@ 
 if (!defined('_ECRIRE_INC_VERSION')) {
 	return;
 }
-require_once _ROOT_RESTREINT . 'base/objets.php';
+require_once _ROOT_RESTREINT.'base/objets.php';
 
 
 /**
@@ -62,7 +62,7 @@ 
 				defined('_DIR_CONNECT')
 				&& preg_match('/^[\w\.]*$/', $serveur)
 			) {
-				$f = _DIR_CONNECT . $serveur . '.php';
+				$f = _DIR_CONNECT.$serveur.'.php';
 				if (!is_readable($f) && !$install) {
 					// chercher une declaration de serveur dans le path
 					// qui peut servir à des plugins à declarer des connexions à une base sqlite
@@ -109,8 +109,8 @@ 
 	// chargement de la version du jeu de fonctions
 	// si pas dans le fichier par defaut
 	$type = $GLOBALS['db_ok']['type'];
-	$jeu = 'spip_' . $type . '_functions_' . $version;
-	if (!isset($GLOBALS[$jeu]) && !find_in_path($type . '_' . $version . '.php', 'req/', true)) {
+	$jeu = 'spip_'.$type.'_functions_'.$version;
+	if (!isset($GLOBALS[$jeu]) && !find_in_path($type.'_'.$version.'.php', 'req/', true)) {
 		spip_logger()->emergency("spip_connect: serveur $index version '$version' non defini pour '$type'");
 		// ne plus reessayer
 		return $GLOBALS['connexions'][$index][$version] = [];
@@ -170,8 +170,8 @@ 
 	$connexion = spip_connect($serveur);
 	$e = sql_errno($serveur);
 	$t = ($connexion['type'] ?? 'sql');
-	$m = "Erreur $e de $t: " . sql_error($serveur) . "\nin " . sql_error_backtrace() . "\n" . trim((string) $connexion['last']);
-	$f = $t . $serveur;
+	$m = "Erreur $e de $t: ".sql_error($serveur)."\nin ".sql_error_backtrace()."\n".trim((string) $connexion['last']);
+	$f = $t.$serveur;
 	spip_logger($f)->error($m);
 }
 
@@ -258,7 +258,7 @@ 
 	// si en cours d'installation ou si db=@test@ on ne pose rien
 	// car c'est un test de connexion
 	if (!defined('_ECRIRE_INSTALL') && $db !== '@test@') {
-		$f = _DIR_TMP . $type . '.' . substr(md5($host . $port . $db), 0, 8) . '.out';
+		$f = _DIR_TMP.$type.'.'.substr(md5($host.$port.$db), 0, 8).'.out';
 	} elseif ($db == '@test@') {
 		$db = '';
 	}
@@ -377,11 +377,11 @@ 
 	} elseif (is_array($a)) {
 		return implode(',', array_map('_q', $a));
 	} elseif (is_scalar($a)) {
-		return ("'" . addslashes($a) . "'");
+		return ("'".addslashes($a)."'");
 	} elseif ($a === null) {
 		return "''";
 	}
-	throw new \RuntimeException('Can’t use _q with ' . gettype($a));
+	throw new \RuntimeException('Can’t use _q with '.gettype($a));
 }
 
 /**
@@ -432,7 +432,7 @@ 
 				$next = reset($textes);
 				if (
 					str_starts_with((string) $next, "'")
-					&& strpos($query_echappees, $part . $next, $currentpos) === $nextpos
+					&& strpos($query_echappees, $part.$next, $currentpos) === $nextpos
 				) {
 					$part .= array_shift($textes);
 				}
@@ -444,7 +444,7 @@ 
 			$parts[$k] = [
 				'texte' => $part,
 				'position' => $nextpos,
-				'placeholder' => '%' . $k . '$s',
+				'placeholder' => '%'.$k.'$s',
 			];
 			$currentpos = $nextpos + strlen((string) $part);
 		}

Braces +1 added lines, -2 removed lines

@@ -435,8 +435,7 @@
 					&& strpos($query_echappees, $part . $next, $currentpos) === $nextpos
 				) {
 					$part .= array_shift($textes);
-				}
-				else {
+				} else {
 					break;
 				}
 			}

ecrire/base/dump.php

Indentation +525 added lines, -525 removed lines

@@ -16,7 +16,7 @@ 
  */
 
 if (!defined('_ECRIRE_INC_VERSION')) {
-	return;
+    return;
 }
 
 define('_VERSION_ARCHIVE', '1.3');
@@ -37,7 +37,7 @@ 
  * @return string
  **/
 function base_dump_meta_name($rub) {
-	return $meta = "status_dump_{$rub}_" . abs($GLOBALS['visiteur_session']['id_auteur']);
+    return $meta = "status_dump_{$rub}_" . abs($GLOBALS['visiteur_session']['id_auteur']);
 }
 
 /**
@@ -52,14 +52,14 @@ 
  * @return string
  **/
 function base_dump_dir($meta) {
-	include_spip('inc/documents');
-	// determine upload va aussi initialiser l'index "restreint"
-	$maindir = determine_upload();
-	if (!$GLOBALS['visiteur_session']['restreint']) {
-		$maindir = _DIR_DUMP;
-	}
-
-	return sous_repertoire($maindir, $meta);
+    include_spip('inc/documents');
+    // determine upload va aussi initialiser l'index "restreint"
+    $maindir = determine_upload();
+    if (!$GLOBALS['visiteur_session']['restreint']) {
+        $maindir = _DIR_DUMP;
+    }
+
+    return sous_repertoire($maindir, $meta);
 }
 
 /**
@@ -73,28 +73,28 @@ 
  * @return array
  */
 function base_lister_toutes_tables(
-	$serveur = '',
-	$tables = [],
-	$exclude = [],
-	$affiche_vrai_prefixe = false
+    $serveur = '',
+    $tables = [],
+    $exclude = [],
+    $affiche_vrai_prefixe = false
 ) {
-	spip_connect($serveur);
-	$connexion = $GLOBALS['connexions'][$serveur ?: 0];
-	$prefixe = $connexion['prefixe'];
-
-	$p = '/^' . $prefixe . '/';
-	$res = $tables;
-	foreach (sql_alltable(null, $serveur) as $t) {
-		if (preg_match($p, (string) $t)) {
-			$t1 = preg_replace($p, 'spip', (string) $t);
-			if (!in_array($t1, $tables) && !in_array($t1, $exclude)) {
-				$res[] = ($affiche_vrai_prefixe ? $t : $t1);
-			}
-		}
-	}
-	sort($res);
-
-	return $res;
+    spip_connect($serveur);
+    $connexion = $GLOBALS['connexions'][$serveur ?: 0];
+    $prefixe = $connexion['prefixe'];
+
+    $p = '/^' . $prefixe . '/';
+    $res = $tables;
+    foreach (sql_alltable(null, $serveur) as $t) {
+        if (preg_match($p, (string) $t)) {
+            $t1 = preg_replace($p, 'spip', (string) $t);
+            if (!in_array($t1, $tables) && !in_array($t1, $exclude)) {
+                $res[] = ($affiche_vrai_prefixe ? $t : $t1);
+            }
+        }
+    }
+    sort($res);
+
+    return $res;
 }
 
 /**
@@ -104,10 +104,10 @@ 
  * @return string
  */
 function base_prefixe_tables($serveur = '') {
-	spip_connect($serveur);
-	$connexion = $GLOBALS['connexions'][$serveur ?: 0];
+    spip_connect($serveur);
+    $connexion = $GLOBALS['connexions'][$serveur ?: 0];
 
-	return $connexion['prefixe'];
+    return $connexion['prefixe'];
 }
 
 
@@ -122,26 +122,26 @@ 
  * @return array
  */
 function base_saisie_tables($name, $tables, $exclude = [], $post = null, $serveur = '') {
-	include_spip('inc/filtres');
-	$res = [];
-	foreach ($tables as $k => $t) {
-		// par defaut tout est coche sauf les tables dans $exclude
-		$check = is_null($post) ? !in_array($t, $exclude) : in_array($t, $post);
-
-		$res[$k] = "<input type='checkbox' value='$t' name='$name"
-			. "[]' id='$name$k'"
-			. ($check ? " checked='checked'" : '')
-			. "/>\n"
-			. "<label for='$name$k'>$t</label>"
-			. ' ('
-			. sinon(
-				singulier_ou_pluriel(sql_countsel($t, '', '', '', $serveur), 'dump:une_donnee', 'dump:nb_donnees'),
-				_T('dump:aucune_donnee')
-			)
-			. ')';
-	}
-
-	return $res;
+    include_spip('inc/filtres');
+    $res = [];
+    foreach ($tables as $k => $t) {
+        // par defaut tout est coche sauf les tables dans $exclude
+        $check = is_null($post) ? !in_array($t, $exclude) : in_array($t, $post);
+
+        $res[$k] = "<input type='checkbox' value='$t' name='$name"
+            . "[]' id='$name$k'"
+            . ($check ? " checked='checked'" : '')
+            . "/>\n"
+            . "<label for='$name$k'>$t</label>"
+            . ' ('
+            . sinon(
+                singulier_ou_pluriel(sql_countsel($t, '', '', '', $serveur), 'dump:une_donnee', 'dump:nb_donnees'),
+                _T('dump:aucune_donnee')
+            )
+            . ')';
+    }
+
+    return $res;
 }
 
 
@@ -153,27 +153,27 @@ 
  * @return array
  */
 function lister_tables_noexport() {
-	// par defaut tout est exporte sauf les tables ci-dessous
-	static $EXPORT_tables_noexport = null;
-	if (!is_null($EXPORT_tables_noexport)) {
-		return $EXPORT_tables_noexport;
-	}
-
-	$EXPORT_tables_noexport = [
-		'spip_caches', // plugin invalideur
-		'spip_resultats', // resultats de recherche ... c'est un cache !
-		'spip_test', // c'est un test !
-		#'spip_referers',
-		#'spip_referers_articles',
-		#'spip_visites',
-		#'spip_visites_articles',
-		#'spip_versions',
-		#'spip_versions_fragments'
-	];
-
-	$EXPORT_tables_noexport = pipeline('lister_tables_noexport', $EXPORT_tables_noexport);
-
-	return $EXPORT_tables_noexport;
+    // par defaut tout est exporte sauf les tables ci-dessous
+    static $EXPORT_tables_noexport = null;
+    if (!is_null($EXPORT_tables_noexport)) {
+        return $EXPORT_tables_noexport;
+    }
+
+    $EXPORT_tables_noexport = [
+        'spip_caches', // plugin invalideur
+        'spip_resultats', // resultats de recherche ... c'est un cache !
+        'spip_test', // c'est un test !
+        #'spip_referers',
+        #'spip_referers_articles',
+        #'spip_visites',
+        #'spip_visites_articles',
+        #'spip_versions',
+        #'spip_versions_fragments'
+    ];
+
+    $EXPORT_tables_noexport = pipeline('lister_tables_noexport', $EXPORT_tables_noexport);
+
+    return $EXPORT_tables_noexport;
 }
 
 /**
@@ -184,25 +184,25 @@ 
  * @return array
  */
 function lister_tables_noimport() {
-	static $IMPORT_tables_noimport = null;
-	if (!is_null($IMPORT_tables_noimport)) {
-		return $IMPORT_tables_noimport;
-	}
-
-	$IMPORT_tables_noimport = [];
-	// par defaut tout est importe sauf les tables ci-dessous
-	// possibiliter de definir cela tables via la meta
-	// compatibilite
-	if (isset($GLOBALS['meta']['IMPORT_tables_noimport'])) {
-		$IMPORT_tables_noimport = unserialize($GLOBALS['meta']['IMPORT_tables_noimport']);
-		if (!is_array($IMPORT_tables_noimport)) {
-			include_spip('inc/meta');
-			effacer_meta('IMPORT_tables_noimport');
-		}
-	}
-	$IMPORT_tables_noimport = pipeline('lister_tables_noimport', $IMPORT_tables_noimport);
-
-	return $IMPORT_tables_noimport;
+    static $IMPORT_tables_noimport = null;
+    if (!is_null($IMPORT_tables_noimport)) {
+        return $IMPORT_tables_noimport;
+    }
+
+    $IMPORT_tables_noimport = [];
+    // par defaut tout est importe sauf les tables ci-dessous
+    // possibiliter de definir cela tables via la meta
+    // compatibilite
+    if (isset($GLOBALS['meta']['IMPORT_tables_noimport'])) {
+        $IMPORT_tables_noimport = unserialize($GLOBALS['meta']['IMPORT_tables_noimport']);
+        if (!is_array($IMPORT_tables_noimport)) {
+            include_spip('inc/meta');
+            effacer_meta('IMPORT_tables_noimport');
+        }
+    }
+    $IMPORT_tables_noimport = pipeline('lister_tables_noimport', $IMPORT_tables_noimport);
+
+    return $IMPORT_tables_noimport;
 }
 
 
@@ -214,23 +214,23 @@ 
  * @return array
  */
 function lister_tables_noerase() {
-	static $IMPORT_tables_noerase = null;
-	if (!is_null($IMPORT_tables_noerase)) {
-		return $IMPORT_tables_noerase;
-	}
-
-	$IMPORT_tables_noerase = [
-		'spip_meta',
-		// par defaut on ne vide pas les stats, car elles ne figurent pas dans les dump
-		// et le cas echeant, un bouton dans l'admin permet de les vider a la main...
-		'spip_referers',
-		'spip_referers_articles',
-		'spip_visites',
-		'spip_visites_articles'
-	];
-	$IMPORT_tables_noerase = pipeline('lister_tables_noerase', $IMPORT_tables_noerase);
-
-	return $IMPORT_tables_noerase;
+    static $IMPORT_tables_noerase = null;
+    if (!is_null($IMPORT_tables_noerase)) {
+        return $IMPORT_tables_noerase;
+    }
+
+    $IMPORT_tables_noerase = [
+        'spip_meta',
+        // par defaut on ne vide pas les stats, car elles ne figurent pas dans les dump
+        // et le cas echeant, un bouton dans l'admin permet de les vider a la main...
+        'spip_referers',
+        'spip_referers_articles',
+        'spip_visites',
+        'spip_visites_articles'
+    ];
+    $IMPORT_tables_noerase = pipeline('lister_tables_noerase', $IMPORT_tables_noerase);
+
+    return $IMPORT_tables_noerase;
 }
 
 
@@ -244,86 +244,86 @@ 
  * @return array
  */
 function base_liste_table_for_dump($exclude_tables = []) {
-	$tables_for_dump = [];
-	$tables_pointees = [];
-	$tables = [];
-	$tables_principales = $GLOBALS['tables_principales'];
-	$tables_auxiliaires = $GLOBALS['tables_auxiliaires'];
-	$tables_jointures = $GLOBALS['tables_jointures'];
-
-	if (
-		include_spip('base/objets')
-		&& function_exists('lister_tables_objets_sql')
-	) {
-		$tables = lister_tables_objets_sql();
-		foreach ($tables as $t => $infos) {
-			if ($infos['principale'] && !isset($tables_principales[$t])) {
-				$tables_principales[$t] = true;
-			}
-			if (!$infos['principale'] && !isset($tables_auxiliaires[$t])) {
-				$tables_auxiliaires[$t] = true;
-			}
-			if (is_countable($infos['tables_jointures']) ? count($infos['tables_jointures']) : 0) {
-				$tables_jointures[$t] = array_merge(
-					$tables_jointures[$t] ?? [],
-					$infos['tables_jointures']
-				);
-			}
-		}
-	}
-
-	// on construit un index des tables de liens
-	// pour les ajouter SI les deux tables qu'ils connectent sont sauvegardees
-	$tables_for_link = [];
-	foreach ($tables_jointures as $table => $liste_relations) {
-		if (is_array($liste_relations)) {
-			$nom = $table;
-			if (!isset($tables_auxiliaires[$nom]) && !isset($tables_principales[$nom])) {
-				$nom = "spip_$table";
-			}
-			if (isset($tables_auxiliaires[$nom]) || isset($tables_principales[$nom])) {
-				foreach ($liste_relations as $link_table) {
-					if (isset($tables_auxiliaires[$link_table])/*||isset($tables_principales[$link_table])*/) {
-						$tables_for_link[$link_table][] = $nom;
-					} else {
-						if (isset($tables_auxiliaires["spip_$link_table"])/*||isset($tables_principales["spip_$link_table"])*/) {
-							$tables_for_link["spip_$link_table"][] = $nom;
-						}
-					}
-				}
-			}
-		}
-	}
-
-	$liste_tables = [...array_keys($tables_principales), ...array_keys($tables_auxiliaires), ...array_keys($tables)];
-	foreach ($liste_tables as $table) {
-		//		$name = preg_replace("{^spip_}","",$table);
-		if (
-			!isset($tables_pointees[$table])
-			&& !in_array($table, $exclude_tables)
-			&& !isset($tables_for_link[$table])
-		) {
-			$tables_for_dump[] = $table;
-			$tables_pointees[$table] = 1;
-		}
-	}
-	foreach ($tables_for_link as $link_table => $liste) {
-		$connecte = true;
-		foreach ($liste as $connect_table) {
-			if (!in_array($connect_table, $tables_for_dump)) {
-				$connecte = false;
-			}
-		}
-		if ($connecte) {
-			# on ajoute les liaisons en premier
-			# si une restauration est interrompue,
-			# cela se verra mieux si il manque des objets
-			# que des liens
-		array_unshift($tables_for_dump, $link_table);
-		}
-	}
-
-	return [$tables_for_dump, $tables_for_link];
+    $tables_for_dump = [];
+    $tables_pointees = [];
+    $tables = [];
+    $tables_principales = $GLOBALS['tables_principales'];
+    $tables_auxiliaires = $GLOBALS['tables_auxiliaires'];
+    $tables_jointures = $GLOBALS['tables_jointures'];
+
+    if (
+        include_spip('base/objets')
+        && function_exists('lister_tables_objets_sql')
+    ) {
+        $tables = lister_tables_objets_sql();
+        foreach ($tables as $t => $infos) {
+            if ($infos['principale'] && !isset($tables_principales[$t])) {
+                $tables_principales[$t] = true;
+            }
+            if (!$infos['principale'] && !isset($tables_auxiliaires[$t])) {
+                $tables_auxiliaires[$t] = true;
+            }
+            if (is_countable($infos['tables_jointures']) ? count($infos['tables_jointures']) : 0) {
+                $tables_jointures[$t] = array_merge(
+                    $tables_jointures[$t] ?? [],
+                    $infos['tables_jointures']
+                );
+            }
+        }
+    }
+
+    // on construit un index des tables de liens
+    // pour les ajouter SI les deux tables qu'ils connectent sont sauvegardees
+    $tables_for_link = [];
+    foreach ($tables_jointures as $table => $liste_relations) {
+        if (is_array($liste_relations)) {
+            $nom = $table;
+            if (!isset($tables_auxiliaires[$nom]) && !isset($tables_principales[$nom])) {
+                $nom = "spip_$table";
+            }
+            if (isset($tables_auxiliaires[$nom]) || isset($tables_principales[$nom])) {
+                foreach ($liste_relations as $link_table) {
+                    if (isset($tables_auxiliaires[$link_table])/*||isset($tables_principales[$link_table])*/) {
+                        $tables_for_link[$link_table][] = $nom;
+                    } else {
+                        if (isset($tables_auxiliaires["spip_$link_table"])/*||isset($tables_principales["spip_$link_table"])*/) {
+                            $tables_for_link["spip_$link_table"][] = $nom;
+                        }
+                    }
+                }
+            }
+        }
+    }
+
+    $liste_tables = [...array_keys($tables_principales), ...array_keys($tables_auxiliaires), ...array_keys($tables)];
+    foreach ($liste_tables as $table) {
+        //		$name = preg_replace("{^spip_}","",$table);
+        if (
+            !isset($tables_pointees[$table])
+            && !in_array($table, $exclude_tables)
+            && !isset($tables_for_link[$table])
+        ) {
+            $tables_for_dump[] = $table;
+            $tables_pointees[$table] = 1;
+        }
+    }
+    foreach ($tables_for_link as $link_table => $liste) {
+        $connecte = true;
+        foreach ($liste as $connect_table) {
+            if (!in_array($connect_table, $tables_for_dump)) {
+                $connecte = false;
+            }
+        }
+        if ($connecte) {
+            # on ajoute les liaisons en premier
+            # si une restauration est interrompue,
+            # cela se verra mieux si il manque des objets
+            # que des liens
+        array_unshift($tables_for_dump, $link_table);
+        }
+    }
+
+    return [$tables_for_dump, $tables_for_link];
 }
 
 /**
@@ -338,34 +338,34 @@ 
  * @param string $serveur
  */
 function base_vider_tables_destination_copie($tables, $exclure_tables = [], $serveur = '') {
-	$trouver_table = charger_fonction('trouver_table', 'base');
-
-	spip_logger('base')->notice(
-		'Vider ' . count($tables) . " tables sur serveur '$serveur' : " . implode(', ', $tables),
-	);
-	foreach ($tables as $table) {
-		// sur le serveur principal, il ne faut pas supprimer l'auteur loge !
-		if (!in_array($table, $exclure_tables) && ($table != 'spip_auteurs' || $serveur != '')) {
-			// regarder si il y a au moins un champ impt='non'
-			$desc = $trouver_table($table, $serveur);
-			if (isset($desc['field']['impt'])) {
-				sql_delete($table, "impt='oui'", $serveur);
-			} elseif ($desc) {
-				sql_delete($table, '', $serveur);
-			}
-		}
-	}
-
-	// sur le serveur principal, il ne faut pas supprimer l'auteur loge !
-	// Bidouille pour garder l'acces admin actuel pendant toute la restauration
-	if (
-		$serveur == ''
-		&& in_array('spip_auteurs', $tables)
-		&& !in_array('spip_auteurs', $exclure_tables)
-	) {
-		base_conserver_copieur(true, $serveur);
-		sql_delete('spip_auteurs', 'id_auteur>0', $serveur);
-	}
+    $trouver_table = charger_fonction('trouver_table', 'base');
+
+    spip_logger('base')->notice(
+        'Vider ' . count($tables) . " tables sur serveur '$serveur' : " . implode(', ', $tables),
+    );
+    foreach ($tables as $table) {
+        // sur le serveur principal, il ne faut pas supprimer l'auteur loge !
+        if (!in_array($table, $exclure_tables) && ($table != 'spip_auteurs' || $serveur != '')) {
+            // regarder si il y a au moins un champ impt='non'
+            $desc = $trouver_table($table, $serveur);
+            if (isset($desc['field']['impt'])) {
+                sql_delete($table, "impt='oui'", $serveur);
+            } elseif ($desc) {
+                sql_delete($table, '', $serveur);
+            }
+        }
+    }
+
+    // sur le serveur principal, il ne faut pas supprimer l'auteur loge !
+    // Bidouille pour garder l'acces admin actuel pendant toute la restauration
+    if (
+        $serveur == ''
+        && in_array('spip_auteurs', $tables)
+        && !in_array('spip_auteurs', $exclure_tables)
+    ) {
+        base_conserver_copieur(true, $serveur);
+        sql_delete('spip_auteurs', 'id_auteur>0', $serveur);
+    }
 }
 
 /**
@@ -376,35 +376,35 @@ 
  * @return void
  */
 function base_conserver_copieur($move = true, $serveur = '') {
-	// s'asurer qu'on a pas deja fait la manip !
-	if ($GLOBALS['visiteur_session']['id_auteur'] > 0 && sql_countsel('spip_auteurs', 'id_auteur>0')) {
-		spip_logger('dump')->notice(
-			'Conserver copieur dans id_auteur=' . $GLOBALS['visiteur_session']['id_auteur'] . " pour le serveur '$serveur'",
-		);
-		sql_delete('spip_auteurs', 'id_auteur<0', $serveur);
-		if ($move) {
-			sql_updateq(
-				'spip_auteurs',
-				['id_auteur' => -$GLOBALS['visiteur_session']['id_auteur']],
-				'id_auteur=' . (int) $GLOBALS['visiteur_session']['id_auteur'],
-				[],
-				$serveur
-			);
-		} else {
-			$row = sql_fetsel(
-				'*',
-				'spip_auteurs',
-				'id_auteur=' . $GLOBALS['visiteur_session']['id_auteur'],
-				'',
-				'',
-				'',
-				'',
-				$serveur
-			);
-			$row['id_auteur'] = -$GLOBALS['visiteur_session']['id_auteur'];
-			sql_insertq('spip_auteurs', $row, [], $serveur);
-		}
-	}
+    // s'asurer qu'on a pas deja fait la manip !
+    if ($GLOBALS['visiteur_session']['id_auteur'] > 0 && sql_countsel('spip_auteurs', 'id_auteur>0')) {
+        spip_logger('dump')->notice(
+            'Conserver copieur dans id_auteur=' . $GLOBALS['visiteur_session']['id_auteur'] . " pour le serveur '$serveur'",
+        );
+        sql_delete('spip_auteurs', 'id_auteur<0', $serveur);
+        if ($move) {
+            sql_updateq(
+                'spip_auteurs',
+                ['id_auteur' => -$GLOBALS['visiteur_session']['id_auteur']],
+                'id_auteur=' . (int) $GLOBALS['visiteur_session']['id_auteur'],
+                [],
+                $serveur
+            );
+        } else {
+            $row = sql_fetsel(
+                '*',
+                'spip_auteurs',
+                'id_auteur=' . $GLOBALS['visiteur_session']['id_auteur'],
+                '',
+                '',
+                '',
+                '',
+                $serveur
+            );
+            $row['id_auteur'] = -$GLOBALS['visiteur_session']['id_auteur'];
+            sql_insertq('spip_auteurs', $row, [], $serveur);
+        }
+    }
 }
 
 /**
@@ -419,20 +419,20 @@ 
  * @param string $serveur
  */
 function base_detruire_copieur_si_besoin($serveur = '') {
-	// rien a faire si ce n'est pas le serveur principal !
-	if ($serveur == '') {
-		if (sql_countsel('spip_auteurs', 'id_auteur>0')) {
-			spip_logger('dump')->notice("Detruire copieur id_auteur<0 pour le serveur '$serveur'");
-			sql_delete('spip_auteurs', 'id_auteur<0', $serveur);
-		} else {
-			spip_logger('dump')->notice(
-				"Restaurer copieur id_auteur<0 pour le serveur '$serveur' (aucun autre auteur en base)",
-			);
-			sql_update('spip_auteurs', ['id_auteur' => '-id_auteur'], 'id_auteur<0');
-		}
-	} else {
-		spip_logger('dump')->notice("Pas de destruction copieur sur serveur '$serveur'");
-	}
+    // rien a faire si ce n'est pas le serveur principal !
+    if ($serveur == '') {
+        if (sql_countsel('spip_auteurs', 'id_auteur>0')) {
+            spip_logger('dump')->notice("Detruire copieur id_auteur<0 pour le serveur '$serveur'");
+            sql_delete('spip_auteurs', 'id_auteur<0', $serveur);
+        } else {
+            spip_logger('dump')->notice(
+                "Restaurer copieur id_auteur<0 pour le serveur '$serveur' (aucun autre auteur en base)",
+            );
+            sql_update('spip_auteurs', ['id_auteur' => '-id_auteur'], 'id_auteur<0');
+        }
+    } else {
+        spip_logger('dump')->notice("Pas de destruction copieur sur serveur '$serveur'");
+    }
 }
 
 /**
@@ -447,40 +447,40 @@ 
  * @return array
  */
 function base_preparer_table_dest($table, $desc, $serveur_dest, $init = false) {
-	$upgrade = false;
-	// si la table existe et qu'on est a l'init, la dropper
-	if (($desc_dest = sql_showtable($table, true, $serveur_dest)) && $init) {
-		if ($serveur_dest == '' && in_array($table, ['spip_meta', 'spip_auteurs'])) {
-			// ne pas dropper auteurs et meta sur le serveur principal
-			// faire un simple upgrade a la place
-			// pour ajouter les champs manquants
-			$upgrade = true;
-			// coherence avec le drop sur les autres tables
-			base_vider_tables_destination_copie([$table], [], $serveur_dest);
-			if ($table == 'spip_meta') {
-				// virer les version base qui vont venir avec l'import
-				sql_delete($table, "nom like '%_base_version'", $serveur_dest);
-				// hum casse la base si pas version_installee a l'import ...
-				sql_delete($table, "nom='version_installee'", $serveur_dest);
-			}
-		} else {
-			sql_drop_table($table, '', $serveur_dest);
-			spip_logger('dump')->notice("drop table '$table' sur serveur '$serveur_dest'");
-		}
-		$desc_dest = false;
-	}
-	// si la table n'existe pas dans la destination, la creer a l'identique !
-	if (!$desc_dest) {
-		spip_logger('dump')->notice("creation '$table' sur serveur '$serveur_dest'");
-		include_spip('base/create');
-		creer_ou_upgrader_table($table, $desc, 'auto', $upgrade, $serveur_dest);
-		$desc_dest = sql_showtable($table, true, $serveur_dest);
-	}
-	if (!$desc_dest) {
-		spip_logger('dump')->error("Erreur creation '$table' sur serveur '$serveur_dest'" . var_export($desc, 1));
-	}
-
-	return $desc_dest;
+    $upgrade = false;
+    // si la table existe et qu'on est a l'init, la dropper
+    if (($desc_dest = sql_showtable($table, true, $serveur_dest)) && $init) {
+        if ($serveur_dest == '' && in_array($table, ['spip_meta', 'spip_auteurs'])) {
+            // ne pas dropper auteurs et meta sur le serveur principal
+            // faire un simple upgrade a la place
+            // pour ajouter les champs manquants
+            $upgrade = true;
+            // coherence avec le drop sur les autres tables
+            base_vider_tables_destination_copie([$table], [], $serveur_dest);
+            if ($table == 'spip_meta') {
+                // virer les version base qui vont venir avec l'import
+                sql_delete($table, "nom like '%_base_version'", $serveur_dest);
+                // hum casse la base si pas version_installee a l'import ...
+                sql_delete($table, "nom='version_installee'", $serveur_dest);
+            }
+        } else {
+            sql_drop_table($table, '', $serveur_dest);
+            spip_logger('dump')->notice("drop table '$table' sur serveur '$serveur_dest'");
+        }
+        $desc_dest = false;
+    }
+    // si la table n'existe pas dans la destination, la creer a l'identique !
+    if (!$desc_dest) {
+        spip_logger('dump')->notice("creation '$table' sur serveur '$serveur_dest'");
+        include_spip('base/create');
+        creer_ou_upgrader_table($table, $desc, 'auto', $upgrade, $serveur_dest);
+        $desc_dest = sql_showtable($table, true, $serveur_dest);
+    }
+    if (!$desc_dest) {
+        spip_logger('dump')->error("Erreur creation '$table' sur serveur '$serveur_dest'" . var_export($desc, 1));
+    }
+
+    return $desc_dest;
 }
 
 /**
@@ -526,210 +526,210 @@ 
  */
 function base_copier_tables($status_file, $tables, $serveur_source, $serveur_dest, $options = []) {
 
-	$status = [];
-	$callback_progression = $options['callback_progression'] ?? '';
-	$max_time = $options['max_time'] ?? 0;
-	$drop_source = $options['drop_source'] ?? false;
-	$no_erase_dest = $options['no_erase_dest'] ?? [];
-	$where = $options['where'] ?? [];
-	$fonction_base_inserer = $options['fonction_base_inserer'] ?? 'inserer_copie';
-	$desc_tables_dest = $options['desc_tables_dest'] ?? [];
-	$racine_fonctions = $options['racine_fonctions_dest'] ?? 'base';
-	$data_pool = $options['data_pool'] ?? 50 * 1024;
-
-	$logger = spip_logger('dump');
-
-	$logger->notice(
-		'Copier ' . count($tables) . " tables de '$serveur_source' vers '$serveur_dest'",
-	);
-
-	if (!$inserer_copie = charger_fonction($fonction_base_inserer, $racine_fonctions, true)) {
-		$logger->notice("Fonction '{$racine_fonctions}_$fonction_base_inserer' inconnue. Abandon");
-
-		return true; // echec mais on a fini, donc true
-	}
-	if (!$preparer_table_dest = charger_fonction('preparer_table_dest', $racine_fonctions, true)) {
-		$logger->notice("Fonction '{$racine_fonctions}_$preparer_table_dest' inconnue. Abandon");
-
-		return true; // echec mais on a fini, donc true
-	}
-
-	if (
-		!lire_fichier($status_file, $status)
-		|| !($status = unserialize($status))
-	) {
-		$status = [];
-	}
-	$status['etape'] = 'basecopie';
-
-	// puis relister les tables a importer
-	// et les vider si besoin, au moment du premier passage ici
-	$initialisation_copie = $status['dump_status_copie'] ?? 0;
-
-	// si init pas encore faite, vider les tables du serveur destination
-	if (!$initialisation_copie) {
-		if (
-			!$vider_tables_destination_copie = charger_fonction(
-				'vider_tables_destination_copie',
-				$racine_fonctions,
-				true
-			)
-		) {
-			$logger->notice(
-				"Fonction '{$racine_fonctions}_vider_tables_destination_copie' inconnue. Abandon",
-			);
-
-			return true; // echec mais on a fini, donc true
-		}
-		$vider_tables_destination_copie($tables, $no_erase_dest, $serveur_dest);
-		$status['dump_status_copie'] = 'ok';
-		ecrire_fichier($status_file, serialize($status));
-	}
-
-	// les tables auteurs et meta doivent etre copiees en dernier !
-	if (in_array('spip_auteurs', $tables)) {
-		$tables = array_diff($tables, ['spip_auteurs']);
-		$tables[] = 'spip_auteurs';
-	}
-	if (in_array('spip_meta', $tables)) {
-		$tables = array_diff($tables, ['spip_meta']);
-		$tables[] = 'spip_meta';
-	}
-	$logger->info('Tables a copier :' . implode(', ', $tables));
-
-	$trouver_table = charger_fonction('trouver_table', 'base');
-
-	foreach ($tables as $table) {
-		// si table commence par spip_ c'est une table SPIP, renommer le prefixe si besoin
-		// sinon chercher la vraie table
-		$desc_source = false;
-		if (str_starts_with((string) $table, 'spip_')) {
-			$desc_source = $trouver_table(preg_replace(',^spip_,', '', (string) $table), $serveur_source, true);
-		}
-		if (!$desc_source || !isset($desc_source['exist']) || !$desc_source['exist']) {
-			$desc_source = $trouver_table($table, $serveur_source, false);
-		}
-
-		// verifier que la table est presente dans la base source
-		if ($desc_source) {
-			// $status['tables_copiees'][$table] contient l'avancement
-			// de la copie pour la $table : 0 a N et -N quand elle est finie (-1 si vide et finie...)
-			if (!isset($status['tables_copiees'][$table])) {
-				$status['tables_copiees'][$table] = 0;
-			}
-
-			if (
-				is_numeric($status['tables_copiees'][$table])
-				&& $status['tables_copiees'][$table] >= 0
-				&& ($desc_dest = $preparer_table_dest(
-					$table,
-					$desc_tables_dest[$table] ?? $desc_source,
-					$serveur_dest,
-					$status['tables_copiees'][$table] == 0
-				))
-			) {
-				if ($callback_progression) {
-					$callback_progression($status['tables_copiees'][$table], 0, $table);
-				}
-				while (true) {
-					$n = (int) $status['tables_copiees'][$table];
-					// on copie par lot de 400
-					$res = sql_select(
-						'*',
-						$table,
-						$where[$table] ?? '',
-						'',
-						'',
-						"$n,400",
-						'',
-						$serveur_source
-					);
-					while ($row = sql_fetch($res, $serveur_source)) {
-						$rows = [$row];
-						// lire un groupe de donnees si demande en option
-						// (permet un envoi par lot vers la destination)
-						if ($data_pool > 0) {
-							$s = strlen(serialize($row));
-							while ($s < $data_pool && ($row = sql_fetch($res, $serveur_source))) {
-								$s += strlen(serialize($row));
-								$rows[] = $row;
-							}
-						}
-						// si l'enregistrement est deja en base, ca fera un echec ou un doublon
-						// mais si ca renvoie false c'est une erreur fatale => abandon
-						if ($inserer_copie($table, $rows, $desc_dest, $serveur_dest) === false) {
-							// forcer la sortie, charge a l'appelant de gerer l'echec
-							$logger->error("Erreur fatale dans $inserer_copie table $table");
-							$status['errors'][] = "Erreur fatale  lors de la copie de la table $table";
-							ecrire_fichier($status_file, serialize($status));
-
-							// copie finie
-							return true;
-						}
-						$status['tables_copiees'][$table] += count($rows);
-						if ($max_time && time() > $max_time) {
-							break;
-						}
-					}
-					if ($n == $status['tables_copiees'][$table]) {
-						break;
-					}
-					$logger->notice("recopie $table " . $status['tables_copiees'][$table]);
-					if ($callback_progression) {
-						$callback_progression($status['tables_copiees'][$table], 0, $table);
-					}
-					ecrire_fichier($status_file, serialize($status));
-					if ($max_time && time() > $max_time) {
-						return false;
-					} // on a pas fini, mais le temps imparti est ecoule
-				}
-				if ($drop_source) {
-					sql_drop_table($table, '', $serveur_source);
-					$logger->notice("drop $table sur serveur source '$serveur_source'");
-				}
-				$status['tables_copiees'][$table] = ($status['tables_copiees'][$table] ? -$status['tables_copiees'][$table] : 'zero');
-				ecrire_fichier($status_file, serialize($status));
-				$logger->info('tables_recopiees ' . implode(',', array_keys($status['tables_copiees'])));
-				if ($callback_progression) {
-					$callback_progression($status['tables_copiees'][$table], $status['tables_copiees'][$table], $table);
-				}
-			} else {
-				if ($status['tables_copiees'][$table] < 0) {
-					$logger->info("Table $table deja copiee : " . $status['tables_copiees'][$table]);
-				}
-				if ($callback_progression) {
-					$callback_progression(
-						0,
-						$status['tables_copiees'][$table],
-						"$table" . ((is_numeric($status['tables_copiees'][$table]) && $status['tables_copiees'][$table] >= 0) ? '[Echec]' : '')
-					);
-				}
-			}
-		} else {
-			$status['errors'][] = "Impossible de lire la description de la table $table";
-			ecrire_fichier($status_file, serialize($status));
-			$logger->error("Impossible de lire la description de la table $table");
-		}
-	}
-
-	// si le nombre de tables envoyees n'est pas egal au nombre de tables demandees
-	// abandonner
-	if ((is_countable($status['tables_copiees']) ? count($status['tables_copiees']) : 0) < count($tables)) {
-		$logger->error(
-			'Nombre de tables copiees incorrect : ' . (is_countable($status['tables_copiees']) ? count($status['tables_copiees']) : 0) . '/' . count($tables),
-		);
-		$status['errors'][] = 'Nombre de tables copiees incorrect : ' . (is_countable($status['tables_copiees']) ? count($status['tables_copiees']) : 0) . '/' . count($tables);
-		ecrire_fichier($status_file, serialize($status));
-	}
-
-	if ($detruire_copieur_si_besoin = charger_fonction('detruire_copieur_si_besoin', $racine_fonctions, true)) {
-		$detruire_copieur_si_besoin($serveur_dest);
-	} else {
-		$logger->notice("Fonction '{$racine_fonctions}_detruire_copieur_si_besoin' inconnue.");
-	}
-
-	// OK, copie complete
-	return true;
+    $status = [];
+    $callback_progression = $options['callback_progression'] ?? '';
+    $max_time = $options['max_time'] ?? 0;
+    $drop_source = $options['drop_source'] ?? false;
+    $no_erase_dest = $options['no_erase_dest'] ?? [];
+    $where = $options['where'] ?? [];
+    $fonction_base_inserer = $options['fonction_base_inserer'] ?? 'inserer_copie';
+    $desc_tables_dest = $options['desc_tables_dest'] ?? [];
+    $racine_fonctions = $options['racine_fonctions_dest'] ?? 'base';
+    $data_pool = $options['data_pool'] ?? 50 * 1024;
+
+    $logger = spip_logger('dump');
+
+    $logger->notice(
+        'Copier ' . count($tables) . " tables de '$serveur_source' vers '$serveur_dest'",
+    );
+
+    if (!$inserer_copie = charger_fonction($fonction_base_inserer, $racine_fonctions, true)) {
+        $logger->notice("Fonction '{$racine_fonctions}_$fonction_base_inserer' inconnue. Abandon");
+
+        return true; // echec mais on a fini, donc true
+    }
+    if (!$preparer_table_dest = charger_fonction('preparer_table_dest', $racine_fonctions, true)) {
+        $logger->notice("Fonction '{$racine_fonctions}_$preparer_table_dest' inconnue. Abandon");
+
+        return true; // echec mais on a fini, donc true
+    }
+
+    if (
+        !lire_fichier($status_file, $status)
+        || !($status = unserialize($status))
+    ) {
+        $status = [];
+    }
+    $status['etape'] = 'basecopie';
+
+    // puis relister les tables a importer
+    // et les vider si besoin, au moment du premier passage ici
+    $initialisation_copie = $status['dump_status_copie'] ?? 0;
+
+    // si init pas encore faite, vider les tables du serveur destination
+    if (!$initialisation_copie) {
+        if (
+            !$vider_tables_destination_copie = charger_fonction(
+                'vider_tables_destination_copie',
+                $racine_fonctions,
+                true
+            )
+        ) {
+            $logger->notice(
+                "Fonction '{$racine_fonctions}_vider_tables_destination_copie' inconnue. Abandon",
+            );
+
+            return true; // echec mais on a fini, donc true
+        }
+        $vider_tables_destination_copie($tables, $no_erase_dest, $serveur_dest);
+        $status['dump_status_copie'] = 'ok';
+        ecrire_fichier($status_file, serialize($status));
+    }
+
+    // les tables auteurs et meta doivent etre copiees en dernier !
+    if (in_array('spip_auteurs', $tables)) {
+        $tables = array_diff($tables, ['spip_auteurs']);
+        $tables[] = 'spip_auteurs';
+    }
+    if (in_array('spip_meta', $tables)) {
+        $tables = array_diff($tables, ['spip_meta']);
+        $tables[] = 'spip_meta';
+    }
+    $logger->info('Tables a copier :' . implode(', ', $tables));
+
+    $trouver_table = charger_fonction('trouver_table', 'base');
+
+    foreach ($tables as $table) {
+        // si table commence par spip_ c'est une table SPIP, renommer le prefixe si besoin
+        // sinon chercher la vraie table
+        $desc_source = false;
+        if (str_starts_with((string) $table, 'spip_')) {
+            $desc_source = $trouver_table(preg_replace(',^spip_,', '', (string) $table), $serveur_source, true);
+        }
+        if (!$desc_source || !isset($desc_source['exist']) || !$desc_source['exist']) {
+            $desc_source = $trouver_table($table, $serveur_source, false);
+        }
+
+        // verifier que la table est presente dans la base source
+        if ($desc_source) {
+            // $status['tables_copiees'][$table] contient l'avancement
+            // de la copie pour la $table : 0 a N et -N quand elle est finie (-1 si vide et finie...)
+            if (!isset($status['tables_copiees'][$table])) {
+                $status['tables_copiees'][$table] = 0;
+            }
+
+            if (
+                is_numeric($status['tables_copiees'][$table])
+                && $status['tables_copiees'][$table] >= 0
+                && ($desc_dest = $preparer_table_dest(
+                    $table,
+                    $desc_tables_dest[$table] ?? $desc_source,
+                    $serveur_dest,
+                    $status['tables_copiees'][$table] == 0
+                ))
+            ) {
+                if ($callback_progression) {
+                    $callback_progression($status['tables_copiees'][$table], 0, $table);
+                }
+                while (true) {
+                    $n = (int) $status['tables_copiees'][$table];
+                    // on copie par lot de 400
+                    $res = sql_select(
+                        '*',
+                        $table,
+                        $where[$table] ?? '',
+                        '',
+                        '',
+                        "$n,400",
+                        '',
+                        $serveur_source
+                    );
+                    while ($row = sql_fetch($res, $serveur_source)) {
+                        $rows = [$row];
+                        // lire un groupe de donnees si demande en option
+                        // (permet un envoi par lot vers la destination)
+                        if ($data_pool > 0) {
+                            $s = strlen(serialize($row));
+                            while ($s < $data_pool && ($row = sql_fetch($res, $serveur_source))) {
+                                $s += strlen(serialize($row));
+                                $rows[] = $row;
+                            }
+                        }
+                        // si l'enregistrement est deja en base, ca fera un echec ou un doublon
+                        // mais si ca renvoie false c'est une erreur fatale => abandon
+                        if ($inserer_copie($table, $rows, $desc_dest, $serveur_dest) === false) {
+                            // forcer la sortie, charge a l'appelant de gerer l'echec
+                            $logger->error("Erreur fatale dans $inserer_copie table $table");
+                            $status['errors'][] = "Erreur fatale  lors de la copie de la table $table";
+                            ecrire_fichier($status_file, serialize($status));
+
+                            // copie finie
+                            return true;
+                        }
+                        $status['tables_copiees'][$table] += count($rows);
+                        if ($max_time && time() > $max_time) {
+                            break;
+                        }
+                    }
+                    if ($n == $status['tables_copiees'][$table]) {
+                        break;
+                    }
+                    $logger->notice("recopie $table " . $status['tables_copiees'][$table]);
+                    if ($callback_progression) {
+                        $callback_progression($status['tables_copiees'][$table], 0, $table);
+                    }
+                    ecrire_fichier($status_file, serialize($status));
+                    if ($max_time && time() > $max_time) {
+                        return false;
+                    } // on a pas fini, mais le temps imparti est ecoule
+                }
+                if ($drop_source) {
+                    sql_drop_table($table, '', $serveur_source);
+                    $logger->notice("drop $table sur serveur source '$serveur_source'");
+                }
+                $status['tables_copiees'][$table] = ($status['tables_copiees'][$table] ? -$status['tables_copiees'][$table] : 'zero');
+                ecrire_fichier($status_file, serialize($status));
+                $logger->info('tables_recopiees ' . implode(',', array_keys($status['tables_copiees'])));
+                if ($callback_progression) {
+                    $callback_progression($status['tables_copiees'][$table], $status['tables_copiees'][$table], $table);
+                }
+            } else {
+                if ($status['tables_copiees'][$table] < 0) {
+                    $logger->info("Table $table deja copiee : " . $status['tables_copiees'][$table]);
+                }
+                if ($callback_progression) {
+                    $callback_progression(
+                        0,
+                        $status['tables_copiees'][$table],
+                        "$table" . ((is_numeric($status['tables_copiees'][$table]) && $status['tables_copiees'][$table] >= 0) ? '[Echec]' : '')
+                    );
+                }
+            }
+        } else {
+            $status['errors'][] = "Impossible de lire la description de la table $table";
+            ecrire_fichier($status_file, serialize($status));
+            $logger->error("Impossible de lire la description de la table $table");
+        }
+    }
+
+    // si le nombre de tables envoyees n'est pas egal au nombre de tables demandees
+    // abandonner
+    if ((is_countable($status['tables_copiees']) ? count($status['tables_copiees']) : 0) < count($tables)) {
+        $logger->error(
+            'Nombre de tables copiees incorrect : ' . (is_countable($status['tables_copiees']) ? count($status['tables_copiees']) : 0) . '/' . count($tables),
+        );
+        $status['errors'][] = 'Nombre de tables copiees incorrect : ' . (is_countable($status['tables_copiees']) ? count($status['tables_copiees']) : 0) . '/' . count($tables);
+        ecrire_fichier($status_file, serialize($status));
+    }
+
+    if ($detruire_copieur_si_besoin = charger_fonction('detruire_copieur_si_besoin', $racine_fonctions, true)) {
+        $detruire_copieur_si_besoin($serveur_dest);
+    } else {
+        $logger->notice("Fonction '{$racine_fonctions}_detruire_copieur_si_besoin' inconnue.");
+    }
+
+    // OK, copie complete
+    return true;
 }
 
 /**
@@ -743,29 +743,29 @@ 
  */
 function base_inserer_copie($table, $rows, $desc_dest, $serveur_dest) {
 
-	// verifier le nombre d'insertion
-	$nb1 = sql_countsel($table, '', '', '', $serveur_dest);
-	// si l'enregistrement est deja en base, ca fera un echec ou un doublon
-	$r = sql_insertq_multi($table, $rows, $desc_dest, $serveur_dest);
-	$nb = sql_countsel($table, '', '', '', $serveur_dest);
-	if ($nb - $nb1 < count($rows)) {
-		spip_logger('dump')->notice(
-			'base_inserer_copie : ' . ($nb - $nb1) . ' insertions au lieu de ' . count($rows) . '. On retente 1 par 1',
-		);
-		foreach ($rows as $row) {
-			// si l'enregistrement est deja en base, ca fera un echec ou un doublon
-			$r = sql_insertq($table, $row, $desc_dest, $serveur_dest);
-		}
-		// on reverifie le total
-		$r = 0;
-		$nb = sql_countsel($table, '', '', '', $serveur_dest);
-		if ($nb - $nb1 < count($rows)) {
-			spip_logger('dump')->error(
-				'base_inserer_copie : ' . ($nb - $nb1) . ' insertions au lieu de ' . count($rows) . ' apres insertion 1 par 1',
-			);
-			$r = false;
-		}
-	}
-
-	return $r;
+    // verifier le nombre d'insertion
+    $nb1 = sql_countsel($table, '', '', '', $serveur_dest);
+    // si l'enregistrement est deja en base, ca fera un echec ou un doublon
+    $r = sql_insertq_multi($table, $rows, $desc_dest, $serveur_dest);
+    $nb = sql_countsel($table, '', '', '', $serveur_dest);
+    if ($nb - $nb1 < count($rows)) {
+        spip_logger('dump')->notice(
+            'base_inserer_copie : ' . ($nb - $nb1) . ' insertions au lieu de ' . count($rows) . '. On retente 1 par 1',
+        );
+        foreach ($rows as $row) {
+            // si l'enregistrement est deja en base, ca fera un echec ou un doublon
+            $r = sql_insertq($table, $row, $desc_dest, $serveur_dest);
+        }
+        // on reverifie le total
+        $r = 0;
+        $nb = sql_countsel($table, '', '', '', $serveur_dest);
+        if ($nb - $nb1 < count($rows)) {
+            spip_logger('dump')->error(
+                'base_inserer_copie : ' . ($nb - $nb1) . ' insertions au lieu de ' . count($rows) . ' apres insertion 1 par 1',
+            );
+            $r = false;
+        }
+    }
+
+    return $r;
 }

Spacing +17 added lines, -17 removed lines

@@ -37,7 +37,7 @@ 
  * @return string
  **/
 function base_dump_meta_name($rub) {
-	return $meta = "status_dump_{$rub}_" . abs($GLOBALS['visiteur_session']['id_auteur']);
+	return $meta = "status_dump_{$rub}_".abs($GLOBALS['visiteur_session']['id_auteur']);
 }
 
 /**
@@ -82,7 +82,7 @@ 
 	$connexion = $GLOBALS['connexions'][$serveur ?: 0];
 	$prefixe = $connexion['prefixe'];
 
-	$p = '/^' . $prefixe . '/';
+	$p = '/^'.$prefixe.'/';
 	$res = $tables;
 	foreach (sql_alltable(null, $serveur) as $t) {
 		if (preg_match($p, (string) $t)) {
@@ -341,7 +341,7 @@ 
 	$trouver_table = charger_fonction('trouver_table', 'base');
 
 	spip_logger('base')->notice(
-		'Vider ' . count($tables) . " tables sur serveur '$serveur' : " . implode(', ', $tables),
+		'Vider '.count($tables)." tables sur serveur '$serveur' : ".implode(', ', $tables),
 	);
 	foreach ($tables as $table) {
 		// sur le serveur principal, il ne faut pas supprimer l'auteur loge !
@@ -379,14 +379,14 @@ 
 	// s'asurer qu'on a pas deja fait la manip !
 	if ($GLOBALS['visiteur_session']['id_auteur'] > 0 && sql_countsel('spip_auteurs', 'id_auteur>0')) {
 		spip_logger('dump')->notice(
-			'Conserver copieur dans id_auteur=' . $GLOBALS['visiteur_session']['id_auteur'] . " pour le serveur '$serveur'",
+			'Conserver copieur dans id_auteur='.$GLOBALS['visiteur_session']['id_auteur']." pour le serveur '$serveur'",
 		);
 		sql_delete('spip_auteurs', 'id_auteur<0', $serveur);
 		if ($move) {
 			sql_updateq(
 				'spip_auteurs',
 				['id_auteur' => -$GLOBALS['visiteur_session']['id_auteur']],
-				'id_auteur=' . (int) $GLOBALS['visiteur_session']['id_auteur'],
+				'id_auteur='.(int) $GLOBALS['visiteur_session']['id_auteur'],
 				[],
 				$serveur
 			);
@@ -394,7 +394,7 @@ 
 			$row = sql_fetsel(
 				'*',
 				'spip_auteurs',
-				'id_auteur=' . $GLOBALS['visiteur_session']['id_auteur'],
+				'id_auteur='.$GLOBALS['visiteur_session']['id_auteur'],
 				'',
 				'',
 				'',
@@ -477,7 +477,7 @@ 
 		$desc_dest = sql_showtable($table, true, $serveur_dest);
 	}
 	if (!$desc_dest) {
-		spip_logger('dump')->error("Erreur creation '$table' sur serveur '$serveur_dest'" . var_export($desc, 1));
+		spip_logger('dump')->error("Erreur creation '$table' sur serveur '$serveur_dest'".var_export($desc, 1));
 	}
 
 	return $desc_dest;
@@ -540,7 +540,7 @@ 
 	$logger = spip_logger('dump');
 
 	$logger->notice(
-		'Copier ' . count($tables) . " tables de '$serveur_source' vers '$serveur_dest'",
+		'Copier '.count($tables)." tables de '$serveur_source' vers '$serveur_dest'",
 	);
 
 	if (!$inserer_copie = charger_fonction($fonction_base_inserer, $racine_fonctions, true)) {
@@ -595,7 +595,7 @@ 
 		$tables = array_diff($tables, ['spip_meta']);
 		$tables[] = 'spip_meta';
 	}
-	$logger->info('Tables a copier :' . implode(', ', $tables));
+	$logger->info('Tables a copier :'.implode(', ', $tables));
 
 	$trouver_table = charger_fonction('trouver_table', 'base');
 
@@ -674,7 +674,7 @@ 
 					if ($n == $status['tables_copiees'][$table]) {
 						break;
 					}
-					$logger->notice("recopie $table " . $status['tables_copiees'][$table]);
+					$logger->notice("recopie $table ".$status['tables_copiees'][$table]);
 					if ($callback_progression) {
 						$callback_progression($status['tables_copiees'][$table], 0, $table);
 					}
@@ -689,19 +689,19 @@ 
 				}
 				$status['tables_copiees'][$table] = ($status['tables_copiees'][$table] ? -$status['tables_copiees'][$table] : 'zero');
 				ecrire_fichier($status_file, serialize($status));
-				$logger->info('tables_recopiees ' . implode(',', array_keys($status['tables_copiees'])));
+				$logger->info('tables_recopiees '.implode(',', array_keys($status['tables_copiees'])));
 				if ($callback_progression) {
 					$callback_progression($status['tables_copiees'][$table], $status['tables_copiees'][$table], $table);
 				}
 			} else {
 				if ($status['tables_copiees'][$table] < 0) {
-					$logger->info("Table $table deja copiee : " . $status['tables_copiees'][$table]);
+					$logger->info("Table $table deja copiee : ".$status['tables_copiees'][$table]);
 				}
 				if ($callback_progression) {
 					$callback_progression(
 						0,
 						$status['tables_copiees'][$table],
-						"$table" . ((is_numeric($status['tables_copiees'][$table]) && $status['tables_copiees'][$table] >= 0) ? '[Echec]' : '')
+						"$table".((is_numeric($status['tables_copiees'][$table]) && $status['tables_copiees'][$table] >= 0) ? '[Echec]' : '')
 					);
 				}
 			}
@@ -716,9 +716,9 @@ 
 	// abandonner
 	if ((is_countable($status['tables_copiees']) ? count($status['tables_copiees']) : 0) < count($tables)) {
 		$logger->error(
-			'Nombre de tables copiees incorrect : ' . (is_countable($status['tables_copiees']) ? count($status['tables_copiees']) : 0) . '/' . count($tables),
+			'Nombre de tables copiees incorrect : '.(is_countable($status['tables_copiees']) ? count($status['tables_copiees']) : 0).'/'.count($tables),
 		);
-		$status['errors'][] = 'Nombre de tables copiees incorrect : ' . (is_countable($status['tables_copiees']) ? count($status['tables_copiees']) : 0) . '/' . count($tables);
+		$status['errors'][] = 'Nombre de tables copiees incorrect : '.(is_countable($status['tables_copiees']) ? count($status['tables_copiees']) : 0).'/'.count($tables);
 		ecrire_fichier($status_file, serialize($status));
 	}
 
@@ -750,7 +750,7 @@ 
 	$nb = sql_countsel($table, '', '', '', $serveur_dest);
 	if ($nb - $nb1 < count($rows)) {
 		spip_logger('dump')->notice(
-			'base_inserer_copie : ' . ($nb - $nb1) . ' insertions au lieu de ' . count($rows) . '. On retente 1 par 1',
+			'base_inserer_copie : '.($nb - $nb1).' insertions au lieu de '.count($rows).'. On retente 1 par 1',
 		);
 		foreach ($rows as $row) {
 			// si l'enregistrement est deja en base, ca fera un echec ou un doublon
@@ -761,7 +761,7 @@ 
 		$nb = sql_countsel($table, '', '', '', $serveur_dest);
 		if ($nb - $nb1 < count($rows)) {
 			spip_logger('dump')->error(
-				'base_inserer_copie : ' . ($nb - $nb1) . ' insertions au lieu de ' . count($rows) . ' apres insertion 1 par 1',
+				'base_inserer_copie : '.($nb - $nb1).' insertions au lieu de '.count($rows).' apres insertion 1 par 1',
 			);
 			$r = false;
 		}

ecrire/base/upgrade.php

Indentation +279 added lines, -279 removed lines

@@ -16,17 +16,17 @@ 
  */
 
 if (!defined('_ECRIRE_INC_VERSION')) {
-	return;
+    return;
 }
 
 if (!defined('_UPGRADE_TIME_OUT')) {
-	/**
-	 * Durée en secondes pour relancer les scripts de mises à jour, x secondes
-	 * avant que la durée d'exécution du script provoque un timeout
-	 *
-	 * @var int
-	 **/
-	define('_UPGRADE_TIME_OUT', 20);
+    /**
+     * Durée en secondes pour relancer les scripts de mises à jour, x secondes
+     * avant que la durée d'exécution du script provoque un timeout
+     *
+     * @var int
+     **/
+    define('_UPGRADE_TIME_OUT', 20);
 }
 
 /**
@@ -49,40 +49,40 @@ 
  * @return void
  */
 function base_upgrade_dist($titre = '', $reprise = '') {
-	if (!$titre) {
-		return;
-	} // anti-testeur automatique
-	if ($GLOBALS['spip_version_base'] != $GLOBALS['meta']['version_installee']) {
-		if (!is_numeric(_request('reinstall'))) {
-			include_spip('base/create');
-			spip_logger('maj')->notice('recree les tables eventuellement disparues');
-			creer_base();
-		}
-
-		// quand on rentre par ici, c'est toujours une mise a jour de SPIP
-		// lancement de l'upgrade SPIP
-		$res = maj_base();
-
-		if ($res) {
-			// on arrete tout ici !
-			exit;
-		}
-	}
-	spip_logger('maj')->notice('Fin de mise a jour SQL. Debut m-a-j acces et config');
-
-	// supprimer quelques fichiers temporaires qui peuvent se retrouver invalides
-	@spip_unlink(_CACHE_RUBRIQUES);
-	@spip_unlink(_CACHE_PIPELINES);
-	@spip_unlink(_CACHE_PLUGINS_PATH);
-	@spip_unlink(_CACHE_PLUGINS_OPT);
-	@spip_unlink(_CACHE_PLUGINS_FCT);
-	@spip_unlink(_CACHE_CHEMIN);
-	@spip_unlink(_DIR_TMP . 'plugin_xml_cache.gz');
-
-	include_spip('inc/auth');
-	auth_synchroniser_distant();
-	$config = charger_fonction('config', 'inc');
-	$config();
+    if (!$titre) {
+        return;
+    } // anti-testeur automatique
+    if ($GLOBALS['spip_version_base'] != $GLOBALS['meta']['version_installee']) {
+        if (!is_numeric(_request('reinstall'))) {
+            include_spip('base/create');
+            spip_logger('maj')->notice('recree les tables eventuellement disparues');
+            creer_base();
+        }
+
+        // quand on rentre par ici, c'est toujours une mise a jour de SPIP
+        // lancement de l'upgrade SPIP
+        $res = maj_base();
+
+        if ($res) {
+            // on arrete tout ici !
+            exit;
+        }
+    }
+    spip_logger('maj')->notice('Fin de mise a jour SQL. Debut m-a-j acces et config');
+
+    // supprimer quelques fichiers temporaires qui peuvent se retrouver invalides
+    @spip_unlink(_CACHE_RUBRIQUES);
+    @spip_unlink(_CACHE_PIPELINES);
+    @spip_unlink(_CACHE_PLUGINS_PATH);
+    @spip_unlink(_CACHE_PLUGINS_OPT);
+    @spip_unlink(_CACHE_PLUGINS_FCT);
+    @spip_unlink(_CACHE_CHEMIN);
+    @spip_unlink(_DIR_TMP . 'plugin_xml_cache.gz');
+
+    include_spip('inc/auth');
+    auth_synchroniser_distant();
+    $config = charger_fonction('config', 'inc');
+    $config();
 }
 
 /**
@@ -113,46 +113,46 @@ 
  */
 function maj_base($version_cible = 0, $redirect = '', $debut_page = true) {
 
-	$version_installee = $GLOBALS['meta']['version_installee'] ?? null;
-
-	spip_logger('maj')->notice(
-		"Version anterieure: $version_installee. Courante: " . $GLOBALS['spip_version_base'],
-	);
-	if (!$version_installee || $GLOBALS['spip_version_base'] < $version_installee) {
-		sql_replace(
-			'spip_meta',
-			[
-				'nom' => 'version_installee',
-				'valeur' => $GLOBALS['spip_version_base'],
-				'impt' => 'non'
-			]
-		);
-		return false;
-	}
-	if (!upgrade_test()) {
-		return true;
-	}
-
-	$cible = ($version_cible ?: $GLOBALS['spip_version_base']);
-
-	if ($version_installee < 2021_01_01_00) {
-		include_spip('maj/legacy/v40');
-	}
-
-	include_spip('maj/2021');
-
-	ksort($GLOBALS['maj']);
-	$res = maj_while($version_installee, $cible, $GLOBALS['maj'], 'version_installee', 'meta', $redirect, $debut_page);
-	if ($res) {
-		if (!is_array($res)) {
-			spip_logger('maj')->error("Pb d'acces SQL a la mise a jour");
-		} else {
-			echo _T('avis_operation_echec') . ' ' . implode(' ', $res);
-			echo install_fin_html();
-		}
-	}
-
-	return $res;
+    $version_installee = $GLOBALS['meta']['version_installee'] ?? null;
+
+    spip_logger('maj')->notice(
+        "Version anterieure: $version_installee. Courante: " . $GLOBALS['spip_version_base'],
+    );
+    if (!$version_installee || $GLOBALS['spip_version_base'] < $version_installee) {
+        sql_replace(
+            'spip_meta',
+            [
+                'nom' => 'version_installee',
+                'valeur' => $GLOBALS['spip_version_base'],
+                'impt' => 'non'
+            ]
+        );
+        return false;
+    }
+    if (!upgrade_test()) {
+        return true;
+    }
+
+    $cible = ($version_cible ?: $GLOBALS['spip_version_base']);
+
+    if ($version_installee < 2021_01_01_00) {
+        include_spip('maj/legacy/v40');
+    }
+
+    include_spip('maj/2021');
+
+    ksort($GLOBALS['maj']);
+    $res = maj_while($version_installee, $cible, $GLOBALS['maj'], 'version_installee', 'meta', $redirect, $debut_page);
+    if ($res) {
+        if (!is_array($res)) {
+            spip_logger('maj')->error("Pb d'acces SQL a la mise a jour");
+        } else {
+            echo _T('avis_operation_echec') . ' ' . implode(' ', $res);
+            echo install_fin_html();
+        }
+    }
+
+    return $res;
 }
 
 /**
@@ -194,53 +194,53 @@ 
  */
 function maj_plugin($nom_meta_base_version, $version_cible, $maj, $table_meta = 'meta') {
 
-	if ($table_meta !== 'meta') {
-		installer_table_meta($table_meta);
-	}
-
-	$current_version = null;
-
-	if (
-		(!isset($GLOBALS[$table_meta][$nom_meta_base_version]))
-		|| (!spip_version_compare($current_version = $GLOBALS[$table_meta][$nom_meta_base_version], $version_cible, '='))
-	) {
-		// $maj['create'] contient les directives propres a la premiere creation de base
-		// c'est une operation derogatoire qui fait aboutir directement dans la version_cible
-		if (isset($maj['create'])) {
-			if (!isset($GLOBALS[$table_meta][$nom_meta_base_version])) {
-				// installation : on ne fait que l'operation create
-				$maj = ['init' => $maj['create']];
-				// et on lui ajoute un appel a inc/config
-				// pour creer les metas par defaut
-				$config = charger_fonction('config', 'inc');
-				$maj[$version_cible] = [[$config]];
-			}
-			// dans tous les cas enlever cet index du tableau
-			unset($maj['create']);
-		}
-		// si init, deja dans le bon ordre
-		if (!isset($maj['init'])) {
-			include_spip('inc/plugin'); // pour spip_version_compare
-			uksort($maj, 'spip_version_compare');
-		}
-
-		// la redirection se fait par defaut sur la page d'administration des plugins
-		// sauf lorsque nous sommes sur l'installation de SPIP
-		// ou define _REDIRECT_MAJ_PLUGIN
-		$redirect = (defined('_REDIRECT_MAJ_PLUGIN') ? _REDIRECT_MAJ_PLUGIN : generer_url_ecrire('admin_plugin'));
-		if (defined('_ECRIRE_INSTALL')) {
-			$redirect = parametre_url(generer_url_ecrire('install'), 'etape', _request('etape'));
-		}
-
-		$res = maj_while($current_version, $version_cible, $maj, $nom_meta_base_version, $table_meta, $redirect);
-		if ($res) {
-			if (!is_array($res)) {
-				spip_logger('maj')->error("Pb d'acces SQL a la mise a jour");
-			} else {
-				echo '<p>' . _T('avis_operation_echec') . ' ' . implode(' ', $res) . '</p>';
-			}
-		}
-	}
+    if ($table_meta !== 'meta') {
+        installer_table_meta($table_meta);
+    }
+
+    $current_version = null;
+
+    if (
+        (!isset($GLOBALS[$table_meta][$nom_meta_base_version]))
+        || (!spip_version_compare($current_version = $GLOBALS[$table_meta][$nom_meta_base_version], $version_cible, '='))
+    ) {
+        // $maj['create'] contient les directives propres a la premiere creation de base
+        // c'est une operation derogatoire qui fait aboutir directement dans la version_cible
+        if (isset($maj['create'])) {
+            if (!isset($GLOBALS[$table_meta][$nom_meta_base_version])) {
+                // installation : on ne fait que l'operation create
+                $maj = ['init' => $maj['create']];
+                // et on lui ajoute un appel a inc/config
+                // pour creer les metas par defaut
+                $config = charger_fonction('config', 'inc');
+                $maj[$version_cible] = [[$config]];
+            }
+            // dans tous les cas enlever cet index du tableau
+            unset($maj['create']);
+        }
+        // si init, deja dans le bon ordre
+        if (!isset($maj['init'])) {
+            include_spip('inc/plugin'); // pour spip_version_compare
+            uksort($maj, 'spip_version_compare');
+        }
+
+        // la redirection se fait par defaut sur la page d'administration des plugins
+        // sauf lorsque nous sommes sur l'installation de SPIP
+        // ou define _REDIRECT_MAJ_PLUGIN
+        $redirect = (defined('_REDIRECT_MAJ_PLUGIN') ? _REDIRECT_MAJ_PLUGIN : generer_url_ecrire('admin_plugin'));
+        if (defined('_ECRIRE_INSTALL')) {
+            $redirect = parametre_url(generer_url_ecrire('install'), 'etape', _request('etape'));
+        }
+
+        $res = maj_while($current_version, $version_cible, $maj, $nom_meta_base_version, $table_meta, $redirect);
+        if ($res) {
+            if (!is_array($res)) {
+                spip_logger('maj')->error("Pb d'acces SQL a la mise a jour");
+            } else {
+                echo '<p>' . _T('avis_operation_echec') . ' ' . implode(' ', $res) . '</p>';
+            }
+        }
+    }
 }
 
 /**
@@ -257,17 +257,17 @@ 
  * @return void
  */
 function relance_maj($meta, $table, $redirect = '') {
-	include_spip('inc/headers');
-	if (!$redirect) {
-		// recuperer la valeur installee en cours
-		// on la tronque numeriquement, elle ne sert pas reellement
-		// sauf pour verifier que ce n'est pas oui ou non
-		// sinon is_numeric va echouer sur un numero de version 1.2.3
-		$installee = (int) $GLOBALS[$table][$meta];
-		$redirect = generer_url_ecrire('upgrade', "reinstall=$installee&meta=$meta&table=$table", true);
-	}
-	echo redirige_formulaire($redirect);
-	exit();
+    include_spip('inc/headers');
+    if (!$redirect) {
+        // recuperer la valeur installee en cours
+        // on la tronque numeriquement, elle ne sert pas reellement
+        // sauf pour verifier que ce n'est pas oui ou non
+        // sinon is_numeric va echouer sur un numero de version 1.2.3
+        $installee = (int) $GLOBALS[$table][$meta];
+        $redirect = generer_url_ecrire('upgrade', "reinstall=$installee&meta=$meta&table=$table", true);
+    }
+    echo redirige_formulaire($redirect);
+    exit();
 }
 
 /**
@@ -280,29 +280,29 @@ 
  * @return void
  */
 function maj_debut_page($installee, $meta, $table) {
-	static $done = false;
-	if ($done) {
-		return;
-	}
-	include_spip('inc/minipres');
-	include_spip('inc/filtres');
-	if (function_exists('ini_set')) {
-		@ini_set('zlib.output_compression', '0'); // pour permettre l'affichage au fur et a mesure
-	}
-	$timeout = _UPGRADE_TIME_OUT * 2;
-	$titre = _T('titre_page_upgrade');
-	$balise_img = charger_filtre('balise_img');
-	$titre .= $balise_img(chemin_image('loader.svg'), '', 'loader');
-	echo(install_debut_html($titre));
-	// script de rechargement auto sur timeout
-	$redirect = generer_url_ecrire('upgrade', "reinstall=$installee&meta=$meta&table=$table", true);
-	echo http_script("window.setTimeout('location.href=\"" . $redirect . "\";'," . ($timeout * 1000) . ')');
-	echo "<div style='text-align: left'>\n";
-	if (ob_get_level()) {
-		ob_flush();
-	}
-	flush();
-	$done = true;
+    static $done = false;
+    if ($done) {
+        return;
+    }
+    include_spip('inc/minipres');
+    include_spip('inc/filtres');
+    if (function_exists('ini_set')) {
+        @ini_set('zlib.output_compression', '0'); // pour permettre l'affichage au fur et a mesure
+    }
+    $timeout = _UPGRADE_TIME_OUT * 2;
+    $titre = _T('titre_page_upgrade');
+    $balise_img = charger_filtre('balise_img');
+    $titre .= $balise_img(chemin_image('loader.svg'), '', 'loader');
+    echo(install_debut_html($titre));
+    // script de rechargement auto sur timeout
+    $redirect = generer_url_ecrire('upgrade', "reinstall=$installee&meta=$meta&table=$table", true);
+    echo http_script("window.setTimeout('location.href=\"" . $redirect . "\";'," . ($timeout * 1000) . ')');
+    echo "<div style='text-align: left'>\n";
+    if (ob_get_level()) {
+        ob_flush();
+    }
+    flush();
+    $done = true;
 }
 
 
@@ -346,63 +346,63 @@ 
  *    - tableau vide sinon.
  */
 function maj_while($installee, $cible, $maj, $meta = '', $table = 'meta', $redirect = '', $debut_page = false) {
-	# inclusions pour que les procedures d'upgrade disposent des fonctions de base
-	include_spip('base/create');
-	include_spip('base/abstract_sql');
-	$trouver_table = charger_fonction('trouver_table', 'base');
-	include_spip('inc/plugin'); // pour spip_version_compare
-	$n = 0;
-	$time = time();
-
-	if (!defined('_TIME_OUT')) {
-		/**
-		 * Définir le timeout qui peut-être utilisé dans les fonctions
-		 * de mises à jour qui durent trop longtemps
-		 *
-		 * À utiliser tel que : `if (time() >= _TIME_OUT)`
-		 *
-		 * @var int
-		 */
-		define('_TIME_OUT', $time + _UPGRADE_TIME_OUT);
-	}
-
-	foreach ($maj as $v => $operations) {
-		// si une maj pour cette version
-		if (
-			$v == 'init'
-			|| spip_version_compare($v, $installee, '>') && spip_version_compare($v, $cible, '<=')
-		) {
-			if ($debut_page) {
-				maj_debut_page($v, $meta, $table);
-			}
-			echo "MAJ $v";
-			$etape = serie_alter($v, $operations, $meta, $table, $redirect);
-			$trouver_table(''); // vider le cache des descriptions de table
-			# echec sur une etape en cours ?
-			# on sort
-			if ($etape) {
-				return [$v, $etape];
-			}
-			$n = time() - $time;
-			spip_logger('maj')->notice("$table $meta: $v en $n secondes");
-			if ($meta) {
-				ecrire_meta($meta, $installee = $v, 'oui', $table);
-			}
-			echo (_IS_CLI ? "\n" : '<br />');
-		}
-		if (time() >= _TIME_OUT) {
-			relance_maj($meta, $table, $redirect);
-		}
-	}
-	$trouver_table(''); // vider le cache des descriptions de table
-	// indispensable pour les chgt de versions qui n'ecrivent pas en base
-	// tant pis pour la redondance eventuelle avec ci-dessus
-	if ($meta) {
-		ecrire_meta($meta, $cible, 'oui', $table);
-	}
-	spip_logger('maj')->notice("MAJ terminee. $meta: $installee");
-
-	return [];
+    # inclusions pour que les procedures d'upgrade disposent des fonctions de base
+    include_spip('base/create');
+    include_spip('base/abstract_sql');
+    $trouver_table = charger_fonction('trouver_table', 'base');
+    include_spip('inc/plugin'); // pour spip_version_compare
+    $n = 0;
+    $time = time();
+
+    if (!defined('_TIME_OUT')) {
+        /**
+         * Définir le timeout qui peut-être utilisé dans les fonctions
+         * de mises à jour qui durent trop longtemps
+         *
+         * À utiliser tel que : `if (time() >= _TIME_OUT)`
+         *
+         * @var int
+         */
+        define('_TIME_OUT', $time + _UPGRADE_TIME_OUT);
+    }
+
+    foreach ($maj as $v => $operations) {
+        // si une maj pour cette version
+        if (
+            $v == 'init'
+            || spip_version_compare($v, $installee, '>') && spip_version_compare($v, $cible, '<=')
+        ) {
+            if ($debut_page) {
+                maj_debut_page($v, $meta, $table);
+            }
+            echo "MAJ $v";
+            $etape = serie_alter($v, $operations, $meta, $table, $redirect);
+            $trouver_table(''); // vider le cache des descriptions de table
+            # echec sur une etape en cours ?
+            # on sort
+            if ($etape) {
+                return [$v, $etape];
+            }
+            $n = time() - $time;
+            spip_logger('maj')->notice("$table $meta: $v en $n secondes");
+            if ($meta) {
+                ecrire_meta($meta, $installee = $v, 'oui', $table);
+            }
+            echo (_IS_CLI ? "\n" : '<br />');
+        }
+        if (time() >= _TIME_OUT) {
+            relance_maj($meta, $table, $redirect);
+        }
+    }
+    $trouver_table(''); // vider le cache des descriptions de table
+    // indispensable pour les chgt de versions qui n'ecrivent pas en base
+    // tant pis pour la redondance eventuelle avec ci-dessus
+    if ($meta) {
+        ecrire_meta($meta, $cible, 'oui', $table);
+    }
+    spip_logger('maj')->notice("MAJ terminee. $meta: $installee");
+
+    return [];
 }
 
 /**
@@ -425,53 +425,53 @@ 
  * @return int
  */
 function serie_alter($serie, $q = [], $meta = '', $table = 'meta', $redirect = '') {
-	$meta2 = $meta . '_maj_' . $serie;
-	$etape = 0;
-	if (isset($GLOBALS[$table][$meta2])) {
-		$etape = (int) $GLOBALS[$table][$meta2];
-	}
-	foreach ($q as $i => $r) {
-		if ($i >= $etape) {
-			$msg = "maj $table $meta2 etape $i";
-			if (
-				is_array($r)
-				&& function_exists($f = array_shift($r))
-			) {
-				// note: $r (arguments de la fonction $f) peut avoir des données tabulaires
-				spip_logger('maj')->notice("$msg: $f " . @implode(',', $r));
-				// pour les fonctions atomiques sql_xx
-				// on enregistre le meta avant de lancer la fonction,
-				// de maniere a eviter de boucler sur timeout
-				// mais pour les fonctions complexes,
-				// il faut les rejouer jusqu'a achevement.
-				// C'est a elle d'assurer qu'elles progressent a chaque rappel
-				if (str_starts_with($f, 'sql_')) {
-					ecrire_meta($meta2, $i + 1, 'non', $table);
-				}
-				echo (_IS_CLI ? '.' : " <span title='$i'>.</span>");
-				$f(...$r);
-				// si temps imparti depasse, on relance sans ecrire en meta
-				// car on est peut etre sorti sur timeout si c'est une fonction longue
-				if (time() >= _TIME_OUT) {
-					relance_maj($meta, $table, $redirect);
-				}
-				ecrire_meta($meta2, $i + 1, 'non', $table);
-				spip_logger('maj')->notice("$meta2: ok");
-			} else {
-				if (!is_array($r)) {
-					spip_logger('maj')->error("maj $i format incorrect");
-				} else {
-					spip_logger('maj')->error("maj $i fonction $f non definie");
-				}
-				// en cas d'erreur serieuse, on s'arrete
-				// mais on permet de passer par dessus en rechargeant la page.
-				return $i + 1;
-			}
-		}
-	}
-	effacer_meta($meta2, $table);
-
-	return 0;
+    $meta2 = $meta . '_maj_' . $serie;
+    $etape = 0;
+    if (isset($GLOBALS[$table][$meta2])) {
+        $etape = (int) $GLOBALS[$table][$meta2];
+    }
+    foreach ($q as $i => $r) {
+        if ($i >= $etape) {
+            $msg = "maj $table $meta2 etape $i";
+            if (
+                is_array($r)
+                && function_exists($f = array_shift($r))
+            ) {
+                // note: $r (arguments de la fonction $f) peut avoir des données tabulaires
+                spip_logger('maj')->notice("$msg: $f " . @implode(',', $r));
+                // pour les fonctions atomiques sql_xx
+                // on enregistre le meta avant de lancer la fonction,
+                // de maniere a eviter de boucler sur timeout
+                // mais pour les fonctions complexes,
+                // il faut les rejouer jusqu'a achevement.
+                // C'est a elle d'assurer qu'elles progressent a chaque rappel
+                if (str_starts_with($f, 'sql_')) {
+                    ecrire_meta($meta2, $i + 1, 'non', $table);
+                }
+                echo (_IS_CLI ? '.' : " <span title='$i'>.</span>");
+                $f(...$r);
+                // si temps imparti depasse, on relance sans ecrire en meta
+                // car on est peut etre sorti sur timeout si c'est une fonction longue
+                if (time() >= _TIME_OUT) {
+                    relance_maj($meta, $table, $redirect);
+                }
+                ecrire_meta($meta2, $i + 1, 'non', $table);
+                spip_logger('maj')->notice("$meta2: ok");
+            } else {
+                if (!is_array($r)) {
+                    spip_logger('maj')->error("maj $i format incorrect");
+                } else {
+                    spip_logger('maj')->error("maj $i fonction $f non definie");
+                }
+                // en cas d'erreur serieuse, on s'arrete
+                // mais on permet de passer par dessus en rechargeant la page.
+                return $i + 1;
+            }
+        }
+    }
+    effacer_meta($meta2, $table);
+
+    return 0;
 }
 
 /**
@@ -480,16 +480,16 @@ 
  * @return bool True si possible.
  **/
 function upgrade_test() {
-	sql_drop_table('spip_test', true);
-	sql_create('spip_test', ['a' => 'int']);
-	sql_alter('TABLE spip_test ADD b INT');
-	sql_insertq('spip_test', ['b' => 1], ['field' => ['b' => 'int']]);
-	$result = sql_select('b', 'spip_test');
-	// ne pas garder le resultat de la requete sinon sqlite3
-	// ne peut pas supprimer la table spip_test lors du sql_alter qui suit
-	// car cette table serait alors 'verouillee'
-	$result = (bool) $result;
-	sql_alter('TABLE spip_test DROP b');
-
-	return $result;
+    sql_drop_table('spip_test', true);
+    sql_create('spip_test', ['a' => 'int']);
+    sql_alter('TABLE spip_test ADD b INT');
+    sql_insertq('spip_test', ['b' => 1], ['field' => ['b' => 'int']]);
+    $result = sql_select('b', 'spip_test');
+    // ne pas garder le resultat de la requete sinon sqlite3
+    // ne peut pas supprimer la table spip_test lors du sql_alter qui suit
+    // car cette table serait alors 'verouillee'
+    $result = (bool) $result;
+    sql_alter('TABLE spip_test DROP b');
+
+    return $result;
 }

Spacing +7 added lines, -7 removed lines

@@ -77,7 +77,7 @@ 
 	@spip_unlink(_CACHE_PLUGINS_OPT);
 	@spip_unlink(_CACHE_PLUGINS_FCT);
 	@spip_unlink(_CACHE_CHEMIN);
-	@spip_unlink(_DIR_TMP . 'plugin_xml_cache.gz');
+	@spip_unlink(_DIR_TMP.'plugin_xml_cache.gz');
 
 	include_spip('inc/auth');
 	auth_synchroniser_distant();
@@ -116,7 +116,7 @@ 
 	$version_installee = $GLOBALS['meta']['version_installee'] ?? null;
 
 	spip_logger('maj')->notice(
-		"Version anterieure: $version_installee. Courante: " . $GLOBALS['spip_version_base'],
+		"Version anterieure: $version_installee. Courante: ".$GLOBALS['spip_version_base'],
 	);
 	if (!$version_installee || $GLOBALS['spip_version_base'] < $version_installee) {
 		sql_replace(
@@ -147,7 +147,7 @@ 
 		if (!is_array($res)) {
 			spip_logger('maj')->error("Pb d'acces SQL a la mise a jour");
 		} else {
-			echo _T('avis_operation_echec') . ' ' . implode(' ', $res);
+			echo _T('avis_operation_echec').' '.implode(' ', $res);
 			echo install_fin_html();
 		}
 	}
@@ -237,7 +237,7 @@ 
 			if (!is_array($res)) {
 				spip_logger('maj')->error("Pb d'acces SQL a la mise a jour");
 			} else {
-				echo '<p>' . _T('avis_operation_echec') . ' ' . implode(' ', $res) . '</p>';
+				echo '<p>'._T('avis_operation_echec').' '.implode(' ', $res).'</p>';
 			}
 		}
 	}
@@ -296,7 +296,7 @@ 
 	echo(install_debut_html($titre));
 	// script de rechargement auto sur timeout
 	$redirect = generer_url_ecrire('upgrade', "reinstall=$installee&meta=$meta&table=$table", true);
-	echo http_script("window.setTimeout('location.href=\"" . $redirect . "\";'," . ($timeout * 1000) . ')');
+	echo http_script("window.setTimeout('location.href=\"".$redirect."\";',".($timeout * 1000).')');
 	echo "<div style='text-align: left'>\n";
 	if (ob_get_level()) {
 		ob_flush();
@@ -425,7 +425,7 @@ 
  * @return int
  */
 function serie_alter($serie, $q = [], $meta = '', $table = 'meta', $redirect = '') {
-	$meta2 = $meta . '_maj_' . $serie;
+	$meta2 = $meta.'_maj_'.$serie;
 	$etape = 0;
 	if (isset($GLOBALS[$table][$meta2])) {
 		$etape = (int) $GLOBALS[$table][$meta2];
@@ -438,7 +438,7 @@ 
 				&& function_exists($f = array_shift($r))
 			) {
 				// note: $r (arguments de la fonction $f) peut avoir des données tabulaires
-				spip_logger('maj')->notice("$msg: $f " . @implode(',', $r));
+				spip_logger('maj')->notice("$msg: $f ".@implode(',', $r));
 				// pour les fonctions atomiques sql_xx
 				// on enregistre le meta avant de lancer la fonction,
 				// de maniere a eviter de boucler sur timeout

ecrire/base/create.php

Indentation +89 added lines, -89 removed lines

@@ -15,7 +15,7 @@ 
  * @package SPIP\Core\Installation
  **/
 if (!defined('_ECRIRE_INC_VERSION')) {
-	return;
+    return;
 }
 
 include_spip('inc/acces');
@@ -32,18 +32,18 @@ 
  * @return bool
  */
 function base_determine_autoinc($table, $desc = []) {
-	if (($t = lister_tables_principales()) && isset($t[$table])) {
-		$autoinc = true;
-	} elseif (($t = lister_tables_auxiliaires()) && isset($t[$table])) {
-		$autoinc = false;
-	} else {
-		// essayer de faire au mieux !
-		$autoinc = (isset($desc['key']['PRIMARY KEY'])
-			&& !str_contains((string) $desc['key']['PRIMARY KEY'], ',')
-			&& !str_contains((string) $desc['field'][$desc['key']['PRIMARY KEY']], 'default'));
-	}
+    if (($t = lister_tables_principales()) && isset($t[$table])) {
+        $autoinc = true;
+    } elseif (($t = lister_tables_auxiliaires()) && isset($t[$table])) {
+        $autoinc = false;
+    } else {
+        // essayer de faire au mieux !
+        $autoinc = (isset($desc['key']['PRIMARY KEY'])
+            && !str_contains((string) $desc['key']['PRIMARY KEY'], ',')
+            && !str_contains((string) $desc['field'][$desc['key']['PRIMARY KEY']], 'default'));
+    }
 
-	return $autoinc;
+    return $autoinc;
 }
 
 /**
@@ -60,49 +60,49 @@ 
  * @return void
  */
 function creer_ou_upgrader_table($table, $desc, $autoinc, $upgrade = false, $serveur = '') {
-	$sql_desc = $upgrade ? sql_showtable($table, true, $serveur) : false;
-	if (!$sql_desc) {
-		if ($autoinc === 'auto') {
-			$autoinc = base_determine_autoinc($table, $desc);
-		}
-		if (isset($desc['field']) && isset($desc['key'])) {
-			sql_create($table, $desc['field'], $desc['key'], $autoinc, false, $serveur);
-		}
-		// verifier la bonne installation de la table (php-fpm es-tu la ?)
-		$sql_desc = sql_showtable($table, true, $serveur);
-		if (!$sql_desc) {
-			// on retente avec un sleep ?
-			sleep(1);
-			sql_create($table, $desc['field'], $desc['key'], $autoinc, false, $serveur);
-			$sql_desc = sql_showtable($table, true, $serveur);
-			if (!$sql_desc) {
-				spip_logger('maj')->critical("Echec creation table $table");
-			}
-		}
-	} else {
-		// ajouter les champs manquants
-		// on ne supprime jamais les champs, car c'est dangereux
-		// c'est toujours a faire manuellement
-		$last = '';
-		if (isset($desc['field'])) {
-			foreach ($desc['field'] as $field => $type) {
-				if (!isset($sql_desc['field'][$field])) {
-					sql_alter("TABLE $table ADD $field $type" . ($last ? " AFTER $last" : ''), $serveur);
-				}
-				$last = $field;
-			}
-		}
-		if (isset($desc['key'])) {
-			foreach ($desc['key'] as $key => $type) {
-				// Ne pas oublier les cas des cles non nommees dans la declaration et qui sont retournees
-				// par le showtable sous la forme d'un index de tableau "KEY $type" et non "KEY"
-				if (!isset($sql_desc['key'][$key]) && !isset($sql_desc['key']["$key $type"])) {
-					sql_alter("TABLE $table ADD $key ($type)", $serveur);
-				}
-				$last = $field;
-			}
-		}
-	}
+    $sql_desc = $upgrade ? sql_showtable($table, true, $serveur) : false;
+    if (!$sql_desc) {
+        if ($autoinc === 'auto') {
+            $autoinc = base_determine_autoinc($table, $desc);
+        }
+        if (isset($desc['field']) && isset($desc['key'])) {
+            sql_create($table, $desc['field'], $desc['key'], $autoinc, false, $serveur);
+        }
+        // verifier la bonne installation de la table (php-fpm es-tu la ?)
+        $sql_desc = sql_showtable($table, true, $serveur);
+        if (!$sql_desc) {
+            // on retente avec un sleep ?
+            sleep(1);
+            sql_create($table, $desc['field'], $desc['key'], $autoinc, false, $serveur);
+            $sql_desc = sql_showtable($table, true, $serveur);
+            if (!$sql_desc) {
+                spip_logger('maj')->critical("Echec creation table $table");
+            }
+        }
+    } else {
+        // ajouter les champs manquants
+        // on ne supprime jamais les champs, car c'est dangereux
+        // c'est toujours a faire manuellement
+        $last = '';
+        if (isset($desc['field'])) {
+            foreach ($desc['field'] as $field => $type) {
+                if (!isset($sql_desc['field'][$field])) {
+                    sql_alter("TABLE $table ADD $field $type" . ($last ? " AFTER $last" : ''), $serveur);
+                }
+                $last = $field;
+            }
+        }
+        if (isset($desc['key'])) {
+            foreach ($desc['key'] as $key => $type) {
+                // Ne pas oublier les cas des cles non nommees dans la declaration et qui sont retournees
+                // par le showtable sous la forme d'un index de tableau "KEY $type" et non "KEY"
+                if (!isset($sql_desc['key'][$key]) && !isset($sql_desc['key']["$key $type"])) {
+                    sql_alter("TABLE $table ADD $key ($type)", $serveur);
+                }
+                $last = $field;
+            }
+        }
+    }
 }
 
 /**
@@ -124,26 +124,26 @@ 
  * @return void
  */
 function alterer_base($tables_inc, $tables_noinc, $up = false, $serveur = '') {
-	if ($up === false) {
-		$old = false;
-		$up = [];
-	} else {
-		$old = true;
-		if (!is_array($up)) {
-			$up = [$up];
-		}
-	}
-	foreach ($tables_inc as $k => $v) {
-		if (!$old || in_array($k, $up)) {
-			creer_ou_upgrader_table($k, $v, true, $old, $serveur);
-		}
-	}
+    if ($up === false) {
+        $old = false;
+        $up = [];
+    } else {
+        $old = true;
+        if (!is_array($up)) {
+            $up = [$up];
+        }
+    }
+    foreach ($tables_inc as $k => $v) {
+        if (!$old || in_array($k, $up)) {
+            creer_ou_upgrader_table($k, $v, true, $old, $serveur);
+        }
+    }
 
-	foreach ($tables_noinc as $k => $v) {
-		if (!$old || in_array($k, $up)) {
-			creer_ou_upgrader_table($k, $v, false, $old, $serveur);
-		}
-	}
+    foreach ($tables_noinc as $k => $v) {
+        if (!$old || in_array($k, $up)) {
+            creer_ou_upgrader_table($k, $v, false, $old, $serveur);
+        }
+    }
 }
 
 /**
@@ -163,16 +163,16 @@ 
  */
 function creer_base($serveur = '') {
 
-	// Note: les mises a jour reexecutent ce code pour s'assurer
-	// de la conformite de la base
-	// pas de panique sur  "already exists" et "duplicate entry" donc.
+    // Note: les mises a jour reexecutent ce code pour s'assurer
+    // de la conformite de la base
+    // pas de panique sur  "already exists" et "duplicate entry" donc.
 
-	alterer_base(
-		lister_tables_principales(),
-		lister_tables_auxiliaires(),
-		false,
-		$serveur
-	);
+    alterer_base(
+        lister_tables_principales(),
+        lister_tables_auxiliaires(),
+        false,
+        $serveur
+    );
 }
 
 /**
@@ -192,10 +192,10 @@ 
  * @return void
  */
 function maj_tables($upgrade_tables = [], $serveur = '') {
-	alterer_base(
-		lister_tables_principales(),
-		lister_tables_auxiliaires(),
-		$upgrade_tables,
-		$serveur
-	);
+    alterer_base(
+        lister_tables_principales(),
+        lister_tables_auxiliaires(),
+        $upgrade_tables,
+        $serveur
+    );
 }

Spacing +1 added lines, -1 removed lines

@@ -87,7 +87,7 @@
 		if (isset($desc['field'])) {
 			foreach ($desc['field'] as $field => $type) {
 				if (!isset($sql_desc['field'][$field])) {
-					sql_alter("TABLE $table ADD $field $type" . ($last ? " AFTER $last" : ''), $serveur);
+					sql_alter("TABLE $table ADD $field $type".($last ? " AFTER $last" : ''), $serveur);
 				}
 				$last = $field;
 			}

ecrire/base/trouver_table.php

Indentation +149 added lines, -149 removed lines

@@ -17,7 +17,7 @@ 
  * @package SPIP\Core\SQL\Tables
  **/
 if (!defined('_ECRIRE_INC_VERSION')) {
-	return;
+    return;
 }
 include_spip('base/objets');
 
@@ -69,152 +69,152 @@ 
  *
  **/
 function base_trouver_table_dist($nom, $serveur = '', $table_spip = true, array $options = []) {
-	$desc_cache = null;
-	static $nom_cache_desc_sql = [];
-
-	if (
-		!spip_connect($serveur)
-		|| !preg_match('/^[a-zA-Z0-9._-]*/', $nom)
-	) {
-		return null;
-	}
-
-	$options += [
-		// si false, baissera le niveau de log si une table demandée n’existe pas
-		'log_missing' => true,
-	];
-
-	$connexion = &$GLOBALS['connexions'][$serveur ? strtolower($serveur) : 0];
-	$objets_sql = lister_tables_objets_sql('::md5');
-
-	// le nom du cache depend du serveur mais aussi du nom de la db et du prefixe
-	// ce qui permet une auto invalidation en cas de modif manuelle du fichier
-	// de connexion, et tout risque d'ambiguite
-	if (!isset($nom_cache_desc_sql[$serveur][$objets_sql])) {
-		$nom_cache_desc_sql[$serveur][$objets_sql] =
-			_DIR_CACHE . 'sql_desc_'
-			. ($serveur ? "{$serveur}_" : '')
-			. substr(md5($connexion['db'] . ':' . $connexion['prefixe'] . ":$objets_sql"), 0, 8)
-			. '.txt';
-		// nouveau nom de cache = nouvelle version en memoire
-		unset($connexion['tables']);
-	}
-
-	// un appel avec $nom vide est une demande explicite de vidange du cache des descriptions
-	if (!$nom) {
-		spip_unlink($nom_cache_desc_sql[$serveur][$objets_sql]);
-		$connexion['tables'] = [];
-
-		return null;
-	}
-
-	$nom_sql = $nom;
-	$nom_sql = preg_match('/\.(.*)$/', $nom, $s) ? $s[1] : $nom;
-
-	$fdesc = $desc = '';
-	$connexion = &$GLOBALS['connexions'][$serveur ?: 0];
-
-	// base sous SPIP: gerer les abreviations explicites des noms de table
-	if (
-		$connexion['spip_connect_version']
-		&& $table_spip
-		&& isset($GLOBALS['table_des_tables'][$nom])
-	) {
-		$nom = $GLOBALS['table_des_tables'][$nom];
-		$nom_sql = 'spip_' . $nom;
-	}
-
-	// si c'est la premiere table qu'on cherche
-	// et si on est pas explicitement en recalcul
-	// on essaye de recharger le cache des decriptions de ce serveur
-	// dans le fichier cache
-	if (
-		!isset($connexion['tables'][$nom_sql])
-		&& defined('_VAR_MODE')
-		&& _VAR_MODE !== 'recalcul'
-		&& (!isset($connexion['tables']) || !$connexion['tables'])
-		&& lire_fichier($nom_cache_desc_sql[$serveur][$objets_sql], $desc_cache)
-		&& ($desc_cache = unserialize($desc_cache))
-	) {
-		$connexion['tables'] = $desc_cache;
-	}
-	if ($table_spip && !isset($connexion['tables'][$nom_sql])) {
-		if (isset($GLOBALS['tables_principales'][$nom_sql])) {
-			$fdesc = $GLOBALS['tables_principales'][$nom_sql];
-		}
-		// meme si pas d'abreviation declaree, trouver la table spip_$nom
-		// si c'est une table principale,
-		// puisqu'on le fait aussi pour les tables auxiliaires
-		elseif ($nom_sql == $nom && isset($GLOBALS['tables_principales']['spip_' . $nom])) {
-			$nom_sql = 'spip_' . $nom;
-			$fdesc = &$GLOBALS['tables_principales'][$nom_sql];
-		} elseif (
-			isset($GLOBALS['tables_auxiliaires'][$n = $nom])
-			|| isset($GLOBALS['tables_auxiliaires'][$n = 'spip_' . $nom])
-		) {
-			$nom_sql = $n;
-			$fdesc = &$GLOBALS['tables_auxiliaires'][$n];
-		}  # table locale a cote de SPIP, comme non SPIP:
-	}
-	if (!isset($connexion['tables'][$nom_sql])) {
-		// La *vraie* base a la priorite
-		$exists = sql_table_exists($nom_sql, $table_spip, $serveur);
-		if (
-			!$exists
-			|| !($desc = sql_showtable($nom_sql, $table_spip, $serveur))
-			|| !$desc['field']
-		) {
-			if (!$fdesc) {
-				spip_logger('base')->log(
-					$options['log_missing'] ? LogLevel::NOTICE : LogLevel::DEBUG,
-					"trouver_table: table inconnue '$serveur' '$nom'"
-				);
-
-				return null;
-			}
-			// on ne sait pas lire la structure de la table :
-			// on retombe sur la description donnee dans les fichiers spip
-			$desc = $fdesc;
-			$desc['exist'] = false;
-		} else {
-			$desc['exist'] = true;
-			// gerer le cas des cles vides (echec de l'analyse sur une vue par exemple)
-			// pour recuperer la declaration de lister_tables_objets_sql() si il y en a une
-			if (! $desc['key']) {
-				spip_logger('base')->info("trouver_table: table sans cle '$serveur' '$nom'");
-				unset($desc['key']);
-			}
-		}
-
-		$desc['table'] = $desc['table_sql'] = $nom_sql;
-		$desc['connexion'] = $serveur;
-
-		// charger les infos declarees pour cette table
-		// en lui passant les infos connues
-		// $desc est prioritaire pour la description de la table
-		$desc = array_merge(lister_tables_objets_sql($nom_sql, $desc), $desc);
-		// s'assurer qu'on a toujours un 'key'
-		if (!isset($desc['key']) && !empty($fdesc['key'])) {
-			$desc['key'] = $fdesc['key'];
-		}
-		if (! isset($desc['key'])) {
-			$desc['key'] = [];
-		}
-
-		// si tables_objets_sql est bien fini d'init, on peut cacher
-		$connexion['tables'][$nom_sql] = $desc;
-		$res = &$connexion['tables'][$nom_sql];
-		// une nouvelle table a ete decrite
-		// mettons donc a jour le cache des descriptions de ce serveur
-		if (is_writable(_DIR_CACHE)) {
-			ecrire_fichier($nom_cache_desc_sql[$serveur][$objets_sql], serialize($connexion['tables']), true);
-		}
-	} else {
-		$res = &$connexion['tables'][$nom_sql];
-	}
-
-	// toujours retourner $nom dans id_table
-	$res['id_table'] = $nom;
-
-	return $res;
+    $desc_cache = null;
+    static $nom_cache_desc_sql = [];
+
+    if (
+        !spip_connect($serveur)
+        || !preg_match('/^[a-zA-Z0-9._-]*/', $nom)
+    ) {
+        return null;
+    }
+
+    $options += [
+        // si false, baissera le niveau de log si une table demandée n’existe pas
+        'log_missing' => true,
+    ];
+
+    $connexion = &$GLOBALS['connexions'][$serveur ? strtolower($serveur) : 0];
+    $objets_sql = lister_tables_objets_sql('::md5');
+
+    // le nom du cache depend du serveur mais aussi du nom de la db et du prefixe
+    // ce qui permet une auto invalidation en cas de modif manuelle du fichier
+    // de connexion, et tout risque d'ambiguite
+    if (!isset($nom_cache_desc_sql[$serveur][$objets_sql])) {
+        $nom_cache_desc_sql[$serveur][$objets_sql] =
+            _DIR_CACHE . 'sql_desc_'
+            . ($serveur ? "{$serveur}_" : '')
+            . substr(md5($connexion['db'] . ':' . $connexion['prefixe'] . ":$objets_sql"), 0, 8)
+            . '.txt';
+        // nouveau nom de cache = nouvelle version en memoire
+        unset($connexion['tables']);
+    }
+
+    // un appel avec $nom vide est une demande explicite de vidange du cache des descriptions
+    if (!$nom) {
+        spip_unlink($nom_cache_desc_sql[$serveur][$objets_sql]);
+        $connexion['tables'] = [];
+
+        return null;
+    }
+
+    $nom_sql = $nom;
+    $nom_sql = preg_match('/\.(.*)$/', $nom, $s) ? $s[1] : $nom;
+
+    $fdesc = $desc = '';
+    $connexion = &$GLOBALS['connexions'][$serveur ?: 0];
+
+    // base sous SPIP: gerer les abreviations explicites des noms de table
+    if (
+        $connexion['spip_connect_version']
+        && $table_spip
+        && isset($GLOBALS['table_des_tables'][$nom])
+    ) {
+        $nom = $GLOBALS['table_des_tables'][$nom];
+        $nom_sql = 'spip_' . $nom;
+    }
+
+    // si c'est la premiere table qu'on cherche
+    // et si on est pas explicitement en recalcul
+    // on essaye de recharger le cache des decriptions de ce serveur
+    // dans le fichier cache
+    if (
+        !isset($connexion['tables'][$nom_sql])
+        && defined('_VAR_MODE')
+        && _VAR_MODE !== 'recalcul'
+        && (!isset($connexion['tables']) || !$connexion['tables'])
+        && lire_fichier($nom_cache_desc_sql[$serveur][$objets_sql], $desc_cache)
+        && ($desc_cache = unserialize($desc_cache))
+    ) {
+        $connexion['tables'] = $desc_cache;
+    }
+    if ($table_spip && !isset($connexion['tables'][$nom_sql])) {
+        if (isset($GLOBALS['tables_principales'][$nom_sql])) {
+            $fdesc = $GLOBALS['tables_principales'][$nom_sql];
+        }
+        // meme si pas d'abreviation declaree, trouver la table spip_$nom
+        // si c'est une table principale,
+        // puisqu'on le fait aussi pour les tables auxiliaires
+        elseif ($nom_sql == $nom && isset($GLOBALS['tables_principales']['spip_' . $nom])) {
+            $nom_sql = 'spip_' . $nom;
+            $fdesc = &$GLOBALS['tables_principales'][$nom_sql];
+        } elseif (
+            isset($GLOBALS['tables_auxiliaires'][$n = $nom])
+            || isset($GLOBALS['tables_auxiliaires'][$n = 'spip_' . $nom])
+        ) {
+            $nom_sql = $n;
+            $fdesc = &$GLOBALS['tables_auxiliaires'][$n];
+        }  # table locale a cote de SPIP, comme non SPIP:
+    }
+    if (!isset($connexion['tables'][$nom_sql])) {
+        // La *vraie* base a la priorite
+        $exists = sql_table_exists($nom_sql, $table_spip, $serveur);
+        if (
+            !$exists
+            || !($desc = sql_showtable($nom_sql, $table_spip, $serveur))
+            || !$desc['field']
+        ) {
+            if (!$fdesc) {
+                spip_logger('base')->log(
+                    $options['log_missing'] ? LogLevel::NOTICE : LogLevel::DEBUG,
+                    "trouver_table: table inconnue '$serveur' '$nom'"
+                );
+
+                return null;
+            }
+            // on ne sait pas lire la structure de la table :
+            // on retombe sur la description donnee dans les fichiers spip
+            $desc = $fdesc;
+            $desc['exist'] = false;
+        } else {
+            $desc['exist'] = true;
+            // gerer le cas des cles vides (echec de l'analyse sur une vue par exemple)
+            // pour recuperer la declaration de lister_tables_objets_sql() si il y en a une
+            if (! $desc['key']) {
+                spip_logger('base')->info("trouver_table: table sans cle '$serveur' '$nom'");
+                unset($desc['key']);
+            }
+        }
+
+        $desc['table'] = $desc['table_sql'] = $nom_sql;
+        $desc['connexion'] = $serveur;
+
+        // charger les infos declarees pour cette table
+        // en lui passant les infos connues
+        // $desc est prioritaire pour la description de la table
+        $desc = array_merge(lister_tables_objets_sql($nom_sql, $desc), $desc);
+        // s'assurer qu'on a toujours un 'key'
+        if (!isset($desc['key']) && !empty($fdesc['key'])) {
+            $desc['key'] = $fdesc['key'];
+        }
+        if (! isset($desc['key'])) {
+            $desc['key'] = [];
+        }
+
+        // si tables_objets_sql est bien fini d'init, on peut cacher
+        $connexion['tables'][$nom_sql] = $desc;
+        $res = &$connexion['tables'][$nom_sql];
+        // une nouvelle table a ete decrite
+        // mettons donc a jour le cache des descriptions de ce serveur
+        if (is_writable(_DIR_CACHE)) {
+            ecrire_fichier($nom_cache_desc_sql[$serveur][$objets_sql], serialize($connexion['tables']), true);
+        }
+    } else {
+        $res = &$connexion['tables'][$nom_sql];
+    }
+
+    // toujours retourner $nom dans id_table
+    $res['id_table'] = $nom;
+
+    return $res;
 }

Spacing +8 added lines, -8 removed lines

@@ -92,9 +92,9 @@ 
 	// de connexion, et tout risque d'ambiguite
 	if (!isset($nom_cache_desc_sql[$serveur][$objets_sql])) {
 		$nom_cache_desc_sql[$serveur][$objets_sql] =
-			_DIR_CACHE . 'sql_desc_'
+			_DIR_CACHE.'sql_desc_'
 			. ($serveur ? "{$serveur}_" : '')
-			. substr(md5($connexion['db'] . ':' . $connexion['prefixe'] . ":$objets_sql"), 0, 8)
+			. substr(md5($connexion['db'].':'.$connexion['prefixe'].":$objets_sql"), 0, 8)
 			. '.txt';
 		// nouveau nom de cache = nouvelle version en memoire
 		unset($connexion['tables']);
@@ -121,7 +121,7 @@ 
 		&& isset($GLOBALS['table_des_tables'][$nom])
 	) {
 		$nom = $GLOBALS['table_des_tables'][$nom];
-		$nom_sql = 'spip_' . $nom;
+		$nom_sql = 'spip_'.$nom;
 	}
 
 	// si c'est la premiere table qu'on cherche
@@ -145,12 +145,12 @@ 
 		// meme si pas d'abreviation declaree, trouver la table spip_$nom
 		// si c'est une table principale,
 		// puisqu'on le fait aussi pour les tables auxiliaires
-		elseif ($nom_sql == $nom && isset($GLOBALS['tables_principales']['spip_' . $nom])) {
-			$nom_sql = 'spip_' . $nom;
+		elseif ($nom_sql == $nom && isset($GLOBALS['tables_principales']['spip_'.$nom])) {
+			$nom_sql = 'spip_'.$nom;
 			$fdesc = &$GLOBALS['tables_principales'][$nom_sql];
 		} elseif (
 			isset($GLOBALS['tables_auxiliaires'][$n = $nom])
-			|| isset($GLOBALS['tables_auxiliaires'][$n = 'spip_' . $nom])
+			|| isset($GLOBALS['tables_auxiliaires'][$n = 'spip_'.$nom])
 		) {
 			$nom_sql = $n;
 			$fdesc = &$GLOBALS['tables_auxiliaires'][$n];
@@ -180,7 +180,7 @@ 
 			$desc['exist'] = true;
 			// gerer le cas des cles vides (echec de l'analyse sur une vue par exemple)
 			// pour recuperer la declaration de lister_tables_objets_sql() si il y en a une
-			if (! $desc['key']) {
+			if (!$desc['key']) {
 				spip_logger('base')->info("trouver_table: table sans cle '$serveur' '$nom'");
 				unset($desc['key']);
 			}
@@ -197,7 +197,7 @@ 
 		if (!isset($desc['key']) && !empty($fdesc['key'])) {
 			$desc['key'] = $fdesc['key'];
 		}
-		if (! isset($desc['key'])) {
+		if (!isset($desc['key'])) {
 			$desc['key'] = [];
 		}
 

ecrire/xml/sax.php

Indentation +244 added lines, -244 removed lines

@@ -10,7 +10,7 @@ 
 \***************************************************************************/
 
 if (!defined('_ECRIRE_INC_VERSION')) {
-	return;
+    return;
 }
 
 include_spip('inc/charsets');
@@ -23,215 +23,215 @@ 
  * @return string
  */
 function xml_entites_html($texte) {
-	if (!is_string($texte) || !$texte || strpbrk($texte, "&\"'<>") == false) {
-		return $texte;
-	}
+    if (!is_string($texte) || !$texte || strpbrk($texte, "&\"'<>") == false) {
+        return $texte;
+    }
 
-	if (!function_exists('spip_htmlspecialchars')) {
-		include_spip('inc/filtres_mini');
-	}
+    if (!function_exists('spip_htmlspecialchars')) {
+        include_spip('inc/filtres_mini');
+    }
 
-	return spip_htmlspecialchars($texte, ENT_QUOTES);
+    return spip_htmlspecialchars($texte, ENT_QUOTES);
 }
 
 function xml_debutElement($phraseur, $name, $attrs) {
-	$depth = $phraseur->depth;
-
-	$t = $phraseur->ouvrant[$depth] ?? ' ';
-	// espace initial signifie: deja integree au resultat
-	if ($t[0] != ' ') {
-		$phraseur->res .= '<' . $t . '>';
-		$phraseur->ouvrant[$depth] = ' ' . $t;
-	}
-	$t = $phraseur->contenu[$depth];
-	// n'indenter que s'il y a un separateur avant
-	$phraseur->res .= preg_replace("/[\n\t ]+$/", "\n$depth", $t);
-	$phraseur->contenu[$depth] = '';
-	$att = '';
-	$sep = ' ';
-	foreach ($attrs as $k => $v) {
-		$delim = str_contains($v, "'") ? '"' : "'";
-		$val = xml_entites_html($v);
-		$att .= $sep . $k . '=' . $delim
-			. ($delim !== '"' ? str_replace('&quot;', '"', $val) : $val)
-			. $delim;
-		$sep = "\n $depth";
-	}
-	$phraseur->depth .= '  ';
-	$phraseur->contenu[$phraseur->depth] = '';
-	$phraseur->ouvrant[$phraseur->depth] = $name . $att;
-	$phraseur->reperes[$phraseur->depth] = xml_get_current_line_number($phraseur->sax);
+    $depth = $phraseur->depth;
+
+    $t = $phraseur->ouvrant[$depth] ?? ' ';
+    // espace initial signifie: deja integree au resultat
+    if ($t[0] != ' ') {
+        $phraseur->res .= '<' . $t . '>';
+        $phraseur->ouvrant[$depth] = ' ' . $t;
+    }
+    $t = $phraseur->contenu[$depth];
+    // n'indenter que s'il y a un separateur avant
+    $phraseur->res .= preg_replace("/[\n\t ]+$/", "\n$depth", $t);
+    $phraseur->contenu[$depth] = '';
+    $att = '';
+    $sep = ' ';
+    foreach ($attrs as $k => $v) {
+        $delim = str_contains($v, "'") ? '"' : "'";
+        $val = xml_entites_html($v);
+        $att .= $sep . $k . '=' . $delim
+            . ($delim !== '"' ? str_replace('&quot;', '"', $val) : $val)
+            . $delim;
+        $sep = "\n $depth";
+    }
+    $phraseur->depth .= '  ';
+    $phraseur->contenu[$phraseur->depth] = '';
+    $phraseur->ouvrant[$phraseur->depth] = $name . $att;
+    $phraseur->reperes[$phraseur->depth] = xml_get_current_line_number($phraseur->sax);
 }
 
 function xml_finElement($phraseur, $name, $fusion_bal = false) {
-	$ouv = $phraseur->ouvrant[$phraseur->depth];
-
-	if ($ouv[0] != ' ') {
-		$phraseur->ouvrant[$phraseur->depth] = ' ' . $ouv;
-	} else {
-		$ouv = '';
-	}
-	$t = $phraseur->contenu[$phraseur->depth];
-	$phraseur->depth = substr($phraseur->depth, 2);
-	$t = preg_replace("/[\n\t ]+$/", "\n" . $phraseur->depth, $t);
-
-	// fusion <balise></balise> en <balise />.
-	// ATTENTION,  certains clients http croient que fusion ==> pas d'atttributs
-	// en particulier pour les balises Script et A.
-	// en presence d'attributs ne le faire que si la DTD est dispo et d'accord
-	// (param fusion_bal)
-
-	if ($t || ($ouv != $name && !$fusion_bal)) {
-		$phraseur->res .= ($ouv ? ('<' . $ouv . '>') : '') . $t . '</' . $name . '>';
-	} else {
-		$phraseur->res .= ($ouv ? ('<' . $ouv . ' />') : ('</' . $name . '>'));
-	}
+    $ouv = $phraseur->ouvrant[$phraseur->depth];
+
+    if ($ouv[0] != ' ') {
+        $phraseur->ouvrant[$phraseur->depth] = ' ' . $ouv;
+    } else {
+        $ouv = '';
+    }
+    $t = $phraseur->contenu[$phraseur->depth];
+    $phraseur->depth = substr($phraseur->depth, 2);
+    $t = preg_replace("/[\n\t ]+$/", "\n" . $phraseur->depth, $t);
+
+    // fusion <balise></balise> en <balise />.
+    // ATTENTION,  certains clients http croient que fusion ==> pas d'atttributs
+    // en particulier pour les balises Script et A.
+    // en presence d'attributs ne le faire que si la DTD est dispo et d'accord
+    // (param fusion_bal)
+
+    if ($t || ($ouv != $name && !$fusion_bal)) {
+        $phraseur->res .= ($ouv ? ('<' . $ouv . '>') : '') . $t . '</' . $name . '>';
+    } else {
+        $phraseur->res .= ($ouv ? ('<' . $ouv . ' />') : ('</' . $name . '>'));
+    }
 }
 
 function xml_textElement($phraseur, $data) {
-	$depth = $phraseur->depth;
-	$phraseur->contenu[$depth] .= preg_match('/^script/', $phraseur->ouvrant[$depth])
-		? $data
-		: xml_entites_html($data);
+    $depth = $phraseur->depth;
+    $phraseur->contenu[$depth] .= preg_match('/^script/', $phraseur->ouvrant[$depth])
+        ? $data
+        : xml_entites_html($data);
 }
 
 function xml_piElement($phraseur, $target, $data) {
-	$depth = $phraseur->depth;
-
-	if (strtolower($target) != 'php') {
-		$phraseur->contenu[$depth] .= $data;
-	} else {
-		ob_start();
-		eval($data);
-		$data = ob_get_contents();
-		ob_end_clean();
-		$phraseur->contenu[$depth] .= $data;
-	}
+    $depth = $phraseur->depth;
+
+    if (strtolower($target) != 'php') {
+        $phraseur->contenu[$depth] .= $data;
+    } else {
+        ob_start();
+        eval($data);
+        $data = ob_get_contents();
+        ob_end_clean();
+        $phraseur->contenu[$depth] .= $data;
+    }
 }
 
 
 function xml_defaultElement($phraseur, $data) {
-	$depth = $phraseur->depth;
+    $depth = $phraseur->depth;
 
-	if (!isset($phraseur->contenu[$depth])) {
-		$phraseur->contenu[$depth] = '';
-	}
-	$phraseur->contenu[$depth] .= $data;
+    if (!isset($phraseur->contenu[$depth])) {
+        $phraseur->contenu[$depth] = '';
+    }
+    $phraseur->contenu[$depth] .= $data;
 }
 
 function xml_parsestring($phraseur, $data) {
-	$phraseur->contenu[$phraseur->depth] = '';
-
-	if (!xml_parse($phraseur->sax, $data, true)) {
-		coordonnees_erreur(
-			$phraseur,
-			xml_error_string(xml_get_error_code($phraseur->sax))
-			. "<br />\n" .
-			($phraseur->depth
-				? '(' .
-					_T('erreur_balise_non_fermee') .
-					' <tt>' .
-					$phraseur->ouvrant[$phraseur->depth] .
-					'</tt> ' .
-					_T('ligne') .
-					' ' .
-					$phraseur->reperes[$phraseur->depth] .
-					") <br />\n"
-				: '')
-		);
-	}
+    $phraseur->contenu[$phraseur->depth] = '';
+
+    if (!xml_parse($phraseur->sax, $data, true)) {
+        coordonnees_erreur(
+            $phraseur,
+            xml_error_string(xml_get_error_code($phraseur->sax))
+            . "<br />\n" .
+            ($phraseur->depth
+                ? '(' .
+                    _T('erreur_balise_non_fermee') .
+                    ' <tt>' .
+                    $phraseur->ouvrant[$phraseur->depth] .
+                    '</tt> ' .
+                    _T('ligne') .
+                    ' ' .
+                    $phraseur->reperes[$phraseur->depth] .
+                    ") <br />\n"
+                : '')
+        );
+    }
 }
 
 function coordonnees_erreur($phraseur, $msg) {
-	$entete_length = substr_count($phraseur->entete, "\n");
-	$phraseur->err[] = [
-		$msg,
-		xml_get_current_line_number($phraseur->sax) + $entete_length,
-		xml_get_current_column_number($phraseur->sax)
-	];
+    $entete_length = substr_count($phraseur->entete, "\n");
+    $phraseur->err[] = [
+        $msg,
+        xml_get_current_line_number($phraseur->sax) + $entete_length,
+        xml_get_current_column_number($phraseur->sax)
+    ];
 }
 
 function xml_sax_dist($page, $apply = false, $phraseur = null, $doctype = '', $charset = null) {
-	if (is_null($charset)) {
-		$charset = $GLOBALS['meta']['charset'];
-	}
-	if ($apply) {
-		ob_start();
-		$r = is_array($apply) ? $page(...$apply) : $page();
-		$page = ob_get_contents();
-		ob_end_clean();
-		// fonction sans aucun "echo", ca doit etre le resultat
-		if (!$page) {
-			$page = $r;
-		}
-	}
-
-	if (!$page) {
-		return '';
-	}
-	// charger la DTD et transcoder les entites,
-	// et escamoter le doctype que sax mange en php5 mais pas en  php4
-	if (!$doctype) {
-		if (!$r = analyser_doctype($page)) {
-			$page = _MESSAGE_DOCTYPE . _DOCTYPE_ECRIRE
-				. preg_replace(_REGEXP_DOCTYPE, '', $page);
-			$r = analyser_doctype($page);
-		}
-		[$entete, $avail, $grammaire, $rotlvl] = array_pad($r, 4, null);
-		$page = substr($page, strlen($entete));
-	} else {
-		$avail = 'SYSTEM';
-		$grammaire = $doctype;
-		$rotlvl = basename($grammaire);
-	}
-
-	include_spip('xml/analyser_dtd');
-	$dtc = charger_dtd($grammaire, $avail, $rotlvl);
-	$page = sax_bug($page, $dtc, $charset);
-
-	// compatibilite Tidy espace public
-	if (!$phraseur) {
-		$indenter_xml = charger_fonction('indenter', 'xml');
-
-		return $indenter_xml($page, $apply);
-	}
-
-	$xml_parser = xml_parser_create($charset);
-
-	xml_set_element_handler(
-		$xml_parser,
-		[$phraseur, 'debutElement'],
-		[$phraseur, 'finElement']
-	);
-
-	xml_set_character_data_handler(
-		$xml_parser,
-		[$phraseur, 'textElement']
-	);
-
-	xml_set_processing_instruction_handler(
-		$xml_parser,
-		[$phraseur, 'piElement']
-	);
-
-	xml_set_default_handler(
-		$xml_parser,
-		[$phraseur, 'defaultElement']
-	);
-
-	xml_parser_set_option($xml_parser, XML_OPTION_CASE_FOLDING, false);
-
-	$phraseur->sax = $xml_parser;
-	if (isset($entete)) {
-		$phraseur->entete = $entete;
-	}
-	$phraseur->page = $page;
-	$phraseur->dtc = $dtc;
-	$phraseur->phraserTout($xml_parser, $page);
-	xml_parser_free($xml_parser);
-	$phraseur->sax = '';
-
-	return $phraseur;
+    if (is_null($charset)) {
+        $charset = $GLOBALS['meta']['charset'];
+    }
+    if ($apply) {
+        ob_start();
+        $r = is_array($apply) ? $page(...$apply) : $page();
+        $page = ob_get_contents();
+        ob_end_clean();
+        // fonction sans aucun "echo", ca doit etre le resultat
+        if (!$page) {
+            $page = $r;
+        }
+    }
+
+    if (!$page) {
+        return '';
+    }
+    // charger la DTD et transcoder les entites,
+    // et escamoter le doctype que sax mange en php5 mais pas en  php4
+    if (!$doctype) {
+        if (!$r = analyser_doctype($page)) {
+            $page = _MESSAGE_DOCTYPE . _DOCTYPE_ECRIRE
+                . preg_replace(_REGEXP_DOCTYPE, '', $page);
+            $r = analyser_doctype($page);
+        }
+        [$entete, $avail, $grammaire, $rotlvl] = array_pad($r, 4, null);
+        $page = substr($page, strlen($entete));
+    } else {
+        $avail = 'SYSTEM';
+        $grammaire = $doctype;
+        $rotlvl = basename($grammaire);
+    }
+
+    include_spip('xml/analyser_dtd');
+    $dtc = charger_dtd($grammaire, $avail, $rotlvl);
+    $page = sax_bug($page, $dtc, $charset);
+
+    // compatibilite Tidy espace public
+    if (!$phraseur) {
+        $indenter_xml = charger_fonction('indenter', 'xml');
+
+        return $indenter_xml($page, $apply);
+    }
+
+    $xml_parser = xml_parser_create($charset);
+
+    xml_set_element_handler(
+        $xml_parser,
+        [$phraseur, 'debutElement'],
+        [$phraseur, 'finElement']
+    );
+
+    xml_set_character_data_handler(
+        $xml_parser,
+        [$phraseur, 'textElement']
+    );
+
+    xml_set_processing_instruction_handler(
+        $xml_parser,
+        [$phraseur, 'piElement']
+    );
+
+    xml_set_default_handler(
+        $xml_parser,
+        [$phraseur, 'defaultElement']
+    );
+
+    xml_parser_set_option($xml_parser, XML_OPTION_CASE_FOLDING, false);
+
+    $phraseur->sax = $xml_parser;
+    if (isset($entete)) {
+        $phraseur->entete = $entete;
+    }
+    $phraseur->page = $page;
+    $phraseur->dtc = $dtc;
+    $phraseur->phraserTout($xml_parser, $page);
+    xml_parser_free($xml_parser);
+    $phraseur->sax = '';
+
+    return $phraseur;
 }
 
 // SAX ne dit pas si une Entite est dans un attribut ou non.
@@ -242,24 +242,24 @@ 
 // sinon on se rabat sur ce qu'en connait SPIP en standard.
 
 function sax_bug($data, $dtc, $charset = null) {
-	if (is_null($charset)) {
-		$charset = $GLOBALS['meta']['charset'];
-	}
-
-	if ($dtc) {
-		$trans = [];
-
-		foreach ($dtc->entites as $k => $v) {
-			if (!strpos(' amp lt gt quot ', (string) $k)) {
-				$trans["&$k;"] = $v;
-			}
-		}
-		$data = strtr($data, $trans);
-	} else {
-		$data = html2unicode($data, true);
-	}
-
-	return unicode2charset($data, $charset);
+    if (is_null($charset)) {
+        $charset = $GLOBALS['meta']['charset'];
+    }
+
+    if ($dtc) {
+        $trans = [];
+
+        foreach ($dtc->entites as $k => $v) {
+            if (!strpos(' amp lt gt quot ', (string) $k)) {
+                $trans["&$k;"] = $v;
+            }
+        }
+        $data = strtr($data, $trans);
+    } else {
+        $data = html2unicode($data, true);
+    }
+
+    return unicode2charset($data, $charset);
 }
 
 // Retirer < ? xml... ? > et autre PI, ainsi que les commentaires en debut
@@ -269,48 +269,48 @@ 
 // les autres formats RSS n'ont pas de DTD,
 // mais un XML Schema que SPIP ne fait pas encore lire.
 function analyser_doctype($data) {
-	if (!preg_match(_REGEXP_DOCTYPE, $data, $page)) {
-		if (preg_match(_REGEXP_XML, $data, $page)) {
-			[, $entete, $topelement] = $page;
-			if ($topelement == 'rss') {
-				return [
-					$entete,
-					'PUBLIC',
-					_DOCTYPE_RSS,
-					'rss-0.91.dtd'
-				];
-			} else {
-				$dtd = $topelement . '.dtd';
-				$f = find_in_path($dtd);
-				if (file_exists($f)) {
-					return [$entete, 'SYSTEM', $f, $dtd];
-				}
-			}
-		}
-		spip_logger()->info('Dtd pas vu pour ' . substr($data, 0, 100));
-
-		return [];
-	}
-	[$entete, , $topelement, $avail, $suite] = $page;
-
-	if (!preg_match('/^"([^"]*)"\s*(.*)$/', $suite, $r) && !preg_match("/^'([^']*)'\s*(.*)$/", $suite, $r)) {
-		return [];
-	}
-	[, $rotlvl, $suite] = $r;
-
-	if (!$suite) {
-		if ($avail != 'SYSTEM') {
-			return [];
-		}
-		$grammaire = $rotlvl;
-		$rotlvl = '';
-	} else {
-		if (!preg_match('/^"([^"]*)"\s*$/', $suite, $r) && !preg_match("/^'([^']*)'\s*$/", $suite, $r)) {
-			return [];
-		}
-
-		$grammaire = $r[1];
-	}
-
-	return [$entete, $avail, $grammaire, $rotlvl];
+    if (!preg_match(_REGEXP_DOCTYPE, $data, $page)) {
+        if (preg_match(_REGEXP_XML, $data, $page)) {
+            [, $entete, $topelement] = $page;
+            if ($topelement == 'rss') {
+                return [
+                    $entete,
+                    'PUBLIC',
+                    _DOCTYPE_RSS,
+                    'rss-0.91.dtd'
+                ];
+            } else {
+                $dtd = $topelement . '.dtd';
+                $f = find_in_path($dtd);
+                if (file_exists($f)) {
+                    return [$entete, 'SYSTEM', $f, $dtd];
+                }
+            }
+        }
+        spip_logger()->info('Dtd pas vu pour ' . substr($data, 0, 100));
+
+        return [];
+    }
+    [$entete, , $topelement, $avail, $suite] = $page;
+
+    if (!preg_match('/^"([^"]*)"\s*(.*)$/', $suite, $r) && !preg_match("/^'([^']*)'\s*(.*)$/", $suite, $r)) {
+        return [];
+    }
+    [, $rotlvl, $suite] = $r;
+
+    if (!$suite) {
+        if ($avail != 'SYSTEM') {
+            return [];
+        }
+        $grammaire = $rotlvl;
+        $rotlvl = '';
+    } else {
+        if (!preg_match('/^"([^"]*)"\s*$/', $suite, $r) && !preg_match("/^'([^']*)'\s*$/", $suite, $r)) {
+            return [];
+        }
+
+        $grammaire = $r[1];
+    }
+
+    return [$entete, $avail, $grammaire, $rotlvl];
 }

Spacing +21 added lines, -21 removed lines

@@ -40,8 +40,8 @@ 
 	$t = $phraseur->ouvrant[$depth] ?? ' ';
 	// espace initial signifie: deja integree au resultat
 	if ($t[0] != ' ') {
-		$phraseur->res .= '<' . $t . '>';
-		$phraseur->ouvrant[$depth] = ' ' . $t;
+		$phraseur->res .= '<'.$t.'>';
+		$phraseur->ouvrant[$depth] = ' '.$t;
 	}
 	$t = $phraseur->contenu[$depth];
 	// n'indenter que s'il y a un separateur avant
@@ -52,14 +52,14 @@ 
 	foreach ($attrs as $k => $v) {
 		$delim = str_contains($v, "'") ? '"' : "'";
 		$val = xml_entites_html($v);
-		$att .= $sep . $k . '=' . $delim
+		$att .= $sep.$k.'='.$delim
 			. ($delim !== '"' ? str_replace('&quot;', '"', $val) : $val)
 			. $delim;
 		$sep = "\n $depth";
 	}
 	$phraseur->depth .= '  ';
 	$phraseur->contenu[$phraseur->depth] = '';
-	$phraseur->ouvrant[$phraseur->depth] = $name . $att;
+	$phraseur->ouvrant[$phraseur->depth] = $name.$att;
 	$phraseur->reperes[$phraseur->depth] = xml_get_current_line_number($phraseur->sax);
 }
 
@@ -67,13 +67,13 @@ 
 	$ouv = $phraseur->ouvrant[$phraseur->depth];
 
 	if ($ouv[0] != ' ') {
-		$phraseur->ouvrant[$phraseur->depth] = ' ' . $ouv;
+		$phraseur->ouvrant[$phraseur->depth] = ' '.$ouv;
 	} else {
 		$ouv = '';
 	}
 	$t = $phraseur->contenu[$phraseur->depth];
 	$phraseur->depth = substr($phraseur->depth, 2);
-	$t = preg_replace("/[\n\t ]+$/", "\n" . $phraseur->depth, $t);
+	$t = preg_replace("/[\n\t ]+$/", "\n".$phraseur->depth, $t);
 
 	// fusion <balise></balise> en <balise />.
 	// ATTENTION,  certains clients http croient que fusion ==> pas d'atttributs
@@ -82,9 +82,9 @@ 
 	// (param fusion_bal)
 
 	if ($t || ($ouv != $name && !$fusion_bal)) {
-		$phraseur->res .= ($ouv ? ('<' . $ouv . '>') : '') . $t . '</' . $name . '>';
+		$phraseur->res .= ($ouv ? ('<'.$ouv.'>') : '').$t.'</'.$name.'>';
 	} else {
-		$phraseur->res .= ($ouv ? ('<' . $ouv . ' />') : ('</' . $name . '>'));
+		$phraseur->res .= ($ouv ? ('<'.$ouv.' />') : ('</'.$name.'>'));
 	}
 }
 
@@ -126,16 +126,16 @@ 
 		coordonnees_erreur(
 			$phraseur,
 			xml_error_string(xml_get_error_code($phraseur->sax))
-			. "<br />\n" .
+			. "<br />\n".
 			($phraseur->depth
-				? '(' .
-					_T('erreur_balise_non_fermee') .
-					' <tt>' .
-					$phraseur->ouvrant[$phraseur->depth] .
-					'</tt> ' .
-					_T('ligne') .
-					' ' .
-					$phraseur->reperes[$phraseur->depth] .
+				? '('.
+					_T('erreur_balise_non_fermee').
+					' <tt>'.
+					$phraseur->ouvrant[$phraseur->depth].
+					'</tt> '.
+					_T('ligne').
+					' '.
+					$phraseur->reperes[$phraseur->depth].
 					") <br />\n"
 				: '')
 		);
@@ -173,7 +173,7 @@ 
 	// et escamoter le doctype que sax mange en php5 mais pas en  php4
 	if (!$doctype) {
 		if (!$r = analyser_doctype($page)) {
-			$page = _MESSAGE_DOCTYPE . _DOCTYPE_ECRIRE
+			$page = _MESSAGE_DOCTYPE._DOCTYPE_ECRIRE
 				. preg_replace(_REGEXP_DOCTYPE, '', $page);
 			$r = analyser_doctype($page);
 		}
@@ -280,18 +280,18 @@ 
 					'rss-0.91.dtd'
 				];
 			} else {
-				$dtd = $topelement . '.dtd';
+				$dtd = $topelement.'.dtd';
 				$f = find_in_path($dtd);
 				if (file_exists($f)) {
 					return [$entete, 'SYSTEM', $f, $dtd];
 				}
 			}
 		}
-		spip_logger()->info('Dtd pas vu pour ' . substr($data, 0, 100));
+		spip_logger()->info('Dtd pas vu pour '.substr($data, 0, 100));
 
 		return [];
 	}
-	[$entete, , $topelement, $avail, $suite] = $page;
+	[$entete,, $topelement, $avail, $suite] = $page;
 
 	if (!preg_match('/^"([^"]*)"\s*(.*)$/', $suite, $r) && !preg_match("/^'([^']*)'\s*(.*)$/", $suite, $r)) {
 		return [];

ecrire/xml/valider.php

Indentation +315 added lines, -315 removed lines

@@ -10,7 +10,7 @@ 
 \***************************************************************************/
 
 if (!defined('_ECRIRE_INC_VERSION')) {
-	return;
+    return;
 }
 
 /**
@@ -22,317 +22,317 @@ 
  **/
 class ValidateurXML
 {
-	public function validerElement($phraseur, $name, $attrs) {
-		if (!($p = isset($this->dtc->elements[$name]))) {
-			if ($p = strpos((string) $name, ':')) {
-				$name = substr((string) $name, $p + 1);
-				$p = isset($this->dtc->elements[$name]);
-			}
-			if (!$p) {
-				coordonnees_erreur($this, " <b>$name</b>&nbsp;: "
-					. _T('zxml_inconnu_balise'));
-
-				return;
-			}
-		}
-		// controler les filles illegitimes, ca suffit
-		$depth = $this->depth;
-		$ouvrant = $this->ouvrant;
-		#spip_logger()->info("trouve $name apres " . $ouvrant[$depth]);
-		if (isset($ouvrant[$depth]) && preg_match('/^\s*(\w+)/', (string) $ouvrant[$depth], $r)) {
-			$pere = $r[1];
-			#spip_logger()->info("pere $pere");
-			if (isset($this->dtc->elements[$pere])) {
-				$fils = $this->dtc->elements[$pere];
-				#spip_logger()->info("rejeton $name fils " . @join(',',$fils));
-				if (!($p = @in_array($name, $fils)) && ($p = strpos((string) $name, ':'))) {
-					$p = substr((string) $name, $p + 1);
-					$p = @in_array($p, $fils);
-				}
-				if (!$p) {
-					$bons_peres = @implode('</b>, <b>', $this->dtc->peres[$name]);
-					coordonnees_erreur($this, " <b>$name</b> "
-						. _T('zxml_non_fils')
-						. ' <b>'
-						. $pere
-						. '</b>'
-						. ($bons_peres ? '<p style="font-size: 80%"> ' . _T('zxml_mais_de') . ' <b>' . $bons_peres . '</b></p>' : ''));
-				} elseif ($this->dtc->regles[$pere][0] == '/') {
-					$frat = substr((string) $depth, 2);
-					if (!isset($this->fratrie[$frat])) {
-						$this->fratrie[$frat] = '';
-					}
-					$this->fratrie[$frat] .= "$name ";
-				}
-			}
-		}
-		// Init de la suite des balises a memoriser si regle difficile
-		if ($this->dtc->regles[$name] && $this->dtc->regles[$name][0] == '/') {
-			$this->fratrie[$depth] = '';
-		}
-		if (isset($this->dtc->attributs[$name])) {
-			foreach ($this->dtc->attributs[$name] as $n => $v) {
-				if ($v[1] == '#REQUIRED' && !isset($attrs[$n])) {
-					coordonnees_erreur($this, " <b>$n</b>"
-						. '&nbsp;:&nbsp;'
-						. _T('zxml_obligatoire_attribut')
-						. " <b>$name</b>");
-				}
-			}
-		}
-	}
-
-	public function validerAttribut($phraseur, $name, $val, $bal) {
-		// Si la balise est inconnue, eviter d'insister
-		if (!isset($this->dtc->attributs[$bal])) {
-			return;
-		}
-
-		$a = $this->dtc->attributs[$bal];
-		if (!isset($a[$name])) {
-			$bons = implode(', ', array_keys($a));
-			if ($bons) {
-				$bons = " title=' " .
-					_T('zxml_connus_attributs') .
-					'&nbsp;: ' .
-					$bons .
-					"'";
-			}
-			$bons .= " style='font-weight: bold'";
-			coordonnees_erreur($this, " <b>$name</b> "
-				. _T('zxml_inconnu_attribut') . ' ' . _T('zxml_de')
-				. " <a$bons>$bal</a> ("
-				. _T('zxml_survoler')
-				. ')');
-		} else {
-			$type = $a[$name][0];
-			if (!preg_match('/^\w+$/', (string) $type)) {
-				$this->valider_motif($phraseur, $name, $val, $bal, $type);
-			} else {
-				if (method_exists($this, $f = 'validerAttribut_' . $type)) {
-					$this->$f($phraseur, $name, $val, $bal);
-				}
-			}
-			#		else spip_logger()->info("$type type d'attribut inconnu");
-		}
-	}
-
-	public function validerAttribut_NMTOKEN($phraseur, $name, $val, $bal) {
-		$this->valider_motif($phraseur, $name, $val, $bal, _REGEXP_NMTOKEN);
-	}
-
-	public function validerAttribut_NMTOKENS($phraseur, $name, $val, $bal) {
-		$this->valider_motif($phraseur, $name, $val, $bal, _REGEXP_NMTOKENS);
-	}
-
-	public function validerAttribut_ID($phraseur, $name, $val, $bal) {
-		if (isset($this->ids[$val])) {
-			[$l, $c] = $this->ids[$val];
-			coordonnees_erreur($this, " <p><b>$val</b> "
-				. _T('zxml_valeur_attribut')
-				. " <b>$name</b> "
-				. _T('zxml_de')
-				. " <b>$bal</b> "
-				. _T('zxml_vu')
-				. " (L$l,C$c)");
-		} else {
-			$this->valider_motif($phraseur, $name, $val, $bal, _REGEXP_ID);
-			$this->ids[$val] = [xml_get_current_line_number($phraseur), xml_get_current_column_number($phraseur)];
-		}
-	}
-
-	public function validerAttribut_IDREF($phraseur, $name, $val, $bal) {
-		$this->idrefs[] = [$val, xml_get_current_line_number($phraseur), xml_get_current_column_number($phraseur)];
-	}
-
-	public function validerAttribut_IDREFS($phraseur, $name, $val, $bal) {
-		$this->idrefss[] = [$val, xml_get_current_line_number($phraseur), xml_get_current_column_number($phraseur)];
-	}
-
-	public function valider_motif($phraseur, $name, $val, $bal, $motif) {
-		if (!preg_match($motif, (string) $val)) {
-			coordonnees_erreur($this, "<b>$val</b> "
-				. _T('zxml_valeur_attribut')
-				. " <b>$name</b> "
-				. _T('zxml_de')
-				. " <b>$bal</b> "
-				. _T('zxml_non_conforme')
-				. '</p><p>'
-				. '<b>' . $motif . '</b>');
-		}
-	}
-
-	public function valider_idref($nom, $ligne, $col) {
-		if (!isset($this->ids[$nom])) {
-			$this->err[] = [" <p><b>$nom</b> " . _T('zxml_inconnu_id'), $ligne, $col];
-		}
-	}
-
-	public function valider_passe2() {
-		if (!$this->err) {
-			foreach ($this->idrefs as $idref) {
-				[$nom, $ligne, $col] = $idref;
-				$this->valider_idref($nom, $ligne, $col);
-			}
-			foreach ($this->idrefss as $idref) {
-				[$noms, $ligne, $col] = $idref;
-				foreach (preg_split('/\s+/', (string) $noms) as $nom) {
-					$this->valider_idref($nom, $ligne, $col);
-				}
-			}
-		}
-	}
-
-	public function debutElement($phraseur, $name, $attrs) {
-		if ($this->dtc->elements) {
-			$this->validerElement($phraseur, $name, $attrs);
-		}
-
-		if ($f = $this->process['debut']) {
-			$f($this, $name, $attrs);
-		}
-		$depth = $this->depth;
-		$this->debuts[$depth] = strlen((string) $this->res);
-		foreach ($attrs as $k => $v) {
-			$this->validerAttribut($phraseur, $k, $v, $name);
-		}
-	}
-
-	public function finElement($phraseur, $name) {
-		$depth = $this->depth;
-		$contenu = $this->contenu;
-
-		$n = strlen((string) $this->res);
-		$c = strlen(trim((string) $contenu[$depth]));
-		$k = $this->debuts[$depth];
-
-		$regle = $this->dtc->regles[$name] ?? false;
-		$vide = ($regle == 'EMPTY');
-		// controler que les balises devant etre vides le sont
-		if ($vide) {
-			if ($n != $k + $c) {
-				coordonnees_erreur($this, " <p><b>$name</b> " . _T('zxml_nonvide_balise'));
-			}
-			// pour les regles PCDATA ou iteration de disjonction, tout est fait
-		} elseif ($regle && $regle != '*') {
-			if ($regle == '+') {
-				// iteration de disjonction non vide: 1 balise au -
-				if ($n == $k) {
-					coordonnees_erreur($this, "<p>\n<b>$name</b> "
-						. _T('zxml_vide_balise'));
-				}
-			} else {
-				$f = $this->fratrie[substr((string) $depth, 2)] ?? null;
-				if (is_null($f) || !preg_match($regle, (string) $f)) {
-					coordonnees_erreur(
-						$this,
-						" <p>\n<b>$name</b> "
-						. _T('zxml_succession_fils_incorrecte')
-						. '&nbsp;: <b>'
-						. $f
-						. '</b>'
-					);
-				}
-			}
-		}
-		if ($f = $this->process['fin']) {
-			$f($this, $name, $vide);
-		}
-	}
-
-	public function textElement($phraseur, $data) {
-		if (trim((string) $data)) {
-			$d = $this->depth;
-			$d = $this->ouvrant[$d];
-			preg_match('/^\s*(\S+)/', (string) $d, $m);
-			if (isset($this->dtc->pcdata[$m[1]]) && $this->dtc->pcdata[$m[1]]) {
-				coordonnees_erreur($this, ' <p><b>' . $m[1] . '</b> '
-					. _T('zxml_nonvide_balise')); // message a affiner
-			}
-		}
-		if ($f = $this->process['text']) {
-			$f($this, $data);
-		}
-	}
-
-	public function piElement($phraseur, $target, $data) {
-		if ($f = $this->process['pi']) {
-			$f($this, $target, $data);
-		}
-	}
-
-	// Denonciation des entitees XML inconnues
-	// Pour contourner le bug de conception de SAX qui ne signale pas si elles
-	// sont dans un attribut, les  entites les plus frequentes ont ete
-	// transcodees au prealable  (sauf & < > " que SAX traite correctement).
-	// On ne les verra donc pas passer a cette etape, contrairement a ce que
-	// le source de la page laisse legitimement supposer.
-
-	public function defaultElement($phraseur, $data) {
-		if (
-			!preg_match('/^<!--/', (string) $data)
-			&& preg_match_all('/&([^;]*)?/', (string) $data, $r, PREG_SET_ORDER)
-		) {
-			foreach ($r as $m) {
-				[$t, $e] = $m;
-				if (!isset($this->dtc->entites[$e])) {
-					coordonnees_erreur($this, " <b>$e</b> "
-						. _T('zxml_inconnu_entite')
-						. ' ');
-				}
-			}
-		}
-		if (isset($this->process['default']) && ($f = $this->process['default'])) {
-			$f($this, $data);
-		}
-	}
-
-	public function phraserTout($phraseur, $data) {
-		xml_parsestring($this, $data);
-
-		if (!$this->dtc || preg_match(',^' . _MESSAGE_DOCTYPE . ',', (string) $data)) {
-			$this->err[] = ['DOCTYPE ?', 0, 0];
-		} else {
-			$this->valider_passe2();
-		}
-	}
-
-	/**
-	 * Constructeur
-	 *
-	 * @param array $process ?
-	 **/
-	public function __construct($process = []) {
-		if (is_array($process)) {
-			$this->process = $process;
-		}
-	}
-
-	public $ids = [];
-	public $idrefs = [];
-	public $idrefss = [];
-	public $debuts = [];
-	public $fratrie = [];
-
-	public $dtc = null;
-	public $sax = null;
-	public $depth = '';
-	public $entete = '';
-	public $page = '';
-	public $res = '';
-	public array $err = [];
-	public array $contenu = [];
-	public array $versions = [];
-
-	public array $ouvrant = [];
-	public array $reperes = [];
-	public array $process = [
-		'debut' => 'xml_debutElement',
-		'fin' => 'xml_finElement',
-		'text' => 'xml_textElement',
-		'pi' => 'xml_piElement',
-		'default' => 'xml_defaultElement'
-	];
+    public function validerElement($phraseur, $name, $attrs) {
+        if (!($p = isset($this->dtc->elements[$name]))) {
+            if ($p = strpos((string) $name, ':')) {
+                $name = substr((string) $name, $p + 1);
+                $p = isset($this->dtc->elements[$name]);
+            }
+            if (!$p) {
+                coordonnees_erreur($this, " <b>$name</b>&nbsp;: "
+                    . _T('zxml_inconnu_balise'));
+
+                return;
+            }
+        }
+        // controler les filles illegitimes, ca suffit
+        $depth = $this->depth;
+        $ouvrant = $this->ouvrant;
+        #spip_logger()->info("trouve $name apres " . $ouvrant[$depth]);
+        if (isset($ouvrant[$depth]) && preg_match('/^\s*(\w+)/', (string) $ouvrant[$depth], $r)) {
+            $pere = $r[1];
+            #spip_logger()->info("pere $pere");
+            if (isset($this->dtc->elements[$pere])) {
+                $fils = $this->dtc->elements[$pere];
+                #spip_logger()->info("rejeton $name fils " . @join(',',$fils));
+                if (!($p = @in_array($name, $fils)) && ($p = strpos((string) $name, ':'))) {
+                    $p = substr((string) $name, $p + 1);
+                    $p = @in_array($p, $fils);
+                }
+                if (!$p) {
+                    $bons_peres = @implode('</b>, <b>', $this->dtc->peres[$name]);
+                    coordonnees_erreur($this, " <b>$name</b> "
+                        . _T('zxml_non_fils')
+                        . ' <b>'
+                        . $pere
+                        . '</b>'
+                        . ($bons_peres ? '<p style="font-size: 80%"> ' . _T('zxml_mais_de') . ' <b>' . $bons_peres . '</b></p>' : ''));
+                } elseif ($this->dtc->regles[$pere][0] == '/') {
+                    $frat = substr((string) $depth, 2);
+                    if (!isset($this->fratrie[$frat])) {
+                        $this->fratrie[$frat] = '';
+                    }
+                    $this->fratrie[$frat] .= "$name ";
+                }
+            }
+        }
+        // Init de la suite des balises a memoriser si regle difficile
+        if ($this->dtc->regles[$name] && $this->dtc->regles[$name][0] == '/') {
+            $this->fratrie[$depth] = '';
+        }
+        if (isset($this->dtc->attributs[$name])) {
+            foreach ($this->dtc->attributs[$name] as $n => $v) {
+                if ($v[1] == '#REQUIRED' && !isset($attrs[$n])) {
+                    coordonnees_erreur($this, " <b>$n</b>"
+                        . '&nbsp;:&nbsp;'
+                        . _T('zxml_obligatoire_attribut')
+                        . " <b>$name</b>");
+                }
+            }
+        }
+    }
+
+    public function validerAttribut($phraseur, $name, $val, $bal) {
+        // Si la balise est inconnue, eviter d'insister
+        if (!isset($this->dtc->attributs[$bal])) {
+            return;
+        }
+
+        $a = $this->dtc->attributs[$bal];
+        if (!isset($a[$name])) {
+            $bons = implode(', ', array_keys($a));
+            if ($bons) {
+                $bons = " title=' " .
+                    _T('zxml_connus_attributs') .
+                    '&nbsp;: ' .
+                    $bons .
+                    "'";
+            }
+            $bons .= " style='font-weight: bold'";
+            coordonnees_erreur($this, " <b>$name</b> "
+                . _T('zxml_inconnu_attribut') . ' ' . _T('zxml_de')
+                . " <a$bons>$bal</a> ("
+                . _T('zxml_survoler')
+                . ')');
+        } else {
+            $type = $a[$name][0];
+            if (!preg_match('/^\w+$/', (string) $type)) {
+                $this->valider_motif($phraseur, $name, $val, $bal, $type);
+            } else {
+                if (method_exists($this, $f = 'validerAttribut_' . $type)) {
+                    $this->$f($phraseur, $name, $val, $bal);
+                }
+            }
+            #		else spip_logger()->info("$type type d'attribut inconnu");
+        }
+    }
+
+    public function validerAttribut_NMTOKEN($phraseur, $name, $val, $bal) {
+        $this->valider_motif($phraseur, $name, $val, $bal, _REGEXP_NMTOKEN);
+    }
+
+    public function validerAttribut_NMTOKENS($phraseur, $name, $val, $bal) {
+        $this->valider_motif($phraseur, $name, $val, $bal, _REGEXP_NMTOKENS);
+    }
+
+    public function validerAttribut_ID($phraseur, $name, $val, $bal) {
+        if (isset($this->ids[$val])) {
+            [$l, $c] = $this->ids[$val];
+            coordonnees_erreur($this, " <p><b>$val</b> "
+                . _T('zxml_valeur_attribut')
+                . " <b>$name</b> "
+                . _T('zxml_de')
+                . " <b>$bal</b> "
+                . _T('zxml_vu')
+                . " (L$l,C$c)");
+        } else {
+            $this->valider_motif($phraseur, $name, $val, $bal, _REGEXP_ID);
+            $this->ids[$val] = [xml_get_current_line_number($phraseur), xml_get_current_column_number($phraseur)];
+        }
+    }
+
+    public function validerAttribut_IDREF($phraseur, $name, $val, $bal) {
+        $this->idrefs[] = [$val, xml_get_current_line_number($phraseur), xml_get_current_column_number($phraseur)];
+    }
+
+    public function validerAttribut_IDREFS($phraseur, $name, $val, $bal) {
+        $this->idrefss[] = [$val, xml_get_current_line_number($phraseur), xml_get_current_column_number($phraseur)];
+    }
+
+    public function valider_motif($phraseur, $name, $val, $bal, $motif) {
+        if (!preg_match($motif, (string) $val)) {
+            coordonnees_erreur($this, "<b>$val</b> "
+                . _T('zxml_valeur_attribut')
+                . " <b>$name</b> "
+                . _T('zxml_de')
+                . " <b>$bal</b> "
+                . _T('zxml_non_conforme')
+                . '</p><p>'
+                . '<b>' . $motif . '</b>');
+        }
+    }
+
+    public function valider_idref($nom, $ligne, $col) {
+        if (!isset($this->ids[$nom])) {
+            $this->err[] = [" <p><b>$nom</b> " . _T('zxml_inconnu_id'), $ligne, $col];
+        }
+    }
+
+    public function valider_passe2() {
+        if (!$this->err) {
+            foreach ($this->idrefs as $idref) {
+                [$nom, $ligne, $col] = $idref;
+                $this->valider_idref($nom, $ligne, $col);
+            }
+            foreach ($this->idrefss as $idref) {
+                [$noms, $ligne, $col] = $idref;
+                foreach (preg_split('/\s+/', (string) $noms) as $nom) {
+                    $this->valider_idref($nom, $ligne, $col);
+                }
+            }
+        }
+    }
+
+    public function debutElement($phraseur, $name, $attrs) {
+        if ($this->dtc->elements) {
+            $this->validerElement($phraseur, $name, $attrs);
+        }
+
+        if ($f = $this->process['debut']) {
+            $f($this, $name, $attrs);
+        }
+        $depth = $this->depth;
+        $this->debuts[$depth] = strlen((string) $this->res);
+        foreach ($attrs as $k => $v) {
+            $this->validerAttribut($phraseur, $k, $v, $name);
+        }
+    }
+
+    public function finElement($phraseur, $name) {
+        $depth = $this->depth;
+        $contenu = $this->contenu;
+
+        $n = strlen((string) $this->res);
+        $c = strlen(trim((string) $contenu[$depth]));
+        $k = $this->debuts[$depth];
+
+        $regle = $this->dtc->regles[$name] ?? false;
+        $vide = ($regle == 'EMPTY');
+        // controler que les balises devant etre vides le sont
+        if ($vide) {
+            if ($n != $k + $c) {
+                coordonnees_erreur($this, " <p><b>$name</b> " . _T('zxml_nonvide_balise'));
+            }
+            // pour les regles PCDATA ou iteration de disjonction, tout est fait
+        } elseif ($regle && $regle != '*') {
+            if ($regle == '+') {
+                // iteration de disjonction non vide: 1 balise au -
+                if ($n == $k) {
+                    coordonnees_erreur($this, "<p>\n<b>$name</b> "
+                        . _T('zxml_vide_balise'));
+                }
+            } else {
+                $f = $this->fratrie[substr((string) $depth, 2)] ?? null;
+                if (is_null($f) || !preg_match($regle, (string) $f)) {
+                    coordonnees_erreur(
+                        $this,
+                        " <p>\n<b>$name</b> "
+                        . _T('zxml_succession_fils_incorrecte')
+                        . '&nbsp;: <b>'
+                        . $f
+                        . '</b>'
+                    );
+                }
+            }
+        }
+        if ($f = $this->process['fin']) {
+            $f($this, $name, $vide);
+        }
+    }
+
+    public function textElement($phraseur, $data) {
+        if (trim((string) $data)) {
+            $d = $this->depth;
+            $d = $this->ouvrant[$d];
+            preg_match('/^\s*(\S+)/', (string) $d, $m);
+            if (isset($this->dtc->pcdata[$m[1]]) && $this->dtc->pcdata[$m[1]]) {
+                coordonnees_erreur($this, ' <p><b>' . $m[1] . '</b> '
+                    . _T('zxml_nonvide_balise')); // message a affiner
+            }
+        }
+        if ($f = $this->process['text']) {
+            $f($this, $data);
+        }
+    }
+
+    public function piElement($phraseur, $target, $data) {
+        if ($f = $this->process['pi']) {
+            $f($this, $target, $data);
+        }
+    }
+
+    // Denonciation des entitees XML inconnues
+    // Pour contourner le bug de conception de SAX qui ne signale pas si elles
+    // sont dans un attribut, les  entites les plus frequentes ont ete
+    // transcodees au prealable  (sauf & < > " que SAX traite correctement).
+    // On ne les verra donc pas passer a cette etape, contrairement a ce que
+    // le source de la page laisse legitimement supposer.
+
+    public function defaultElement($phraseur, $data) {
+        if (
+            !preg_match('/^<!--/', (string) $data)
+            && preg_match_all('/&([^;]*)?/', (string) $data, $r, PREG_SET_ORDER)
+        ) {
+            foreach ($r as $m) {
+                [$t, $e] = $m;
+                if (!isset($this->dtc->entites[$e])) {
+                    coordonnees_erreur($this, " <b>$e</b> "
+                        . _T('zxml_inconnu_entite')
+                        . ' ');
+                }
+            }
+        }
+        if (isset($this->process['default']) && ($f = $this->process['default'])) {
+            $f($this, $data);
+        }
+    }
+
+    public function phraserTout($phraseur, $data) {
+        xml_parsestring($this, $data);
+
+        if (!$this->dtc || preg_match(',^' . _MESSAGE_DOCTYPE . ',', (string) $data)) {
+            $this->err[] = ['DOCTYPE ?', 0, 0];
+        } else {
+            $this->valider_passe2();
+        }
+    }
+
+    /**
+     * Constructeur
+     *
+     * @param array $process ?
+     **/
+    public function __construct($process = []) {
+        if (is_array($process)) {
+            $this->process = $process;
+        }
+    }
+
+    public $ids = [];
+    public $idrefs = [];
+    public $idrefss = [];
+    public $debuts = [];
+    public $fratrie = [];
+
+    public $dtc = null;
+    public $sax = null;
+    public $depth = '';
+    public $entete = '';
+    public $page = '';
+    public $res = '';
+    public array $err = [];
+    public array $contenu = [];
+    public array $versions = [];
+
+    public array $ouvrant = [];
+    public array $reperes = [];
+    public array $process = [
+        'debut' => 'xml_debutElement',
+        'fin' => 'xml_finElement',
+        'text' => 'xml_textElement',
+        'pi' => 'xml_piElement',
+        'default' => 'xml_defaultElement'
+    ];
 }
 
 
@@ -342,8 +342,8 @@ 
  *
  **/
 function xml_valider_dist($page, $apply = false, $process = false, $doctype = '', $charset = null) {
-	$f = new ValidateurXML($process);
-	$sax = charger_fonction('sax', 'xml');
+    $f = new ValidateurXML($process);
+    $sax = charger_fonction('sax', 'xml');
 
-	return $sax($page, $apply, $f, $doctype, $charset);
+    return $sax($page, $apply, $f, $doctype, $charset);
 }

ecrire/xml/analyser_dtd.php

Indentation +309 added lines, -309 removed lines

@@ -10,58 +10,58 @@ 
 \***************************************************************************/
 
 if (!defined('_ECRIRE_INC_VERSION')) {
-	return;
+    return;
 }
 
 include_spip('xml/interfaces');
 
 function charger_dtd($grammaire, $avail, $rotlvl) {
-	$r = null;
-	static $dtd = []; # cache bien utile pour le validateur en boucle
-
-	if (isset($dtd[$grammaire])) {
-		return $dtd[$grammaire];
-	}
-
-	if ($avail == 'SYSTEM') {
-		$grammaire = find_in_path($grammaire);
-	}
-
-	$file = _DIR_CACHE_XML . preg_replace('/[^\w.]/', '_', (string) $rotlvl) . '.gz';
-
-	if (lire_fichier($file, $r)) {
-		if (!$grammaire) {
-			return [];
-		}
-		if ($avail == 'SYSTEM' && filemtime($file) < filemtime($grammaire)) {
-			$r = false;
-		}
-	}
-
-	if ($r) {
-		$dtc = unserialize($r);
-	} else {
-		spip_timer('dtd');
-		$dtc = new DTC();
-		// L'analyseur retourne un booleen de reussite et modifie $dtc.
-		// Retourner vide en cas d'echec
-		if (!analyser_dtd($grammaire, $avail, $dtc)) {
-			$dtc = [];
-		} else {
-			// tri final pour presenter les suggestions de corrections
-			foreach ($dtc->peres as $k => $v) {
-				asort($v);
-				$dtc->peres[$k] = $v;
-			}
-
-			spip_logger()->info("Analyser DTD $avail $grammaire (" . spip_timer('dtd') . ') ' . (is_countable($dtc->macros) ? count($dtc->macros) : 0) . ' macros, ' . (is_countable($dtc->elements) ? count($dtc->elements) : 0) . ' elements, ' . (is_countable($dtc->attributs) ? count($dtc->attributs) : 0) . " listes d'attributs, " . (is_countable($dtc->entites) ? count($dtc->entites) : 0) . ' entites');
-			#	$r = $dtc->regles; ksort($r);foreach($r as $l => $v) {$t=array_keys($dtc->attributs[$l]);echo "<b>$l</b> '$v' ", count($t), " attributs: ", join (', ',$t);$t=$dtc->peres[$l];echo "<br />",count($t), " peres: ", @join (', ',$t), "<br />\n";}exit;
-			ecrire_fichier($file, serialize($dtc), true);
-		}
-	}
-	$dtd[$grammaire] = $dtc;
-
-	return $dtc;
+    $r = null;
+    static $dtd = []; # cache bien utile pour le validateur en boucle
+
+    if (isset($dtd[$grammaire])) {
+        return $dtd[$grammaire];
+    }
+
+    if ($avail == 'SYSTEM') {
+        $grammaire = find_in_path($grammaire);
+    }
+
+    $file = _DIR_CACHE_XML . preg_replace('/[^\w.]/', '_', (string) $rotlvl) . '.gz';
+
+    if (lire_fichier($file, $r)) {
+        if (!$grammaire) {
+            return [];
+        }
+        if ($avail == 'SYSTEM' && filemtime($file) < filemtime($grammaire)) {
+            $r = false;
+        }
+    }
+
+    if ($r) {
+        $dtc = unserialize($r);
+    } else {
+        spip_timer('dtd');
+        $dtc = new DTC();
+        // L'analyseur retourne un booleen de reussite et modifie $dtc.
+        // Retourner vide en cas d'echec
+        if (!analyser_dtd($grammaire, $avail, $dtc)) {
+            $dtc = [];
+        } else {
+            // tri final pour presenter les suggestions de corrections
+            foreach ($dtc->peres as $k => $v) {
+                asort($v);
+                $dtc->peres[$k] = $v;
+            }
+
+            spip_logger()->info("Analyser DTD $avail $grammaire (" . spip_timer('dtd') . ') ' . (is_countable($dtc->macros) ? count($dtc->macros) : 0) . ' macros, ' . (is_countable($dtc->elements) ? count($dtc->elements) : 0) . ' elements, ' . (is_countable($dtc->attributs) ? count($dtc->attributs) : 0) . " listes d'attributs, " . (is_countable($dtc->entites) ? count($dtc->entites) : 0) . ' entites');
+            #	$r = $dtc->regles; ksort($r);foreach($r as $l => $v) {$t=array_keys($dtc->attributs[$l]);echo "<b>$l</b> '$v' ", count($t), " attributs: ", join (', ',$t);$t=$dtc->peres[$l];echo "<br />",count($t), " peres: ", @join (', ',$t), "<br />\n";}exit;
+            ecrire_fichier($file, serialize($dtc), true);
+        }
+    }
+    $dtd[$grammaire] = $dtc;
+
+    return $dtc;
 }
 
 // Compiler une regle de production en une Regexp qu'on appliquera sur la
@@ -73,137 +73,137 @@ 
 // et parentheser le tout pour que  | + * ? s'applique dessus.
 
 function compilerRegle($val) {
-	return str_replace(
-		'()',
-		'',
-		preg_replace(
-			'/\s*,\s*/',
-			'',
-			preg_replace(
-				'/(\w+)\s*/',
-				'(?:\1 )',
-				preg_replace(
-					'/\s*\)/',
-					')',
-					preg_replace(
-						'/\s*([(+*|?])\s*/',
-						'\1',
-						preg_replace('/\s*#\w+\s*[,|]?\s*/', '', (string) $val)
-					)
-				)
-			)
-		)
-	);
+    return str_replace(
+        '()',
+        '',
+        preg_replace(
+            '/\s*,\s*/',
+            '',
+            preg_replace(
+                '/(\w+)\s*/',
+                '(?:\1 )',
+                preg_replace(
+                    '/\s*\)/',
+                    ')',
+                    preg_replace(
+                        '/\s*([(+*|?])\s*/',
+                        '\1',
+                        preg_replace('/\s*#\w+\s*[,|]?\s*/', '', (string) $val)
+                    )
+                )
+            )
+        )
+    );
 }
 
 
 function analyser_dtd($loc, $avail, &$dtc) {
-	// creer le repertoire de cache si ce n'est fait
-	// (utile aussi pour le resultat de la compil)
-	$file = sous_repertoire(_DIR_CACHE_XML);
-	// si DTD locale, ignorer ce repertoire pour le moment
-	if ($avail == 'SYSTEM') {
-		$file = $loc;
-		if (_DIR_RACINE && str_starts_with((string) $file, (string) _DIR_RACINE)) {
-			$file = substr((string) $file, strlen((string) _DIR_RACINE));
-		}
-		$file = find_in_path($file);
-	} else {
-		$file .= preg_replace('/[^\w.]/', '_', (string) $loc);
-	}
-
-	$dtd = '';
-	if (@is_readable($file)) {
-		lire_fichier($file, $dtd);
-	} else {
-		if ($avail == 'PUBLIC') {
-			include_spip('inc/distant');
-			$dtd = recuperer_url($loc);
-			$dtd = trim($dtd['page'] ?? '');
-			if ($dtd) {
-				ecrire_fichier($file, $dtd, true);
-			}
-		}
-	}
-
-	$dtd = ltrim($dtd);
-	if (!$dtd) {
-		spip_logger()->info("DTD '$loc' ($file) inaccessible");
-
-		return false;
-	} else {
-		spip_logger()->info("analyse de la DTD $loc ");
-	}
-
-	while ($dtd) {
-		if ($dtd[0] != '<') {
-			$r = analyser_dtd_lexeme($dtd, $dtc, $loc);
-		} elseif ($dtd[1] != '!') {
-			$r = analyser_dtd_pi($dtd, $dtc, $loc);
-		} elseif ($dtd[2] == '[') {
-			$r = analyser_dtd_data($dtd, $dtc, $loc);
-		} else {
-			$r = match ($dtd[3]) {
-				'%' => analyser_dtd_data($dtd, $dtc, $loc),
-				'T' => analyser_dtd_attlist($dtd, $dtc, $loc),
-				'L' => analyser_dtd_element($dtd, $dtc, $loc),
-				'N' => analyser_dtd_entity($dtd, $dtc, $loc),
-				'O' => analyser_dtd_notation($dtd, $dtc, $loc),
-				'-' => analyser_dtd_comment($dtd, $dtc, $loc),
-				default => -1,
-			};
-		}
-		if (!is_string($r)) {
-			spip_logger()->info("erreur $r dans la DTD  " . substr($dtd, 0, 80) . '.....');
-
-			return false;
-		}
-		$dtd = $r;
-	}
-
-	return true;
+    // creer le repertoire de cache si ce n'est fait
+    // (utile aussi pour le resultat de la compil)
+    $file = sous_repertoire(_DIR_CACHE_XML);
+    // si DTD locale, ignorer ce repertoire pour le moment
+    if ($avail == 'SYSTEM') {
+        $file = $loc;
+        if (_DIR_RACINE && str_starts_with((string) $file, (string) _DIR_RACINE)) {
+            $file = substr((string) $file, strlen((string) _DIR_RACINE));
+        }
+        $file = find_in_path($file);
+    } else {
+        $file .= preg_replace('/[^\w.]/', '_', (string) $loc);
+    }
+
+    $dtd = '';
+    if (@is_readable($file)) {
+        lire_fichier($file, $dtd);
+    } else {
+        if ($avail == 'PUBLIC') {
+            include_spip('inc/distant');
+            $dtd = recuperer_url($loc);
+            $dtd = trim($dtd['page'] ?? '');
+            if ($dtd) {
+                ecrire_fichier($file, $dtd, true);
+            }
+        }
+    }
+
+    $dtd = ltrim($dtd);
+    if (!$dtd) {
+        spip_logger()->info("DTD '$loc' ($file) inaccessible");
+
+        return false;
+    } else {
+        spip_logger()->info("analyse de la DTD $loc ");
+    }
+
+    while ($dtd) {
+        if ($dtd[0] != '<') {
+            $r = analyser_dtd_lexeme($dtd, $dtc, $loc);
+        } elseif ($dtd[1] != '!') {
+            $r = analyser_dtd_pi($dtd, $dtc, $loc);
+        } elseif ($dtd[2] == '[') {
+            $r = analyser_dtd_data($dtd, $dtc, $loc);
+        } else {
+            $r = match ($dtd[3]) {
+                '%' => analyser_dtd_data($dtd, $dtc, $loc),
+                'T' => analyser_dtd_attlist($dtd, $dtc, $loc),
+                'L' => analyser_dtd_element($dtd, $dtc, $loc),
+                'N' => analyser_dtd_entity($dtd, $dtc, $loc),
+                'O' => analyser_dtd_notation($dtd, $dtc, $loc),
+                '-' => analyser_dtd_comment($dtd, $dtc, $loc),
+                default => -1,
+            };
+        }
+        if (!is_string($r)) {
+            spip_logger()->info("erreur $r dans la DTD  " . substr($dtd, 0, 80) . '.....');
+
+            return false;
+        }
+        $dtd = $r;
+    }
+
+    return true;
 }
 
 function analyser_dtd_comment($dtd, &$dtc, $grammaire) {
-	// ejecter les commentaires, surtout quand ils contiennent du code.
-	// Option /s car sur plusieurs lignes parfois
+    // ejecter les commentaires, surtout quand ils contiennent du code.
+    // Option /s car sur plusieurs lignes parfois
 
-	if (!preg_match('/^<!--.*?-->\s*(.*)$/s', (string) $dtd, $m)) {
-		return -6;
-	}
+    if (!preg_match('/^<!--.*?-->\s*(.*)$/s', (string) $dtd, $m)) {
+        return -6;
+    }
 
-	return $m[1];
+    return $m[1];
 }
 
 function analyser_dtd_pi($dtd, &$dtc, $grammaire) {
-	if (!preg_match('/^<\?.*?>\s*(.*)$/s', (string) $dtd, $m)) {
-		return -10;
-	}
+    if (!preg_match('/^<\?.*?>\s*(.*)$/s', (string) $dtd, $m)) {
+        return -10;
+    }
 
-	return $m[1];
+    return $m[1];
 }
 
 function analyser_dtd_lexeme($dtd, &$dtc, $grammaire) {
 
-	if (!preg_match(_REGEXP_ENTITY_DEF, (string) $dtd, $m)) {
-		return -9;
-	}
-
-	[, $s] = $m;
-	$n = $dtc->macros[$s];
-
-	if (is_array($n)) {
-		// en cas d'inclusion, l'espace de nom est le meme
-		// mais gaffe aux DTD dont l'URL est relative a l'engloblante
-		if (
-			$n[0] == 'PUBLIC' && !tester_url_absolue($n[1])
-		) {
-			$n[1] = substr((string) $grammaire, 0, strrpos((string) $grammaire, '/') + 1) . $n[1];
-		}
-		analyser_dtd($n[1], $n[0], $dtc);
-	}
-
-	return ltrim(substr((string) $dtd, strlen($m[0])));
+    if (!preg_match(_REGEXP_ENTITY_DEF, (string) $dtd, $m)) {
+        return -9;
+    }
+
+    [, $s] = $m;
+    $n = $dtc->macros[$s];
+
+    if (is_array($n)) {
+        // en cas d'inclusion, l'espace de nom est le meme
+        // mais gaffe aux DTD dont l'URL est relative a l'engloblante
+        if (
+            $n[0] == 'PUBLIC' && !tester_url_absolue($n[1])
+        ) {
+            $n[1] = substr((string) $grammaire, 0, strrpos((string) $grammaire, '/') + 1) . $n[1];
+        }
+        analyser_dtd($n[1], $n[0], $dtc);
+    }
+
+    return ltrim(substr((string) $dtd, strlen($m[0])));
 }
 
 // il faudrait gerer plus proprement les niveaux d'inclusion:
@@ -211,78 +211,78 @@ 
 
 function analyser_dtd_data($dtd, &$dtc, $grammaire) {
 
-	if (!preg_match(_REGEXP_INCLUDE_USE, (string) $dtd, $m)) {
-		return -11;
-	}
-	if (
-		!preg_match(
-			'/^((\s*<!(\[\s*%\s*[^;]*;\s*\[([^]<]*<[^>]*>)*[^]<]*\]\]>)|([^]>]*>))*[^]<]*)\]\]>\s*/s',
-			$m[2],
-			$r
-		)
-	) {
-		return -12;
-	}
-
-	return $dtc->macros[$m[1]] == 'INCLUDE'
-		? $r[1] . substr($m[2], strlen($r[0]))
-		: substr($m[2], strlen($r[0]));
+    if (!preg_match(_REGEXP_INCLUDE_USE, (string) $dtd, $m)) {
+        return -11;
+    }
+    if (
+        !preg_match(
+            '/^((\s*<!(\[\s*%\s*[^;]*;\s*\[([^]<]*<[^>]*>)*[^]<]*\]\]>)|([^]>]*>))*[^]<]*)\]\]>\s*/s',
+            $m[2],
+            $r
+        )
+    ) {
+        return -12;
+    }
+
+    return $dtc->macros[$m[1]] == 'INCLUDE'
+        ? $r[1] . substr($m[2], strlen($r[0]))
+        : substr($m[2], strlen($r[0]));
 }
 
 function analyser_dtd_notation($dtd, &$dtc, $grammaire) {
-	if (!preg_match('/^<!NOTATION.*?>\s*(.*)$/s', (string) $dtd, $m)) {
-		return -8;
-	}
-	spip_logger()->info('analyser_dtd_notation a ecrire');
+    if (!preg_match('/^<!NOTATION.*?>\s*(.*)$/s', (string) $dtd, $m)) {
+        return -8;
+    }
+    spip_logger()->info('analyser_dtd_notation a ecrire');
 
-	return $m[1];
+    return $m[1];
 }
 
 function analyser_dtd_entity($dtd, &$dtc, $grammaire) {
-	if (!preg_match(_REGEXP_ENTITY_DECL, (string) $dtd, $m)) {
-		return -2;
-	}
-
-	[$t, $term, $nom, $type, $k1, $k2, $k3, $k4, $k5, $k6, $c, $q, $alt, $dtd] = $m;
-
-	if (isset($dtc->macros[$nom]) && $dtc->macros[$nom]) {
-		return $dtd;
-	}
-	if (isset($dtc->entites[$nom])) {
-		spip_logger()->info("redefinition de l'entite $nom");
-	}
-	if ($k6) {
-		return $k6 . $dtd;
-	} // cas du synonyme complet
-	$val = expanserEntite(($k2 ? $k3 : ($k4 ? $k5 : $k6)), $dtc->macros);
-
-	// cas particulier double evaluation: 'PUBLIC "..." "...."'
-	if (preg_match('/(PUBLIC|SYSTEM)\s+"([^"]*)"\s*("([^"]*)")?\s*$/s', $val, $r)) {
-		[$t, $type, $val, $q, $alt] = $r;
-	}
-
-	if (!$term) {
-		$dtc->entites[$nom] = $val;
-	} elseif (!$type) {
-		$dtc->macros[$nom] = $val;
-	} else {
-		if ($type == 'SYSTEM' && !$alt) {
-			$alt = $val;
-		}
-		if (!$alt) {
-			$dtc->macros[$nom] = $val;
-		} else {
-			if (
-				$type == 'PUBLIC' && !str_contains($alt, '/')
-			) {
-				$alt = preg_replace(',/[^/]+$,', '/', (string) $grammaire)
-					. $alt;
-			}
-			$dtc->macros[$nom] = [$type, $alt];
-		}
-	}
-
-	return $dtd;
+    if (!preg_match(_REGEXP_ENTITY_DECL, (string) $dtd, $m)) {
+        return -2;
+    }
+
+    [$t, $term, $nom, $type, $k1, $k2, $k3, $k4, $k5, $k6, $c, $q, $alt, $dtd] = $m;
+
+    if (isset($dtc->macros[$nom]) && $dtc->macros[$nom]) {
+        return $dtd;
+    }
+    if (isset($dtc->entites[$nom])) {
+        spip_logger()->info("redefinition de l'entite $nom");
+    }
+    if ($k6) {
+        return $k6 . $dtd;
+    } // cas du synonyme complet
+    $val = expanserEntite(($k2 ? $k3 : ($k4 ? $k5 : $k6)), $dtc->macros);
+
+    // cas particulier double evaluation: 'PUBLIC "..." "...."'
+    if (preg_match('/(PUBLIC|SYSTEM)\s+"([^"]*)"\s*("([^"]*)")?\s*$/s', $val, $r)) {
+        [$t, $type, $val, $q, $alt] = $r;
+    }
+
+    if (!$term) {
+        $dtc->entites[$nom] = $val;
+    } elseif (!$type) {
+        $dtc->macros[$nom] = $val;
+    } else {
+        if ($type == 'SYSTEM' && !$alt) {
+            $alt = $val;
+        }
+        if (!$alt) {
+            $dtc->macros[$nom] = $val;
+        } else {
+            if (
+                $type == 'PUBLIC' && !str_contains($alt, '/')
+            ) {
+                $alt = preg_replace(',/[^/]+$,', '/', (string) $grammaire)
+                    . $alt;
+            }
+            $dtc->macros[$nom] = [$type, $alt];
+        }
+    }
+
+    return $dtd;
 }
 
 // Dresser le tableau des filles potentielles de l'element
@@ -295,71 +295,71 @@ 
 // Fin du controle en finElement
 
 function analyser_dtd_element($dtd, &$dtc, $grammaire) {
-	if (!preg_match('/^<!ELEMENT\s+([^>\s]+)([^>]*)>\s*(.*)$/s', (string) $dtd, $m)) {
-		return -3;
-	}
-
-	[, $nom, $contenu, $dtd] = $m;
-	$nom = expanserEntite($nom, $dtc->macros);
-
-	if (isset($dtc->elements[$nom])) {
-		spip_logger()->info("redefinition de l'element $nom dans la DTD");
-
-		return -4;
-	}
-	$filles = [];
-	$contenu = expanserEntite($contenu, $dtc->macros);
-	$val = $contenu ? compilerRegle($contenu) : '(?:EMPTY )';
-	if ($val == '(?:EMPTY )') {
-		$dtc->regles[$nom] = 'EMPTY';
-	} elseif ($val == '(?:ANY )') {
-		$dtc->regles[$nom] = 'ANY';
-	} else {
-		$last = substr((string) $val, -1);
-		$dtc->regles[$nom] = preg_match('/ \w/', (string) $val) || (!empty($last) && !str_contains('*+?', $last))
-			? "/^$val$/"
-			: $last;
-		$filles = array_values(preg_split('/\W+/', (string) $val, -1, PREG_SPLIT_NO_EMPTY));
-
-		foreach ($filles as $k) {
-			if (!isset($dtc->peres[$k])) {
-				$dtc->peres[$k] = [];
-			}
-			if (!in_array($nom, $dtc->peres[$k])) {
-				$dtc->peres[$k][] = $nom;
-			}
-		}
-	}
-	$dtc->pcdata[$nom] = (!str_contains($contenu, '#PCDATA'));
-	$dtc->elements[$nom] = $filles;
-
-	return $dtd;
+    if (!preg_match('/^<!ELEMENT\s+([^>\s]+)([^>]*)>\s*(.*)$/s', (string) $dtd, $m)) {
+        return -3;
+    }
+
+    [, $nom, $contenu, $dtd] = $m;
+    $nom = expanserEntite($nom, $dtc->macros);
+
+    if (isset($dtc->elements[$nom])) {
+        spip_logger()->info("redefinition de l'element $nom dans la DTD");
+
+        return -4;
+    }
+    $filles = [];
+    $contenu = expanserEntite($contenu, $dtc->macros);
+    $val = $contenu ? compilerRegle($contenu) : '(?:EMPTY )';
+    if ($val == '(?:EMPTY )') {
+        $dtc->regles[$nom] = 'EMPTY';
+    } elseif ($val == '(?:ANY )') {
+        $dtc->regles[$nom] = 'ANY';
+    } else {
+        $last = substr((string) $val, -1);
+        $dtc->regles[$nom] = preg_match('/ \w/', (string) $val) || (!empty($last) && !str_contains('*+?', $last))
+            ? "/^$val$/"
+            : $last;
+        $filles = array_values(preg_split('/\W+/', (string) $val, -1, PREG_SPLIT_NO_EMPTY));
+
+        foreach ($filles as $k) {
+            if (!isset($dtc->peres[$k])) {
+                $dtc->peres[$k] = [];
+            }
+            if (!in_array($nom, $dtc->peres[$k])) {
+                $dtc->peres[$k][] = $nom;
+            }
+        }
+    }
+    $dtc->pcdata[$nom] = (!str_contains($contenu, '#PCDATA'));
+    $dtc->elements[$nom] = $filles;
+
+    return $dtd;
 }
 
 
 function analyser_dtd_attlist($dtd, &$dtc, $grammaire) {
-	if (!preg_match('/^<!ATTLIST\s+(\S+)\s+([^>]*)>\s*(.*)/s', (string) $dtd, $m)) {
-		return -5;
-	}
-
-	[, $nom, $val, $dtd] = $m;
-	$nom = expanserEntite($nom, $dtc->macros);
-	$val = expanserEntite($val, $dtc->macros);
-	if (!isset($dtc->attributs[$nom])) {
-		$dtc->attributs[$nom] = [];
-	}
-
-	if (preg_match_all("/\s*(\S+)\s+(([(][^)]*[)])|(\S+))\s+([^\s']*)(\s*'[^']*')?/", $val, $r2, PREG_SET_ORDER)) {
-		foreach ($r2 as $m2) {
-			$v = preg_match('/^\w+$/', $m2[2]) ? $m2[2]
-				: ('/^' . preg_replace('/\s+/', '', $m2[2]) . '$/');
-			$m21 = expanserEntite($m2[1], $dtc->macros);
-			$m25 = expanserEntite($m2[5], $dtc->macros);
-			$dtc->attributs[$nom][$m21] = [$v, $m25];
-		}
-	}
-
-	return $dtd;
+    if (!preg_match('/^<!ATTLIST\s+(\S+)\s+([^>]*)>\s*(.*)/s', (string) $dtd, $m)) {
+        return -5;
+    }
+
+    [, $nom, $val, $dtd] = $m;
+    $nom = expanserEntite($nom, $dtc->macros);
+    $val = expanserEntite($val, $dtc->macros);
+    if (!isset($dtc->attributs[$nom])) {
+        $dtc->attributs[$nom] = [];
+    }
+
+    if (preg_match_all("/\s*(\S+)\s+(([(][^)]*[)])|(\S+))\s+([^\s']*)(\s*'[^']*')?/", $val, $r2, PREG_SET_ORDER)) {
+        foreach ($r2 as $m2) {
+            $v = preg_match('/^\w+$/', $m2[2]) ? $m2[2]
+                : ('/^' . preg_replace('/\s+/', '', $m2[2]) . '$/');
+            $m21 = expanserEntite($m2[1], $dtc->macros);
+            $m25 = expanserEntite($m2[5], $dtc->macros);
+            $dtc->attributs[$nom][$m21] = [$v, $m25];
+        }
+    }
+
+    return $dtd;
 }
 
 
@@ -375,26 +375,26 @@ 
  * @return string|array
  **/
 function expanserEntite($val, $macros = []) {
-	static $vu = [];
-	if (!is_string($val)) {
-		return $vu;
-	}
-
-	if (preg_match_all(_REGEXP_ENTITY_USE, $val, $r, PREG_SET_ORDER)) {
-		foreach ($r as $m) {
-			$ent = $m[1];
-			// il peut valoir ""
-			if (!isset($macros[$ent])) {
-				spip_logger()->info("Entite $ent inconnu");
-			} else {
-				if (!isset($vu[$ent])) {
-					$vu[$ent] = 0;
-				}
-				++$vu[$ent];
-				$val = str_replace($m[0], $macros[$ent], $val);
-			}
-		}
-	}
-
-	return trim(preg_replace('/\s+/', ' ', $val));
+    static $vu = [];
+    if (!is_string($val)) {
+        return $vu;
+    }
+
+    if (preg_match_all(_REGEXP_ENTITY_USE, $val, $r, PREG_SET_ORDER)) {
+        foreach ($r as $m) {
+            $ent = $m[1];
+            // il peut valoir ""
+            if (!isset($macros[$ent])) {
+                spip_logger()->info("Entite $ent inconnu");
+            } else {
+                if (!isset($vu[$ent])) {
+                    $vu[$ent] = 0;
+                }
+                ++$vu[$ent];
+                $val = str_replace($m[0], $macros[$ent], $val);
+            }
+        }
+    }
+
+    return trim(preg_replace('/\s+/', ' ', $val));
 }

Spacing +7 added lines, -7 removed lines

@@ -27,7 +27,7 @@ 
 		$grammaire = find_in_path($grammaire);
 	}
 
-	$file = _DIR_CACHE_XML . preg_replace('/[^\w.]/', '_', (string) $rotlvl) . '.gz';
+	$file = _DIR_CACHE_XML.preg_replace('/[^\w.]/', '_', (string) $rotlvl).'.gz';
 
 	if (lire_fichier($file, $r)) {
 		if (!$grammaire) {
@@ -54,7 +54,7 @@ 
 				$dtc->peres[$k] = $v;
 			}
 
-			spip_logger()->info("Analyser DTD $avail $grammaire (" . spip_timer('dtd') . ') ' . (is_countable($dtc->macros) ? count($dtc->macros) : 0) . ' macros, ' . (is_countable($dtc->elements) ? count($dtc->elements) : 0) . ' elements, ' . (is_countable($dtc->attributs) ? count($dtc->attributs) : 0) . " listes d'attributs, " . (is_countable($dtc->entites) ? count($dtc->entites) : 0) . ' entites');
+			spip_logger()->info("Analyser DTD $avail $grammaire (".spip_timer('dtd').') '.(is_countable($dtc->macros) ? count($dtc->macros) : 0).' macros, '.(is_countable($dtc->elements) ? count($dtc->elements) : 0).' elements, '.(is_countable($dtc->attributs) ? count($dtc->attributs) : 0)." listes d'attributs, ".(is_countable($dtc->entites) ? count($dtc->entites) : 0).' entites');
 			#	$r = $dtc->regles; ksort($r);foreach($r as $l => $v) {$t=array_keys($dtc->attributs[$l]);echo "<b>$l</b> '$v' ", count($t), " attributs: ", join (', ',$t);$t=$dtc->peres[$l];echo "<br />",count($t), " peres: ", @join (', ',$t), "<br />\n";}exit;
 			ecrire_fichier($file, serialize($dtc), true);
 		}
@@ -154,7 +154,7 @@ 
 			};
 		}
 		if (!is_string($r)) {
-			spip_logger()->info("erreur $r dans la DTD  " . substr($dtd, 0, 80) . '.....');
+			spip_logger()->info("erreur $r dans la DTD  ".substr($dtd, 0, 80).'.....');
 
 			return false;
 		}
@@ -198,7 +198,7 @@ 
 		if (
 			$n[0] == 'PUBLIC' && !tester_url_absolue($n[1])
 		) {
-			$n[1] = substr((string) $grammaire, 0, strrpos((string) $grammaire, '/') + 1) . $n[1];
+			$n[1] = substr((string) $grammaire, 0, strrpos((string) $grammaire, '/') + 1).$n[1];
 		}
 		analyser_dtd($n[1], $n[0], $dtc);
 	}
@@ -225,7 +225,7 @@ 
 	}
 
 	return $dtc->macros[$m[1]] == 'INCLUDE'
-		? $r[1] . substr($m[2], strlen($r[0]))
+		? $r[1].substr($m[2], strlen($r[0]))
 		: substr($m[2], strlen($r[0]));
 }
 
@@ -252,7 +252,7 @@ 
 		spip_logger()->info("redefinition de l'entite $nom");
 	}
 	if ($k6) {
-		return $k6 . $dtd;
+		return $k6.$dtd;
 	} // cas du synonyme complet
 	$val = expanserEntite(($k2 ? $k3 : ($k4 ? $k5 : $k6)), $dtc->macros);
 
@@ -352,7 +352,7 @@ 
 	if (preg_match_all("/\s*(\S+)\s+(([(][^)]*[)])|(\S+))\s+([^\s']*)(\s*'[^']*')?/", $val, $r2, PREG_SET_ORDER)) {
 		foreach ($r2 as $m2) {
 			$v = preg_match('/^\w+$/', $m2[2]) ? $m2[2]
-				: ('/^' . preg_replace('/\s+/', '', $m2[2]) . '$/');
+				: ('/^'.preg_replace('/\s+/', '', $m2[2]).'$/');
 			$m21 = expanserEntite($m2[1], $dtc->macros);
 			$m25 = expanserEntite($m2[5], $dtc->macros);
 			$dtc->attributs[$nom][$m21] = [$v, $m25];