spip / SPIP

ecrire/inc/prepare_recherche.php

Indentation +94 added lines, -94 removed lines

@@ -41,87 +41,87 @@ 
  * @return array
  */
 function inc_prepare_recherche_dist($recherche, $table='articles', $cond=false, $serveur='', $modificateurs = array(), $primary='') {
-	static $cache = array();
-	$delai_fraicheur = min(_DELAI_CACHE_resultats,time()-$GLOBALS['meta']['derniere_modif']);
+    static $cache = array();
+    $delai_fraicheur = min(_DELAI_CACHE_resultats,time()-$GLOBALS['meta']['derniere_modif']);
 
-	// si recherche n'est pas dans le contexte, on va prendre en globals
-	// ca permet de faire des inclure simple.
-	if (!isset($recherche) AND isset($GLOBALS['recherche']))
-		$recherche = $GLOBALS['recherche'];
+    // si recherche n'est pas dans le contexte, on va prendre en globals
+    // ca permet de faire des inclure simple.
+    if (!isset($recherche) AND isset($GLOBALS['recherche']))
+        $recherche = $GLOBALS['recherche'];
 
-	// traiter le cas {recherche?}
-	if ($cond AND !strlen($recherche))
-		return array("0 as points" /* as points */, /* where */ '');
+    // traiter le cas {recherche?}
+    if ($cond AND !strlen($recherche))
+        return array("0 as points" /* as points */, /* where */ '');
 		
 	
-	$rechercher = false;
-
-	if (!isset($cache[$serveur][$table][$recherche])){
-		$hash_serv = ($serveur?substr(md5($serveur),0,16):'');
-		$hash = substr(md5($recherche . $table),0,16);
-		$where = "(resultats.recherche='$hash' AND resultats.table_objet=".sql_quote($table)." AND resultats.serveur='$hash_serv')";
-		$row = sql_fetsel('UNIX_TIMESTAMP(NOW())-UNIX_TIMESTAMP(resultats.maj) AS fraicheur','spip_resultats AS resultats',$where,'','fraicheur DESC','0,1');
-		if (!$row
-		  OR ($row['fraicheur']>$delai_fraicheur)
-		  OR (defined('_VAR_MODE') AND _VAR_MODE=='recalcul')){
-		 	$rechercher = true;
-		}
-	}
-
-	// si on n'a pas encore traite les donnees dans une boucle precedente
-	if ($rechercher) {
-		//$tables = liste_des_champs();
-		$x = objet_type($table);
-		$points = recherche_en_base($recherche,
-			$x,
-			array(
-				'score' => true,
-				'toutvoir' => true,
-				'jointures' => true
-				),
-			$serveur);
-		// pas de résultat, pas de point
-		$points = isset($points[$x]) ? $points[$x] : array();
-
-		// permettre aux plugins de modifier le resultat
-		$points = pipeline('prepare_recherche',array(
-			'args'=>array('type'=>$x,'recherche'=>$recherche,'serveur'=>$serveur,'modificateurs'=>$modificateurs),
-			'data'=>$points
-		));
-
-		// supprimer les anciens resultats de cette recherche
-		// et les resultats trop vieux avec une marge
-		// pas de AS resultats dans un delete (mysql)
-		$whered = str_replace(array("resultats.recherche","resultats.table_objet","resultats.serveur"),array("recherche","table_objet","serveur"),$where);
-		sql_delete('spip_resultats', 'NOT(' .sql_date_proche('maj', (0-($delai_fraicheur+100)), " SECOND") . ") OR ($whered)");
-
-		// inserer les resultats dans la table de cache des resultats
-		if (count($points)){
-			$tab_couples = array();
-			foreach ($points as $id => $p){
-				$tab_couples[] = array(
-					'recherche' => $hash,
-					'id' => $id,
-					'points' => $p['score'],
-					'table_objet' => $table,
-					'serveur' => $hash_serv,
-				);
-			}
-			sql_insertq_multi('spip_resultats',$tab_couples,array());
-		}
-	}
-
-	if (!isset($cache[$serveur][$table][$recherche])){
-		if (!$serveur)
-			$cache[$serveur][$table][$recherche] = array("resultats.points AS points",$where);
-		else {
-			if (sql_countsel('spip_resultats as resultats',$where))
-			$rows = sql_allfetsel('resultats.id,resultats.points','spip_resultats as resultats',$where);
-			$cache[$serveur][$table][$recherche] = generer_select_where_explicites($table, $primary, $rows, $serveur);
-		}
-	}
-
-	return $cache[$serveur][$table][$recherche];
+    $rechercher = false;
+
+    if (!isset($cache[$serveur][$table][$recherche])){
+        $hash_serv = ($serveur?substr(md5($serveur),0,16):'');
+        $hash = substr(md5($recherche . $table),0,16);
+        $where = "(resultats.recherche='$hash' AND resultats.table_objet=".sql_quote($table)." AND resultats.serveur='$hash_serv')";
+        $row = sql_fetsel('UNIX_TIMESTAMP(NOW())-UNIX_TIMESTAMP(resultats.maj) AS fraicheur','spip_resultats AS resultats',$where,'','fraicheur DESC','0,1');
+        if (!$row
+          OR ($row['fraicheur']>$delai_fraicheur)
+          OR (defined('_VAR_MODE') AND _VAR_MODE=='recalcul')){
+                $rechercher = true;
+        }
+    }
+
+    // si on n'a pas encore traite les donnees dans une boucle precedente
+    if ($rechercher) {
+        //$tables = liste_des_champs();
+        $x = objet_type($table);
+        $points = recherche_en_base($recherche,
+            $x,
+            array(
+                'score' => true,
+                'toutvoir' => true,
+                'jointures' => true
+                ),
+            $serveur);
+        // pas de résultat, pas de point
+        $points = isset($points[$x]) ? $points[$x] : array();
+
+        // permettre aux plugins de modifier le resultat
+        $points = pipeline('prepare_recherche',array(
+            'args'=>array('type'=>$x,'recherche'=>$recherche,'serveur'=>$serveur,'modificateurs'=>$modificateurs),
+            'data'=>$points
+        ));
+
+        // supprimer les anciens resultats de cette recherche
+        // et les resultats trop vieux avec une marge
+        // pas de AS resultats dans un delete (mysql)
+        $whered = str_replace(array("resultats.recherche","resultats.table_objet","resultats.serveur"),array("recherche","table_objet","serveur"),$where);
+        sql_delete('spip_resultats', 'NOT(' .sql_date_proche('maj', (0-($delai_fraicheur+100)), " SECOND") . ") OR ($whered)");
+
+        // inserer les resultats dans la table de cache des resultats
+        if (count($points)){
+            $tab_couples = array();
+            foreach ($points as $id => $p){
+                $tab_couples[] = array(
+                    'recherche' => $hash,
+                    'id' => $id,
+                    'points' => $p['score'],
+                    'table_objet' => $table,
+                    'serveur' => $hash_serv,
+                );
+            }
+            sql_insertq_multi('spip_resultats',$tab_couples,array());
+        }
+    }
+
+    if (!isset($cache[$serveur][$table][$recherche])){
+        if (!$serveur)
+            $cache[$serveur][$table][$recherche] = array("resultats.points AS points",$where);
+        else {
+            if (sql_countsel('spip_resultats as resultats',$where))
+            $rows = sql_allfetsel('resultats.id,resultats.points','spip_resultats as resultats',$where);
+            $cache[$serveur][$table][$recherche] = generer_select_where_explicites($table, $primary, $rows, $serveur);
+        }
+    }
+
+    return $cache[$serveur][$table][$recherche];
 }
 
 
@@ -137,23 +137,23 @@ 
  * @return array
  */
 function generer_select_where_explicites($table, $primary, $rows, $serveur){
-	# calculer le {id_article IN()} et le {... as points}
-	if (!count($rows)){
-		return array("''", "0=1");
-	}
-	else {
-		$listes_ids = array();
-		$select = '0';
-		foreach ($rows as $r)
-			$listes_ids[$r['points']][] = $r['id'];
-
-		foreach ($listes_ids as $p => $ids)
-			$select .= "+$p*(".
-			           sql_in("$table.$primary", $ids,'',$serveur)
-			           .") ";
-
-		return array("$select AS points ",calcul_mysql_in("$table.$primary",array_map('reset',$rows),'',$serveur));
-	}
+    # calculer le {id_article IN()} et le {... as points}
+    if (!count($rows)){
+        return array("''", "0=1");
+    }
+    else {
+        $listes_ids = array();
+        $select = '0';
+        foreach ($rows as $r)
+            $listes_ids[$r['points']][] = $r['id'];
+
+        foreach ($listes_ids as $p => $ids)
+            $select .= "+$p*(".
+                        sql_in("$table.$primary", $ids,'',$serveur)
+                        .") ";
+
+        return array("$select AS points ",calcul_mysql_in("$table.$primary",array_map('reset',$rows),'',$serveur));
+    }
 }
 
 

ecrire/inc/cvt_configurer.php

Indentation +136 added lines, -136 removed lines

@@ -21,28 +21,28 @@ 
  * @return array
  */
 function cvtconf_formulaire_charger($flux){
-	if (
-		$form = $flux['args']['form']
-		and strncmp($form,'configurer_',11)==0 // un #FORMULAIRE_CONFIGURER_XXX
-	) {
-		// Pour tous les formulaires CONFIGURER, ayant une fonction charger ou pas, on teste si autorisé
-		include_spip('inc/autoriser');
-		if (!autoriser('configurer', '_'.substr($form,11))) {
-			return false;
-		}
+    if (
+        $form = $flux['args']['form']
+        and strncmp($form,'configurer_',11)==0 // un #FORMULAIRE_CONFIGURER_XXX
+    ) {
+        // Pour tous les formulaires CONFIGURER, ayant une fonction charger ou pas, on teste si autorisé
+        include_spip('inc/autoriser');
+        if (!autoriser('configurer', '_'.substr($form,11))) {
+            return false;
+        }
 		
-		// S'il n'y a pas de fonction charger(), on génère un contexte automatiquement
-		if (!charger_fonction("charger","formulaires/$form/",true)) {
-			$flux['data'] = cvtconf_formulaires_configurer_recense($form);
-			$flux['data']['editable'] = true;
-			if (_request('var_mode')=='configurer' AND autoriser('webmestre')){
-				if (!_AJAX) var_dump($flux['data']);
-				// reinjecter pour la trace au traitement
-				$flux['data']['_hidden'] = "<input type='hidden' name='var_mode' value='configurer' />";
-			}
-		}
-	}
-	return $flux;
+        // S'il n'y a pas de fonction charger(), on génère un contexte automatiquement
+        if (!charger_fonction("charger","formulaires/$form/",true)) {
+            $flux['data'] = cvtconf_formulaires_configurer_recense($form);
+            $flux['data']['editable'] = true;
+            if (_request('var_mode')=='configurer' AND autoriser('webmestre')){
+                if (!_AJAX) var_dump($flux['data']);
+                // reinjecter pour la trace au traitement
+                $flux['data']['_hidden'] = "<input type='hidden' name='var_mode' value='configurer' />";
+            }
+        }
+    }
+    return $flux;
 }
 
 /**
@@ -52,14 +52,14 @@ 
  * @return array
  */
 function cvtconf_formulaire_traiter($flux){
-	if ($form = $flux['args']['form']
-	  AND strncmp($form,'configurer_',11)==0 // un #FORMULAIRE_CONFIGURER_XXX
-		AND !charger_fonction("traiter","formulaires/$form/",true) // sans fonction traiter()
-		) {
-		$trace = cvtconf_formulaires_configurer_enregistre($form,$flux['args']['args']);
-		$flux['data'] = array('message_ok'=>_T('config_info_enregistree').$trace,'editable'=>true);
-	}
-	return $flux;
+    if ($form = $flux['args']['form']
+      AND strncmp($form,'configurer_',11)==0 // un #FORMULAIRE_CONFIGURER_XXX
+        AND !charger_fonction("traiter","formulaires/$form/",true) // sans fonction traiter()
+        ) {
+        $trace = cvtconf_formulaires_configurer_enregistre($form,$flux['args']['args']);
+        $flux['data'] = array('message_ok'=>_T('config_info_enregistree').$trace,'editable'=>true);
+    }
+    return $flux;
 }
 
 /**
@@ -75,29 +75,29 @@ 
  * @return string
  */
 function cvtconf_formulaires_configurer_enregistre($form,$args){
-		$valeurs = array();
-		// charger les valeurs
-		// ce qui permet de prendre en charge une fonction charger() existante
-		// qui prend alors la main sur l'auto detection
-		if ($charger_valeurs = charger_fonction("charger","formulaires/$form/",true))
-			$valeurs = call_user_func_array($charger_valeurs,$args);
-		$valeurs = pipeline(
-			'formulaire_charger',
-			array(
-				'args'=>array('form'=>$form,'args'=>$args,'je_suis_poste'=>false),
-				'data'=>$valeurs)
-		);
-		// ne pas stocker editable !
-		unset($valeurs['editable']);
-
-		// recuperer les valeurs postees
-		$store = array();
-		foreach($valeurs as $k=>$v){
-			if (substr($k,0,1)!=='_')
-				$store[$k] = _request($k);
-		}
-
-		return cvtconf_configurer_stocker($form,$valeurs,$store);
+        $valeurs = array();
+        // charger les valeurs
+        // ce qui permet de prendre en charge une fonction charger() existante
+        // qui prend alors la main sur l'auto detection
+        if ($charger_valeurs = charger_fonction("charger","formulaires/$form/",true))
+            $valeurs = call_user_func_array($charger_valeurs,$args);
+        $valeurs = pipeline(
+            'formulaire_charger',
+            array(
+                'args'=>array('form'=>$form,'args'=>$args,'je_suis_poste'=>false),
+                'data'=>$valeurs)
+        );
+        // ne pas stocker editable !
+        unset($valeurs['editable']);
+
+        // recuperer les valeurs postees
+        $store = array();
+        foreach($valeurs as $k=>$v){
+            if (substr($k,0,1)!=='_')
+                $store[$k] = _request($k);
+        }
+
+        return cvtconf_configurer_stocker($form,$valeurs,$store);
 }
 
 /**
@@ -113,25 +113,25 @@ 
  * @return array
  */
 function cvtconf_definir_configurer_conteneur($form,$valeurs) {
-		// stocker en base
-		// par defaut, dans un casier serialize dans spip_meta (idem CFG)
-		$casier = substr($form,11);
-		$table = 'meta';
-		$prefixe = '';
-		$stockage = '';
-
-		if (isset($valeurs['_meta_casier']))   $casier   = $valeurs['_meta_casier'];
-		if (isset($valeurs['_meta_prefixe']))  $prefixe  = $valeurs['_meta_prefixe'];
-		if (isset($valeurs['_meta_stockage'])) $stockage = $valeurs['_meta_stockage'] . '::';
+        // stocker en base
+        // par defaut, dans un casier serialize dans spip_meta (idem CFG)
+        $casier = substr($form,11);
+        $table = 'meta';
+        $prefixe = '';
+        $stockage = '';
+
+        if (isset($valeurs['_meta_casier']))   $casier   = $valeurs['_meta_casier'];
+        if (isset($valeurs['_meta_prefixe']))  $prefixe  = $valeurs['_meta_prefixe'];
+        if (isset($valeurs['_meta_stockage'])) $stockage = $valeurs['_meta_stockage'] . '::';
 			
-		// si on indique juste une table, il faut vider les autres proprietes
-		// car par defaut on utilise ni casier ni prefixe dans ce cas
-		if (isset($valeurs['_meta_table'])) {
-			$table = $valeurs['_meta_table'];
-			$casier = (isset($valeurs['_meta_casier'])?$valeurs['_meta_casier']:'');
-		}
+        // si on indique juste une table, il faut vider les autres proprietes
+        // car par defaut on utilise ni casier ni prefixe dans ce cas
+        if (isset($valeurs['_meta_table'])) {
+            $table = $valeurs['_meta_table'];
+            $casier = (isset($valeurs['_meta_casier'])?$valeurs['_meta_casier']:'');
+        }
 	
-		return array($table,$casier,$prefixe,$stockage);
+        return array($table,$casier,$prefixe,$stockage);
 }
 
 /**
@@ -142,39 +142,39 @@ 
  * @return array
  */
 function cvtconf_formulaires_configurer_recense($form){
-	$valeurs = array('editable'=>' ');
-
-	// sinon cas analyse du squelette
-	if ($f = find_in_path($form.'.' . _EXTENSION_SQUELETTES, 'formulaires/')
-		AND lire_fichier($f, $contenu)) {
-
-		for ($i=0;$i<2;$i++) {
-			// a la seconde iteration, evaluer le fond avec les valeurs deja trouvees
-			// permet de trouver aussi les name="#GET{truc}"
-			if ($i==1) $contenu = recuperer_fond("formulaires/$form",$valeurs);
-
-			$balises = array_merge(extraire_balises($contenu,'input'),
-				extraire_balises($contenu,'textarea'),
-				extraire_balises($contenu,'select'));
-
-			foreach($balises as $b) {
-				if ($n = extraire_attribut($b, 'name')
-					AND preg_match(",^([\w\-]+)(\[\w*\])?$,",$n,$r)
-					AND !in_array($n,array('formulaire_action','formulaire_action_args'))
-					AND extraire_attribut($b,'type')!=='submit') {
-						$valeurs[$r[1]] = '';
-						// recuperer les valeurs _meta_xx qui peuvent etre fournies
-						// en input hidden dans le squelette
-						if (strncmp($r[1],'_meta_',6)==0)
-							$valeurs[$r[1]] = extraire_attribut($b,'value');
-					}
-			}
-		}
-	}
-
-
-	cvtconf_configurer_lire_meta($form,$valeurs);
-	return $valeurs;
+    $valeurs = array('editable'=>' ');
+
+    // sinon cas analyse du squelette
+    if ($f = find_in_path($form.'.' . _EXTENSION_SQUELETTES, 'formulaires/')
+        AND lire_fichier($f, $contenu)) {
+
+        for ($i=0;$i<2;$i++) {
+            // a la seconde iteration, evaluer le fond avec les valeurs deja trouvees
+            // permet de trouver aussi les name="#GET{truc}"
+            if ($i==1) $contenu = recuperer_fond("formulaires/$form",$valeurs);
+
+            $balises = array_merge(extraire_balises($contenu,'input'),
+                extraire_balises($contenu,'textarea'),
+                extraire_balises($contenu,'select'));
+
+            foreach($balises as $b) {
+                if ($n = extraire_attribut($b, 'name')
+                    AND preg_match(",^([\w\-]+)(\[\w*\])?$,",$n,$r)
+                    AND !in_array($n,array('formulaire_action','formulaire_action_args'))
+                    AND extraire_attribut($b,'type')!=='submit') {
+                        $valeurs[$r[1]] = '';
+                        // recuperer les valeurs _meta_xx qui peuvent etre fournies
+                        // en input hidden dans le squelette
+                        if (strncmp($r[1],'_meta_',6)==0)
+                            $valeurs[$r[1]] = extraire_attribut($b,'value');
+                    }
+            }
+        }
+    }
+
+
+    cvtconf_configurer_lire_meta($form,$valeurs);
+    return $valeurs;
 }
 
 /**
@@ -185,24 +185,24 @@ 
  * @return string
  */
 function cvtconf_configurer_stocker($form,$valeurs,$store) {
-	$trace = '';
-	list($table,$casier,$prefixe,$stockage) = cvtconf_definir_configurer_conteneur($form,$valeurs);
-	// stocker en base
-	// par defaut, dans un casier serialize dans spip_meta (idem CFG)
-	if (!isset($GLOBALS[$table]))
-		lire_metas($table);
-
-	$prefixe = ($prefixe?$prefixe.'_':'');
-	$table = ($table) ? "/$table/" : ""; 
-	$casier = ($casier) ? rtrim($casier,'/').'/' : ""; // slash final, sinon rien
+    $trace = '';
+    list($table,$casier,$prefixe,$stockage) = cvtconf_definir_configurer_conteneur($form,$valeurs);
+    // stocker en base
+    // par defaut, dans un casier serialize dans spip_meta (idem CFG)
+    if (!isset($GLOBALS[$table]))
+        lire_metas($table);
+
+    $prefixe = ($prefixe?$prefixe.'_':'');
+    $table = ($table) ? "/$table/" : ""; 
+    $casier = ($casier) ? rtrim($casier,'/').'/' : ""; // slash final, sinon rien
 	
-	foreach($store as $k=>$v){
-		ecrire_config("$stockage$table$prefixe$casier$k", $v);
-		if (_request('var_mode')=='configurer' AND autoriser('webmestre')){
-			$trace .= "<br />table $table : ".$prefixe.$k." = $v;";
-		}
-	}
-	return $trace;
+    foreach($store as $k=>$v){
+        ecrire_config("$stockage$table$prefixe$casier$k", $v);
+        if (_request('var_mode')=='configurer' AND autoriser('webmestre')){
+            $trace .= "<br />table $table : ".$prefixe.$k." = $v;";
+        }
+    }
+    return $trace;
 }
 
 /**
@@ -211,23 +211,23 @@ 
  * @param array $valeurs
  */
 function cvtconf_configurer_lire_meta($form,&$valeurs) {
-	list($table,$casier,$prefixe,$stockage) = cvtconf_definir_configurer_conteneur($form,$valeurs);
-
-	$table = ($table) ? "/$table/" : ""; 
-	$prefixe = ($prefixe?$prefixe.'_':'');
-	if ($casier) {
-		$meta = lire_config("$stockage$table$prefixe$casier");
-		$prefixe = '';
-	}
-	else {
-		$table = rtrim($table, '/');
-		$meta = lire_config("$stockage$table");
-	}
-
-	foreach($valeurs as $k=>$v){
-		if (substr($k,0,1)!=='_')
-		$valeurs[$k] = (isset($meta[$prefixe.$k])?$meta[$prefixe.$k]:'');
-	}
+    list($table,$casier,$prefixe,$stockage) = cvtconf_definir_configurer_conteneur($form,$valeurs);
+
+    $table = ($table) ? "/$table/" : ""; 
+    $prefixe = ($prefixe?$prefixe.'_':'');
+    if ($casier) {
+        $meta = lire_config("$stockage$table$prefixe$casier");
+        $prefixe = '';
+    }
+    else {
+        $table = rtrim($table, '/');
+        $meta = lire_config("$stockage$table");
+    }
+
+    foreach($valeurs as $k=>$v){
+        if (substr($k,0,1)!=='_')
+        $valeurs[$k] = (isset($meta[$prefixe.$k])?$meta[$prefixe.$k]:'');
+    }
 }
 
 

