spip / SPIP

ecrire/action/cookie.php

Indentation +86 added lines, -86 removed lines

@@ -16,7 +16,7 @@ 
  */
 
 if (!defined('_ECRIRE_INC_VERSION')) {
-	return;
+    return;
 }
 
 include_spip('inc/actions');
@@ -32,94 +32,94 @@ 
  * @return void
  */
 function action_cookie_dist($set_cookie_admin = null, $change_session = null) {
-	$redirect_echec = $redirect = null;
-	$test_echec_cookie = null;
-	$url = '';
-	if (is_null($set_cookie_admin)) {
-		$set_cookie_admin = _request('cookie_admin');
-		$change_session = _request('change_session');
-		$test_echec_cookie = _request('test_echec_cookie');
+    $redirect_echec = $redirect = null;
+    $test_echec_cookie = null;
+    $url = '';
+    if (is_null($set_cookie_admin)) {
+        $set_cookie_admin = _request('cookie_admin');
+        $change_session = _request('change_session');
+        $test_echec_cookie = _request('test_echec_cookie');
 
-		// La cible de notre operation de connexion
-		$url = securiser_redirect_action(_request('url'));
-		$redirect = $url ?: generer_url_ecrire('accueil');
-		$redirect_echec = _request('url_echec');
-		if (!isset($redirect_echec)) {
-			if (str_contains((string) $redirect, (string) _DIR_RESTREINT_ABS)) {
-				$redirect_echec = generer_url_public('login', '', true);
-			} else {
-				$redirect_echec = $redirect;
-			}
-		}
-	}
+        // La cible de notre operation de connexion
+        $url = securiser_redirect_action(_request('url'));
+        $redirect = $url ?: generer_url_ecrire('accueil');
+        $redirect_echec = _request('url_echec');
+        if (!isset($redirect_echec)) {
+            if (str_contains((string) $redirect, (string) _DIR_RESTREINT_ABS)) {
+                $redirect_echec = generer_url_public('login', '', true);
+            } else {
+                $redirect_echec = $redirect;
+            }
+        }
+    }
 
 
-	// rejoue le cookie pour renouveler spip_session
-	if ($change_session == 'oui') {
-		$session = charger_fonction('session', 'inc');
-		$session(true);
-		spip_logger()->info('statut 204 pour ' . $_SERVER['REQUEST_URI']);
-		http_response_code(204); // No Content
-		return;
-	}
+    // rejoue le cookie pour renouveler spip_session
+    if ($change_session == 'oui') {
+        $session = charger_fonction('session', 'inc');
+        $session(true);
+        spip_logger()->info('statut 204 pour ' . $_SERVER['REQUEST_URI']);
+        http_response_code(204); // No Content
+        return;
+    }
 
-	// tentative de connexion en auth_http
-	if (_request('essai_auth_http') && !$GLOBALS['ignore_auth_http']) {
-		include_spip('inc/auth');
-		if (
-			@$_SERVER['PHP_AUTH_USER']
-			&& @$_SERVER['PHP_AUTH_PW']
-			&& ($auteur = lire_php_auth($_SERVER['PHP_AUTH_USER'], $_SERVER['PHP_AUTH_PW']))
-		) {
-			auth_loger($auteur);
-			redirige_par_entete(parametre_url($redirect, 't', time(), '&'));
-		} else {
-			ask_php_auth(
-				_T('info_connexion_refusee'),
-				_T('login_login_pass_incorrect'),
-				_T('login_retour_site'),
-				'url=' . rawurlencode((string) $redirect),
-				_T('login_nouvelle_tentative'),
-				(str_contains((string) $url, (string) _DIR_RESTREINT_ABS))
-			);
-		}
-	} else {
-		// en cas de login sur bonjour=oui, on tente de poser un cookie
-		// puis de passer au login qui diagnostiquera l'echec de cookie
-		// le cas echeant.
-		if ($test_echec_cookie == 'oui') {
-			spip_setcookie('spip_session', 'test_echec_cookie', httponly: true);
-			if ($redirect) {
-				$redirect = parametre_url(
-					parametre_url($redirect_echec, 'var_echec_cookie', 'oui', '&'),
-					'url',
-					rawurlencode((string) $redirect),
-					'&'
-				);
-			}
-		} else {
-			$cook = $_COOKIE['spip_admin'] ?? '';
-			// Suppression cookie d'admin ?
-			if ($set_cookie_admin == 'non') {
-				if ($cook) {
-					spip_setcookie('spip_admin', $cook, time() - 3600 * 24, httponly: true);
-				}
-			} // Ajout de cookie d'admin
-			else {
-				if ($set_cookie_admin && _DUREE_COOKIE_ADMIN) {
-					spip_setcookie(
-						'spip_admin',
-						$set_cookie_admin,
-						time() + max(_DUREE_COOKIE_ADMIN, 2 * _RENOUVELLE_ALEA),
-						httponly: true
-					);
-				}
-			}
-		}
-	}
+    // tentative de connexion en auth_http
+    if (_request('essai_auth_http') && !$GLOBALS['ignore_auth_http']) {
+        include_spip('inc/auth');
+        if (
+            @$_SERVER['PHP_AUTH_USER']
+            && @$_SERVER['PHP_AUTH_PW']
+            && ($auteur = lire_php_auth($_SERVER['PHP_AUTH_USER'], $_SERVER['PHP_AUTH_PW']))
+        ) {
+            auth_loger($auteur);
+            redirige_par_entete(parametre_url($redirect, 't', time(), '&'));
+        } else {
+            ask_php_auth(
+                _T('info_connexion_refusee'),
+                _T('login_login_pass_incorrect'),
+                _T('login_retour_site'),
+                'url=' . rawurlencode((string) $redirect),
+                _T('login_nouvelle_tentative'),
+                (str_contains((string) $url, (string) _DIR_RESTREINT_ABS))
+            );
+        }
+    } else {
+        // en cas de login sur bonjour=oui, on tente de poser un cookie
+        // puis de passer au login qui diagnostiquera l'echec de cookie
+        // le cas echeant.
+        if ($test_echec_cookie == 'oui') {
+            spip_setcookie('spip_session', 'test_echec_cookie', httponly: true);
+            if ($redirect) {
+                $redirect = parametre_url(
+                    parametre_url($redirect_echec, 'var_echec_cookie', 'oui', '&'),
+                    'url',
+                    rawurlencode((string) $redirect),
+                    '&'
+                );
+            }
+        } else {
+            $cook = $_COOKIE['spip_admin'] ?? '';
+            // Suppression cookie d'admin ?
+            if ($set_cookie_admin == 'non') {
+                if ($cook) {
+                    spip_setcookie('spip_admin', $cook, time() - 3600 * 24, httponly: true);
+                }
+            } // Ajout de cookie d'admin
+            else {
+                if ($set_cookie_admin && _DUREE_COOKIE_ADMIN) {
+                    spip_setcookie(
+                        'spip_admin',
+                        $set_cookie_admin,
+                        time() + max(_DUREE_COOKIE_ADMIN, 2 * _RENOUVELLE_ALEA),
+                        httponly: true
+                    );
+                }
+            }
+        }
+    }
 
-	// Redirection finale
-	if ($redirect) {
-		redirige_par_entete($redirect, true);
-	}
+    // Redirection finale
+    if ($redirect) {
+        redirige_par_entete($redirect, true);
+    }
 }

Spacing +2 added lines, -2 removed lines

@@ -58,7 +58,7 @@ 
 	if ($change_session == 'oui') {
 		$session = charger_fonction('session', 'inc');
 		$session(true);
-		spip_logger()->info('statut 204 pour ' . $_SERVER['REQUEST_URI']);
+		spip_logger()->info('statut 204 pour '.$_SERVER['REQUEST_URI']);
 		http_response_code(204); // No Content
 		return;
 	}
@@ -78,7 +78,7 @@ 
 				_T('info_connexion_refusee'),
 				_T('login_login_pass_incorrect'),
 				_T('login_retour_site'),
-				'url=' . rawurlencode((string) $redirect),
+				'url='.rawurlencode((string) $redirect),
 				_T('login_nouvelle_tentative'),
 				(str_contains((string) $url, (string) _DIR_RESTREINT_ABS))
 			);

ecrire/src/Sql/Sqlite/Traducteur.php

Indentation +176 added lines, -176 removed lines

@@ -11,180 +11,180 @@
  */
 class Traducteur
 {
-	/** Pour les corrections à effectuer sur les requêtes : array(code=>'texte') trouvé
-	 *
-	 * @var array
-	 */
-	public $textes = [];
-
-	protected LoggerInterface $logger;
-
-	/**
-	 * Constructeur
-	 */
-	public function __construct(
-		/** Requête à préparer */
-		public string $query,
-		/** Prefixe des tables à utiliser */
-		public string $prefixe,
-		/** Version SQLite (2 ou 3) */
-		public string $sqlite_version
-	) {
-		$this->logger = spip_logger('sqlite'); // FIXME: inject it.
-	}
-
-	/**
-	 * Transformer la requete pour SQLite
-	 *
-	 * Enlève les textes, transforme la requête pour quelle soit
-	 * bien interprétée par SQLite, puis remet les textes
-	 * la fonction affecte `$this->query`
-	 */
-	public function traduire_requete() {
-		//
-		// 1) Protection des textes en les remplacant par des codes
-		//
-		// enlever les 'textes' et initialiser avec
-		[$this->query, $textes] = query_echappe_textes($this->query);
-
-		//
-		// 2) Corrections de la requete
-		//
-		// Correction Create Database
-		// Create Database -> requete ignoree
-		if (str_starts_with((string) $this->query, 'CREATE DATABASE')) {
-			$this->logger->notice("Sqlite : requete non executee -> $this->query");
-			$this->query = 'SELECT 1';
-		}
-
-		// Correction Insert Ignore
-		// INSERT IGNORE -> insert (tout court et pas 'insert or replace')
-		if (str_starts_with((string) $this->query, 'INSERT IGNORE')) {
-			$this->logger->debug("Sqlite : requete transformee -> $this->query");
-			$this->query = 'INSERT ' . substr((string) $this->query, '13');
-		}
-
-		// Correction des dates avec INTERVAL
-		// utiliser sql_date_proche() de preference
-		if (str_contains((string) $this->query, 'INTERVAL')) {
-			$this->query = preg_replace_callback(
-				'/DATE_(ADD|SUB)(.*)INTERVAL\s+(\d+)\s+([a-zA-Z]+)\)/U',
-				fn(array $matches): string => $this->_remplacerDateParTime($matches),
-				(string) $this->query
-			);
-		}
-
-		if (str_contains((string) $this->query, 'LEFT(')) {
-			$this->query = str_replace('LEFT(', '_LEFT(', (string) $this->query);
-		}
-
-		if (str_contains((string) $this->query, 'TIMESTAMPDIFF(')) {
-			$this->query = preg_replace('/TIMESTAMPDIFF\(\s*([^,]*)\s*,/Uims', "TIMESTAMPDIFF('\\1',", (string) $this->query);
-		}
-
-		// Correction Field
-		// remplace FIELD(table,i,j,k...) par CASE WHEN table=i THEN n ... ELSE 0 END
-		if (str_contains((string) $this->query, 'FIELD')) {
-			$this->query = preg_replace_callback(
-				'/FIELD\s*\(([^\)]*)\)/',
-				fn(array $matches): string => $this->_remplacerFieldParCase($matches),
-				(string) $this->query
-			);
-		}
-
-		// Correction des noms de tables FROM
-		// mettre les bons noms de table dans from, update, insert, replace...
-		if (preg_match('/\s(SET|VALUES|WHERE|DATABASE)\s/iS', (string) $this->query, $regs)) {
-			$suite = strstr((string) $this->query, $regs[0]);
-			$this->query = substr((string) $this->query, 0, -strlen($suite));
-		} else {
-			$suite = '';
-		}
-		$pref = ($this->prefixe) ? $this->prefixe . '_' : '';
-		$this->query = preg_replace('/([,\s])spip_/S', '\1' . $pref, (string) $this->query) . $suite;
-
-		// Correction zero AS x
-		// pg n'aime pas 0+x AS alias, sqlite, dans le meme style,
-		// n'apprecie pas du tout SELECT 0 as x ... ORDER BY x
-		// il dit que x ne doit pas être un integer dans le order by !
-		// on remplace du coup x par vide() dans ce cas uniquement
-		//
-		// apparait dans public/vertebrer.php et dans le plugin menu aussi qui genere aussi ce genre de requete via un {par num #GET{tri_num}}
-		// mais est-ce encore un soucis pour sqlite en 2021 ? (ie commenter le preg_replace marche très bien en sqlite 3.28)
-		// on ne remplace que dans ORDER BY ou GROUP BY
-		if (str_contains($this->query, '0 AS') && preg_match('/\s(ORDER|GROUP) BY\s/i', $this->query, $regs)) {
-			$suite = strstr($this->query, $regs[0]);
-			$this->query = substr($this->query, 0, -strlen($suite));
-			// on cherche les noms des x dans 0 AS x
-			// on remplace dans $suite le nom par vide()
-			preg_match_all('/\b0 AS\s*([^\s,]+)/', $this->query, $matches, PREG_PATTERN_ORDER);
-			foreach ($matches[1] as $m) {
-				if (str_contains($suite, $m)) {
-					$suite = preg_replace(",\b$m\b,", 'VIDE()', $suite);
-				}
-			}
-			$this->query .= $suite;
-		}
-
-		// Correction possible des divisions entieres
-		// Le standard SQL (lequel? ou?) semble indiquer que
-		// a/b=c doit donner c entier si a et b sont entiers 4/3=1.
-		// C'est ce que retournent effectivement SQL Server et SQLite
-		// Ce n'est pas ce qu'applique MySQL qui retourne un reel : 4/3=1.333...
-		//
-		// On peut forcer la conversion en multipliant par 1.0 avant la division
-		// /!\ SQLite 3.5.9 Debian/Ubuntu est victime d'un bug en plus !
-		// cf. https://bugs.launchpad.net/ubuntu/+source/sqlite3/+bug/254228
-		//     http://www.sqlite.org/cvstrac/tktview?tn=3202
-		// (4*1.0/3) n'est pas rendu dans ce cas !
-		# $this->query = str_replace('/','* 1.00 / ',$this->query);
-
-		//
-		// 3) Remise en place des textes d'origine
-		//
-		// Correction Antiquotes et echappements
-		// ` => rien
-		if (str_contains($this->query, '`')) {
-			$this->query = str_replace('`', '', $this->query);
-		}
-
-		$this->query = query_reinjecte_textes($this->query, $textes);
-
-		return $this->query;
-	}
-
-	/**
-	 * Callback pour remplacer `DATE_` / `INTERVAL`
-	 * par `DATE ... strtotime`
-	 *
-	 * @param array $matches Captures
-	 * @return string texte de date compris par SQLite
-	 */
-	public function _remplacerDateParTime($matches) {
-		$op = strtoupper($matches[1] == 'ADD') ? '+' : '-';
-
-		return "datetime$matches[2] '$op$matches[3] $matches[4]')";
-	}
-
-	/**
-	 * Callback pour remplacer `FIELD(table,i,j,k...)`
-	 * par `CASE WHEN table=i THEN n ... ELSE 0 END`
-	 *
-	 * @param array $matches Captures
-	 * @return string texte de liste ordonnée compris par SQLite
-	 */
-	public function _remplacerFieldParCase($matches) {
-		$fields = substr((string) $matches[0], 6, -1); // ne recuperer que l'interieur X de field(X)
-		$t = explode(',', $fields);
-		$index = array_shift($t);
-
-		$res = '';
-		$n = 0;
-		foreach ($t as $v) {
-			$n++;
-			$res .= "\nWHEN $index=$v THEN $n";
-		}
-
-		return "CASE $res ELSE 0 END ";
-	}
+    /** Pour les corrections à effectuer sur les requêtes : array(code=>'texte') trouvé
+     *
+     * @var array
+     */
+    public $textes = [];
+
+    protected LoggerInterface $logger;
+
+    /**
+     * Constructeur
+     */
+    public function __construct(
+        /** Requête à préparer */
+        public string $query,
+        /** Prefixe des tables à utiliser */
+        public string $prefixe,
+        /** Version SQLite (2 ou 3) */
+        public string $sqlite_version
+    ) {
+        $this->logger = spip_logger('sqlite'); // FIXME: inject it.
+    }
+
+    /**
+     * Transformer la requete pour SQLite
+     *
+     * Enlève les textes, transforme la requête pour quelle soit
+     * bien interprétée par SQLite, puis remet les textes
+     * la fonction affecte `$this->query`
+     */
+    public function traduire_requete() {
+        //
+        // 1) Protection des textes en les remplacant par des codes
+        //
+        // enlever les 'textes' et initialiser avec
+        [$this->query, $textes] = query_echappe_textes($this->query);
+
+        //
+        // 2) Corrections de la requete
+        //
+        // Correction Create Database
+        // Create Database -> requete ignoree
+        if (str_starts_with((string) $this->query, 'CREATE DATABASE')) {
+            $this->logger->notice("Sqlite : requete non executee -> $this->query");
+            $this->query = 'SELECT 1';
+        }
+
+        // Correction Insert Ignore
+        // INSERT IGNORE -> insert (tout court et pas 'insert or replace')
+        if (str_starts_with((string) $this->query, 'INSERT IGNORE')) {
+            $this->logger->debug("Sqlite : requete transformee -> $this->query");
+            $this->query = 'INSERT ' . substr((string) $this->query, '13');
+        }
+
+        // Correction des dates avec INTERVAL
+        // utiliser sql_date_proche() de preference
+        if (str_contains((string) $this->query, 'INTERVAL')) {
+            $this->query = preg_replace_callback(
+                '/DATE_(ADD|SUB)(.*)INTERVAL\s+(\d+)\s+([a-zA-Z]+)\)/U',
+                fn(array $matches): string => $this->_remplacerDateParTime($matches),
+                (string) $this->query
+            );
+        }
+
+        if (str_contains((string) $this->query, 'LEFT(')) {
+            $this->query = str_replace('LEFT(', '_LEFT(', (string) $this->query);
+        }
+
+        if (str_contains((string) $this->query, 'TIMESTAMPDIFF(')) {
+            $this->query = preg_replace('/TIMESTAMPDIFF\(\s*([^,]*)\s*,/Uims', "TIMESTAMPDIFF('\\1',", (string) $this->query);
+        }
+
+        // Correction Field
+        // remplace FIELD(table,i,j,k...) par CASE WHEN table=i THEN n ... ELSE 0 END
+        if (str_contains((string) $this->query, 'FIELD')) {
+            $this->query = preg_replace_callback(
+                '/FIELD\s*\(([^\)]*)\)/',
+                fn(array $matches): string => $this->_remplacerFieldParCase($matches),
+                (string) $this->query
+            );
+        }
+
+        // Correction des noms de tables FROM
+        // mettre les bons noms de table dans from, update, insert, replace...
+        if (preg_match('/\s(SET|VALUES|WHERE|DATABASE)\s/iS', (string) $this->query, $regs)) {
+            $suite = strstr((string) $this->query, $regs[0]);
+            $this->query = substr((string) $this->query, 0, -strlen($suite));
+        } else {
+            $suite = '';
+        }
+        $pref = ($this->prefixe) ? $this->prefixe . '_' : '';
+        $this->query = preg_replace('/([,\s])spip_/S', '\1' . $pref, (string) $this->query) . $suite;
+
+        // Correction zero AS x
+        // pg n'aime pas 0+x AS alias, sqlite, dans le meme style,
+        // n'apprecie pas du tout SELECT 0 as x ... ORDER BY x
+        // il dit que x ne doit pas être un integer dans le order by !
+        // on remplace du coup x par vide() dans ce cas uniquement
+        //
+        // apparait dans public/vertebrer.php et dans le plugin menu aussi qui genere aussi ce genre de requete via un {par num #GET{tri_num}}
+        // mais est-ce encore un soucis pour sqlite en 2021 ? (ie commenter le preg_replace marche très bien en sqlite 3.28)
+        // on ne remplace que dans ORDER BY ou GROUP BY
+        if (str_contains($this->query, '0 AS') && preg_match('/\s(ORDER|GROUP) BY\s/i', $this->query, $regs)) {
+            $suite = strstr($this->query, $regs[0]);
+            $this->query = substr($this->query, 0, -strlen($suite));
+            // on cherche les noms des x dans 0 AS x
+            // on remplace dans $suite le nom par vide()
+            preg_match_all('/\b0 AS\s*([^\s,]+)/', $this->query, $matches, PREG_PATTERN_ORDER);
+            foreach ($matches[1] as $m) {
+                if (str_contains($suite, $m)) {
+                    $suite = preg_replace(",\b$m\b,", 'VIDE()', $suite);
+                }
+            }
+            $this->query .= $suite;
+        }
+
+        // Correction possible des divisions entieres
+        // Le standard SQL (lequel? ou?) semble indiquer que
+        // a/b=c doit donner c entier si a et b sont entiers 4/3=1.
+        // C'est ce que retournent effectivement SQL Server et SQLite
+        // Ce n'est pas ce qu'applique MySQL qui retourne un reel : 4/3=1.333...
+        //
+        // On peut forcer la conversion en multipliant par 1.0 avant la division
+        // /!\ SQLite 3.5.9 Debian/Ubuntu est victime d'un bug en plus !
+        // cf. https://bugs.launchpad.net/ubuntu/+source/sqlite3/+bug/254228
+        //     http://www.sqlite.org/cvstrac/tktview?tn=3202
+        // (4*1.0/3) n'est pas rendu dans ce cas !
+        # $this->query = str_replace('/','* 1.00 / ',$this->query);
+
+        //
+        // 3) Remise en place des textes d'origine
+        //
+        // Correction Antiquotes et echappements
+        // ` => rien
+        if (str_contains($this->query, '`')) {
+            $this->query = str_replace('`', '', $this->query);
+        }
+
+        $this->query = query_reinjecte_textes($this->query, $textes);
+
+        return $this->query;
+    }
+
+    /**
+     * Callback pour remplacer `DATE_` / `INTERVAL`
+     * par `DATE ... strtotime`
+     *
+     * @param array $matches Captures
+     * @return string texte de date compris par SQLite
+     */
+    public function _remplacerDateParTime($matches) {
+        $op = strtoupper($matches[1] == 'ADD') ? '+' : '-';
+
+        return "datetime$matches[2] '$op$matches[3] $matches[4]')";
+    }
+
+    /**
+     * Callback pour remplacer `FIELD(table,i,j,k...)`
+     * par `CASE WHEN table=i THEN n ... ELSE 0 END`
+     *
+     * @param array $matches Captures
+     * @return string texte de liste ordonnée compris par SQLite
+     */
+    public function _remplacerFieldParCase($matches) {
+        $fields = substr((string) $matches[0], 6, -1); // ne recuperer que l'interieur X de field(X)
+        $t = explode(',', $fields);
+        $index = array_shift($t);
+
+        $res = '';
+        $n = 0;
+        foreach ($t as $v) {
+            $n++;
+            $res .= "\nWHEN $index=$v THEN $n";
+        }
+
+        return "CASE $res ELSE 0 END ";
+    }
 }

