spip / SPIP

ecrire/iterateur/data.php

Indentation +532 added lines, -532 removed lines

@@ -23,16 +23,16 @@ 
  * @return
  */
 function iterateur_DATA_dist($b) {
-	$b->iterateur = 'DATA'; # designe la classe d'iterateur
-	$b->show = array(
-		'field' => array(
-			'cle' => 'STRING',
-			'valeur' => 'STRING',
-			'*' => 'ALL' // Champ joker *
-		)
-	);
-	$b->select[] = '.valeur';
-	return $b;
+    $b->iterateur = 'DATA'; # designe la classe d'iterateur
+    $b->show = array(
+        'field' => array(
+            'cle' => 'STRING',
+            'valeur' => 'STRING',
+            '*' => 'ALL' // Champ joker *
+        )
+    );
+    $b->select[] = '.valeur';
+    return $b;
 }
 
 
@@ -40,453 +40,453 @@ 
  * IterateurDATA pour iterer sur des donnees
  */
 class IterateurDATA implements Iterator {
-	/**
-	 * tableau de donnees
-	 * @var array
-	 */
-	protected $tableau = array();
-
-	/**
-	 * Conditions de filtrage
-	 * ie criteres de selection
-	 * @var array
-	 */
-	protected $filtre = array();
-
-
-	/**
-	 * Cle courante
-	 * @var null
-	 */
-	protected $cle = null;
-
-	/**
-	 * Valeur courante
-	 * @var null
-	 */
-	protected $valeur = null;
-
-	/**
-	 * Erreur presente ? 
-	 *
-	 * @var bool
-	**/
-	public $err = false;
-
-	/**
-	 * Calcul du total des elements 
-	 *
-	 * @var int|null
-	**/
-	public $total = null;
-
-	/**
-	 * Constructeur
-	 *
-	 * @param  $command
-	 * @param array $info
-	 */
-	public function __construct($command, $info=array()) {
-		$this->type='DATA';
-		$this->command = $command;
-		$this->info = $info;
-
-		$this->select($command);
-	}
-
-	/**
-	 * Revenir au depart
-	 * @return void
-	 */
-	public function rewind() {
-		reset($this->tableau);
-		list($this->cle, $this->valeur) = each($this->tableau);
-	}
-
-	/**
-	 * Declarer les criteres exceptions
-	 * @return array
-	 */
-	public function exception_des_criteres() {
-		return array('tableau');
-	}
-
-	/**
-	 * Recuperer depuis le cache si possible
-	 * @param  $cle
-	 * @return
-	 */
-	protected function cache_get($cle) {
-		if (!$cle) return;
-		# utiliser memoization si dispo
-		include_spip('inc/memoization');
-		if (!function_exists('cache_get')) return;
-		return cache_get($cle);
-	}
-
-	/**
-	 * Stocker en cache si possible
-	 * @param  $cle
-	 * @param  $ttl
-	 * @return
-	 */
-	protected function cache_set($cle, $ttl, $valeur = null) {
-		if (!$cle) return;
-		if (is_null($valeur)) {
-			$valeur = $this->tableau;
-		}
-		# utiliser memoization si dispo
-		include_spip('inc/memoization');
-		if (!function_exists('cache_set')) return;
-		return cache_set($cle,
-			array(
-				'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 donnees de la boucle DATA
-	 *
-	 * @throws Exception
-	 * @param  $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']) and 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=...}
+    /**
+     * tableau de donnees
+     * @var array
+     */
+    protected $tableau = array();
+
+    /**
+     * Conditions de filtrage
+     * ie criteres de selection
+     * @var array
+     */
+    protected $filtre = array();
+
+
+    /**
+     * Cle courante
+     * @var null
+     */
+    protected $cle = null;
+
+    /**
+     * Valeur courante
+     * @var null
+     */
+    protected $valeur = null;
+
+    /**
+     * Erreur presente ? 
+     *
+     * @var bool
+     **/
+    public $err = false;
+
+    /**
+     * Calcul du total des elements 
+     *
+     * @var int|null
+     **/
+    public $total = null;
+
+    /**
+     * Constructeur
+     *
+     * @param  $command
+     * @param array $info
+     */
+    public function __construct($command, $info=array()) {
+        $this->type='DATA';
+        $this->command = $command;
+        $this->info = $info;
+
+        $this->select($command);
+    }
+
+    /**
+     * Revenir au depart
+     * @return void
+     */
+    public function rewind() {
+        reset($this->tableau);
+        list($this->cle, $this->valeur) = each($this->tableau);
+    }
+
+    /**
+     * Declarer les criteres exceptions
+     * @return array
+     */
+    public function exception_des_criteres() {
+        return array('tableau');
+    }
+
+    /**
+     * Recuperer depuis le cache si possible
+     * @param  $cle
+     * @return
+     */
+    protected function cache_get($cle) {
+        if (!$cle) return;
+        # utiliser memoization si dispo
+        include_spip('inc/memoization');
+        if (!function_exists('cache_get')) return;
+        return cache_get($cle);
+    }
+
+    /**
+     * Stocker en cache si possible
+     * @param  $cle
+     * @param  $ttl
+     * @return
+     */
+    protected function cache_set($cle, $ttl, $valeur = null) {
+        if (!$cle) return;
+        if (is_null($valeur)) {
+            $valeur = $this->tableau;
+        }
+        # utiliser memoization si dispo
+        include_spip('inc/memoization');
+        if (!function_exists('cache_set')) return;
+        return cache_set($cle,
+            array(
+                '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 donnees de la boucle DATA
+     *
+     * @throws Exception
+     * @param  $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']) and 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'])
-		AND 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_log("erreur datasource ".var_export($command,true));
-		}
-
-		// {datapath query.results}
-		// extraire le chemin "query.results" du tableau de donnees
-		if (!$this->err
-		AND isset($this->command['datapath'])
-		AND 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'])
-		  AND !in_array($this->command['sourcemode'],array('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];
-
-		# 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 = intval($this->command['datacache']);
-		if ($cache
-		AND ($cache['time'] + (isset($ttl) ? $ttl : $cache['ttl'])
-			> time())
-		AND !(_request('var_mode') === 'recalcul'
-			AND include_spip('inc/autoriser')
-			AND autoriser('recalcul')
-		)) {
-			$this->tableau = $cache['data'];
-		}
-		else try {
-			# dommage que ca ne soit pas une option de yql_to_array...
-			if ($this->command['sourcemode'] == 'yql')
-				if (!isset($ttl)) $ttl = 3600;
-
-			if (isset($this->command['sourcemode'])
-			AND in_array($this->command['sourcemode'],
-				array('table', 'array', 'tableau'))
-			) {
-				if (is_array($a = $src)
-				OR (is_string($a)
-				AND $a = str_replace('"', '"', $a) # fragile!
-				AND is_array($a = @unserialize($a)))
-				)
-					$this->tableau = $a;
-			}
-			else {
-				if (preg_match(',^https?://,', $src)) {
-					include_spip('inc/distant');
-					$u = recuperer_page($src, false, false, _DATA_SOURCE_MAX_SIZE);
-					if (!$u)
-						throw new Exception("404");
-					if (!isset($ttl)) $ttl = 24*3600;
-				} else if (@is_dir($src)) {
-					$u = $src;
-					if (!isset($ttl)) $ttl = 10;
-				} else if (@is_readable($src) && @is_file($src)) {
-					$u = spip_file_get_contents($src);
-					if (!isset($ttl)) $ttl = 10;
-				} else {
-					$u = $src;
-					if (!isset($ttl)) $ttl = 10;
-				}
-				if (!$this->err
-				AND $g = charger_fonction($this->command['sourcemode'] . '_to_array', 'inc', true)) {
-					$args = $this->command['source'];
-					$args[0] = $u;
-					if (is_array($a = call_user_func_array($g,$args))) {
-						$this->tableau = $a;
-					}
-				}
-			}
-
-			if (!is_array($this->tableau))
-				$this->err = true;
-
-			if (!$this->err AND isset($ttl) and $ttl>0)
-				$this->cache_set($cle, $ttl);
-
-		}
-		catch (Exception $e) {
-			$e = $e->getMessage();
-			$err = sprintf("[%s, %s] $e",
-				$src,
-				$this->command['sourcemode']);
-			erreur_squelette(array($err, array()));
-			$this->err = true;
-		}
-
-		# en cas d'erreur, utiliser le cache si encore dispo
-		if ($this->err
-		AND $cache) {
-			$this->tableau = $cache['data'];
-			$this->err = false;
-		}
-	}
-
-
-	/**
-	 * Retourne un tableau donne depuis un critere liste
-	 * Critere {liste X1, X2, X3}
-	 * 
-	**/
-	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(',', $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(',', $this->command['enum'][0]);
-			} else {
-				$this->command['enum'] = $this->command['enum'][0];
-			}
-		}
-		if (count($this->command['enum'])>=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() {
-		list(,$base) = each($this->command['datapath']);
-		if (strlen($base = ltrim(trim($base),"/"))) {
-			$this->tableau = table_valeur($this->tableau, $base);
-			if (!is_array($this->tableau)) {
-				$this->tableau = array();
-				$this->err = true;
-				spip_log("datapath '$base' absent");
-			}
-		}
-	}
-
-	/**
-	 * Ordonner les resultats
-	 * {par x}
-	 * 
-	**/
-	protected function select_orderby() {
-		$sortfunc = '';
-		$aleas = 0;
-		foreach($this->command['orderby'] as $tri) {
-			// virer le / initial pour les criteres de la forme {par /xx}
-			if (preg_match(',^\.?([/\w]+)( DESC)?$,iS', ltrim($tri, '/'), $r)) {
-				// tri par cle
-				if ($r[1] == 'cle'){
-					if (isset($r[2]) and $r[2])
-						krsort($this->tableau);
-					else
-						ksort($this->tableau);
-				}
-				# {par hasard}
-				else if ($r[1] == 'alea') {
-					$k = array_keys($this->tableau);
-					shuffle($k);
-					$v = array();
-					foreach($k as $cle)
-						$v[$cle] = $this->tableau[$cle];
-					$this->tableau = $v;
-				}
-				else {
-					# {par valeur}
-					if ($r[1] == 'valeur')
-						$tv = '%s';
-					# {par valeur/xx/yy} ??
-					else
-						$tv = 'table_valeur(%s, '.var_export($r[1],true).')';
-					$sortfunc .= '
+        // {source format, [URL], [arg2]...}
+        if (isset($this->command['source'])
+        AND 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_log("erreur datasource ".var_export($command,true));
+        }
+
+        // {datapath query.results}
+        // extraire le chemin "query.results" du tableau de donnees
+        if (!$this->err
+        AND isset($this->command['datapath'])
+        AND 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'])
+          AND !in_array($this->command['sourcemode'],array('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];
+
+        # 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 = intval($this->command['datacache']);
+        if ($cache
+        AND ($cache['time'] + (isset($ttl) ? $ttl : $cache['ttl'])
+            > time())
+        AND !(_request('var_mode') === 'recalcul'
+            AND include_spip('inc/autoriser')
+            AND autoriser('recalcul')
+        )) {
+            $this->tableau = $cache['data'];
+        }
+        else try {
+            # dommage que ca ne soit pas une option de yql_to_array...
+            if ($this->command['sourcemode'] == 'yql')
+                if (!isset($ttl)) $ttl = 3600;
+
+            if (isset($this->command['sourcemode'])
+            AND in_array($this->command['sourcemode'],
+                array('table', 'array', 'tableau'))
+            ) {
+                if (is_array($a = $src)
+                OR (is_string($a)
+                AND $a = str_replace('"', '"', $a) # fragile!
+                AND is_array($a = @unserialize($a)))
+                )
+                    $this->tableau = $a;
+            }
+            else {
+                if (preg_match(',^https?://,', $src)) {
+                    include_spip('inc/distant');
+                    $u = recuperer_page($src, false, false, _DATA_SOURCE_MAX_SIZE);
+                    if (!$u)
+                        throw new Exception("404");
+                    if (!isset($ttl)) $ttl = 24*3600;
+                } else if (@is_dir($src)) {
+                    $u = $src;
+                    if (!isset($ttl)) $ttl = 10;
+                } else if (@is_readable($src) && @is_file($src)) {
+                    $u = spip_file_get_contents($src);
+                    if (!isset($ttl)) $ttl = 10;
+                } else {
+                    $u = $src;
+                    if (!isset($ttl)) $ttl = 10;
+                }
+                if (!$this->err
+                AND $g = charger_fonction($this->command['sourcemode'] . '_to_array', 'inc', true)) {
+                    $args = $this->command['source'];
+                    $args[0] = $u;
+                    if (is_array($a = call_user_func_array($g,$args))) {
+                        $this->tableau = $a;
+                    }
+                }
+            }
+
+            if (!is_array($this->tableau))
+                $this->err = true;
+
+            if (!$this->err AND isset($ttl) and $ttl>0)
+                $this->cache_set($cle, $ttl);
+
+        }
+        catch (Exception $e) {
+            $e = $e->getMessage();
+            $err = sprintf("[%s, %s] $e",
+                $src,
+                $this->command['sourcemode']);
+            erreur_squelette(array($err, array()));
+            $this->err = true;
+        }
+
+        # en cas d'erreur, utiliser le cache si encore dispo
+        if ($this->err
+        AND $cache) {
+            $this->tableau = $cache['data'];
+            $this->err = false;
+        }
+    }
+
+
+    /**
+     * Retourne un tableau donne depuis un critere liste
+     * Critere {liste X1, X2, X3}
+     * 
+     **/
+    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(',', $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(',', $this->command['enum'][0]);
+            } else {
+                $this->command['enum'] = $this->command['enum'][0];
+            }
+        }
+        if (count($this->command['enum'])>=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() {
+        list(,$base) = each($this->command['datapath']);
+        if (strlen($base = ltrim(trim($base),"/"))) {
+            $this->tableau = table_valeur($this->tableau, $base);
+            if (!is_array($this->tableau)) {
+                $this->tableau = array();
+                $this->err = true;
+                spip_log("datapath '$base' absent");
+            }
+        }
+    }
+
+    /**
+     * Ordonner les resultats
+     * {par x}
+     * 
+     **/
+    protected function select_orderby() {
+        $sortfunc = '';
+        $aleas = 0;
+        foreach($this->command['orderby'] as $tri) {
+            // virer le / initial pour les criteres de la forme {par /xx}
+            if (preg_match(',^\.?([/\w]+)( DESC)?$,iS', ltrim($tri, '/'), $r)) {
+                // tri par cle
+                if ($r[1] == 'cle'){
+                    if (isset($r[2]) and $r[2])
+                        krsort($this->tableau);
+                    else
+                        ksort($this->tableau);
+                }
+                # {par hasard}
+                else if ($r[1] == 'alea') {
+                    $k = array_keys($this->tableau);
+                    shuffle($k);
+                    $v = array();
+                    foreach($k as $cle)
+                        $v[$cle] = $this->tableau[$cle];
+                    $this->tableau = $v;
+                }
+                else {
+                    # {par valeur}
+                    if ($r[1] == 'valeur')
+                        $tv = '%s';
+                    # {par valeur/xx/yy} ??
+                    else
+                        $tv = 'table_valeur(%s, '.var_export($r[1],true).')';
+                    $sortfunc .= '
 					$a = '.sprintf($tv,'$aa').';
 					$b = '.sprintf($tv,'$bb').';
 					if ($a <> $b)
 						return ($a ' . ((isset($r[2]) and $r[2]) ? '>' : '<').' $b) ? -1 : 1;';
-				}
-			}
-		}
+                }
+            }
+        }
 
-		if ($sortfunc) {
-			uasort($this->tableau, create_function('$aa,$bb',
-				$sortfunc.'
+        if ($sortfunc) {
+            uasort($this->tableau, create_function('$aa,$bb',
+                $sortfunc.'
 				return 0;'
-			));
-		}
-	}
-
-
-	/**
-	 * 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($this->command['groupby'][0], '/'))) {
-			$vu = array();
-			foreach($this->tableau as $k => $v) {
-				$val = table_valeur($v, $fusion);
-				if (isset($vu[$val]))
-					unset($this->tableau[$k]);
-				else
-					$vu[$val] = true;
-			}
-		}
-	}
+            ));
+        }
+    }
+
+
+    /**
+     * 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($this->command['groupby'][0], '/'))) {
+            $vu = array();
+            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 ?
-	 * @return bool
-	 */
-	public function valid(){
-		return !is_null($this->cle);
-	}
-
-	/**
-	 * Retourner la valeur
-	 * @return null
-	 */
-	public function current() {
-		return $this->valeur;
-	}
-
-	/**
-	 * Retourner la cle
-	 * @return null
-	 */
-	public function key() {
-		return $this->cle;
-	}
-
-	/**
-	 * Passer a la valeur suivante
-	 * @return void
-	 */
-	public function next(){
-		if ($this->valid())
-			list($this->cle, $this->valeur) = each($this->tableau);
-	}
-
-	/**
-	 * Compter le nombre total de resultats
-	 * @return int
-	 */
-	public function count() {
-		if (is_null($this->total))
-			$this->total = count($this->tableau);
-	  return $this->total;
-	}
+    /**
+     * L'iterateur est-il encore valide ?
+     * @return bool
+     */
+    public function valid(){
+        return !is_null($this->cle);
+    }
+
+    /**
+     * Retourner la valeur
+     * @return null
+     */
+    public function current() {
+        return $this->valeur;
+    }
+
+    /**
+     * Retourner la cle
+     * @return null
+     */
+    public function key() {
+        return $this->cle;
+    }
+
+    /**
+     * Passer a la valeur suivante
+     * @return void
+     */
+    public function next(){
+        if ($this->valid())
+            list($this->cle, $this->valeur) = each($this->tableau);
+    }
+
+    /**
+     * Compter le nombre total de resultats
+     * @return int
+     */
+    public function count() {
+        if (is_null($this->total))
+            $this->total = count($this->tableau);
+        return $this->total;
+    }
 }
 
 /*
@@ -500,7 +500,7 @@ 
  * @return array
  */
 function inc_file_to_array_dist($u) {
-	return preg_split('/\r?\n/', $u);
+    return preg_split('/\r?\n/', $u);
 }
 
 /**
@@ -508,8 +508,8 @@ 
  * @return unknown
  */
 function inc_plugins_to_array_dist() {
-	include_spip('inc/plugin');
-	return liste_chemin_plugin_actifs();
+    include_spip('inc/plugin');
+    return liste_chemin_plugin_actifs();
 }
 
 /**
@@ -518,7 +518,7 @@ 
  * @return array
  */
 function inc_xml_to_array_dist($u) {
-	return @XMLObjectToArray(new SimpleXmlIterator($u));
+    return @XMLObjectToArray(new SimpleXmlIterator($u));
 }
 
 /**
@@ -546,14 +546,14 @@ 
  * @return array|bool
  */
 function inc_yql_to_array_dist($u) {
-	define('_YQL_ENDPOINT', 'http://query.yahooapis.com/v1/public/yql?&env=store%3A%2F%2Fdatatables.org%2Falltableswithkeys&q=');
-	$v = recuperer_page($url = _YQL_ENDPOINT.urlencode($u).'&format=json');
-	$w = json_decode($v);
-	if (!$w) {
-		throw new Exception('YQL: r&#233;ponse vide ou mal form&#233;e');
-		return false;
-	}
-	return inc_object_to_array($w);
+    define('_YQL_ENDPOINT', 'http://query.yahooapis.com/v1/public/yql?&env=store%3A%2F%2Fdatatables.org%2Falltableswithkeys&q=');
+    $v = recuperer_page($url = _YQL_ENDPOINT.urlencode($u).'&format=json');
+    $w = json_decode($v);
+    if (!$w) {
+        throw new Exception('YQL: r&#233;ponse vide ou mal form&#233;e');
+        return false;
+    }
+    return inc_object_to_array($w);
 }
 
 /**
@@ -562,17 +562,17 @@ 
  * @return array|bool
  */
 function inc_sql_to_array_dist($u) {
-	# sortir le connecteur de $u
-	preg_match(',^(?:(\w+):)?(.*)$,S', $u, $v);
-	$serveur = (string) $v[1];
-	$req = trim($v[2]);
-	if ($s = sql_query($req, $serveur)) {
-		$r = array();
-		while ($t = sql_fetch($s))
-			$r[] = $t;
-		return $r;
-	}
-	return false;
+    # sortir le connecteur de $u
+    preg_match(',^(?:(\w+):)?(.*)$,S', $u, $v);
+    $serveur = (string) $v[1];
+    $req = trim($v[2]);
+    if ($s = sql_query($req, $serveur)) {
+        $r = array();
+        while ($t = sql_fetch($s))
+            $r[] = $t;
+        return $r;
+    }
+    return false;
 }
 
 /**
@@ -581,9 +581,9 @@ 
  * @return array|bool
  */
 function inc_json_to_array_dist($u) {
-	if (is_array($json = json_decode($u))
-	OR is_object($json))
-		return (array) $json;
+    if (is_array($json = json_decode($u))
+    OR is_object($json))
+        return (array) $json;
 }
 
 /**
@@ -592,17 +592,17 @@ 
  * @return array|bool
  */
 function inc_csv_to_array_dist($u) {
-	include_spip('inc/csv');
-	list($entete,$csv) = analyse_csv($u);
-	array_unshift($csv,$entete);
-
-	include_spip('inc/charsets');
-	foreach ($entete as $k => $v) {
-		$v = strtolower(preg_replace(',\W+,', '_', translitteration($v)));
-		foreach ($csv as &$item)
-			$item[$v] = &$item[$k];
-	}
-	return $csv;
+    include_spip('inc/csv');
+    list($entete,$csv) = analyse_csv($u);
+    array_unshift($csv,$entete);
+
+    include_spip('inc/charsets');
+    foreach ($entete as $k => $v) {
+        $v = strtolower(preg_replace(',\W+,', '_', translitteration($v)));
+        foreach ($csv as &$item)
+            $item[$v] = &$item[$k];
+    }
+    return $csv;
 }
 
 /**
@@ -611,10 +611,10 @@ 
  * @return array|bool
  */
 function inc_rss_to_array_dist($u) {
-	include_spip('inc/syndic');
-	if (is_array($rss = analyser_backend($u)))
-		$tableau = $rss;
-	return $tableau;
+    include_spip('inc/syndic');
+    if (is_array($rss = analyser_backend($u)))
+        $tableau = $rss;
+    return $tableau;
 }
 
 /**
@@ -623,8 +623,8 @@ 
  * @return array|bool
  */
 function inc_atom_to_array_dist($u) {
-	$g = charger_fonction('rss_to_array', 'inc');
-	return $g($u);
+    $g = charger_fonction('rss_to_array', 'inc');
+    return $g($u);
 }
 
 /**
@@ -634,9 +634,9 @@ 
  * @return array|bool
  */
 function inc_glob_to_array_dist($u) {
-	return (array) glob($u,
-		GLOB_MARK | GLOB_NOSORT | GLOB_BRACE
-	);
+    return (array) glob($u,
+        GLOB_MARK | GLOB_NOSORT | GLOB_BRACE
+    );
 }
 
 /**
@@ -646,13 +646,13 @@ 
  * @throws Exception
  */
 function inc_yaml_to_array_dist($u){
-	include_spip('inc/yaml-mini');
-	if (!function_exists("yaml_decode")){
-		throw new Exception('YAML: impossible de trouver la fonction yaml_decode');
-		return false;
-	}
+    include_spip('inc/yaml-mini');
+    if (!function_exists("yaml_decode")){
+        throw new Exception('YAML: impossible de trouver la fonction yaml_decode');
+        return false;
+    }
 
-	return yaml_decode($u);
+    return yaml_decode($u);
 }
 
 
@@ -666,7 +666,7 @@ 
  * @return array|bool
  */
 function inc_pregfiles_to_array_dist($dir, $regexp=-1, $limit=10000) {
-	return (array) preg_files($dir, $regexp, $limit);
+    return (array) preg_files($dir, $regexp, $limit);
 }
 
 /**
@@ -677,19 +677,19 @@ 
  * @return array|bool
  */
 function inc_ls_to_array_dist($u) {
-	$glob = charger_fonction('glob_to_array', 'inc');
-	$a = $glob($u);
-	foreach ($a as &$v) {
-		$b = (array) @stat($v);
-		foreach ($b as $k => $ignore)
-			if (is_numeric($k)) unset($b[$k]);
-		$b['file'] = preg_replace('`/$`','',$v) ;
-		$v = array_merge(
-			pathinfo($v),
-			$b
-		);
-	}
-	return $a;
+    $glob = charger_fonction('glob_to_array', 'inc');
+    $a = $glob($u);
+    foreach ($a as &$v) {
+        $b = (array) @stat($v);
+        foreach ($b as $k => $ignore)
+            if (is_numeric($k)) unset($b[$k]);
+        $b['file'] = preg_replace('`/$`','',$v) ;
+        $v = array_merge(
+            pathinfo($v),
+            $b
+        );
+    }
+    return $a;
 }
 
 /**
@@ -698,23 +698,23 @@ 
  * @return array|bool
  */
 function XMLObjectToArray($object){
-	$xml_array = array();
-	for( $object->rewind(); $object->valid(); $object->next() ) {
-		if(array_key_exists($key = $object->key(), $xml_array)){
-			$key .= '-'.uniqid();
-		}
-		$vars = get_object_vars($object->current());
-		if (isset($vars['@attributes']))
-			foreach($vars['@attributes'] as $k => $v)
-			$xml_array[$key][$k] = $v;
-		if($object->hasChildren()){
-			$xml_array[$key][] = XMLObjectToArray(
-				$object->current());
-		}
-		else{
-			$xml_array[$key][] = strval($object->current());
-		}
-	}
-	return $xml_array;
+    $xml_array = array();
+    for( $object->rewind(); $object->valid(); $object->next() ) {
+        if(array_key_exists($key = $object->key(), $xml_array)){
+            $key .= '-'.uniqid();
+        }
+        $vars = get_object_vars($object->current());
+        if (isset($vars['@attributes']))
+            foreach($vars['@attributes'] as $k => $v)
+            $xml_array[$key][$k] = $v;
+        if($object->hasChildren()){
+            $xml_array[$key][] = XMLObjectToArray(
+                $object->current());
+        }
+        else{
+            $xml_array[$key][] = strval($object->current());
+        }
+    }
+    return $xml_array;
 }
 ?>

Spacing +41 added lines, -41 removed lines

@@ -12,7 +12,7 @@ 
 
 if (!defined('_ECRIRE_INC_VERSION')) return;
 
-if (!defined('_DATA_SOURCE_MAX_SIZE')) define('_DATA_SOURCE_MAX_SIZE',2*1048576);
+if (!defined('_DATA_SOURCE_MAX_SIZE')) define('_DATA_SOURCE_MAX_SIZE', 2 * 1048576);
 
 
 /**
@@ -86,8 +86,8 @@ 
 	 * @param  $command
 	 * @param array $info
 	 */
-	public function __construct($command, $info=array()) {
-		$this->type='DATA';
+	public function __construct($command, $info = array()) {
+		$this->type = 'DATA';
 		$this->command = $command;
 		$this->info = $info;
 
@@ -189,7 +189,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_log("erreur datasource ".var_export($command,true));
+			spip_log("erreur datasource ".var_export($command, true));
 		}
 
 		// {datapath query.results}
@@ -226,8 +226,8 @@ 
 		# l'objet en cache ; cf plugins/icalendar
 		# perf : pas de fonction table_to_array ! (table est deja un array)
 		if (isset($this->command['sourcemode'])
-		  AND !in_array($this->command['sourcemode'],array('table', 'array', 'tableau')))
-			charger_fonction($this->command['sourcemode'] . '_to_array', 'inc', true);
+		  AND !in_array($this->command['sourcemode'], array('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];
@@ -235,7 +235,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);
 		if (isset($this->command['datacache']))
@@ -271,7 +271,7 @@ 
 					$u = recuperer_page($src, false, false, _DATA_SOURCE_MAX_SIZE);
 					if (!$u)
 						throw new Exception("404");
-					if (!isset($ttl)) $ttl = 24*3600;
+					if (!isset($ttl)) $ttl = 24 * 3600;
 				} else if (@is_dir($src)) {
 					$u = $src;
 					if (!isset($ttl)) $ttl = 10;
@@ -283,10 +283,10 @@ 
 					if (!isset($ttl)) $ttl = 10;
 				}
 				if (!$this->err
-				AND $g = charger_fonction($this->command['sourcemode'] . '_to_array', 'inc', true)) {
+				AND $g = charger_fonction($this->command['sourcemode'].'_to_array', 'inc', true)) {
 					$args = $this->command['source'];
 					$args[0] = $u;
-					if (is_array($a = call_user_func_array($g,$args))) {
+					if (is_array($a = call_user_func_array($g, $args))) {
 						$this->tableau = $a;
 					}
 				}
@@ -295,7 +295,7 @@ 
 			if (!is_array($this->tableau))
 				$this->err = true;
 
-			if (!$this->err AND isset($ttl) and $ttl>0)
+			if (!$this->err AND isset($ttl) and $ttl > 0)
 				$this->cache_set($cle, $ttl);
 
 		}
@@ -348,10 +348,10 @@ 
 				$this->command['enum'] = $this->command['enum'][0];
 			}
 		}
-		if (count($this->command['enum'])>=3)
-			$enum = range(array_shift($this->command['enum']),array_shift($this->command['enum']),array_shift($this->command['enum']));
+		if (count($this->command['enum']) >= 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']));
+			$enum = range(array_shift($this->command['enum']), array_shift($this->command['enum']));
 		$this->tableau = $enum;
 	}
 
@@ -363,7 +363,7 @@ 
 	**/
 	protected function select_datapath() {
 		list(,$base) = each($this->command['datapath']);
-		if (strlen($base = ltrim(trim($base),"/"))) {
+		if (strlen($base = ltrim(trim($base), "/"))) {
 			$this->tableau = table_valeur($this->tableau, $base);
 			if (!is_array($this->tableau)) {
 				$this->tableau = array();
@@ -381,11 +381,11 @@ 
 	protected function select_orderby() {
 		$sortfunc = '';
 		$aleas = 0;
-		foreach($this->command['orderby'] as $tri) {
+		foreach ($this->command['orderby'] as $tri) {
 			// virer le / initial pour les criteres de la forme {par /xx}
 			if (preg_match(',^\.?([/\w]+)( DESC)?$,iS', ltrim($tri, '/'), $r)) {
 				// tri par cle
-				if ($r[1] == 'cle'){
+				if ($r[1] == 'cle') {
 					if (isset($r[2]) and $r[2])
 						krsort($this->tableau);
 					else
@@ -396,7 +396,7 @@ 
 					$k = array_keys($this->tableau);
 					shuffle($k);
 					$v = array();
-					foreach($k as $cle)
+					foreach ($k as $cle)
 						$v[$cle] = $this->tableau[$cle];
 					$this->tableau = $v;
 				}
@@ -406,10 +406,10 @@ 
 						$tv = '%s';
 					# {par valeur/xx/yy} ??
 					else
-						$tv = 'table_valeur(%s, '.var_export($r[1],true).')';
+						$tv = '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 ' . ((isset($r[2]) and $r[2]) ? '>' : '<').' $b) ? -1 : 1;';
 				}
@@ -434,7 +434,7 @@ 
 		// virer le / initial pour les criteres de la forme {fusion /xx}
 		if (strlen($fusion = ltrim($this->command['groupby'][0], '/'))) {
 			$vu = array();
-			foreach($this->tableau as $k => $v) {
+			foreach ($this->tableau as $k => $v) {
 				$val = table_valeur($v, $fusion);
 				if (isset($vu[$val]))
 					unset($this->tableau[$k]);
@@ -449,7 +449,7 @@ 
 	 * L'iterateur est-il encore valide ?
 	 * @return bool
 	 */
-	public function valid(){
+	public function valid() {
 		return !is_null($this->cle);
 	}
 
@@ -473,7 +473,7 @@ 
 	 * Passer a la valeur suivante
 	 * @return void
 	 */
-	public function next(){
+	public function next() {
 		if ($this->valid())
 			list($this->cle, $this->valeur) = each($this->tableau);
 	}
@@ -529,14 +529,14 @@ 
  * @return   array
  *
  */
-function inc_object_to_array( $object ) {
-    if( !is_object( $object ) && !is_array( $object ) ) {
+function inc_object_to_array($object) {
+    if (!is_object($object) && !is_array($object)) {
         return $object;
     }
-    if( is_object( $object ) ) {
-        $object = get_object_vars( $object );
+    if (is_object($object)) {
+        $object = get_object_vars($object);
     }
-    return array_map( 'inc_object_to_array', $object );
+    return array_map('inc_object_to_array', $object);
 }
 
 /**
@@ -593,8 +593,8 @@ 
  */
 function inc_csv_to_array_dist($u) {
 	include_spip('inc/csv');
-	list($entete,$csv) = analyse_csv($u);
-	array_unshift($csv,$entete);
+	list($entete, $csv) = analyse_csv($u);
+	array_unshift($csv, $entete);
 
 	include_spip('inc/charsets');
 	foreach ($entete as $k => $v) {
@@ -645,9 +645,9 @@ 
  * @return bool|array
  * @throws Exception
  */
-function inc_yaml_to_array_dist($u){
+function inc_yaml_to_array_dist($u) {
 	include_spip('inc/yaml-mini');
-	if (!function_exists("yaml_decode")){
+	if (!function_exists("yaml_decode")) {
 		throw new Exception('YAML: impossible de trouver la fonction yaml_decode');
 		return false;
 	}
@@ -665,7 +665,7 @@ 
  * @param int $limit
  * @return array|bool
  */
-function inc_pregfiles_to_array_dist($dir, $regexp=-1, $limit=10000) {
+function inc_pregfiles_to_array_dist($dir, $regexp = -1, $limit = 10000) {
 	return (array) preg_files($dir, $regexp, $limit);
 }
 
@@ -683,7 +683,7 @@ 
 		$b = (array) @stat($v);
 		foreach ($b as $k => $ignore)
 			if (is_numeric($k)) unset($b[$k]);
-		$b['file'] = preg_replace('`/$`','',$v) ;
+		$b['file'] = preg_replace('`/$`', '', $v);
 		$v = array_merge(
 			pathinfo($v),
 			$b
@@ -697,21 +697,21 @@ 
  * @param Object $object
  * @return array|bool
  */
-function XMLObjectToArray($object){
+function XMLObjectToArray($object) {
 	$xml_array = array();
-	for( $object->rewind(); $object->valid(); $object->next() ) {
-		if(array_key_exists($key = $object->key(), $xml_array)){
+	for ($object->rewind(); $object->valid(); $object->next()) {
+		if (array_key_exists($key = $object->key(), $xml_array)) {
 			$key .= '-'.uniqid();
 		}
 		$vars = get_object_vars($object->current());
 		if (isset($vars['@attributes']))
-			foreach($vars['@attributes'] as $k => $v)
+			foreach ($vars['@attributes'] as $k => $v)
 			$xml_array[$key][$k] = $v;
-		if($object->hasChildren()){
+		if ($object->hasChildren()) {
 			$xml_array[$key][] = XMLObjectToArray(
 				$object->current());
 		}
-		else{
+		else {
 			$xml_array[$key][] = strval($object->current());
 		}
 	}

Braces +107 added lines, -69 removed lines

@@ -10,9 +10,13 @@ 
  *  Pour plus de details voir le fichier COPYING.txt ou l'aide en ligne.   *
 \***************************************************************************/
 
-if (!defined('_ECRIRE_INC_VERSION')) return;
+if (!defined('_ECRIRE_INC_VERSION')) {
+    return;
+}
 
-if (!defined('_DATA_SOURCE_MAX_SIZE')) define('_DATA_SOURCE_MAX_SIZE',2*1048576);
+if (!defined('_DATA_SOURCE_MAX_SIZE')) {
+    define('_DATA_SOURCE_MAX_SIZE',2*1048576);
+}
 
 
 /**
@@ -117,10 +121,14 @@ 
 	 * @return
 	 */
 	protected function cache_get($cle) {
-		if (!$cle) return;
+		if (!$cle) {
+		    return;
+		}
 		# utiliser memoization si dispo
 		include_spip('inc/memoization');
-		if (!function_exists('cache_get')) return;
+		if (!function_exists('cache_get')) {
+		    return;
+		}
 		return cache_get($cle);
 	}
 
@@ -131,13 +139,17 @@ 
 	 * @return
 	 */
 	protected function cache_set($cle, $ttl, $valeur = null) {
-		if (!$cle) return;
+		if (!$cle) {
+		    return;
+		}
 		if (is_null($valeur)) {
 			$valeur = $this->tableau;
 		}
 		# utiliser memoization si dispo
 		include_spip('inc/memoization');
-		if (!function_exists('cache_set')) return;
+		if (!function_exists('cache_set')) {
+		    return;
+		}
 		return cache_set($cle,
 			array(
 				'data' => $valeur,
@@ -226,20 +238,23 @@ 
 		# l'objet en cache ; cf plugins/icalendar
 		# perf : pas de fonction table_to_array ! (table est deja un array)
 		if (isset($this->command['sourcemode'])
-		  AND !in_array($this->command['sourcemode'],array('table', 'array', 'tableau')))
-			charger_fonction($this->command['sourcemode'] . '_to_array', 'inc', true);
+		  AND !in_array($this->command['sourcemode'],array('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];
 
 		# avons-nous un cache dispo ?
 		$cle = null;
-		if (is_string($src))
-			$cle = 'datasource_'.md5($this->command['sourcemode'].':'.var_export($this->command['source'],true));
+		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 = intval($this->command['datacache']);
+		if (isset($this->command['datacache'])) {
+					$ttl = intval($this->command['datacache']);
+		}
 		if ($cache
 		AND ($cache['time'] + (isset($ttl) ? $ttl : $cache['ttl'])
 			> time())
@@ -248,11 +263,12 @@ 
 			AND autoriser('recalcul')
 		)) {
 			$this->tableau = $cache['data'];
-		}
-		else try {
+		} else {
+		    try {
 			# dommage que ca ne soit pas une option de yql_to_array...
 			if ($this->command['sourcemode'] == 'yql')
 				if (!isset($ttl)) $ttl = 3600;
+		}
 
 			if (isset($this->command['sourcemode'])
 			AND in_array($this->command['sourcemode'],
@@ -262,25 +278,34 @@ 
 				OR (is_string($a)
 				AND $a = str_replace('"', '"', $a) # fragile!
 				AND is_array($a = @unserialize($a)))
-				)
-					$this->tableau = $a;
-			}
-			else {
+				) {
+									$this->tableau = $a;
+				}
+			} else {
 				if (preg_match(',^https?://,', $src)) {
 					include_spip('inc/distant');
 					$u = recuperer_page($src, false, false, _DATA_SOURCE_MAX_SIZE);
-					if (!$u)
-						throw new Exception("404");
-					if (!isset($ttl)) $ttl = 24*3600;
+					if (!$u) {
+											throw new Exception("404");
+					}
+					if (!isset($ttl)) {
+					    $ttl = 24*3600;
+					}
 				} else if (@is_dir($src)) {
 					$u = $src;
-					if (!isset($ttl)) $ttl = 10;
+					if (!isset($ttl)) {
+					    $ttl = 10;
+					}
 				} else if (@is_readable($src) && @is_file($src)) {
 					$u = spip_file_get_contents($src);
-					if (!isset($ttl)) $ttl = 10;
+					if (!isset($ttl)) {
+					    $ttl = 10;
+					}
 				} else {
 					$u = $src;
-					if (!isset($ttl)) $ttl = 10;
+					if (!isset($ttl)) {
+					    $ttl = 10;
+					}
 				}
 				if (!$this->err
 				AND $g = charger_fonction($this->command['sourcemode'] . '_to_array', 'inc', true)) {
@@ -292,14 +317,15 @@ 
 				}
 			}
 
-			if (!is_array($this->tableau))
-				$this->err = true;
+			if (!is_array($this->tableau)) {
+							$this->err = true;
+			}
 
-			if (!$this->err AND isset($ttl) and $ttl>0)
-				$this->cache_set($cle, $ttl);
+			if (!$this->err AND isset($ttl) and $ttl>0) {
+							$this->cache_set($cle, $ttl);
+			}
 
-		}
-		catch (Exception $e) {
+		} catch (Exception $e) {
 			$e = $e->getMessage();
 			$err = sprintf("[%s, %s] $e",
 				$src,
@@ -348,10 +374,11 @@ 
 				$this->command['enum'] = $this->command['enum'][0];
 			}
 		}
-		if (count($this->command['enum'])>=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']));
+		if (count($this->command['enum'])>=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;
 	}
 
@@ -386,27 +413,30 @@ 
 			if (preg_match(',^\.?([/\w]+)( DESC)?$,iS', ltrim($tri, '/'), $r)) {
 				// tri par cle
 				if ($r[1] == 'cle'){
-					if (isset($r[2]) and $r[2])
-						krsort($this->tableau);
-					else
-						ksort($this->tableau);
+					if (isset($r[2]) and $r[2]) {
+											krsort($this->tableau);
+					} else {
+											ksort($this->tableau);
+					}
 				}
 				# {par hasard}
 				else if ($r[1] == 'alea') {
 					$k = array_keys($this->tableau);
 					shuffle($k);
 					$v = array();
-					foreach($k as $cle)
-						$v[$cle] = $this->tableau[$cle];
+					foreach($k as $cle) {
+											$v[$cle] = $this->tableau[$cle];
+					}
 					$this->tableau = $v;
-				}
-				else {
+				} else {
 					# {par valeur}
-					if ($r[1] == 'valeur')
-						$tv = '%s';
+					if ($r[1] == 'valeur') {
+											$tv = '%s';
+					}
 					# {par valeur/xx/yy} ??
-					else
-						$tv = 'table_valeur(%s, '.var_export($r[1],true).')';
+					else {
+											$tv = 'table_valeur(%s, '.var_export($r[1],true).')';
+					}
 					$sortfunc .= '
 					$a = '.sprintf($tv,'$aa').';
 					$b = '.sprintf($tv,'$bb').';
@@ -436,10 +466,11 @@ 
 			$vu = array();
 			foreach($this->tableau as $k => $v) {
 				$val = table_valeur($v, $fusion);
-				if (isset($vu[$val]))
-					unset($this->tableau[$k]);
-				else
-					$vu[$val] = true;
+				if (isset($vu[$val])) {
+									unset($this->tableau[$k]);
+				} else {
+									$vu[$val] = true;
+				}
 			}
 		}
 	}
@@ -474,8 +505,9 @@ 
 	 * @return void
 	 */
 	public function next(){
-		if ($this->valid())
-			list($this->cle, $this->valeur) = each($this->tableau);
+		if ($this->valid()) {
+					list($this->cle, $this->valeur) = each($this->tableau);
+		}
 	}
 
 	/**
@@ -483,8 +515,9 @@ 
 	 * @return int
 	 */
 	public function count() {
-		if (is_null($this->total))
-			$this->total = count($this->tableau);
+		if (is_null($this->total)) {
+					$this->total = count($this->tableau);
+		}
 	  return $this->total;
 	}
 }
@@ -568,8 +601,9 @@ 
 	$req = trim($v[2]);
 	if ($s = sql_query($req, $serveur)) {
 		$r = array();
-		while ($t = sql_fetch($s))
-			$r[] = $t;
+		while ($t = sql_fetch($s)) {
+					$r[] = $t;
+		}
 		return $r;
 	}
 	return false;
@@ -582,9 +616,10 @@ 
  */
 function inc_json_to_array_dist($u) {
 	if (is_array($json = json_decode($u))
-	OR is_object($json))
-		return (array) $json;
-}
+	OR is_object($json)) {
+			return (array) $json;
+	}
+	}
 
 /**
  * csv -> tableau
@@ -599,8 +634,9 @@ 
 	include_spip('inc/charsets');
 	foreach ($entete as $k => $v) {
 		$v = strtolower(preg_replace(',\W+,', '_', translitteration($v)));
-		foreach ($csv as &$item)
-			$item[$v] = &$item[$k];
+		foreach ($csv as &$item) {
+					$item[$v] = &$item[$k];
+		}
 	}
 	return $csv;
 }
@@ -612,8 +648,9 @@ 
  */
 function inc_rss_to_array_dist($u) {
 	include_spip('inc/syndic');
-	if (is_array($rss = analyser_backend($u)))
-		$tableau = $rss;
+	if (is_array($rss = analyser_backend($u))) {
+			$tableau = $rss;
+	}
 	return $tableau;
 }
 
@@ -681,8 +718,9 @@ 
 	$a = $glob($u);
 	foreach ($a as &$v) {
 		$b = (array) @stat($v);
-		foreach ($b as $k => $ignore)
-			if (is_numeric($k)) unset($b[$k]);
+		foreach ($b as $k => $ignore) {
+					if (is_numeric($k)) unset($b[$k]);
+		}
 		$b['file'] = preg_replace('`/$`','',$v) ;
 		$v = array_merge(
 			pathinfo($v),
@@ -704,14 +742,14 @@ 
 			$key .= '-'.uniqid();
 		}
 		$vars = get_object_vars($object->current());
-		if (isset($vars['@attributes']))
-			foreach($vars['@attributes'] as $k => $v)
+		if (isset($vars['@attributes'])) {
+					foreach($vars['@attributes'] as $k => $v)
 			$xml_array[$key][$k] = $v;
+		}
 		if($object->hasChildren()){
 			$xml_array[$key][] = XMLObjectToArray(
 				$object->current());
-		}
-		else{
+		} else{
 			$xml_array[$key][] = strval($object->current());
 		}
 	}