ecrire/inc/notifications.php

Indentation +99 added lines, -99 removed lines

@@ -26,16 +26,16 @@ 
  */
 function inc_notifications_dist($quoi, $id=0, $options=array()) {
 
-	// charger les fichiers qui veulent ajouter des definitions
-	// ou faire des trucs aussi dans le pipeline, ca fait deux api pour le prix d'une ...
-	pipeline('notifications',array('args'=>array('quoi'=>$quoi,'id'=>$id,'options'=>$options)));
-
-	if ($notification = charger_fonction($quoi,'notifications',true)) {
-		spip_log("$notification($quoi,$id"
-			.($options?",".serialize($options):"")
-			.")",'notifications');
-		$notification($quoi, $id, $options);
-	}
+    // charger les fichiers qui veulent ajouter des definitions
+    // ou faire des trucs aussi dans le pipeline, ca fait deux api pour le prix d'une ...
+    pipeline('notifications',array('args'=>array('quoi'=>$quoi,'id'=>$id,'options'=>$options)));
+
+    if ($notification = charger_fonction($quoi,'notifications',true)) {
+        spip_log("$notification($quoi,$id"
+            .($options?",".serialize($options):"")
+            .")",'notifications');
+        $notification($quoi, $id, $options);
+    }
 }
 
 /**
@@ -48,15 +48,15 @@ 
  * @param array $exclure
  */
 function notifications_nettoyer_emails(&$emails, $exclure = array()){
-	// filtrer et unifier
-	include_spip('inc/filtres');
-	$emails = array_unique(array_filter(array_map('email_valide',array_map('trim', $emails))));
-	if ($exclure AND count($exclure)){
-		// nettoyer les exclusions d'abord
-		notifications_nettoyer_emails($exclure);
-		// faire un diff
-		$emails = array_diff($emails,$exclure);
-	}
+    // filtrer et unifier
+    include_spip('inc/filtres');
+    $emails = array_unique(array_filter(array_map('email_valide',array_map('trim', $emails))));
+    if ($exclure AND count($exclure)){
+        // nettoyer les exclusions d'abord
+        notifications_nettoyer_emails($exclure);
+        // faire un diff
+        $emails = array_diff($emails,$exclure);
+    }
 }
 
 /**
@@ -70,71 +70,71 @@ 
  * @param string $headers
  */
 function notifications_envoyer_mails($emails, $texte, $sujet="", $from = "", $headers = ""){
-	// rien a faire si pas de texte !
-	if (!strlen($texte))
-		return;
-
-	// si on ne specifie qu'un email, le mettre dans un tableau
-	if (!is_array($emails))
-		$emails = explode(',',$emails);
-
-	notifications_nettoyer_emails($emails);
-
-	// tester si le mail est deja en html
-	if (strpos($texte,"<")!==false // eviter les tests suivants si possible
-		AND $ttrim = trim($texte)
-		AND substr($ttrim,0,1)=="<"
-	  AND substr($ttrim,-1,1)==">"
-	  AND stripos($ttrim,"</html>")!==false){
-
-		if(!strlen($sujet)){
-			// dans ce cas on ruse un peu : extraire le sujet du title
-			if (preg_match(",<title>(.*)</title>,Uims",$texte,$m))
-				$sujet = $m[1];
-			else {
-				// fallback, on prend le body si on le trouve
-				if (preg_match(",<body[^>]*>(.*)</body>,Uims",$texte,$m))
-					$ttrim = $m[1];
-
-				// et on extrait la premiere ligne de vrai texte...
-				// nettoyer le html et les retours chariots
-				$ttrim = textebrut($ttrim);
-				$ttrim = str_replace("\r\n", "\r", $ttrim);
-				$ttrim = str_replace("\r", "\n", $ttrim);
-				// decouper
-				$ttrim = explode("\n",trim($ttrim));
-				// extraire la premiere ligne de texte brut
-				$sujet = array_shift($ttrim);
-			}
-		}
-
-		// si besoin on ajoute le content-type dans les headers
-		if (stripos($headers,"Content-Type")===false)
-			$headers .= "Content-Type: text/html\n";
-	}
-
-	// si le sujet est vide, extraire la premiere ligne du corps
-	// du mail qui est donc du texte
-	if (!strlen($sujet)){
-		// nettoyer un peu les retours chariots
-		$texte = str_replace("\r\n", "\r", $texte);
-		$texte = str_replace("\r", "\n", $texte);
-		// decouper
-		$texte = explode("\n",trim($texte));
-		// extraire la premiere ligne
-		$sujet = array_shift($texte);
-		$texte = trim(implode("\n",$texte));
-	}
-
-	$envoyer_mail = charger_fonction('envoyer_mail','inc');
-	foreach($emails as $email){
-		// passer dans un pipeline qui permet un ajout eventuel
-		// (url de suivi des notifications par exemple)
-		$envoi = pipeline('notifications_envoyer_mails',array('email'=>$email,'sujet'=>$sujet,'texte'=>$texte));
-		$email = $envoi['email'];
-
-		job_queue_add('envoyer_mail', ">$email : ".$envoi['sujet'], array($email, $envoi['sujet'], $envoi['texte'], $from, $headers), 'inc/');
-	}
+    // rien a faire si pas de texte !
+    if (!strlen($texte))
+        return;
+
+    // si on ne specifie qu'un email, le mettre dans un tableau
+    if (!is_array($emails))
+        $emails = explode(',',$emails);
+
+    notifications_nettoyer_emails($emails);
+
+    // tester si le mail est deja en html
+    if (strpos($texte,"<")!==false // eviter les tests suivants si possible
+        AND $ttrim = trim($texte)
+        AND substr($ttrim,0,1)=="<"
+      AND substr($ttrim,-1,1)==">"
+      AND stripos($ttrim,"</html>")!==false){
+
+        if(!strlen($sujet)){
+            // dans ce cas on ruse un peu : extraire le sujet du title
+            if (preg_match(",<title>(.*)</title>,Uims",$texte,$m))
+                $sujet = $m[1];
+            else {
+                // fallback, on prend le body si on le trouve
+                if (preg_match(",<body[^>]*>(.*)</body>,Uims",$texte,$m))
+                    $ttrim = $m[1];
+
+                // et on extrait la premiere ligne de vrai texte...
+                // nettoyer le html et les retours chariots
+                $ttrim = textebrut($ttrim);
+                $ttrim = str_replace("\r\n", "\r", $ttrim);
+                $ttrim = str_replace("\r", "\n", $ttrim);
+                // decouper
+                $ttrim = explode("\n",trim($ttrim));
+                // extraire la premiere ligne de texte brut
+                $sujet = array_shift($ttrim);
+            }
+        }
+
+        // si besoin on ajoute le content-type dans les headers
+        if (stripos($headers,"Content-Type")===false)
+            $headers .= "Content-Type: text/html\n";
+    }
+
+    // si le sujet est vide, extraire la premiere ligne du corps
+    // du mail qui est donc du texte
+    if (!strlen($sujet)){
+        // nettoyer un peu les retours chariots
+        $texte = str_replace("\r\n", "\r", $texte);
+        $texte = str_replace("\r", "\n", $texte);
+        // decouper
+        $texte = explode("\n",trim($texte));
+        // extraire la premiere ligne
+        $sujet = array_shift($texte);
+        $texte = trim(implode("\n",$texte));
+    }
+
+    $envoyer_mail = charger_fonction('envoyer_mail','inc');
+    foreach($emails as $email){
+        // passer dans un pipeline qui permet un ajout eventuel
+        // (url de suivi des notifications par exemple)
+        $envoi = pipeline('notifications_envoyer_mails',array('email'=>$email,'sujet'=>$sujet,'texte'=>$texte));
+        $email = $envoi['email'];
+
+        job_queue_add('envoyer_mail', ">$email : ".$envoi['sujet'], array($email, $envoi['sujet'], $envoi['texte'], $from, $headers), 'inc/');
+    }
 
 }
 
@@ -150,9 +150,9 @@ 
  * @return string
  */
 function email_notification_objet($id_objet, $type_objet, $modele) {
-	$envoyer_mail = charger_fonction('envoyer_mail','inc'); // pour nettoyer_titre_email
-	$id_type = id_table_objet($type_objet);
-	return recuperer_fond($modele,array($id_type=>$id_objet,"id"=>$id_objet));
+    $envoyer_mail = charger_fonction('envoyer_mail','inc'); // pour nettoyer_titre_email
+    $id_type = id_table_objet($type_objet);
+    return recuperer_fond($modele,array($id_type=>$id_objet,"id"=>$id_objet));
 }
 
 /**
@@ -166,29 +166,29 @@ 
  * @return string
  */
 function email_notification_article($id_article, $modele) {
-	$envoyer_mail = charger_fonction('envoyer_mail','inc'); // pour nettoyer_titre_email
+    $envoyer_mail = charger_fonction('envoyer_mail','inc'); // pour nettoyer_titre_email
 
-	return recuperer_fond($modele,array('id_article'=>$id_article));
+    return recuperer_fond($modele,array('id_article'=>$id_article));
 }
 
 // Compatibilite, ne plus utiliser
 // http://doc.spip.org/@notifier_publication_article
 function notifier_publication_article($id_article) {
-	if ($GLOBALS['meta']["suivi_edito"] == "oui") {
-		$adresse_suivi = $GLOBALS['meta']["adresse_suivi"];
-		$texte = email_notification_article($id_article, "notifications/article_publie");
-		notifications_envoyer_mails($adresse_suivi, $texte);
-	}
+    if ($GLOBALS['meta']["suivi_edito"] == "oui") {
+        $adresse_suivi = $GLOBALS['meta']["adresse_suivi"];
+        $texte = email_notification_article($id_article, "notifications/article_publie");
+        notifications_envoyer_mails($adresse_suivi, $texte);
+    }
 }
 
 // Compatibilite, ne plus utiliser
 // http://doc.spip.org/@notifier_proposition_article
 function notifier_proposition_article($id_article) {
-	if ($GLOBALS['meta']["suivi_edito"] == "oui") {
-		$adresse_suivi = $GLOBALS['meta']["adresse_suivi"];
-		$texte = email_notification_article($id_article, "notifications/article_propose");
-		notifications_envoyer_mails($adresse_suivi, $texte);
-	}
+    if ($GLOBALS['meta']["suivi_edito"] == "oui") {
+        $adresse_suivi = $GLOBALS['meta']["adresse_suivi"];
+        $texte = email_notification_article($id_article, "notifications/article_propose");
+        notifications_envoyer_mails($adresse_suivi, $texte);
+    }
 }
 
 ?>

ecrire/inc/install.php

Indentation +333 added lines, -333 removed lines

@@ -40,12 +40,12 @@ 
 **/
 function install_fichier_connexion($nom, $texte)
 {
-	$texte = "<"."?php\n"
-	. "if (!defined(\"_ECRIRE_INC_VERSION\")) return;\n"
-	. $texte
-	. "?".">";
+    $texte = "<"."?php\n"
+    . "if (!defined(\"_ECRIRE_INC_VERSION\")) return;\n"
+    . $texte
+    . "?".">";
 
-	ecrire_fichier($nom, $texte);
+    ecrire_fichier($nom, $texte);
 }
 
 
@@ -74,18 +74,18 @@ 
 **/
 function install_connexion($adr, $port, $login, $pass, $base, $type, $pref, $ldap='')
 {
-	$adr = addcslashes($adr,"'\\");
-	$port = addcslashes($port,"'\\");
-	$login = addcslashes($login,"'\\");
-	$pass = addcslashes($pass,"'\\");
-	$base = addcslashes($base,"'\\");
-	$type = addcslashes($type,"'\\");
-	$pref = addcslashes($pref,"'\\");
-	$ldap = addcslashes($ldap,"'\\");
-	return "\$GLOBALS['spip_connect_version'] = 0.7;\n"
-	. "spip_connect_db("
-	. "'$adr','$port','$login','$pass','$base'"
-	. ",'$type', '$pref','$ldap');\n";
+    $adr = addcslashes($adr,"'\\");
+    $port = addcslashes($port,"'\\");
+    $login = addcslashes($login,"'\\");
+    $pass = addcslashes($pass,"'\\");
+    $base = addcslashes($base,"'\\");
+    $type = addcslashes($type,"'\\");
+    $pref = addcslashes($pref,"'\\");
+    $ldap = addcslashes($ldap,"'\\");
+    return "\$GLOBALS['spip_connect_version'] = 0.7;\n"
+    . "spip_connect_db("
+    . "'$adr','$port','$login','$pass','$base'"
+    . ",'$type', '$pref','$ldap');\n";
 }
 
 