Spacing +3 added lines, -3 removed lines

@@ -61,7 +61,7 @@ 
 		// INSERT IGNORE -> insert (tout court et pas 'insert or replace')
 		if (str_starts_with((string) $this->query, 'INSERT IGNORE')) {
 			$this->logger->debug("Sqlite : requete transformee -> $this->query");
-			$this->query = 'INSERT ' . substr((string) $this->query, '13');
+			$this->query = 'INSERT '.substr((string) $this->query, '13');
 		}
 
 		// Correction des dates avec INTERVAL
@@ -100,8 +100,8 @@ 
 		} else {
 			$suite = '';
 		}
-		$pref = ($this->prefixe) ? $this->prefixe . '_' : '';
-		$this->query = preg_replace('/([,\s])spip_/S', '\1' . $pref, (string) $this->query) . $suite;
+		$pref = ($this->prefixe) ? $this->prefixe.'_' : '';
+		$this->query = preg_replace('/([,\s])spip_/S', '\1'.$pref, (string) $this->query).$suite;
 
 		// Correction zero AS x
 		// pg n'aime pas 0+x AS alias, sqlite, dans le meme style,

ecrire/src/Sql/Sqlite/Requeteur.php

Indentation +108 added lines, -108 removed lines

@@ -15,112 +15,112 @@
 
 class Requeteur
 {
-	/** @var string texte de la requête */
-	public $query = ''; // la requete
-	/** @var string Nom de la connexion */
-	public $serveur = '';
-	/** @var \PDO|null Identifiant de la connexion SQLite */
-	public $link = null;
-	/** @var string Prefixe des tables SPIP */
-	public $prefixe = '';
-	/** @var string Nom de la base de donnée */
-	public $db = '';
-	/** @var bool Doit-on tracer les requetes (var_profile) ? */
-	public $tracer = false; // doit-on tracer les requetes (var_profile)
-
-	/** @var string Version de SQLite (2 ou 3) */
-	public $sqlite_version = '';
-
-	protected LoggerInterface $logger;
-
-	/**
-	 * Constructeur
-	 *
-	 * @param string $serveur
-	 */
-	public function __construct($serveur = '') {
-		_sqlite_init();
-		$this->serveur = strtolower($serveur);
-		$this->logger = spip_logger('sqlite'); // FIXME: inject it.
-
-		if (!($this->link = _sqlite_link($this->serveur)) && (!defined('_ECRIRE_INSTALL') || !_ECRIRE_INSTALL)) {
-			$this->logger->error('Aucune connexion sqlite (link)');
-
-			return;
-		}
-
-		$this->sqlite_version = _sqlite_is_version('', $this->link);
-
-		$this->prefixe = $GLOBALS['connexions'][$this->serveur ?: 0]['prefixe'];
-		$this->db = $GLOBALS['connexions'][$this->serveur ?: 0]['db'];
-
-		// tracage des requetes ?
-		$this->tracer = (isset($_GET['var_profile']) && $_GET['var_profile']);
-	}
-
-	/**
-	 * Lancer la requête transmise et faire le tracage si demandé
-	 *
-	 * @param string $query
-	 *     Requête à exécuter
-	 * @param bool|null $tracer
-	 *     true pour tracer la requête
-	 * @return bool|\PDOStatement|array
-	 */
-	public function executer_requete($query, $tracer = null) {
-		if (is_null($tracer)) {
-			$tracer = $this->tracer;
-		}
-		$err = '';
-		$t = 0;
-		if ($tracer || defined('_DEBUG_TRACE_QUERIES') && _DEBUG_TRACE_QUERIES) {
-			include_spip('public/tracer');
-			$t = trace_query_start();
-		}
-
-		# $this->logger->debug("requete: $this->serveur >> $query"); // boum ? pourquoi ?
-		if ($this->link) {
-			// memoriser la derniere erreur PHP vue
-			$last_error = (function_exists('error_get_last') ? error_get_last() : '');
-			$e = null;
-			// sauver la derniere requete
-			$GLOBALS['connexions'][$this->serveur ?: 0]['last'] = $query;
-			$GLOBALS['connexions'][$this->serveur ?: 0]['total_requetes']++;
-
-			try {
-				$r = $this->link->query($query);
-			} catch (\PDOException $e) {
-				$this->logger->error('PDOException: ' . $e->getMessage());
-				$r = false;
-			}
-
-			// loger les warnings/erreurs eventuels de sqlite remontant dans PHP
-			if ($e && $e instanceof \PDOException) {
-				$err = strip_tags($e->getMessage()) . ' in ' . $e->getFile() . ' line ' . $e->getLine();
-				$this->logger->error("$err - " . $query);
-			} elseif (($err = (function_exists('error_get_last') ? error_get_last() : '')) && $err != $last_error) {
-				$err = strip_tags($err['message']) . ' in ' . $err['file'] . ' line ' . $err['line'];
-				$this->logger->error("$err - " . $query);
-			} else {
-				$err = '';
-			}
-		} else {
-			$r = false;
-		}
-
-		if (spip_sqlite_errno($this->serveur)) {
-			$err .= spip_sqlite_error($query, $this->serveur);
-		}
-
-		return $t ? trace_query_end($query, $t, $r, $err, $this->serveur) : $r;
-	}
-
-	/**
-	 * Obtient l'identifiant de la dernière ligne insérée ou modifiée
-	 *
-	 * @return string|false
-	 **/
-	public function last_insert_id() {
-		return $this->link->lastInsertId();
-	}
+    /** @var string texte de la requête */
+    public $query = ''; // la requete
+    /** @var string Nom de la connexion */
+    public $serveur = '';
+    /** @var \PDO|null Identifiant de la connexion SQLite */
+    public $link = null;
+    /** @var string Prefixe des tables SPIP */
+    public $prefixe = '';
+    /** @var string Nom de la base de donnée */
+    public $db = '';
+    /** @var bool Doit-on tracer les requetes (var_profile) ? */
+    public $tracer = false; // doit-on tracer les requetes (var_profile)
+
+    /** @var string Version de SQLite (2 ou 3) */
+    public $sqlite_version = '';
+
+    protected LoggerInterface $logger;
+
+    /**
+     * Constructeur
+     *
+     * @param string $serveur
+     */
+    public function __construct($serveur = '') {
+        _sqlite_init();
+        $this->serveur = strtolower($serveur);
+        $this->logger = spip_logger('sqlite'); // FIXME: inject it.
+
+        if (!($this->link = _sqlite_link($this->serveur)) && (!defined('_ECRIRE_INSTALL') || !_ECRIRE_INSTALL)) {
+            $this->logger->error('Aucune connexion sqlite (link)');
+
+            return;
+        }
+
+        $this->sqlite_version = _sqlite_is_version('', $this->link);
+
+        $this->prefixe = $GLOBALS['connexions'][$this->serveur ?: 0]['prefixe'];
+        $this->db = $GLOBALS['connexions'][$this->serveur ?: 0]['db'];
+
+        // tracage des requetes ?
+        $this->tracer = (isset($_GET['var_profile']) && $_GET['var_profile']);
+    }
+
+    /**
+     * Lancer la requête transmise et faire le tracage si demandé
+     *
+     * @param string $query
+     *     Requête à exécuter
+     * @param bool|null $tracer
+     *     true pour tracer la requête
+     * @return bool|\PDOStatement|array
+     */
+    public function executer_requete($query, $tracer = null) {
+        if (is_null($tracer)) {
+            $tracer = $this->tracer;
+        }
+        $err = '';
+        $t = 0;
+        if ($tracer || defined('_DEBUG_TRACE_QUERIES') && _DEBUG_TRACE_QUERIES) {
+            include_spip('public/tracer');
+            $t = trace_query_start();
+        }
+
+        # $this->logger->debug("requete: $this->serveur >> $query"); // boum ? pourquoi ?
+        if ($this->link) {
+            // memoriser la derniere erreur PHP vue
+            $last_error = (function_exists('error_get_last') ? error_get_last() : '');
+            $e = null;
+            // sauver la derniere requete
+            $GLOBALS['connexions'][$this->serveur ?: 0]['last'] = $query;
+            $GLOBALS['connexions'][$this->serveur ?: 0]['total_requetes']++;
+
+            try {
+                $r = $this->link->query($query);
+            } catch (\PDOException $e) {
+                $this->logger->error('PDOException: ' . $e->getMessage());
+                $r = false;
+            }
+
+            // loger les warnings/erreurs eventuels de sqlite remontant dans PHP
+            if ($e && $e instanceof \PDOException) {
+                $err = strip_tags($e->getMessage()) . ' in ' . $e->getFile() . ' line ' . $e->getLine();
+                $this->logger->error("$err - " . $query);
+            } elseif (($err = (function_exists('error_get_last') ? error_get_last() : '')) && $err != $last_error) {
+                $err = strip_tags($err['message']) . ' in ' . $err['file'] . ' line ' . $err['line'];
+                $this->logger->error("$err - " . $query);
+            } else {
+                $err = '';
+            }
+        } else {
+            $r = false;
+        }
+
+        if (spip_sqlite_errno($this->serveur)) {
+            $err .= spip_sqlite_error($query, $this->serveur);
+        }
+
+        return $t ? trace_query_end($query, $t, $r, $err, $this->serveur) : $r;
+    }
+
+    /**
+     * Obtient l'identifiant de la dernière ligne insérée ou modifiée
+     *
+     * @return string|false
+     **/
+    public function last_insert_id() {
+        return $this->link->lastInsertId();
+    }
 }

Spacing +5 added lines, -5 removed lines

@@ -90,17 +90,17 @@
 			try {
 				$r = $this->link->query($query);
 			} catch (\PDOException $e) {
-				$this->logger->error('PDOException: ' . $e->getMessage());
+				$this->logger->error('PDOException: '.$e->getMessage());
 				$r = false;
 			}
 
 			// loger les warnings/erreurs eventuels de sqlite remontant dans PHP
 			if ($e && $e instanceof \PDOException) {
-				$err = strip_tags($e->getMessage()) . ' in ' . $e->getFile() . ' line ' . $e->getLine();
-				$this->logger->error("$err - " . $query);
+				$err = strip_tags($e->getMessage()).' in '.$e->getFile().' line '.$e->getLine();
+				$this->logger->error("$err - ".$query);
 			} elseif (($err = (function_exists('error_get_last') ? error_get_last() : '')) && $err != $last_error) {
-				$err = strip_tags($err['message']) . ' in ' . $err['file'] . ' line ' . $err['line'];
-				$this->logger->error("$err - " . $query);
+				$err = strip_tags($err['message']).' in '.$err['file'].' line '.$err['line'];
+				$this->logger->error("$err - ".$query);
 			} else {
 				$err = '';
 			}

ecrire/src/Texte/Collecteur/AbstractCollecteur.php

Indentation +282 added lines, -282 removed lines

