[platal.git] / include / emails.inc.php

<?php
/***************************************************************************
 *  Copyright (C) 2003-2007 Polytechnique.org                              *
 *  http://opensource.polytechnique.org/                                   *
 *                                                                         *
 *  This program is free software; you can redistribute it and/or modify   *
 *  it under the terms of the GNU General Public License as published by   *
 *  the Free Software Foundation; either version 2 of the License, or      *
 *  (at your option) any later version.                                    *
 *                                                                         *
 *  This program is distributed in the hope that it will be useful,        *
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of         *
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the          *
 *  GNU General Public License for more details.                           *
 *                                                                         *
 *  You should have received a copy of the GNU General Public License      *
 *  along with this program; if not, write to the Free Software            *
 *  Foundation, Inc.,                                                      *
 *  59 Temple Place, Suite 330, Boston, MA  02111-1307  USA                *
 ***************************************************************************/

require_once("xorg.misc.inc.php");

// {{{ defines

define("SUCCESS", 1);
define("ERROR_INACTIVE_REDIRECTION", 2);
define("ERROR_INVALID_EMAIL", 3);
define("ERROR_LOOP_EMAIL", 4);

// }}}
// {{{ function fix_bestalias()

function fix_bestalias($uid)
{
    $res = XDB::query("SELECT COUNT(*) FROM aliases WHERE id={?} AND FIND_IN_SET('bestalias',flags) AND type!='homonyme'", $uid);
    if ($n = $res->fetchOneCell()) {
        return;
    }
    XDB::execute("UPDATE  aliases
                               SET  flags=CONCAT(flags,',','bestalias')
                 WHERE  id={?} AND type!='homonyme'
                  ORDER BY  !FIND_IN_SET('usage',flags),alias LIKE '%.%', LENGTH(alias)
                     LIMIT  1", $uid);
}

// }}}
// {{{ function valide_email()

function valide_email($str)
{
    global $globals;

    $em = trim(rtrim($str));
    $em = str_replace('<', '', $em);
    $em = str_replace('>', '', $em);
    list($ident, $dom) = explode('@', $em);
    if ($dom == $globals->mail->domain or $dom == $globals->mail->domain2) {
        list($ident1) = explode('_', $ident);
        list($ident) = explode('+', $ident1);
    }
    return $ident . '@' . $dom;
}

// }}}
// {{{ class Bogo

class Bogo
{
    // {{{ properties

    var $state;
    var $_states = Array('let_spams', 'tag_spams', 'tag_and_drop_spams', 'drop_spams');

    // }}}
    // {{{ constructor

    function Bogo($uid)
    {
        if (!$uid) {
            return;
        }
        $res = XDB::query('SELECT email FROM emails WHERE uid={?} AND flags="filter"', $uid);
        if ($res->numRows()) {
                $this->state = $res->fetchOneCell();
        } else {
            $this->state = 'tag_and_drop_spams';
            $res = XDB::query("INSERT INTO emails (uid,email,rewrite,panne,flags)
                                    VALUES ({?},'tag_and_drop_spams','','0000-00-00','filter')", $uid);
        }
    }

    // }}}
    // {{{ function change()

    function change($uid, $state)
    {
    $this->state = is_int($state) ? $this->_states[$state] : $state;
    XDB::execute('UPDATE emails SET email={?} WHERE uid={?} AND flags = "filter"',
                     $this->state, $uid);
    }

    // }}}
    // {{{ function level()

    function level()
    { return array_search($this->state, $this->_states); }

    // }}}
}

// }}}
// {{{ class Email

class Email
{
    // {{{ properties
    
    var $email;
    var $active;
    var $broken;
    var $rewrite;
    var $panne;
    var $last;
    var $panne_level;

    // }}}
    // {{{ constructor

    function Email($row)
    {
        list($this->email, $flags, $this->rewrite, $this->panne, $this->last, $this->panne_level) = $row;
        $this->active = ($flags == 'active');
        $this->broken = ($flags == 'panne');
    }

    // }}}
    // {{{ function activate()

    function activate($uid)
    {
        if (!$this->active) {
            XDB::execute("UPDATE  emails
                             SET  panne_level = IF(flags = 'panne', panne_level - 1, panne_level),
                                  flags = 'active'
                           WHERE  uid={?} AND email={?}", $uid, $this->email);
        $_SESSION['log']->log("email_on", $this->email.($uid!=S::v('uid') ? "(admin on $uid)" : ""));
            $this->active = true;
            $this->broken = false;
        }
    }

    // }}}
    // {{{ function deactivate()

    function deactivate($uid)
    {
        if ($this->active) {
            XDB::execute("UPDATE  emails SET flags =''
                     WHERE  uid={?} AND email={?}", $uid, $this->email);
            $_SESSION['log']->log("email_off",$this->email.($uid!=S::v('uid') ? "(admin on $uid)" : "") );
            $this->active = false;
        }
    }
    
    // }}}
    // {{{ function rewrite()

    function rewrite($rew, $uid)
    {
        if ($this->rewrite == $rew) {
            return;
        }
        XDB::execute('UPDATE emails SET rewrite={?} WHERE uid={?} AND email={?}', $rew, $uid, $this->email);
        $this->rewrite = $rew;
        return;
    }

    // }}}
}

// }}}
// {{{ class Redirect

class Redirect
{
    // {{{ properties
    
    var $flag_active = 'active';
    var $emails;
    var $bogo;
    var $uid;

    // }}}
    // {{{ function Redirect()

    function Redirect($_uid)
    {
        $this->uid=$_uid;
        $res = XDB::iterRow("
            SELECT email, flags, rewrite, panne, last, panne_level
              FROM emails WHERE uid = {?} AND flags != 'filter'", $_uid);
        $this->emails=Array();
        while ($row = $res->next()) {
            $this->emails[] = new Email($row);
        }
        $this->bogo = new Bogo($_uid);
    }

    // }}}
    // {{{ function other_active()

    function other_active($email)
    {
        foreach ($this->emails as $mail) {
            if ($mail->email!=$email && $mail->active) {
                return true;
            }
        }
        return false;
    }

    // }}}
    // {{{ function delete_email()

    function delete_email($email)
    {
        if (!$this->other_active($email)) {
            return ERROR_INACTIVE_REDIRECTION;
        }
        XDB::execute('DELETE FROM emails WHERE uid={?} AND email={?}', $this->uid, $email);
        $_SESSION['log']->log('email_del',$email.($this->uid!=S::v('uid') ? " (admin on {$this->uid})" : ""));
        foreach ($this->emails as $i=>$mail) {
            if ($email==$mail->email) {
                unset($this->emails[$i]);
            }
        }
        check_redirect($this);
        return SUCCESS;
    }

    // }}}
    // {{{ function add_email()
    
    function add_email($email)
    {
        $email_stripped = strtolower(trim($email));
        if (!isvalid_email($email_stripped)) {
            return ERROR_INVALID_EMAIL;
        }
        if (!isvalid_email_redirection($email_stripped)) {
            return ERROR_LOOP_EMAIL;
        }
        XDB::execute('REPLACE INTO emails (uid,email,flags) VALUES({?},{?},"active")', $this->uid, $email);
        if ($logger = S::v('log', null)) { // may be absent --> step4.php
            $logger->log('email_add',$email.($this->uid!=S::v('uid') ? " (admin on {$this->uid})" : ""));
        }
        foreach ($this->emails as $mail) {
            if ($mail->email == $email_stripped) {
                return SUCCESS;
            }
        }
        $this->emails[] = new Email(array($email, 'active', '', '0000-00-00', '0000-00-00', 0));

        // security stuff
        check_email($email, "Ajout d'une adresse surveillée aux redirections de " . $this->uid);
        check_redirect($this);
        return SUCCESS;
    }

    // }}}
    // {{{ function modify_email()

    function modify_email($emails_actifs,$emails_rewrite)
    {
        foreach ($this->emails as $i=>$mail) {
            if (in_array($mail->email,$emails_actifs)) {
                $this->emails[$i]->activate($this->uid);
            } else {
                $this->emails[$i]->deactivate($this->uid);
            }
            $this->emails[$i]->rewrite($emails_rewrite[$mail->email], $this->uid);
        }
        check_redirect($this);
    }

    function modify_one_email($email, $activate) 
    {
        $allinactive = true;
        $thisone = false;
        foreach ($this->emails as $i=>$mail) {
            if ($mail->email == $email) {
                $thisone = $i;
            }
            $allinactive &= !$mail->active || $mail->email == $email;
        }
        if ($thisone === false) {
            return ERROR_INVALID_EMAIL;
        }
        if ($allinactive || $activate) {
            $this->emails[$thisone]->activate($this->uid);
        } else {
            $this->emails[$thisone]->deactivate($this->uid);
        }
        check_redirect($this);
        if ($allinactive && !$activate) {
            return ERROR_INACTIVE_REDIRECTION;
        } else {
            return SUCCESS;
        } 
    }

	function modify_one_email_redirect($email, $redirect) {
		foreach ($this->emails as $i=>$mail) {
			if ($mail->email == $email) {
				$this->emails[$i]->rewrite($redirect, $this->uid);
                check_redirect($this);
                return;
			}
		}
	}
    // }}}
    // {{{ function get_broken_mx()

    function get_broken_mx()
    {
        $res = XDB::query("SELECT  host, text
                             FROM  mx_watch
                            WHERE  state != 'ok'");
        if (!$res->numRows()) {
            return array();
        }
        $mxs = $res->fetchAllAssoc();
        $mails = array();
        foreach ($this->emails as &$mail) {
            if ($mail->active) {
                list(,$domain) = explode('@', $mail->email);
                getmxrr($domain, $lcl_mxs);
                if (empty($lcl_mxs)) {
                    $lcl_mxs = array($domain);
                }
                $broken = false;
                foreach ($mxs as &$mx) {
                    foreach ($lcl_mxs as $lcl) {
                        if (fnmatch($mx['host'], $lcl)) {
                            $broken = $mx['text'];
                            break;
                        }
                    }
                    if ($broken) {
                        $mails[] = array('mail' => $mail->email, 'text' => $broken);
                    }
                }
            }
        }
        return $mails;
    }

    // }}}
}

// }}}

// vim:set et sw=4 sts=4 sws=4 foldmethod=marker enc=utf-8:
?>
Commit	Line	Data
0337d704	1	<?php
0337d704	2	/***************************************************************************
5ddeb07c	3	* Copyright (C) 2003-2007 Polytechnique.org *
0337d704	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	{
08cce2ff	36	$res = XDB::query("SELECT COUNT(*) FROM aliases WHERE id={?} AND FIND_IN_SET('bestalias',flags) AND type!='homonyme'", $uid);
0337d704	37	if ($n = $res->fetchOneCell()) {
	38	return;
	39	}
08cce2ff	40	XDB::execute("UPDATE aliases
0337d704	41	SET flags=CONCAT(flags,',','bestalias')
3c1e6a1e	42	WHERE id={?} AND type!='homonyme'
	43	ORDER BY !FIND_IN_SET('usage',flags),alias LIKE '%.%', LENGTH(alias)
	44	LIMIT 1", $uid);
0337d704	45	}
	46
	47	// }}}
	48	// {{{ function valide_email()
	49
	50	function valide_email($str)
	51	{
a3a049fc	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;
0337d704	63	}
	64
	65	// }}}
	66	// {{{ class Bogo
	67
	68	class Bogo
	69	{
	70	// {{{ properties
a3a049fc	71
0337d704	72	var $state;
94f3f9ba	73	var $_states = Array('let_spams', 'tag_spams', 'tag_and_drop_spams', 'drop_spams');
0337d704	74
	75	// }}}
	76	// {{{ constructor
a3a049fc	77
0337d704	78	function Bogo($uid)
0337d704	79	{
3c1e6a1e	80	if (!$uid) {
	81	return;
	82	}
	83	$res = XDB::query('SELECT email FROM emails WHERE uid={?} AND flags="filter"', $uid);
	84	if ($res->numRows()) {
	85	$this->state = $res->fetchOneCell();
	86	} else {
	87	$this->state = 'tag_and_drop_spams';
	88	$res = XDB::query("INSERT INTO emails (uid,email,rewrite,panne,flags)
	89	VALUES ({?},'tag_and_drop_spams','','0000-00-00','filter')", $uid);
	90	}
0337d704	91	}
	92
	93	// }}}
	94	// {{{ function change()
	95
	96	function change($uid, $state)
	97	{
3c1e6a1e	98	$this->state = is_int($state) ? $this->_states[$state] : $state;
3c1e6a1e	99	XDB::execute('UPDATE emails SET email={?} WHERE uid={?} AND flags = "filter"',
a3a049fc	100	$this->state, $uid);
0337d704	101	}
	102
	103	// }}}
	104	// {{{ function level()
	105
	106	function level()
	107	{ return array_search($this->state, $this->_states); }
	108
	109	// }}}
	110	}
	111
	112	// }}}
	113	// {{{ class Email
	114
	115	class Email
	116	{
	117	// {{{ properties
	118
	119	var $email;
	120	var $active;
dc557110	121	var $broken;
0337d704	122	var $rewrite;
0337d704	123	var $panne;
dc557110	124	var $last;
2069538b	125	var $panne_level;
0337d704	126
	127	// }}}
	128	// {{{ constructor
	129
	130	function Email($row)
	131	{
2069538b	132	list($this->email, $flags, $this->rewrite, $this->panne, $this->last, $this->panne_level) = $row;
dc557110	133	$this->active = ($flags == 'active');
dc557110	134	$this->broken = ($flags == 'panne');
0337d704	135	}
	136
	137	// }}}
	138	// {{{ function activate()
	139
	140	function activate($uid)
	141	{
0337d704	142	if (!$this->active) {
dc557110	143	XDB::execute("UPDATE emails
	144	SET panne_level = IF(flags = 'panne', panne_level - 1, panne_level),
	145	flags = 'active'
	146	WHERE uid={?} AND email={?}", $uid, $this->email);
3c1e6a1e	147	$_SESSION['log']->log("email_on", $this->email.($uid!=S::v('uid') ? "(admin on $uid)" : ""));
0337d704	148	$this->active = true;
dc557110	149	$this->broken = false;
0337d704	150	}
	151	}
	152
	153	// }}}
	154	// {{{ function deactivate()
	155
	156	function deactivate($uid)
	157	{
0337d704	158	if ($this->active) {
08cce2ff	159	XDB::execute("UPDATE emails SET flags =''
3c1e6a1e	160	WHERE uid={?} AND email={?}", $uid, $this->email);
3c1e6a1e	161	$_SESSION['log']->log("email_off",$this->email.($uid!=S::v('uid') ? "(admin on $uid)" : "") );
0337d704	162	$this->active = false;
	163	}
	164	}
	165
	166	// }}}
	167	// {{{ function rewrite()
	168
	169	function rewrite($rew, $uid)
	170	{
3c1e6a1e	171	if ($this->rewrite == $rew) {
0337d704	172	return;
0337d704	173	}
3c1e6a1e	174	XDB::execute('UPDATE emails SET rewrite={?} WHERE uid={?} AND email={?}', $rew, $uid, $this->email);
	175	$this->rewrite = $rew;
	176	return;
0337d704	177	}
	178
	179	// }}}
	180	}
	181
	182	// }}}
	183	// {{{ class Redirect
	184
	185	class Redirect
	186	{
	187	// {{{ properties
	188
	189	var $flag_active = 'active';
	190	var $emails;
	191	var $bogo;
	192	var $uid;
	193
	194	// }}}
	195	// {{{ function Redirect()
	196
	197	function Redirect($_uid)
	198	{
3c1e6a1e	199	$this->uid=$_uid;
08cce2ff	200	$res = XDB::iterRow("
3c1e6a1e	201	SELECT email, flags, rewrite, panne, last, panne_level
	202	FROM emails WHERE uid = {?} AND flags != 'filter'", $_uid);
	203	$this->emails=Array();
0337d704	204	while ($row = $res->next()) {
3c1e6a1e	205	$this->emails[] = new Email($row);
0337d704	206	}
3c1e6a1e	207	$this->bogo = new Bogo($_uid);
0337d704	208	}
	209
	210	// }}}
	211	// {{{ function other_active()
	212
	213	function other_active($email)
	214	{
	215	foreach ($this->emails as $mail) {
	216	if ($mail->email!=$email && $mail->active) {
	217	return true;
	218	}
	219	}
	220	return false;
	221	}
	222
	223	// }}}
	224	// {{{ function delete_email()
	225
	226	function delete_email($email)
	227	{
0337d704	228	if (!$this->other_active($email)) {
	229	return ERROR_INACTIVE_REDIRECTION;
	230	}
08cce2ff	231	XDB::execute('DELETE FROM emails WHERE uid={?} AND email={?}', $this->uid, $email);
cab08090	232	$_SESSION['log']->log('email_del',$email.($this->uid!=S::v('uid') ? " (admin on {$this->uid})" : ""));
3c1e6a1e	233	foreach ($this->emails as $i=>$mail) {
3c1e6a1e	234	if ($email==$mail->email) {
0337d704	235	unset($this->emails[$i]);
0337d704	236	}
3c1e6a1e	237	}
ccdbc270	238	check_redirect($this);
0337d704	239	return SUCCESS;
	240	}
	241
	242	// }}}
	243	// {{{ function add_email()
	244
	245	function add_email($email)
	246	{
0337d704	247	$email_stripped = strtolower(trim($email));
	248	if (!isvalid_email($email_stripped)) {
	249	return ERROR_INVALID_EMAIL;
	250	}
	251	if (!isvalid_email_redirection($email_stripped)) {
	252	return ERROR_LOOP_EMAIL;
	253	}
08cce2ff	254	XDB::execute('REPLACE INTO emails (uid,email,flags) VALUES({?},{?},"active")', $this->uid, $email);
3c1e6a1e	255	if ($logger = S::v('log', null)) { // may be absent --> step4.php
3c1e6a1e	256	$logger->log('email_add',$email.($this->uid!=S::v('uid') ? " (admin on {$this->uid})" : ""));
0337d704	257	}
3c1e6a1e	258	foreach ($this->emails as $mail) {
3c1e6a1e	259	if ($mail->email == $email_stripped) {
0337d704	260	return SUCCESS;
0337d704	261	}
3c1e6a1e	262	}
d2367745	263	$this->emails[] = new Email(array($email, 'active', '', '0000-00-00', '0000-00-00', 0));
ca6d07f4	264
ca6d07f4	265	// security stuff
a7de4ef7	266	check_email($email, "Ajout d'une adresse surveillée aux redirections de " . $this->uid);
ccdbc270	267	check_redirect($this);
0337d704	268	return SUCCESS;
	269	}
	270
	271	// }}}
	272	// {{{ function modify_email()
	273
	274	function modify_email($emails_actifs,$emails_rewrite)
	275	{
3c1e6a1e	276	foreach ($this->emails as $i=>$mail) {
0337d704	277	if (in_array($mail->email,$emails_actifs)) {
0337d704	278	$this->emails[$i]->activate($this->uid);
3c1e6a1e	279	} else {
0337d704	280	$this->emails[$i]->deactivate($this->uid);
3c1e6a1e	281	}
3c1e6a1e	282	$this->emails[$i]->rewrite($emails_rewrite[$mail->email], $this->uid);
0337d704	283	}
ccdbc270	284	check_redirect($this);
0337d704	285	}
0337d704	286
ccdbc270	287	function modify_one_email($email, $activate)
ccdbc270	288	{
b7582015	289	$allinactive = true;
b7582015	290	$thisone = false;
8ffa657a	291	foreach ($this->emails as $i=>$mail) {
8ffa657a	292	if ($mail->email == $email) {
b7582015	293	$thisone = $i;
8ffa657a	294	}
b7582015	295	$allinactive &= !$mail->active \|\| $mail->email == $email;
8ffa657a	296	}
b7582015	297	if ($thisone === false) {
	298	return ERROR_INVALID_EMAIL;
	299	}
ccdbc270	300	if ($allinactive \|\| $activate) {
b7582015	301	$this->emails[$thisone]->activate($this->uid);
ccdbc270	302	} else {
b7582015	303	$this->emails[$thisone]->deactivate($this->uid);
ccdbc270	304	}
ccdbc270	305	check_redirect($this);
b7582015	306	if ($allinactive && !$activate) {
	307	return ERROR_INACTIVE_REDIRECTION;
	308	} else {
	309	return SUCCESS;
	310	}
8ffa657a	311	}
8ffa657a	312
b7582015	313	function modify_one_email_redirect($email, $redirect) {
	314	foreach ($this->emails as $i=>$mail) {
	315	if ($mail->email == $email) {
	316	$this->emails[$i]->rewrite($redirect, $this->uid);
ccdbc270	317	check_redirect($this);
ccdbc270	318	return;
b7582015	319	}
	320	}
	321	}
0337d704	322	// }}}
ccdbc270	323	// {{{ function get_broken_mx()
	324
	325	function get_broken_mx()
	326	{
120bd636	327	$res = XDB::query("SELECT host, text
	328	FROM mx_watch
	329	WHERE state != 'ok'");
	330	if (!$res->numRows()) {
ccdbc270	331	return array();
ccdbc270	332	}
c754cf5b	333	$mxs = $res->fetchAllAssoc();
ccdbc270	334	$mails = array();
	335	foreach ($this->emails as &$mail) {
	336	if ($mail->active) {
	337	list(,$domain) = explode('@', $mail->email);
	338	getmxrr($domain, $lcl_mxs);
	339	if (empty($lcl_mxs)) {
	340	$lcl_mxs = array($domain);
	341	}
	342	$broken = false;
	343	foreach ($mxs as &$mx) {
	344	foreach ($lcl_mxs as $lcl) {
c754cf5b	345	if (fnmatch($mx['host'], $lcl)) {
ccdbc270	346	$broken = $mx['text'];
	347	break;
	348	}
	349	}
	350	if ($broken) {
	351	$mails[] = array('mail' => $mail->email, 'text' => $broken);
	352	}
	353	}
	354	}
	355	}
	356	return $mails;
	357	}
	358
	359	// }}}
0337d704	360	}
	361
	362	// }}}
	363
a7de4ef7	364	// vim:set et sw=4 sts=4 sws=4 foldmethod=marker enc=utf-8:
0337d704	365	?>