@@ -102,23 +102,23 @@ 
 **/
 function analyse_fichier_connection($file)
 {
-	$s = @join('', file($file));
-	if (preg_match("#mysql_connect\([\"'](.*)[\"'],[\"'](.*)[\"'],[\"'](.*)[\"']\)#", $s, $regs)) {
-		array_shift($regs);
-		return $regs;
-	} else {
-		$ar = '\s*\'([^\']*)\'';
-		$r = '\s*,' . $ar;
-		$r = "#spip_connect_db[(]$ar$r$r$r$r(?:$r(?:$r(?:$r)?)?)?#";
-		if (preg_match($r, $s, $regs)) {
-			$regs[2] = $regs[1] . (!$regs[2] ? '' : ":$port_db;");
-			array_shift($regs);
-			array_shift($regs);
-			return $regs;
-		}
-	}
-	spip_log("$file n'est pas un fichier de connexion");
-	return array();
+    $s = @join('', file($file));
+    if (preg_match("#mysql_connect\([\"'](.*)[\"'],[\"'](.*)[\"'],[\"'](.*)[\"']\)#", $s, $regs)) {
+        array_shift($regs);
+        return $regs;
+    } else {
+        $ar = '\s*\'([^\']*)\'';
+        $r = '\s*,' . $ar;
+        $r = "#spip_connect_db[(]$ar$r$r$r$r(?:$r(?:$r(?:$r)?)?)?#";
+        if (preg_match($r, $s, $regs)) {
+            $regs[2] = $regs[1] . (!$regs[2] ? '' : ":$port_db;");
+            array_shift($regs);
+            array_shift($regs);
+            return $regs;
+        }
+    }
+    spip_log("$file n'est pas un fichier de connexion");
+    return array();
 }
 
 /**
@@ -136,20 +136,20 @@ 
 **/
 function bases_referencees($exclu='')
 {
-	$tables = array();
-	foreach(preg_files(_DIR_CONNECT, '.php$') as $f) {
-		if ($f != $exclu AND analyse_fichier_connection($f))
-			$tables[]= basename($f, '.php');
-	}
-	return $tables;
+    $tables = array();
+    foreach(preg_files(_DIR_CONNECT, '.php$') as $f) {
+        if ($f != $exclu AND analyse_fichier_connection($f))
+            $tables[]= basename($f, '.php');
+    }
+    return $tables;
 }
 
 
 function install_mode_appel($server_db, $tout=true)
 {
-	return ($server_db != 'mysql') ? ''
-	: (($tout  ? test_rappel_nom_base_mysql($server_db) : '')
-		. test_sql_mode_mysql($server_db)	);
+    return ($server_db != 'mysql') ? ''
+    : (($tout  ? test_rappel_nom_base_mysql($server_db) : '')
+        . test_sql_mode_mysql($server_db)	);
 }
 
 //
@@ -157,224 +157,224 @@ 
 // (sert a l'etape 1 de l'installation)
 // http://doc.spip.org/@tester_compatibilite_hebergement
 function tester_compatibilite_hebergement() {
-	$err = array();
-
-	$p = phpversion();
-	if (preg_match(',^([0-9]+)\.([0-9]+)\.([0-9]+),', $p, $regs)) {
-		$php = array($regs[1], $regs[2], $regs[3]);
-		$m = '5.1.0';
-		$min = explode('.', $m);
-		if ($php[0]<$min[0]
-		OR ($php[0]==$min[0] AND $php[1]<$min[1])
-		OR ($php[0]==$min[0] AND $php[1]==$min[1] AND $php[2]<$min[2]))
-			$err[] = _T('install_php_version', array('version' => $p,  'minimum' => $m));
-	}
-
-	// Si on n'a pas la bonne version de PHP, c'est la fin
-	if ($err) 
-		die("<div class='error'>" 
-		. "<h3>"._T('avis_attention').'</h3><p>'._T('install_echec_annonce')."</p><ul class='spip'>"
-		. "<li><strong>{$err[0]}</strong></li>\n</ul></div>");
-
-	// Il faut une base de donnees tout de meme ...
-	$serveurs = install_select_serveur();
-	if (!$serveurs)
-		$err[] = _T('install_extension_php_obligatoire')
-		. " <a href='http://www.php.net/mysql'>MYSQL</a>"
-		. "| <a href='http://www.php.net/pgsql'>PostgreSQL</a>"
-		. "| <a href='http://www.php.net/sqlite'>SQLite</a>";
-
-	// et il faut preg
-	if (!function_exists('preg_match_all'))
-		$err[] = _T('install_extension_php_obligatoire')
-		. " <a href='http://se.php.net/pcre'>PCRE</a>";
-
-	// et surtout pas ce mbstring.overload
-	if ($a = @ini_get('mbstring.func_overload'))
-		$err[] = _T('install_extension_mbstring')
-		. "mbstring.func_overload=$a - <a href='http://www.php.net/mb_string'>mb_string</a>.<br /><small>";
-
-	if ($err) {
-			echo "<div class='error'>"
-				."<h3>"._T('avis_attention').'</h3><p>'._T('install_echec_annonce')."</p><ul class='spip'>";
-			foreach($err as $e)
-				echo "<li><strong>$e</strong></li>\n";
-
-		# a priori ici on pourrait die(), mais il faut laisser la possibilite
-		# de forcer malgre tout (pour tester, ou si bug de detection)
-		echo "</ul></div>\n";
-	}
+    $err = array();
+
+    $p = phpversion();
+    if (preg_match(',^([0-9]+)\.([0-9]+)\.([0-9]+),', $p, $regs)) {
+        $php = array($regs[1], $regs[2], $regs[3]);
+        $m = '5.1.0';
+        $min = explode('.', $m);
+        if ($php[0]<$min[0]
+        OR ($php[0]==$min[0] AND $php[1]<$min[1])
+        OR ($php[0]==$min[0] AND $php[1]==$min[1] AND $php[2]<$min[2]))
+            $err[] = _T('install_php_version', array('version' => $p,  'minimum' => $m));
+    }
+
+    // Si on n'a pas la bonne version de PHP, c'est la fin
+    if ($err) 
+        die("<div class='error'>" 
+        . "<h3>"._T('avis_attention').'</h3><p>'._T('install_echec_annonce')."</p><ul class='spip'>"
+        . "<li><strong>{$err[0]}</strong></li>\n</ul></div>");
+
+    // Il faut une base de donnees tout de meme ...
+    $serveurs = install_select_serveur();
+    if (!$serveurs)
+        $err[] = _T('install_extension_php_obligatoire')
+        . " <a href='http://www.php.net/mysql'>MYSQL</a>"
+        . "| <a href='http://www.php.net/pgsql'>PostgreSQL</a>"
+        . "| <a href='http://www.php.net/sqlite'>SQLite</a>";
+
+    // et il faut preg
+    if (!function_exists('preg_match_all'))
+        $err[] = _T('install_extension_php_obligatoire')
+        . " <a href='http://se.php.net/pcre'>PCRE</a>";
+
+    // et surtout pas ce mbstring.overload
+    if ($a = @ini_get('mbstring.func_overload'))
+        $err[] = _T('install_extension_mbstring')
+        . "mbstring.func_overload=$a - <a href='http://www.php.net/mb_string'>mb_string</a>.<br /><small>";
+
+    if ($err) {
+            echo "<div class='error'>"
+                ."<h3>"._T('avis_attention').'</h3><p>'._T('install_echec_annonce')."</p><ul class='spip'>";
+            foreach($err as $e)
+                echo "<li><strong>$e</strong></li>\n";
+
+        # a priori ici on pourrait die(), mais il faut laisser la possibilite
+        # de forcer malgre tout (pour tester, ou si bug de detection)
+        echo "</ul></div>\n";
+    }
 }
 
 
 // Une fonction pour faciliter la recherche du login (superflu ?)
 // http://doc.spip.org/@login_hebergeur
 function login_hebergeur() {
-	global $HTTP_X_HOST, $REQUEST_URI, $SERVER_NAME, $HTTP_HOST;
-
-	$base_hebergeur = 'localhost'; # par defaut
-
-	// Lycos (ex-Multimachin)
-	if ($HTTP_X_HOST == 'membres.lycos.fr') {
-		preg_match(',^/([^/]*),', $REQUEST_URI, $regs);
-		$login_hebergeur = $regs[1];
-	}
-	// Altern
-	else if (preg_match(',altern\.com$,', $SERVER_NAME)) {
-		preg_match(',([^.]*\.[^.]*)$,', $HTTP_HOST, $regs);
-		$login_hebergeur = preg_replace('[^\w\d]', '_', $regs[1]);
-	}
-	// Free
-	else if (preg_match(',(.*)\.free\.fr$,', $SERVER_NAME, $regs)) {
-		$base_hebergeur = 'sql.free.fr';
-		$login_hebergeur = $regs[1];
-	} else $login_hebergeur = '';
-
-	return array($base_hebergeur, $login_hebergeur);
+    global $HTTP_X_HOST, $REQUEST_URI, $SERVER_NAME, $HTTP_HOST;
+
+    $base_hebergeur = 'localhost'; # par defaut
+
+    // Lycos (ex-Multimachin)
+    if ($HTTP_X_HOST == 'membres.lycos.fr') {
+        preg_match(',^/([^/]*),', $REQUEST_URI, $regs);
+        $login_hebergeur = $regs[1];
+    }
+    // Altern
+    else if (preg_match(',altern\.com$,', $SERVER_NAME)) {
+        preg_match(',([^.]*\.[^.]*)$,', $HTTP_HOST, $regs);
+        $login_hebergeur = preg_replace('[^\w\d]', '_', $regs[1]);
+    }
+    // Free
+    else if (preg_match(',(.*)\.free\.fr$,', $SERVER_NAME, $regs)) {
+        $base_hebergeur = 'sql.free.fr';
+        $login_hebergeur = $regs[1];
+    } else $login_hebergeur = '';
+
+    return array($base_hebergeur, $login_hebergeur);
 }
 
 
 // http://doc.spip.org/@info_etape
 function info_etape($titre, $complement = ''){
-	return "<h2>".$titre."</h2>\n" .
-	($complement ? "".$complement."\n":'');
+    return "<h2>".$titre."</h2>\n" .
+    ($complement ? "".$complement."\n":'');
 }
 
 // http://doc.spip.org/@bouton_suivant
 function bouton_suivant($code = '') {
-	if($code=='') $code = _T('bouton_suivant');
-	static $suivant = 0;
-	$id = 'suivant'.(($suivant>0)?strval($suivant):'');
-	$suivant +=1;
-	return "\n<p class='boutons suivant'><input id='".$id."' type='submit'\nvalue=\"" .
-		$code .
-		" >>\" /></p>\n";
+    if($code=='') $code = _T('bouton_suivant');
+    static $suivant = 0;
+    $id = 'suivant'.(($suivant>0)?strval($suivant):'');
+    $suivant +=1;
+    return "\n<p class='boutons suivant'><input id='".$id."' type='submit'\nvalue=\"" .
+        $code .
+        " >>\" /></p>\n";
 }
 
 // http://doc.spip.org/@info_progression_etape
 function info_progression_etape($en_cours,$phase,$dir, $erreur = false){
-	//$en_cours = _request('etape')?_request('etape'):"";
-	$liste = find_all_in_path($dir,$phase.'(([0-9])+|fin)[.]php$');
-	$debut = 1; $etat = "ok";
-	$last = count($liste);
+    //$en_cours = _request('etape')?_request('etape'):"";
+    $liste = find_all_in_path($dir,$phase.'(([0-9])+|fin)[.]php$');
+    $debut = 1; $etat = "ok";
+    $last = count($liste);
 //	$texte_etat = array('ok'=>'OK','encours'=>_T('en_cours'),'todo'=>_T('todo'));
 
-	$intitule_etat["etape_"][1] = typo(_T('info_connexion_base_donnee'));
-	$intitule_etat["etape_"][2] = typo(_T('menu_aide_installation_choix_base'));
-	$intitule_etat["etape_"][3] = typo(_T('info_informations_personnelles'));
-	$intitule_etat["etape_"][4] = typo(_T('info_derniere_etape'));
+    $intitule_etat["etape_"][1] = typo(_T('info_connexion_base_donnee'));
+    $intitule_etat["etape_"][2] = typo(_T('menu_aide_installation_choix_base'));
+    $intitule_etat["etape_"][3] = typo(_T('info_informations_personnelles'));
+    $intitule_etat["etape_"][4] = typo(_T('info_derniere_etape'));
 
-	$intitule_etat["etape_ldap"][1] = typo(_T('titre_connexion_ldap'));
-	$intitule_etat["etape_ldap"][2] = typo(_T('titre_connexion_ldap'));
-	$intitule_etat["etape_ldap"][3] = typo(_T('info_chemin_acces_1'));
-	$intitule_etat["etape_ldap"][4] = typo(_T('info_reglage_ldap'));
-	$intitule_etat["etape_ldap"][5] = typo(_T('info_ldap_ok'));
+    $intitule_etat["etape_ldap"][1] = typo(_T('titre_connexion_ldap'));
+    $intitule_etat["etape_ldap"][2] = typo(_T('titre_connexion_ldap'));
+    $intitule_etat["etape_ldap"][3] = typo(_T('info_chemin_acces_1'));
+    $intitule_etat["etape_ldap"][4] = typo(_T('info_reglage_ldap'));
+    $intitule_etat["etape_ldap"][5] = typo(_T('info_ldap_ok'));
 
 //	$aff_etapes = "<span id='etapes'>";
 
-	$aff_etapes = "<ul id='infos_etapes' class='infos_$phase$en_cours'>";
-
-	foreach($liste as $etape=>$fichier){
-		if ($debut < $last) {
-			if ($debut == $en_cours && $erreur) $class = "on erreur";
-			else if ($debut == $en_cours) $class = "on";
-			else if ($debut > $en_cours) $class = "prochains";
-			else $class = "valides";
-
-			$aff_etapes .= "<li class='$class'><div class='fond'>";
-			$aff_etapes .= ($debut == $en_cours)?"<strong>":'';
-			$aff_etapes .= "<em>"._T('etape')." </em><span class='numero_etape'>$debut</span><em>&nbsp;: </em>";
-			$aff_etapes .= $intitule_etat["$phase"][$debut];
-			$aff_etapes .= ($debut == $en_cours)?"</strong>":'';
-			$aff_etapes .= "</div></li>";
-		}
-		$debut++;
-	}
-	$aff_etapes .= "</ul>";
-	$aff_etapes .= "<br class='nettoyeur' />\n";
-	return $aff_etapes;
+    $aff_etapes = "<ul id='infos_etapes' class='infos_$phase$en_cours'>";
+
+    foreach($liste as $etape=>$fichier){
+        if ($debut < $last) {
+            if ($debut == $en_cours && $erreur) $class = "on erreur";
+            else if ($debut == $en_cours) $class = "on";
+            else if ($debut > $en_cours) $class = "prochains";
+            else $class = "valides";
+
+            $aff_etapes .= "<li class='$class'><div class='fond'>";
+            $aff_etapes .= ($debut == $en_cours)?"<strong>":'';
+            $aff_etapes .= "<em>"._T('etape')." </em><span class='numero_etape'>$debut</span><em>&nbsp;: </em>";
+            $aff_etapes .= $intitule_etat["$phase"][$debut];
+            $aff_etapes .= ($debut == $en_cours)?"</strong>":'';
+            $aff_etapes .= "</div></li>";
+        }
+        $debut++;
+    }
+    $aff_etapes .= "</ul>";
+    $aff_etapes .= "<br class='nettoyeur' />\n";
+    return $aff_etapes;
 }
 
 
 // http://doc.spip.org/@fieldset
 function fieldset($legend,  $champs = array(), $apres='', $avant='') {
-	return "<fieldset>\n" .
-	  $avant .
-	  ($legend ? "<legend>".$legend."</legend>\n" : '') .
-	  fieldset_champs($champs) .
-	  $apres .
-	  "</fieldset>\n";
+    return "<fieldset>\n" .
+        $avant .
+        ($legend ? "<legend>".$legend."</legend>\n" : '') .
+        fieldset_champs($champs) .
+        $apres .
+        "</fieldset>\n";
 }
 
 function fieldset_champs($champs = array())