@@ -12,286 +12,286 @@
 namespace Spip\Texte\Collecteur;
 
 abstract class AbstractCollecteur {
-	protected static string $markPrefix = 'COLLECT';
-	protected string $markId;
-
-	public static array $listeBalisesBloc = [
-		'address', 'applet', 'article', 'aside',
-		'blockquote', 'button',
-		'center',
-		'dl', 'dt', 'dd', 'div',
-		'fieldset', 'figure', 'figcaption', 'footer', 'form',
-		'h1', 'h2', 'h3', 'h4', 'h5', 'h6', 'hr', 'hgroup', 'head', 'header',
-		'iframe',
-		'li',
-		'map', 'marquee',
-		'nav', 'noscript',
-		'object', 'ol',
-		'pre',
-		'section',
-		'table', 'tr', 'td', 'th', 'tbody', 'foot', 'textarea',
-		'ul',
-		'script', 'style'
-	];
-
-	/**
-	 * Collecteur générique des occurences d'une preg dans un texte avec leurs positions et longueur
-	 * @param string $texte
-	 *   texte à analyser pour la collecte
-	 * @param string $if_chars
-	 *   caractere(s) à tester avant de tenter la preg
-	 * @param string $start_with
-	 *   caractere(s) par lesquels commencent l'expression recherchée (permet de démarrer la preg à la prochaine occurence de cette chaine)
-	 * @param string $preg
-	 *   preg utilisée pour la collecte
-	 * @param int $max_items
-	 *   pour limiter le nombre de preg collectée (pour la detection simple de présence par exemple)
-	 * @return array
-	 */
-	protected static function collecteur(string $texte, string $if_chars, string $start_with, string $preg, int $max_items = 0): array {
-
-		$collection = [];
-		$pos = 0;
-		while (
-			(!$if_chars || str_contains($texte, $if_chars))
-			&& ($next = ($start_with ? strpos($texte, $start_with, $pos) : $pos)) !== false
-			&& preg_match($preg, $texte, $r, PREG_OFFSET_CAPTURE, $next)
-		) {
-			$found_pos = $r[0][1];
-			$found_length = strlen($r[0][0]);
-			$match = [
-				'raw' => $r[0][0],
-				'match' => array_column($r, 0),
-				'pos' => $found_pos,
-				'length' => $found_length
-			];
-
-			$collection[] = $match;
-
-			if ($max_items && count($collection) === $max_items) {
-				break;
-			}
-
-			$pos = $match['pos'] + $match['length'];
-		}
-
-		return $collection;
-	}
-
-	/**
-	 * Sanitizer une collection d'occurences
-	 */
-	protected function sanitizer_collection(array $collection, string $sanitize_callback): array {
-		foreach ($collection as &$c) {
-			$c['raw'] = $sanitize_callback($c['raw']);
-		}
-
-		return $collection;
-	}
-
-	/**
-	 * @return array
-	 */
-	public function collecter(string $texte, array $options = []): array {
-		return [];
-	}
-
-	public function detecter($texte): bool {
-		if (!empty($this->markId) && str_contains((string) $texte, $this->markId)) {
-			return true;
-		}
-		return !empty($this->collecter($texte, ['detecter_presence' => true]));
-	}
-
-	/**
-	 * Echapper les occurences de la collecte par un texte neutre du point de vue HTML
-	 *
-	 * @see retablir()
-	 * @param string $texte
-	 * @param array $options
-	 *   string $sanitize_callback
-	 * @return array
-	 *   texte, marqueur utilise pour echapper les modeles
-	 */
-	public function echapper(string $texte, array $options = []): string {
-		if (!function_exists('creer_uniqid')) {
-			include_spip('inc/acces');
-		}
-
-		$collection = $this->collecter($texte, $options);
-		if (!empty($options['sanitize_callback']) && is_callable($options['sanitize_callback'])) {
-			$collection = $this->sanitizer_collection($collection, $options['sanitize_callback']);
-		}
-
-		if ($collection !== []) {
-			if (empty($this->markId)) {
-				// generer un marqueur qui n'existe pas dans le texte
-				do {
-					$this->markId = substr(md5(uniqid(static::class, 1)), 0, 7);
-					$this->markId = '@|' . static::$markPrefix . $this->markId . '|';
-				} while (str_contains($texte, $this->markId));
-			}
-
-			$offset_pos = 0;
-			foreach ($collection as $c) {
-				$rempl = $this->markId . base64_encode((string) $c['raw']) . '|@';
-				$texte = substr_replace($texte, $rempl, $c['pos'] + $offset_pos, $c['length']);
-				$offset_pos += strlen($rempl) - $c['length'];
-			}
-		}
-
-		return $texte;
-	}
-
-
-	/**
-	 * Retablir les occurences échappées précédemment
-	 *
-	 * @see echapper()
-	 */
-	function retablir(string $texte): string {
-
-		if (!empty($this->markId)) {
-			$lm = strlen($this->markId);
-			$pos = 0;
-			while (
-				($p = strpos($texte, $this->markId, $pos)) !== false
-				&& ($end = strpos($texte, '|@', $p + $lm))
-			) {
-				$base64 = substr($texte, $p + $lm, $end - ($p + $lm));
-				if ($c = base64_decode($base64, true)) {
-					$texte = substr_replace($texte, $c, $p, $end + 2 - $p);
-					$pos = $p + strlen($c);
-				}
-				else {
-					$pos = $end;
-				}
-			}
-		}
-
-		return $texte;
-	}
-
-	/**
-	 * Detecter si un texte contient des balises bloc ou non
-	 */
-	public static function echappementTexteContientBaliseBloc(string $texte): bool {
-		static $pregBalisesBloc;
-
-		if ($pregBalisesBloc === null) {
-			$pregBalisesBloc = ',</?(' . implode('|', static::$listeBalisesBloc) . ')[>[:space:]],iS';
-		}
-		return (str_contains($texte, '<') && preg_match($pregBalisesBloc, $texte)) ? true : false;
-	}
-
-	/**
-	 * Creer un bloc base64 correspondant a $texte ; au besoin en marquant
-	 * une $source differente ;
-	 * si $isBloc n'est pas fourni, le script detecte automagiquement si ce qu'on
-	 * echappe est un div ou un span
-	 */
-	public static function echappementHtmlBase64(string $texte, string $source = '', ?bool $isBloc = null, array $attributs = []): string {
-
-		if ($texte === '') {
-			return '';
-		}
-
-		// Tester si on echappe en span ou en div
-		$isBloc ??= self::echappementTexteContientBaliseBloc($texte);
-		$tag = $isBloc ? 'div' : 'span';
-		$atts = '';
-		if (!empty($attributs)) {
-			if (!function_exists('attribut_html')) {
-				include_spip('inc/filtres');
-			}
-			foreach ($attributs as $k => $v) {
-				$atts .= " $k=\"" . \attribut_html($v) . '"';
-			}
-		}
-
-		// Decouper en morceaux, base64 a des probleme selon la taille de la pile
-		$taille = 30000;
-		$return = '';
-		for ($i = 0; $i < strlen($texte); $i += $taille) {
-			// Convertir en base64 et cacher dans un attribut
-			// utiliser les " pour eviter le re-encodage de ' et &#8217
-			$base64 = base64_encode(substr($texte, $i, $taille));
-			$return .= "<$tag class=\"base64$source\" title=\"$base64\"{$atts}></$tag>";
-		}
-
-		return $return;
-	}
-
-
-	/**
-	 * Rétablir les contenus échappés dans un texte en <(div|span) class="base64..."></(div|span)>
-	 * Rq: $source sert a faire des echappements "a soi" qui ne sont pas nettoyes
-	 * par propre() : exemple dans multi et dans typo()
-	 *
-	 * @see echappementHtmlBase64()
-	 */
-	public static function retablir_depuisHtmlBase64(string $texte, string $source = '', string $filtre = ''): string {
-		if (str_contains($texte, "base64$source")) {
-			# spip_logger()->info(spip_htmlspecialchars($texte));  ## pour les curieux
-			$max_prof = 5;
-			$encore = true;
-			while ($encore && str_contains($texte, 'base64' . $source) && $max_prof--) {
-				$encore = false;
-				foreach (['span', 'div'] as $tag) {
-					$htmlTagCollecteur = new HtmlTag(
-						$tag,
-						"@<{$tag}\s(class=['\"]base64{$source}['\"]\stitle=['\"]([^'\">]*)['\"][^>]*?)(/?)>\s*</{$tag}>@isS",
-						''
-					);
-					$collection = $htmlTagCollecteur->collecter($texte);
-					if (!empty($collection)) {
-						$collection = array_reverse($collection);
-						foreach ($collection as $c) {
-							$title = $c['match'][2];
-							if ($title && ($rempl = base64_decode($title, true))) {
-								$encore = true;
-								// recherche d'attributs supplementaires
-								$at = [];
-								foreach (['lang', 'dir'] as $attr) {
-									if ($a = extraire_attribut($c['match'][0], $attr)) {
-										$at[$attr] = $a;
-									}
-								}
-								if ($at) {
-									$rempl = "<$tag>$rempl</$tag>";
-									foreach ($at as $attr => $a) {
-										$rempl = inserer_attribut($rempl, $attr, $a);
-									}
-								}
-								if ($filtre) {
-									$rempl = $filtre($rempl);
-								}
-								$texte = substr_replace($texte, $rempl, $c['pos'], $c['length']);
-							}
-						}
-					}
-				}
-			}
-		}
-		return $texte;
-	}
-
-	/**
-	 * @param callable|null $callback_function
-	 */
-	public function echapper_enHtmlBase64(string $texte, string $source = '', $callback_function = null, array $callback_options = []): string {
-		$collection = $this->collecter($texte);
-		if (!empty($collection)) {
-			$collection = array_reverse($collection);
-			foreach ($collection as $c) {
-				$echap = $c['raw'];
-				if ($callback_function) {
-					$echap = $callback_function($c, $callback_options);
-				}
-				$echap = self::echappementHtmlBase64($echap, $source);
-				$texte = substr_replace($texte, $echap, $c['pos'], $c['length']);
-			}
-		}
-		return $texte;
-	}
+    protected static string $markPrefix = 'COLLECT';
+    protected string $markId;
+
+    public static array $listeBalisesBloc = [
+        'address', 'applet', 'article', 'aside',
+        'blockquote', 'button',
+        'center',
+        'dl', 'dt', 'dd', 'div',
+        'fieldset', 'figure', 'figcaption', 'footer', 'form',
+        'h1', 'h2', 'h3', 'h4', 'h5', 'h6', 'hr', 'hgroup', 'head', 'header',
+        'iframe',
+        'li',
+        'map', 'marquee',
+        'nav', 'noscript',
+        'object', 'ol',
+        'pre',
+        'section',
+        'table', 'tr', 'td', 'th', 'tbody', 'foot', 'textarea',
+        'ul',
+        'script', 'style'
+    ];
+
+    /**
+     * Collecteur générique des occurences d'une preg dans un texte avec leurs positions et longueur
+     * @param string $texte
+     *   texte à analyser pour la collecte
+     * @param string $if_chars
+     *   caractere(s) à tester avant de tenter la preg
+     * @param string $start_with
+     *   caractere(s) par lesquels commencent l'expression recherchée (permet de démarrer la preg à la prochaine occurence de cette chaine)
+     * @param string $preg
+     *   preg utilisée pour la collecte
+     * @param int $max_items
+     *   pour limiter le nombre de preg collectée (pour la detection simple de présence par exemple)
+     * @return array
+     */
+    protected static function collecteur(string $texte, string $if_chars, string $start_with, string $preg, int $max_items = 0): array {
+
+        $collection = [];
+        $pos = 0;
+        while (
+            (!$if_chars || str_contains($texte, $if_chars))
+            && ($next = ($start_with ? strpos($texte, $start_with, $pos) : $pos)) !== false
+            && preg_match($preg, $texte, $r, PREG_OFFSET_CAPTURE, $next)
+        ) {
+            $found_pos = $r[0][1];
+            $found_length = strlen($r[0][0]);
+            $match = [
+                'raw' => $r[0][0],
+                'match' => array_column($r, 0),
+                'pos' => $found_pos,
+                'length' => $found_length
+            ];
+
+            $collection[] = $match;
+
+            if ($max_items && count($collection) === $max_items) {
+                break;
+            }
+
+            $pos = $match['pos'] + $match['length'];
+        }
+
+        return $collection;
+    }
+
+    /**
+     * Sanitizer une collection d'occurences
+     */
+    protected function sanitizer_collection(array $collection, string $sanitize_callback): array {
+        foreach ($collection as &$c) {
+            $c['raw'] = $sanitize_callback($c['raw']);
+        }
+
+        return $collection;
+    }
+
+    /**
+     * @return array
+     */
+    public function collecter(string $texte, array $options = []): array {
+        return [];
+    }
+
+    public function detecter($texte): bool {
+        if (!empty($this->markId) && str_contains((string) $texte, $this->markId)) {
+            return true;
+        }
+        return !empty($this->collecter($texte, ['detecter_presence' => true]));
+    }
+
+    /**
+     * Echapper les occurences de la collecte par un texte neutre du point de vue HTML
+     *
+     * @see retablir()
+     * @param string $texte
+     * @param array $options
+     *   string $sanitize_callback
+     * @return array
+     *   texte, marqueur utilise pour echapper les modeles
+     */
+    public function echapper(string $texte, array $options = []): string {
+        if (!function_exists('creer_uniqid')) {
+            include_spip('inc/acces');
+        }
+
+        $collection = $this->collecter($texte, $options);
+        if (!empty($options['sanitize_callback']) && is_callable($options['sanitize_callback'])) {
+            $collection = $this->sanitizer_collection($collection, $options['sanitize_callback']);
+        }
+
+        if ($collection !== []) {
+            if (empty($this->markId)) {
+                // generer un marqueur qui n'existe pas dans le texte
+                do {
+                    $this->markId = substr(md5(uniqid(static::class, 1)), 0, 7);
+                    $this->markId = '@|' . static::$markPrefix . $this->markId . '|';
+                } while (str_contains($texte, $this->markId));
+            }
+
+            $offset_pos = 0;
+            foreach ($collection as $c) {
+                $rempl = $this->markId . base64_encode((string) $c['raw']) . '|@';
+                $texte = substr_replace($texte, $rempl, $c['pos'] + $offset_pos, $c['length']);
+                $offset_pos += strlen($rempl) - $c['length'];
+            }
+        }
+
+        return $texte;
+    }
+
+
+    /**
+     * Retablir les occurences échappées précédemment
+     *
+     * @see echapper()
+     */
+    function retablir(string $texte): string {
+
+        if (!empty($this->markId)) {
+            $lm = strlen($this->markId);
+            $pos = 0;
+            while (
+                ($p = strpos($texte, $this->markId, $pos)) !== false
+                && ($end = strpos($texte, '|@', $p + $lm))
+            ) {
+                $base64 = substr($texte, $p + $lm, $end - ($p + $lm));
+                if ($c = base64_decode($base64, true)) {
+                    $texte = substr_replace($texte, $c, $p, $end + 2 - $p);
+                    $pos = $p + strlen($c);
+                }
+                else {
+                    $pos = $end;
+                }
+            }
+        }
+
+        return $texte;
+    }
+
+    /**
+     * Detecter si un texte contient des balises bloc ou non
+     */
+    public static function echappementTexteContientBaliseBloc(string $texte): bool {
+        static $pregBalisesBloc;
+
+        if ($pregBalisesBloc === null) {
+            $pregBalisesBloc = ',</?(' . implode('|', static::$listeBalisesBloc) . ')[>[:space:]],iS';
+        }
+        return (str_contains($texte, '<') && preg_match($pregBalisesBloc, $texte)) ? true : false;
+    }
+
+    /**
+     * Creer un bloc base64 correspondant a $texte ; au besoin en marquant
+     * une $source differente ;
+     * si $isBloc n'est pas fourni, le script detecte automagiquement si ce qu'on
+     * echappe est un div ou un span
+     */
+    public static function echappementHtmlBase64(string $texte, string $source = '', ?bool $isBloc = null, array $attributs = []): string {
+
+        if ($texte === '') {
+            return '';
+        }
+
+        // Tester si on echappe en span ou en div
+        $isBloc ??= self::echappementTexteContientBaliseBloc($texte);
+        $tag = $isBloc ? 'div' : 'span';
+        $atts = '';
+        if (!empty($attributs)) {
+            if (!function_exists('attribut_html')) {
+                include_spip('inc/filtres');
+            }
+            foreach ($attributs as $k => $v) {
+                $atts .= " $k=\"" . \attribut_html($v) . '"';
+            }
+        }
+
+        // Decouper en morceaux, base64 a des probleme selon la taille de la pile
+        $taille = 30000;
+        $return = '';
+        for ($i = 0; $i < strlen($texte); $i += $taille) {
+            // Convertir en base64 et cacher dans un attribut
+            // utiliser les " pour eviter le re-encodage de ' et &#8217
+            $base64 = base64_encode(substr($texte, $i, $taille));
+            $return .= "<$tag class=\"base64$source\" title=\"$base64\"{$atts}></$tag>";
+        }
+
+        return $return;
+    }
+
+
+    /**
+     * Rétablir les contenus échappés dans un texte en <(div|span) class="base64..."></(div|span)>
+     * Rq: $source sert a faire des echappements "a soi" qui ne sont pas nettoyes
+     * par propre() : exemple dans multi et dans typo()
+     *
+     * @see echappementHtmlBase64()
+     */
+    public static function retablir_depuisHtmlBase64(string $texte, string $source = '', string $filtre = ''): string {
+        if (str_contains($texte, "base64$source")) {
+            # spip_logger()->info(spip_htmlspecialchars($texte));  ## pour les curieux
+            $max_prof = 5;
+            $encore = true;
+            while ($encore && str_contains($texte, 'base64' . $source) && $max_prof--) {
+                $encore = false;
+                foreach (['span', 'div'] as $tag) {
+                    $htmlTagCollecteur = new HtmlTag(
+                        $tag,
+                        "@<{$tag}\s(class=['\"]base64{$source}['\"]\stitle=['\"]([^'\">]*)['\"][^>]*?)(/?)>\s*</{$tag}>@isS",
+                        ''
+                    );
+                    $collection = $htmlTagCollecteur->collecter($texte);
+                    if (!empty($collection)) {
+                        $collection = array_reverse($collection);
+                        foreach ($collection as $c) {
+                            $title = $c['match'][2];
+                            if ($title && ($rempl = base64_decode($title, true))) {
+                                $encore = true;
+                                // recherche d'attributs supplementaires
+                                $at = [];
+                                foreach (['lang', 'dir'] as $attr) {
+                                    if ($a = extraire_attribut($c['match'][0], $attr)) {
+                                        $at[$attr] = $a;
+                                    }
+                                }
+                                if ($at) {
+                                    $rempl = "<$tag>$rempl</$tag>";
+                                    foreach ($at as $attr => $a) {
+                                        $rempl = inserer_attribut($rempl, $attr, $a);
+                                    }
+                                }
+                                if ($filtre) {
+                                    $rempl = $filtre($rempl);
+                                }
+                                $texte = substr_replace($texte, $rempl, $c['pos'], $c['length']);
+                            }
+                        }
+                    }
+                }
+            }
+        }
+        return $texte;
+    }
+
+    /**
+     * @param callable|null $callback_function
+     */
+    public function echapper_enHtmlBase64(string $texte, string $source = '', $callback_function = null, array $callback_options = []): string {
+        $collection = $this->collecter($texte);
+        if (!empty($collection)) {
+            $collection = array_reverse($collection);
+            foreach ($collection as $c) {
+                $echap = $c['raw'];
+                if ($callback_function) {
+                    $echap = $callback_function($c, $callback_options);
+                }
+                $echap = self::echappementHtmlBase64($echap, $source);
+                $texte = substr_replace($texte, $echap, $c['pos'], $c['length']);
+            }
+        }
+        return $texte;
+    }
 }

