spip / SPIP

ecrire/base/abstract_sql.php

Indentation +693 added lines, -693 removed lines

@@ -25,7 +25,7 @@ 
  */
 
 if (!defined('_ECRIRE_INC_VERSION')) {
-	return;
+    return;
 }
 
 /** Version de l'API SQL */
@@ -45,39 +45,39 @@ 
  *     contexte de l'erreur
  **/
 function sql_error_backtrace($compil_info = false) {
-	$trace = debug_backtrace();
-	$caller = array_shift($trace);
-	while (count($trace) and (empty($trace[0]['file']) or $trace[0]['file'] === $caller['file'] or $trace[0]['file'] === __FILE__)) {
-		array_shift($trace);
-	}
-
-	if ($compil_info) {
-		$contexte_compil = [
-			$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
-		];
-
-		return $contexte_compil;
-	}
-
-	$message = count($trace) ? $trace[0]['file'] . ' L' . $trace[0]['line'] : '';
-	$f = [];
-	while (count($trace) and $t = array_shift($trace)) {
-		if (in_array($t['function'], ['include_once', 'include_spip', 'find_in_path'])) {
-			break;
-		}
-		$f[] = $t['function'];
-	}
-	if (count($f)) {
-		$message .= ' [' . implode('(),', $f) . '()]';
-	}
-
-	return $message;
+    $trace = debug_backtrace();
+    $caller = array_shift($trace);
+    while (count($trace) and (empty($trace[0]['file']) or $trace[0]['file'] === $caller['file'] or $trace[0]['file'] === __FILE__)) {
+        array_shift($trace);
+    }
+
+    if ($compil_info) {
+        $contexte_compil = [
+            $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
+        ];
+
+        return $contexte_compil;
+    }
+
+    $message = count($trace) ? $trace[0]['file'] . ' L' . $trace[0]['line'] : '';
+    $f = [];
+    while (count($trace) and $t = array_shift($trace)) {
+        if (in_array($t['function'], ['include_once', 'include_spip', 'find_in_path'])) {
+            break;
+        }
+        $f[] = $t['function'];
+    }
+    if (count($f)) {
+        $message .= ' [' . implode('(),', $f) . '()]';
+    }
+
+    return $message;
 }
 
 
@@ -102,16 +102,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) or !$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) or !$f) {
+            return $f;
+        }
+        $sql_serveur[$serveur][$ins_sql] = $f;
+    }
+
+    return $sql_serveur[$serveur][$ins_sql];
 }
 
 /**
@@ -133,23 +133,23 @@ 
  *     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) {
-		if (function_exists($f = @$desc['get_charset'])) {
-			if ($f($c, $serveur, $option !== false)) {
-				return $c;
-			}
-		}
-	}
-	spip_log(
-		"SPIP ne connait pas les Charsets disponibles sur le serveur $serveur. Le serveur choisira seul.",
-		_LOG_AVERTISSEMENT
-	);
-
-	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) {
+        if (function_exists($f = @$desc['get_charset'])) {
+            if ($f($c, $serveur, $option !== false)) {
+                return $c;
+            }
+        }
+    }
+    spip_log(
+        "SPIP ne connait pas les Charsets disponibles sur le serveur $serveur. Le serveur choisira seul.",
+        _LOG_AVERTISSEMENT
+    );
+
+    return false;
 }
 
 
@@ -175,12 +175,12 @@ 
  *    Retourne true si elle reussie.
  **/
 function sql_set_charset($charset, $serveur = '', $option = true) {
-	$f = sql_serveur('set_charset', $serveur, $option === 'continue' or $option === false);
-	if (!is_string($f) or !$f) {
-		return false;
-	}
+    $f = sql_serveur('set_charset', $serveur, $option === 'continue' or $option === false);
+    if (!is_string($f) or !$f) {
+        return false;
+    }
 
-	return $f($charset, $serveur, $option !== false);
+    return $f($charset, $serveur, $option !== false);
 }
 
 
@@ -231,59 +231,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' or $option === false);
-	if (!is_string($f) or !$f) {
-		return false;
-	}
-
-	$debug = (defined('_VAR_MODE') and _VAR_MODE == 'debug');
-	if (($option !== false) and !$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' or $option === false);
+    if (!is_string($f) or !$f) {
+        return false;
+    }
+
+    $debug = (defined('_VAR_MODE') and _VAR_MODE == 'debug');
+    if (($option !== false) and !$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;
 }
 
 
@@ -320,16 +320,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);
 }
 
 
