Commit | Line | Data |
---|---|---|
834fd0f6 | 1 | #!/usr/bin/php5 -q |
2 | <?php | |
3 | /*************************************************************************** | |
9f5bd98e | 4 | * Copyright (C) 2003-2010 Polytechnique.org * |
834fd0f6 | 5 | * http://opensource.polytechnique.org/ * |
6 | * * | |
7 | * This program is free software; you can redistribute it and/or modify * | |
8 | * it under the terms of the GNU General Public License as published by * | |
9 | * the Free Software Foundation; either version 2 of the License, or * | |
10 | * (at your option) any later version. * | |
11 | * * | |
12 | * This program is distributed in the hope that it will be useful, * | |
13 | * but WITHOUT ANY WARRANTY; without even the implied warranty of * | |
14 | * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * | |
15 | * GNU General Public License for more details. * | |
16 | * * | |
17 | * You should have received a copy of the GNU General Public License * | |
18 | * along with this program; if not, write to the Free Software * | |
19 | * Foundation, Inc., * | |
20 | * 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA * | |
21 | ***************************************************************************/ | |
22 | ||
60e3880a | 23 | require './connect.db.inc.php'; |
636987ce | 24 | ini_set('max_execution_time', '75'); |
dc3441ff | 25 | ini_set('memory_limit', '128M'); |
834fd0f6 | 26 | $sent_mails = 0; |
27 | $handler = time(); | |
28 | ||
98429893 FB |
29 | /* Cleanup dead locks */ |
30 | XDB::execute('UPDATE email_list_moderate | |
31 | SET handler = NULL | |
32 | WHERE handler < NOW() - 300'); | |
33 | ||
834fd0f6 | 34 | while ($sent_mails < $globals->lists->max_mail_per_min |
35 | && time() - $handler < 60) { | |
36 | // take a lock on a mail | |
5ecaa68e | 37 | XDB::execute('UPDATE email_list_moderate |
834fd0f6 | 38 | SET handler = {?} |
39 | WHERE handler IS NULL | |
40 | ORDER BY ts | |
5ecaa68e | 41 | LIMIT 1', $handler); |
834fd0f6 | 42 | if (XDB::affectedRows() == 0) { |
43 | break; | |
44 | } | |
5fb34c48 | 45 | $query = XDB::query('SELECT a.full_name, a.uid, a.password, |
60e3880a | 46 | ml.ml, ml.domain, ml.mid, ml.action, ml.message |
5ecaa68e | 47 | FROM accounts AS a |
60e3880a SJ |
48 | INNER JOIN email_list_moderate AS ml ON (a.uid = ml.uid) |
49 | WHERE ml.handler = {?}', $handler); | |
50 | list($fullname, $uid, $password, $list, $domain, $mid, $action, $reason) = $query->fetchOneRow(); | |
834fd0f6 | 51 | |
52 | // build the client | |
53 | $client = new MMList($uid, $password, $domain); | |
54 | ||
55 | // send the mail | |
5ecaa68e | 56 | $mail = $client->get_pending_mail($list, $mid); |
834fd0f6 | 57 | list($det,$mem,$own) = $client->get_members($list); |
58 | $count = 0; | |
59 | switch ($action) { | |
60 | case 'accept': | |
61 | $action = 1; /** 1 = ACCEPT **/ | |
62 | $subject = "Message accepté"; | |
60e3880a | 63 | $append = "a été accepté par $fullname.\n"; |
a7c55d51 | 64 | $type = 'nonspam'; |
834fd0f6 | 65 | $count += count($mem) + count($own); |
66 | break; | |
67 | case 'refuse': | |
68 | $action = 2; /** 2 = REJECT **/ | |
69 | $subject = "Message refusé"; | |
60e3880a | 70 | $append = "a été refusé par $fullname avec la raison :\n\n" . $reason; |
a7c55d51 | 71 | $type = 'nonspam'; |
834fd0f6 | 72 | $count += count($own) + 1; |
73 | break; | |
74 | case 'delete': | |
75 | $action = 3; /** 3 = DISCARD **/ | |
76 | $subject = "Message supprimé"; | |
60e3880a | 77 | $append = "a été supprimé par $fullname.\n\n" |
5ecaa68e | 78 | . "Rappel : il ne faut utiliser cette opération " |
834fd0f6 | 79 | . "que dans le cas de spams ou de virus !\n"; |
a7c55d51 | 80 | $type = 'spam'; |
ceb2a271 | 81 | $count += count($own); |
834fd0f6 | 82 | break; |
83 | } | |
84 | ||
a7c55d51 AA |
85 | // if the mail was classified as Unsure, feed bogo |
86 | $raw_mail = html_entity_decode($client->get_pending_mail($list, $mid, 1)); | |
87 | // search for the X-Spam-Flag header | |
88 | $end_of_headers = strpos($raw_mail, "\r\n\r\n"); | |
dc3441ff | 89 | if ($end_of_headers === false) { // sometimes headers are separated by \n |
a7c55d51 | 90 | $end_of_headers = strpos($raw_mail, "\n\n"); |
dc3441ff | 91 | } |
a7c55d51 | 92 | $x_spam_flag = ''; |
734e15dc | 93 | if (preg_match('/^X-Spam-Flag: ([a-zA-Z]+), tests=bogofilter/m', substr($raw_mail, 0, $end_of_headers + 1), $matches)) { |
a7c55d51 | 94 | $x_spam_flag = $matches[1]; |
dc3441ff | 95 | } |
a7c55d51 | 96 | if ($x_spam_flag == 'Unsure') { |
dc3441ff AA |
97 | $mailer = new PlMailer(); |
98 | $mailer->addTo($type . '@' . $globals->mail->domain); | |
60e3880a SJ |
99 | $mailer->setFrom('"' . $fullname . '" <web@' . $globals->mail->domain . '>'); |
100 | $mailer->setTxtBody($type . ' soumis par ' . $fullname . ' via la modération de la liste ' . $list . '@' . $domain); | |
dc3441ff AA |
101 | $mailer->addAttachment($raw_mail, 'message/rfc822', $type . '.mail', false); |
102 | $mailer->send(); | |
103 | } | |
a7c55d51 | 104 | |
85d7633f AA |
105 | // send feedback to the mailing list owners |
106 | if ($client->handle_request($list, $mid, $action, utf8_decode($reason))) { | |
107 | $sent_mails += $count; | |
3e9cfdad | 108 | $texte = "Le message suivant :\n\n" |
85d7633f AA |
109 | . " Auteur: {$mail['sender']}\n" |
110 | . " Sujet : « {$mail['subj']} »\n" | |
111 | . " Date : ".strftime("le %d %b %Y à %H:%M:%S", (int)$mail['stamp'])."\n\n" | |
112 | . $append; | |
113 | $mailer = new PlMailer(); | |
114 | $mailer->addTo("$list-owner@{$domain}"); | |
115 | $mailer->setFrom("$list-bounces@{$domain}"); | |
116 | $mailer->addHeader('Reply-To', "$list-owner@{$domain}"); | |
117 | $mailer->setSubject($subject); | |
118 | $mailer->setTxtBody($texte); | |
119 | $mailer->send(); | |
120 | } | |
121 | ||
834fd0f6 | 122 | // release the lock |
5ecaa68e SJ |
123 | XDB::execute('DELETE FROM email_list_moderate |
124 | WHERE handler = {?}', | |
834fd0f6 | 125 | $handler); |
126 | sleep(60 * $count / $globals->lists->max_mail_per_min); | |
127 | } | |
128 | ||
129 | // vim:set et sw=4 sts=4 sws=4 foldmethod=marker enc=utf-8: | |
130 | ?> |