-  {
-	$fieldset = '';
-	foreach ($champs as $nom => $contenu) {
-		$type = isset($contenu['hidden']) ? 'hidden' : (preg_match(',^pass,', $nom) ? 'password' : 'text');
-		$class = isset($contenu['hidden']) ? '' : "class='formo' size='40' ";
-		if(isset($contenu['alternatives'])) {
-			$fieldset .= $contenu['label'] ."\n";
-			foreach($contenu['alternatives'] as $valeur => $label) {
-				$fieldset .= "<input type='radio' name='".$nom .
-				"' id='$nom-$valeur' value='$valeur'"
-				  .(($valeur==$contenu['valeur'])?"\nchecked='checked'":'')
-				  ."/>\n";
-				$fieldset .= "<label for='$nom-$valeur'>".$label."</label>\n";
-			}
-			$fieldset .= "<br />\n";
-		}
-		else {
-			$fieldset .= "<label for='".$nom."'>".$contenu['label']."</label>\n";
-			$fieldset .= "<input ".$class."type='".$type."' id='" . $nom . "' name='".$nom."'\nvalue='".$contenu['valeur']."'"
-							  .(preg_match(',^(pass|login),', $nom)?" autocomplete='off'":'')
-			          . ((isset($contenu['required']) AND $contenu['required'])?" required='required'":"")
-			          .	" />\n";
-		}
-	}
-	return $fieldset;
+    {
+    $fieldset = '';
+    foreach ($champs as $nom => $contenu) {
+        $type = isset($contenu['hidden']) ? 'hidden' : (preg_match(',^pass,', $nom) ? 'password' : 'text');
+        $class = isset($contenu['hidden']) ? '' : "class='formo' size='40' ";
+        if(isset($contenu['alternatives'])) {
+            $fieldset .= $contenu['label'] ."\n";
+            foreach($contenu['alternatives'] as $valeur => $label) {
+                $fieldset .= "<input type='radio' name='".$nom .
+                "' id='$nom-$valeur' value='$valeur'"
+                    .(($valeur==$contenu['valeur'])?"\nchecked='checked'":'')
+                    ."/>\n";
+                $fieldset .= "<label for='$nom-$valeur'>".$label."</label>\n";
+            }
+            $fieldset .= "<br />\n";
+        }
+        else {
+            $fieldset .= "<label for='".$nom."'>".$contenu['label']."</label>\n";
+            $fieldset .= "<input ".$class."type='".$type."' id='" . $nom . "' name='".$nom."'\nvalue='".$contenu['valeur']."'"
+                                .(preg_match(',^(pass|login),', $nom)?" autocomplete='off'":'')
+                        . ((isset($contenu['required']) AND $contenu['required'])?" required='required'":"")
+                        .	" />\n";
+        }
+    }
+    return $fieldset;
 }
 
 function install_select_serveur()
 {
-	$options = array();
-	$dir = _DIR_RESTREINT . 'req/';
-	$d = @opendir($dir);
-	if (!$d) return array();
-	while ($f = readdir($d)) {
-		if ((preg_match('/^(.*)[.]php$/', $f, $s))
-		AND is_readable($f = $dir . $f)) {
-			require_once($f);
-			$s = $s[1];
-			$v = 'spip_versions_' . $s;
-			if (function_exists($v) AND $v()) {
-			  $titre = _T("install_select_type_$s");
-				// proposer sqlite3 par defaut si dispo
-				$selected = ($s=='sqlite3'?" selected='selected'":"");
-			  $options[$s] =  "<option value='$s'$selected>"
-			    . ($titre ? $titre : $s)
-			    ."</option>";
-			} else spip_log("$s: portage indisponible");
-		}
-	}
-	sort($options);
-	return $options;
+    $options = array();
+    $dir = _DIR_RESTREINT . 'req/';
+    $d = @opendir($dir);
+    if (!$d) return array();
+    while ($f = readdir($d)) {
+        if ((preg_match('/^(.*)[.]php$/', $f, $s))
+        AND is_readable($f = $dir . $f)) {
+            require_once($f);
+            $s = $s[1];
+            $v = 'spip_versions_' . $s;
+            if (function_exists($v) AND $v()) {
+                $titre = _T("install_select_type_$s");
+                // proposer sqlite3 par defaut si dispo
+                $selected = ($s=='sqlite3'?" selected='selected'":"");
+                $options[$s] =  "<option value='$s'$selected>"
+                . ($titre ? $titre : $s)
+                ."</option>";
+            } else spip_log("$s: portage indisponible");
+        }
+    }
+    sort($options);
+    return $options;
 }
 
 // http://doc.spip.org/@install_connexion_form
 function install_connexion_form($db, $login, $pass, $predef, $hidden, $etape, $jquery=true)
 {
-	$server_db = (is_string($predef[0])) ? $predef[0] : '';
-
-	return generer_form_ecrire('install', (
-	  "\n<input type='hidden' name='etape' value='$etape' />"
-	. $hidden
-	. (_request('echec')?
-			("<p><b>"._T('avis_connexion_echec_1').
-			"</b></p><p>"._T('avis_connexion_echec_2')."</p><p style='font-size: small;'>"._T('avis_connexion_echec_3')."</p>")
-			:"")
-
-	. ($jquery?http_script('',  'jquery.js'):'')
-	. http_script('
+    $server_db = (is_string($predef[0])) ? $predef[0] : '';
+
+    return generer_form_ecrire('install', (
+        "\n<input type='hidden' name='etape' value='$etape' />"
+    . $hidden
+    . (_request('echec')?
+            ("<p><b>"._T('avis_connexion_echec_1').
+            "</b></p><p>"._T('avis_connexion_echec_2')."</p><p style='font-size: small;'>"._T('avis_connexion_echec_3')."</p>")
+            :"")
+
+    . ($jquery?http_script('',  'jquery.js'):'')
+    . http_script('
 		$(document).ready(function() {
 			$("input[type=hidden][name=server_db]").each(function(){
 				if ($(this).attr("value").match("sqlite*")){
@@ -395,67 +395,67 @@ 
 			}
 		});')
 
-	. ($server_db
-		? '<input type="hidden" name="server_db" value="'.$server_db.'" />'
-			. (($predef[0])
-			   ?('<h3>'._T('install_serveur_hebergeur').'</h3>')
-				:'')
-		: ('<fieldset><legend>'
-		   ._T('install_select_type_db')
-		. "</legend>"
-			.'<label for="sql_serveur_db" class="p">'
-			. _T('install_types_db_connus')
-			// Passer l'avertissement SQLIte en  commentaire, on pourra facilement le supprimer par la suite sans changer les traductions.
-			. "<br /><small>(". _T('install_types_db_connus_avertissement') .')</small>'
-			.'</label>'
-		. "\n<div class='p center'><select name='server_db' id='sql_serveur_db' >\n"
-		.   join("\n", install_select_serveur())
-		. "\n</select></div></fieldset>")
-	)
-	. '<div id="install_adresse_base_hebergeur">'
-	. '<p>'. _T('texte_connexion_mysql').'</p>'
-	. ($predef[1]
-	? '<h3>'._T('install_adresse_base_hebergeur').'</h3>'
-	: fieldset(_T('entree_base_donnee_1'),
-		array(
-			'adresse_db' => array(
-				'label' => $db[1],
-				'valeur' => $db[0]
-			),
-		)
-	)
-	)
-	. '</div>'
-
-	. '<div id="install_login_base_hebergeur">'
-	. ($predef[2]
-	? '<h3>'._T('install_login_base_hebergeur').'</h3>'
-	: fieldset(_T('entree_login_connexion_1'),
-		array(
-			'login_db' => array(
-					'label' => $login[1],
-					'valeur' => $login[0]
-			),
-		)
-	)
-	)
-	. '</div>'
-
-	. '<div id="install_pass_base_hebergeur">'
-	. ($predef[3]
-	? '<h3>'._T('install_pass_base_hebergeur').'</h3>'
-	: fieldset(_T('entree_mot_passe_1'),
-		array(
-			'pass_db' => array(
-				'label' => $pass[1],
-				'valeur' => $pass[0]
-			),
-		)
-	)
-	)
-	. '</div>'
-
-	. bouton_suivant()));
+    . ($server_db
+        ? '<input type="hidden" name="server_db" value="'.$server_db.'" />'
+            . (($predef[0])
+               ?('<h3>'._T('install_serveur_hebergeur').'</h3>')
+                :'')
+        : ('<fieldset><legend>'
+            ._T('install_select_type_db')
+        . "</legend>"
+            .'<label for="sql_serveur_db" class="p">'
+            . _T('install_types_db_connus')
+            // Passer l'avertissement SQLIte en  commentaire, on pourra facilement le supprimer par la suite sans changer les traductions.
+            . "<br /><small>(". _T('install_types_db_connus_avertissement') .')</small>'
+            .'</label>'
+        . "\n<div class='p center'><select name='server_db' id='sql_serveur_db' >\n"
+        .   join("\n", install_select_serveur())
+        . "\n</select></div></fieldset>")
+    )
+    . '<div id="install_adresse_base_hebergeur">'
+    . '<p>'. _T('texte_connexion_mysql').'</p>'
+    . ($predef[1]
+    ? '<h3>'._T('install_adresse_base_hebergeur').'</h3>'
+    : fieldset(_T('entree_base_donnee_1'),
+        array(
+            'adresse_db' => array(
+                'label' => $db[1],
+                'valeur' => $db[0]
+            ),
+        )
+    )
+    )
+    . '</div>'
+
+    . '<div id="install_login_base_hebergeur">'
+    . ($predef[2]
+    ? '<h3>'._T('install_login_base_hebergeur').'</h3>'
+    : fieldset(_T('entree_login_connexion_1'),
+        array(
+            'login_db' => array(
+                    'label' => $login[1],
+                    'valeur' => $login[0]
+            ),
+        )
+    )
+    )
+    . '</div>'
+
+    . '<div id="install_pass_base_hebergeur">'
+    . ($predef[3]
+    ? '<h3>'._T('install_pass_base_hebergeur').'</h3>'
+    : fieldset(_T('entree_mot_passe_1'),
+        array(
+            'pass_db' => array(
+                'label' => $pass[1],
+                'valeur' => $pass[0]
+            ),
+        )
+    )
+    )
+    . '</div>'
+
+    . bouton_suivant()));
 
 }
 
@@ -465,23 +465,23 @@ 
 // http://doc.spip.org/@predef_ou_cache
 function predef_ou_cache($adresse_db, $login_db, $pass_db, $server_db)
 {
-	return ((defined('_INSTALL_HOST_DB'))
-		? ''
-		: "\n<input type='hidden' name='adresse_db'  value=\"".spip_htmlspecialchars($adresse_db)."\" />"
-	)
-	. ((defined('_INSTALL_USER_DB'))
-		? ''
-		: "\n<input type='hidden' name='login_db' value=\"".spip_htmlspecialchars($login_db)."\" />"
-	)
-	. ((defined('_INSTALL_PASS_DB'))
-		? ''
-		: "\n<input type='hidden' name='pass_db' value=\"".spip_htmlspecialchars($pass_db)."\" />"
-	)
-
-	. ((defined('_INSTALL_SERVER_DB'))
-		? ''
-		: "\n<input type='hidden' name='server_db' value=\"".spip_htmlspecialchars($server_db)."\" />"
-	   );
+    return ((defined('_INSTALL_HOST_DB'))
+        ? ''
+        : "\n<input type='hidden' name='adresse_db'  value=\"".spip_htmlspecialchars($adresse_db)."\" />"
+    )
+    . ((defined('_INSTALL_USER_DB'))
+        ? ''
+        : "\n<input type='hidden' name='login_db' value=\"".spip_htmlspecialchars($login_db)."\" />"
+    )
+    . ((defined('_INSTALL_PASS_DB'))
+        ? ''
+        : "\n<input type='hidden' name='pass_db' value=\"".spip_htmlspecialchars($pass_db)."\" />"
+    )
+
+    . ((defined('_INSTALL_SERVER_DB'))
+        ? ''
+        : "\n<input type='hidden' name='server_db' value=\"".spip_htmlspecialchars($server_db)."\" />"
+        );
 }
 
 // presentation des bases existantes
@@ -489,45 +489,45 @@ 
 // http://doc.spip.org/@install_etape_liste_bases
 function install_etape_liste_bases($server_db, $login_db, $disabled=array())
 {
-	$bases = $checked = array();
-	$noms = sql_listdbs($server_db);
-	if (!$noms) return '';
-
-	foreach ($noms as $nom){
-		$id = spip_htmlspecialchars($nom);
-		$dis = in_array($nom, $disabled) ? " disabled='disabled'" : '';
-		$base = " name=\"choix_db\" value=\""
-		  . $nom
-		  . '"'
-		  . $dis
-		  . " type='radio' id='$id'";
-		$label = "<label for='$id'>"
-		. ($dis ? "<i>$nom</i>" : $nom)
-		. "</label>";
-
-		if (!$checked AND !$dis AND
-		    (($nom == $login_db) OR
-			($GLOBALS['table_prefix'] == $nom))) {
-			$checked = "<input$base checked='checked' />\n$label";
-		} else {
-			$bases[]= "<input$base />\n$label";
-		}
-	}
-
-	if (!$bases && !$checked) return false;
-
-	if ($checked) {array_unshift($bases, $checked); $checked = true;}
-
-	return array($checked, $bases);
+    $bases = $checked = array();
+    $noms = sql_listdbs($server_db);
+    if (!$noms) return '';
+
+    foreach ($noms as $nom){
+        $id = spip_htmlspecialchars($nom);
+        $dis = in_array($nom, $disabled) ? " disabled='disabled'" : '';
+        $base = " name=\"choix_db\" value=\""
+            . $nom
+            . '"'
+            . $dis
+            . " type='radio' id='$id'";
+        $label = "<label for='$id'>"
+        . ($dis ? "<i>$nom</i>" : $nom)
+        . "</label>";
+
+        if (!$checked AND !$dis AND
+            (($nom == $login_db) OR
+            ($GLOBALS['table_prefix'] == $nom))) {
+            $checked = "<input$base checked='checked' />\n$label";
+        } else {
+            $bases[]= "<input$base />\n$label";
+        }
+    }
+
+    if (!$bases && !$checked) return false;
+
+    if ($checked) {array_unshift($bases, $checked); $checked = true;}
+
+    return array($checked, $bases);
 }
 
 function install_propager($hidden)
 {
-	$res = '';
-	foreach($hidden as $k) {
-		$v = spip_htmlentities(_request($k));
-		$res .= "<input type='hidden' name='$k' value='$v' />";
-	}
-	return $res;
+    $res = '';
+    foreach($hidden as $k) {
+        $v = spip_htmlentities(_request($k));
+        $res .= "<input type='hidden' name='$k' value='$v' />";
+    }
+    return $res;
 }
 ?>

ecrire/inc/flock.php

Indentation +313 added lines, -313 removed lines

@@ -22,56 +22,56 @@ 
 #define('_SPIP_LOCK_MODE',2); // utiliser le nfslock de spip
 
 if (_SPIP_LOCK_MODE==2)
-	include_spip('inc/nfslock');
+    include_spip('inc/nfslock');
 
 $GLOBALS['liste_verrous'] = array();
 // http://doc.spip.org/@spip_fopen_lock
 function spip_fopen_lock($fichier,$mode,$verrou){
-	if (_SPIP_LOCK_MODE==1){
-		if ($fl = @fopen($fichier,$mode))
-			// verrou
-			@flock($fl, $verrou);
-		return $fl;
-	}
-	elseif(_SPIP_LOCK_MODE==2) {
-		if (($verrou = spip_nfslock($fichier)) && ($fl = @fopen($fichier,$mode))){
-			$GLOBALS['liste_verrous'][$fl] = array($fichier,$verrou);
-			return $fl;
-		}
-		else return false;
-	}
-	return @fopen($fichier,$mode);
+    if (_SPIP_LOCK_MODE==1){
+        if ($fl = @fopen($fichier,$mode))
+            // verrou
+            @flock($fl, $verrou);
+        return $fl;
+    }
+    elseif(_SPIP_LOCK_MODE==2) {
+        if (($verrou = spip_nfslock($fichier)) && ($fl = @fopen($fichier,$mode))){
+            $GLOBALS['liste_verrous'][$fl] = array($fichier,$verrou);
+            return $fl;
+        }
+        else return false;
+    }
+    return @fopen($fichier,$mode);
 }
 // http://doc.spip.org/@spip_fclose_unlock
 function spip_fclose_unlock($handle){
-	if (_SPIP_LOCK_MODE==1){
-		@flock($handle, LOCK_UN);
-	}
-	elseif(_SPIP_LOCK_MODE==2) {
-		spip_nfsunlock(reset($GLOBALS['liste_verrous'][$handle]),end($GLOBALS['liste_verrous'][$handle]));
-		unset($GLOBALS['liste_verrous'][$handle]);
-	}
-	return @fclose($handle);
+    if (_SPIP_LOCK_MODE==1){
+        @flock($handle, LOCK_UN);
+    }
+    elseif(_SPIP_LOCK_MODE==2) {
+        spip_nfsunlock(reset($GLOBALS['liste_verrous'][$handle]),end($GLOBALS['liste_verrous'][$handle]));
+        unset($GLOBALS['liste_verrous'][$handle]);
+    }
+    return @fclose($handle);
 }
 
 
 // http://doc.spip.org/@spip_file_get_contents
 function spip_file_get_contents ($fichier) {
-	if (substr($fichier, -3) != '.gz') {
-		if (function_exists('file_get_contents')
-		AND ( 
-			// quand on est sous window on ne sait pas si file_get_contents marche
-			// on essaye : si ca retourne du contenu alors c'est bon
-			// sinon on fait un file() pour avoir le coeur net
-		  ($contenu = @file_get_contents ($fichier))
-		  OR _OS_SERVEUR != 'windows')
-		)
-			return $contenu;
-		else
-			$contenu = @file($fichier);
-	} else
-			$contenu = @gzfile($fichier);
-	return is_array($contenu)?join('', $contenu):(string)$contenu;
+    if (substr($fichier, -3) != '.gz') {
+        if (function_exists('file_get_contents')
+        AND ( 
+            // quand on est sous window on ne sait pas si file_get_contents marche
+            // on essaye : si ca retourne du contenu alors c'est bon
+            // sinon on fait un file() pour avoir le coeur net
+            ($contenu = @file_get_contents ($fichier))
+          OR _OS_SERVEUR != 'windows')
+        )
+            return $contenu;
+        else
+            $contenu = @file($fichier);
+    } else
+            $contenu = @gzfile($fichier);
+    return is_array($contenu)?join('', $contenu):(string)$contenu;
 }
 
 // options = array(
@@ -79,43 +79,43 @@ 
 // dezippe automatiquement les fichiers .gz
 // http://doc.spip.org/@lire_fichier
 function lire_fichier ($fichier, &$contenu, $options=false) {
-	$contenu = '';
-	// inutile car si le fichier n'existe pas, le lock va renvoyer false juste apres
-	// economisons donc les acces disque, sauf chez free qui rale pour un rien
-	if (_TEST_FILE_EXISTS AND !@file_exists($fichier))
-		return false;
-
-	#spip_timer('lire_fichier');
-
-	// pas de @ sur spip_fopen_lock qui est silencieux de toute facon
-	if ($fl = spip_fopen_lock($fichier, 'r', LOCK_SH)) {
-		// lire le fichier avant tout
-		$contenu = spip_file_get_contents($fichier);
-
-		// le fichier a-t-il ete supprime par le locker ?
-		// on ne verifie que si la tentative de lecture a echoue
-		// pour discriminer un contenu vide d'un fichier absent
-		// et eviter un acces disque
-		if (!$contenu AND !@file_exists($fichier)) {
-			spip_fclose_unlock($fl);
-			return false;
-		}
-
-		// liberer le verrou
-		spip_fclose_unlock($fl);
-
-		// Verifications
-		$ok = true;
-		if ($options['phpcheck'] == 'oui')
-			$ok &= (preg_match(",[?]>\n?$,", $contenu));
-
-		#spip_log("$fread $fichier ".spip_timer('lire_fichier'));
-		if (!$ok)
-			spip_log("echec lecture $fichier");
-
-		return $ok;
-	}
-	return false;
+    $contenu = '';
+    // inutile car si le fichier n'existe pas, le lock va renvoyer false juste apres
+    // economisons donc les acces disque, sauf chez free qui rale pour un rien
+    if (_TEST_FILE_EXISTS AND !@file_exists($fichier))
+        return false;
+
+    #spip_timer('lire_fichier');
+
+    // pas de @ sur spip_fopen_lock qui est silencieux de toute facon
+    if ($fl = spip_fopen_lock($fichier, 'r', LOCK_SH)) {
+        // lire le fichier avant tout
+        $contenu = spip_file_get_contents($fichier);
+
+        // le fichier a-t-il ete supprime par le locker ?
+        // on ne verifie que si la tentative de lecture a echoue
+        // pour discriminer un contenu vide d'un fichier absent
+        // et eviter un acces disque
+        if (!$contenu AND !@file_exists($fichier)) {
+            spip_fclose_unlock($fl);
+            return false;
+        }
+
+        // liberer le verrou
+        spip_fclose_unlock($fl);
+
+        // Verifications
+        $ok = true;
+        if ($options['phpcheck'] == 'oui')
+            $ok &= (preg_match(",[?]>\n?$,", $contenu));
+
+        #spip_log("$fread $fichier ".spip_timer('lire_fichier'));
+        if (!$ok)
+            spip_log("echec lecture $fichier");
+
+        return $ok;
+    }
+    return false;
 }
 
 //
@@ -125,77 +125,77 @@ 
 // http://doc.spip.org/@ecrire_fichier
 function ecrire_fichier ($fichier, $contenu, $ignorer_echec = false, $truncate=true) {
 
-	#spip_timer('ecrire_fichier');
-
-	// verrouiller le fichier destination
-	if ($fp = spip_fopen_lock($fichier, 'a',LOCK_EX)) {
-	// ecrire les donnees, compressees le cas echeant
-	// (on ouvre un nouveau pointeur sur le fichier, ce qui a l'avantage
-	// de le recreer si le locker qui nous precede l'avait supprime...)
-		if (substr($fichier, -3) == '.gz')
-			$contenu = gzencode($contenu);
-		// si c'est une ecriture avec troncation , on fait plutot une ecriture complete a cote suivie unlink+rename
-		// pour etre sur d'avoir une operation atomique
-		// y compris en NFS : http://www.ietf.org/rfc/rfc1094.txt
-		// sauf sous wintruc ou ca ne marche pas
-		$ok = false;
-		if ($truncate AND _OS_SERVEUR != 'windows'){
-			if (!function_exists('creer_uniqid'))
-				include_spip('inc/acces');
-			$id = creer_uniqid();
-			// on ouvre un pointeur sur un fichier temporaire en ecriture +raz
-			if ($fp2 = spip_fopen_lock("$fichier.$id", 'w',LOCK_EX)) {
-				$s = @fputs($fp2, $contenu, $a = strlen($contenu));
-				$ok = ($s == $a);
-				spip_fclose_unlock($fp2);
-				spip_fclose_unlock($fp);
-				// unlink direct et pas spip_unlink car on avait deja le verrou
-				// a priori pas besoin car rename ecrase la cible
-				// @unlink($fichier);
-				// le rename aussitot, atomique quand on est pas sous windows
-				// au pire on arrive en second en cas de concourance, et le rename echoue
-				// --> on a la version de l'autre process qui doit etre identique
-				@rename("$fichier.$id",$fichier);
-				// precaution en cas d'echec du rename
-				if (!_TEST_FILE_EXISTS OR @file_exists("$fichier.$id"))
-					@unlink("$fichier.$id");
-				if ($ok)
-					$ok = file_exists($fichier);
-			}
-			else
-				// echec mais penser a fermer ..
-				spip_fclose_unlock($fp);
-		}
-		// sinon ou si methode precedente a echoueee
-		// on se rabat sur la methode ancienne
-		if (!$ok){
-			// ici on est en ajout ou sous windows, cas desespere
-			if ($truncate)
-				@ftruncate($fp,0);
-			$s = @fputs($fp, $contenu, $a = strlen($contenu));
-
-			$ok = ($s == $a);
-			spip_fclose_unlock($fp);
-		}
-
-		// liberer le verrou et fermer le fichier
-		@chmod($fichier, _SPIP_CHMOD & 0666);
-		if ($ok) {
-			if (strpos($fichier,".php")!==false){
-				spip_clear_opcode_cache(realpath($fichier));
-			}
-			return $ok;
-		}
-	}
-
-	if (!$ignorer_echec){
-		include_spip('inc/autoriser');
-		if (autoriser('chargerftp'))
-			raler_fichier($fichier);
-		spip_unlink($fichier);
-	}
-	spip_log("Ecriture fichier $fichier impossible",_LOG_INFO_IMPORTANTE);
-	return false;
+    #spip_timer('ecrire_fichier');
+
+    // verrouiller le fichier destination
+    if ($fp = spip_fopen_lock($fichier, 'a',LOCK_EX)) {
+    // ecrire les donnees, compressees le cas echeant
+    // (on ouvre un nouveau pointeur sur le fichier, ce qui a l'avantage
+    // de le recreer si le locker qui nous precede l'avait supprime...)
+        if (substr($fichier, -3) == '.gz')
+            $contenu = gzencode($contenu);
+        // si c'est une ecriture avec troncation , on fait plutot une ecriture complete a cote suivie unlink+rename
+        // pour etre sur d'avoir une operation atomique
+        // y compris en NFS : http://www.ietf.org/rfc/rfc1094.txt
+        // sauf sous wintruc ou ca ne marche pas
+        $ok = false;
+        if ($truncate AND _OS_SERVEUR != 'windows'){
+            if (!function_exists('creer_uniqid'))
+                include_spip('inc/acces');
+            $id = creer_uniqid();
+            // on ouvre un pointeur sur un fichier temporaire en ecriture +raz
+            if ($fp2 = spip_fopen_lock("$fichier.$id", 'w',LOCK_EX)) {
+                $s = @fputs($fp2, $contenu, $a = strlen($contenu));
+                $ok = ($s == $a);
+                spip_fclose_unlock($fp2);
+                spip_fclose_unlock($fp);
+                // unlink direct et pas spip_unlink car on avait deja le verrou
+                // a priori pas besoin car rename ecrase la cible
+                // @unlink($fichier);
+                // le rename aussitot, atomique quand on est pas sous windows
+                // au pire on arrive en second en cas de concourance, et le rename echoue
+                // --> on a la version de l'autre process qui doit etre identique
+                @rename("$fichier.$id",$fichier);
+                // precaution en cas d'echec du rename
+                if (!_TEST_FILE_EXISTS OR @file_exists("$fichier.$id"))
+                    @unlink("$fichier.$id");
+                if ($ok)
+                    $ok = file_exists($fichier);
+            }
+            else
+                // echec mais penser a fermer ..
+                spip_fclose_unlock($fp);
+        }
+        // sinon ou si methode precedente a echoueee
+        // on se rabat sur la methode ancienne
+        if (!$ok){
+            // ici on est en ajout ou sous windows, cas desespere
+            if ($truncate)
+                @ftruncate($fp,0);
+            $s = @fputs($fp, $contenu, $a = strlen($contenu));
+
+            $ok = ($s == $a);
+            spip_fclose_unlock($fp);
+        }
+
+        // liberer le verrou et fermer le fichier
+        @chmod($fichier, _SPIP_CHMOD & 0666);
+        if ($ok) {
+            if (strpos($fichier,".php")!==false){
+                spip_clear_opcode_cache(realpath($fichier));
+            }
+            return $ok;
+        }
+    }
+
+    if (!$ignorer_echec){
+        include_spip('inc/autoriser');
+        if (autoriser('chargerftp'))
+            raler_fichier($fichier);
+        spip_unlink($fichier);
+    }
+    spip_log("Ecriture fichier $fichier impossible",_LOG_INFO_IMPORTANTE);
+    return false;
 }
 
 /**
@@ -207,10 +207,10 @@ 
  * @param <type> $truncate 
  */
 function ecrire_fichier_securise ($fichier, $contenu, $ecrire_quand_meme = false, $truncate=true) {
-	if (substr($fichier,-4) !== '.php')
-		spip_log('Erreur de programmation: '.$fichier.' doit finir par .php');
-	$contenu = "<"."?php die ('Acces interdit'); ?".">\n" . $contenu;
-	return ecrire_fichier($fichier, $contenu, $ecrire_quand_meme, $truncate);
+    if (substr($fichier,-4) !== '.php')
+        spip_log('Erreur de programmation: '.$fichier.' doit finir par .php');
+    $contenu = "<"."?php die ('Acces interdit'); ?".">\n" . $contenu;
+    return ecrire_fichier($fichier, $contenu, $ecrire_quand_meme, $truncate);
 }
 
 /**
@@ -220,29 +220,29 @@ 
  * @param <type> $options 
  */
 function lire_fichier_securise ($fichier, &$contenu, $options=false) {
-	if ($res = lire_fichier($fichier,$contenu,$options)){
-		$contenu = substr($contenu,strlen("<"."?php die ('Acces interdit'); ?".">\n"));
-	}
-	return $res;
+    if ($res = lire_fichier($fichier,$contenu,$options)){
+        $contenu = substr($contenu,strlen("<"."?php die ('Acces interdit'); ?".">\n"));
+    }
+    return $res;
 }
 
 // http://doc.spip.org/@raler_fichier
 function raler_fichier($fichier)
 {
-	include_spip('inc/minipres');
-	$dir = dirname($fichier);
-	http_status(401);
-	echo minipres(_T('texte_inc_meta_2'), "<h4 style='color: red'>"
-		. _T('texte_inc_meta_1', array('fichier' => $fichier))
-		. " <a href='"
-		. generer_url_ecrire('install', "etape=chmod&test_dir=$dir")
-		. "'>"
-		. _T('texte_inc_meta_2')
-		. "</a> "
-		. _T('texte_inc_meta_3',
-		     array('repertoire' => joli_repertoire($dir)))
-		. "</h4>\n");
-	exit;
+    include_spip('inc/minipres');
+    $dir = dirname($fichier);
+    http_status(401);
+    echo minipres(_T('texte_inc_meta_2'), "<h4 style='color: red'>"
+        . _T('texte_inc_meta_1', array('fichier' => $fichier))
+        . " <a href='"
+        . generer_url_ecrire('install', "etape=chmod&test_dir=$dir")
+        . "'>"
+        . _T('texte_inc_meta_2')
+        . "</a> "
+        . _T('texte_inc_meta_3',
+                array('repertoire' => joli_repertoire($dir)))
+        . "</h4>\n");
+    exit;
 }
 
 //
@@ -252,9 +252,9 @@ 
 // http://doc.spip.org/@jeune_fichier
 function jeune_fichier($fichier, $n)
 {
-	if (!file_exists($fichier)) return false;
-	if (!$c = @filemtime($fichier)) return false;
-	return (time()-$n <= $c);
+    if (!file_exists($fichier)) return false;
+    if (!$c = @filemtime($fichier)) return false;
+    return (time()-$n <= $c);
 }
 
 //
@@ -262,31 +262,31 @@ 
 //
 // http://doc.spip.org/@supprimer_fichier
 function supprimer_fichier($fichier, $lock=true) {
-	if (!@file_exists($fichier))
-		return true;
+    if (!@file_exists($fichier))
+        return true;
 
-	if ($lock) {
-		// verrouiller le fichier destination
-		if (!$fp = spip_fopen_lock($fichier, 'a', LOCK_EX))
-			return false;
+    if ($lock) {
+        // verrouiller le fichier destination
+        if (!$fp = spip_fopen_lock($fichier, 'a', LOCK_EX))
+            return false;
 	
-		// liberer le verrou
-		spip_fclose_unlock($fp);
-	}
+        // liberer le verrou
+        spip_fclose_unlock($fp);
+    }
 	
-	// supprimer
-	return @unlink($fichier);
+    // supprimer
+    return @unlink($fichier);
 }
 
 // Supprimer brutalement, si le fichier existe
 // http://doc.spip.org/@spip_unlink
 function spip_unlink($f) {
-	if (!is_dir($f))
-		supprimer_fichier($f,false);
-	else {
-		@unlink("$f/.ok");
-		@rmdir($f);
-	}
+    if (!is_dir($f))
+        supprimer_fichier($f,false);
+    else {
+        @unlink("$f/.ok");
+        @rmdir($f);
+    }
 }
 
 /**
@@ -295,13 +295,13 @@ 
  * @param null $filename
  */
 function spip_clearstatcache($clear_realpath_cache = false, $filename=null){
-	if (!defined('PHP_VERSION_ID') || PHP_VERSION_ID < 50300) {
-   // Below PHP 5.3, clearstatcache does not accept any function parameters.
-   return clearstatcache();
- }
- else {
-	 return clearstatcache($clear_realpath_cache, $filename);
- }
+    if (!defined('PHP_VERSION_ID') || PHP_VERSION_ID < 50300) {
+    // Below PHP 5.3, clearstatcache does not accept any function parameters.
+    return clearstatcache();
+    }
+    else {
+        return clearstatcache($clear_realpath_cache, $filename);
+    }
 
 }
 
@@ -317,19 +317,19 @@ 
  *   The absolute path of the PHP file to invalidate.
  */
 function spip_clear_opcode_cache($filepath) {
-	spip_clearstatcache(TRUE, $filepath);
+    spip_clearstatcache(TRUE, $filepath);
 
-  // Zend OPcache
-  if (function_exists('opcache_invalidate')) {
+    // Zend OPcache
+    if (function_exists('opcache_invalidate')) {
     opcache_invalidate($filepath, TRUE);
-  }
-  // APC.
-  if (function_exists('apc_delete_file')) {
+    }
+    // APC.
+    if (function_exists('apc_delete_file')) {
     // apc_delete_file() throws a PHP warning in case the specified file was
     // not compiled yet.
     // @see http://php.net/apc-delete-file
     @apc_delete_file($filepath);
-  }
+    }
 }
 
 /**
@@ -344,12 +344,12 @@ 
  *
  */
 function spip_attend_invalidation_opcode_cache(){
-	if (function_exists('opcache_get_configuration')
-	  AND @ini_get('opcache.enable')
-	  AND @ini_get('opcache.validate_timestamps')
-	  AND $duree = @ini_get('opcache.revalidate_freq') ) {
-		sleep($duree+1);
-	}
+    if (function_exists('opcache_get_configuration')
+      AND @ini_get('opcache.enable')
+      AND @ini_get('opcache.validate_timestamps')
+      AND $duree = @ini_get('opcache.revalidate_freq') ) {
+        sleep($duree+1);
+    }
 }
 
 /**
@@ -361,18 +361,18 @@ 
  * @return bool Suppression reussie.
  */
 function supprimer_repertoire($dir) {
-	if (!file_exists($dir)) return true;
-	if (!is_dir($dir) || is_link($dir)) return @unlink($dir);
+    if (!file_exists($dir)) return true;
+    if (!is_dir($dir) || is_link($dir)) return @unlink($dir);
 	
-	foreach (scandir($dir) as $item) {
-		if ($item == '.' || $item == '..') continue;
-		if (!supprimer_repertoire($dir . "/" . $item)) {
-			@chmod($dir . "/" . $item, 0777);
-			if (!supprimer_repertoire($dir . "/" . $item)) return false;
-		};
-	}
+    foreach (scandir($dir) as $item) {
+        if ($item == '.' || $item == '..') continue;
+        if (!supprimer_repertoire($dir . "/" . $item)) {
+            @chmod($dir . "/" . $item, 0777);
+            if (!supprimer_repertoire($dir . "/" . $item)) return false;
+        };
+    }
 	
-	return @rmdir($dir);
+    return @rmdir($dir);
 }
 
 	
@@ -384,61 +384,61 @@ 
 //
 // http://doc.spip.org/@sous_repertoire
 function sous_repertoire($base, $subdir='', $nobase = false, $tantpis=false) {
-	static $dirs = array();
-
-	$base = str_replace("//", "/", $base);
-
-	# suppr le dernier caractere si c'est un / ou un _
-	$base = rtrim($base, '/_');
-
-	if (!strlen($subdir)) {
-		$n = strrpos($base, "/");
-		if ($n === false) return $nobase ? '' : ($base .'/');
-		$subdir = substr($base, $n+1);
-		$base = substr($base, 0, $n+1);
-	} else {
-		$base .= '/';
-		$subdir = str_replace("/", "", $subdir);
-	}
-
-	$baseaff = $nobase ? '' : $base;
-	if (isset($dirs[$base.$subdir]))
-		return $baseaff.$dirs[$base.$subdir];
-
-
-	if (_CREER_DIR_PLAT AND @file_exists("$base${subdir}.plat"))
-		return $baseaff.($dirs[$base.$subdir] = "${subdir}_");
-
-	$path = $base.$subdir; # $path = 'IMG/distant/pdf' ou 'IMG/distant_pdf'
-
-	if (file_exists("$path/.ok"))
-		return $baseaff.($dirs[$base.$subdir] = "$subdir/");
-
-	@mkdir($path, _SPIP_CHMOD);
-	@chmod($path, _SPIP_CHMOD);
-
-	if (is_dir($path) && is_writable($path)) {
-		@touch ("$path/.ok");
-		spip_log("creation $base$subdir/");
-		return $baseaff.($dirs[$base.$subdir] = "$subdir/");
-	}
-
-	// en cas d'echec c'est peut etre tout simplement que le disque est plein :
-	// l'inode du fichier dir_test existe, mais impossible d'y mettre du contenu
-	// => sauf besoin express (define dans mes_options), ne pas creer le .plat
-	if (_CREER_DIR_PLAT
-	AND $f = @fopen("$base${subdir}.plat", "w"))
-		fclose($f);
-	else {
-		spip_log("echec creation $base${subdir}");
-		if ($tantpis) return '';
-		if (!_DIR_RESTREINT)
-			$base = preg_replace(',^' . _DIR_RACINE .',', '',$base);
-		$base .= $subdir;
-		raler_fichier($base . '/.plat');
-	}
-	spip_log("faux sous-repertoire $base${subdir}");
-	return $baseaff.($dirs[$base.$subdir] = "${subdir}_");
+    static $dirs = array();
+
+    $base = str_replace("//", "/", $base);
+
+    # suppr le dernier caractere si c'est un / ou un _
+    $base = rtrim($base, '/_');
+
+    if (!strlen($subdir)) {
+        $n = strrpos($base, "/");
+        if ($n === false) return $nobase ? '' : ($base .'/');
+        $subdir = substr($base, $n+1);
+        $base = substr($base, 0, $n+1);
+    } else {
+        $base .= '/';
+        $subdir = str_replace("/", "", $subdir);
+    }
+
+    $baseaff = $nobase ? '' : $base;
+    if (isset($dirs[$base.$subdir]))
+        return $baseaff.$dirs[$base.$subdir];
+
+
+    if (_CREER_DIR_PLAT AND @file_exists("$base${subdir}.plat"))
+        return $baseaff.($dirs[$base.$subdir] = "${subdir}_");
+
+    $path = $base.$subdir; # $path = 'IMG/distant/pdf' ou 'IMG/distant_pdf'
+
+    if (file_exists("$path/.ok"))
+        return $baseaff.($dirs[$base.$subdir] = "$subdir/");
+
+    @mkdir($path, _SPIP_CHMOD);
+    @chmod($path, _SPIP_CHMOD);
+
+    if (is_dir($path) && is_writable($path)) {
+        @touch ("$path/.ok");
+        spip_log("creation $base$subdir/");
+        return $baseaff.($dirs[$base.$subdir] = "$subdir/");
+    }
+
+    // en cas d'echec c'est peut etre tout simplement que le disque est plein :
+    // l'inode du fichier dir_test existe, mais impossible d'y mettre du contenu
+    // => sauf besoin express (define dans mes_options), ne pas creer le .plat
+    if (_CREER_DIR_PLAT
+    AND $f = @fopen("$base${subdir}.plat", "w"))
+        fclose($f);
+    else {
+        spip_log("echec creation $base${subdir}");
+        if ($tantpis) return '';
+        if (!_DIR_RESTREINT)
+            $base = preg_replace(',^' . _DIR_RACINE .',', '',$base);
+        $base .= $subdir;
+        raler_fichier($base . '/.plat');
+    }
+    spip_log("faux sous-repertoire $base${subdir}");
+    return $baseaff.($dirs[$base.$subdir] = "${subdir}_");
 }
 
 //
@@ -455,46 +455,46 @@ 
 //
 // http://doc.spip.org/@preg_files
 function preg_files($dir, $pattern=-1 /* AUTO */, $maxfiles = 10000, $recurs=array()) {
-	$nbfiles = 0;
-	if ($pattern == -1)
-		$pattern = "^$dir";
-	$fichiers = array();
-	// revenir au repertoire racine si on a recu dossier/truc
-	// pour regarder dossier/truc/ ne pas oublier le / final
-	$dir = preg_replace(',/[^/]*$,', '', $dir);
-	if ($dir == '') $dir = '.';
-
-	if (@is_dir($dir) AND is_readable($dir) AND $d = @opendir($dir)) {
-		while (($f = readdir($d)) !== false && ($nbfiles<$maxfiles)) {
-			if ($f[0] != '.' # ignorer . .. .svn etc
-			AND $f != 'CVS'
-			AND $f != 'remove.txt'
-			AND is_readable($f = "$dir/$f")) {
-				if (is_file($f)) {
-					if (preg_match(";$pattern;iS", $f))
-					{
-						$fichiers[] = $f;
-						$nbfiles++;
-					}
-				} 
-				else if (is_dir($f) AND is_array($recurs)){
-					$rp = @realpath($f);
-					if (!is_string($rp) OR !strlen($rp)) $rp=$f; # realpath n'est peut etre pas autorise
-					if (!isset($recurs[$rp])) {
-						$recurs[$rp] = true;
-						$beginning = $fichiers;
-						$end = preg_files("$f/", $pattern,
-							$maxfiles-$nbfiles, $recurs);
-						$fichiers = array_merge((array)$beginning, (array)$end);
-						$nbfiles = count($fichiers);
-					}
-				}
-			}
-		}
-		closedir($d);
-	}
-	sort($fichiers);
-	return $fichiers;
+    $nbfiles = 0;
+    if ($pattern == -1)
+        $pattern = "^$dir";
+    $fichiers = array();
+    // revenir au repertoire racine si on a recu dossier/truc
+    // pour regarder dossier/truc/ ne pas oublier le / final
+    $dir = preg_replace(',/[^/]*$,', '', $dir);
+    if ($dir == '') $dir = '.';
+
+    if (@is_dir($dir) AND is_readable($dir) AND $d = @opendir($dir)) {
+        while (($f = readdir($d)) !== false && ($nbfiles<$maxfiles)) {
+            if ($f[0] != '.' # ignorer . .. .svn etc
+            AND $f != 'CVS'
+            AND $f != 'remove.txt'
+            AND is_readable($f = "$dir/$f")) {
+                if (is_file($f)) {
+                    if (preg_match(";$pattern;iS", $f))
+                    {
+                        $fichiers[] = $f;
+                        $nbfiles++;
+                    }
+                } 
+                else if (is_dir($f) AND is_array($recurs)){
+                    $rp = @realpath($f);
+                    if (!is_string($rp) OR !strlen($rp)) $rp=$f; # realpath n'est peut etre pas autorise
+                    if (!isset($recurs[$rp])) {
+                        $recurs[$rp] = true;
+                        $beginning = $fichiers;
+                        $end = preg_files("$f/", $pattern,
+                            $maxfiles-$nbfiles, $recurs);
+                        $fichiers = array_merge((array)$beginning, (array)$end);
+                        $nbfiles = count($fichiers);
+                    }
+                }
+            }
+        }
+        closedir($d);
+    }
+    sort($fichiers);
+    return $fichiers;
 }
 
 ?>

ecrire/inc/queue.php

Indentation +426 added lines, -426 removed lines

@@ -48,85 +48,85 @@ 
  *	id of job
  */
 function queue_add_job($function, $description, $arguments = array(), $file = '', $no_duplicate = false, $time=0, $priority=0){
-	include_spip('base/abstract_sql');
-
-	// cas pourri de ecrire/action/editer_site avec l'option reload=oui
-	if (defined('_GENIE_SYNDIC_NOW'))
-		$arguments['id_syndic'] = _GENIE_SYNDIC_NOW;
-
-	// serialiser les arguments
-	$arguments = serialize($arguments);
-	$md5args = md5($arguments);
-
-	// si pas de date programee, des que possible
-	$duplicate_where = 'status='.intval(_JQ_SCHEDULED).' AND ';
-	if (!$time){
-		$time = time();
-		$duplicate_where = ""; // ne pas dupliquer si deja le meme job en cours d'execution
-	}
-	$date = date('Y-m-d H:i:s',$time);
-
-	$set_job = array(
-		'fonction'=>$function,
-		'descriptif'=>$description,
-		'args'=>$arguments,
-		'md5args'=>$md5args,
-		'inclure'=>$file,
-		'priorite'=>max(-10,min(10,intval($priority))),
-		'date'=>$date,
-		'status'=>_JQ_SCHEDULED,
-	);
-	// si option ne pas dupliquer, regarder si la fonction existe deja
-	// avec les memes args et file
-	if (
-			$no_duplicate
-		AND
-			$id_job = sql_getfetsel('id_job','spip_jobs',
-				$duplicate_where =
-					$duplicate_where . 'fonction='.sql_quote($function)
-				.(($no_duplicate==='function_only')?'':
-				 ' AND md5args='.sql_quote($md5args).' AND inclure='.sql_quote($file)))
-		)
-		return $id_job;
-
-	$id_job = sql_insertq('spip_jobs',$set_job);
-	// en cas de concurrence, deux process peuvent arriver jusqu'ici en parallele
-	// avec le meme job unique a inserer. Dans ce cas, celui qui a eu l'id le plus grand
-	// doit s'effacer
-	if (
-			$no_duplicate
-		AND
-			$id_prev = sql_getfetsel('id_job','spip_jobs',"id_job<".intval($id_job)." AND $duplicate_where")){
-		sql_delete('spip_jobs','id_job='.intval($id_job));
-		return $id_prev;
-	}
-
-	// verifier la non duplication qui peut etre problematique en cas de concurence
-	// il faut dans ce cas que seul le dernier ajoute se supprime !
-
-	// une option de debug pour verifier que les arguments en base sont bons
-	// ie cas d'un char non acceptables sur certains type de champs
-	// qui coupe la valeur
-	if (defined('_JQ_INSERT_CHECK_ARGS') AND $id_job) {
-		$args = sql_getfetsel('args', 'spip_jobs', 'id_job='.intval($id_job));
-		if ($args!==$arguments) {
-			spip_log('arguments job errones / longueur '.strlen($args)." vs ".strlen($arguments).' / valeur : '.var_export($arguments,true),'queue');
-		}
-	}
-
-	if ($id_job){
-		queue_update_next_job_time($time);
-	}
-	// si la mise en file d'attente du job echoue,
-	// il ne faut pas perdre l'execution de la fonction
-	// on la lance immediatement, c'est un fallback
-	// sauf en cas d'upgrade necessaire (table spip_jobs inexistante)
-	elseif($GLOBALS['meta']['version_installee']==$GLOBALS['spip_version_base']) {
-		$set_job['id_job'] = 0;
-		queue_start_job($set_job);
-	}
-
-	return $id_job;
+    include_spip('base/abstract_sql');
+
+    // cas pourri de ecrire/action/editer_site avec l'option reload=oui
+    if (defined('_GENIE_SYNDIC_NOW'))
+        $arguments['id_syndic'] = _GENIE_SYNDIC_NOW;
+
+    // serialiser les arguments
+    $arguments = serialize($arguments);
+    $md5args = md5($arguments);
+
+    // si pas de date programee, des que possible
+    $duplicate_where = 'status='.intval(_JQ_SCHEDULED).' AND ';
+    if (!$time){
+        $time = time();
+        $duplicate_where = ""; // ne pas dupliquer si deja le meme job en cours d'execution
+    }
+    $date = date('Y-m-d H:i:s',$time);
+
+    $set_job = array(
+        'fonction'=>$function,
+        'descriptif'=>$description,
+        'args'=>$arguments,
+        'md5args'=>$md5args,
+        'inclure'=>$file,
+        'priorite'=>max(-10,min(10,intval($priority))),
+        'date'=>$date,
+        'status'=>_JQ_SCHEDULED,
+    );
+    // si option ne pas dupliquer, regarder si la fonction existe deja
+    // avec les memes args et file
+    if (
+            $no_duplicate
+        AND
+            $id_job = sql_getfetsel('id_job','spip_jobs',
+                $duplicate_where =
+                    $duplicate_where . 'fonction='.sql_quote($function)
+                .(($no_duplicate==='function_only')?'':
+                 ' AND md5args='.sql_quote($md5args).' AND inclure='.sql_quote($file)))
+        )
+        return $id_job;
+
+    $id_job = sql_insertq('spip_jobs',$set_job);
+    // en cas de concurrence, deux process peuvent arriver jusqu'ici en parallele
+    // avec le meme job unique a inserer. Dans ce cas, celui qui a eu l'id le plus grand
+    // doit s'effacer
+    if (
+            $no_duplicate
+        AND
+            $id_prev = sql_getfetsel('id_job','spip_jobs',"id_job<".intval($id_job)." AND $duplicate_where")){
+        sql_delete('spip_jobs','id_job='.intval($id_job));
+        return $id_prev;
+    }
+
+    // verifier la non duplication qui peut etre problematique en cas de concurence
+    // il faut dans ce cas que seul le dernier ajoute se supprime !
+
+    // une option de debug pour verifier que les arguments en base sont bons
+    // ie cas d'un char non acceptables sur certains type de champs
+    // qui coupe la valeur
+    if (defined('_JQ_INSERT_CHECK_ARGS') AND $id_job) {
+        $args = sql_getfetsel('args', 'spip_jobs', 'id_job='.intval($id_job));
+        if ($args!==$arguments) {
+            spip_log('arguments job errones / longueur '.strlen($args)." vs ".strlen($arguments).' / valeur : '.var_export($arguments,true),'queue');
+        }
+    }
+
+    if ($id_job){
+        queue_update_next_job_time($time);
+    }
+    // si la mise en file d'attente du job echoue,
+    // il ne faut pas perdre l'execution de la fonction
+    // on la lance immediatement, c'est un fallback
+    // sauf en cas d'upgrade necessaire (table spip_jobs inexistante)
+    elseif($GLOBALS['meta']['version_installee']==$GLOBALS['spip_version_base']) {
+        $set_job['id_job'] = 0;
+        queue_start_job($set_job);
+    }
+
+    return $id_job;
 }
 
 /**
@@ -135,11 +135,11 @@ 
  * @return void
  */
 function queue_purger(){
-	include_spip('base/abstract_sql');
-	sql_delete('spip_jobs');
-  sql_delete("spip_jobs_liens","id_job NOT IN (".sql_get_select("id_job","spip_jobs").")");
-  include_spip('inc/genie');
-  genie_queue_watch_dist();
+    include_spip('base/abstract_sql');
+    sql_delete('spip_jobs');
+    sql_delete("spip_jobs_liens","id_job NOT IN (".sql_get_select("id_job","spip_jobs").")");
+    include_spip('inc/genie');
+    genie_queue_watch_dist();
 }
 
 /**
@@ -149,21 +149,21 @@ 
  * @return bool
  */
 function queue_remove_job($id_job){
-	include_spip('base/abstract_sql');
-
-	if ($row = sql_fetsel('fonction,inclure,date','spip_jobs','id_job='.intval($id_job))
-	 AND $res = sql_delete('spip_jobs','id_job='.intval($id_job))){
-		queue_unlink_job($id_job);
-		// est-ce une tache cron qu'il faut relancer ?
-		if ($periode = queue_is_cron_job($row['fonction'],$row['inclure'])){
-			// relancer avec les nouveaux arguments de temps
-			include_spip('inc/genie');
-			// relancer avec la periode prevue
-			queue_genie_replan_job($row['fonction'],$periode,strtotime($row['date']));
-		}
-		queue_update_next_job_time();
-	}
-	return $res;
+    include_spip('base/abstract_sql');
+
+    if ($row = sql_fetsel('fonction,inclure,date','spip_jobs','id_job='.intval($id_job))
+     AND $res = sql_delete('spip_jobs','id_job='.intval($id_job))){
+        queue_unlink_job($id_job);
+        // est-ce une tache cron qu'il faut relancer ?
+        if ($periode = queue_is_cron_job($row['fonction'],$row['inclure'])){
+            // relancer avec les nouveaux arguments de temps
+            include_spip('inc/genie');
+            // relancer avec la periode prevue
+            queue_genie_replan_job($row['fonction'],$periode,strtotime($row['date']));
+        }
+        queue_update_next_job_time();
+    }
+    return $res;
 }
 
 /**
@@ -176,18 +176,18 @@ 
  *  or an array of simple array to link multiples objet in one time
  */
 function queue_link_job($id_job,$objets){
-	include_spip('base/abstract_sql');
-
-	if (is_array($objets) AND count($objets)){
-		if (is_array(reset($objets))){
-			foreach($objets as $k=>$o){
-				$objets[$k]['id_job'] = $id_job;
-			}
-			sql_insertq_multi('spip_jobs_liens',$objets);
-		}
-		else
-			sql_insertq('spip_jobs_liens',array_merge(array('id_job'=>$id_job),$objets));
-	}
+    include_spip('base/abstract_sql');
+
+    if (is_array($objets) AND count($objets)){
+        if (is_array(reset($objets))){
+            foreach($objets as $k=>$o){
+                $objets[$k]['id_job'] = $id_job;
+            }
+            sql_insertq_multi('spip_jobs_liens',$objets);
+        }
+        else
+            sql_insertq('spip_jobs_liens',array_merge(array('id_job'=>$id_job),$objets));
+    }
 }
 
 /**
@@ -199,7 +199,7 @@ 
  *	result of sql_delete
  */
 function queue_unlink_job($id_job){
-	return sql_delete("spip_jobs_liens","id_job=".intval($id_job));
+    return sql_delete("spip_jobs_liens","id_job=".intval($id_job));
 }
 
 /**
@@ -211,48 +211,48 @@ 
  */
 function queue_start_job($row){
 
-	// deserialiser les arguments
-	$args = unserialize($row['args']);
-	if ($args===false){
-		spip_log('arguments job errones '.var_export($row,true),'queue');
-		$args = array();
-	}
-
-	$fonction = $row['fonction'];
-	if (strlen($inclure = trim($row['inclure']))){
-		if (substr($inclure,-1)=='/'){ // c'est un chemin pour charger_fonction
-			$f = charger_fonction($fonction,rtrim($inclure,'/'),false);
-			if ($f)
-				$fonction = $f;
-		}
-		else
-			include_spip($inclure);
-	}
-
-	if (!function_exists($fonction)){
-		spip_log("fonction $fonction ($inclure) inexistante ".var_export($row,true),'queue');
-		return false;
-	}
-
-	spip_log("queue [".$row['id_job']."]: $fonction() start", 'queue');
-	switch (count($args)) {
-		case 0:	$res = $fonction(); break;
-		case 1:	$res = $fonction($args[0]); break;
-		case 2:	$res = $fonction($args[0],$args[1]); break;
-		case 3:	$res = $fonction($args[0],$args[1], $args[2]); break;
-		case 4:	$res = $fonction($args[0],$args[1], $args[2], $args[3]); break;
-		case 5:	$res = $fonction($args[0],$args[1], $args[2], $args[3], $args[4]); break;
-		case 6:	$res = $fonction($args[0],$args[1], $args[2], $args[3], $args[4], $args[5]); break;
-		case 7:	$res = $fonction($args[0],$args[1], $args[2], $args[3], $args[4], $args[5], $args[6]); break;
-		case 8:	$res = $fonction($args[0],$args[1], $args[2], $args[3], $args[4], $args[5], $args[6], $args[7]); break;
-		case 9:	$res = $fonction($args[0],$args[1], $args[2], $args[3], $args[4], $args[5], $args[6], $args[7], $args[8]); break;
-		case 10:$res = $fonction($args[0],$args[1], $args[2], $args[3], $args[4], $args[5], $args[6], $args[7], $args[8], $args[9]); break;
-		default:
-			# plus lent mais completement generique
-			$res = call_user_func_array($fonction, $args);
-	}
-	spip_log("queue [".$row['id_job']."]: $fonction() end", 'queue');
-	return $res;
+    // deserialiser les arguments
+    $args = unserialize($row['args']);
+    if ($args===false){
+        spip_log('arguments job errones '.var_export($row,true),'queue');
+        $args = array();
+    }
+
+    $fonction = $row['fonction'];
+    if (strlen($inclure = trim($row['inclure']))){
+        if (substr($inclure,-1)=='/'){ // c'est un chemin pour charger_fonction
+            $f = charger_fonction($fonction,rtrim($inclure,'/'),false);
+            if ($f)
+                $fonction = $f;
+        }
+        else
+            include_spip($inclure);
+    }
+
+    if (!function_exists($fonction)){
+        spip_log("fonction $fonction ($inclure) inexistante ".var_export($row,true),'queue');
+        return false;
+    }
+
+    spip_log("queue [".$row['id_job']."]: $fonction() start", 'queue');
+    switch (count($args)) {
+        case 0:	$res = $fonction(); break;
+        case 1:	$res = $fonction($args[0]); break;
+        case 2:	$res = $fonction($args[0],$args[1]); break;
+        case 3:	$res = $fonction($args[0],$args[1], $args[2]); break;
+        case 4:	$res = $fonction($args[0],$args[1], $args[2], $args[3]); break;
+        case 5:	$res = $fonction($args[0],$args[1], $args[2], $args[3], $args[4]); break;
+        case 6:	$res = $fonction($args[0],$args[1], $args[2], $args[3], $args[4], $args[5]); break;
+        case 7:	$res = $fonction($args[0],$args[1], $args[2], $args[3], $args[4], $args[5], $args[6]); break;
+        case 8:	$res = $fonction($args[0],$args[1], $args[2], $args[3], $args[4], $args[5], $args[6], $args[7]); break;
+        case 9:	$res = $fonction($args[0],$args[1], $args[2], $args[3], $args[4], $args[5], $args[6], $args[7], $args[8]); break;
+        case 10:$res = $fonction($args[0],$args[1], $args[2], $args[3], $args[4], $args[5], $args[6], $args[7], $args[8], $args[9]); break;
+        default:
+            # plus lent mais completement generique
+            $res = call_user_func_array($fonction, $args);
+    }
+    spip_log("queue [".$row['id_job']."]: $fonction() end", 'queue');
+    return $res;
 
 }
 
@@ -271,82 +271,82 @@ 
  * @return null|false
  */
 function queue_schedule($force_jobs = null){
-	$time = time();
-	if (defined('_DEBUG_BLOCK_QUEUE')) {
-		spip_log("_DEBUG_BLOCK_QUEUE : schedule stop",'jq'._LOG_DEBUG);
-		return;
-	}
-
-	// rien a faire si le prochain job est encore dans le futur
-	if (queue_sleep_time_to_next_job()>0 AND (!$force_jobs OR !count($force_jobs))){
-		spip_log("queue_sleep_time_to_next_job",'jq'._LOG_DEBUG);
-		return;
-	}
-
-	include_spip('base/abstract_sql');
-	// on ne peut rien faire si pas de connexion SQL
-	if (!spip_connect())  return false;
-
-	if (!defined('_JQ_MAX_JOBS_TIME_TO_EXECUTE')){
-		$max_time = ini_get('max_execution_time')/2;
-		// valeur conservatrice si on a pas reussi a lire le max_execution_time
-		if (!$max_time) $max_time=5;
-		define('_JQ_MAX_JOBS_TIME_TO_EXECUTE',min($max_time,15)); // une valeur maxi en temps.
-	}
-	$end_time = $time + _JQ_MAX_JOBS_TIME_TO_EXECUTE;
-
-	spip_log("JQ schedule $time / $end_time",'jq'._LOG_DEBUG);
-
-	if (!defined('_JQ_MAX_JOBS_EXECUTE'))
-		define('_JQ_MAX_JOBS_EXECUTE',200);
-	$nbj=0;
-	// attraper les jobs
-	// dont la date est passee (echus en attente),
-	// par odre :
-	//	- de priorite
-	//	- de date
-	// lorsqu'un job cron n'a pas fini, sa priorite est descendue
-	// pour qu'il ne bloque pas les autres jobs en attente
-	if (is_array($force_jobs) AND count($force_jobs))
-		$cond = "status=".intval(_JQ_SCHEDULED)." AND ".sql_in("id_job", $force_jobs);
-	else {
-		$now = date('Y-m-d H:i:s',$time);
-		$cond = "status=".intval(_JQ_SCHEDULED)." AND date<=".sql_quote($now);
-	}
-
-	register_shutdown_function('queue_error_handler'); // recuperer les erreurs auant que possible
-	$res = sql_allfetsel('*','spip_jobs',$cond,'','priorite DESC,date','0,'.(_JQ_MAX_JOBS_EXECUTE+1));
-	do {
-		if ($row = array_shift($res)){
-			$nbj++;
-			// il faut un verrou, a base de sql_delete
-			if (sql_delete('spip_jobs',"id_job=".intval($row['id_job'])." AND status=".intval(_JQ_SCHEDULED))){
-				#spip_log("JQ schedule job ".$nbj." OK",'jq');
-				// on reinsert dans la base aussitot avec un status=_JQ_PENDING
-				$row['status'] = _JQ_PENDING;
-				$row['date'] = date('Y-m-d H:i:s',$time);
-				sql_insertq('spip_jobs', $row);
-
-				// on a la main sur le job :
-				// l'executer
-				$result = queue_start_job($row);
-
-				$time = time();
-				queue_close_job($row, $time, $result);
-			}
-		}
-		spip_log("JQ schedule job end time ".$time,'jq'._LOG_DEBUG);
-	} while ($nbj<_JQ_MAX_JOBS_EXECUTE AND $row AND $time<$end_time);
-	spip_log("JQ schedule end time ".time(),'jq'._LOG_DEBUG);
-
-	if ($row = array_shift($res)){
-		queue_update_next_job_time(0); // on sait qu'il y a encore des jobs a lancer ASAP
-		spip_log("JQ encore !",'jq'._LOG_DEBUG);
-	}
-	else
-		queue_update_next_job_time();
-
-	return true;
+    $time = time();
+    if (defined('_DEBUG_BLOCK_QUEUE')) {
+        spip_log("_DEBUG_BLOCK_QUEUE : schedule stop",'jq'._LOG_DEBUG);
+        return;
+    }
+
+    // rien a faire si le prochain job est encore dans le futur
+    if (queue_sleep_time_to_next_job()>0 AND (!$force_jobs OR !count($force_jobs))){
+        spip_log("queue_sleep_time_to_next_job",'jq'._LOG_DEBUG);
+        return;
+    }
+
+    include_spip('base/abstract_sql');
+    // on ne peut rien faire si pas de connexion SQL
+    if (!spip_connect())  return false;
+
+    if (!defined('_JQ_MAX_JOBS_TIME_TO_EXECUTE')){
+        $max_time = ini_get('max_execution_time')/2;
+        // valeur conservatrice si on a pas reussi a lire le max_execution_time
+        if (!$max_time) $max_time=5;
+        define('_JQ_MAX_JOBS_TIME_TO_EXECUTE',min($max_time,15)); // une valeur maxi en temps.
+    }
+    $end_time = $time + _JQ_MAX_JOBS_TIME_TO_EXECUTE;
+
+    spip_log("JQ schedule $time / $end_time",'jq'._LOG_DEBUG);
+
+    if (!defined('_JQ_MAX_JOBS_EXECUTE'))
+        define('_JQ_MAX_JOBS_EXECUTE',200);
+    $nbj=0;
+    // attraper les jobs
+    // dont la date est passee (echus en attente),
+    // par odre :
+    //	- de priorite
+    //	- de date
+    // lorsqu'un job cron n'a pas fini, sa priorite est descendue
+    // pour qu'il ne bloque pas les autres jobs en attente
+    if (is_array($force_jobs) AND count($force_jobs))
+        $cond = "status=".intval(_JQ_SCHEDULED)." AND ".sql_in("id_job", $force_jobs);
+    else {
+        $now = date('Y-m-d H:i:s',$time);
+        $cond = "status=".intval(_JQ_SCHEDULED)." AND date<=".sql_quote($now);
+    }
+
+    register_shutdown_function('queue_error_handler'); // recuperer les erreurs auant que possible
+    $res = sql_allfetsel('*','spip_jobs',$cond,'','priorite DESC,date','0,'.(_JQ_MAX_JOBS_EXECUTE+1));
+    do {
+        if ($row = array_shift($res)){
+            $nbj++;
+            // il faut un verrou, a base de sql_delete
+            if (sql_delete('spip_jobs',"id_job=".intval($row['id_job'])." AND status=".intval(_JQ_SCHEDULED))){
+                #spip_log("JQ schedule job ".$nbj." OK",'jq');
+                // on reinsert dans la base aussitot avec un status=_JQ_PENDING
+                $row['status'] = _JQ_PENDING;
+                $row['date'] = date('Y-m-d H:i:s',$time);
+                sql_insertq('spip_jobs', $row);
+
+                // on a la main sur le job :
+                // l'executer
+                $result = queue_start_job($row);
+
+                $time = time();
+                queue_close_job($row, $time, $result);
+            }
+        }
+        spip_log("JQ schedule job end time ".$time,'jq'._LOG_DEBUG);
+    } while ($nbj<_JQ_MAX_JOBS_EXECUTE AND $row AND $time<$end_time);
+    spip_log("JQ schedule end time ".time(),'jq'._LOG_DEBUG);
+
+    if ($row = array_shift($res)){
+        queue_update_next_job_time(0); // on sait qu'il y a encore des jobs a lancer ASAP
+        spip_log("JQ encore !",'jq'._LOG_DEBUG);
+    }
+    else
+        queue_update_next_job_time();
+
+    return true;
 }
 
 /**
@@ -360,21 +360,21 @@ 
  * @param int $result
  */
 function queue_close_job(&$row,$time,$result=0){
-	// est-ce une tache cron qu'il faut relancer ?
-	if ($periode = queue_is_cron_job($row['fonction'],$row['inclure'])){
-		// relancer avec les nouveaux arguments de temps
-		include_spip('inc/genie');
-		if ($result<0)
-			// relancer tout de suite, mais en baissant la priorite
-			queue_genie_replan_job($row['fonction'],$periode,0-$result,null,$row['priorite']-1);
-		else
-			// relancer avec la periode prevue
-			queue_genie_replan_job($row['fonction'],$periode,$time);
-	}
-	// purger ses liens eventuels avec des objets
-	sql_delete("spip_jobs_liens","id_job=".intval($row['id_job']));
-	// supprimer le job fini
-	sql_delete('spip_jobs','id_job='.intval($row['id_job']));
+    // est-ce une tache cron qu'il faut relancer ?
+    if ($periode = queue_is_cron_job($row['fonction'],$row['inclure'])){
+        // relancer avec les nouveaux arguments de temps
+        include_spip('inc/genie');
+        if ($result<0)
+            // relancer tout de suite, mais en baissant la priorite
+            queue_genie_replan_job($row['fonction'],$periode,0-$result,null,$row['priorite']-1);
+        else
+            // relancer avec la periode prevue
+            queue_genie_replan_job($row['fonction'],$periode,$time);
+    }
+    // purger ses liens eventuels avec des objets
+    sql_delete("spip_jobs_liens","id_job=".intval($row['id_job']));
+    // supprimer le job fini
+    sql_delete('spip_jobs','id_job='.intval($row['id_job']));
 }
 
 /**
@@ -382,10 +382,10 @@ 
  * en terminant la gestion de la queue
  */
 function queue_error_handler(){
-	// se remettre dans le bon dossier, car Apache le change parfois (toujours?)
-	chdir(_ROOT_CWD);
+    // se remettre dans le bon dossier, car Apache le change parfois (toujours?)
+    chdir(_ROOT_CWD);
 
-	queue_update_next_job_time();
+    queue_update_next_job_time();
 }
 
 
@@ -397,16 +397,16 @@ 
  * @return <type>
  */
 function queue_is_cron_job($function,$inclure){
-	static $taches = null;
-	if (strncmp($inclure,'genie/',6)==0){
-		if (is_null($taches)){
-			include_spip('inc/genie');
-			$taches = taches_generales();
-		}
-		if (isset($taches[$function]))
-			return $taches[$function];
-	}
-	return false;
+    static $taches = null;
+    if (strncmp($inclure,'genie/',6)==0){
+        if (is_null($taches)){
+            include_spip('inc/genie');
+            $taches = taches_generales();
+        }
+        if (isset($taches[$function]))
+            return $taches[$function];
+    }
+    return false;
 }
 
 /**
@@ -420,48 +420,48 @@ 
  *	temps de la tache ajoutee ou 0 pour ASAP
  */
 function queue_update_next_job_time($next_time=null){
-	static $nb_jobs_scheduled = null;
-	static $deja_la = false;
-	// prendre le min des $next_time que l'on voit passer ici, en cas de reentrance
-	static $next = null;
-	// queue_close_job peut etre reentrant ici
-	if ($deja_la) return;
-	$deja_la = true;
-
-	include_spip('base/abstract_sql');
-	$time = time();
-
-	// traiter les jobs morts au combat (_JQ_PENDING depuis plus de 180s)
-	// pour cause de timeout ou autre erreur fatale
-	$res = sql_allfetsel("*","spip_jobs","status=".intval(_JQ_PENDING)." AND date<".sql_quote(date('Y-m-d H:i:s',$time-180)));
-	if (is_array($res)) {
-		foreach ($res as $row)
-			queue_close_job($row,$time);
-	}
-
-	// chercher la date du prochain job si pas connu
-	if (is_null($next) OR is_null(queue_sleep_time_to_next_job())){
-		$date = sql_getfetsel('date','spip_jobs',"status=".intval(_JQ_SCHEDULED),'','date','0,1');
-		$next = strtotime($date);
-	}
-	if (!is_null($next_time)){
-		if (is_null($next) OR $next>$next_time)
-			$next = $next_time;
-	}
-
-		if ($next){
-			if (is_null($nb_jobs_scheduled))
-				$nb_jobs_scheduled = sql_countsel('spip_jobs',"status=".intval(_JQ_SCHEDULED)." AND date<".sql_quote(date('Y-m-d H:i:s',$time)));
-			elseif ($next<=$time)
-				$nb_jobs_scheduled++;
-			// si trop de jobs en attente, on force la purge en fin de hit
-			// pour assurer le coup
-			if ($nb_jobs_scheduled>defined('_JQ_NB_JOBS_OVERFLOW')?_JQ_NB_JOBS_OVERFLOW:10000)
-				define('_DIRECT_CRON_FORCE',true);
-		}
-
-	queue_set_next_job_time($next);
-	$deja_la = false;
+    static $nb_jobs_scheduled = null;
+    static $deja_la = false;
+    // prendre le min des $next_time que l'on voit passer ici, en cas de reentrance
+    static $next = null;
+    // queue_close_job peut etre reentrant ici
+    if ($deja_la) return;
+    $deja_la = true;
+
+    include_spip('base/abstract_sql');
+    $time = time();
+
+    // traiter les jobs morts au combat (_JQ_PENDING depuis plus de 180s)
+    // pour cause de timeout ou autre erreur fatale
+    $res = sql_allfetsel("*","spip_jobs","status=".intval(_JQ_PENDING)." AND date<".sql_quote(date('Y-m-d H:i:s',$time-180)));
+    if (is_array($res)) {
+        foreach ($res as $row)
+            queue_close_job($row,$time);
+    }
+
+    // chercher la date du prochain job si pas connu
+    if (is_null($next) OR is_null(queue_sleep_time_to_next_job())){
+        $date = sql_getfetsel('date','spip_jobs',"status=".intval(_JQ_SCHEDULED),'','date','0,1');
+        $next = strtotime($date);
+    }
+    if (!is_null($next_time)){
+        if (is_null($next) OR $next>$next_time)
+            $next = $next_time;
+    }
+
+        if ($next){
+            if (is_null($nb_jobs_scheduled))
+                $nb_jobs_scheduled = sql_countsel('spip_jobs',"status=".intval(_JQ_SCHEDULED)." AND date<".sql_quote(date('Y-m-d H:i:s',$time)));
+            elseif ($next<=$time)
+                $nb_jobs_scheduled++;
+            // si trop de jobs en attente, on force la purge en fin de hit
+            // pour assurer le coup
+            if ($nb_jobs_scheduled>defined('_JQ_NB_JOBS_OVERFLOW')?_JQ_NB_JOBS_OVERFLOW:10000)
+                define('_DIRECT_CRON_FORCE',true);
+        }
+
+    queue_set_next_job_time($next);
+    $deja_la = false;
 }
 
 
@@ -471,27 +471,27 @@ 
  */
 function queue_set_next_job_time($next) {
 
-	// utiliser le temps courant reel plutot que temps de la requete ici
-	$time = time();
-
-	// toujours relire la valeur pour comparer, pour tenir compte des maj concourrantes
-	// et ne mettre a jour que si il y a un interet a le faire
-	// permet ausis d'initialiser le nom de fichier a coup sur
-	$curr_next = $_SERVER['REQUEST_TIME'] + max(0,queue_sleep_time_to_next_job(true));
-	if (
-			($curr_next<=$time AND $next>$time) // le prochain job est dans le futur mais pas la date planifiee actuelle
-			OR $curr_next>$next // le prochain job est plus tot que la date planifiee actuelle
-		) {
-		if (include_spip('inc/memoization') AND defined('_MEMOIZE_MEMORY') AND _MEMOIZE_MEMORY) {
-			cache_set(_JQ_NEXT_JOB_TIME_FILENAME,intval($next));
-		}
-		else {
-			ecrire_fichier(_JQ_NEXT_JOB_TIME_FILENAME,intval($next));
-		}
-		queue_sleep_time_to_next_job($next);
-	}
-
-	return queue_sleep_time_to_next_job();
+    // utiliser le temps courant reel plutot que temps de la requete ici
+    $time = time();
+
+    // toujours relire la valeur pour comparer, pour tenir compte des maj concourrantes
+    // et ne mettre a jour que si il y a un interet a le faire
+    // permet ausis d'initialiser le nom de fichier a coup sur
+    $curr_next = $_SERVER['REQUEST_TIME'] + max(0,queue_sleep_time_to_next_job(true));
+    if (
+            ($curr_next<=$time AND $next>$time) // le prochain job est dans le futur mais pas la date planifiee actuelle
+            OR $curr_next>$next // le prochain job est plus tot que la date planifiee actuelle
+        ) {
+        if (include_spip('inc/memoization') AND defined('_MEMOIZE_MEMORY') AND _MEMOIZE_MEMORY) {
+            cache_set(_JQ_NEXT_JOB_TIME_FILENAME,intval($next));
+        }
+        else {
+            ecrire_fichier(_JQ_NEXT_JOB_TIME_FILENAME,intval($next));
+        }
+        queue_sleep_time_to_next_job($next);
+    }
+
+    return queue_sleep_time_to_next_job();
 }
 
 /**
@@ -503,110 +503,110 @@ 
  * @return string
  */
 function queue_affichage_cron(){
-	$texte = "";
-
-	$time_to_next = queue_sleep_time_to_next_job();
-	// rien a faire si le prochain job est encore dans le futur
-	if ($time_to_next>0 OR defined('_DEBUG_BLOCK_QUEUE'))
-		return $texte;
-
-	// ne pas relancer si on vient de lancer dans la meme seconde par un hit concurent
-	if (file_exists($lock=_DIR_TMP."cron.lock") AND !(@filemtime($lock)<$_SERVER['REQUEST_TIME']))
-		return $texte;
-	@touch($lock);
-
-	// il y a des taches en attentes
-	// si depuis plus de 5min, on essaye de lancer le cron par tous les moyens pour rattraper le coup
-	// on est sans doute sur un site qui n'autorise pas http sortant ou avec peu de trafic
-	$urgent = false;
-	if ($time_to_next<-300)
-		$urgent = true;
-
-	$url_cron = generer_url_action('cron','',false,true);
-
-	if (!defined('_HTML_BG_CRON_FORCE') OR !_HTML_BG_CRON_FORCE){
-
-		// methode la plus rapide :
-		// Si fsockopen est possible, on lance le cron via un socket en asynchrone
-		// si fsockopen echoue (disponibilite serveur, firewall) on essaye pas cURL
-		// car on a toutes les chances d'echouer pareil mais sans moyen de le savoir
-		// on passe direct a la methode background-image
-		if(function_exists('fsockopen')){
-			$parts=parse_url($url_cron);
-
-			switch ($parts['scheme']) {
-				case 'https':
-					$scheme = 'ssl://';
-					$port = 443;
-					break;
-				case 'http':
-				default:
-					$scheme = '';
-					$port = 80;
-			}
-
-			$fp = @fsockopen($scheme.$parts['host'],
-		        isset($parts['port'])?$parts['port']:$port,
-		        $errno, $errstr, 1);
-
-			if ($fp) {
-				$timeout = 200; // ms
-				stream_set_timeout($fp,0,$timeout * 1000);
-				$query = $parts['path'].($parts['query']?"?".$parts['query']:"");
-				$out = "GET ".$query." HTTP/1.1\r\n";
-				$out.= "Host: ".$parts['host']."\r\n";
-				$out.= "Connection: Close\r\n\r\n";
-				fwrite($fp, $out);
-				spip_timer('read');
-				$t = 0;
-				// on lit la reponse si possible pour fermer proprement la connexion
-				// avec un timeout total de 200ms pour ne pas se bloquer
-				while (!feof($fp) AND $t<$timeout) {
-					@fgets($fp, 1024);
-					$t += spip_timer('read',true);
-					spip_timer('read');
-				}
-				fclose($fp);
-				if (!$urgent)
-					return $texte;
-			}
-		}
-		// si fsockopen n'est pas dispo on essaye cURL :
-		// lancer le cron par un cURL asynchrone si cURL est present
-		elseif (function_exists("curl_init")){
-			//setting the curl parameters.
-			$ch = curl_init($url_cron);
-			curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
-			// cf bug : http://www.php.net/manual/en/function.curl-setopt.php#104597
-			curl_setopt($ch, CURLOPT_NOSIGNAL, 1);
-			// valeur mini pour que la requete soit lancee
-			curl_setopt($ch, CURLOPT_TIMEOUT_MS, 200);
-			// lancer
-			curl_exec($ch);
-			// fermer
-			curl_close($ch);
-			if (!$urgent)
-				return $texte;
-		}
-	}
-
-	// si deja force, on retourne sans rien
-	if (defined('_DIRECT_CRON_FORCE'))
-		return $texte;
-
-	// si c'est un bot
-	// inutile de faire un appel par image background,
-	// on force un appel direct en fin de hit
-	if ((defined('_IS_BOT') AND _IS_BOT)){
-		define('_DIRECT_CRON_FORCE',true);
-		return $texte;
-	}
-
-	// en derniere solution, on insere une image background dans la page
-	$texte = '<!-- SPIP-CRON --><div style="background-image: url(\'' .
-		generer_url_action('cron') .
-		'\');"></div>';
-
-	return $texte;
+    $texte = "";
+
+    $time_to_next = queue_sleep_time_to_next_job();
+    // rien a faire si le prochain job est encore dans le futur
+    if ($time_to_next>0 OR defined('_DEBUG_BLOCK_QUEUE'))
+        return $texte;
+
+    // ne pas relancer si on vient de lancer dans la meme seconde par un hit concurent
+    if (file_exists($lock=_DIR_TMP."cron.lock") AND !(@filemtime($lock)<$_SERVER['REQUEST_TIME']))
+        return $texte;
+    @touch($lock);
+
+    // il y a des taches en attentes
+    // si depuis plus de 5min, on essaye de lancer le cron par tous les moyens pour rattraper le coup
+    // on est sans doute sur un site qui n'autorise pas http sortant ou avec peu de trafic
+    $urgent = false;
+    if ($time_to_next<-300)
+        $urgent = true;
+
+    $url_cron = generer_url_action('cron','',false,true);
+
+    if (!defined('_HTML_BG_CRON_FORCE') OR !_HTML_BG_CRON_FORCE){
+
+        // methode la plus rapide :
+        // Si fsockopen est possible, on lance le cron via un socket en asynchrone
+        // si fsockopen echoue (disponibilite serveur, firewall) on essaye pas cURL
+        // car on a toutes les chances d'echouer pareil mais sans moyen de le savoir
+        // on passe direct a la methode background-image
+        if(function_exists('fsockopen')){
+            $parts=parse_url($url_cron);
+
+            switch ($parts['scheme']) {
+                case 'https':
+                    $scheme = 'ssl://';
+                    $port = 443;
+                    break;
+                case 'http':
+                default:
+                    $scheme = '';
+                    $port = 80;
+            }
+
+            $fp = @fsockopen($scheme.$parts['host'],
+                isset($parts['port'])?$parts['port']:$port,
+                $errno, $errstr, 1);
+
+            if ($fp) {
+                $timeout = 200; // ms
+                stream_set_timeout($fp,0,$timeout * 1000);
+                $query = $parts['path'].($parts['query']?"?".$parts['query']:"");
+                $out = "GET ".$query." HTTP/1.1\r\n";
+                $out.= "Host: ".$parts['host']."\r\n";
+                $out.= "Connection: Close\r\n\r\n";
+                fwrite($fp, $out);
+                spip_timer('read');
+                $t = 0;
+                // on lit la reponse si possible pour fermer proprement la connexion
+                // avec un timeout total de 200ms pour ne pas se bloquer
+                while (!feof($fp) AND $t<$timeout) {
+                    @fgets($fp, 1024);
+                    $t += spip_timer('read',true);
+                    spip_timer('read');
+                }
+                fclose($fp);
+                if (!$urgent)
+                    return $texte;
+            }
+        }
+        // si fsockopen n'est pas dispo on essaye cURL :
+        // lancer le cron par un cURL asynchrone si cURL est present
+        elseif (function_exists("curl_init")){
+            //setting the curl parameters.
+            $ch = curl_init($url_cron);
+            curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
+            // cf bug : http://www.php.net/manual/en/function.curl-setopt.php#104597
+            curl_setopt($ch, CURLOPT_NOSIGNAL, 1);
+            // valeur mini pour que la requete soit lancee
+            curl_setopt($ch, CURLOPT_TIMEOUT_MS, 200);
+            // lancer
+            curl_exec($ch);
+            // fermer
+            curl_close($ch);
+            if (!$urgent)
+                return $texte;
+        }
+    }
+
+    // si deja force, on retourne sans rien
+    if (defined('_DIRECT_CRON_FORCE'))
+        return $texte;
+
+    // si c'est un bot
+    // inutile de faire un appel par image background,
+    // on force un appel direct en fin de hit
+    if ((defined('_IS_BOT') AND _IS_BOT)){
+        define('_DIRECT_CRON_FORCE',true);
+        return $texte;
+    }
+
+    // en derniere solution, on insere une image background dans la page
+    $texte = '<!-- SPIP-CRON --><div style="background-image: url(\'' .
+        generer_url_action('cron') .
+        '\');"></div>';
+
+    return $texte;
 }
 ?>

ecrire/inc/lister_objets.php

Indentation +18 added lines, -18 removed lines

@@ -26,28 +26,28 @@
  * @return string
  */
 function inc_lister_objets_dist($vue, $contexte=array(), $force=false){
-	$res = ""; // debug
-	if (!is_array($contexte))
-		return _L('$contexte doit etre un tableau dans inc/lister_objets');
-
-	$fond = "prive/objets/liste/$vue";
-	if (!find_in_path($fond."."._EXTENSION_SQUELETTES)) {
-		// traiter les cas particuliers
-		include_spip('base/connect_sql');
-		$vue = table_objet($vue);
-		$fond = "prive/objets/liste/$vue";
-		if (!find_in_path($fond."."._EXTENSION_SQUELETTES))
-			return _L("vue $vue introuvable pour lister les objets");
-	}
+    $res = ""; // debug
+    if (!is_array($contexte))
+        return _L('$contexte doit etre un tableau dans inc/lister_objets');
+
+    $fond = "prive/objets/liste/$vue";
+    if (!find_in_path($fond."."._EXTENSION_SQUELETTES)) {
+        // traiter les cas particuliers
+        include_spip('base/connect_sql');
+        $vue = table_objet($vue);
+        $fond = "prive/objets/liste/$vue";
+        if (!find_in_path($fond."."._EXTENSION_SQUELETTES))
+            return _L("vue $vue introuvable pour lister les objets");
+    }
 		
 	
-	$contexte['sinon']=($force ? $contexte['titre']:'');
+    $contexte['sinon']=($force ? $contexte['titre']:'');
 
-	$res = recuperer_fond($fond,$contexte,array('ajax'=>true));
-	if (_request('var_liste'))
-		echo var_export($contexte, true);
+    $res = recuperer_fond($fond,$contexte,array('ajax'=>true));
+    if (_request('var_liste'))
+        echo var_export($contexte, true);
 		
-	return $res;
+    return $res;
 }
 
 ?>

ecrire/inc/csv.php

Indentation +66 added lines, -66 removed lines

@@ -14,76 +14,76 @@
 
 function analyse_csv($t)
 {
-	$virg = substr_count($t, ',');
-	$pvirg = substr_count($t, ';');
-	$tab = substr_count($t, "\t");
-	if ($virg > $pvirg)
-		{ $sep = ','; $hs = ',';}
-	else	{ $sep = ';'; $hs = '&#59;'; $virg = $pvirg;}
-	if ($tab > $virg) {$sep = "\t"; $hs = "\t";}
+    $virg = substr_count($t, ',');
+    $pvirg = substr_count($t, ';');
+    $tab = substr_count($t, "\t");
+    if ($virg > $pvirg)
+        { $sep = ','; $hs = ',';}
+    else	{ $sep = ';'; $hs = '&#59;'; $virg = $pvirg;}
+    if ($tab > $virg) {$sep = "\t"; $hs = "\t";}
 
-	$t = preg_replace('/\r?\n/', "\n",
-				      preg_replace('/[\r\n]+/', "\n", $t));
-	// un separateur suivi de 3 guillemets attention !
-	// attention au ; suceptible d'etre confondu avec un separateur
-	// on substitue un # et on remplacera a la fin
-	$t = preg_replace("/([\n$sep])\"\"\"/",'\\1"&#34#',$t);
-	$t = str_replace('""','&#34#',$t);
-	preg_match_all('/"[^"]*"/', $t, $r);
-	foreach($r[0] as $cell)
-		$t = str_replace($cell,
-			str_replace($sep, $hs,
-				str_replace("\n", "<br />",
-					    substr($cell,1,-1))),
-			$t);
-	list($entete, $corps) = explode("\n",$t,2);
-	$caption = '';
-	// sauter la ligne de tete formee seulement de separateurs
-	if (substr_count($entete, $sep) == strlen($entete)) {
-		list($entete, $corps) = explode("\n",$corps,2);
-	}
-	// si une seule colonne, en faire le titre
-	if (preg_match("/^([^$sep]+)$sep+\$/", $entete, $l)) {
-			$caption = "\n||" .  $l[1] . "|";
-			list($entete, $corps) = explode("\n",$corps,2);
-	}
-	// si premiere colonne vide, le raccourci doit quand meme produire <th...
-	if ($entete[0] == $sep) $entete = ' ' . $entete;
+    $t = preg_replace('/\r?\n/', "\n",
+                        preg_replace('/[\r\n]+/', "\n", $t));
+    // un separateur suivi de 3 guillemets attention !
+    // attention au ; suceptible d'etre confondu avec un separateur
+    // on substitue un # et on remplacera a la fin
+    $t = preg_replace("/([\n$sep])\"\"\"/",'\\1"&#34#',$t);
+    $t = str_replace('""','&#34#',$t);
+    preg_match_all('/"[^"]*"/', $t, $r);
+    foreach($r[0] as $cell)
+        $t = str_replace($cell,
+            str_replace($sep, $hs,
+                str_replace("\n", "<br />",
+                        substr($cell,1,-1))),
+            $t);
+    list($entete, $corps) = explode("\n",$t,2);
+    $caption = '';
+    // sauter la ligne de tete formee seulement de separateurs
+    if (substr_count($entete, $sep) == strlen($entete)) {
+        list($entete, $corps) = explode("\n",$corps,2);
+    }
+    // si une seule colonne, en faire le titre
+    if (preg_match("/^([^$sep]+)$sep+\$/", $entete, $l)) {
+            $caption = "\n||" .  $l[1] . "|";
+            list($entete, $corps) = explode("\n",$corps,2);
+    }
+    // si premiere colonne vide, le raccourci doit quand meme produire <th...
+    if ($entete[0] == $sep) $entete = ' ' . $entete;
 
-	$lignes = explode("\n", $corps);
+    $lignes = explode("\n", $corps);
 
-	// retrait des lignes vides finales
-	while(count($lignes) > 0
-	AND preg_match("/^$sep*$/", $lignes[count($lignes)-1]))
-	  unset($lignes[count($lignes)-1]);
-	//  calcul du  nombre de colonne a chaque ligne
-	$nbcols = array();
-	$max = $mil = substr_count($entete, $sep);
-	foreach($lignes as $k=>$v) {
-	  if ($max <> ($nbcols[$k]= substr_count($v, $sep))) {
-	    if ($max > $nbcols[$k])
-	      $mil = $nbcols[$k];
-	    else { $mil = $max; $max = $nbcols[$k];}
-	  }
-	}
-	// Si pas le meme nombre, cadrer au nombre max
-	if ($mil <> $max)
-	  foreach($nbcols as $k=>$v) {
-	    if ($v < $max) $lignes[$k].= str_repeat($sep, $max-$v);
-	    }
-	// et retirer les colonnes integralement vides
-	while(true) {
-	  $nbcols =  ($entete[strlen($entete)-1]===$sep);
-	  foreach($lignes as $v) $nbcols &= ($v[strlen($v)-1]===$sep);
-	  if (!$nbcols) break;
-	  $entete = substr($entete,0,-1);
-	  foreach($lignes as $k=>$v) $lignes[$k] = substr($v,0,-1);
-	}
+    // retrait des lignes vides finales
+    while(count($lignes) > 0
+    AND preg_match("/^$sep*$/", $lignes[count($lignes)-1]))
+        unset($lignes[count($lignes)-1]);
+    //  calcul du  nombre de colonne a chaque ligne
+    $nbcols = array();
+    $max = $mil = substr_count($entete, $sep);
+    foreach($lignes as $k=>$v) {
+        if ($max <> ($nbcols[$k]= substr_count($v, $sep))) {
+        if ($max > $nbcols[$k])
+            $mil = $nbcols[$k];
+        else { $mil = $max; $max = $nbcols[$k];}
+        }
+    }
+    // Si pas le meme nombre, cadrer au nombre max
+    if ($mil <> $max)
+        foreach($nbcols as $k=>$v) {
+        if ($v < $max) $lignes[$k].= str_repeat($sep, $max-$v);
+        }
+    // et retirer les colonnes integralement vides
+    while(true) {
+        $nbcols =  ($entete[strlen($entete)-1]===$sep);
+        foreach($lignes as $v) $nbcols &= ($v[strlen($v)-1]===$sep);
+        if (!$nbcols) break;
+        $entete = substr($entete,0,-1);
+        foreach($lignes as $k=>$v) $lignes[$k] = substr($v,0,-1);
+    }
 
-	foreach($lignes as &$l) {
-		$l = explode($sep, $l);
-	}
-	return array(explode($sep, $entete), $lignes);
+    foreach($lignes as &$l) {
+        $l = explode($sep, $l);
+    }
+    return array(explode($sep, $entete), $lignes);
 }
 
 

ecrire/inc/lien_court.php

Indentation +6 added lines, -6 removed lines

@@ -20,14 +20,14 @@
  * http://zoumzamzouilam/truc/chose/machin..."
  */
 function inc_lien_court($url) {
-	$long_url = defined('_MAX_LONG_URL') ? _MAX_LONG_URL : 40;
-	$coupe_url = defined('_MAX_COUPE_URL') ? _MAX_COUPE_URL : 35;
+    $long_url = defined('_MAX_LONG_URL') ? _MAX_LONG_URL : 40;
+    $coupe_url = defined('_MAX_COUPE_URL') ? _MAX_COUPE_URL : 35;
 
-	if (strlen($url)>$long_url) {
-		$url = substr($url,0,$coupe_url).'...';
-	}
+    if (strlen($url)>$long_url) {
+        $url = substr($url,0,$coupe_url).'...';
+    }
 
-	return $url;
+    return $url;
 }
 
 ?>
\ No newline at end of file