www/plugins/notifications2/notifications_pipelines.php

   1 <?php
   2 /*
   3  * Plugin Notifications
   4  * (c) 2009-2012 SPIP
   5  * Distribue sous licence GPL
   6  *
   7  */
   8
   9 if (!defined("_ECRIRE_INC_VERSION")) return;
  10
  11 /**
  12  *
  13  * Declarer la tache cron de notification lente (messagerie de l'espace prive)
  14  * @param array $taches_generales
  15  * @return array
  16  */
  17 function notifications_taches_generales_cron($taches_generales){
  18         $taches_generales['notifications'] = 60*10; // toutes les 10 minutes
  19         return $taches_generales;
  20 }
  21
  22 $GLOBALS['notifications_post_edition']['spip_signatures'] = "petitionsignee";
  23
  24 // Initialise les reglages sous forme de tableau
  25 function notifications_go($x){
  26         if (!is_array($GLOBALS['notifications'] = @unserialize($GLOBALS['meta']['notifications'])))
  27                 $GLOBALS['notifications'] = array();
  28         return $x;
  29 }
  30
  31
  32 /**
  33  * Pipeline post-edition
  34  * pour permettre de se pluger sur une modification en base non notifiee par defaut
  35  *
  36  * @param array $x
  37  * @return array
  38  */
  39 function notifications_post_edition($x){
  40         #spip_log($x,'notifications');
  41         if (isset($x['args']['table'])
  42                 AND $quoi = $GLOBALS['notifications_post_edition'][$x['args']['table']]
  43         ){
  44                 // repasser par l'entree principale
  45                 $notifications = charger_fonction('notifications', 'inc');
  46                 $notifications($quoi, $x['args']['id_objet'], array());
  47         }
  48
  49         return $x;
  50 }
  51
  52 /**
  53  * Ajouter des destinataires dans une notification en lot
  54  *
  55  * @param array $flux
  56  * @return array
  57  */
  58 function notifications_notifications_destinataires($flux){
  59         static $sent = array();
  60         $quoi = $flux['args']['quoi'];
  61         $options = $flux['args']['options'];
  62
  63         // proposition d'article prevenir les admins restreints
  64         if ($quoi=='instituerarticle' AND $GLOBALS['notifications']['prevenir_admins_restreints']
  65                 AND $options['statut']=='prop' AND $options['statut_ancien']!='publie' // ligne a commenter si vous voulez prevenir de la publication
  66         ){
  67
  68                 $id_article = $flux['args']['id'];
  69                 include_spip('base/abstract_sql');
  70                 $t = sql_fetsel("id_rubrique", "spip_articles", "id_article=" . intval($id_article));
  71                 $id_rubrique = $t['id_rubrique'];
  72
  73                 while ($id_rubrique){
  74                         $hierarchie[] = $id_rubrique;
  75                         $res = sql_fetsel("id_parent", "spip_rubriques", "id_rubrique=" . intval($id_rubrique));
  76                         if (!$res){ // rubrique inexistante
  77                                 $id_rubrique = 0;
  78                                 break;
  79                         }
  80                         $id_parent = $res['id_parent'];
  81                         $id_rubrique = $id_parent;
  82                 }
  83                 spip_log("Prop article > admin restreint de " . join(',', $hierarchie), 'notifications');
  84
  85                 //les admins de la rub et de ses parents
  86                 $result_email = sql_select(
  87                         "auteurs.email,auteurs.id_auteur,lien.id_objet as id_rubrique",
  88                         "spip_auteurs AS auteurs JOIN spip_auteurs_liens AS lien ON auteurs.id_auteur=lien.id_auteur ",
  89                         "lien.objet='rubrique' AND ".sql_in('lien.id_objet',sql_quote($hierarchie))." AND auteurs.statut='0minirezo'");
  90
  91                 while ($qui = sql_fetch($result_email)){
  92                         spip_log($options['statut'] . " article > admin restreint " . $qui['id_auteur'] . " de la rubrique" . $qui['id_rubrique'] . " prevenu", 'notifications');
  93                         $flux['data'][] = $qui['email'];
  94                 }
  95
  96         }
  97
  98         // publication d'article : prevenir les auteurs
  99         if ($quoi=='instituerarticle'
 100                 AND $GLOBALS['notifications']['prevenir_auteurs_articles']
 101         ){
 102                 $id_article = $flux['args']['id'];
 103
 104
 105                 include_spip('base/abstract_sql');
 106
 107                 // Qui va-t-on prevenir en plus ?
 108                 $result_email = sql_select(
 109                         "auteurs.email",
 110                         "spip_auteurs AS auteurs JOIN spip_auteurs_liens AS lien ON auteurs.id_auteur=lien.id_auteur",
 111                         "lien.id_objet=".intval($id_article)." AND lien.objet='article'");
 112
 113                 while ($qui = sql_fetch($result_email)){
 114                         $flux['data'][] = $qui['email'];
 115                         spip_log($options['statut'] . " article > auteur " . $qui['id_auteur'] . " prevenu", 'notifications');
 116                 }
 117
 118         }
 119
 120         // forum valide ou prive : prevenir les autres contributeurs du thread
 121         if (($quoi=='forumprive' AND $GLOBALS['notifications']['thread_forum_prive'])
 122                 OR ($quoi=='forumvalide' AND $GLOBALS['notifications']['thread_forum'])
 123         ){
 124
 125                 $id_forum = $flux['args']['id'];
 126
 127                 if ($t = $options['forum']
 128                         OR $t = sql_fetsel("*", "spip_forum", "id_forum=" . intval($id_forum))
 129                 ){
 130
 131                         // Tous les participants a ce *thread*, abonnes
 132                         // on prend les emails parmi notification_email (prioritaire si rempli) email_auteur ou email de l'auteur qd id_auteur connu
 133                         $s = sql_select("F.email_auteur, F.notification_email, A.email",
 134                                 "spip_forum AS F LEFT JOIN spip_auteurs AS A ON F.id_auteur=A.id_auteur",
 135                                 "notification=1 AND id_thread=" . intval($t['id_thread']) . " AND (email_auteur != '' OR notification_email != '' OR A.email IS NOT NULL )");
 136                         while ($r = sql_fetch($s)){
 137                                 if ($r['notification_email'])
 138                                         $flux['data'][] = $r['notification_email'];
 139                                 elseif($r['email_auteur'])
 140                                         $flux['data'][] = $r['email_auteur'];
 141                                 elseif($r['email'])
 142                                         $flux['data'][] = $r['email'];
 143                         }
 144
 145                         /*
 146                         // 3. Tous les auteurs des messages qui precedent (desactive egalement)
 147                         // (possibilite exclusive de la possibilite precedente)
 148                         // TODO: est-ce utile, par rapport au thread ?
 149                         else if (defined('_SUIVI_FORUMS_REPONSES')
 150                         AND _SUIVI_FORUMS_REPONSES) {
 151                                 $id_parent = $id_forum;
 152                                 while ($r = spip_fetch_array(spip_query("SELECT email_auteur, id_parent FROM spip_forum WHERE id_forum=$id_parent AND statut='publie'"))) {
 153                                         $tous[] = $r['email_auteur'];
 154                                         $id_parent = $r['id_parent'];
 155                                 }
 156                         }
 157                         */
 158                 }
 159         }
 160
 161         // Les moderateurs de forums public
 162         if ($quoi=='forumposte' AND $GLOBALS['notifications']['moderateurs_forum']){
 163                 foreach (explode(',', $GLOBALS['notifications']['moderateurs_forum']) as $m){
 164                         $flux['data'][] = $m;
 165                 }
 166         }
 167
 168         // noter les envois de ce forum pour ne pas doublonner
 169         if (in_array($quoi, array('forumposte', 'forumvalide', 'forumprive'))
 170                 AND $id = $flux['args']['id']
 171         ){
 172                 if (isset($sent[$id])){
 173                         $flux['data'] = array_diff($flux['data'], $sent[$id]);
 174                 } else {
 175                         $sent[$id] = array();
 176                 }
 177                 $sent[$id] = array_merge($sent[$id], $flux['data']);
 178         }
 179
 180         return $flux;
 181 }
 182
 183
 184 /**
 185  * Pipeline notifications_envoyer_mails
 186  * appele a chaque envoi de mails
 187  * permet de gerer les contributeurs :
 188  *  - inscription auto si activee
 189  *  - url de suivi des forums
 190  *
 191  * @param array $flux
 192  * @return array
 193  */
 194 /*
 195 function notifications_notifications_envoyer_mails($flux){
 196         if ($GLOBALS['notifications']['suivi']){
 197
 198                 // ajouter un acces a la page de suivi
 199                 $url = url_absolue(generer_url_public('suivi', 'email=' . $flux['email']));
 200                 $flux['texte'] .= "\n\n" . _L('Gerer mes abonnements : ') . $url;
 201
 202                 // ajouter les auteurs en base ?
 203                 // ici ou dans la page de suivi lorsqu'ils essayent vraiment de gerer
 204                 // leurs abonnements ?
 205                 // $a = notifications_creer_auteur($email);
 206         }
 207
 208         return $flux;
 209 }
 210 */
 211
 212 function notifications_url_suivi($email){
 213         if (!$email) return "";
 214         include_spip("inc/securiser_action");
 215         $key = calculer_cle_action("abonner_notifications $email");
 216         $url = url_absolue(generer_url_public('notifications', "email=$email&key=$key"));
 217         return $url;
 218 }
 219
 220 /**
 221  * Regarder si l'auteur est dans la base de donnees, sinon l'ajouter
 222  * comme s'il avait demande a s'inscrire comme visiteur
 223  * Pour l'historique il faut retrouver le nom de la personne,
 224  * pour ca on va regarder dans les forums existants
 225  * Si c'est la personne connectee, c'est plus facile
 226  *
 227  * @param string $email
 228  * @return array|bool
 229  */
 230 function notifications_creer_auteur($email){
 231
 232         include_spip('base/abstract_sql');
 233         if (!$a = sql_fetsel('*', 'spip_auteurs', 'email=' . sql_quote($email))){
 234                 if ($GLOBALS['visiteur_session']['session_email']===$email
 235                         AND isset($GLOBALS['visiteur_session']['session_nom'])
 236                 ){
 237                         $nom = $GLOBALS['visiteur_session']['session_nom'];
 238                 } else {
 239                         if ($b = sql_fetsel('auteur', 'spip_forum',
 240                                 'email_auteur=' . sql_quote($email) . ' AND auteur!=""',
 241                                 /* groupby */
 242                                 '', /* orderby */
 243                                 array('date_heure DESC'),
 244                                 /* limit */
 245                                 '1')
 246                         ){
 247                                 $nom = $b['auteur'];
 248                         } else {
 249                                 $nom = $email;
 250                         }
 251                 }
 252                 // charger message_inscription()
 253                 if ($traiter = charger_fonction('traiter', 'formulaires/inscription', true)){
 254                         // "pirater" les globals
 255                         $_GET['nom_inscription'] = $nom;
 256                         $_GET['email_inscription'] = $email;
 257                         $a = $traiter('6forum', null);
 258                 }
 259                 if (!is_array($a)){
 260                         spip_log("erreur sur la creation d'auteur: $a", 'notifications');
 261                         next;
 262                 }
 263         }
 264
 265         // lui donner un cookie_oubli s'il n'en a pas deja un
 266         if (!isset($a['cookie_oubli'])){
 267                 include_spip('inc/acces'); # pour creer_uniqid
 268                 $a['cookie_oubli'] = creer_uniqid();
 269                 sql_updateq('spip_auteurs',
 270                         array('cookie_oubli' => $a['cookie_oubli']),
 271                         'id_auteur=' . $a['id_auteur']
 272                 );
 273         }
 274
 275         return $a;
 276 }
 277
 278 /**
 279  * Pretraiter le mail/sujet quand il est au format html
 280  * pour la fonction notifications_envoyer_mails qui ne sait traiter que les mails html
 281  *
 282  * @param string $email
 283  * @param $texte_ou_html
 284  */
 285 function notifications_envoyer_mails_texte_ou_html($email, $texte_ou_html){
 286         $texte_ou_html = trim($texte_ou_html);
 287
 288         // tester si le mail est deja en html
 289         if (substr($texte_ou_html,0,1)=="<"
 290           AND substr($texte_ou_html,-1,1)==">"
 291           AND stripos($texte_ou_html,"</html>")!==false){
 292
 293                 // dans ce cas on ruse un peu : extraire le sujet du title
 294                 $sujet = "";
 295                 if (preg_match(",<title>(.*)</title>,Uims",$texte_ou_html,$m))
 296                         $sujet = $m[1];
 297
 298                 // et envoyer un content-type pour envoyer_mail
 299                 return notifications_envoyer_mails($email, $texte_ou_html, $sujet, "","Content-Type: text/html\n");
 300         }
 301         else
 302                 // texte brut, on passe
 303                 return notifications_envoyer_mails($email, $texte_ou_html);
 304 }
 305
 306 /* TODO
 307         // Envoyer un message de bienvenue/connexion au posteur du forum,
 308         // dans le cas ou il ne s'est pas authentifie
 309         // Souci : ne pas notifier comme ca si on est deja present dans le thread
 310         // (eviter d'avoir deux notificaitons pour ce message qu'on a, dans 99,99%
 311         // des cas, poste nous-memes !)
 312         if (strlen(trim($t['email_auteur']))
 313         AND email_valide($t['email_auteur'])
 314         AND !$GLOBALS['visiteur_session']['id_auteur']) {
 315                 $msg = Notifications_jeuneposteur($t, $email);
 316                 if ($t['email_auteur'] == 'fil@rezo.net')
 317                         notifications_envoyer_mails($t['email_auteur'], $msg['body'],$msg['subject'])
 318         }
 319 */
 320
 321
 322 /*
 323 // Creer un mail pour les forums envoyes par quelqu'un qui n'est pas authentifie
 324 // en lui souhaitant la bienvenue et avec un lien suivi&p= de connexion au site
 325 function Notifications_jeuneposteur($t, $email) {
 326         return array('test', 'coucou');
 327 }
 328 */
 329
 330 ?>