@@ -373,23 +373,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' or $option === false);
-	if (!is_string($f) or !$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' or $option === false);
+    if (!is_string($f) or !$f) {
+        return false;
+    }
+    $r = $f($from, $where, $groupby, $having, $serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 /**
@@ -421,16 +421,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' or $option === false);
-	if (!is_string($f) or !$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' or $option === false);
+    if (!is_string($f) or !$f) {
+        return false;
+    }
+    $r = $f($q, $serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 /**
@@ -453,12 +453,12 @@ 
  *    presentant une ligne de resultat d'une selection
  */
 function sql_fetch($res, $serveur = '', $option = true) {
-	$f = sql_serveur('fetch', $serveur, $option === 'continue' or $option === false);
-	if (!is_string($f) or !$f) {
-		return false;
-	}
+    $f = sql_serveur('fetch', $serveur, $option === 'continue' or $option === false);
+    if (!is_string($f) or !$f) {
+        return false;
+    }
 
-	return $f($res, null, $serveur, $option !== false);
+    return $f($res, null, $serveur, $option !== false);
 }
 
 
@@ -485,20 +485,20 @@ 
  *    presentant une ligne de resultat d'une selection
  */
 function sql_fetch_all($res, $serveur = '', $option = true) {
-	$rows = [];
-	if (!$res) {
-		return $rows;
-	}
-	$f = sql_serveur('fetch', $serveur, $option === 'continue' or $option === false);
-	if (!is_string($f) or !$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' or $option === false);
+    if (!is_string($f) or !$f) {
+        return [];
+    }
+    while ($r = $f($res, null, $serveur, $option !== false)) {
+        $rows[] = $r;
+    }
+    sql_free($res, $serveur);
+
+    return $rows;
 }
 
 /**
@@ -526,16 +526,16 @@ 
  *    Operation effectuée (true), sinon false.
  **/
 function sql_seek($res, $row_number, $serveur = '', $option = true) {
-	$f = sql_serveur('seek', $serveur, $option === 'continue' or $option === false);
-	if (!is_string($f) or !$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' or $option === false);
+    if (!is_string($f) or !$f) {
+        return false;
+    }
+    $r = $f($res, $row_number, $serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 
@@ -560,16 +560,16 @@ 
  *    False en cas d'erreur.
  **/
 function sql_listdbs($serveur = '', $option = true) {
-	$f = sql_serveur('listdbs', $serveur, $option === 'continue' or $option === false);
-	if (!is_string($f) or !$f) {
-		return false;
-	}
-	$r = $f($serveur);
-	if ($r === false) {
-		spip_sql_erreur($serveur);
-	}
-
-	return $r;
+    $f = sql_serveur('listdbs', $serveur, $option === 'continue' or $option === false);
+    if (!is_string($f) or !$f) {
+        return false;
+    }
+    $r = $f($serveur);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 
@@ -592,16 +592,16 @@ 
  *     - False en cas d'erreur.
  **/
 function sql_selectdb($nom, $serveur = '', $option = true) {
-	$f = sql_serveur('selectdb', $serveur, $option === 'continue' or $option === false);
-	if (!is_string($f) or !$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' or $option === false);
+    if (!is_string($f) or !$f) {
+        return false;
+    }
+    $r = $f($nom, $serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 /**
@@ -626,16 +626,16 @@ 
  *     - false en cas d'erreur.
  **/
 function sql_count($res, $serveur = '', $option = true) {
-	$f = sql_serveur('count', $serveur, $option === 'continue' or $option === false);
-	if (!is_string($f) or !$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' or $option === false);
+    if (!is_string($f) or !$f) {
+        return false;
+    }
+    $r = $f($res, $serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 /**
@@ -657,12 +657,12 @@ 
  *     True si réussi
  */
 function sql_free($res, $serveur = '', $option = true) {
-	$f = sql_serveur('free', $serveur, $option === 'continue' or $option === false);
-	if (!is_string($f) or !$f) {
-		return false;
-	}
+    $f = sql_serveur('free', $serveur, $option === 'continue' or $option === false);
+    if (!is_string($f) or !$f) {
+        return false;
+    }
 
-	return $f($res);
+    return $f($res);
 }
 
 
@@ -700,17 +700,17 @@ 
  *     - False en cas d'erreur.
  **/
 function sql_insert($table, $noms, $valeurs, $desc = [], $serveur = '', $option = true) {
-	$f = sql_serveur('insert', $serveur, $option === 'continue' or $option === false);
-	if (!is_string($f) or !$f) {
-		return false;
-	}
-	$r = $f($table, $noms, $valeurs, $desc, $serveur, $option !== false);
-	if ($r === false or $r === null) {
-		spip_sql_erreur($serveur);
-		$r = false;
-	}
-
-	return $r;
+    $f = sql_serveur('insert', $serveur, $option === 'continue' or $option === false);
+    if (!is_string($f) or !$f) {
+        return false;
+    }
+    $r = $f($table, $noms, $valeurs, $desc, $serveur, $option !== false);
+    if ($r === false or $r === null) {
+        spip_sql_erreur($serveur);
+        $r = false;
+    }
+
+    return $r;
 }
 
 /**
@@ -751,17 +751,17 @@ 
  *     - False en cas d'erreur.
  **/
 function sql_insertq($table, $couples = [], $desc = [], $serveur = '', $option = true) {
-	$f = sql_serveur('insertq', $serveur, $option === 'continue' or $option === false);
-	if (!is_string($f) or !$f) {
-		return false;
-	}
-	$r = $f($table, $couples, $desc, $serveur, $option !== false);
-	if ($r === false or $r === null) {
-		spip_sql_erreur($serveur);
-		$r = false;
-	}
-
-	return $r;
+    $f = sql_serveur('insertq', $serveur, $option === 'continue' or $option === false);
+    if (!is_string($f) or !$f) {
+        return false;
+    }
+    $r = $f($table, $couples, $desc, $serveur, $option !== false);
+    if ($r === false or $r === null) {
+        spip_sql_erreur($serveur);
+        $r = false;
+    }
+
+    return $r;
 }
 
 /**
@@ -796,17 +796,17 @@ 
  *     - False en cas d'erreur.
  **/
 function sql_insertq_multi($table, $couples = [], $desc = [], $serveur = '', $option = true) {
-	$f = sql_serveur('insertq_multi', $serveur, $option === 'continue' or $option === false);
-	if (!is_string($f) or !$f) {
-		return false;
-	}
-	$r = $f($table, $couples, $desc, $serveur, $option !== false);
-	if ($r === false or $r === null) {
-		spip_sql_erreur($serveur);
-		$r = false;
-	}
-
-	return $r;
+    $f = sql_serveur('insertq_multi', $serveur, $option === 'continue' or $option === false);
+    if (!is_string($f) or !$f) {
+        return false;
+    }
+    $r = $f($table, $couples, $desc, $serveur, $option !== false);
+    if ($r === false or $r === null) {
+        spip_sql_erreur($serveur);
+        $r = false;
+    }
+
+    return $r;
 }
 
 /**
@@ -846,16 +846,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' or $option === false);
-	if (!is_string($f) or !$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' or $option === false);
+    if (!is_string($f) or !$f) {
+        return false;
+    }
+    $r = $f($table, $exp, $where, $desc, $serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 
@@ -901,16 +901,16 @@ 
  *     - False en cas d'erreur.
  **/
 function sql_updateq($table, $exp, $where = '', $desc = [], $serveur = '', $option = true) {
-	$f = sql_serveur('updateq', $serveur, $option === 'continue' or $option === false);
-	if (!is_string($f) or !$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' or $option === false);
+    if (!is_string($f) or !$f) {
+        return false;
+    }
+    $r = $f($table, $exp, $where, $desc, $serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 /**
@@ -941,16 +941,16 @@ 
  *     - False en cas d'erreur.
  **/
 function sql_delete($table, $where = '', $serveur = '', $option = true) {
-	$f = sql_serveur('delete', $serveur, $option === 'continue' or $option === false);
-	if (!is_string($f) or !$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' or $option === false);
+    if (!is_string($f) or !$f) {
+        return false;
+    }
+    $r = $f($table, $where, $serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 /**
@@ -986,16 +986,16 @@ 
  *     - False en cas d'erreur.
  **/
 function sql_replace($table, $couples, $desc = [], $serveur = '', $option = true) {
-	$f = sql_serveur('replace', $serveur, $option === 'continue' or $option === false);
-	if (!is_string($f) or !$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' or $option === false);
+    if (!is_string($f) or !$f) {
+        return false;
+    }
+    $r = $f($table, $couples, $desc, $serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 
@@ -1033,16 +1033,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' or $option === false);
-	if (!is_string($f) or !$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' or $option === false);
+    if (!is_string($f) or !$f) {
+        return false;
+    }
+    $r = $f($table, $tab_couples, $desc, $serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 /**
@@ -1070,16 +1070,16 @@ 
  *     - False en cas d'erreur.
  **/
 function sql_drop_table($table, $exist = '', $serveur = '', $option = true) {
-	$f = sql_serveur('drop_table', $serveur, $option === 'continue' or $option === false);
-	if (!is_string($f) or !$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' or $option === false);
+    if (!is_string($f) or !$f) {
+        return false;
+    }
+    $r = $f($table, $exist, $serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 /**
@@ -1103,16 +1103,16 @@ 
  *     - true si la requête a réussie, false sinon
  */
 function sql_drop_view($table, $exist = '', $serveur = '', $option = true) {
-	$f = sql_serveur('drop_view', $serveur, $option === 'continue' or $option === false);
-	if (!is_string($f) or !$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' or $option === false);
+    if (!is_string($f) or !$f) {
+        return false;
+    }
+    $r = $f($table, $exist, $serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 /**
@@ -1136,18 +1136,18 @@ 
  *     Ressource à utiliser avec sql_fetch()
  **/
 function sql_showbase($spip = null, $serveur = '', $option = true) {
-	$f = sql_serveur('showbase', $serveur, $option === 'continue' or $option === false);
-	if (!is_string($f) or !$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' or $option === false);
+    if (!is_string($f) or !$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);
 }
 
 /**
@@ -1170,15 +1170,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;
 }
 
 /**
@@ -1211,31 +1211,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' or $option === false);
-	if (!is_string($f) or !$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' or $option === false);
+    if (!is_string($f) or !$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;
 }
 
 
@@ -1263,21 +1263,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' or $option === false);
-	if (!is_string($f) or !$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' or $option === false);
+    if (!is_string($f) or !$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);
 }
 
 
@@ -1323,24 +1323,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' or $option === false);
-	if (!is_string($f) or !$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' or $option === false);
+    if (!is_string($f) or !$f) {
+        return false;
+    }
+    $r = $f($nom, $champs, $cles, $autoinc, $temporary, $serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 /**
@@ -1358,16 +1358,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' or $option === false);
-	if (!is_string($f) or !$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' or $option === false);
+    if (!is_string($f) or !$f) {
+        return false;
+    }
+    $r = $f($nom, $serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 
@@ -1397,16 +1397,16 @@ 
  *     - false en cas d'échec.
  **/
 function sql_create_view($nom, $select_query, $serveur = '', $option = true) {
-	$f = sql_serveur('create_view', $serveur, $option === 'continue' or $option === false);
-	if (!is_string($f) or !$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' or $option === false);
+    if (!is_string($f) or !$f) {
+        return false;
+    }
+    $r = $f($nom, $select_query, $serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 /**
@@ -1435,12 +1435,12 @@ 
  *     Texte de sélection pour la requête
  */
 function sql_multi($sel, $lang, $serveur = '', $option = true) {
-	$f = sql_serveur('multi', $serveur, $option === 'continue' or $option === false);
-	if (!is_string($f) or !$f) {
-		return false;
-	}
+    $f = sql_serveur('multi', $serveur, $option === 'continue' or $option === false);
+    if (!is_string($f) or !$f) {
+        return false;
+    }
 
-	return $f($sel, $lang);
+    return $f($sel, $lang);
 }
 
 
@@ -1455,12 +1455,12 @@ 
  *      False si le serveur est indisponible
  */
 function sql_error($serveur = '') {
-	$f = sql_serveur('error', $serveur, 'continue');
-	if (!is_string($f) or !$f) {
-		return false;
-	}
+    $f = sql_serveur('error', $serveur, 'continue');
+    if (!is_string($f) or !$f) {
+        return false;
+    }
 
-	return $f('query inconnue', $serveur);
+    return $f('query inconnue', $serveur);
 }
 
 /**
@@ -1474,12 +1474,12 @@ 
  *      False si le serveur est indisponible
  */
 function sql_errno($serveur = '') {
-	$f = sql_serveur('errno', $serveur, 'continue');
-	if (!is_string($f) or !$f) {
-		return false;
-	}
+    $f = sql_serveur('errno', $serveur, 'continue');
+    if (!is_string($f) or !$f) {
+        return false;
+    }
 
-	return $f($serveur);
+    return $f($serveur);
 }
 
 /**
@@ -1497,16 +1497,16 @@ 
  * @return array           Tableau de l'explication
  */
 function sql_explain($q, $serveur = '', $option = true) {
-	$f = sql_serveur('explain', $serveur, 'continue');
-	if (!is_string($f) or !$f) {
-		return false;
-	}
-	$r = $f($q, $serveur, $option !== false);
-	if ($r === false) {
-		spip_sql_erreur($serveur);
-	}
-
-	return $r;
+    $f = sql_serveur('explain', $serveur, 'continue');
+    if (!is_string($f) or !$f) {
+        return false;
+    }
+    $r = $f($q, $serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 /**
@@ -1524,16 +1524,16 @@ 
  * @return bool            Toujours true
  */
 function sql_optimize($table, $serveur = '', $option = true) {
-	$f = sql_serveur('optimize', $serveur, $option === 'continue' or $option === false);
-	if (!is_string($f) or !$f) {
-		return false;
-	}
-	$r = $f($table, $serveur, $option !== false);
-	if ($r === false) {
-		spip_sql_erreur($serveur);
-	}
-
-	return $r;
+    $f = sql_serveur('optimize', $serveur, $option === 'continue' or $option === false);
+    if (!is_string($f) or !$f) {
+        return false;
+    }
+    $r = $f($table, $serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 /**
@@ -1553,16 +1553,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' or $option === false);
-	if (!is_string($f) or !$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' or $option === false);
+    if (!is_string($f) or !$f) {
+        return false;
+    }
+    $r = $f($table, $serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 
@@ -1587,16 +1587,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' or $option === false);
-	if (!is_string($f) or !$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' or $option === false);
+    if (!is_string($f) or !$f) {
+        return false;
+    }
+    $r = $f($ins, $serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 /**
@@ -1644,27 +1644,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;
 }
 
 
@@ -1721,22 +1721,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);
 }
 
 
@@ -1783,33 +1783,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];
 }
 
 /**
@@ -1827,9 +1827,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']);
 }
 
 /**
@@ -1865,16 +1865,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, 'continue');
-	if (!is_string($f) or !$f) {
-		return false;
-	}
-	$r = $f($serveur, $option !== false);
-	if ($r === false) {
-		spip_sql_erreur($serveur);
-	}
-
-	return $r;
+    $f = sql_serveur('preferer_transaction', $serveur, 'continue');
+    if (!is_string($f) or !$f) {
+        return false;
+    }
+    $r = $f($serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 ;
@@ -1899,16 +1899,16 @@ 
  *      false en cas d'erreur
  **/
 function sql_demarrer_transaction($serveur = '', $option = true) {
-	$f = sql_serveur('demarrer_transaction', $serveur, 'continue');
-	if (!is_string($f) or !$f) {
-		return false;
-	}
-	$r = $f($serveur, $option !== false);
-	if ($r === false) {
-		spip_sql_erreur($serveur);
-	}
-
-	return $r;
+    $f = sql_serveur('demarrer_transaction', $serveur, 'continue');
+    if (!is_string($f) or !$f) {
+        return false;
+    }
+    $r = $f($serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 ;
@@ -1933,16 +1933,16 @@ 
  *      false en cas d'erreur
  **/
 function sql_terminer_transaction($serveur = '', $option = true) {
-	$f = sql_serveur('terminer_transaction', $serveur, 'continue');
-	if (!is_string($f) or !$f) {
-		return false;
-	}
-	$r = $f($serveur, $option !== false);
-	if ($r === false) {
-		spip_sql_erreur($serveur);
-	}
-
-	return $r;
+    $f = sql_serveur('terminer_transaction', $serveur, 'continue');
+    if (!is_string($f) or !$f) {
+        return false;
+    }
+    $r = $f($serveur, $option !== false);
+    if ($r === false) {
+        spip_sql_erreur($serveur);
+    }
+
+    return $r;
 }
 
 ;
@@ -1969,12 +1969,12 @@ 
  *     Valeur hexadécimale attendue par le serveur SQL
  **/
 function sql_hex($val, $serveur = '', $option = true) {
-	$f = sql_serveur('hex', $serveur, $option === 'continue' or $option === false);
-	if (!is_string($f) or !$f) {
-		return false;
-	}
+    $f = sql_serveur('hex', $serveur, $option === 'continue' or $option === false);
+    if (!is_string($f) or !$f) {
+        return false;
+    }
 
-	return $f($val);
+    return $f($val);
 }
 
 /**
@@ -2000,12 +2000,12 @@ 
  *     La chaine echappee
  **/
 function sql_quote($val, $serveur = '', $type = '') {
-	$f = sql_serveur('quote', $serveur, true);
-	if (!is_string($f) or !$f) {
-		$f = '_q';
-	}
+    $f = sql_serveur('quote', $serveur, true);
+    if (!is_string($f) or !$f) {
+        $f = '_q';
+    }
 
-	return $f($val, $type);
+    return $f($val, $type);
 }
 
 /**
@@ -2030,12 +2030,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) or !$f) {
-		return false;
-	}
+    $f = sql_serveur('date_proche', $serveur, true);
+    if (!is_string($f) or !$f) {
+        return false;
+    }
 
-	return $f($champ, $interval, $unite);
+    return $f($champ, $interval, $unite);
 }
 
 /**
@@ -2071,26 +2071,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) or !$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($valeurs))) {
-		return ($not ? '0=0' : '0=1');
-	}
-
-	$f = sql_serveur('in', $serveur, $option === 'continue' or $option === false);
-	if (!is_string($f) or !$f) {
-		return false;
-	}
-
-	return $f($champ, $valeurs, $not ? 'NOT' : '', $serveur, $option !== false);
+    $quote = sql_serveur('quote', $serveur, true);
+    if (!is_string($quote) or !$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($valeurs))) {
+        return ($not ? '0=0' : '0=1');
+    }
+
+    $f = sql_serveur('in', $serveur, $option === 'continue' or $option === false);
+    if (!is_string($f) or !$f) {
+        return false;
+    }
+
+    return $f($champ, $valeurs, $not ? 'NOT' : '', $serveur, $option !== false);
 }
 
 /**
@@ -2107,19 +2107,19 @@ 
  * @param bool $option
  */
 function sql_in($champ, $valeurs, $not = '', $serveur = '', $option = true) {
-	$type = '';
-	if (!is_array($valeurs)) {
-		$valeurs = strval($valeurs);
-		if (isset($valeurs[0]) and $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 = strval($valeurs);
+        if (isset($valeurs[0]) and $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);
 }
 
 
@@ -2160,24 +2160,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);
 }
 
 /**
@@ -2209,29 +2209,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 = intval($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 and sql_fetch($res, $serveur, $option)) {
-			$pos++;
-		}
-	}
-
-	return $pos;
+    // pas de saut en arriere qu'on ne sait pas faire sans sql_seek
+    if (($saut = intval($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 and sql_fetch($res, $serveur, $option)) {
+            $pos++;
+        }
+    }
+
+    return $pos;
 }
 
 
@@ -2251,7 +2251,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));
 }
 
 /**
@@ -2270,7 +2270,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));
 }
 
 /**
@@ -2292,19 +2292,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);
 }
 
 
@@ -2327,32 +2327,32 @@ 
  **/
 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');
-	if (isset($GLOBALS['tables_auxiliaires'][$nom])) {
-		return $GLOBALS['tables_auxiliaires'][$nom];
-	}
-
-	return 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');
+    if (isset($GLOBALS['tables_auxiliaires'][$nom])) {
+        return $GLOBALS['tables_auxiliaires'][$nom];
+    }
+
+    return false;
 }
 
 /**
@@ -2365,8 +2365,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 +303 added lines, -303 removed lines

@@ -16,7 +16,7 @@ 
  * @package SPIP\Core\SQL
  **/
 if (!defined('_ECRIRE_INC_VERSION')) {
-	return;
+    return;
 }
 require_once _ROOT_RESTREINT . 'base/objets.php';
 
@@ -42,118 +42,118 @@ 
  **/
 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 = (!preg_match('/^[\w\.]*$/', $serveur))
-			? '' // nom de serveur mal ecrit
-			: ($serveur ?
-				(_DIR_CONNECT . $serveur . '.php') // serveur externe
-				: (_FILE_CONNECT ?: ($install ? _FILE_CONNECT_TMP // init du serveur principal
-						: ''))); // installation pas faite
-
-		unset($GLOBALS['db_ok']);
-		unset($GLOBALS['spip_connect_version']);
-		if ($f) {
-			if (is_readable($f)) {
-				include($f);
-			} elseif ($serveur and !$install) {
-				// chercher une declaration de serveur dans le path
-				// qui pourra un jour servir a declarer des bases sqlite
-				// par des plugins. Et sert aussi aux boucles POUR.
-				find_in_path("$serveur.php", 'connect/', true);
-			}
-		}
-		if (!isset($GLOBALS['db_ok'])) {
-			// fera mieux la prochaine fois
-			if ($install) {
-				return false;
-			}
-			if ($f and is_readable($f)) {
-				spip_log("spip_connect: fichier de connexion '$f' OK.", _LOG_INFO_IMPORTANTE);
-			} else {
-				spip_log("spip_connect: fichier de connexion '$f' non trouve", _LOG_INFO_IMPORTANTE);
-			}
-			spip_log("spip_connect: echec connexion ou serveur $index mal defini dans '$f'.", _LOG_HS);
-
-			// 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])) {
-		if (!find_in_path($type . '_' . $version . '.php', 'req/', true)) {
-			spip_log("spip_connect: serveur $index version '$version' non defini pour '$type'", _LOG_HS);
-
-			// 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_log('spip_connect: absence de charset', _LOG_AVERTISSEMENT);
-
-			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']
-			and sql_showtable('spip_meta', true, $serveur)
-			and $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 = (!preg_match('/^[\w\.]*$/', $serveur))
+            ? '' // nom de serveur mal ecrit
+            : ($serveur ?
+                (_DIR_CONNECT . $serveur . '.php') // serveur externe
+                : (_FILE_CONNECT ?: ($install ? _FILE_CONNECT_TMP // init du serveur principal
+                        : ''))); // installation pas faite
+
+        unset($GLOBALS['db_ok']);
+        unset($GLOBALS['spip_connect_version']);
+        if ($f) {
+            if (is_readable($f)) {
+                include($f);
+            } elseif ($serveur and !$install) {
+                // chercher une declaration de serveur dans le path
+                // qui pourra un jour servir a declarer des bases sqlite
+                // par des plugins. Et sert aussi aux boucles POUR.
+                find_in_path("$serveur.php", 'connect/', true);
+            }
+        }
+        if (!isset($GLOBALS['db_ok'])) {
+            // fera mieux la prochaine fois
+            if ($install) {
+                return false;
+            }
+            if ($f and is_readable($f)) {
+                spip_log("spip_connect: fichier de connexion '$f' OK.", _LOG_INFO_IMPORTANTE);
+            } else {
+                spip_log("spip_connect: fichier de connexion '$f' non trouve", _LOG_INFO_IMPORTANTE);
+            }
+            spip_log("spip_connect: echec connexion ou serveur $index mal defini dans '$f'.", _LOG_HS);
+
+            // 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])) {
+        if (!find_in_path($type . '_' . $version . '.php', 'req/', true)) {
+            spip_log("spip_connect: serveur $index version '$version' non defini pour '$type'", _LOG_HS);
+
+            // 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_log('spip_connect: absence de charset', _LOG_AVERTISSEMENT);
+
+            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']
+            and sql_showtable('spip_meta', true, $serveur)
+            and $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];
 }
 
 /**
@@ -162,12 +162,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($connexion['last']);
-	$f = $t . $serveur;
-	spip_log($m, $f . '.' . _LOG_ERREUR);
+    $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($connexion['last']);
+    $f = $t . $serveur;
+    spip_log($m, $f . '.' . _LOG_ERREUR);
 }
 
 /**
@@ -189,23 +189,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 
-		and $f = ($desc[$version][$ins] ?? '')
-		and function_exists($f)
-	 ) {
-		return $f;
-	}
-	if ($continue) {
-		return $desc;
-	}
-	if ($ins) {
-		spip_log("Le serveur '$serveur' version $version n'a pas '$ins'", _LOG_ERREUR);
-	}
-	include_spip('inc/minipres');
-	echo minipres(_T('info_travaux_titre'), _T('titre_probleme_technique'), ['status' => 503]);
-	exit;
+    $desc = spip_connect($serveur, $version);
+    if (
+        $desc 
+        and $f = ($desc[$version][$ins] ?? '')
+        and function_exists($f)
+        ) {
+        return $f;
+    }
+    if ($continue) {
+        return $desc;
+    }
+    if ($ins) {
+        spip_log("Le serveur '$serveur' version $version n'a pas '$ins'", _LOG_ERREUR);
+    }
+    include_spip('inc/minipres');
+    echo minipres(_T('info_travaux_titre'), _T('titre_probleme_technique'), ['status' => 503]);
+    exit;
 }
 
 /**
@@ -231,69 +231,69 @@ 
  * @return array          Description de la connexion
  */
 function spip_connect_db(
-	$host,
-	$port,
-	$login,
-	$pass,
-	$db = '',
-	$type = 'mysql',
-	$prefixe = '',
-	$auth = '',
-	$charset = ''
+    $host,
+    $port,
+    $login,
+    $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') and $db !== '@test@') {
-		$f = _DIR_TMP . $type . '.' . substr(md5($host . $port . $db), 0, 8) . '.out';
-	} elseif ($db == '@test@') {
-		$db = '';
-	}
-
-	if (
-		$f
-		and @file_exists($f)
-		and (time() - @filemtime($f) < _CONNECT_RETRY_DELAY)
-	) {
-		spip_log("Echec : $f recent. Pas de tentative de connexion", _LOG_HS);
-
-		return;
-	}
-
-	if (!$prefixe) {
-		$prefixe = $GLOBALS['table_prefix'] ?? $db;
-	}
-	$h = charger_fonction($type, 'req', true);
-	if (!$h) {
-		spip_log("les requetes $type ne sont pas fournies", _LOG_HS);
-
-		return;
-	}
-	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_log("Echec connexion serveur $type : host[$host] port[$port] login[$login] base[$db]", $type . '.' . _LOG_HS);
-	}
+    // 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') and $db !== '@test@') {
+        $f = _DIR_TMP . $type . '.' . substr(md5($host . $port . $db), 0, 8) . '.out';
+    } elseif ($db == '@test@') {
+        $db = '';
+    }
+
+    if (
+        $f
+        and @file_exists($f)
+        and (time() - @filemtime($f) < _CONNECT_RETRY_DELAY)
+    ) {
+        spip_log("Echec : $f recent. Pas de tentative de connexion", _LOG_HS);
+
+        return;
+    }
+
+    if (!$prefixe) {
+        $prefixe = $GLOBALS['table_prefix'] ?? $db;
+    }
+    $h = charger_fonction($type, 'req', true);
+    if (!$h) {
+        spip_log("les requetes $type ne sont pas fournies", _LOG_HS);
+
+        return;
+    }
+    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_log("Echec connexion serveur $type : host[$host] port[$port] login[$login] base[$db]", $type . '.' . _LOG_HS);
+    }
 }
 
 
@@ -325,32 +325,32 @@ 
  *     - nom du charset sinon
  **/
 function spip_connect_main($connexion, $charset_sql_connexion = '') {
-	if ($GLOBALS['spip_connect_version'] < 0.1 and _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'")
-		or 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 and _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'")
+        or is_string($r)
+    ) {
+        return false;
+    }
+    if (!($f = $connexion['fetch'])) {
+        return false;
+    }
+    $r = $f($r);
+
+    return (isset($r['valeur']) && $r['valeur']) ? $r['valeur'] : -1;
 }
 
 /**
@@ -366,9 +366,9 @@ 
  * @return array
  */
 function spip_connect_ldap($serveur = '') {
-	include_spip('auth/ldap');
+    include_spip('auth/ldap');
 
-	return auth_ldap_connect($serveur);
+    return auth_ldap_connect($serveur);
 }
 
 /**
@@ -384,16 +384,16 @@ 
  * @return string Valeur échappée.
  **/
 function _q($a): string {
-	if (is_numeric($a)) {
-		return strval($a);
-	} elseif (is_array($a)) {
-		return join(',', 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 strval($a);
+    } elseif (is_array($a)) {
+        return join(',', 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));
 }
 
 /**
@@ -409,66 +409,66 @@ 
  * @return array
  */
 function query_echappe_textes($query, $uniqid = null) {
-	static $codeEchappements = null;
-	if (is_null($codeEchappements) or $uniqid) {
-		if (is_null($uniqid)) {
-			$uniqid = uniqid();
-		}
-		$uniqid = substr(md5($uniqid), 0, 4);
-		$codeEchappements = ['\\\\' => "\x1@#{$uniqid}#@\x1", "\\'" => "\x2@#{$uniqid}#@\x2", '\\"' => "\x3@#{$uniqid}#@\x3"];
-	}
-	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 (strpos($query, (string) $codeEchappement) !== false) {
-			return [$query, []];
-		}
-	}
-
-	$query_echappees = str_replace(array_keys($codeEchappements), array_values($codeEchappements), $query);
-	if (preg_match_all("/('[^']*')|(\"[^\"]*\")/S", $query_echappees, $textes)) {
-		$textes = reset($textes); // indice 0 du match
-		switch (count($textes)) {
-			case 0:
-				$replace = [];
-				break;
-			case 1:
-				$replace = ['%1$s'];
-				break;
-			case 2:
-				$replace = ['%1$s', '%2$s'];
-				break;
-			case 3:
-				$replace = ['%1$s', '%2$s', '%3$s'];
-				break;
-			case 4:
-				$replace = ['%1$s', '%2$s', '%3$s', '%4$s'];
-				break;
-			case 5:
-				$replace = ['%1$s', '%2$s', '%3$s', '%4$s', '%5$s'];
-				break;
-			default:
-				$replace = range(1, count($textes));
-				$replace = '%' . implode('$s,%', $replace) . '$s';
-				$replace = explode(',', $replace);
-				break;
-		}
-		$query_echappees = str_replace($textes, $replace, $query_echappees);
-	} else {
-		$textes = [];
-	}
-
-	// si il reste des quotes simples ou doubles, c'est qu'on s'est emmelles 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) or $uniqid) {
+        if (is_null($uniqid)) {
+            $uniqid = uniqid();
+        }
+        $uniqid = substr(md5($uniqid), 0, 4);
+        $codeEchappements = ['\\\\' => "\x1@#{$uniqid}#@\x1", "\\'" => "\x2@#{$uniqid}#@\x2", '\\"' => "\x3@#{$uniqid}#@\x3"];
+    }
+    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 (strpos($query, (string) $codeEchappement) !== false) {
+            return [$query, []];
+        }
+    }
+
+    $query_echappees = str_replace(array_keys($codeEchappements), array_values($codeEchappements), $query);
+    if (preg_match_all("/('[^']*')|(\"[^\"]*\")/S", $query_echappees, $textes)) {
+        $textes = reset($textes); // indice 0 du match
+        switch (count($textes)) {
+            case 0:
+                $replace = [];
+                break;
+            case 1:
+                $replace = ['%1$s'];
+                break;
+            case 2:
+                $replace = ['%1$s', '%2$s'];
+                break;
+            case 3:
+                $replace = ['%1$s', '%2$s', '%3$s'];
+                break;
+            case 4:
+                $replace = ['%1$s', '%2$s', '%3$s', '%4$s'];
+                break;
+            case 5:
+                $replace = ['%1$s', '%2$s', '%3$s', '%4$s', '%5$s'];
+                break;
+            default:
+                $replace = range(1, count($textes));
+                $replace = '%' . implode('$s,%', $replace) . '$s';
+                $replace = explode(',', $replace);
+                break;
+        }
+        $query_echappees = str_replace($textes, $replace, $query_echappees);
+    } else {
+        $textes = [];
+    }
+
+    // si il reste des quotes simples ou doubles, c'est qu'on s'est emmelles les pinceaux
+    // dans le doute on ne touche a rien
+    if (strpbrk($query_echappees, "'\"") !== false) {
+        return [$query, []];
+    }
+
+    return [$query_echappees, $textes];
 }
 
 /**
@@ -482,14 +482,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);
 
-	$query = sprintf($query, ...$textes);
+    $query = sprintf($query, ...$textes);
 
-	$query = str_replace(array_values($codeEchappements), array_keys($codeEchappements), $query);
+    $query = str_replace(array_values($codeEchappements), array_keys($codeEchappements), $query);
 
-	return $query;
+    return $query;
 }
 
 
@@ -508,7 +508,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;
 }

ecrire/base/dump.php

Indentation +540 added lines, -540 removed lines

@@ -17,7 +17,7 @@ 
  */
 
 if (!defined('_ECRIRE_INC_VERSION')) {
-	return;
+    return;
 }
 
 define('_VERSION_ARCHIVE', '1.3');
@@ -38,7 +38,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']);
 }
 
 /**
@@ -53,15 +53,15 @@ 
  * @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;
-	}
-	$dir = sous_repertoire($maindir, $meta);
-
-	return $dir;
+    include_spip('inc/documents');
+    // determine upload va aussi initialiser l'index "restreint"
+    $maindir = determine_upload();
+    if (!$GLOBALS['visiteur_session']['restreint']) {
+        $maindir = _DIR_DUMP;
+    }
+    $dir = sous_repertoire($maindir, $meta);
+
+    return $dir;
 }
 
 /**
@@ -75,28 +75,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, $t)) {
-			$t1 = preg_replace($p, 'spip', $t);
-			if (!in_array($t1, $tables) and !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, $t)) {
+            $t1 = preg_replace($p, 'spip', $t);
+            if (!in_array($t1, $tables) and !in_array($t1, $exclude)) {
+                $res[] = ($affiche_vrai_prefixe ? $t : $t1);
+            }
+        }
+    }
+    sort($res);
+
+    return $res;
 }
 
 /**
@@ -106,11 +106,11 @@ 
  * @return string
  */
 function base_prefixe_tables($serveur = '') {
-	spip_connect($serveur);
-	$connexion = $GLOBALS['connexions'][$serveur ?: 0];
-	$prefixe = $connexion['prefixe'];
+    spip_connect($serveur);
+    $connexion = $GLOBALS['connexions'][$serveur ?: 0];
+    $prefixe = $connexion['prefixe'];
 
-	return $prefixe;
+    return $prefixe;
 }
 
 
@@ -125,31 +125,31 @@ 
  * @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
-		if (is_null($post)) {
-			$check = (in_array($t, $exclude) ? false : true);
-		} // mais si on a poste une selection, la reprendre
-		else {
-			$check = 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
+        if (is_null($post)) {
+            $check = (in_array($t, $exclude) ? false : true);
+        } // mais si on a poste une selection, la reprendre
+        else {
+            $check = 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;
 }
 
 
@@ -161,27 +161,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;
 }
 
 /**
@@ -192,25 +192,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;
 }
 
 
@@ -222,23 +222,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;
 }
 
 
@@ -252,86 +252,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')
-		and function_exists('lister_tables_objets_sql')
-	) {
-		$tables = lister_tables_objets_sql();
-		foreach ($tables as $t => $infos) {
-			if ($infos['principale'] and !isset($tables_principales[$t])) {
-				$tables_principales[$t] = true;
-			}
-			if (!$infos['principale'] and !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')
+        and function_exists('lister_tables_objets_sql')
+    ) {
+        $tables = lister_tables_objets_sql();
+        foreach ($tables as $t => $infos) {
+            if ($infos['principale'] and !isset($tables_principales[$t])) {
+                $tables_principales[$t] = true;
+            }
+            if (!$infos['principale'] and !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];
 }
 
 /**
@@ -346,37 +346,37 @@ 
  * @param string $serveur
  */
 function base_vider_tables_destination_copie($tables, $exclure_tables = [], $serveur = '') {
-	$trouver_table = charger_fonction('trouver_table', 'base');
-
-	spip_log(
-		'Vider ' . count($tables) . " tables sur serveur '$serveur' : " . join(', ', $tables),
-		'base.' . _LOG_INFO_IMPORTANTE
-	);
-	foreach ($tables as $table) {
-		if (!in_array($table, $exclure_tables)) {
-			// sur le serveur principal, il ne faut pas supprimer l'auteur loge !
-			if (($table != 'spip_auteurs') or $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 == ''
-		and in_array('spip_auteurs', $tables)
-		and !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_log(
+        'Vider ' . count($tables) . " tables sur serveur '$serveur' : " . join(', ', $tables),
+        'base.' . _LOG_INFO_IMPORTANTE
+    );
+    foreach ($tables as $table) {
+        if (!in_array($table, $exclure_tables)) {
+            // sur le serveur principal, il ne faut pas supprimer l'auteur loge !
+            if (($table != 'spip_auteurs') or $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 == ''
+        and in_array('spip_auteurs', $tables)
+        and !in_array('spip_auteurs', $exclure_tables)
+    ) {
+        base_conserver_copieur(true, $serveur);
+        sql_delete('spip_auteurs', 'id_auteur>0', $serveur);
+    }
 }
 
 /**
@@ -387,36 +387,36 @@ 
  * @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 and sql_countsel('spip_auteurs', 'id_auteur>0')) {
-		spip_log(
-			'Conserver copieur dans id_auteur=' . $GLOBALS['visiteur_session']['id_auteur'] . " pour le serveur '$serveur'",
-			'dump.' . _LOG_INFO_IMPORTANTE
-		);
-		sql_delete('spip_auteurs', 'id_auteur<0', $serveur);
-		if ($move) {
-			sql_updateq(
-				'spip_auteurs',
-				['id_auteur' => -$GLOBALS['visiteur_session']['id_auteur']],
-				'id_auteur=' . intval($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 and sql_countsel('spip_auteurs', 'id_auteur>0')) {
+        spip_log(
+            'Conserver copieur dans id_auteur=' . $GLOBALS['visiteur_session']['id_auteur'] . " pour le serveur '$serveur'",
+            'dump.' . _LOG_INFO_IMPORTANTE
+        );
+        sql_delete('spip_auteurs', 'id_auteur<0', $serveur);
+        if ($move) {
+            sql_updateq(
+                'spip_auteurs',
+                ['id_auteur' => -$GLOBALS['visiteur_session']['id_auteur']],
+                'id_auteur=' . intval($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);
+        }
+    }
 }
 
 /**
@@ -431,21 +431,21 @@ 
  * @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_log("Detruire copieur id_auteur<0 pour le serveur '$serveur'", 'dump.' . _LOG_INFO_IMPORTANTE);
-			sql_delete('spip_auteurs', 'id_auteur<0', $serveur);
-		} else {
-			spip_log(
-				"Restaurer copieur id_auteur<0 pour le serveur '$serveur' (aucun autre auteur en base)",
-				'dump.' . _LOG_INFO_IMPORTANTE
-			);
-			sql_update('spip_auteurs', ['id_auteur' => '-id_auteur'], 'id_auteur<0');
-		}
-	} else {
-		spip_log("Pas de destruction copieur sur serveur '$serveur'", 'dump.' . _LOG_INFO_IMPORTANTE);
-	}
+    // rien a faire si ce n'est pas le serveur principal !
+    if ($serveur == '') {
+        if (sql_countsel('spip_auteurs', 'id_auteur>0')) {
+            spip_log("Detruire copieur id_auteur<0 pour le serveur '$serveur'", 'dump.' . _LOG_INFO_IMPORTANTE);
+            sql_delete('spip_auteurs', 'id_auteur<0', $serveur);
+        } else {
+            spip_log(
+                "Restaurer copieur id_auteur<0 pour le serveur '$serveur' (aucun autre auteur en base)",
+                'dump.' . _LOG_INFO_IMPORTANTE
+            );
+            sql_update('spip_auteurs', ['id_auteur' => '-id_auteur'], 'id_auteur<0');
+        }
+    } else {
+        spip_log("Pas de destruction copieur sur serveur '$serveur'", 'dump.' . _LOG_INFO_IMPORTANTE);
+    }
 }
 
 /**
@@ -460,40 +460,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) and $init) {
-		if ($serveur_dest == '' and 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_log("drop table '$table' sur serveur '$serveur_dest'", 'dump.' . _LOG_INFO_IMPORTANTE);
-		}
-		$desc_dest = false;
-	}
-	// si la table n'existe pas dans la destination, la creer a l'identique !
-	if (!$desc_dest) {
-		spip_log("creation '$table' sur serveur '$serveur_dest'", 'dump.' . _LOG_INFO_IMPORTANTE);
-		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_log("Erreur creation '$table' sur serveur '$serveur_dest'" . var_export($desc, 1), 'dump.' . _LOG_ERREUR);
-	}
-
-	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) and $init) {
+        if ($serveur_dest == '' and 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_log("drop table '$table' sur serveur '$serveur_dest'", 'dump.' . _LOG_INFO_IMPORTANTE);
+        }
+        $desc_dest = false;
+    }
+    // si la table n'existe pas dans la destination, la creer a l'identique !
+    if (!$desc_dest) {
+        spip_log("creation '$table' sur serveur '$serveur_dest'", 'dump.' . _LOG_INFO_IMPORTANTE);
+        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_log("Erreur creation '$table' sur serveur '$serveur_dest'" . var_export($desc, 1), 'dump.' . _LOG_ERREUR);
+    }
+
+    return $desc_dest;
 }
 
 /**
@@ -539,211 +539,211 @@ 
  */
 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;
-
-	spip_log(
-		'Copier ' . count($tables) . " tables de '$serveur_source' vers '$serveur_dest'",
-		'dump.' . _LOG_INFO_IMPORTANTE
-	);
-
-	if (!$inserer_copie = charger_fonction($fonction_base_inserer, $racine_fonctions, true)) {
-		spip_log("Fonction '{$racine_fonctions}_$fonction_base_inserer' inconnue. Abandon", 'dump.' . _LOG_INFO_IMPORTANTE);
-
-		return true; // echec mais on a fini, donc true
-	}
-	if (!$preparer_table_dest = charger_fonction('preparer_table_dest', $racine_fonctions, true)) {
-		spip_log("Fonction '{$racine_fonctions}_$preparer_table_dest' inconnue. Abandon", 'dump.' . _LOG_INFO_IMPORTANTE);
-
-		return true; // echec mais on a fini, donc true
-	}
-
-	if (
-		!lire_fichier($status_file, $status)
-		or !$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 = (!isset($status['dump_status_copie'])) ? 0 : $status['dump_status_copie'];
-
-	// 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
-			)
-		) {
-			spip_log(
-				"Fonction '{$racine_fonctions}_vider_tables_destination_copie' inconnue. Abandon",
-				'dump.' . _LOG_INFO_IMPORTANTE
-			);
-
-			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';
-	}
-	spip_log('Tables a copier :' . implode(', ', $tables), 'dump.' . _LOG_INFO);
-
-	$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 (strncmp($table, 'spip_', 5) == 0) {
-			$desc_source = $trouver_table(preg_replace(',^spip_,', '', $table), $serveur_source, true);
-		}
-		if (!$desc_source or !isset($desc_source['exist']) or !$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])
-				and $status['tables_copiees'][$table] >= 0
-				and $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 = intval($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 and $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
-							spip_log("Erreur fatale dans $inserer_copie table $table", 'dump' . _LOG_ERREUR);
-							$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 and time() > $max_time) {
-							break;
-						}
-					}
-					if ($n == $status['tables_copiees'][$table]) {
-						break;
-					}
-					spip_log("recopie $table " . $status['tables_copiees'][$table], 'dump.' . _LOG_INFO_IMPORTANTE);
-					if ($callback_progression) {
-						$callback_progression($status['tables_copiees'][$table], 0, $table);
-					}
-					ecrire_fichier($status_file, serialize($status));
-					if ($max_time and time() > $max_time) {
-						return false;
-					} // on a pas fini, mais le temps imparti est ecoule
-				}
-				if ($drop_source) {
-					sql_drop_table($table, '', $serveur_source);
-					spip_log("drop $table sur serveur source '$serveur_source'", 'dump.' . _LOG_INFO_IMPORTANTE);
-				}
-				$status['tables_copiees'][$table] = ($status['tables_copiees'][$table] ? -$status['tables_copiees'][$table] : 'zero');
-				ecrire_fichier($status_file, serialize($status));
-				spip_log('tables_recopiees ' . implode(',', array_keys($status['tables_copiees'])), 'dump.' . _LOG_INFO);
-				if ($callback_progression) {
-					$callback_progression($status['tables_copiees'][$table], $status['tables_copiees'][$table], $table);
-				}
-			} else {
-				if ($status['tables_copiees'][$table] < 0) {
-					spip_log("Table $table deja copiee : " . $status['tables_copiees'][$table], 'dump.' . _LOG_INFO);
-				}
-				if ($callback_progression) {
-					$callback_progression(
-						0,
-						$status['tables_copiees'][$table],
-						"$table" . ((is_numeric($status['tables_copiees'][$table]) and $status['tables_copiees'][$table] >= 0) ? '[Echec]' : '')
-					);
-				}
-			}
-		} else {
-			$status['errors'][] = "Impossible de lire la description de la table $table";
-			ecrire_fichier($status_file, serialize($status));
-			spip_log("Impossible de lire la description de la table $table", 'dump.' . _LOG_ERREUR);
-		}
-	}
-
-	// 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)) {
-		spip_log(
-			'Nombre de tables copiees incorrect : ' . (is_countable($status['tables_copiees']) ? count($status['tables_copiees']) : 0) . '/' . count($tables),
-			'dump.' . _LOG_ERREUR
-		);
-		$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 {
-		spip_log("Fonction '{$racine_fonctions}_detruire_copieur_si_besoin' inconnue.", 'dump.' . _LOG_INFO_IMPORTANTE);
-	}
-
-	// 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;
+
+    spip_log(
+        'Copier ' . count($tables) . " tables de '$serveur_source' vers '$serveur_dest'",
+        'dump.' . _LOG_INFO_IMPORTANTE
+    );
+
+    if (!$inserer_copie = charger_fonction($fonction_base_inserer, $racine_fonctions, true)) {
+        spip_log("Fonction '{$racine_fonctions}_$fonction_base_inserer' inconnue. Abandon", 'dump.' . _LOG_INFO_IMPORTANTE);
+
+        return true; // echec mais on a fini, donc true
+    }
+    if (!$preparer_table_dest = charger_fonction('preparer_table_dest', $racine_fonctions, true)) {
+        spip_log("Fonction '{$racine_fonctions}_$preparer_table_dest' inconnue. Abandon", 'dump.' . _LOG_INFO_IMPORTANTE);
+
+        return true; // echec mais on a fini, donc true
+    }
+
+    if (
+        !lire_fichier($status_file, $status)
+        or !$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 = (!isset($status['dump_status_copie'])) ? 0 : $status['dump_status_copie'];
+
+    // 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
+            )
+        ) {
+            spip_log(
+                "Fonction '{$racine_fonctions}_vider_tables_destination_copie' inconnue. Abandon",
+                'dump.' . _LOG_INFO_IMPORTANTE
+            );
+
+            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';
+    }
+    spip_log('Tables a copier :' . implode(', ', $tables), 'dump.' . _LOG_INFO);
+
+    $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 (strncmp($table, 'spip_', 5) == 0) {
+            $desc_source = $trouver_table(preg_replace(',^spip_,', '', $table), $serveur_source, true);
+        }
+        if (!$desc_source or !isset($desc_source['exist']) or !$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])
+                and $status['tables_copiees'][$table] >= 0
+                and $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 = intval($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 and $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
+                            spip_log("Erreur fatale dans $inserer_copie table $table", 'dump' . _LOG_ERREUR);
+                            $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 and time() > $max_time) {
+                            break;
+                        }
+                    }
+                    if ($n == $status['tables_copiees'][$table]) {
+                        break;
+                    }
+                    spip_log("recopie $table " . $status['tables_copiees'][$table], 'dump.' . _LOG_INFO_IMPORTANTE);
+                    if ($callback_progression) {
+                        $callback_progression($status['tables_copiees'][$table], 0, $table);
+                    }
+                    ecrire_fichier($status_file, serialize($status));
+                    if ($max_time and time() > $max_time) {
+                        return false;
+                    } // on a pas fini, mais le temps imparti est ecoule
+                }
+                if ($drop_source) {
+                    sql_drop_table($table, '', $serveur_source);
+                    spip_log("drop $table sur serveur source '$serveur_source'", 'dump.' . _LOG_INFO_IMPORTANTE);
+                }
+                $status['tables_copiees'][$table] = ($status['tables_copiees'][$table] ? -$status['tables_copiees'][$table] : 'zero');
+                ecrire_fichier($status_file, serialize($status));
+                spip_log('tables_recopiees ' . implode(',', array_keys($status['tables_copiees'])), 'dump.' . _LOG_INFO);
+                if ($callback_progression) {
+                    $callback_progression($status['tables_copiees'][$table], $status['tables_copiees'][$table], $table);
+                }
+            } else {
+                if ($status['tables_copiees'][$table] < 0) {
+                    spip_log("Table $table deja copiee : " . $status['tables_copiees'][$table], 'dump.' . _LOG_INFO);
+                }
+                if ($callback_progression) {
+                    $callback_progression(
+                        0,
+                        $status['tables_copiees'][$table],
+                        "$table" . ((is_numeric($status['tables_copiees'][$table]) and $status['tables_copiees'][$table] >= 0) ? '[Echec]' : '')
+                    );
+                }
+            }
+        } else {
+            $status['errors'][] = "Impossible de lire la description de la table $table";
+            ecrire_fichier($status_file, serialize($status));
+            spip_log("Impossible de lire la description de la table $table", 'dump.' . _LOG_ERREUR);
+        }
+    }
+
+    // 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)) {
+        spip_log(
+            'Nombre de tables copiees incorrect : ' . (is_countable($status['tables_copiees']) ? count($status['tables_copiees']) : 0) . '/' . count($tables),
+            'dump.' . _LOG_ERREUR
+        );
+        $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 {
+        spip_log("Fonction '{$racine_fonctions}_detruire_copieur_si_besoin' inconnue.", 'dump.' . _LOG_INFO_IMPORTANTE);
+    }
+
+    // OK, copie complete
+    return true;
 }
 
 /**
@@ -757,31 +757,31 @@ 
  */
 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_log(
-			'base_inserer_copie : ' . ($nb - $nb1) . ' insertions au lieu de ' . count($rows) . '. On retente 1 par 1',
-			'dump' . _LOG_INFO_IMPORTANTE
-		);
-		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_log(
-				'base_inserer_copie : ' . ($nb - $nb1) . ' insertions au lieu de ' . count($rows) . ' apres insertion 1 par 1',
-				'dump' . _LOG_ERREUR
-			);
-			$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_log(
+            'base_inserer_copie : ' . ($nb - $nb1) . ' insertions au lieu de ' . count($rows) . '. On retente 1 par 1',
+            'dump' . _LOG_INFO_IMPORTANTE
+        );
+        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_log(
+                'base_inserer_copie : ' . ($nb - $nb1) . ' insertions au lieu de ' . count($rows) . ' apres insertion 1 par 1',
+                'dump' . _LOG_ERREUR
+            );
+            $r = false;
+        }
+    }
+
+    return $r;
 }

ecrire/base/upgrade.php

Indentation +282 added lines, -282 removed lines

@@ -17,17 +17,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);
 }
 
 /**
@@ -50,40 +50,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_log('recree les tables eventuellement disparues', 'maj.' . _LOG_INFO_IMPORTANTE);
-			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_log('Fin de mise a jour SQL. Debut m-a-j acces et config', 'maj.' . _LOG_INFO_IMPORTANTE);
-
-	// 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_log('recree les tables eventuellement disparues', 'maj.' . _LOG_INFO_IMPORTANTE);
+            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_log('Fin de mise a jour SQL. Debut m-a-j acces et config', 'maj.' . _LOG_INFO_IMPORTANTE);
+
+    // 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();
 }
 
 /**
@@ -114,51 +114,51 @@ 
  */
 function maj_base($version_cible = 0, $redirect = '', $debut_page = true) {
 
-	$version_installee = $GLOBALS['meta']['version_installee'] ?? null;
-
-	spip_log(
-		"Version anterieure: $version_installee. Courante: " . $GLOBALS['spip_version_base'],
-		'maj.' . _LOG_INFO_IMPORTANTE
-	);
-	if (!$version_installee or ($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/v21');
-		include_spip('maj/legacy/v30');
-		include_spip('maj/legacy/v31');
-		include_spip('maj/legacy/v32');
-		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_log("Pb d'acces SQL a la mise a jour", 'maj.' . _LOG_INFO_ERREUR);
-		} else {
-			echo _T('avis_operation_echec') . ' ' . join(' ', $res);
-			echo install_fin_html();
-		}
-	}
-
-	return $res;
+    $version_installee = $GLOBALS['meta']['version_installee'] ?? null;
+
+    spip_log(
+        "Version anterieure: $version_installee. Courante: " . $GLOBALS['spip_version_base'],
+        'maj.' . _LOG_INFO_IMPORTANTE
+    );
+    if (!$version_installee or ($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/v21');
+        include_spip('maj/legacy/v30');
+        include_spip('maj/legacy/v31');
+        include_spip('maj/legacy/v32');
+        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_log("Pb d'acces SQL a la mise a jour", 'maj.' . _LOG_INFO_ERREUR);
+        } else {
+            echo _T('avis_operation_echec') . ' ' . join(' ', $res);
+            echo install_fin_html();
+        }
+    }
+
+    return $res;
 }
 
 /**
@@ -200,53 +200,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_log("Pb d'acces SQL a la mise a jour", 'maj.' . _LOG_INFO_ERREUR);
-			} else {
-				echo '<p>' . _T('avis_operation_echec') . ' ' . join(' ', $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_log("Pb d'acces SQL a la mise a jour", 'maj.' . _LOG_INFO_ERREUR);
+            } else {
+                echo '<p>' . _T('avis_operation_echec') . ' ' . join(' ', $res) . '</p>';
+            }
+        }
+    }
 }
 
 /**
@@ -263,17 +263,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 = intval($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 = intval($GLOBALS[$table][$meta]);
+        $redirect = generer_url_ecrire('upgrade', "reinstall=$installee&meta=$meta&table=$table", true);
+    }
+    echo redirige_formulaire($redirect);
+    exit();
 }
 
 /**
@@ -286,26 +286,26 @@ 
  * @return void
  */
 function maj_debut_page($installee, $meta, $table) {
-	static $done = false;
-	if ($done) {
-		return;
-	}
-	include_spip('inc/minipres');
-	@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');
+    @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;
 }
 
 
@@ -349,64 +349,64 @@ 
  *    - 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' or
-			(spip_version_compare($v, $installee, '>')
-				and 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_log("$table $meta: $v en $n secondes", 'maj.' . _LOG_INFO_IMPORTANTE);
-			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_log("MAJ terminee. $meta: $installee", 'maj.' . _LOG_INFO_IMPORTANTE);
-
-	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' or
+            (spip_version_compare($v, $installee, '>')
+                and 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_log("$table $meta: $v en $n secondes", 'maj.' . _LOG_INFO_IMPORTANTE);
+            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_log("MAJ terminee. $meta: $installee", 'maj.' . _LOG_INFO_IMPORTANTE);
+
+    return [];
 }
 
 /**
@@ -429,53 +429,53 @@ 
  * @return int
  */
 function serie_alter($serie, $q = [], $meta = '', $table = 'meta', $redirect = '') {
-	$meta2 = $meta . '_maj_' . $serie;
-	$etape = 0;
-	if (isset($GLOBALS[$table][$meta2])) {
-		$etape = intval($GLOBALS[$table][$meta2]);
-	}
-	foreach ($q as $i => $r) {
-		if ($i >= $etape) {
-			$msg = "maj $table $meta2 etape $i";
-			if (
-				is_array($r)
-				and function_exists($f = array_shift($r))
-			) {
-				// note: $r (arguments de la fonction $f) peut avoir des données tabulaires
-				spip_log("$msg: $f " . @join(',', $r), 'maj.' . _LOG_INFO_IMPORTANTE);
-				// 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 (strncmp($f, 'sql_', 4) == 0) {
-					ecrire_meta($meta2, $i + 1, 'non', $table);
-				}
-				echo (_IS_CLI ? '.' : " <span title='$i'>.</span>");
-				call_user_func_array($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_log("$meta2: ok", 'maj.' . _LOG_INFO_IMPORTANTE);
-			} else {
-				if (!is_array($r)) {
-					spip_log("maj $i format incorrect", 'maj.' . _LOG_ERREUR);
-				} else {
-					spip_log("maj $i fonction $f non definie", 'maj.' . _LOG_ERREUR);
-				}
-				// 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 = intval($GLOBALS[$table][$meta2]);
+    }
+    foreach ($q as $i => $r) {
+        if ($i >= $etape) {
+            $msg = "maj $table $meta2 etape $i";
+            if (
+                is_array($r)
+                and function_exists($f = array_shift($r))
+            ) {
+                // note: $r (arguments de la fonction $f) peut avoir des données tabulaires
+                spip_log("$msg: $f " . @join(',', $r), 'maj.' . _LOG_INFO_IMPORTANTE);
+                // 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 (strncmp($f, 'sql_', 4) == 0) {
+                    ecrire_meta($meta2, $i + 1, 'non', $table);
+                }
+                echo (_IS_CLI ? '.' : " <span title='$i'>.</span>");
+                call_user_func_array($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_log("$meta2: ok", 'maj.' . _LOG_INFO_IMPORTANTE);
+            } else {
+                if (!is_array($r)) {
+                    spip_log("maj $i format incorrect", 'maj.' . _LOG_ERREUR);
+                } else {
+                    spip_log("maj $i fonction $f non definie", 'maj.' . _LOG_ERREUR);
+                }
+                // 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;
 }
 
 /**
@@ -484,16 +484,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 = $result ? true : false;
-	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 = $result ? true : false;
+    sql_alter('TABLE spip_test DROP b');
+
+    return $result;
 }

ecrire/index.php

Indentation +77 added lines, -77 removed lines

@@ -19,14 +19,14 @@ 
 /** Drapeau indiquant que l'on est dans l'espace privé */
 define('_ESPACE_PRIVE', true);
 if (!defined('_ECRIRE_INC_VERSION')) {
-	include 'inc_version.php';
+    include 'inc_version.php';
 }
 
 // Verification anti magic_quotes_sybase, pour qui addslashes("'") = "''"
 // On prefere la faire ici plutot que dans inc_version, c'est moins souvent et
 // si le reglage est modifie sur un site en prod, ca fait moins mal
 if (addslashes("'") !== "\\'") {
-	die('SPIP incompatible magic_quotes_sybase');
+    die('SPIP incompatible magic_quotes_sybase');
 }
 
 include_spip('inc/cookie');
@@ -42,18 +42,18 @@ 
 // alors il faut blinder les variables d'URL
 //
 if (autoriser_sans_cookie($exec, false)) {
-	if (!isset($reinstall)) {
-		$reinstall = 'non';
-	}
-	$var_auth = true;
+    if (!isset($reinstall)) {
+        $reinstall = 'non';
+    }
+    $var_auth = true;
 } else {
-	// Authentification, redefinissable
-	$auth = charger_fonction('auth', 'inc');
-	$var_auth = $auth();
-	if ($var_auth) {
-		echo auth_echec($var_auth);
-		exit;
-	}
+    // Authentification, redefinissable
+    $auth = charger_fonction('auth', 'inc');
+    $var_auth = $auth();
+    if ($var_auth) {
+        echo auth_echec($var_auth);
+        exit;
+    }
 }
 
 // initialiser a la langue par defaut
@@ -64,29 +64,29 @@ 
 
 
 if (_request('action') or _request('var_ajax') or _request('formulaire_action')) {
-	if (!autoriser_sans_cookie($exec)) {
-		// Charger l'aiguilleur qui va mettre sur la bonne voie les traitements derogatoires
-		include_spip('public/aiguiller');
-		if (
-			// cas des appels actions ?action=xxx
-			traiter_appels_actions()
-			or
-			// cas des hits ajax sur les inclusions ajax
-			traiter_appels_inclusions_ajax()
-			or
-			// cas des formulaires charger/verifier/traiter
-			traiter_formulaires_dynamiques()
-		) {
-			exit;
-		} // le hit est fini !
-	}
+    if (!autoriser_sans_cookie($exec)) {
+        // Charger l'aiguilleur qui va mettre sur la bonne voie les traitements derogatoires
+        include_spip('public/aiguiller');
+        if (
+            // cas des appels actions ?action=xxx
+            traiter_appels_actions()
+            or
+            // cas des hits ajax sur les inclusions ajax
+            traiter_appels_inclusions_ajax()
+            or
+            // cas des formulaires charger/verifier/traiter
+            traiter_formulaires_dynamiques()
+        ) {
+            exit;
+        } // le hit est fini !
+    }
 }
 // securiser les redirect du back-office
 if (_request('redirect')) {
-	if (!function_exists('securiser_redirect_action')) {
-		include_spip('public/aiguiller');
-	}
-	set_request('redirect', securiser_redirect_action(_request('redirect')));
+    if (!function_exists('securiser_redirect_action')) {
+        include_spip('public/aiguiller');
+    }
+    set_request('redirect', securiser_redirect_action(_request('redirect')));
 }
 
 
@@ -96,12 +96,12 @@ 
 
 // Controle de la version, sauf si on est deja en train de s'en occuper
 if (
-	!$reinstall == 'oui'
-	and !_AJAX
-	and isset($GLOBALS['meta']['version_installee'])
-	and ($GLOBALS['spip_version_base'] != (str_replace(',', '.', $GLOBALS['meta']['version_installee'])))
+    !$reinstall == 'oui'
+    and !_AJAX
+    and isset($GLOBALS['meta']['version_installee'])
+    and ($GLOBALS['spip_version_base'] != (str_replace(',', '.', $GLOBALS['meta']['version_installee'])))
 ) {
-	$exec = 'demande_mise_a_jour';
+    $exec = 'demande_mise_a_jour';
 }
 
 // Quand une action d'administration est en cours (meta "admin"),
@@ -111,39 +111,39 @@ 
 // sinon c'est qu'elle a ete interrompue et il faut la reprendre
 
 elseif (isset($GLOBALS['meta']['admin'])) {
-	if (preg_match('/^(.*)_(\d+)_/', $GLOBALS['meta']['admin'], $l)) {
-		[, $var_f, $n] = $l;
-	}
-	if (
-		_AJAX
-		or !(
-			isset($_COOKIE['spip_admin'])
-			or (isset($GLOBALS['visiteur_session']) and $GLOBALS['visiteur_session']['statut'] == '0minirezo')
-		)
-	) {
-		spip_log('Quand la meta admin vaut ' .
-			$GLOBALS['meta']['admin'] .
-			' seul un admin peut se connecter et sans AJAX.' .
-			' En cas de probleme, detruire cette meta.');
-		die(_T('info_travaux_texte'));
-	}
-	if ($n) {
-		[, $var_f, $n] = $l;
-		if (tester_url_ecrire("base_$var_f")) {
-			$var_f = "base_$var_f";
-		}
-		if ($var_f != $exec) {
-			spip_log("Le script $var_f lance par auteur$n se substitue a l'exec $exec");
-			$exec = $var_f;
-			set_request('exec', $exec);
-		}
-	}
+    if (preg_match('/^(.*)_(\d+)_/', $GLOBALS['meta']['admin'], $l)) {
+        [, $var_f, $n] = $l;
+    }
+    if (
+        _AJAX
+        or !(
+            isset($_COOKIE['spip_admin'])
+            or (isset($GLOBALS['visiteur_session']) and $GLOBALS['visiteur_session']['statut'] == '0minirezo')
+        )
+    ) {
+        spip_log('Quand la meta admin vaut ' .
+            $GLOBALS['meta']['admin'] .
+            ' seul un admin peut se connecter et sans AJAX.' .
+            ' En cas de probleme, detruire cette meta.');
+        die(_T('info_travaux_texte'));
+    }
+    if ($n) {
+        [, $var_f, $n] = $l;
+        if (tester_url_ecrire("base_$var_f")) {
+            $var_f = "base_$var_f";
+        }
+        if ($var_f != $exec) {
+            spip_log("Le script $var_f lance par auteur$n se substitue a l'exec $exec");
+            $exec = $var_f;
+            set_request('exec', $exec);
+        }
+    }
 }
 // si nom pas plausible, prendre le script par defaut
 // attention aux deux cas 404/403 qui commencent par un 4 !
 elseif (!preg_match(',^[a-z4_][0-9a-z_-]*$,i', $exec)) {
-	$exec = 'accueil';
-	set_request('exec', $exec);
+    $exec = 'accueil';
+    set_request('exec', $exec);
 }
 
 // compatibilite ascendante : obsolete, ne plus utiliser
@@ -155,19 +155,19 @@ 
 // on appelle directement la fonction, car un appel d'action peut conduire a une boucle infinie
 // si le cookie n'est pas pose correctement dans l'action
 if (
-	!$var_auth and isset($_COOKIE['spip_lang_ecrire'])
-	and $_COOKIE['spip_lang_ecrire'] <> $GLOBALS['visiteur_session']['lang']
+    !$var_auth and isset($_COOKIE['spip_lang_ecrire'])
+    and $_COOKIE['spip_lang_ecrire'] <> $GLOBALS['visiteur_session']['lang']
 ) {
-	include_spip('action/converser');
-	action_converser_post($GLOBALS['visiteur_session']['lang'], true);
+    include_spip('action/converser');
+    action_converser_post($GLOBALS['visiteur_session']['lang'], true);
 }
 
 if ($var_f = tester_url_ecrire($exec)) {
-	$var_f = charger_fonction($var_f);
-	$var_f(); // at last
+    $var_f = charger_fonction($var_f);
+    $var_f(); // at last
 } else {
-	// Rien de connu: rerouter vers exec=404 au lieu d'echouer
-	// ce qui permet de laisser la main a un plugin
-	$var_f = charger_fonction('404');
-	$var_f($exec);
+    // Rien de connu: rerouter vers exec=404 au lieu d'echouer
+    // ce qui permet de laisser la main a un plugin
+    $var_f = charger_fonction('404');
+    $var_f($exec);
 }

ecrire/install/etape_1.php

Indentation +30 added lines, -30 removed lines

@@ -18,7 +18,7 @@ 
  */
 
 if (!defined('_ECRIRE_INC_VERSION')) {
-	return;
+    return;
 }
 
 /**
@@ -35,45 +35,45 @@ 
  *
  */
 function install_etape_1_dist() {
-	echo install_debut_html();
+    echo install_debut_html();
 
-	// stopper en cas de grosse incompatibilite de l'hebergement
-	tester_compatibilite_hebergement();
+    // stopper en cas de grosse incompatibilite de l'hebergement
+    tester_compatibilite_hebergement();
 
-	// Recuperer les anciennes donnees pour plus de facilite (si presentes)
-	$s = !@is_readable(_FILE_CONNECT_TMP) ? ''
-		: analyse_fichier_connection(_FILE_CONNECT_TMP);
+    // Recuperer les anciennes donnees pour plus de facilite (si presentes)
+    $s = !@is_readable(_FILE_CONNECT_TMP) ? ''
+        : analyse_fichier_connection(_FILE_CONNECT_TMP);
 
-	[$adresse_db, $login_db] = $s ?: login_hebergeur();
+    [$adresse_db, $login_db] = $s ?: login_hebergeur();
 
-	$chmod = (isset($_GET['chmod']) and preg_match(',^[0-9]+$,', $_GET['chmod'])) ?
-		sprintf('%04o', $_GET['chmod']) : '0777';
+    $chmod = (isset($_GET['chmod']) and preg_match(',^[0-9]+$,', $_GET['chmod'])) ?
+        sprintf('%04o', $_GET['chmod']) : '0777';
 
-	if (@is_readable(_FILE_CHMOD_TMP)) {
-		$s = @join('', @file(_FILE_CHMOD_TMP));
-		if (preg_match("#define\('_SPIP_CHMOD', (.*)\)#", $s, $regs)) {
-			$chmod = $regs[1];
-		}
-	}
+    if (@is_readable(_FILE_CHMOD_TMP)) {
+        $s = @join('', @file(_FILE_CHMOD_TMP));
+        if (preg_match("#define\('_SPIP_CHMOD', (.*)\)#", $s, $regs)) {
+            $chmod = $regs[1];
+        }
+    }
 
 
-	$db = [$adresse_db, _T('entree_base_donnee_2')];
-	$login = [$login_db, _T('entree_login_connexion_2')];
-	$pass = ['', _T('entree_mot_passe_2')];
+    $db = [$adresse_db, _T('entree_base_donnee_2')];
+    $login = [$login_db, _T('entree_login_connexion_2')];
+    $pass = ['', _T('entree_mot_passe_2')];
 
-	$predef = [
-		defined('_INSTALL_SERVER_DB') ? _INSTALL_SERVER_DB : '',
-		defined('_INSTALL_HOST_DB'),
-		defined('_INSTALL_USER_DB'),
-		defined('_INSTALL_PASS_DB')
-	];
+    $predef = [
+        defined('_INSTALL_SERVER_DB') ? _INSTALL_SERVER_DB : '',
+        defined('_INSTALL_HOST_DB'),
+        defined('_INSTALL_USER_DB'),
+        defined('_INSTALL_PASS_DB')
+    ];
 
 
-	echo info_progression_etape(1, 'etape_', 'install/');
+    echo info_progression_etape(1, 'etape_', 'install/');
 
-	// ces deux chaines de langues doivent etre reecrites
+    // ces deux chaines de langues doivent etre reecrites
 #	echo info_etape(_T('info_connexion_mysql'), _T('texte_connexion_mysql').aide ("install1", true));
-	echo info_etape(_T('info_connexion_base_donnee'));
-	echo install_connexion_form($db, $login, $pass, $predef, "\n<input type='hidden' name='chmod' value='$chmod' />", 2);
-	echo install_fin_html();
+    echo info_etape(_T('info_connexion_base_donnee'));
+    echo install_connexion_form($db, $login, $pass, $predef, "\n<input type='hidden' name='chmod' value='$chmod' />", 2);
+    echo install_fin_html();
 }

ecrire/install/etape_3b.php

Indentation +138 added lines, -138 removed lines

@@ -11,147 +11,147 @@
 \***************************************************************************/
 
 if (!defined('_ECRIRE_INC_VERSION')) {
-	return;
+    return;
 }
 
 include_spip('inc/headers');
 
 function install_etape_3b_dist() {
-	$auth_spip = null;
-	$session = null;
-	$row = null;
-	$login = _request('login');
-	$email = _request('email');
-	$nom = _request('nom');
-	$pass = _request('pass');
-	$pass_verif = _request('pass_verif');
-
-	$server_db = defined('_INSTALL_SERVER_DB')
-		? _INSTALL_SERVER_DB
-		: _request('server_db');
-
-	if (!defined('_PASS_LONGUEUR_MINI')) {
-		define('_PASS_LONGUEUR_MINI', 6);
-	}
-	if (!defined('_LOGIN_TROP_COURT')) {
-		define('_LOGIN_TROP_COURT', 4);
-	}
-	if ($login) {
-		$echec = ($pass != $pass_verif) ?
-			_T('info_passes_identiques')
-			: ((strlen($pass) < _PASS_LONGUEUR_MINI) ?
-				_T('info_passe_trop_court_car_pluriel', ['nb' => _PASS_LONGUEUR_MINI])
-				: ((strlen($login) < _LOGIN_TROP_COURT) ?
-					_T('info_login_trop_court')
-					: ''));
-		include_spip('inc/filtres');
-		if (!$echec and $email and !email_valide($email)) {
-			$echec = _T('form_email_non_valide');
-		}
-		if ($echec) {
-			echo minipres(
-				'AUTO',
-				info_progression_etape(3, 'etape_', 'install/', true) .
-				"<div class='error'><h3>$echec</h3>\n" .
-				'<p>' . _T('avis_connexion_echec_2') . '</p>' .
-				'</div>'
-			);
-			exit;
-		}
-	}
-
-	if (@file_exists(_FILE_CHMOD_TMP)) {
-		include(_FILE_CHMOD_TMP);
-	} else {
-		redirige_url_ecrire('install');
-	}
-
-	if (!@file_exists(_FILE_CONNECT_TMP)) {
-		redirige_url_ecrire('install');
-	}
-
-	# maintenant on connait le vrai charset du site s'il est deja configure
-	# sinon par defaut lire_meta reglera _DEFAULT_CHARSET
-	# (les donnees arrivent de toute facon postees en _DEFAULT_CHARSET)
-
-	lire_metas();
-	if ($login) {
-		include_spip('inc/charsets');
-
-		$nom = (importer_charset($nom, _DEFAULT_CHARSET));
-		$login = (importer_charset($login, _DEFAULT_CHARSET));
-		$email = (importer_charset($email, _DEFAULT_CHARSET));
-		# pour le passwd, bizarrement il faut le convertir comme s'il avait
-		# ete tape en iso-8859-1 ; car c'est en fait ce que voit md5.js
-		$pass = unicode2charset(utf_8_to_unicode($pass), 'iso-8859-1');
-		include_spip('auth/sha256.inc');
-		include_spip('inc/acces');
-		$htpass = generer_htpass($pass);
-		$alea_actuel = creer_uniqid();
-		$alea_futur = creer_uniqid();
-		$shapass = spip_sha256($alea_actuel . $pass);
-		// prelablement, creer le champ webmestre si il n'existe pas (install neuve
-		// sur une vieille base
-		$t = sql_showtable('spip_auteurs', true);
-		if (!isset($t['field']['webmestre'])) {
-			@sql_alter("TABLE spip_auteurs ADD webmestre varchar(3)  DEFAULT 'non' NOT NULL");
-		}
-
-		$id_auteur = sql_getfetsel('id_auteur', 'spip_auteurs', 'login=' . sql_quote($login));
-		if ($id_auteur !== null) {
-			sql_updateq('spip_auteurs', [
-				'nom' => $nom,
-				'email' => $email,
-				'login' => $login,
-				'pass' => $shapass,
-				'alea_actuel' => $alea_actuel,
-				'alea_futur' => $alea_futur,
-				'htpass' => $htpass,
-				'statut' => '0minirezo'
-			], "id_auteur=$id_auteur");
-		} else {
-			$id_auteur = sql_insertq('spip_auteurs', [
-				'nom' => $nom,
-				'email' => $email,
-				'login' => $login,
-				'pass' => $shapass,
-				'htpass' => $htpass,
-				'alea_actuel' => $alea_actuel,
-				'alea_futur' => $alea_futur,
-				'statut' => '0minirezo'
-			]);
-		}
-		// le passer webmestre separrement du reste, au cas ou l'alter n'aurait pas fonctionne
-		@sql_updateq('spip_auteurs', ['webmestre' => 'oui'], "id_auteur=$id_auteur");
-
-		// inserer email comme email webmaster principal
-		// (sauf s'il est vide: cas de la re-installation)
-		if ($email) {
-			ecrire_meta('email_webmaster', $email);
-		}
-
-		// Connecter directement celui qui vient de (re)donner son login
-		// mais sans cookie d'admin ni connexion longue
-		include_spip('inc/auth');
-		if (
-			!$auteur = auth_identifier_login($login, $pass)
-			or !auth_loger($auteur)
-		) {
-			spip_log("login automatique impossible $auth_spip $session" . (is_countable($row) ? count($row) : 0));
-		}
-	}
-
-	// installer les metas
-	$config = charger_fonction('config', 'inc');
-	$config();
-
-	// activer les plugins
-	// leur installation ne peut pas se faire sur le meme hit, il faudra donc
-	// poursuivre au hit suivant
-	include_spip('inc/plugin');
-	actualise_plugins_actifs();
-
-
-	include_spip('inc/distant');
-	redirige_par_entete(parametre_url(self(), 'etape', '4', '&'));
+    $auth_spip = null;
+    $session = null;
+    $row = null;
+    $login = _request('login');
+    $email = _request('email');
+    $nom = _request('nom');
+    $pass = _request('pass');
+    $pass_verif = _request('pass_verif');
+
+    $server_db = defined('_INSTALL_SERVER_DB')
+        ? _INSTALL_SERVER_DB
+        : _request('server_db');
+
+    if (!defined('_PASS_LONGUEUR_MINI')) {
+        define('_PASS_LONGUEUR_MINI', 6);
+    }
+    if (!defined('_LOGIN_TROP_COURT')) {
+        define('_LOGIN_TROP_COURT', 4);
+    }
+    if ($login) {
+        $echec = ($pass != $pass_verif) ?
+            _T('info_passes_identiques')
+            : ((strlen($pass) < _PASS_LONGUEUR_MINI) ?
+                _T('info_passe_trop_court_car_pluriel', ['nb' => _PASS_LONGUEUR_MINI])
+                : ((strlen($login) < _LOGIN_TROP_COURT) ?
+                    _T('info_login_trop_court')
+                    : ''));
+        include_spip('inc/filtres');
+        if (!$echec and $email and !email_valide($email)) {
+            $echec = _T('form_email_non_valide');
+        }
+        if ($echec) {
+            echo minipres(
+                'AUTO',
+                info_progression_etape(3, 'etape_', 'install/', true) .
+                "<div class='error'><h3>$echec</h3>\n" .
+                '<p>' . _T('avis_connexion_echec_2') . '</p>' .
+                '</div>'
+            );
+            exit;
+        }
+    }
+
+    if (@file_exists(_FILE_CHMOD_TMP)) {
+        include(_FILE_CHMOD_TMP);
+    } else {
+        redirige_url_ecrire('install');
+    }
+
+    if (!@file_exists(_FILE_CONNECT_TMP)) {
+        redirige_url_ecrire('install');
+    }
+
+    # maintenant on connait le vrai charset du site s'il est deja configure
+    # sinon par defaut lire_meta reglera _DEFAULT_CHARSET
+    # (les donnees arrivent de toute facon postees en _DEFAULT_CHARSET)
+
+    lire_metas();
+    if ($login) {
+        include_spip('inc/charsets');
+
+        $nom = (importer_charset($nom, _DEFAULT_CHARSET));
+        $login = (importer_charset($login, _DEFAULT_CHARSET));
+        $email = (importer_charset($email, _DEFAULT_CHARSET));
+        # pour le passwd, bizarrement il faut le convertir comme s'il avait
+        # ete tape en iso-8859-1 ; car c'est en fait ce que voit md5.js
+        $pass = unicode2charset(utf_8_to_unicode($pass), 'iso-8859-1');
+        include_spip('auth/sha256.inc');
+        include_spip('inc/acces');
+        $htpass = generer_htpass($pass);
+        $alea_actuel = creer_uniqid();
+        $alea_futur = creer_uniqid();
+        $shapass = spip_sha256($alea_actuel . $pass);
+        // prelablement, creer le champ webmestre si il n'existe pas (install neuve
+        // sur une vieille base
+        $t = sql_showtable('spip_auteurs', true);
+        if (!isset($t['field']['webmestre'])) {
+            @sql_alter("TABLE spip_auteurs ADD webmestre varchar(3)  DEFAULT 'non' NOT NULL");
+        }
+
+        $id_auteur = sql_getfetsel('id_auteur', 'spip_auteurs', 'login=' . sql_quote($login));
+        if ($id_auteur !== null) {
+            sql_updateq('spip_auteurs', [
+                'nom' => $nom,
+                'email' => $email,
+                'login' => $login,
+                'pass' => $shapass,
+                'alea_actuel' => $alea_actuel,
+                'alea_futur' => $alea_futur,
+                'htpass' => $htpass,
+                'statut' => '0minirezo'
+            ], "id_auteur=$id_auteur");
+        } else {
+            $id_auteur = sql_insertq('spip_auteurs', [
+                'nom' => $nom,
+                'email' => $email,
+                'login' => $login,
+                'pass' => $shapass,
+                'htpass' => $htpass,
+                'alea_actuel' => $alea_actuel,
+                'alea_futur' => $alea_futur,
+                'statut' => '0minirezo'
+            ]);
+        }
+        // le passer webmestre separrement du reste, au cas ou l'alter n'aurait pas fonctionne
+        @sql_updateq('spip_auteurs', ['webmestre' => 'oui'], "id_auteur=$id_auteur");
+
+        // inserer email comme email webmaster principal
+        // (sauf s'il est vide: cas de la re-installation)
+        if ($email) {
+            ecrire_meta('email_webmaster', $email);
+        }
+
+        // Connecter directement celui qui vient de (re)donner son login
+        // mais sans cookie d'admin ni connexion longue
+        include_spip('inc/auth');
+        if (
+            !$auteur = auth_identifier_login($login, $pass)
+            or !auth_loger($auteur)
+        ) {
+            spip_log("login automatique impossible $auth_spip $session" . (is_countable($row) ? count($row) : 0));
+        }
+    }
+
+    // installer les metas
+    $config = charger_fonction('config', 'inc');
+    $config();
+
+    // activer les plugins
+    // leur installation ne peut pas se faire sur le meme hit, il faudra donc
+    // poursuivre au hit suivant
+    include_spip('inc/plugin');
+    actualise_plugins_actifs();
+
+
+    include_spip('inc/distant');
+    redirige_par_entete(parametre_url(self(), 'etape', '4', '&'));
 }

ecrire/genie/mise_a_jour.php

Indentation +116 added lines, -116 removed lines

@@ -17,7 +17,7 @@ 
  */
 
 if (!defined('_ECRIRE_INC_VERSION')) {
-	return;
+    return;
 }
 
 /**
@@ -27,15 +27,15 @@ 
  * @return int
  */
 function genie_mise_a_jour_dist($t) {
-	include_spip('inc/meta');
-	$maj = info_maj('spip', 'SPIP', $GLOBALS['spip_version_branche']);
-	ecrire_meta('info_maj_spip', $maj ? ($GLOBALS['spip_version_branche'] . "|$maj") : '', 'non');
+    include_spip('inc/meta');
+    $maj = info_maj('spip', 'SPIP', $GLOBALS['spip_version_branche']);
+    ecrire_meta('info_maj_spip', $maj ? ($GLOBALS['spip_version_branche'] . "|$maj") : '', 'non');
 
-	mise_a_jour_ecran_securite();
+    mise_a_jour_ecran_securite();
 
-	spip_log('Verification version SPIP : ' . ($maj ?: 'version a jour'), 'verifie_maj');
+    spip_log('Verification version SPIP : ' . ($maj ?: 'version a jour'), 'verifie_maj');
 
-	return 1;
+    return 1;
 }
 
 // TODO : fournir une URL sur spip.net pour maitriser la diffusion d'une nouvelle version de l'ecran via l'update auto
@@ -52,46 +52,46 @@ 
  * ou de ne repondre une 304 que si le md5 est bon
  */
 function mise_a_jour_ecran_securite() {
-	// TODO : url https avec verification du certificat
-	return;
-
-	// si l'ecran n'est pas deja present ou pas updatable, sortir
-	if (
-		!_URL_ECRAN_SECURITE
-		or !file_exists($filename = _DIR_ETC . 'ecran_securite.php')
-		or !is_writable($filename)
-		or !$last_modified = filemtime($filename)
-		or !$md5 = md5_file($filename)
-	) {
-		return false;
-	}
-
-	include_spip('inc/distant');
-	$tmp_file = _DIR_TMP . 'ecran_securite.php';
-	$url = parametre_url(_URL_ECRAN_SECURITE, 'md5', $md5);
-	$url = parametre_url($url, 'vspip', $GLOBALS['spip_version_branche']);
-	$res = recuperer_url($url, [
-		'if_modified_since' => $last_modified,
-		'file' => $tmp_file
-	]);
-
-	// si il y a une version plus recente que l'on a recu correctement
-	if (
-		$res['status'] == 200
-		and $res['length']
-		and $tmp_file = $res['file']
-	) {
-		if ($md5 !== md5_file($tmp_file)) {
-			// on essaye de l'inclure pour verifier que ca ne fait pas erreur fatale
-			include_once $tmp_file;
-			// ok, on le copie a la place de l'ecran existant
-			// en backupant l'ecran avant, au cas ou
-			@copy($filename, $filename . '-bck-' . date('Y-m-d-His', $last_modified));
-			@rename($tmp_file, $filename);
-		} else {
-			@unlink($tmp_file);
-		}
-	}
+    // TODO : url https avec verification du certificat
+    return;
+
+    // si l'ecran n'est pas deja present ou pas updatable, sortir
+    if (
+        !_URL_ECRAN_SECURITE
+        or !file_exists($filename = _DIR_ETC . 'ecran_securite.php')
+        or !is_writable($filename)
+        or !$last_modified = filemtime($filename)
+        or !$md5 = md5_file($filename)
+    ) {
+        return false;
+    }
+
+    include_spip('inc/distant');
+    $tmp_file = _DIR_TMP . 'ecran_securite.php';
+    $url = parametre_url(_URL_ECRAN_SECURITE, 'md5', $md5);
+    $url = parametre_url($url, 'vspip', $GLOBALS['spip_version_branche']);
+    $res = recuperer_url($url, [
+        'if_modified_since' => $last_modified,
+        'file' => $tmp_file
+    ]);
+
+    // si il y a une version plus recente que l'on a recu correctement
+    if (
+        $res['status'] == 200
+        and $res['length']
+        and $tmp_file = $res['file']
+    ) {
+        if ($md5 !== md5_file($tmp_file)) {
+            // on essaye de l'inclure pour verifier que ca ne fait pas erreur fatale
+            include_once $tmp_file;
+            // ok, on le copie a la place de l'ecran existant
+            // en backupant l'ecran avant, au cas ou
+            @copy($filename, $filename . '-bck-' . date('Y-m-d-His', $last_modified));
+            @rename($tmp_file, $filename);
+        } else {
+            @unlink($tmp_file);
+        }
+    }
 }
 
 /**
@@ -109,54 +109,54 @@ 
  * @return string
  */
 function info_maj($dir, $file, $version) {
-	include_spip('inc/plugin');
-
-	[$maj, $min, $rev] = preg_split('/\D+/', $version);
-
-	$nom = _DIR_CACHE_XML . _VERSIONS_LISTE;
-	$page = !file_exists($nom) ? '' : file_get_contents($nom);
-	$page = info_maj_cache($nom, $dir, $page);
-
-	// reperer toutes les versions de numero majeur superieur ou egal
-	// (a revoir quand on arrivera a SPIP V10 ...)
-	$p = substr('0123456789', intval($maj));
-	$p = ',/' . $file . '\D+([' . $p . ']+)\D+(\d+)(\D+(\d+))?.*?[.]zip",i';
-	preg_match_all($p, $page, $m, PREG_SET_ORDER);
-	$page = $page_majeure = '';
-
-	// branche en cours d'utilisation
-	$branche = implode('.', array_slice(explode('.', $version, 3), 0, 2));
-
-	foreach ($m as $v) {
-		$v = array_pad($v, 5, 0);
-		[, $maj2, $min2, , $rev2] = $v;
-		$branche_maj = $maj2 . '.' . $min2;
-		$version_maj = $maj2 . '.' . $min2 . '.' . $rev2;
-		// d'abord les mises à jour de la même branche
-		if (
-			(spip_version_compare($version, $version_maj, '<'))
-			and (spip_version_compare($page, $version_maj, '<'))
-			and spip_version_compare($branche, $branche_maj, '=')
-		) {
-			$page = $version_maj;
-		}
-		// puis les mises à jours majeures
-		if (
-			(spip_version_compare($version, $version_maj, '<'))
-			and (spip_version_compare($page, $version_maj, '<'))
-			and spip_version_compare($branche, $branche_maj, '<')
-		) {
-			$page_majeure = $version_maj;
-		}
-	}
-	if (!$page and !$page_majeure) {
-		return '';
-	}
-
-	$message = $page ? _T('nouvelle_version_spip', ['version' => $page]) . ($page_majeure ? ' | ' : '') : '';
-	$message .= $page_majeure ? _T('nouvelle_version_spip_majeure', ['version' => $page_majeure]) : '';
-
-	return "<a class='info_maj_spip' href='https://www.spip.net/fr_update' title='$page'>" . $message . '</a>';
+    include_spip('inc/plugin');
+
+    [$maj, $min, $rev] = preg_split('/\D+/', $version);
+
+    $nom = _DIR_CACHE_XML . _VERSIONS_LISTE;
+    $page = !file_exists($nom) ? '' : file_get_contents($nom);
+    $page = info_maj_cache($nom, $dir, $page);
+
+    // reperer toutes les versions de numero majeur superieur ou egal
+    // (a revoir quand on arrivera a SPIP V10 ...)
+    $p = substr('0123456789', intval($maj));
+    $p = ',/' . $file . '\D+([' . $p . ']+)\D+(\d+)(\D+(\d+))?.*?[.]zip",i';
+    preg_match_all($p, $page, $m, PREG_SET_ORDER);
+    $page = $page_majeure = '';
+
+    // branche en cours d'utilisation
+    $branche = implode('.', array_slice(explode('.', $version, 3), 0, 2));
+
+    foreach ($m as $v) {
+        $v = array_pad($v, 5, 0);
+        [, $maj2, $min2, , $rev2] = $v;
+        $branche_maj = $maj2 . '.' . $min2;
+        $version_maj = $maj2 . '.' . $min2 . '.' . $rev2;
+        // d'abord les mises à jour de la même branche
+        if (
+            (spip_version_compare($version, $version_maj, '<'))
+            and (spip_version_compare($page, $version_maj, '<'))
+            and spip_version_compare($branche, $branche_maj, '=')
+        ) {
+            $page = $version_maj;
+        }
+        // puis les mises à jours majeures
+        if (
+            (spip_version_compare($version, $version_maj, '<'))
+            and (spip_version_compare($page, $version_maj, '<'))
+            and spip_version_compare($branche, $branche_maj, '<')
+        ) {
+            $page_majeure = $version_maj;
+        }
+    }
+    if (!$page and !$page_majeure) {
+        return '';
+    }
+
+    $message = $page ? _T('nouvelle_version_spip', ['version' => $page]) . ($page_majeure ? ' | ' : '') : '';
+    $message .= $page_majeure ? _T('nouvelle_version_spip_majeure', ['version' => $page_majeure]) : '';
+
+    return "<a class='info_maj_spip' href='https://www.spip.net/fr_update' title='$page'>" . $message . '</a>';
 }
 
 /**
@@ -177,25 +177,25 @@ 
  *     Contenu du fichier de cache de l'info de maj de SPIP.
  */
 function info_maj_cache($nom, $dir, $page = '') {
-	include_spip('inc/acces');
-	$alea_ephemere = charger_aleas();
-	$re = '<archives id="a' . $alea_ephemere . '">';
-	if (preg_match("/$re/", $page)) {
-		return $page;
-	}
-
-	$url = _VERSIONS_SERVEUR . $dir . '/' . _VERSIONS_LISTE;
-	$a = file_exists($nom) ? filemtime($nom) : '';
-	include_spip('inc/distant');
-	$res = recuperer_url_cache($url, ['if_modified_since' => $a]);
-	// Si rien de neuf (ou inaccessible), garder l'ancienne
-	if ($res) {
-		$page = $res['page'] ?: $page;
-	}
-	// Placer l'indicateur de fraicheur
-	$page = preg_replace('/^<archives.*?>/', $re, $page);
-	sous_repertoire(_DIR_CACHE_XML);
-	ecrire_fichier($nom, $page);
-
-	return $page;
+    include_spip('inc/acces');
+    $alea_ephemere = charger_aleas();
+    $re = '<archives id="a' . $alea_ephemere . '">';
+    if (preg_match("/$re/", $page)) {
+        return $page;
+    }
+
+    $url = _VERSIONS_SERVEUR . $dir . '/' . _VERSIONS_LISTE;
+    $a = file_exists($nom) ? filemtime($nom) : '';
+    include_spip('inc/distant');
+    $res = recuperer_url_cache($url, ['if_modified_since' => $a]);
+    // Si rien de neuf (ou inaccessible), garder l'ancienne
+    if ($res) {
+        $page = $res['page'] ?: $page;
+    }
+    // Placer l'indicateur de fraicheur
+    $page = preg_replace('/^<archives.*?>/', $re, $page);
+    sous_repertoire(_DIR_CACHE_XML);
+    ecrire_fichier($nom, $page);
+
+    return $page;
 }

ecrire/genie/optimiser.php

Indentation +111 added lines, -111 removed lines

@@ -17,7 +17,7 @@ 
  **/
 
 if (!defined('_ECRIRE_INC_VERSION')) {
-	return;
+    return;
 }
 
 include_spip('base/abstract_sql');
@@ -35,26 +35,26 @@ 
  **/
 function genie_optimiser_dist($t) {
 
-	optimiser_base_une_table();
-	optimiser_base();
-	optimiser_caches_contextes();
+    optimiser_base_une_table();
+    optimiser_base();
+    optimiser_caches_contextes();
 
-	// la date souhaitee pour le tour suivant = apres-demain a 4h du mat ;
-	// sachant qu'on a un delai de 48h, on renvoie aujourd'hui a 4h du mat
-	// avec une periode de flou entre 2h et 6h pour ne pas saturer un hebergeur
-	// qui aurait beaucoup de sites SPIP
-	return -(mktime(2, 0, 0) + random_int(0, 3600 * 4));
+    // la date souhaitee pour le tour suivant = apres-demain a 4h du mat ;
+    // sachant qu'on a un delai de 48h, on renvoie aujourd'hui a 4h du mat
+    // avec une periode de flou entre 2h et 6h pour ne pas saturer un hebergeur
+    // qui aurait beaucoup de sites SPIP
+    return -(mktime(2, 0, 0) + random_int(0, 3600 * 4));
 }
 
 /**
  * Vider les contextes ajax de plus de 48h
  */
 function optimiser_caches_contextes() {
-	sous_repertoire(_DIR_CACHE, 'contextes');
-	if (is_dir($d = _DIR_CACHE . 'contextes')) {
-		include_spip('inc/invalideur');
-		purger_repertoire($d, ['mtime' => time() - 48 * 24 * 3600, 'limit' => 10000]);
-	}
+    sous_repertoire(_DIR_CACHE, 'contextes');
+    if (is_dir($d = _DIR_CACHE . 'contextes')) {
+        include_spip('inc/invalideur');
+        purger_repertoire($d, ['mtime' => time() - 48 * 24 * 3600, 'limit' => 10000]);
+    }
 }
 
 /**
@@ -69,7 +69,7 @@ 
  * @return void
  **/
 function optimiser_base($attente = 86400) {
-	optimiser_base_disparus($attente);
+    optimiser_base_disparus($attente);
 }
 
 
@@ -86,28 +86,28 @@ 
  **/
 function optimiser_base_une_table() {
 
-	$tables = [];
-	$result = sql_showbase();
-
-	// on n'optimise qu'une seule table a chaque fois,
-	// pour ne pas vautrer le systeme
-	// lire http://dev.mysql.com/doc/refman/5.0/fr/optimize-table.html
-	while ($row = sql_fetch($result)) {
-		$tables[] = array_shift($row);
-	}
-
-	spip_log('optimiser_base_une_table ' . json_encode($tables, JSON_THROW_ON_ERROR), 'genie' . _LOG_DEBUG);
-	if ($tables) {
-		$table_op = intval(lire_config('optimiser_table', 0) + 1) % sizeof($tables);
-		ecrire_config('optimiser_table', $table_op);
-		$q = $tables[$table_op];
-		spip_log("optimiser_base_une_table : debut d'optimisation de la table $q", 'genie' . _LOG_DEBUG);
-		if (sql_optimize($q)) {
-			spip_log("optimiser_base_une_table : fin d'optimisation de la table $q", 'genie' . _LOG_DEBUG);
-		} else {
-			spip_log("optimiser_base_une_table : Pas d'optimiseur necessaire", 'genie' . _LOG_DEBUG);
-		}
-	}
+    $tables = [];
+    $result = sql_showbase();
+
+    // on n'optimise qu'une seule table a chaque fois,
+    // pour ne pas vautrer le systeme
+    // lire http://dev.mysql.com/doc/refman/5.0/fr/optimize-table.html
+    while ($row = sql_fetch($result)) {
+        $tables[] = array_shift($row);
+    }
+
+    spip_log('optimiser_base_une_table ' . json_encode($tables, JSON_THROW_ON_ERROR), 'genie' . _LOG_DEBUG);
+    if ($tables) {
+        $table_op = intval(lire_config('optimiser_table', 0) + 1) % sizeof($tables);
+        ecrire_config('optimiser_table', $table_op);
+        $q = $tables[$table_op];
+        spip_log("optimiser_base_une_table : debut d'optimisation de la table $q", 'genie' . _LOG_DEBUG);
+        if (sql_optimize($q)) {
+            spip_log("optimiser_base_une_table : fin d'optimisation de la table $q", 'genie' . _LOG_DEBUG);
+        } else {
+            spip_log("optimiser_base_une_table : Pas d'optimiseur necessaire", 'genie' . _LOG_DEBUG);
+        }
+    }
 }
 
 
@@ -133,18 +133,18 @@ 
  *     Nombre de suppressions
  **/
 function optimiser_sansref($table, $id, $sel, $and = '') {
-	$in = [];
-	while ($row = sql_fetch($sel)) {
-		$in[$row['id']] = true;
-	}
-	sql_free($sel);
-
-	if ($in) {
-		sql_delete($table, sql_in($id, array_keys($in)) . ($and ? " AND $and" : ''));
-		spip_log("optimiser_sansref: Numeros des entrees $id supprimees dans la table $table: " . implode(', ', array_keys($in)), 'genie' . _LOG_DEBUG);
-	}
-
-	return count($in);
+    $in = [];
+    while ($row = sql_fetch($sel)) {
+        $in[$row['id']] = true;
+    }
+    sql_free($sel);
+
+    if ($in) {
+        sql_delete($table, sql_in($id, array_keys($in)) . ($and ? " AND $and" : ''));
+        spip_log("optimiser_sansref: Numeros des entrees $id supprimees dans la table $table: " . implode(', ', array_keys($in)), 'genie' . _LOG_DEBUG);
+    }
+
+    return count($in);
 }
 
 
@@ -166,81 +166,81 @@ 
  **/
 function optimiser_base_disparus($attente = 86400) {
 
-	# format = 20060610110141, si on veut forcer une optimisation tout de suite
-	$mydate = date('Y-m-d H:i:s', time() - $attente);
-	$mydate_quote = sql_quote($mydate);
+    # format = 20060610110141, si on veut forcer une optimisation tout de suite
+    $mydate = date('Y-m-d H:i:s', time() - $attente);
+    $mydate_quote = sql_quote($mydate);
 
-	$n = 0;
+    $n = 0;
 
-	//
-	// Rubriques
-	//
+    //
+    // Rubriques
+    //
 
-	# les articles qui sont dans une id_rubrique inexistante
-	# attention on controle id_rubrique>0 pour ne pas tuer les articles
-	# specialement affectes a une rubrique non-existante (plugin,
-	# cf. https://core.spip.net/issues/1549 )
-	$res = sql_select(
-		'A.id_article AS id',
-		'spip_articles AS A
+    # les articles qui sont dans une id_rubrique inexistante
+    # attention on controle id_rubrique>0 pour ne pas tuer les articles
+    # specialement affectes a une rubrique non-existante (plugin,
+    # cf. https://core.spip.net/issues/1549 )
+    $res = sql_select(
+        'A.id_article AS id',
+        'spip_articles AS A
 		        LEFT JOIN spip_rubriques AS R
 		          ON A.id_rubrique=R.id_rubrique',
-		"A.id_rubrique > 0
+        "A.id_rubrique > 0
 			 AND R.id_rubrique IS NULL
 		         AND A.maj < $mydate_quote"
-	);
+    );
 
-	$n += optimiser_sansref('spip_articles', 'id_article', $res);
+    $n += optimiser_sansref('spip_articles', 'id_article', $res);
 
-	// les articles a la poubelle
-	sql_delete('spip_articles', "statut='poubelle' AND maj < $mydate_quote");
+    // les articles a la poubelle
+    sql_delete('spip_articles', "statut='poubelle' AND maj < $mydate_quote");
 
-	//
-	// Auteurs
-	//
+    //
+    // Auteurs
+    //
 
-	include_spip('action/editer_liens');
-	// optimiser les liens de tous les auteurs vers des objets effaces
-	// et depuis des auteurs effaces
-	$n += objet_optimiser_liens(['auteur' => '*'], '*');
+    include_spip('action/editer_liens');
+    // optimiser les liens de tous les auteurs vers des objets effaces
+    // et depuis des auteurs effaces
+    $n += objet_optimiser_liens(['auteur' => '*'], '*');
 
-	# effacer les auteurs poubelle qui ne sont lies a rien
-	$res = sql_select(
-		'A.id_auteur AS id',
-		'spip_auteurs AS A
+    # effacer les auteurs poubelle qui ne sont lies a rien
+    $res = sql_select(
+        'A.id_auteur AS id',
+        'spip_auteurs AS A
 		      	LEFT JOIN spip_auteurs_liens AS L
 		          ON L.id_auteur=A.id_auteur',
-		"L.id_auteur IS NULL
+        "L.id_auteur IS NULL
 		       	AND A.statut='5poubelle' AND A.maj < $mydate_quote"
-	);
-
-	$n += optimiser_sansref('spip_auteurs', 'id_auteur', $res);
-
-	# supprimer les auteurs 'nouveau' qui n'ont jamais donne suite
-	# au mail de confirmation (45 jours pour repondre, ca devrait suffire)
-	if (!defined('_AUTEURS_DELAI_REJET_NOUVEAU')) {
-		define('_AUTEURS_DELAI_REJET_NOUVEAU', 45 * 24 * 3600);
-	}
-	sql_delete('spip_auteurs', "statut='nouveau' AND maj < " . sql_quote(date('Y-m-d', time() - intval(_AUTEURS_DELAI_REJET_NOUVEAU))));
-
-	/**
-	 * Permet aux plugins de compléter l'optimisation suite aux éléments disparus
-	 *
-	 * L'index 'data' est un entier indiquant le nombre d'optimisations
-	 * qui ont été réalisées (par exemple le nombre de suppressions faites)
-	 * et qui doit être incrémenté par les fonctions
-	 * utilisant ce pipeline si elles suppriment des éléments.
-	 *
-	 * @pipeline_appel optimiser_base_disparus
-	 */
-	$n = pipeline('optimiser_base_disparus', [
-		'args' => [
-			'attente' => $attente,
-			'date' => $mydate
-		],
-		'data' => $n
-	]);
-
-
-	spip_log("optimiser_base_disparus : {$n} lien(s) mort(s)", 'genie' . _LOG_DEBUG);
+    );
+
+    $n += optimiser_sansref('spip_auteurs', 'id_auteur', $res);
+
+    # supprimer les auteurs 'nouveau' qui n'ont jamais donne suite
+    # au mail de confirmation (45 jours pour repondre, ca devrait suffire)
+    if (!defined('_AUTEURS_DELAI_REJET_NOUVEAU')) {
+        define('_AUTEURS_DELAI_REJET_NOUVEAU', 45 * 24 * 3600);
+    }
+    sql_delete('spip_auteurs', "statut='nouveau' AND maj < " . sql_quote(date('Y-m-d', time() - intval(_AUTEURS_DELAI_REJET_NOUVEAU))));
+
+    /**
+     * Permet aux plugins de compléter l'optimisation suite aux éléments disparus
+     *
+     * L'index 'data' est un entier indiquant le nombre d'optimisations
+     * qui ont été réalisées (par exemple le nombre de suppressions faites)
+     * et qui doit être incrémenté par les fonctions
+     * utilisant ce pipeline si elles suppriment des éléments.
+     *
+     * @pipeline_appel optimiser_base_disparus
+     */
+    $n = pipeline('optimiser_base_disparus', [
+        'args' => [
+            'attente' => $attente,
+            'date' => $mydate
+        ],
+        'data' => $n
+    ]);
+
+
+    spip_log("optimiser_base_disparus : {$n} lien(s) mort(s)", 'genie' . _LOG_DEBUG);
 }