Spacing +5 added lines, -5 removed lines

@@ -128,13 +128,13 @@ 
 				// generer un marqueur qui n'existe pas dans le texte
 				do {
 					$this->markId = substr(md5(uniqid(static::class, 1)), 0, 7);
-					$this->markId = '@|' . static::$markPrefix . $this->markId . '|';
+					$this->markId = '@|'.static::$markPrefix.$this->markId.'|';
 				} while (str_contains($texte, $this->markId));
 			}
 
 			$offset_pos = 0;
 			foreach ($collection as $c) {
-				$rempl = $this->markId . base64_encode((string) $c['raw']) . '|@';
+				$rempl = $this->markId.base64_encode((string) $c['raw']).'|@';
 				$texte = substr_replace($texte, $rempl, $c['pos'] + $offset_pos, $c['length']);
 				$offset_pos += strlen($rempl) - $c['length'];
 			}
@@ -179,7 +179,7 @@ 
 		static $pregBalisesBloc;
 
 		if ($pregBalisesBloc === null) {
-			$pregBalisesBloc = ',</?(' . implode('|', static::$listeBalisesBloc) . ')[>[:space:]],iS';
+			$pregBalisesBloc = ',</?('.implode('|', static::$listeBalisesBloc).')[>[:space:]],iS';
 		}
 		return (str_contains($texte, '<') && preg_match($pregBalisesBloc, $texte)) ? true : false;
 	}
@@ -205,7 +205,7 @@ 
 				include_spip('inc/filtres');
 			}
 			foreach ($attributs as $k => $v) {
-				$atts .= " $k=\"" . \attribut_html($v) . '"';
+				$atts .= " $k=\"".\attribut_html($v).'"';
 			}
 		}
 
@@ -235,7 +235,7 @@ 
 			# spip_logger()->info(spip_htmlspecialchars($texte));  ## pour les curieux
 			$max_prof = 5;
 			$encore = true;
