include/emails.inc.php

   1 <?php
   2 /***************************************************************************
   3  *  Copyright (C) 2003-2006 Polytechnique.org                              *
   4  *  http://opensource.polytechnique.org/                                   *
   5  *                                                                         *
   6  *  This program is free software; you can redistribute it and/or modify   *
   7  *  it under the terms of the GNU General Public License as published by   *
   8  *  the Free Software Foundation; either version 2 of the License, or      *
   9  *  (at your option) any later version.                                    *
  10  *                                                                         *
  11  *  This program is distributed in the hope that it will be useful,        *
  12  *  but WITHOUT ANY WARRANTY; without even the implied warranty of         *
  13  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the          *
  14  *  GNU General Public License for more details.                           *
  15  *                                                                         *
  16  *  You should have received a copy of the GNU General Public License      *
  17  *  along with this program; if not, write to the Free Software            *
  18  *  Foundation, Inc.,                                                      *
  19  *  59 Temple Place, Suite 330, Boston, MA  02111-1307  USA                *
  20  ***************************************************************************/
  21
  22 require_once("xorg.misc.inc.php");
  23
  24 // {{{ defines
  25
  26 define("SUCCESS", 1);
  27 define("ERROR_INACTIVE_REDIRECTION", 2);
  28 define("ERROR_INVALID_EMAIL", 3);
  29 define("ERROR_LOOP_EMAIL", 4);
  30
  31 // }}}
  32 // {{{ function fix_bestalias()
  33
  34 function fix_bestalias($uid)
  35 {
  36     $res = XDB::query("SELECT COUNT(*) FROM aliases WHERE id={?} AND FIND_IN_SET('bestalias',flags) AND type!='homonyme'", $uid);
  37     if ($n = $res->fetchOneCell()) {
  38         return;
  39     }
  40     XDB::execute("UPDATE  aliases
  41                                SET  flags=CONCAT(flags,',','bestalias')
  42                              WHERE  id={?} AND type!='homonyme'
  43                           ORDER BY  !FIND_IN_SET('usage',flags),alias LIKE '%.%', LENGTH(alias)
  44                              LIMIT  1", $uid);
  45 }
  46
  47 // }}}
  48 // {{{ function valide_email()
  49
  50 function valide_email($str)
  51 {
  52     global $globals;
  53
  54     $em = trim(rtrim($str));
  55     $em = str_replace('<', '', $em);
  56     $em = str_replace('>', '', $em);
  57     list($ident, $dom) = explode('@', $em);
  58     if ($dom == $globals->mail->domain or $dom == $globals->mail->domain2) {
  59         list($ident1) = explode('_', $ident);
  60         list($ident) = explode('+', $ident1);
  61     }
  62     return $ident . '@' . $dom;
  63 }
  64
  65 // }}}
  66 // {{{ class Bogo
  67
  68 class Bogo
  69 {
  70     // {{{ properties
  71
  72     var $state;
  73     var $_states = Array('let_spams', 'tag_spams', 'tag_and_drop_spams', 'drop_spams');
  74
  75     // }}}
  76     // {{{ constructor
  77
  78     function Bogo($uid)
  79     {
  80         $res = XDB::query('SELECT email FROM emails WHERE uid={?} AND flags="filter"', $uid);
  81         if ($res->numRows()) {
  82             $this->state = $res->fetchOneCell();
  83         } else {
  84             $this->state = 'tag_and_drop_spams';
  85             $res = XDB::query("INSERT INTO emails (uid,email,rewrite,panne,flags)
  86                                               VALUES ({?},'tag_and_drop_spams','','0000-00-00','filter')", $uid);
  87         }
  88     }
  89
  90     // }}}
  91     // {{{ function change()
  92
  93     function change($uid, $state)
  94     {
  95         $this->state = is_int($state) ? $this->_states[$state] : $state;
  96         XDB::execute('UPDATE emails SET email={?} WHERE uid={?} AND flags = "filter"',
  97                      $this->state, $uid);
  98     }
  99
 100     // }}}
 101     // {{{ function level()
 102
 103     function level()
 104     { return array_search($this->state, $this->_states); }
 105
 106     // }}}
 107 }
 108
 109 // }}}
 110 // {{{ class Email
 111
 112 class Email
 113 {
 114     // {{{ properties
 115
 116     var $email;
 117     var $active;
 118     var $broken;
 119     var $rewrite;
 120     var $panne;
 121     var $last;
 122     var $panne_level;
 123
 124     // }}}
 125     // {{{ constructor
 126
 127     function Email($row)
 128     {
 129         list($this->email, $flags, $this->rewrite, $this->panne, $this->last, $this->panne_level) = $row;
 130         $this->active = ($flags == 'active');
 131         $this->broken = ($flags == 'panne');
 132     }
 133
 134     // }}}
 135     // {{{ function activate()
 136
 137     function activate($uid)
 138     {
 139         if (!$this->active) {
 140             XDB::execute("UPDATE  emails
 141                              SET  panne_level = IF(flags = 'panne', panne_level - 1, panne_level),
 142                                   flags = 'active'
 143                            WHERE  uid={?} AND email={?}", $uid, $this->email);
 144             $_SESSION['log']->log("email_on", $this->email.($uid!=S::v('uid') ? "(admin on $uid)" : ""));
 145             $this->active = true;
 146             $this->broken = false;
 147         }
 148     }
 149
 150     // }}}
 151     // {{{ function deactivate()
 152
 153     function deactivate($uid)
 154     {
 155         if ($this->active) {
 156             XDB::execute("UPDATE  emails SET flags =''
 157                                      WHERE  uid={?} AND email={?}", $uid, $this->email);
 158                 $_SESSION['log']->log("email_off",$this->email.($uid!=S::v('uid') ? "(admin on $uid)" : "") );
 159             $this->active = false;
 160         }
 161     }
 162
 163     // }}}
 164     // {{{ function rewrite()
 165
 166     function rewrite($rew, $uid)
 167     {
 168         if ($this->rewrite == $rew) {
 169             return;
 170         }
 171             XDB::execute('UPDATE emails SET rewrite={?} WHERE uid={?} AND email={?}', $rew, $uid, $this->email);
 172         $this->rewrite = $rew;
 173             return;
 174     }
 175
 176     // }}}
 177 }
 178
 179 // }}}
 180 // {{{ class Redirect
 181
 182 class Redirect
 183 {
 184     // {{{ properties
 185
 186     var $flag_active = 'active';
 187     var $emails;
 188     var $bogo;
 189     var $uid;
 190
 191     // }}}
 192     // {{{ function Redirect()
 193
 194     function Redirect($_uid)
 195     {
 196         $this->uid=$_uid;
 197         $res = XDB::iterRow("
 198                 SELECT email, flags, rewrite, panne, last, panne_level
 199                   FROM emails WHERE uid = {?} AND flags != 'filter'", $_uid);
 200         $this->emails=Array();
 201         while ($row = $res->next()) {
 202                 $this->emails[] = new Email($row);
 203         }
 204         $this->bogo = new Bogo($_uid);
 205     }
 206
 207     // }}}
 208     // {{{ function other_active()
 209
 210     function other_active($email)
 211     {
 212         foreach ($this->emails as $mail) {
 213             if ($mail->email!=$email && $mail->active) {
 214                 return true;
 215             }
 216         }
 217         return false;
 218     }
 219
 220     // }}}
 221     // {{{ function delete_email()
 222
 223     function delete_email($email)
 224     {
 225         if (!$this->other_active($email)) {
 226             return ERROR_INACTIVE_REDIRECTION;
 227         }
 228         XDB::execute('DELETE FROM emails WHERE uid={?} AND email={?}', $this->uid, $email);
 229         $_SESSION['log']->log('email_del',$email.($this->uid!=S::v('uid') ? " (admin on {$this->uid})" : ""));
 230             foreach ($this->emails as $i=>$mail) {
 231                 if ($email==$mail->email) {
 232                 unset($this->emails[$i]);
 233             }
 234         }
 235         return SUCCESS;
 236     }
 237
 238     // }}}
 239     // {{{ function add_email()
 240
 241     function add_email($email)
 242     {
 243         $email_stripped = strtolower(trim($email));
 244         if (!isvalid_email($email_stripped)) {
 245             return ERROR_INVALID_EMAIL;
 246         }
 247         if (!isvalid_email_redirection($email_stripped)) {
 248             return ERROR_LOOP_EMAIL;
 249         }
 250         XDB::execute('REPLACE INTO emails (uid,email,flags) VALUES({?},{?},"active")', $this->uid, $email);
 251             if ($logger = S::v('log', null)) { // may be absent --> step4.php
 252                 $logger->log('email_add',$email.($this->uid!=S::v('uid') ? " (admin on {$this->uid})" : ""));
 253         }
 254         foreach ($this->emails as $mail) {
 255                 if ($mail->email == $email_stripped) {
 256                 return SUCCESS;
 257             }
 258             }
 259         $this->emails[] = new Email(array($email,1,'','0000-00-00'));
 260
 261         // security stuff
 262         $res = XDB::query("SELECT state, description
 263                              FROM emails_watch
 264                             WHERE state != 'safe' AND email = {?}", $email);
 265         if ($res->numRows()) {
 266             $row = $res->fetchOneAssoc();
 267             $message = "L'email $email vient d'être ajouté aux redirections de ". S::v('forlife')
 268                      . ". Cette adresse est surveillée avec l'état *" . $row['state']
 269                      . "* et la description :\n" . $row['description'];
 270             $message = wordwrap($message);
 271             require_once("diogenes/diogenes.hermes.inc.php");
 272             $mailer = new HermesMailer();
 273             $mailer->setFrom("webmaster@polytechnique.org");
 274             $mailer->addTo("hotliners@staff.polytechnique.org");
 275             $mailer->setSubject("ALERTE LORS DE L'AJOUT DE REDIRECTION de "
 276                 . S::v('prenom') . ' ' . S::v('nom') . '(' . S::v('promo') . ')');
 277             $mailer->setTxtBody($message
 278                 . "\n\nInformations de connexion :\n" . var_export($_SERVER, true));
 279             $mailer->send();
 280         }
 281         return SUCCESS;
 282     }
 283
 284     // }}}
 285     // {{{ function modify_email()
 286
 287     function modify_email($emails_actifs,$emails_rewrite)
 288     {
 289             foreach ($this->emails as $i=>$mail) {
 290             if (in_array($mail->email,$emails_actifs)) {
 291                 $this->emails[$i]->activate($this->uid);
 292                 } else {
 293                 $this->emails[$i]->deactivate($this->uid);
 294                 }
 295                 $this->emails[$i]->rewrite($emails_rewrite[$mail->email], $this->uid);
 296         }
 297     }
 298
 299     function modify_one_email($email, $activate) {
 300         foreach ($this->emails as $i=>$mail) {
 301             if ($mail->email == $email) {
 302                 if ($activate)
 303                     $this->emails[$i]->activate($this->uid);
 304                 else
 305                     $this->emails[$i]->deactivate($this->uid);
 306             }
 307         }
 308     }
 309
 310     // }}}
 311 }
 312
 313 // }}}
 314
 315 // vim:set et sw=4 sts=4 sws=4 foldmethod=marker:
 316 ?>