projects / platal.git / blame
? search:
summary | shortlog | log | commit | commitdiff | tree
blob | blame (incremental) | history | HEAD
Do not send the NL to people without valid redirection
[platal.git] / bin / lists.rpc.py
CommitLineData
0337d704 1#!/usr/bin/env python
2#***************************************************************************
3#* Copyright (C) 2004 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
22import base64, MySQLdb, os, getopt, sys, sha, signal, re, shutil, ConfigParser
23import MySQLdb.converters
24import SocketServer
25
26sys.path.append('/usr/lib/mailman/bin')
27
28from pwd import getpwnam
29from grp import getgrnam
30
31from SimpleXMLRPCServer import SimpleXMLRPCServer
32from SimpleXMLRPCServer import SimpleXMLRPCRequestHandler
33
34import paths
35from Mailman import MailList
36from Mailman import Utils
37from Mailman import Message
38from Mailman import Errors
39from Mailman import mm_cfg
40from Mailman import i18n
41from Mailman.UserDesc import UserDesc
42from Mailman.ListAdmin import readMessage
43from email.Iterators import typed_subpart_iterator
44from threading import Lock
45
46class AuthFailed(Exception): pass
47
48################################################################################
49#
50# CONFIG
51#
52#------------------------------------------------
53
54config = ConfigParser.ConfigParser()
78dd3eb2 55config.read(os.path.dirname(__file__)+'/../configs/platal.ini')
0337d704 56config.read(os.path.dirname(__file__)+'/../configs/platal.conf')
57
ae6c293b 58def get_config(sec, val, default=None):
0337d704 59 try:
60 return config.get(sec, val)[1:-1]
61 except ConfigParser.NoOptionError, e:
62 if default is None:
63 print e
64 sys.exit(1)
65 else:
66 return default
67
0337d704 68MYSQL_USER = get_config('Core', 'dbuser')
69MYSQL_PASS = get_config('Core', 'dbpwd')
70
71PLATAL_DOMAIN = get_config('Mail', 'domain')
72PLATAL_DOMAIN2 = get_config('Mail', 'domain2', '')
73
0337d704 74VHOST_SEP = get_config('Lists', 'vhost_sep', '_')
75ON_CREATE_CMD = get_config('Lists', 'on_create', '')
76
77################################################################################
78#
79# CLASSES
80#
81#------------------------------------------------
82# Manage Basic authentication
83#
84
85class BasicAuthXMLRPCRequestHandler(SimpleXMLRPCRequestHandler):
86
87 """XMLRPC Request Handler
88 This request handler is used to provide BASIC HTTP user authentication.
89 It first overloads the do_POST() function, authenticates the user, then
90 calls the super.do_POST().
91
92 Moreover, we override _dispatch, so that we call functions with as first
93 argument a UserDesc taken from the database, containing name, email and perms
94 """
95
ae6c293b 96 def _dispatch(self, method, params):
0337d704 97 # TODO: subclass in SimpleXMLRPCDispatcher and not here.
98 new_params = list(params)
ae6c293b 99 new_params.insert(0, self.data[2])
100 new_params.insert(0, self.data[1])
101 new_params.insert(0, self.data[0])
102 return self.server._dispatch(method, new_params)
0337d704 103
104 def do_POST(self):
105 try:
106 _, auth = self.headers["authorization"].split()
107 uid, md5 = base64.decodestring(auth).strip().split(':')
108 vhost = self.path.split('/')[1].lower()
ae6c293b 109 self.data = self.getUser(uid, md5, vhost)
0337d704 110 if self.data is None:
111 raise AuthFailed
112 # Call super.do_POST() to do the actual work
113 SimpleXMLRPCRequestHandler.do_POST(self)
114 except:
115 self.send_response(401)
116 self.end_headers()
117
118 def getUser(self, uid, md5, vhost):
ae6c293b 119 res = mysql_fetchone ("""SELECT CONCAT(u.prenom, ' ', u.nom), a.alias, u.perms
0337d704 120 FROM auth_user_md5 AS u
121 INNER JOIN aliases AS a ON ( a.id=u.user_id AND a.type='a_vie' )
ae6c293b 122 WHERE u.user_id = '%s' AND u.password = '%s' AND u.perms IN ('admin', 'user')
0337d704 123 LIMIT 1""" %( uid, md5 ) )
124 if res:
ae6c293b 125 name, forlife, perms = res
0337d704 126 if vhost != PLATAL_DOMAIN:
127 res = mysql_fetchone ("""SELECT uid
128 FROM groupex.membres AS m
129 INNER JOIN groupex.asso AS a ON (m.asso_id = a.id)
130 WHERE perms='admin' AND uid='%s' AND mail_domain='%s'""" %( uid , vhost ) )
131 if res: perms= 'admin'
132 userdesc = UserDesc(forlife+'@'+PLATAL_DOMAIN, name, None, 0)
ae6c293b 133 return (userdesc, perms, vhost)
0337d704 134 else:
135 return None
ae6c293b 136
0337d704 137################################################################################
138#
139# XML RPC STUFF
140#
141#-------------------------------------------------------------------------------
142# helpers
143#
144
145def connectDB():
146 db = MySQLdb.connect(
147 db='x4dat',
148 user=MYSQL_USER,
149 passwd=MYSQL_PASS,
6bd94db9 150 unix_socket='/var/run/mysqld/mysqld.sock')
0337d704 151 db.ping()
152 return db.cursor()
153
154def mysql_fetchone(query):
155 ret = None
156 try:
157 lock.acquire()
158 mysql.execute(query)
159 if int(mysql.rowcount) > 0:
160 ret = mysql.fetchone()
161 finally:
162 lock.release()
163 return ret
164
ae6c293b 165def is_admin_on(userdesc, perms, mlist):
0337d704 166 return ( perms == 'admin' ) or ( userdesc.address in mlist.owner )
167
168
ae6c293b 169def quote(s, is_header=False):
0337d704 170 if is_header:
ae6c293b 171 h = Utils.oneline(s, 'iso-8859-1')
0337d704 172 else:
173 h = s
720a960d 174 h = str('').join(re.split('[\x00-\x09\x0B-\x1f]+', h))
c8529706 175 return Utils.uquote(h.replace('&', '&amp;').replace('>', '&gt;').replace('<', '&lt;'))
0337d704 176
177def to_forlife(email):
178 try:
ae6c293b 179 mbox, fqdn = email.split('@')
0337d704 180 except:
181 mbox = email
182 fqdn = PLATAL_DOMAIN
183 if ( fqdn == PLATAL_DOMAIN ) or ( fqdn == PLATAL_DOMAIN2 ):
ae6c293b 184 res = mysql_fetchone("""SELECT CONCAT(f.alias, '@%s'), CONCAT(u.prenom, ' ', u.nom)
0337d704 185 FROM auth_user_md5 AS u
186 INNER JOIN aliases AS f ON (f.id=u.user_id AND f.type='a_vie')
187 INNER JOIN aliases AS a ON (a.id=u.user_id AND a.alias='%s' AND a.type!='homonyme')
ae6c293b 188 WHERE u.perms IN ('admin', 'user')
0337d704 189 LIMIT 1""" %( PLATAL_DOMAIN, mbox ) )
190 if res:
191 return res
192 else:
ae6c293b 193 return (None, None)
194 return (email, mbox)
0337d704 195
196##
197# see /usr/lib/mailman/bin/rmlist
198##
199def remove_it(listname, filename):
200 if os.path.islink(filename) or os.path.isfile(filename):
201 os.unlink(filename)
202 elif os.path.isdir(filename):
203 shutil.rmtree(filename)
ae6c293b 204
0337d704 205#-------------------------------------------------------------------------------
206# helpers on lists
207#
208
ae6c293b 209def get_list_info(userdesc, perms, mlist, front_page=0):
0337d704 210 members = mlist.getRegularMemberKeys()
211 is_member = userdesc.address in members
ae6c293b 212 is_owner = userdesc.address in mlist.owner
0337d704 213 if mlist.advertised or is_member or is_owner or (not front_page and perms == 'admin'):
214 is_pending = False
215 if not is_member and (mlist.subscribe_policy > 1):
216 try:
217 mlist.Lock()
218 for id in mlist.GetSubscriptionIds():
219 if userdesc.address == mlist.GetRecord(id)[1]:
220 is_pending = 1
221 break
222 mlist.Unlock()
223 except:
224 mlist.Unlock()
225 return 0
226
227 host = mlist.internal_name().split(VHOST_SEP)[0].lower()
228 details = {
229 'list' : mlist.real_name,
230 'addr' : mlist.real_name.lower() + '@' + host,
231 'host' : host,
232 'desc' : quote(mlist.description),
233 'info' : quote(mlist.info),
234 'diff' : (mlist.default_member_moderation>0) + (mlist.generic_nonmember_action>0),
235 'ins' : mlist.subscribe_policy > 1,
ae6c293b 236 'priv' : 1-mlist.advertised,
0337d704 237 'sub' : 2*is_member + is_pending,
238 'own' : is_owner,
239 'nbsub': len(members)
240 }
ae6c293b 241 return (details, members)
0337d704 242 return 0
243
ae6c293b 244def get_options(userdesc, perms, vhost, listname, opts):
0337d704 245 try:
ae6c293b 246 mlist = MailList.MailList(vhost+VHOST_SEP+listname.lower(), lock=0)
0337d704 247 except:
248 return 0
249 try:
250 if not is_admin_on(userdesc, perms, mlist):
251 return 0
252 options = { }
ae6c293b 253 for (k, v) in mlist.__dict__.iteritems():
0337d704 254 if k in opts:
255 if type(v) is str:
256 options[k] = quote(v)
257 else: options[k] = v
ae6c293b 258 details = get_list_info(userdesc, perms, mlist)[0]
259 return (details, options)
0337d704 260 except:
261 return 0
262
ae6c293b 263def set_options(userdesc, perms, vhost, listname, opts, vals):
0337d704 264 try:
ae6c293b 265 mlist = MailList.MailList(vhost+VHOST_SEP+listname.lower(), lock=0)
0337d704 266 except:
267 return 0
268 try:
269 if not is_admin_on(userdesc, perms, mlist):
270 return 0
271 mlist.Lock()
ae6c293b 272 for (k, v) in vals.iteritems():
0337d704 273 if k not in opts:
274 continue
275 if k == 'default_member_moderation':
276 for member in mlist.getMembers():
277 mlist.setMemberOption(member, mm_cfg.Moderate, int(v))
278 t = type(mlist.__dict__[k])
279 if t is bool: mlist.__dict__[k] = bool(v)
280 elif t is int: mlist.__dict__[k] = int(v)
ae6c293b 281 elif t is str: mlist.__dict__[k] = Utils.uncanonstr(v, 'fr')
0337d704 282 else: mlist.__dict__[k] = v
283 mlist.Save()
284 mlist.Unlock()
285 return 1
286 except:
287 mlist.Unlock()
288 return 0
289
290#-------------------------------------------------------------------------------
291# users procedures for [ index.php ]
292#
293
ae6c293b 294def get_lists(userdesc, perms, vhost, email=None):
0337d704 295 if email is None:
296 udesc = userdesc
297 else:
298 udesc = UserDesc(email, email, None, 0)
299 prefix = vhost.lower()+VHOST_SEP
300 names = Utils.list_names()
301 names.sort()
302 result = []
303 for name in names:
304 if not name.startswith(prefix):
305 continue
306 try:
ae6c293b 307 mlist = MailList.MailList(name, lock=0)
0337d704 308 except:
309 continue
310 try:
ae6c293b 311 details = get_list_info(udesc, perms, mlist, (email is None and vhost == PLATAL_DOMAIN))[0]
0337d704 312 result.append(details)
313 except:
314 continue
315 return result
316
ae6c293b 317def subscribe(userdesc, perms, vhost, listname):
0337d704 318 try:
ae6c293b 319 mlist = MailList.MailList(vhost+VHOST_SEP+listname.lower(), lock=0)
0337d704 320 except:
321 return 0
322 try:
323 mlist.Lock()
ae6c293b 324 if ( mlist.subscribe_policy in (0, 1) ) or userdesc.address in mlist.owner:
0337d704 325 mlist.ApprovedAddMember(userdesc)
326 result = 2
327 else:
328 result = 1
329 try:
330 mlist.AddMember(userdesc)
331 except Errors.MMNeedApproval:
332 pass
333 mlist.Save()
334 except:
335 result = 0
336 mlist.Unlock()
337 return result
338
ae6c293b 339def unsubscribe(userdesc, perms, vhost, listname):
0337d704 340 try:
ae6c293b 341 mlist = MailList.MailList(vhost+VHOST_SEP+listname.lower(), lock=0)
0337d704 342 except:
343 return 0
344 try:
345 mlist.Lock()
346 mlist.ApprovedDeleteMember(userdesc.address)
347 mlist.Save()
348 mlist.Unlock()
349 return 1
350 except:
351 mlist.Unlock()
352 return 0
353
354#-------------------------------------------------------------------------------
355# users procedures for [ index.php ]
356#
357
ae6c293b 358def get_members(userdesc, perms, vhost, listname):
0337d704 359 try:
ae6c293b 360 mlist = MailList.MailList(vhost+VHOST_SEP+listname.lower(), lock=0)
0337d704 361 except:
362 return 0
363 try:
ae6c293b 364 details, members = get_list_info(userdesc, perms, mlist)
0337d704 365 members.sort()
366 members = map(lambda member: (quote(mlist.getMemberName(member)) or '', member), members)
ae6c293b 367 return (details, members, mlist.owner)
0337d704 368 except:
369 return 0
370
371#-------------------------------------------------------------------------------
372# users procedures for [ trombi.php ]
373#
374
ae6c293b 375def get_members_limit(userdesc, perms, vhost, listname, page, nb_per_page):
0337d704 376 try:
ae6c293b 377 members = get_members(userdesc, perms, vhost, listname.lower())[1]
0337d704 378 except:
379 return 0
380 i = int(page) * int(nb_per_page)
381 return (len(members), members[i:i+int(nb_per_page)])
382
ae6c293b 383def get_owners(userdesc, perms, vhost, listname):
0337d704 384 try:
ae6c293b 385 details, members, owners = get_members(userdesc, perms, vhost, listname.lower())
0337d704 386 except:
387 return 0
ae6c293b 388 return (details, owners)
0337d704 389
390#-------------------------------------------------------------------------------
391# owners procedures [ admin.php ]
392#
393
c4d57bd8 394def replace_email(userdesc, perms, vhost, listname, from_email, to_email):
395 try:
396 mlist = MailList.MailList(vhost+VHOST_SEP+listname.lower(), lock=0)
397 except:
398 return 0
399 try:
400 if not is_admin_on(userdesc, perms, mlist):
401 return 0
402
403 mlist.Lock()
404 mlist.ApprovedChangeMemberAddress(from_email, to_email, 0)
405 mlist.Save()
406 mlist.Unlock()
407 return 1
408 except:
409 return 0
410
ae6c293b 411def mass_subscribe(userdesc, perms, vhost, listname, users):
0337d704 412 try:
ae6c293b 413 mlist = MailList.MailList(vhost+VHOST_SEP+listname.lower(), lock=0)
0337d704 414 except:
415 return 0
416 try:
417 if not is_admin_on(userdesc, perms, mlist):
418 return 0
ae6c293b 419
0337d704 420 members = mlist.getRegularMemberKeys()
421 added = []
422 mlist.Lock()
423 for user in users:
424 email, name = to_forlife(user)
425 if ( email is None ) or ( email in members ):
426 continue
427 userd = UserDesc(email, name, None, 0)
428 mlist.ApprovedAddMember(userd)
429 added.append( (quote(userd.fullname), userd.address) )
430 mlist.Save()
431 except:
432 pass
433 mlist.Unlock()
434 return added
435
ae6c293b 436def mass_unsubscribe(userdesc, perms, vhost, listname, users):
0337d704 437 try:
ae6c293b 438 mlist = MailList.MailList(vhost+VHOST_SEP+listname.lower(), lock=0)
0337d704 439 except:
440 return 0
441 try:
442 if not is_admin_on(userdesc, perms, mlist):
443 return 0
ae6c293b 444
0337d704 445 mlist.Lock()
446 map(lambda user: mlist.ApprovedDeleteMember(user), users)
447 mlist.Save()
448 except:
449 pass
450 mlist.Unlock()
451 return users
452
ae6c293b 453def add_owner(userdesc, perms, vhost, listname, user):
0337d704 454 try:
ae6c293b 455 mlist = MailList.MailList(vhost+VHOST_SEP+listname.lower(), lock=0)
0337d704 456 except:
457 return 0
458 try:
459 if not is_admin_on(userdesc, perms, mlist):
460 return 0
461 email = to_forlife(user)[0]
462 if email is None:
463 return 0
464 if email not in mlist.owner:
465 mlist.Lock()
466 mlist.owner.append(email)
467 mlist.Save()
468 except:
469 pass
470 mlist.Unlock()
471 return True
472
ae6c293b 473def del_owner(userdesc, perms, vhost, listname, user):
0337d704 474 try:
ae6c293b 475 mlist = MailList.MailList(vhost+VHOST_SEP+listname.lower(), lock=0)
0337d704 476 except:
477 return 0
478 try:
479 if not is_admin_on(userdesc, perms, mlist):
480 return 0
481 if len(mlist.owner) < 2:
482 return 0
483 mlist.Lock()
484 mlist.owner.remove(user)
485 mlist.Save()
486 except:
487 pass
488 mlist.Unlock()
489 return True
490
491#-------------------------------------------------------------------------------
492# owners procedures [ admin.php ]
493#
494
ae6c293b 495def get_pending_ops(userdesc, perms, vhost, listname):
0337d704 496 try:
ae6c293b 497 mlist = MailList.MailList(vhost+VHOST_SEP+listname.lower(), lock=0)
0337d704 498 except:
499 return 0
500 try:
501 if not is_admin_on(userdesc, perms, mlist):
502 return 0
ae6c293b 503
0337d704 504 mlist.Lock()
ae6c293b 505
0337d704 506 subs = []
507 seen = []
508 dosave = False
509 for id in mlist.GetSubscriptionIds():
510 time, addr, fullname, passwd, digest, lang = mlist.GetRecord(id)
511 if addr in seen:
512 mlist.HandleRequest(id, mm_cfg.DISCARD)
513 dosave = True
514 continue
515 seen.append(addr)
516 try:
517 login = re.match("^[^.]*\.[^.]*\.\d\d\d\d$", addr.split('@')[0]).group()
518 subs.append({'id': id, 'name': quote(fullname), 'addr': addr, 'login': login })
519 except:
520 subs.append({'id': id, 'name': quote(fullname), 'addr': addr })
521
522 helds = []
523 for id in mlist.GetHeldMessageIds():
524 ptime, sender, subject, reason, filename, msgdata = mlist.GetRecord(id)
525 try:
526 size = os.path.getsize(os.path.join(mm_cfg.DATA_DIR, filename))
527 except OSError, e:
528 if e.errno <> errno.ENOENT: raise
529 continue
530 helds.append({
531 'id' : id,
532 'sender': quote(sender, True),
533 'size' : size,
534 'subj' : quote(subject, True),
535 'stamp' : ptime
536 })
537 if dosave: mlist.Save()
538 mlist.Unlock()
539 except:
540 mlist.Unlock()
541 return 0
ae6c293b 542 return (subs, helds)
0337d704 543
544
ae6c293b 545def handle_request(userdesc, perms, vhost, listname, id, value, comment):
0337d704 546 try:
ae6c293b 547 mlist = MailList.MailList(vhost+VHOST_SEP+listname.lower(), lock=0)
0337d704 548 except:
549 return 0
550 try:
551 if not is_admin_on(userdesc, perms, mlist):
552 return 0
553 mlist.Lock()
ae6c293b 554 mlist.HandleRequest(int(id), int(value), comment)
0337d704 555 mlist.Save()
556 mlist.Unlock()
557 return 1
558 except:
559 mlist.Unlock()
560 return 0
561
562
ae6c293b 563def get_pending_mail(userdesc, perms, vhost, listname, id, raw=0):
0337d704 564 try:
ae6c293b 565 mlist = MailList.MailList(vhost+VHOST_SEP+listname.lower(), lock=0)
0337d704 566 except:
567 return 0
568 try:
569 if not is_admin_on(userdesc, perms, mlist):
570 return 0
571 mlist.Lock()
572 ptime, sender, subject, reason, filename, msgdata = mlist.GetRecord(int(id))
573 fpath = os.path.join(mm_cfg.DATA_DIR, filename)
574 size = os.path.getsize(fpath)
575 msg = readMessage(fpath)
576 mlist.Unlock()
ae6c293b 577
0337d704 578 if raw:
579 return str(msg)
ae0508cb 580 results_plain = []
581 results_html = []
ae6c293b 582 for part in typed_subpart_iterator(msg, 'text', 'plain'):
0337d704 583 c = part.get_payload()
ae0508cb 584 if c is not None: results_plain.append (c)
585 results_plain = map(lambda x: quote(x), results_plain)
586 for part in typed_subpart_iterator(msg, 'text', 'html'):
587 c = part.get_payload()
588 if c is not None: results_html.append (c)
589 results_html = map(lambda x: quote(x), results_html)
0337d704 590 return {'id' : id,
591 'sender': quote(sender, True),
592 'size' : size,
593 'subj' : quote(subject, True),
594 'stamp' : ptime,
ae0508cb 595 'parts_plain' : results_plain,
596 'parts_html': results_html }
0337d704 597 except:
598 mlist.Unlock()
599 return 0
600
601#-------------------------------------------------------------------------------
602# owner options [ options.php ]
603#
604
605owner_opts = ['accept_these_nonmembers', 'admin_notify_mchanges', 'description', \
606 'default_member_moderation', 'generic_nonmember_action', 'info', \
607 'subject_prefix', 'goodbye_msg', 'send_goodbye_msg', 'subscribe_policy', \
608 'welcome_msg']
609
ae6c293b 610def get_owner_options(userdesc, perms, vhost, listname):
611 return get_options(userdesc, perms, vhost, listname.lower(), owner_opts)
0337d704 612
ae6c293b 613def set_owner_options(userdesc, perms, vhost, listname, values):
614 return set_options(userdesc, perms, vhost, listname.lower(), owner_opts, values)
0337d704 615
ae6c293b 616def add_to_wl(userdesc, perms, vhost, listname, addr):
0337d704 617 try:
ae6c293b 618 mlist = MailList.MailList(vhost+VHOST_SEP+listname.lower(), lock=0)
0337d704 619 except:
620 return 0
621 try:
622 if not is_admin_on(userdesc, perms, mlist):
623 return 0
624 mlist.Lock()
625 mlist.accept_these_nonmembers.append(addr)
626 mlist.Save()
627 mlist.Unlock()
628 return 1
629 except:
630 mlist.Unlock()
631 return 0
632
ae6c293b 633def del_from_wl(userdesc, perms, vhost, listname, addr):
0337d704 634 try:
ae6c293b 635 mlist = MailList.MailList(vhost+VHOST_SEP+listname.lower(), lock=0)
0337d704 636 except:
637 return 0
638 try:
639 if not is_admin_on(userdesc, perms, mlist):
640 return 0
641 mlist.Lock()
642 mlist.accept_these_nonmembers.remove(addr)
643 mlist.Save()
644 mlist.Unlock()
645 return 1
646 except:
647 mlist.Unlock()
648 return 0
649
ae6c293b 650def get_bogo_level(userdesc, perms, vhost, listname):
0337d704 651 try:
ae6c293b 652 mlist = MailList.MailList(vhost+VHOST_SEP+listname.lower(), lock=0)
0337d704 653 except:
654 return 0
655 try:
656 if not is_admin_on(userdesc, perms, mlist):
657 return 0
658 if mlist.header_filter_rules == []:
659 return 0
660 action = mlist.header_filter_rules[0][1]
661 if action == mm_cfg.HOLD:
662 return 1
663 if action == mm_cfg.DISCARD:
664 return 2
665 except:
666 return 0
667
ae6c293b 668def set_bogo_level(userdesc, perms, vhost, listname, level):
0337d704 669 try:
ae6c293b 670 mlist = MailList.MailList(vhost+VHOST_SEP+listname.lower(), lock=0)
0337d704 671 except:
672 return 0
673 try:
674 if not is_admin_on(userdesc, perms, mlist):
675 return 0
676 hfr = []
677 if int(level) is 1:
678 hfr.append(('X-Spam-Flag: Yes, tests=bogofilter', mm_cfg.HOLD, False))
679 elif int(level) is 2:
680 hfr.append(('X-Spam-Flag: Yes, tests=bogofilter', mm_cfg.DISCARD, False))
681 if mlist.header_filter_rules != hfr:
682 mlist.Lock()
683 mlist.header_filter_rules = hfr
684 mlist.Save()
685 mlist.Unlock()
686 return 1
687 except:
688 mlist.Unlock()
689 return 0
690
691#-------------------------------------------------------------------------------
692# admin procedures [ soptions.php ]
693#
694
695admin_opts = [ 'advertised', 'archive', \
696 'max_message_size', 'msg_footer', 'msg_header']
697
ae6c293b 698def get_admin_options(userdesc, perms, vhost, listname):
0337d704 699 if perms != 'admin':
700 return 0
ae6c293b 701 return get_options(userdesc, perms, vhost, listname.lower(), admin_opts)
0337d704 702
ae6c293b 703def set_admin_options(userdesc, perms, vhost, listname, values):
0337d704 704 if perms != 'admin':
705 return 0
ae6c293b 706 return set_options(userdesc, perms, vhost, listname.lower(), admin_opts, values)
0337d704 707
708#-------------------------------------------------------------------------------
709# admin procedures [ check.php ]
710#
711
712check_opts = {
713 'acceptable_aliases' : '',
714 'admin_immed_notify' : True,
715 'administrivia' : True,
716 'anonymous_list' : False,
717 'autorespond_admin' : False,
718 'autorespond_postings' : False,
719 'autorespond_requests' : False,
720 'available_languages' : ['fr'],
721 'ban_list' : [],
722 'bounce_matching_headers' : '',
723 'bounce_processing' : False,
724 'convert_html_to_plaintext' : False,
725 'digestable' : False,
726 'digest_is_default' : False,
727 'discard_these_nonmembers' : [],
728 'emergency' : False,
729 'encode_ascii_prefixes' : 2,
730 'filter_content' : False,
731 'first_strip_reply_to' : False,
732 'forward_auto_discards' : True,
733 'hold_these_nonmembers' : [],
734 'host_name' : 'listes.polytechnique.org',
735 'include_list_post_header' : False,
736 'include_rfc2369_headers' : False,
737 'max_num_recipients' : 0,
738 'new_member_options' : 256,
739 'nondigestable' : True,
740 'obscure_addresses' : True,
741 'preferred_language' : 'fr',
742 'reject_these_nonmembers' : [],
743 'reply_goes_to_list' : 0,
744 'reply_to_address' : '',
745 'require_explicit_destination' : False,
746 'send_reminders' : 0,
747 'send_welcome_msg' : True,
748 'topics_enabled' : False,
749 'umbrella_list' : False,
750 'unsubscribe_policy' : 0,
751}
752
ae6c293b 753def check_options(userdesc, perms, vhost, listname, correct=False):
0337d704 754 try:
ae6c293b 755 mlist = MailList.MailList(vhost+VHOST_SEP+listname.lower(), lock=0)
0337d704 756 except:
757 return 0
758 try:
759 if perms != 'admin': return 0
760 if correct:
761 mlist.Lock()
762 options = { }
ae6c293b 763 for (k, v) in check_opts.iteritems():
0337d704 764 if mlist.__dict__[k] != v:
ae6c293b 765 options[k] = v, mlist.__dict__[k]
0337d704 766 if correct: mlist.__dict__[k] = v
767 if mlist.real_name.lower() != listname:
768 options['real_name'] = listname, mlist.real_name
769 if correct: mlist.real_name = listname
770 if correct:
771 mlist.Save()
772 mlist.Unlock()
ae6c293b 773 details = get_list_info(userdesc, perms, mlist)[0]
774 return (details, options)
0337d704 775 except:
776 if correct: mlist.Unlock()
777 return 0
778
779#-------------------------------------------------------------------------------
780# super-admin procedures
781#
782
ae6c293b 783def get_all_lists(userdesc, perms, vhost):
0337d704 784 prefix = vhost.lower()+VHOST_SEP
785 names = Utils.list_names()
786 names.sort()
787 result = []
788 for name in names:
789 if not name.startswith(prefix):
790 continue
ae6c293b 791 result.append(name.replace(prefix, ''))
0337d704 792 return result
793
ae6c293b 794def create_list(userdesc, perms, vhost, listname, desc, advertise, modlevel, inslevel, owners, members):
0337d704 795 if perms != 'admin':
796 return 0
797 name = vhost.lower()+VHOST_SEP+listname.lower();
798 if Utils.list_exists(name):
799 return 0
ae6c293b 800
0337d704 801 owner = []
802 for o in owners:
803 email = to_forlife(o)[0]
804 if email is not None:
805 owner.append(email)
806 if len(owner) is 0:
807 return 0
808
809 mlist = MailList.MailList()
810 try:
811 oldmask = os.umask(002)
812 pw = sha.new('foobar').hexdigest()
ae6c293b 813
0337d704 814 try:
815 mlist.Create(name, owner[0], pw)
816 finally:
817 os.umask(oldmask)
818
819 mlist.real_name = listname
820 mlist.host_name = 'listes.polytechnique.org'
821 mlist.description = desc
822
823 mlist.advertised = int(advertise) is 0
824 mlist.default_member_moderation = int(modlevel) is 2
825 mlist.generic_nonmember_action = int(modlevel) > 0
826 mlist.subscribe_policy = 2 * (int(inslevel) is 1)
827 mlist.admin_notify_mchanges = (mlist.subscribe_policy or mlist.generic_nonmember_action or mlist.default_member_moderation or not mlist.advertised)
ae6c293b 828
0337d704 829 mlist.owner = owner
ae6c293b 830
0337d704 831 mlist.subject_prefix = '['+listname+'] '
832 mlist.max_message_size = 0
833
31f2df6a 834 inverted_listname = '_'.join(listname.split('_', 1)[-1::-1])
0337d704 835 mlist.msg_footer = "_______________________________________________\n" \
31f2df6a 836 + "Liste de diffusion %(real_name)s\n" \
837 + "http://listes.polytechnique.org/members/" + inverted_listname
ae6c293b 838
0337d704 839 mlist.header_filter_rules = []
840 mlist.header_filter_rules.append(('X-Spam-Flag: Yes, tests=bogofilter', mm_cfg.HOLD, False))
841
842 mlist.Save()
843
844 mlist.Unlock()
845
98c79ede 846 if ON_CREATE_CMD != '':
847 try: os.system(ON_CREATE_CMD + ' ' + name)
848 except: pass
849
ae6c293b 850 check_options(userdesc, perms, vhost, listname.lower(), True)
851 mass_subscribe(userdesc, perms, vhost, listname.lower(), members)
0337d704 852
853 # avoid the "-1 mail to moderate" bug
854 mlist = MailList.MailList(name)
855 mlist._UpdateRecords()
856 mlist.Save()
857 mlist.Unlock()
0337d704 858 except:
859 try:
860 mlist.Unlock()
861 except:
862 pass
863 return 0
864 return 1
865
ae6c293b 866def delete_list(userdesc, perms, vhost, listname, del_archives=0):
0337d704 867 lname = vhost+VHOST_SEP+listname.lower()
868 try:
ae6c293b 869 mlist = MailList.MailList(lname, lock=0)
0337d704 870 except:
871 return 0
872 try:
873 if not is_admin_on(userdesc, perms, mlist):
874 return 0
875 # remove the list
876 REMOVABLES = [ os.path.join('lists', lname), ]
877 # remove stalled locks
878 for filename in os.listdir(mm_cfg.LOCK_DIR):
879 fn_lname = filename.split('.')[0]
880 if fn_lname == lname:
881 REMOVABLES.append(os.path.join(mm_cfg.LOCK_DIR, filename))
882 # remove archives ?
883 if del_archives:
884 REMOVABLES.extend([
885 os.path.join('archives', 'private', lname),
886 os.path.join('archives', 'private', lname+'.mbox'),
887 os.path.join('archives', 'public', lname),
888 os.path.join('archives', 'public', lname+'.mbox')
889 ])
890 map(lambda dir: remove_it(lname, os.path.join(mm_cfg.VAR_PREFIX, dir)), REMOVABLES)
891 return 1
892 except:
893 return 0
894
ae6c293b 895def kill(userdesc, perms, vhost, alias, del_from_promo):
0337d704 896 exclude = []
897 if not del_from_promo:
898 exclude.append(PLATAL_DOMAIN+VHOST_SEP+'promo'+alias[-4:])
899 for list in Utils.list_names():
900 if list in exclude: continue
901 try:
ae6c293b 902 mlist = MailList.MailList(list, lock=0)
0337d704 903 except:
904 continue
905 try:
906 mlist.Lock()
ae6c293b 907 mlist.ApprovedDeleteMember(alias+'@'+PLATAL_DOMAIN, None, 0, 0)
0337d704 908 mlist.Save()
909 mlist.Unlock()
910 except:
911 mlist.Unlock()
912 return 1
913
914
915#-------------------------------------------------------------------------------
916# server
917#
918class FastXMLRPCServer(SocketServer.ThreadingMixIn, SimpleXMLRPCServer):
ae6c293b 919 allow_reuse_address = True
0337d704 920
921################################################################################
922#
ae6c293b 923# INIT
0337d704 924#
925#-------------------------------------------------------------------------------
926# use Mailman user and group (not root)
927# fork in background if asked to
928#
929
930uid = getpwnam(mm_cfg.MAILMAN_USER)[2]
931gid = getgrnam(mm_cfg.MAILMAN_GROUP)[2]
932
933if not os.getuid():
ae6c293b 934 os.setregid(gid, gid)
935 os.setreuid(uid, uid)
0337d704 936
937signal.signal(signal.SIGHUP, signal.SIG_IGN)
938
939if ( os.getuid() is not uid ) or ( os.getgid() is not gid):
940 sys.exit(0)
941
942opts, args = getopt.getopt(sys.argv[1:], 'f')
943for o, a in opts:
944 if o == '-f' and os.fork():
945 sys.exit(0)
946
947i18n.set_language('fr')
948mysql = connectDB()
949lock = Lock()
950
951#-------------------------------------------------------------------------------
952# server
953#
954server = FastXMLRPCServer(("localhost", 4949), BasicAuthXMLRPCRequestHandler)
955
956# index.php
957server.register_function(get_lists)
958server.register_function(subscribe)
959server.register_function(unsubscribe)
960# members.php
961server.register_function(get_members)
962# trombi.php
963server.register_function(get_members_limit)
964server.register_function(get_owners)
965# admin.php
c4d57bd8 966server.register_function(replace_email)
0337d704 967server.register_function(mass_subscribe)
968server.register_function(mass_unsubscribe)
969server.register_function(add_owner)
970server.register_function(del_owner)
971# moderate.php
972server.register_function(get_pending_ops)
973server.register_function(handle_request)
974server.register_function(get_pending_mail)
975# options.php
976server.register_function(get_owner_options)
977server.register_function(set_owner_options)
978server.register_function(add_to_wl)
979server.register_function(del_from_wl)
980server.register_function(get_bogo_level)
981server.register_function(set_bogo_level)
982# soptions.php
983server.register_function(get_admin_options)
984server.register_function(set_admin_options)
985# check.php
986server.register_function(check_options)
987# create + del
988server.register_function(get_all_lists)
989server.register_function(create_list)
990server.register_function(delete_list)
991# utilisateurs.php
992server.register_function(kill)
993
994server.serve_forever()
995
996# vim:set et:
plat/al