-			while ($encore && str_contains($texte, 'base64' . $source) && $max_prof--) {
+			while ($encore && str_contains($texte, 'base64'.$source) && $max_prof--) {
 				$encore = false;
 				foreach (['span', 'div'] as $tag) {
 					$htmlTagCollecteur = new HtmlTag(

ecrire/src/ErrorHandler.php

Indentation +24 added lines, -24 removed lines

@@ -7,33 +7,33 @@
  * @internal
  */
 final class ErrorHandler {
-	static bool $done = false;
+    static bool $done = false;
 
-	public static function setup(?int $error_level = null): void {
-		if (!self::$done) {
-			self::$done = true;
-			error_reporting($error_level);
-			set_error_handler(self::user_deprecated(...), E_USER_DEPRECATED);
-		}
-	}
+    public static function setup(?int $error_level = null): void {
+        if (!self::$done) {
+            self::$done = true;
+            error_reporting($error_level);
+            set_error_handler(self::user_deprecated(...), E_USER_DEPRECATED);
+        }
+    }
 
-	/** Loger les `trigger_deprecated()` */
-	private static function user_deprecated(int $errno, string $errstr, string $errfile, int $errline): bool {
-		if (!(\E_USER_DEPRECATED & $errno)) {
-			return false;
-		}
+    /** Loger les `trigger_deprecated()` */
+    private static function user_deprecated(int $errno, string $errstr, string $errfile, int $errline): bool {
+        if (!(\E_USER_DEPRECATED & $errno)) {
+            return false;
+        }
 
-		$backtrace = debug_backtrace();
-		array_shift($backtrace);
-		do {
-			$t = array_shift($backtrace);
-			$fqdn = ($t['class'] ?? '') . ($t['type'] ?? '') . ($t['function'] ?? '');
-		} while (in_array($fqdn, ['trigger_error', 'trigger_deprecation']));
+        $backtrace = debug_backtrace();
+        array_shift($backtrace);
+        do {
+            $t = array_shift($backtrace);
+            $fqdn = ($t['class'] ?? '') . ($t['type'] ?? '') . ($t['function'] ?? '');
+        } while (in_array($fqdn, ['trigger_error', 'trigger_deprecation']));
 
-		$errfile = $t['file'];
-		$errline = $t['line'];
+        $errfile = $t['file'];
+        $errline = $t['line'];
 
-		spip_logger('deprecated')->info(sprintf('%s in %s on line %s', $errstr, $errfile, $errline));
-		return false;
-	}
+        spip_logger('deprecated')->info(sprintf('%s in %s on line %s', $errstr, $errfile, $errline));
+        return false;
+    }
 }

Spacing +1 added lines, -1 removed lines

@@ -27,7 +27,7 @@
 		array_shift($backtrace);
 		do {
 			$t = array_shift($backtrace);
-			$fqdn = ($t['class'] ?? '') . ($t['type'] ?? '') . ($t['function'] ?? '');
+			$fqdn = ($t['class'] ?? '').($t['type'] ?? '').($t['function'] ?? '');
 		} while (in_array($fqdn, ['trigger_error', 'trigger_deprecation']));
 
 		$errfile = $t['file'];

ecrire/src/Afficher/Minipage/Admin.php

Indentation +142 added lines, -142 removed lines

@@ -15,146 +15,146 @@
  * Présentation des pages simplifiées d’admin pour envoyer un message à un utilisateur
  **/
 class Admin extends Page {
-	public const TYPE = 'admin';
-	protected function setOptions(array $options) {
-		$options['couleur_fond'] = '#999';
-		if (empty($options['css_files'])) {
-			$options['css_files'] = [];
-		}
-		array_unshift($options['css_files'], find_in_theme('minipres.css'));
-
-		$options['page_title'] = ($options['titre'] ?? '');
-
-		return $options;
-	}
-
-
-	/**
-	 * Retourne le début d'une page HTML minimale (de type installation ou erreur)
-	 *
-	 * @param array $options
-	 * @return string
-	 *    Code HTML
-	 */
-	public function installDebutPage($options = []) {
-
-		$options = $this->setOptions($options);
-		return parent::ouvreBody($options)
-			. parent::ouvreCorps($options);
-	}
-
-	/**
-	 * Retourne le fin d'une page HTML minimale (de type installation ou erreur)
-	 *
-	 * @param array $options
-	 * @return string
-	 *    Code HTML
-	 */
-	public function installFinPage($options = []) {
-
-		$options = $this->setOptions($options);
-		return parent::fermeCorps($options)
-			. parent::fermeBody();
-	}
-
-
-	/**
-	 * Retourne une page HTML contenant, dans une présentation minimale,
-	 * le contenu transmis dans `$corps`.
-	 *
-	 * Appelée pour afficher un message d’erreur (l’utilisateur n’a pas
-	 * accès à cette page par exemple).
-	 *
-	 * Lorsqu’aucun argument n’est transmis, un header 403 est renvoyé,
-	 * ainsi qu’un message indiquant une interdiction d’accès.
-	 *
-	 * @param string $corps
-	 *   Corps de la page
-	 * @param array $options
-	 * @return string
-	 *   HTML de la page
-	 * @see  ouvreBody()
-	 *   string $titre : Titre à l'affichage (différent de $page_title)
-	 *   int $status : status de la page
-	 *   string $footer : pied de la box en remplacement du bouton retour par défaut
-	 * @uses ouvreBody()
-	 * @uses fermeBody()
-	 *
-	 */
-	public function page($corps = '', $options = []) {
-
-		$footer = '';
-
-		$titre = $options['titre'] ?? '';
-		if (!$titre) {
-			if (empty($corps) && !isset($options['status'])) {
-				$options['status'] = 403;
-			}
-
-			if (
-				!$titre = _request('action')
-				&& !$titre = _request('exec')
-				&& !$titre = _request('page')
-			) {
-				$titre = '?';
-			}
-
-			$titre = spip_htmlspecialchars($titre);
-
-			$titre = ($titre == 'install')
-				? _T('avis_espace_interdit')
-				: $titre . ' : ' . _T('info_acces_interdit');
-
-			$statut = $GLOBALS['visiteur_session']['statut'] ?? '';
-			$nom = $GLOBALS['visiteur_session']['nom'] ?? '';
-
-			if ($statut != '0minirezo') {
-				$titre = _T('info_acces_interdit');
-			}
-
-			if ($statut && test_espace_prive()) {
-				$footer = bouton_action(_T('public:accueil_site'), generer_url_ecrire('accueil'));
-			}
-			elseif (!empty($_COOKIE['spip_admin'])) {
-				$footer = bouton_action(_T('public:lien_connecter'), generer_url_public('login'));
-			}
-			else {
-				$footer = bouton_action(_T('public:accueil_site'), $GLOBALS['meta']['adresse_site'] ?? '');
-			}
-
-			spip_logger('minipres')->info($nom . " $titre " . $_SERVER['REQUEST_URI']);
-
-			$options['footer'] = $footer;
-			if (empty($corps)) {
-				$corps = "<div class='msg-alert error'>"
-					. $titre
-					. '</div>';
-				$options['titre'] = '';
-			}
-			else {
-				$options['titre'] = $titre;
-			}
-		}
-		else {
-			$options['titre'] = $titre;
-		}
-		$options['page_title'] = $titre;
-
-		$options = $this->setOptions($options);
-
-		$html = parent::page($corps, $options);
-
-		if (!_AJAX) {
-			return $html;
-		} else {
-			include_spip('inc/headers');
-			include_spip('inc/actions');
-			$url = self('&', true);
-			foreach ($_POST as $v => $c) {
-				$url = parametre_url($url, $v, $c, '&');
-			}
-			ajax_retour('<div>' . $titre . redirige_formulaire($url) . '</div>', false);
-			return '';
-		}
-	}
+    public const TYPE = 'admin';
+    protected function setOptions(array $options) {
+        $options['couleur_fond'] = '#999';
+        if (empty($options['css_files'])) {
+            $options['css_files'] = [];
+        }
+        array_unshift($options['css_files'], find_in_theme('minipres.css'));
+
+        $options['page_title'] = ($options['titre'] ?? '');
+
+        return $options;
+    }
+
+
+    /**
+     * Retourne le début d'une page HTML minimale (de type installation ou erreur)
+     *
+     * @param array $options
+     * @return string
+     *    Code HTML
+     */
+    public function installDebutPage($options = []) {
+
+        $options = $this->setOptions($options);
+        return parent::ouvreBody($options)
+            . parent::ouvreCorps($options);
+    }
+
+    /**
+     * Retourne le fin d'une page HTML minimale (de type installation ou erreur)
+     *
+     * @param array $options
+     * @return string
+     *    Code HTML
+     */
+    public function installFinPage($options = []) {
+
+        $options = $this->setOptions($options);
+        return parent::fermeCorps($options)
+            . parent::fermeBody();
+    }
+
+
+    /**
+     * Retourne une page HTML contenant, dans une présentation minimale,
+     * le contenu transmis dans `$corps`.
+     *
+     * Appelée pour afficher un message d’erreur (l’utilisateur n’a pas
+     * accès à cette page par exemple).
+     *
+     * Lorsqu’aucun argument n’est transmis, un header 403 est renvoyé,
+     * ainsi qu’un message indiquant une interdiction d’accès.
+     *
+     * @param string $corps
+     *   Corps de la page
+     * @param array $options
+     * @return string
+     *   HTML de la page
+     * @see  ouvreBody()
+     *   string $titre : Titre à l'affichage (différent de $page_title)
+     *   int $status : status de la page
+     *   string $footer : pied de la box en remplacement du bouton retour par défaut
+     * @uses ouvreBody()
+     * @uses fermeBody()
+     *
+     */
+    public function page($corps = '', $options = []) {
+
+        $footer = '';
+
+        $titre = $options['titre'] ?? '';
+        if (!$titre) {
+            if (empty($corps) && !isset($options['status'])) {
+                $options['status'] = 403;
+            }
+
+            if (
+                !$titre = _request('action')
+                && !$titre = _request('exec')
+                && !$titre = _request('page')
+            ) {
+                $titre = '?';
+            }
+
+            $titre = spip_htmlspecialchars($titre);
+
+            $titre = ($titre == 'install')
+                ? _T('avis_espace_interdit')
+                : $titre . '&nbsp;: ' . _T('info_acces_interdit');
+
+            $statut = $GLOBALS['visiteur_session']['statut'] ?? '';
+            $nom = $GLOBALS['visiteur_session']['nom'] ?? '';
+
+            if ($statut != '0minirezo') {
+                $titre = _T('info_acces_interdit');
+            }
+
+            if ($statut && test_espace_prive()) {
+                $footer = bouton_action(_T('public:accueil_site'), generer_url_ecrire('accueil'));
+            }
+            elseif (!empty($_COOKIE['spip_admin'])) {
+                $footer = bouton_action(_T('public:lien_connecter'), generer_url_public('login'));
+            }
+            else {
+                $footer = bouton_action(_T('public:accueil_site'), $GLOBALS['meta']['adresse_site'] ?? '');
+            }
+
+            spip_logger('minipres')->info($nom . " $titre " . $_SERVER['REQUEST_URI']);
+
+            $options['footer'] = $footer;
+            if (empty($corps)) {
+                $corps = "<div class='msg-alert error'>"
+                    . $titre
+                    . '</div>';
+                $options['titre'] = '';
+            }
+            else {
+                $options['titre'] = $titre;
+            }
+        }
+        else {
+            $options['titre'] = $titre;
+        }
+        $options['page_title'] = $titre;
+
+        $options = $this->setOptions($options);
+
+        $html = parent::page($corps, $options);
+
+        if (!_AJAX) {
+            return $html;
+        } else {
+            include_spip('inc/headers');
+            include_spip('inc/actions');
+            $url = self('&', true);
+            foreach ($_POST as $v => $c) {
+                $url = parametre_url($url, $v, $c, '&');
+            }
+            ajax_retour('<div>' . $titre . redirige_formulaire($url) . '</div>', false);
+            return '';
+        }
+    }
 }

Spacing +3 added lines, -3 removed lines

@@ -103,7 +103,7 @@ 
 
 			$titre = ($titre == 'install')
 				? _T('avis_espace_interdit')
-				: $titre . ' : ' . _T('info_acces_interdit');
+				: $titre.' : '._T('info_acces_interdit');
 
 			$statut = $GLOBALS['visiteur_session']['statut'] ?? '';
 			$nom = $GLOBALS['visiteur_session']['nom'] ?? '';
@@ -122,7 +122,7 @@ 
 				$footer = bouton_action(_T('public:accueil_site'), $GLOBALS['meta']['adresse_site'] ?? '');
 			}
 
-			spip_logger('minipres')->info($nom . " $titre " . $_SERVER['REQUEST_URI']);
+			spip_logger('minipres')->info($nom." $titre ".$_SERVER['REQUEST_URI']);
 
 			$options['footer'] = $footer;
 			if (empty($corps)) {
@@ -153,7 +153,7 @@ 
 			foreach ($_POST as $v => $c) {
 				$url = parametre_url($url, $v, $c, '&');
 			}
-			ajax_retour('<div>' . $titre . redirige_formulaire($url) . '</div>', false);
+			ajax_retour('<div>'.$titre.redirige_formulaire($url).'</div>', false);
 			return '';
 		}
 	}

ecrire/src/Compilateur/Iterateur/Decorator.php

Indentation +557 added lines, -557 removed lines

@@ -9,569 +9,569 @@
 
 class Decorator extends FilterIterator
 {
-	/**
-	 * Conditions de filtrage
-	 * ie criteres de selection.
-	 *
-	 * @var array
-	 */
-	protected $filtre = [];
-
-	/**
-	 * Fonction de filtrage compilee a partir des criteres de filtre.
-	 *
-	 * @var string
-	 */
-	protected $func_filtre;
-
-	/**
-	 * Critere {offset, limit}.
-	 *
-	 * @var int
-	 * @var int
-	 */
-	protected $offset;
-	protected $limit;
-
-	/**
-	 * nombre d'elements recuperes depuis la position 0,
-	 * en tenant compte des filtres.
-	 *
-	 * @var int
-	 */
-	protected $fetched = 0;
-
-	/**
-	 * Y a t'il une erreur ?
-	 *
-	 * @var bool
-	 */
-	protected $err = false;
-
-	// Extension SPIP des iterateurs PHP
-	/**
-	 * type de l'iterateur.
-	 *
-	 * @var string
-	 */
-	protected $type;
-
-	/**
-	 * position courante de l'iterateur.
-	 *
-	 * @var int
-	 */
-	protected $pos = 0;
-
-	/**
-	 * nombre total resultats dans l'iterateur.
-	 *
-	 * @var int
-	 */
-	protected $total;
-
-	/**
-	 * nombre maximal de recherche pour $total
-	 * si l'iterateur n'implemente pas de fonction specifique.
-	 */
-	protected $max = 100000;
-
-	protected LoggerInterface $logger;
-
-	/**
-	 * Liste des champs a inserer dans les $row
-	 * retournes par ->fetch().
-	 */
-	protected $select = [];
-	private readonly Iterator $iter;
-
-	public function __construct(
-		Iterator $iter,
-		/** Parametres de l'iterateur */
-		protected array $command,
-		/** Infos du compilateur */
-		protected array $info
-	) {
-		$this->logger = spip_logger(); // FIXME: inject it.
-		parent::__construct($iter);
-		parent::rewind(); // remettre a la premiere position (bug? connu de FilterIterator)
-
-		// recuperer l'iterateur transmis
-		$this->iter = $this->getInnerIterator();
-
-		// chercher la liste des champs a retourner par
-		// fetch si l'objet ne les calcule pas tout seul
-		if (!method_exists($this->iter, 'fetch')) {
-			$this->calculer_select();
-			$this->calculer_filtres();
-		}
-
-		// emptyIterator critere {si} faux n'a pas d'erreur !
-		if (property_exists($this->iter, 'err') && $this->iter->err !== null) {
-			$this->err = $this->iter->err;
-		}
-
-		// pas d'init a priori, le calcul ne sera fait qu'en cas de besoin (provoque une double requete souvent inutile en sqlite)
-		//$this->total = $this->count();
-	}
-
-	/**
-	 * Drapeau a activer en cas d'echec
-	 * (select SQL errone, non chargement des DATA, etc).
-	 */
-	public function err() {
-		if (method_exists($this->iter, 'err')) {
-			return $this->iter->err();
-		}
-		if (property_exists($this->iter, 'err')) {
-			return $this->iter->err;
-		}
-
-		return false;
-	}
-
-	// recuperer la valeur d'une balise #X
-	// en fonction des methodes
-	// et proprietes disponibles
-	public function get_select($nom) {
-		if (is_object($this->iter) && method_exists($this->iter, $nom)) {
-			try {
-				return $this->iter->{$nom}();
-			} catch (Exception) {
-				// #GETCHILDREN sur un fichier de DirectoryIterator ...
-				$this->logger->info("Methode {$nom} en echec sur " . $this->iter::class);
-				$this->logger->info("Cela peut être normal : retour d'une ligne de resultat ne pouvant pas calculer cette methode");
-
-				return '';
-			}
-		}
-		/*
+    /**
+     * Conditions de filtrage
+     * ie criteres de selection.
+     *
+     * @var array
+     */
+    protected $filtre = [];
+
+    /**
+     * Fonction de filtrage compilee a partir des criteres de filtre.
+     *
+     * @var string
+     */
+    protected $func_filtre;
+
+    /**
+     * Critere {offset, limit}.
+     *
+     * @var int
+     * @var int
+     */
+    protected $offset;
+    protected $limit;
+
+    /**
+     * nombre d'elements recuperes depuis la position 0,
+     * en tenant compte des filtres.
+     *
+     * @var int
+     */
+    protected $fetched = 0;
+
+    /**
+     * Y a t'il une erreur ?
+     *
+     * @var bool
+     */
+    protected $err = false;
+
+    // Extension SPIP des iterateurs PHP
+    /**
+     * type de l'iterateur.
+     *
+     * @var string
+     */
+    protected $type;
+
+    /**
+     * position courante de l'iterateur.
+     *
+     * @var int
+     */
+    protected $pos = 0;
+
+    /**
+     * nombre total resultats dans l'iterateur.
+     *
+     * @var int
+     */
+    protected $total;
+
+    /**
+     * nombre maximal de recherche pour $total
+     * si l'iterateur n'implemente pas de fonction specifique.
+     */
+    protected $max = 100000;
+
+    protected LoggerInterface $logger;
+
+    /**
+     * Liste des champs a inserer dans les $row
+     * retournes par ->fetch().
+     */
+    protected $select = [];
+    private readonly Iterator $iter;
+
+    public function __construct(
+        Iterator $iter,
+        /** Parametres de l'iterateur */
+        protected array $command,
+        /** Infos du compilateur */
+        protected array $info
+    ) {
+        $this->logger = spip_logger(); // FIXME: inject it.
+        parent::__construct($iter);
+        parent::rewind(); // remettre a la premiere position (bug? connu de FilterIterator)
+
+        // recuperer l'iterateur transmis
+        $this->iter = $this->getInnerIterator();
+
+        // chercher la liste des champs a retourner par
+        // fetch si l'objet ne les calcule pas tout seul
+        if (!method_exists($this->iter, 'fetch')) {
+            $this->calculer_select();
+            $this->calculer_filtres();
+        }
+
+        // emptyIterator critere {si} faux n'a pas d'erreur !
+        if (property_exists($this->iter, 'err') && $this->iter->err !== null) {
+            $this->err = $this->iter->err;
+        }
+
+        // pas d'init a priori, le calcul ne sera fait qu'en cas de besoin (provoque une double requete souvent inutile en sqlite)
+        //$this->total = $this->count();
+    }
+
+    /**
+     * Drapeau a activer en cas d'echec
+     * (select SQL errone, non chargement des DATA, etc).
+     */
+    public function err() {
+        if (method_exists($this->iter, 'err')) {
+            return $this->iter->err();
+        }
+        if (property_exists($this->iter, 'err')) {
+            return $this->iter->err;
+        }
+
+        return false;
+    }
+
+    // recuperer la valeur d'une balise #X
+    // en fonction des methodes
+    // et proprietes disponibles
+    public function get_select($nom) {
+        if (is_object($this->iter) && method_exists($this->iter, $nom)) {
+            try {
+                return $this->iter->{$nom}();
+            } catch (Exception) {
+                // #GETCHILDREN sur un fichier de DirectoryIterator ...
+                $this->logger->info("Methode {$nom} en echec sur " . $this->iter::class);
+                $this->logger->info("Cela peut être normal : retour d'une ligne de resultat ne pouvant pas calculer cette methode");
+
+                return '';
+            }
+        }
+        /*
 		if (property_exists($this->iter, $nom)) {
 			return $this->iter->$nom;
 		}*/
-		// cle et valeur par defaut
-		// ICI PLANTAGE SI ON NE CONTROLE PAS $nom
-		if (
-			in_array($nom, ['cle', 'valeur'])
-			&& method_exists($this, $nom)
-		) {
-			return $this->{$nom}();
-		}
-
-		// Par defaut chercher en xpath dans la valeur()
-		return table_valeur($this->valeur(), $nom, null);
-	}
-
-	public function next(): void {
-		++$this->pos;
-		parent::next();
-	}
-
-	/**
-	 * revient au depart.
-	 */
-	public function rewind(): void {
-		$this->pos = 0;
-		$this->fetched = 0;
-		parent::rewind();
-	}
-
-	/**
-	 * aller a la position absolue n,
-	 * comptee depuis le debut.
-	 *
-	 * @param int    $n
-	 *                         absolute pos
-	 * @param string $continue
-	 *                         param for sql_ api
-	 *
-	 * @return bool
-	 *              success or fail if not implemented
-	 */
-	public function seek($n = 0, $continue = null) {
-		if ($this->func_filtre || !method_exists($this->iter, 'seek') || !$this->iter->seek($n)) {
-			$this->seek_loop($n);
-		}
-		$this->pos = $n;
-		$this->fetched = $n;
-
-		return true;
-	}
-
-	/**
-	 * Avancer de $saut pas.
-	 *
-	 * @param int $saut
-	 * @param int|null $max
-	 *
-	 * @return int
-	 */
-	public function skip($saut, $max = null) {
-		// pas de saut en arriere autorise pour cette fonction
-		if (($saut = (int) $saut) <= 0) {
-			return $this->pos;
-		}
-		$seek = $this->pos + $saut;
-		// si le saut fait depasser le maxi, on libere la resource
-		// et on sort
-		if (is_null($max)) {
-			$max = $this->count();
-		}
-
-		if ($seek >= $max || $seek >= $this->count()) {
-			// sortie plus rapide que de faire next() jusqu'a la fin !
-			$this->free();
-
-			return $max;
-		}
-
-		$this->seek($seek);
-
-		return $this->pos;
-	}
-
-	/**
-	 * Renvoyer un tableau des donnees correspondantes
-	 * a la position courante de l'iterateur
-	 * en controlant si on respecte le filtre
-	 * Appliquer aussi le critere {offset,limit}.
-	 *
-	 * @return array|bool
-	 */
-	public function fetch() {
-		if (method_exists($this->iter, 'fetch')) {
-			return $this->iter->fetch();
-		}
-		while (
-				$this->valid()
-				&& (!$this->accept() || $this->offset !== null && $this->fetched++ < $this->offset)
-		) {
-			$this->next();
-		}
-
-		if (!$this->valid()) {
-			return false;
-		}
-
-		if (
-				$this->limit !== null
-				&& $this->fetched > $this->offset + $this->limit
-		) {
-			return false;
-		}
-
-		$r = [];
-		foreach ($this->select as $nom) {
-			$r[$nom] = $this->get_select($nom);
-		}
-		$this->next();
-
-		return $r;
-	}
-
-	// retourner la cle pour #CLE
-	public function cle() {
-		return $this->key();
-	}
-
-	// retourner la valeur pour #VALEUR
-	public function valeur() {
-		return $this->current();
-	}
-
-	/**
-	 * Accepte-t-on l'entree courante lue ?
-	 * On execute les filtres pour le savoir.
-	 */
-	public function accept(): bool {
-		if ($f = $this->func_filtre) {
-			return $f();
-		}
-
-		return true;
-	}
-
-	/**
-	 * liberer la ressource.
-	 *
-	 * @return bool
-	 */
-	public function free() {
-		if (method_exists($this->iter, 'free')) {
-			$this->iter->free();
-		}
-		$this->pos = $this->total = 0;
-
-		return true;
-	}
-
-	/**
-	 * Compter le nombre total de resultats
-	 * pour #TOTAL_BOUCLE.
-	 *
-	 * @return int
-	 */
-	public function count() {
-		if (is_null($this->total)) {
-			if (
-				method_exists($this->iter, 'count')
-				&& !$this->func_filtre
-			) {
-				return $this->total = $this->iter->count();
-			}
-			// compter les lignes et rembobiner
-			$total = 0;
-			$pos = $this->pos; // sauver la position
-			$this->rewind();
-			while ($this->fetch() && $total < $this->max) {
-				++$total;
-			}
-			$this->seek($pos);
-			$this->total = $total;
-		}
-
-		return $this->total;
-	}
-
-	/**
-	 * Assembler le tableau de filtres traduits depuis les conditions SQL
-	 * les filtres vides ou null sont ignores.
-	 *
-	 * @param array $filtres
-	 * @param string $operateur
-	 *
-	 * @return null|string
-	 */
-	protected function assembler_filtres($filtres, $operateur = 'AND') {
-		$filtres_string = [];
-		foreach ($filtres as $k => $v) {
-			// si c'est un tableau de OR/AND + 2 sous-filtres, on recurse pour transformer en chaine
-			if (is_array($v) && in_array(reset($v), ['OR', 'AND'])) {
-				$op = array_shift($v);
-				$v = $this->assembler_filtres($v, $op);
-			}
-			if (is_null($v) || !is_string($v) || empty($v)) {
-				continue;
-			}
-			$filtres_string[] = $v;
-		}
-
-		if ($filtres_string === []) {
-			return null;
-		}
-
-		return '(' . implode(") {$operateur} (", $filtres_string) . ')';
-	}
-
-	/**
-	 * Traduire un element du tableau where SQL en un filtre.
-	 *
-	 * @param array|string $v
-	 *
-	 * @return null|array|string
-	 */
-	protected function traduire_condition_sql_en_filtre($v) {
-		if (is_array($v)) {
-			if ((count($v) >= 2) && ('REGEXP' == $v[0]) && ("'.*'" == $v[2])) {
-				return 'true';
-			}
-			if ((count($v) >= 2) && ('LIKE' == $v[0]) && ("'%'" == $v[2])) {
-				return 'true';
-			}
-			$op = $v[0] ?: $v;
-		} else {
-			$op = $v;
-		}
-		if (!$op || 1 == $op || '0=0' == $op) {
-			return 'true';
-		}
-		if ('0=1' === $op) {
-			return 'false';
-		}
-		// traiter {cle IN a,b} ou {valeur !IN a,b}
-		if (preg_match(',^\(([\w/]+)(\s+NOT)?\s+IN\s+(\(.*\))\)$,', (string) $op, $regs)) {
-			return $this->composer_filtre($regs[1], 'IN', $regs[3], $regs[2]);
-		}
-
-		// 3 possibilites : count($v) =
-		// * 1 : {x y} ; on recoit $v[0] = y
-		// * 2 : {x !op y} ; on recoit $v[0] = 'NOT', $v[1] = array() // array du type {x op y}
-		// * 3 : {x op y} ; on recoit $v[0] = 'op', $v[1] = x, $v[2] = y
-
-		// 1 : forcement traite par un critere, on passe
-		if (!$v || !is_array($v) || 1 == count($v)) {
-			return null; // sera ignore
-		}
-		if (2 == count($v) && is_array($v[1])) {
-			return $this->composer_filtre($v[1][1], $v[1][0], $v[1][2], 'NOT');
-		}
-		if (3 == count($v)) {
-			// traiter le OR/AND suivi de 2 valeurs
-			if (in_array($op, ['OR', 'AND'])) {
-				array_shift($v);
-				foreach (array_keys($v) as $k) {
-					$v[$k] = $this->traduire_condition_sql_en_filtre($v[$k]);
-					if (null === $v[$k]) {
-						unset($v[$k]);
-					} elseif ('true' === $v[$k]) {
-						if ('OR' === $op) {
-							return 'true';
-						}
-						if ('AND' === $op) {
-							unset($v[$k]);
-						}
-					} elseif ('false' === $v[$k]) {
-						if ('OR' === $op) {
-							unset($v[$k]);
-						}
-						if ('AND' === $op) {
-							return 'false';
-						}
-					}
-				}
-				if ($v === []) {
-					return null;
-				}
-				if (1 === count($v)) {
-					return reset($v);
-				}
-				array_unshift($v, $op);
-
-				return $v;
-			}
-
-			return $this->composer_filtre($v[1], $v[0], $v[2]);
-		}
-
-		return null;  // sera ignore
-	}
-
-	/**
-	 * Calculer un filtre sur un champ du tableau.
-	 *
-	 * @param string $cle
-	 * @param string $op
-	 * @param string $valeur
-	 * @param bool $not
-	 *
-	 * @return null|string
-	 */
-	protected function composer_filtre($cle, $op, $valeur, $not = false) {
-		if (
-			method_exists($this->iter, 'exception_des_criteres')
-			&& in_array($cle, $this->iter->exception_des_criteres())
-		) {
-			return null;
-		}
-		// TODO: analyser le filtre pour refuser ce qu'on ne sait pas traiter ?
-		// mais c'est normalement deja opere par calculer_critere_infixe()
-		// qui regarde la description 'desc' (en casse reelle d'ailleurs : {isDir=1}
-		// ne sera pas vu si l'on a defini desc['field']['isdir'] pour que #ISDIR soit present.
-		// il faudrait peut etre definir les 2 champs isDir et isdir... a reflechir...
-
-		// if (!in_array($cle, array('cle', 'valeur')))
-		//	return;
-
-		$a = '$this->get_select(\'' . $cle . '\')';
-
-		$filtre = '';
-
-		if ('REGEXP' == $op) {
-			$filtre = 'filtrer("match", ' . $a . ', ' . str_replace('\"', '"', (string) $valeur) . ')';
-			$op = '';
-		} else {
-			if ('LIKE' == $op) {
-				$valeur = str_replace(['\"', '_', '%'], ['"', '.', '.*'], preg_quote((string) $valeur));
-				$filtre = 'filtrer("match", ' . $a . ', ' . $valeur . ')';
-				$op = '';
-			} else {
-				if ('=' == $op) {
-					$op = '==';
-				} else {
-					if ('IN' == $op) {
-						$filtre = 'in_array(' . $a . ', array' . $valeur . ')';
-						$op = '';
-					} else {
-						if (!in_array($op, ['<', '<=', '>', '>='])) {
-							$this->logger->info('operateur non reconnu ' . $op); // [todo] mettre une erreur de squelette
-							$op = '';
-						}
-					}
-				}
-			}
-		}
-
-		if ($op) {
-			$filtre = $a . $op . str_replace('\"', '"', (string) $valeur);
-		}
-
-		if ($not) {
-			$filtre = "!({$filtre})";
-		}
-
-		return $filtre;
-	}
-
-	// calcule les elements a retournes par fetch()
-	// enleve les elements inutiles du select()
-	//
-	private function calculer_select() {
-		if ($select = &$this->command['select']) {
-			foreach ($select as $s) {
-				// /!\ $s = '.nom'
-				if ('.' == $s[0]) {
-					$s = substr((string) $s, 1);
-				}
-				$this->select[] = $s;
-			}
-		}
-	}
-
-	private function calculer_filtres() {
-		// Issu de calculer_select() de public/composer L.519
-		// TODO: externaliser...
-		//
-		// retirer les criteres vides:
-		// {X ?} avec X absent de l'URL
-		// {par #ENV{X}} avec X absent de l'URL
-		// IN sur collection vide (ce dernier devrait pouvoir etre fait a la compil)
-		if ($where = &$this->command['where']) {
-			foreach ($where as $k => $v) {
-				$this->filtre[] = $this->traduire_condition_sql_en_filtre($v);
-			}
-		}
-
-		// critere {2,7}
-		if (isset($this->command['limit']) && $this->command['limit']) {
-			$limit = explode(',', (string) $this->command['limit']);
-			$this->offset = $limit[0];
-			$this->limit = $limit[1];
-		}
-
-		// Creer la fonction de filtrage sur $this
-		if ($this->filtre) {
-			if ($filtres = $this->assembler_filtres($this->filtre)) {
-				$filtres = 'return ' . $filtres . ';';
-				$this->func_filtre = fn () => eval($filtres);
-			} else {
-				$this->func_filtre = null;
-			}
-		}
-	}
-
-	/*
+        // cle et valeur par defaut
+        // ICI PLANTAGE SI ON NE CONTROLE PAS $nom
+        if (
+            in_array($nom, ['cle', 'valeur'])
+            && method_exists($this, $nom)
+        ) {
+            return $this->{$nom}();
+        }
+
+        // Par defaut chercher en xpath dans la valeur()
+        return table_valeur($this->valeur(), $nom, null);
+    }
+
+    public function next(): void {
+        ++$this->pos;
+        parent::next();
+    }
+
+    /**
+     * revient au depart.
+     */
+    public function rewind(): void {
+        $this->pos = 0;
+        $this->fetched = 0;
+        parent::rewind();
+    }
+
+    /**
+     * aller a la position absolue n,
+     * comptee depuis le debut.
+     *
+     * @param int    $n
+     *                         absolute pos
+     * @param string $continue
+     *                         param for sql_ api
+     *
+     * @return bool
+     *              success or fail if not implemented
+     */
+    public function seek($n = 0, $continue = null) {
+        if ($this->func_filtre || !method_exists($this->iter, 'seek') || !$this->iter->seek($n)) {
+            $this->seek_loop($n);
+        }
+        $this->pos = $n;
+        $this->fetched = $n;
+
+        return true;
+    }
+
+    /**
+     * Avancer de $saut pas.
+     *
+     * @param int $saut
+     * @param int|null $max
+     *
+     * @return int
+     */
+    public function skip($saut, $max = null) {
+        // pas de saut en arriere autorise pour cette fonction
+        if (($saut = (int) $saut) <= 0) {
+            return $this->pos;
+        }
+        $seek = $this->pos + $saut;
+        // si le saut fait depasser le maxi, on libere la resource
+        // et on sort
+        if (is_null($max)) {
+            $max = $this->count();
+        }
+
+        if ($seek >= $max || $seek >= $this->count()) {
+            // sortie plus rapide que de faire next() jusqu'a la fin !
+            $this->free();
+
+            return $max;
+        }
+
+        $this->seek($seek);
+
+        return $this->pos;
+    }
+
+    /**
+     * Renvoyer un tableau des donnees correspondantes
+     * a la position courante de l'iterateur
+     * en controlant si on respecte le filtre
+     * Appliquer aussi le critere {offset,limit}.
+     *
+     * @return array|bool
+     */
+    public function fetch() {
+        if (method_exists($this->iter, 'fetch')) {
+            return $this->iter->fetch();
+        }
+        while (
+                $this->valid()
+                && (!$this->accept() || $this->offset !== null && $this->fetched++ < $this->offset)
+        ) {
+            $this->next();
+        }
+
+        if (!$this->valid()) {
+            return false;
+        }
+
+        if (
+                $this->limit !== null
+                && $this->fetched > $this->offset + $this->limit
+        ) {
+            return false;
+        }
+
+        $r = [];
+        foreach ($this->select as $nom) {
+            $r[$nom] = $this->get_select($nom);
+        }
+        $this->next();
+
+        return $r;
+    }
+
+    // retourner la cle pour #CLE
+    public function cle() {
+        return $this->key();
+    }
+
+    // retourner la valeur pour #VALEUR
+    public function valeur() {
+        return $this->current();
+    }
+
+    /**
+     * Accepte-t-on l'entree courante lue ?
+     * On execute les filtres pour le savoir.
+     */
+    public function accept(): bool {
+        if ($f = $this->func_filtre) {
+            return $f();
+        }
+
+        return true;
+    }
+
+    /**
+     * liberer la ressource.
+     *
+     * @return bool
+     */
+    public function free() {
+        if (method_exists($this->iter, 'free')) {
+            $this->iter->free();
+        }
+        $this->pos = $this->total = 0;
+
+        return true;
+    }
+
+    /**
+     * Compter le nombre total de resultats
+     * pour #TOTAL_BOUCLE.
+     *
+     * @return int
+     */
+    public function count() {
+        if (is_null($this->total)) {
+            if (
+                method_exists($this->iter, 'count')
+                && !$this->func_filtre
+            ) {
+                return $this->total = $this->iter->count();
+            }
+            // compter les lignes et rembobiner
+            $total = 0;
+            $pos = $this->pos; // sauver la position
+            $this->rewind();
+            while ($this->fetch() && $total < $this->max) {
+                ++$total;
+            }
+            $this->seek($pos);
+            $this->total = $total;
+        }
+
+        return $this->total;
+    }
+
+    /**
+     * Assembler le tableau de filtres traduits depuis les conditions SQL
+     * les filtres vides ou null sont ignores.
+     *
+     * @param array $filtres
+     * @param string $operateur
+     *
+     * @return null|string
+     */
+    protected function assembler_filtres($filtres, $operateur = 'AND') {
+        $filtres_string = [];
+        foreach ($filtres as $k => $v) {
+            // si c'est un tableau de OR/AND + 2 sous-filtres, on recurse pour transformer en chaine
+            if (is_array($v) && in_array(reset($v), ['OR', 'AND'])) {
+                $op = array_shift($v);
+                $v = $this->assembler_filtres($v, $op);
+            }
+            if (is_null($v) || !is_string($v) || empty($v)) {
+                continue;
+            }
+            $filtres_string[] = $v;
+        }
+
+        if ($filtres_string === []) {
+            return null;
+        }
+
+        return '(' . implode(") {$operateur} (", $filtres_string) . ')';
+    }
+
+    /**
+     * Traduire un element du tableau where SQL en un filtre.
+     *
+     * @param array|string $v
+     *
+     * @return null|array|string
+     */
+    protected function traduire_condition_sql_en_filtre($v) {
+        if (is_array($v)) {
+            if ((count($v) >= 2) && ('REGEXP' == $v[0]) && ("'.*'" == $v[2])) {
+                return 'true';
+            }
+            if ((count($v) >= 2) && ('LIKE' == $v[0]) && ("'%'" == $v[2])) {
+                return 'true';
+            }
+            $op = $v[0] ?: $v;
+        } else {
+            $op = $v;
+        }
+        if (!$op || 1 == $op || '0=0' == $op) {
+            return 'true';
+        }
+        if ('0=1' === $op) {
+            return 'false';
+        }
+        // traiter {cle IN a,b} ou {valeur !IN a,b}
+        if (preg_match(',^\(([\w/]+)(\s+NOT)?\s+IN\s+(\(.*\))\)$,', (string) $op, $regs)) {
+            return $this->composer_filtre($regs[1], 'IN', $regs[3], $regs[2]);
+        }
+
+        // 3 possibilites : count($v) =
+        // * 1 : {x y} ; on recoit $v[0] = y
+        // * 2 : {x !op y} ; on recoit $v[0] = 'NOT', $v[1] = array() // array du type {x op y}
+        // * 3 : {x op y} ; on recoit $v[0] = 'op', $v[1] = x, $v[2] = y
+
+        // 1 : forcement traite par un critere, on passe
+        if (!$v || !is_array($v) || 1 == count($v)) {
+            return null; // sera ignore
+        }
+        if (2 == count($v) && is_array($v[1])) {
+            return $this->composer_filtre($v[1][1], $v[1][0], $v[1][2], 'NOT');
+        }
+        if (3 == count($v)) {
+            // traiter le OR/AND suivi de 2 valeurs
+            if (in_array($op, ['OR', 'AND'])) {
+                array_shift($v);
+                foreach (array_keys($v) as $k) {
+                    $v[$k] = $this->traduire_condition_sql_en_filtre($v[$k]);
+                    if (null === $v[$k]) {
+                        unset($v[$k]);
+                    } elseif ('true' === $v[$k]) {
+                        if ('OR' === $op) {
+                            return 'true';
+                        }
+                        if ('AND' === $op) {
+                            unset($v[$k]);
+                        }
+                    } elseif ('false' === $v[$k]) {
+                        if ('OR' === $op) {
+                            unset($v[$k]);
+                        }
+                        if ('AND' === $op) {
+                            return 'false';
+                        }
+                    }
+                }
+                if ($v === []) {
+                    return null;
+                }
+                if (1 === count($v)) {
+                    return reset($v);
+                }
+                array_unshift($v, $op);
+
+                return $v;
+            }
+
+            return $this->composer_filtre($v[1], $v[0], $v[2]);
+        }
+
+        return null;  // sera ignore
+    }
+
+    /**
+     * Calculer un filtre sur un champ du tableau.
+     *
+     * @param string $cle
+     * @param string $op
+     * @param string $valeur
+     * @param bool $not
+     *
+     * @return null|string
+     */
+    protected function composer_filtre($cle, $op, $valeur, $not = false) {
+        if (
+            method_exists($this->iter, 'exception_des_criteres')
+            && in_array($cle, $this->iter->exception_des_criteres())
+        ) {
+            return null;
+        }
+        // TODO: analyser le filtre pour refuser ce qu'on ne sait pas traiter ?
+        // mais c'est normalement deja opere par calculer_critere_infixe()
+        // qui regarde la description 'desc' (en casse reelle d'ailleurs : {isDir=1}
+        // ne sera pas vu si l'on a defini desc['field']['isdir'] pour que #ISDIR soit present.
+        // il faudrait peut etre definir les 2 champs isDir et isdir... a reflechir...
+
+        // if (!in_array($cle, array('cle', 'valeur')))
+        //	return;
+
+        $a = '$this->get_select(\'' . $cle . '\')';
+
+        $filtre = '';
+
+        if ('REGEXP' == $op) {
+            $filtre = 'filtrer("match", ' . $a . ', ' . str_replace('\"', '"', (string) $valeur) . ')';
+            $op = '';
+        } else {
+            if ('LIKE' == $op) {
+                $valeur = str_replace(['\"', '_', '%'], ['"', '.', '.*'], preg_quote((string) $valeur));
+                $filtre = 'filtrer("match", ' . $a . ', ' . $valeur . ')';
+                $op = '';
+            } else {
+                if ('=' == $op) {
+                    $op = '==';
+                } else {
+                    if ('IN' == $op) {
+                        $filtre = 'in_array(' . $a . ', array' . $valeur . ')';
+                        $op = '';
+                    } else {
+                        if (!in_array($op, ['<', '<=', '>', '>='])) {
+                            $this->logger->info('operateur non reconnu ' . $op); // [todo] mettre une erreur de squelette
+                            $op = '';
+                        }
+                    }
+                }
+            }
+        }
+
+        if ($op) {
+            $filtre = $a . $op . str_replace('\"', '"', (string) $valeur);
+        }
+
+        if ($not) {
+            $filtre = "!({$filtre})";
+        }
+
+        return $filtre;
+    }
+
+    // calcule les elements a retournes par fetch()
+    // enleve les elements inutiles du select()
+    //
+    private function calculer_select() {
+        if ($select = &$this->command['select']) {
+            foreach ($select as $s) {
+                // /!\ $s = '.nom'
+                if ('.' == $s[0]) {
+                    $s = substr((string) $s, 1);
+                }
+                $this->select[] = $s;
+            }
+        }
+    }
+
+    private function calculer_filtres() {
+        // Issu de calculer_select() de public/composer L.519
+        // TODO: externaliser...
+        //
+        // retirer les criteres vides:
+        // {X ?} avec X absent de l'URL
+        // {par #ENV{X}} avec X absent de l'URL
+        // IN sur collection vide (ce dernier devrait pouvoir etre fait a la compil)
+        if ($where = &$this->command['where']) {
+            foreach ($where as $k => $v) {
+                $this->filtre[] = $this->traduire_condition_sql_en_filtre($v);
+            }
+        }
+
+        // critere {2,7}
+        if (isset($this->command['limit']) && $this->command['limit']) {
+            $limit = explode(',', (string) $this->command['limit']);
+            $this->offset = $limit[0];
+            $this->limit = $limit[1];
+        }
+
+        // Creer la fonction de filtrage sur $this
+        if ($this->filtre) {
+            if ($filtres = $this->assembler_filtres($this->filtre)) {
+                $filtres = 'return ' . $filtres . ';';
+                $this->func_filtre = fn () => eval($filtres);
+            } else {
+                $this->func_filtre = null;
+            }
+        }
+    }
+
+    /*
 	 * aller a la position $n en parcourant
 	 * un par un tous les elements
 	 */
-	private function seek_loop($n) {
-		if ($this->pos > $n) {
-			$this->rewind();
-		}
+    private function seek_loop($n) {
+        if ($this->pos > $n) {
+            $this->rewind();
+        }
 
-		while ($this->pos < $n && $this->valid()) {
-			$this->next();
-		}
+        while ($this->pos < $n && $this->valid()) {
+            $this->next();
+        }
 
-		return true;
-	}
+        return true;
+    }
 }

Spacing +10 added lines, -10 removed lines

@@ -139,7 +139,7 @@ 
 				return $this->iter->{$nom}();
 			} catch (Exception) {
 				// #GETCHILDREN sur un fichier de DirectoryIterator ...
-				$this->logger->info("Methode {$nom} en echec sur " . $this->iter::class);
+				$this->logger->info("Methode {$nom} en echec sur ".$this->iter::class);
 				$this->logger->info("Cela peut être normal : retour d'une ligne de resultat ne pouvant pas calculer cette methode");
 
 				return '';
@@ -360,7 +360,7 @@ 
 			return null;
 		}
 
-		return '(' . implode(") {$operateur} (", $filtres_string) . ')';
+		return '('.implode(") {$operateur} (", $filtres_string).')';
 	}
 
 	/**
@@ -443,7 +443,7 @@ 
 			return $this->composer_filtre($v[1], $v[0], $v[2]);
 		}
 
-		return null;  // sera ignore
+		return null; // sera ignore
 	}
 
 	/**
@@ -472,28 +472,28 @@ 
 		// if (!in_array($cle, array('cle', 'valeur')))
 		//	return;
 
-		$a = '$this->get_select(\'' . $cle . '\')';
+		$a = '$this->get_select(\''.$cle.'\')';
 
 		$filtre = '';
 
 		if ('REGEXP' == $op) {
-			$filtre = 'filtrer("match", ' . $a . ', ' . str_replace('\"', '"', (string) $valeur) . ')';
+			$filtre = 'filtrer("match", '.$a.', '.str_replace('\"', '"', (string) $valeur).')';
 			$op = '';
 		} else {
 			if ('LIKE' == $op) {
 				$valeur = str_replace(['\"', '_', '%'], ['"', '.', '.*'], preg_quote((string) $valeur));
-				$filtre = 'filtrer("match", ' . $a . ', ' . $valeur . ')';
+				$filtre = 'filtrer("match", '.$a.', '.$valeur.')';
 				$op = '';
 			} else {
 				if ('=' == $op) {
 					$op = '==';
 				} else {
 					if ('IN' == $op) {
-						$filtre = 'in_array(' . $a . ', array' . $valeur . ')';
+						$filtre = 'in_array('.$a.', array'.$valeur.')';
 						$op = '';
 					} else {
 						if (!in_array($op, ['<', '<=', '>', '>='])) {
-							$this->logger->info('operateur non reconnu ' . $op); // [todo] mettre une erreur de squelette
+							$this->logger->info('operateur non reconnu '.$op); // [todo] mettre une erreur de squelette
 							$op = '';
 						}
 					}
@@ -502,7 +502,7 @@ 
 		}
 
 		if ($op) {
-			$filtre = $a . $op . str_replace('\"', '"', (string) $valeur);
+			$filtre = $a.$op.str_replace('\"', '"', (string) $valeur);
 		}
 
 		if ($not) {
@@ -551,7 +551,7 @@ 
 		// Creer la fonction de filtrage sur $this
 		if ($this->filtre) {
 			if ($filtres = $this->assembler_filtres($this->filtre)) {
-				$filtres = 'return ' . $filtres . ';';
+				$filtres = 'return '.$filtres.';';
 				$this->func_filtre = fn () => eval($filtres);
 			} else {
 				$this->func_filtre = null;

ecrire/src/Compilateur/Iterateur/Factory.php

Indentation +54 added lines, -54 removed lines

@@ -12,61 +12,61 @@
  */
 class Factory
 {
-	public static function create($iterateur, $command, $info = null) {
-		$logger = spip_logger(); // FIXME: inject it.
-		$iter = null;
-		// cas des SI {si expression} analises tres tot
-		// pour eviter le chargement de tout iterateur
-		if (isset($command['si'])) {
-			foreach ($command['si'] as $si) {
-				if (!$si) {
-					// $command pour boucle SQL peut generer des erreurs de compilation
-					// s'il est transmis alors qu'on est dans un iterateur vide
-					return new Decorator(new EmptyIterator(), [], $info);
-				}
-			}
-		}
+    public static function create($iterateur, $command, $info = null) {
+        $logger = spip_logger(); // FIXME: inject it.
+        $iter = null;
+        // cas des SI {si expression} analises tres tot
+        // pour eviter le chargement de tout iterateur
+        if (isset($command['si'])) {
+            foreach ($command['si'] as $si) {
+                if (!$si) {
+                    // $command pour boucle SQL peut generer des erreurs de compilation
+                    // s'il est transmis alors qu'on est dans un iterateur vide
+                    return new Decorator(new EmptyIterator(), [], $info);
+                }
+            }
+        }
 
-		// chercher un iterateur PHP existant (par exemple dans SPL)
-		// (il faudrait passer l'argument ->sql_serveur
-		// pour etre certain qu'on est sur un "php:")
-		if (class_exists($iterateur)) {
-			$a = $command['args'] ?? [];
+        // chercher un iterateur PHP existant (par exemple dans SPL)
+        // (il faudrait passer l'argument ->sql_serveur
+        // pour etre certain qu'on est sur un "php:")
+        if (class_exists($iterateur)) {
+            $a = $command['args'] ?? [];
 
-			// permettre de passer un Iterateur directement {args #ITERATEUR} :
-			// si on recoit deja un iterateur en argument, on l'utilise
-			if ((is_countable($a) ? count($a) : 0) == 1 && is_object($a[0]) && is_subclass_of($a[0], \Iterator::class)) {
-				$iter = $a[0];
-			} else {
-				// sinon, on cree un iterateur du type donne
-				// arguments de creation de l'iterateur...
-				try {
-					$iter = new $iterateur(...$a);
-				} catch (Exception $e) {
-					$logger->info("Erreur de chargement de l'iterateur {$iterateur}");
-					$logger->info($e->getMessage());
-					$iter = new EmptyIterator();
-				}
-			}
-		} else {
-			// chercher la classe d'iterateur Iterateur/XXX
-			// definie dans le fichier src/Compilateur/Iterateur/xxx.php
-			// FIXME: déclarer quelque part les iterateurs supplémentaires
-			$class = __NAMESPACE__ . '\\' . ucfirst(strtolower((string) $iterateur));
-			if (!class_exists($class)) {
-				// historique
-				// Chercher IterateurXXX
-				include_spip('iterateur/' . strtolower($iterateur));
-				$class = 'Iterateur' . $iterateur;
-				if (!class_exists($class)) {
-					exit("Iterateur {$iterateur} non trouvé");
-					// si l'iterateur n'existe pas, on se rabat sur le generique
-					// $iter = new EmptyIterator();
-				}
-			}
-			$iter = new $class($command, $info);
-		}
+            // permettre de passer un Iterateur directement {args #ITERATEUR} :
+            // si on recoit deja un iterateur en argument, on l'utilise
+            if ((is_countable($a) ? count($a) : 0) == 1 && is_object($a[0]) && is_subclass_of($a[0], \Iterator::class)) {
+                $iter = $a[0];
+            } else {
+                // sinon, on cree un iterateur du type donne
+                // arguments de creation de l'iterateur...
+                try {
+                    $iter = new $iterateur(...$a);
+                } catch (Exception $e) {
+                    $logger->info("Erreur de chargement de l'iterateur {$iterateur}");
+                    $logger->info($e->getMessage());
+                    $iter = new EmptyIterator();
+                }
+            }
+        } else {
+            // chercher la classe d'iterateur Iterateur/XXX
+            // definie dans le fichier src/Compilateur/Iterateur/xxx.php
+            // FIXME: déclarer quelque part les iterateurs supplémentaires
+            $class = __NAMESPACE__ . '\\' . ucfirst(strtolower((string) $iterateur));
+            if (!class_exists($class)) {
+                // historique
+                // Chercher IterateurXXX
+                include_spip('iterateur/' . strtolower($iterateur));
+                $class = 'Iterateur' . $iterateur;
+                if (!class_exists($class)) {
+                    exit("Iterateur {$iterateur} non trouvé");
+                    // si l'iterateur n'existe pas, on se rabat sur le generique
+                    // $iter = new EmptyIterator();
+                }
+            }
+            $iter = new $class($command, $info);
+        }
 
-		return new Decorator($iter, $command, $info);
-	}
+        return new Decorator($iter, $command, $info);
+    }
 }

ecrire/src/Compilateur/Iterateur/Data.php

Indentation +465 added lines, -465 removed lines

@@ -12,473 +12,473 @@
  */
 class Data extends AbstractIterateur implements Iterator
 {
-	/** Tableau de données */
-	protected array $tableau = [];
-
-	/**
-	 * Conditions de filtrage
-	 * ie criteres de selection
-	 */
-	protected array $filtre = [];
-
-	/**
-	 * Cle courante
-	 *
-	 * @var scalar
-	 */
-	protected $cle = null;
-
-	/**
-	 * Valeur courante
-	 *
-	 * @var mixed
-	 */
-	protected $valeur = null;
-
-	/**
-	 * Constructeur
-	 *
-	 * @param  $command
-	 * @param array $info
-	 */
-	public function __construct(array $command, array $info = []) {
-		include_spip('iterateur/data');
-		$this->type = 'DATA';
-		$this->command = $command;
-		$this->info = $info;
-		$this->select($command);
-	}
-
-	/**
-	 * Revenir au depart
-	 *
-	 * @return void
-	 */
-	public function rewind(): void {
-		reset($this->tableau);
-		$this->cle = array_key_first($this->tableau);
-		$this->valeur = current($this->tableau);
-		next($this->tableau);
-	}
-
-	/**
-	 * Déclarer les critères exceptions
-	 *
-	 * @return array
-	 */
-	public function exception_des_criteres() {
-		return ['tableau'];
-	}
-
-	/**
-	 * Récupérer depuis le cache si possible
-	 *
-	 * @param string $cle
-	 * @return mixed
-	 */
-	protected function cache_get($cle) {
-		if (!$cle) {
-			return;
-		}
-		# utiliser memoization si dispo
-		if (!function_exists('cache_get')) {
-			return;
-		}
-
-		return cache_get($cle);
-	}
-
-	/**
-	 * Stocker en cache si possible
-	 *
-	 * @param string $cle
-	 * @param int $ttl
-	 * @param null|mixed $valeur
-	 * @return bool
-	 */
-	protected function cache_set($cle, $ttl, $valeur = null) {
-		if (!$cle) {
-			return;
-		}
-		if (is_null($valeur)) {
-			$valeur = $this->tableau;
-		}
-		# utiliser memoization si dispo
-		if (!function_exists('cache_set')) {
-			return;
-		}
-
-		return cache_set(
-			$cle,
-			[
-				'data' => $valeur,
-				'time' => time(),
-				'ttl' => $ttl
-			],
-			3600 + $ttl
-		);
-		# conserver le cache 1h de plus que la validite demandee,
-		# pour le cas ou le serveur distant ne reponde plus
-	}
-
-	/**
-	 * Aller chercher les données de la boucle DATA
-	 *
-	 * @throws Exception
-	 * @param array $command
-	 * @return void
-	 */
-	protected function select($command) {
-
-		// l'iterateur DATA peut etre appele en passant (data:type)
-		// le type se retrouve dans la commande 'from'
-		// dans ce cas la le critere {source}, si present, n'a pas besoin du 1er argument
-		if (isset($this->command['from'][0])) {
-			if (isset($this->command['source']) && is_array($this->command['source'])) {
-				array_unshift($this->command['source'], $this->command['sourcemode']);
-			}
-			$this->command['sourcemode'] = $this->command['from'][0];
-		}
-
-		// cherchons differents moyens de creer le tableau de donnees
-		// les commandes connues pour l'iterateur DATA
-		// sont : {tableau #ARRAY} ; {cle=...} ; {valeur=...}
-
-		// {source format, [URL], [arg2]...}
-		if (
-			isset($this->command['source'])
-			&& isset($this->command['sourcemode'])
-		) {
-			$this->select_source();
-		}
-
-		// Critere {liste X1, X2, X3}
-		if (isset($this->command['liste'])) {
-			$this->select_liste();
-		}
-		if (isset($this->command['enum'])) {
-			$this->select_enum();
-		}
-
-		// Si a ce stade on n'a pas de table, il y a un bug
-		if (!is_array($this->tableau)) {
-			$this->err = true;
-			spip_logger()->info('erreur datasource ' . var_export($command, true));
-		}
-
-		// {datapath query.results}
-		// extraire le chemin "query.results" du tableau de donnees
-		if (
-			!$this->err
-			&& isset($this->command['datapath'])
-			&& is_array($this->command['datapath'])
-		) {
-			$this->select_datapath();
-		}
-
-		// tri {par x}
-		if ($this->command['orderby']) {
-			$this->select_orderby();
-		}
-
-		// grouper les resultats {fusion /x/y/z} ;
-		if ($this->command['groupby']) {
-			$this->select_groupby();
-		}
-
-		$this->rewind();
-		#var_dump($this->tableau);
-	}
-
-
-	/**
-	 * Aller chercher les donnees de la boucle DATA
-	 * depuis une source
-	 * {source format, [URL], [arg2]...}
-	 */
-	protected function select_source() {
-		# un peu crado : avant de charger le cache il faut charger
-		# les class indispensables, sinon PHP ne saura pas gerer
-		# l'objet en cache ; cf plugins/icalendar
-		# perf : pas de fonction table_to_array ! (table est deja un array)
-		if (
-			isset($this->command['sourcemode'])
-			&& !in_array($this->command['sourcemode'], ['table', 'array', 'tableau'])
-		) {
-			charger_fonction($this->command['sourcemode'] . '_to_array', 'inc', true);
-		}
-
-		# le premier argument peut etre un array, une URL etc.
-		$src = $this->command['source'][0] ?? null;
-
-		# avons-nous un cache dispo ?
-		$cle = null;
-		if (is_string($src)) {
-			$cle = 'datasource_' . md5($this->command['sourcemode'] . ':' . var_export($this->command['source'], true));
-		}
-
-		$cache = $this->cache_get($cle);
-		if (isset($this->command['datacache'])) {
-			$ttl = (int) $this->command['datacache'];
-		}
-		if (
-			$cache
-			&& $cache['time'] + ($ttl ?? $cache['ttl']) > time()
-			&& !(_request('var_mode') === 'recalcul' && include_spip('inc/autoriser') && autoriser('recalcul'))
-		) {
-			$this->tableau = $cache['data'];
-		} else {
-			try {
-				if (
-					isset($this->command['sourcemode'])
-					&& in_array(
-						$this->command['sourcemode'],
-						['table', 'array', 'tableau']
-					)
-				) {
-					if (
-						is_array($a = $src)
-						|| is_string($a) && ($a = str_replace('"', '"', $a)) && is_array($a = @unserialize($a))
-					) {
-						$this->tableau = $a;
-					}
-				} else {
-					$data = $src;
-					if (is_string($src)) {
-						if (tester_url_absolue($src)) {
-							include_spip('inc/distant');
-							$data = recuperer_url($src, ['taille_max' => _DATA_SOURCE_MAX_SIZE]);
-							$data = $data['page'] ?? '';
-							if (!$data) {
-								throw new Exception('404');
-							}
-							if (!isset($ttl)) {
-								$ttl = 24 * 3600;
-							}
-						} elseif (@is_dir($src)) {
-							$data = $src;
-						} elseif (@is_readable($src) && @is_file($src)) {
-							$data = spip_file_get_contents($src);
-						}
-						if (!isset($ttl)) {
-							$ttl = 10;
-						}
-					}
-					if (
-						!$this->err
-						&& ($data_to_array = charger_fonction($this->command['sourcemode'] . '_to_array', 'inc', true))
-					) {
-						$args = $this->command['source'];
-						$args[0] = $data;
-						if (is_array($a = $data_to_array(...$args))) {
-							$this->tableau = $a;
-						}
-					}
-				}
-
-				if (!is_array($this->tableau)) {
-					$this->err = true;
-				}
-
-				if (!$this->err && isset($ttl) && $ttl > 0) {
-					$this->cache_set($cle, $ttl);
-				}
-			} catch (Exception $e) {
-				$e = $e->getMessage();
-				$err = sprintf(
-					"[%s, %s] $e",
-					$src,
-					$this->command['sourcemode']
-				);
-				erreur_squelette([$err, []]);
-				$this->err = true;
-			}
-		}
-
-		# en cas d'erreur, utiliser le cache si encore dispo
-		if ($this->err && $cache) {
-			$this->tableau = $cache['data'];
-			$this->err = false;
-		}
-	}
-
-
-	/**
-	 * Retourne un tableau donne depuis un critère liste
-	 *
-	 * Critère `{liste X1, X2, X3}`
-	 *
-	 * @see critere_DATA_liste_dist()
-	 *
-	 **/
-	protected function select_liste() {
-		# s'il n'y a qu'une valeur dans la liste, sans doute une #BALISE
-		if (!isset($this->command['liste'][1])) {
-			if (!is_array($this->command['liste'][0])) {
-				$this->command['liste'] = explode(',', (string) $this->command['liste'][0]);
-			} else {
-				$this->command['liste'] = $this->command['liste'][0];
-			}
-		}
-		$this->tableau = $this->command['liste'];
-	}
-
-	/**
-	 * Retourne un tableau donne depuis un critere liste
-	 * Critere {enum Xmin, Xmax}
-	 *
-	 **/
-	protected function select_enum() {
-		# s'il n'y a qu'une valeur dans la liste, sans doute une #BALISE
-		if (!isset($this->command['enum'][1])) {
-			if (!is_array($this->command['enum'][0])) {
-				$this->command['enum'] = explode(',', (string) $this->command['enum'][0]);
-			} else {
-				$this->command['enum'] = $this->command['enum'][0];
-			}
-		}
-		if ((is_countable($this->command['enum']) ? count($this->command['enum']) : 0) >= 3) {
-			$enum = range(
-				array_shift($this->command['enum']),
-				array_shift($this->command['enum']),
-				array_shift($this->command['enum'])
-			);
-		} else {
-			$enum = range(array_shift($this->command['enum']), array_shift($this->command['enum']));
-		}
-		$this->tableau = $enum;
-	}
-
-
-	/**
-	 * extraire le chemin "query.results" du tableau de donnees
-	 * {datapath query.results}
-	 *
-	 **/
-	protected function select_datapath() {
-		$base = reset($this->command['datapath']);
-		if (strlen($base = ltrim(trim((string) $base), '/'))) {
-			$results = table_valeur($this->tableau, $base);
-			if (is_array($results)) {
-				$this->tableau = $results;
-			} else {
-				$this->tableau = [];
-				$this->err = true;
-				spip_logger()->info("datapath '$base' absent");
-			}
-		}
-	}
-
-	/**
-	 * Ordonner les resultats
-	 * {par x}
-	 *
-	 **/
-	protected function select_orderby() {
-		$sortfunc = '';
-		foreach ($this->command['orderby'] as $tri) {
-			// virer le / initial pour les criteres de la forme {par /xx}
-			if (preg_match(',^\.?([/\w:_-]+)( DESC)?$,iS', ltrim((string) $tri, '/'), $r)) {
-				$r = array_pad($r, 3, null);
-
-				// tri par cle
-				if ($r[1] == 'cle') {
-					if (isset($r[2]) && $r[2]) {
-						krsort($this->tableau);
-					} else {
-						ksort($this->tableau);
-					}
-				} # {par hasard}
-				else {
-					if ($r[1] == 'hasard') {
-						$k = array_keys($this->tableau);
-						shuffle($k);
-						$v = [];
-						foreach ($k as $cle) {
-							$v[$cle] = $this->tableau[$cle];
-						}
-						$this->tableau = $v;
-					} else {
-						# {par valeur} ou {par valeur/xx/yy}
-						$tv = $r[1] == 'valeur' ? '%s' : 'table_valeur(%s, ' . var_export($r[1], true) . ')';
-						$sortfunc .= '
+    /** Tableau de données */
+    protected array $tableau = [];
+
+    /**
+     * Conditions de filtrage
+     * ie criteres de selection
+     */
+    protected array $filtre = [];
+
+    /**
+     * Cle courante
+     *
+     * @var scalar
+     */
+    protected $cle = null;
+
+    /**
+     * Valeur courante
+     *
+     * @var mixed
+     */
+    protected $valeur = null;
+
+    /**
+     * Constructeur
+     *
+     * @param  $command
+     * @param array $info
+     */
+    public function __construct(array $command, array $info = []) {
+        include_spip('iterateur/data');
+        $this->type = 'DATA';
+        $this->command = $command;
+        $this->info = $info;
+        $this->select($command);
+    }
+
+    /**
+     * Revenir au depart
+     *
+     * @return void
+     */
+    public function rewind(): void {
+        reset($this->tableau);
+        $this->cle = array_key_first($this->tableau);
+        $this->valeur = current($this->tableau);
+        next($this->tableau);
+    }
+
+    /**
+     * Déclarer les critères exceptions
+     *
+     * @return array
+     */
+    public function exception_des_criteres() {
+        return ['tableau'];
+    }
+
+    /**
+     * Récupérer depuis le cache si possible
+     *
+     * @param string $cle
+     * @return mixed
+     */
+    protected function cache_get($cle) {
+        if (!$cle) {
+            return;
+        }
+        # utiliser memoization si dispo
+        if (!function_exists('cache_get')) {
+            return;
+        }
+
+        return cache_get($cle);
+    }
+
+    /**
+     * Stocker en cache si possible
+     *
+     * @param string $cle
+     * @param int $ttl
+     * @param null|mixed $valeur
+     * @return bool
+     */
+    protected function cache_set($cle, $ttl, $valeur = null) {
+        if (!$cle) {
+            return;
+        }
+        if (is_null($valeur)) {
+            $valeur = $this->tableau;
+        }
+        # utiliser memoization si dispo
+        if (!function_exists('cache_set')) {
+            return;
+        }
+
+        return cache_set(
+            $cle,
+            [
+                'data' => $valeur,
+                'time' => time(),
+                'ttl' => $ttl
+            ],
+            3600 + $ttl
+        );
+        # conserver le cache 1h de plus que la validite demandee,
+        # pour le cas ou le serveur distant ne reponde plus
+    }
+
+    /**
+     * Aller chercher les données de la boucle DATA
+     *
+     * @throws Exception
+     * @param array $command
+     * @return void
+     */
+    protected function select($command) {
+
+        // l'iterateur DATA peut etre appele en passant (data:type)
+        // le type se retrouve dans la commande 'from'
+        // dans ce cas la le critere {source}, si present, n'a pas besoin du 1er argument
+        if (isset($this->command['from'][0])) {
+            if (isset($this->command['source']) && is_array($this->command['source'])) {
+                array_unshift($this->command['source'], $this->command['sourcemode']);
+            }
+            $this->command['sourcemode'] = $this->command['from'][0];
+        }
+
+        // cherchons differents moyens de creer le tableau de donnees
+        // les commandes connues pour l'iterateur DATA
+        // sont : {tableau #ARRAY} ; {cle=...} ; {valeur=...}
+
+        // {source format, [URL], [arg2]...}
+        if (
+            isset($this->command['source'])
+            && isset($this->command['sourcemode'])
+        ) {
+            $this->select_source();
+        }
+
+        // Critere {liste X1, X2, X3}
+        if (isset($this->command['liste'])) {
+            $this->select_liste();
+        }
+        if (isset($this->command['enum'])) {
+            $this->select_enum();
+        }
+
+        // Si a ce stade on n'a pas de table, il y a un bug
+        if (!is_array($this->tableau)) {
+            $this->err = true;
+            spip_logger()->info('erreur datasource ' . var_export($command, true));
+        }
+
+        // {datapath query.results}
+        // extraire le chemin "query.results" du tableau de donnees
+        if (
+            !$this->err
+            && isset($this->command['datapath'])
+            && is_array($this->command['datapath'])
+        ) {
+            $this->select_datapath();
+        }
+
+        // tri {par x}
+        if ($this->command['orderby']) {
+            $this->select_orderby();
+        }
+
+        // grouper les resultats {fusion /x/y/z} ;
+        if ($this->command['groupby']) {
+            $this->select_groupby();
+        }
+
+        $this->rewind();
+        #var_dump($this->tableau);
+    }
+
+
+    /**
+     * Aller chercher les donnees de la boucle DATA
+     * depuis une source
+     * {source format, [URL], [arg2]...}
+     */
+    protected function select_source() {
+        # un peu crado : avant de charger le cache il faut charger
+        # les class indispensables, sinon PHP ne saura pas gerer
+        # l'objet en cache ; cf plugins/icalendar
+        # perf : pas de fonction table_to_array ! (table est deja un array)
+        if (
+            isset($this->command['sourcemode'])
+            && !in_array($this->command['sourcemode'], ['table', 'array', 'tableau'])
+        ) {
+            charger_fonction($this->command['sourcemode'] . '_to_array', 'inc', true);
+        }
+
+        # le premier argument peut etre un array, une URL etc.
+        $src = $this->command['source'][0] ?? null;
+
+        # avons-nous un cache dispo ?
+        $cle = null;
+        if (is_string($src)) {
+            $cle = 'datasource_' . md5($this->command['sourcemode'] . ':' . var_export($this->command['source'], true));
+        }
+
+        $cache = $this->cache_get($cle);
+        if (isset($this->command['datacache'])) {
+            $ttl = (int) $this->command['datacache'];
+        }
+        if (
+            $cache
+            && $cache['time'] + ($ttl ?? $cache['ttl']) > time()
+            && !(_request('var_mode') === 'recalcul' && include_spip('inc/autoriser') && autoriser('recalcul'))
+        ) {
+            $this->tableau = $cache['data'];
+        } else {
+            try {
+                if (
+                    isset($this->command['sourcemode'])
+                    && in_array(
+                        $this->command['sourcemode'],
+                        ['table', 'array', 'tableau']
+                    )
+                ) {
+                    if (
+                        is_array($a = $src)
+                        || is_string($a) && ($a = str_replace('"', '"', $a)) && is_array($a = @unserialize($a))
+                    ) {
+                        $this->tableau = $a;
+                    }
+                } else {
+                    $data = $src;
+                    if (is_string($src)) {
+                        if (tester_url_absolue($src)) {
+                            include_spip('inc/distant');
+                            $data = recuperer_url($src, ['taille_max' => _DATA_SOURCE_MAX_SIZE]);
+                            $data = $data['page'] ?? '';
+                            if (!$data) {
+                                throw new Exception('404');
+                            }
+                            if (!isset($ttl)) {
+                                $ttl = 24 * 3600;
+                            }
+                        } elseif (@is_dir($src)) {
+                            $data = $src;
+                        } elseif (@is_readable($src) && @is_file($src)) {
+                            $data = spip_file_get_contents($src);
+                        }
+                        if (!isset($ttl)) {
+                            $ttl = 10;
+                        }
+                    }
+                    if (
+                        !$this->err
+                        && ($data_to_array = charger_fonction($this->command['sourcemode'] . '_to_array', 'inc', true))
+                    ) {
+                        $args = $this->command['source'];
+                        $args[0] = $data;
+                        if (is_array($a = $data_to_array(...$args))) {
+                            $this->tableau = $a;
+                        }
+                    }
+                }
+
+                if (!is_array($this->tableau)) {
+                    $this->err = true;
+                }
+
+                if (!$this->err && isset($ttl) && $ttl > 0) {
+                    $this->cache_set($cle, $ttl);
+                }
+            } catch (Exception $e) {
+                $e = $e->getMessage();
+                $err = sprintf(
+                    "[%s, %s] $e",
+                    $src,
+                    $this->command['sourcemode']
+                );
+                erreur_squelette([$err, []]);
+                $this->err = true;
+            }
+        }
+
+        # en cas d'erreur, utiliser le cache si encore dispo
+        if ($this->err && $cache) {
+            $this->tableau = $cache['data'];
+            $this->err = false;
+        }
+    }
+
+
+    /**
+     * Retourne un tableau donne depuis un critère liste
+     *
+     * Critère `{liste X1, X2, X3}`
+     *
+     * @see critere_DATA_liste_dist()
+     *
+     **/
+    protected function select_liste() {
+        # s'il n'y a qu'une valeur dans la liste, sans doute une #BALISE
+        if (!isset($this->command['liste'][1])) {
+            if (!is_array($this->command['liste'][0])) {
+                $this->command['liste'] = explode(',', (string) $this->command['liste'][0]);
+            } else {
+                $this->command['liste'] = $this->command['liste'][0];
+            }
+        }
+        $this->tableau = $this->command['liste'];
+    }
+
+    /**
+     * Retourne un tableau donne depuis un critere liste
+     * Critere {enum Xmin, Xmax}
+     *
+     **/
+    protected function select_enum() {
+        # s'il n'y a qu'une valeur dans la liste, sans doute une #BALISE
+        if (!isset($this->command['enum'][1])) {
+            if (!is_array($this->command['enum'][0])) {
+                $this->command['enum'] = explode(',', (string) $this->command['enum'][0]);
+            } else {
+                $this->command['enum'] = $this->command['enum'][0];
+            }
+        }
+        if ((is_countable($this->command['enum']) ? count($this->command['enum']) : 0) >= 3) {
+            $enum = range(
+                array_shift($this->command['enum']),
+                array_shift($this->command['enum']),
+                array_shift($this->command['enum'])
+            );
+        } else {
+            $enum = range(array_shift($this->command['enum']), array_shift($this->command['enum']));
+        }
+        $this->tableau = $enum;
+    }
+
+
+    /**
+     * extraire le chemin "query.results" du tableau de donnees
+     * {datapath query.results}
+     *
+     **/
+    protected function select_datapath() {
+        $base = reset($this->command['datapath']);
+        if (strlen($base = ltrim(trim((string) $base), '/'))) {
+            $results = table_valeur($this->tableau, $base);
+            if (is_array($results)) {
+                $this->tableau = $results;
+            } else {
+                $this->tableau = [];
+                $this->err = true;
+                spip_logger()->info("datapath '$base' absent");
+            }
+        }
+    }
+
+    /**
+     * Ordonner les resultats
+     * {par x}
+     *
+     **/
+    protected function select_orderby() {
+        $sortfunc = '';
+        foreach ($this->command['orderby'] as $tri) {
+            // virer le / initial pour les criteres de la forme {par /xx}
+            if (preg_match(',^\.?([/\w:_-]+)( DESC)?$,iS', ltrim((string) $tri, '/'), $r)) {
+                $r = array_pad($r, 3, null);
+
+                // tri par cle
+                if ($r[1] == 'cle') {
+                    if (isset($r[2]) && $r[2]) {
+                        krsort($this->tableau);
+                    } else {
+                        ksort($this->tableau);
+                    }
+                } # {par hasard}
+                else {
+                    if ($r[1] == 'hasard') {
+                        $k = array_keys($this->tableau);
+                        shuffle($k);
+                        $v = [];
+                        foreach ($k as $cle) {
+                            $v[$cle] = $this->tableau[$cle];
+                        }
+                        $this->tableau = $v;
+                    } else {
+                        # {par valeur} ou {par valeur/xx/yy}
+                        $tv = $r[1] == 'valeur' ? '%s' : 'table_valeur(%s, ' . var_export($r[1], true) . ')';
+                        $sortfunc .= '
 					$a = ' . sprintf($tv, '$aa') . ';
 					$b = ' . sprintf($tv, '$bb') . ';
 					if ($a <> $b)
 						return ($a ' . (empty($r[2]) ? '<' : '>') . ' $b) ? -1 : 1;';
-					}
-				}
-			}
-		}
-
-		if ($sortfunc) {
-			$sortfunc .= "\n return 0;";
-			uasort($this->tableau, fn($aa, $bb) => eval($sortfunc));
-		}
-	}
-
-
-	/**
-	 * Grouper les resultats
-	 * {fusion /x/y/z}
-	 *
-	 **/
-	protected function select_groupby() {
-		// virer le / initial pour les criteres de la forme {fusion /xx}
-		if (strlen($fusion = ltrim((string) $this->command['groupby'][0], '/'))) {
-			$vu = [];
-			foreach ($this->tableau as $k => $v) {
-				$val = table_valeur($v, $fusion);
-				if (isset($vu[$val])) {
-					unset($this->tableau[$k]);
-				} else {
-					$vu[$val] = true;
-				}
-			}
-		}
-	}
-
-
-	/**
-	 * L'iterateur est-il encore valide ?
-	 */
-	public function valid(): bool {
-		return !is_null($this->cle);
-	}
-
-	/**
-	 * Retourner la valeur
-	 */
-	public function current(): mixed {
-		return $this->valeur;
-	}
-
-	/**
-	 * Retourner la cle
-	 */
-	public function key(): mixed {
-		return $this->cle;
-	}
-
-	/**
-	 * Passer a la valeur suivante
-	 */
-	public function next(): void {
-		if ($this->valid()) {
-			$this->cle = key($this->tableau);
-			$this->valeur = current($this->tableau);
-			next($this->tableau);
-		}
-	}
-
-	/**
-	 * Compter le nombre total de resultats
-	 */
-	public function count(): int {
-		if (is_null($this->total)) {
-			$this->total = count($this->tableau);
-		}
-
-		return $this->total;
-	}
+                    }
+                }
+            }
+        }
+
+        if ($sortfunc) {
+            $sortfunc .= "\n return 0;";
+            uasort($this->tableau, fn($aa, $bb) => eval($sortfunc));
+        }
+    }
+
+
+    /**
+     * Grouper les resultats
+     * {fusion /x/y/z}
+     *
+     **/
+    protected function select_groupby() {
+        // virer le / initial pour les criteres de la forme {fusion /xx}
+        if (strlen($fusion = ltrim((string) $this->command['groupby'][0], '/'))) {
+            $vu = [];
+            foreach ($this->tableau as $k => $v) {
+                $val = table_valeur($v, $fusion);
+                if (isset($vu[$val])) {
+                    unset($this->tableau[$k]);
+                } else {
+                    $vu[$val] = true;
+                }
+            }
+        }
+    }
+
+
+    /**
+     * L'iterateur est-il encore valide ?
+     */
+    public function valid(): bool {
+        return !is_null($this->cle);
+    }
+
+    /**
+     * Retourner la valeur
+     */
+    public function current(): mixed {
+        return $this->valeur;
+    }
+
+    /**
+     * Retourner la cle
+     */
+    public function key(): mixed {
+        return $this->cle;
+    }
+
+    /**
+     * Passer a la valeur suivante
+     */
+    public function next(): void {
+        if ($this->valid()) {
+            $this->cle = key($this->tableau);
+            $this->valeur = current($this->tableau);
+            next($this->tableau);
+        }
+    }
+
+    /**
+     * Compter le nombre total de resultats
+     */
+    public function count(): int {
+        if (is_null($this->total)) {
+            $this->total = count($this->tableau);
+        }
+
+        return $this->total;
+    }
 }

Spacing +8 added lines, -8 removed lines

@@ -163,7 +163,7 @@ 
 		// Si a ce stade on n'a pas de table, il y a un bug
 		if (!is_array($this->tableau)) {
 			$this->err = true;
-			spip_logger()->info('erreur datasource ' . var_export($command, true));
+			spip_logger()->info('erreur datasource '.var_export($command, true));
 		}
 
 		// {datapath query.results}
@@ -205,7 +205,7 @@ 
 			isset($this->command['sourcemode'])
 			&& !in_array($this->command['sourcemode'], ['table', 'array', 'tableau'])
 		) {
-			charger_fonction($this->command['sourcemode'] . '_to_array', 'inc', true);
+			charger_fonction($this->command['sourcemode'].'_to_array', 'inc', true);
 		}
 
 		# le premier argument peut etre un array, une URL etc.
