Improves blacklist verification.
[platal.git] / include / newsletter.inc.php
1 <?php
2 /***************************************************************************
3 * Copyright (C) 2003-2009 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("massmailer.inc.php");
23
24 // {{{ class NewsLetter
25
26 class NewsLetter extends MassMailer
27 {
28 public $_date;
29 public $_cats = array();
30 public $_arts = array();
31
32 function __construct($id = null)
33 {
34 parent::__construct('newsletter/nl.mail.tpl', 'nl.css', 'nl/show', 'newsletter', 'newsletter_ins');
35 if (isset($id)) {
36 if ($id == 'last') {
37 $res = XDB::query("SELECT MAX(id) FROM newsletter WHERE bits!='new'");
38 $id = $res->fetchOneCell();
39 }
40 $res = XDB::query("SELECT * FROM newsletter WHERE id={?} OR short_name={?} LIMIT 1", $id, $id);
41 } else {
42 $res = XDB::query("SELECT * FROM newsletter WHERE bits='new'");
43 if (!$res->numRows()) {
44 Newsletter::create();
45 }
46 $res = XDB::query("SELECT * FROM newsletter WHERE bits='new'");
47 }
48 if ($res->numRows() != 1) {
49 throw new MailNotFound();
50 }
51 $nl = $res->fetchOneAssoc();
52
53 $this->_id = $nl['id'];
54 $this->_shortname = $nl['short_name'];
55 $this->_date = $nl['date'];
56 $this->_title = $nl['titre'];
57 $this->_title_mail = $nl['titre_mail'];
58 $this->_head = $nl['head'];
59
60 $res = XDB::iterRow("SELECT cid,titre FROM newsletter_cat ORDER BY pos");
61 while (list($cid, $title) = $res->next()) {
62 $this->_cats[$cid] = $title;
63 }
64
65 $res = XDB::iterRow(
66 "SELECT a.title,a.body,a.append,a.aid,a.cid,a.pos
67 FROM newsletter_art AS a
68 INNER JOIN newsletter AS n USING(id)
69 LEFT JOIN newsletter_cat AS c ON(a.cid=c.cid)
70 WHERE a.id={?}
71 ORDER BY c.pos,a.pos", $this->_id);
72 while (list($title, $body, $append, $aid, $cid, $pos) = $res->next()) {
73 $this->_arts[$cid]["a$aid"] = new NLArticle($title, $body, $append, $aid, $cid, $pos);
74 }
75 }
76
77 public function save()
78 {
79 XDB::execute('UPDATE newsletter SET date={?},titre={?},titre_mail={?},head={?},short_name={?} WHERE id={?}',
80 $this->_date, $this->_title, $this->_title_mail, $this->_head, $this->_shortname,$this->_id);
81 }
82
83 public function getArt($aid)
84 {
85 foreach ($this->_arts as $key=>$artlist) {
86 if (isset($artlist["a$aid"])) {
87 return $artlist["a$aid"];
88 }
89 }
90 return null;
91 }
92
93 public function saveArticle(&$a)
94 {
95 if ($a->_aid >= 0) {
96 XDB::execute('REPLACE INTO newsletter_art (id, aid, cid, pos, title, body, append)
97 VALUES ({?}, {?}, {?}, {?}, {?}, {?}, {?})',
98 $this->_id, $a->_aid, $a->_cid, $a->_pos,
99 $a->_title, $a->_body, $a->_append);
100 $this->_arts['a' . $a->_aid] = $a;
101 } else {
102 XDB::execute('INSERT INTO newsletter_art
103 SELECT {?}, MAX(aid)+1, {?}, '
104 . ($a->_pos ? intval($a->_pos) : 'MAX(pos)+1')
105 . ', {?}, {?}, {?}
106 FROM newsletter_art AS a
107 WHERE a.id = {?}',
108 $this->_id, $a->_cid, $a->_title, $a->_body, $a->_append, $this->_id);
109 $this->_arts['a' . $a->_aid] = $a;
110 }
111 }
112
113 public function delArticle($aid)
114 {
115 XDB::execute('DELETE FROM newsletter_art WHERE id={?} AND aid={?}', $this->_id, $aid);
116 foreach ($this->_arts as $key=>$art) {
117 unset($this->_arts[$key]["a$aid"]);
118 }
119 }
120
121 protected function assignData(&$smarty)
122 {
123 $smarty->assign_by_ref('nl', $this);
124 }
125
126 protected function setSent()
127 {
128 XDB::execute("UPDATE newsletter SET bits='sent' WHERE id={?}", $this->_id);
129 }
130
131 static public function subscriptionState($uid = null)
132 {
133 $user = is_null($uid) ? S::v('uid') : $uid;
134 $res = XDB::query("SELECT 1
135 FROM newsletter_ins
136 WHERE user_id={?}", $user);
137 return $res->fetchOneCell();
138 }
139
140 static public function unsubscribe($uid = null)
141 {
142 $user = is_null($uid) ? S::v('uid') : $uid;
143 XDB::execute("DELETE FROM newsletter_ins
144 WHERE user_id={?}", $user);
145 }
146
147 static public function subscribe($uid = null)
148 {
149 $user = is_null($uid) ? S::v('uid') : $uid;
150 XDB::execute("REPLACE INTO newsletter_ins (user_id,last)
151 VALUES ({?}, 0)", $user);
152 }
153
154 protected function subscriptionWhere()
155 {
156 return '1';
157 }
158
159 static public function create()
160 {
161 XDB::execute("INSERT INTO newsletter
162 SET bits='new',date=NOW(),titre='to be continued',titre_mail='to be continued'");
163 }
164
165 static public function listSent()
166 {
167 $res = XDB::query("SELECT IF(short_name IS NULL, id,short_name) as id,date,titre_mail AS titre
168 FROM newsletter
169 WHERE bits!='new'
170 ORDER BY date DESC");
171 return $res->fetchAllAssoc();
172 }
173
174 static public function listAll()
175 {
176 $res = XDB::query("SELECT IF(short_name IS NULL, id,short_name) as id,date,titre_mail AS titre
177 FROM newsletter
178 ORDER BY date DESC");
179 return $res->fetchAllAssoc();
180 }
181 }
182
183 // }}}
184 // {{{ class NLArticle
185
186 class NLArticle
187 {
188 // {{{ properties
189
190 var $_aid;
191 var $_cid;
192 var $_pos;
193 var $_title;
194 var $_body;
195 var $_append;
196
197 // }}}
198 // {{{ constructor
199
200 function __construct($title='', $body='', $append='', $aid=-1, $cid=0, $pos=0)
201 {
202 $this->_body = $body;
203 $this->_title = $title;
204 $this->_append = $append;
205 $this->_aid = $aid;
206 $this->_cid = $cid;
207 $this->_pos = $pos;
208 }
209
210 // }}}
211 // {{{ function title()
212
213 public function title()
214 { return trim($this->_title); }
215
216 // }}}
217 // {{{ function body()
218
219 public function body()
220 { return trim($this->_body); }
221
222 // }}}
223 // {{{ function append()
224
225 public function append()
226 { return trim($this->_append); }
227
228 // }}}
229 // {{{ function toText()
230
231 public function toText($hash = null, $login = null)
232 {
233 $title = '*'.$this->title().'*';
234 $body = MiniWiki::WikiToText($this->_body, true);
235 $app = MiniWiki::WikiToText($this->_append,false,4);
236 $text = trim("$title\n\n$body\n\n$app")."\n";
237 if (!is_null($hash) && !is_null($login)) {
238 $text = str_replace('%HASH%', "$hash/$login", $text);
239 } else {
240 $text = str_replace('%HASH%', '', $text);
241 }
242 return $text;
243 }
244
245 // }}}
246 // {{{ function toHtml()
247
248 public function toHtml($hash = null, $login = null)
249 {
250 $title = "<h2 class='xorg_nl'><a id='art{$this->_aid}'></a>".pl_entities($this->title()).'</h2>';
251 $body = MiniWiki::WikiToHTML($this->_body);
252 $app = MiniWiki::WikiToHTML($this->_append);
253
254 $art = "$title\n";
255 $art .= "<div class='art'>\n$body\n";
256 if ($app) {
257 $art .= "<div class='app'>$app</div>";
258 }
259 $art .= "</div>\n";
260 if (!is_null($hash) && !is_null($login)) {
261 $art = str_replace('%HASH%', "$hash/$login", $art);
262 } else {
263 $art = str_replace('%HASH%', '', $art);
264 }
265
266 return $art;
267 }
268
269 // }}}
270 // {{{ function check()
271
272 public function check()
273 {
274 $text = MiniWiki::WikiToText($this->_body);
275 $arr = explode("\n",wordwrap($text,68));
276 $c = 0;
277 foreach ($arr as $line) {
278 if (trim($line)) {
279 $c++;
280 }
281 }
282 return $c<9;
283 }
284
285 // }}}
286 // {{{ function parseUrlsFromArticle()
287
288 private function parseUrlsFromArticle()
289 {
290 $email_regex = '([a-z0-9.\-+_\$]+@([\-.+_]?[a-z0-9])+)';
291 $url_regex = '((https?|ftp)://[a-zA-Z0-9._%#+/?=&~-]+)';
292 $regex = '{' . $email_regex . '|' . $url_regex . '}i';
293
294 $matches = array();
295 $body_matches = array();
296 if (preg_match_all($regex, $this->body(), $body_matches)) {
297 $matches = array_merge($matches, $body_matches[0]);
298 }
299
300 $append_matches = array();
301 if (preg_match_all($regex, $this->append(), $append_matches)) {
302 $matches = array_merge($matches, $append_matches[0]);
303 }
304
305 return $matches;
306 }
307
308 // }}}
309 // {{{ function getLinkIps()
310
311 public function getLinkIps(&$blacklist_host_resolution_count)
312 {
313 $matches = $this->parseUrlsFromArticle();
314 $article_ips = array();
315
316 if (!empty($matches)) {
317 global $globals;
318
319 foreach ($matches as $match) {
320 $host = parse_url($match, PHP_URL_HOST);
321 if ($host == '') {
322 list(, $host) = explode('@', $match);
323 }
324
325 if ($blacklist_host_resolution_count >= $globals->mail->blacklist_host_resolution_limit) {
326 break;
327 }
328
329 if (!preg_match('/^(' . str_replace(' ', '|', $globals->mail->domain_whitelist) . ')$/i', $host)) {
330 $article_ips = array_merge($article_ips, array(gethostbyname($host) => $host));
331 ++$blacklist_host_resolution_count;
332 }
333 }
334 }
335
336 return $article_ips;
337 }
338
339 // }}}
340 }
341
342 // }}}
343
344 // vim:set et sw=4 sts=4 sws=4 enc=utf-8:
345 ?>