@@ -214,7 +214,7 @@ 
 		# avons-nous un cache dispo ?
 		$cle = null;
 		if (is_string($src)) {
-			$cle = 'datasource_' . md5($this->command['sourcemode'] . ':' . var_export($this->command['source'], true));
+			$cle = 'datasource_'.md5($this->command['sourcemode'].':'.var_export($this->command['source'], true));
 		}
 
 		$cache = $this->cache_get($cle);
@@ -266,7 +266,7 @@ 
 					}
 					if (
 						!$this->err
-						&& ($data_to_array = charger_fonction($this->command['sourcemode'] . '_to_array', 'inc', true))
+						&& ($data_to_array = charger_fonction($this->command['sourcemode'].'_to_array', 'inc', true))
 					) {
 						$args = $this->command['source'];
 						$args[0] = $data;
@@ -400,12 +400,12 @@ 
 						$this->tableau = $v;
 					} else {
 						# {par valeur} ou {par valeur/xx/yy}
-						$tv = $r[1] == 'valeur' ? '%s' : 'table_valeur(%s, ' . var_export($r[1], true) . ')';
+						$tv = $r[1] == 'valeur' ? '%s' : 'table_valeur(%s, '.var_export($r[1], true).')';
 						$sortfunc .= '
-					$a = ' . sprintf($tv, '$aa') . ';
-					$b = ' . sprintf($tv, '$bb') . ';
+					$a = ' . sprintf($tv, '$aa').';
+					$b = ' . sprintf($tv, '$bb').';
 					if ($a <> $b)
-						return ($a ' . (empty($r[2]) ? '<' : '>') . ' $b) ? -1 : 1;';
+						return ($a ' . (empty($r[2]) ? '<' : '>').' $b) ? -1 : 1;';
 					}
 				}
 			}