projects / platal.git / blame
? search:
summary | shortlog | log | commit | commitdiff | tree
blob | blame (incremental) | history | HEAD
Integrates external readers to the rss feeds and the iCal calendars.
[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
ea626742 174 h = str('').join(re.split('[\x00-\x08\x0B-\x1f]+', h))
25112e7a 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)
cf5e8ef1 194 return (email.lower(), 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:
cf5e8ef1 298 udesc = UserDesc(email.lower(), email.lower(), None, 0)
0337d704 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
79a9ca23 358def get_name(member):
359 try:
360 return quote(mlist.getMemberName(member))
361 except:
79a9ca23 362 return ''
363
ae6c293b 364def get_members(userdesc, perms, vhost, listname):
0337d704 365 try:
ae6c293b 366 mlist = MailList.MailList(vhost+VHOST_SEP+listname.lower(), lock=0)
0337d704 367 except:
368 return 0
369 try:
ae6c293b 370 details, members = get_list_info(userdesc, perms, mlist)
0337d704 371 members.sort()
79a9ca23 372 members = map(lambda member: (get_name(member), member), members)
ae6c293b 373 return (details, members, mlist.owner)
0337d704 374 except:
375 return 0
376
377#-------------------------------------------------------------------------------
378# users procedures for [ trombi.php ]
379#
380
ae6c293b 381def get_members_limit(userdesc, perms, vhost, listname, page, nb_per_page):
0337d704 382 try:
ae6c293b 383 members = get_members(userdesc, perms, vhost, listname.lower())[1]
0337d704 384 except:
385 return 0
386 i = int(page) * int(nb_per_page)
387 return (len(members), members[i:i+int(nb_per_page)])
388
ae6c293b 389def get_owners(userdesc, perms, vhost, listname):
0337d704 390 try:
ae6c293b 391 details, members, owners = get_members(userdesc, perms, vhost, listname.lower())
0337d704 392 except:
393 return 0
ae6c293b 394 return (details, owners)
0337d704 395
396#-------------------------------------------------------------------------------
397# owners procedures [ admin.php ]
398#
399
c4d57bd8 400def replace_email(userdesc, perms, vhost, listname, from_email, to_email):
401 try:
402 mlist = MailList.MailList(vhost+VHOST_SEP+listname.lower(), lock=0)
403 except:
404 return 0
405 try:
406 if not is_admin_on(userdesc, perms, mlist):
407 return 0
408
409 mlist.Lock()
cf5e8ef1 410 mlist.ApprovedChangeMemberAddress(from_email.lower(), to_email.lower(), 0)
c4d57bd8 411 mlist.Save()
412 mlist.Unlock()
413 return 1
414 except:
415 return 0
416
ae6c293b 417def mass_subscribe(userdesc, perms, vhost, listname, users):
0337d704 418 try:
ae6c293b 419 mlist = MailList.MailList(vhost+VHOST_SEP+listname.lower(), lock=0)
0337d704 420 except:
421 return 0
422 try:
423 if not is_admin_on(userdesc, perms, mlist):
424 return 0
ae6c293b 425
0337d704 426 members = mlist.getRegularMemberKeys()
427 added = []
428 mlist.Lock()
429 for user in users:
430 email, name = to_forlife(user)
431 if ( email is None ) or ( email in members ):
432 continue
433 userd = UserDesc(email, name, None, 0)
434 mlist.ApprovedAddMember(userd)
435 added.append( (quote(userd.fullname), userd.address) )
436 mlist.Save()
437 except:
438 pass
439 mlist.Unlock()
440 return added
441
ae6c293b 442def mass_unsubscribe(userdesc, perms, vhost, listname, users):
0337d704 443 try:
ae6c293b 444 mlist = MailList.MailList(vhost+VHOST_SEP+listname.lower(), lock=0)
0337d704 445 except:
446 return 0
447 try:
448 if not is_admin_on(userdesc, perms, mlist):
449 return 0
ae6c293b 450
0337d704 451 mlist.Lock()
452 map(lambda user: mlist.ApprovedDeleteMember(user), users)
453 mlist.Save()
454 except:
455 pass
456 mlist.Unlock()
457 return users
458
ae6c293b 459def add_owner(userdesc, perms, vhost, listname, user):
0337d704 460 try:
ae6c293b 461 mlist = MailList.MailList(vhost+VHOST_SEP+listname.lower(), lock=0)
0337d704 462 except:
463 return 0
464 try:
465 if not is_admin_on(userdesc, perms, mlist):
466 return 0
467 email = to_forlife(user)[0]
468 if email is None:
469 return 0
470 if email not in mlist.owner:
471 mlist.Lock()
472 mlist.owner.append(email)
473 mlist.Save()
474 except:
475 pass
476 mlist.Unlock()
477 return True
478
ae6c293b 479def del_owner(userdesc, perms, vhost, listname, user):
0337d704 480 try:
ae6c293b 481 mlist = MailList.MailList(vhost+VHOST_SEP+listname.lower(), lock=0)
0337d704 482 except:
483 return 0
484 try:
485 if not is_admin_on(userdesc, perms, mlist):
486 return 0
487 if len(mlist.owner) < 2:
488 return 0
489 mlist.Lock()
490 mlist.owner.remove(user)
491 mlist.Save()
492 except:
493 pass
494 mlist.Unlock()
495 return True
496
497#-------------------------------------------------------------------------------
498# owners procedures [ admin.php ]
499#
500
ae6c293b 501def get_pending_ops(userdesc, perms, vhost, listname):
0337d704 502 try:
ae6c293b 503 mlist = MailList.MailList(vhost+VHOST_SEP+listname.lower(), lock=0)
0337d704 504 except:
505 return 0
506 try:
507 if not is_admin_on(userdesc, perms, mlist):
508 return 0
ae6c293b 509
0337d704 510 mlist.Lock()
ae6c293b 511
0337d704 512 subs = []
513 seen = []
514 dosave = False
515 for id in mlist.GetSubscriptionIds():
516 time, addr, fullname, passwd, digest, lang = mlist.GetRecord(id)
517 if addr in seen:
518 mlist.HandleRequest(id, mm_cfg.DISCARD)
519 dosave = True
520 continue
521 seen.append(addr)
522 try:
523 login = re.match("^[^.]*\.[^.]*\.\d\d\d\d$", addr.split('@')[0]).group()
524 subs.append({'id': id, 'name': quote(fullname), 'addr': addr, 'login': login })
525 except:
526 subs.append({'id': id, 'name': quote(fullname), 'addr': addr })
527
528 helds = []
529 for id in mlist.GetHeldMessageIds():
530 ptime, sender, subject, reason, filename, msgdata = mlist.GetRecord(id)
531 try:
532 size = os.path.getsize(os.path.join(mm_cfg.DATA_DIR, filename))
533 except OSError, e:
534 if e.errno <> errno.ENOENT: raise
535 continue
536 helds.append({
537 'id' : id,
538 'sender': quote(sender, True),
539 'size' : size,
540 'subj' : quote(subject, True),
541 'stamp' : ptime
542 })
543 if dosave: mlist.Save()
544 mlist.Unlock()
545 except:
546 mlist.Unlock()
547 return 0
ae6c293b 548 return (subs, helds)
0337d704 549
ae6c293b 550def handle_request(userdesc, perms, vhost, listname, id, value, comment):
0337d704 551 try:
ae6c293b 552 mlist = MailList.MailList(vhost+VHOST_SEP+listname.lower(), lock=0)
0337d704 553 except:
554 return 0
555 try:
556 if not is_admin_on(userdesc, perms, mlist):
557 return 0
558 mlist.Lock()
ae6c293b 559 mlist.HandleRequest(int(id), int(value), comment)
0337d704 560 mlist.Save()
561 mlist.Unlock()
562 return 1
563 except:
564 mlist.Unlock()
565 return 0
566
4b0d9ef3 567def get_pending_sub(userdesc, perms, vhost, listname, id):
568 try:
569 mlist = MailList.MailList(vhost+VHOST_SEP+listname.lower(), lock=0)
570 except:
571 return 0
572 try:
573 if not is_admin_on(userdesc, perms, mlist):
574 return 0
575
576 mlist.Lock()
577 sub = 0
578 id = int(id)
579 if id in mlist.GetSubscriptionIds():
580 time, addr, fullname, passwd, digest, lang = mlist.GetRecord(id)
581 try:
582 login = re.match("^[^.]*\.[^.]*\.\d\d\d\d$", addr.split('@')[0]).group()
583 sub = {'id': id, 'name': quote(fullname), 'addr': addr, 'login': login }
584 except:
585 sub = {'id': id, 'name': quote(fullname), 'addr': addr }
586 mlist.Unlock()
587 except:
588 mlist.Unlock()
589 return 0
590 return sub
0337d704 591
ae6c293b 592def get_pending_mail(userdesc, perms, vhost, listname, id, raw=0):
0337d704 593 try:
ae6c293b 594 mlist = MailList.MailList(vhost+VHOST_SEP+listname.lower(), lock=0)
0337d704 595 except:
596 return 0
597 try:
598 if not is_admin_on(userdesc, perms, mlist):
599 return 0
600 mlist.Lock()
601 ptime, sender, subject, reason, filename, msgdata = mlist.GetRecord(int(id))
602 fpath = os.path.join(mm_cfg.DATA_DIR, filename)
603 size = os.path.getsize(fpath)
604 msg = readMessage(fpath)
605 mlist.Unlock()
ae6c293b 606
0337d704 607 if raw:
ea626742 608 return quote(str(msg))
ae0508cb 609 results_plain = []
610 results_html = []
ae6c293b 611 for part in typed_subpart_iterator(msg, 'text', 'plain'):
0337d704 612 c = part.get_payload()
ae0508cb 613 if c is not None: results_plain.append (c)
614 results_plain = map(lambda x: quote(x), results_plain)
615 for part in typed_subpart_iterator(msg, 'text', 'html'):
616 c = part.get_payload()
617 if c is not None: results_html.append (c)
618 results_html = map(lambda x: quote(x), results_html)
0337d704 619 return {'id' : id,
620 'sender': quote(sender, True),
621 'size' : size,
622 'subj' : quote(subject, True),
623 'stamp' : ptime,
ae0508cb 624 'parts_plain' : results_plain,
625 'parts_html': results_html }
0337d704 626 except:
627 mlist.Unlock()
628 return 0
629
630#-------------------------------------------------------------------------------
631# owner options [ options.php ]
632#
633
634owner_opts = ['accept_these_nonmembers', 'admin_notify_mchanges', 'description', \
635 'default_member_moderation', 'generic_nonmember_action', 'info', \
636 'subject_prefix', 'goodbye_msg', 'send_goodbye_msg', 'subscribe_policy', \
637 'welcome_msg']
638
ae6c293b 639def get_owner_options(userdesc, perms, vhost, listname):
640 return get_options(userdesc, perms, vhost, listname.lower(), owner_opts)
0337d704 641
ae6c293b 642def set_owner_options(userdesc, perms, vhost, listname, values):
643 return set_options(userdesc, perms, vhost, listname.lower(), owner_opts, values)
0337d704 644
ae6c293b 645def add_to_wl(userdesc, perms, vhost, listname, addr):
0337d704 646 try:
ae6c293b 647 mlist = MailList.MailList(vhost+VHOST_SEP+listname.lower(), lock=0)
0337d704 648 except:
649 return 0
650 try:
651 if not is_admin_on(userdesc, perms, mlist):
652 return 0
653 mlist.Lock()
654 mlist.accept_these_nonmembers.append(addr)
655 mlist.Save()
656 mlist.Unlock()
657 return 1
658 except:
659 mlist.Unlock()
660 return 0
661
ae6c293b 662def del_from_wl(userdesc, perms, vhost, listname, addr):
0337d704 663 try:
ae6c293b 664 mlist = MailList.MailList(vhost+VHOST_SEP+listname.lower(), lock=0)
0337d704 665 except:
666 return 0
667 try:
668 if not is_admin_on(userdesc, perms, mlist):
669 return 0
670 mlist.Lock()
671 mlist.accept_these_nonmembers.remove(addr)
672 mlist.Save()
673 mlist.Unlock()
674 return 1
675 except:
676 mlist.Unlock()
677 return 0
678
ae6c293b 679def get_bogo_level(userdesc, perms, vhost, listname):
0337d704 680 try:
ae6c293b 681 mlist = MailList.MailList(vhost+VHOST_SEP+listname.lower(), lock=0)
0337d704 682 except:
683 return 0
684 try:
685 if not is_admin_on(userdesc, perms, mlist):
686 return 0
687 if mlist.header_filter_rules == []:
688 return 0
4988c5a9 689 try:
690 action = mlist.header_filter_rules[1][1]
0337d704 691 return 2
4988c5a9 692 except:
693 action = mlist.header_filter_rules[0][1]
694 if action == mm_cfg.HOLD:
695 return 1
696 if action == mm_cfg.DISCARD:
697 return 3
0337d704 698 except:
699 return 0
700
ae6c293b 701def set_bogo_level(userdesc, perms, vhost, listname, level):
0337d704 702 try:
ae6c293b 703 mlist = MailList.MailList(vhost+VHOST_SEP+listname.lower(), lock=0)
0337d704 704 except:
705 return 0
706 try:
707 if not is_admin_on(userdesc, perms, mlist):
708 return 0
709 hfr = []
710 if int(level) is 1:
711 hfr.append(('X-Spam-Flag: Yes, tests=bogofilter', mm_cfg.HOLD, False))
712 elif int(level) is 2:
4988c5a9 713 hfr.append(('X-Spam-Flag: Yes, tests=bogofilter, spamicity=(0\.999999|1\.000000)', mm_cfg.DISCARD, False))
714 hfr.append(('X-Spam-Flag: Yes, tests=bogofilter', mm_cfg.HOLD, False))
715 elif int(level) is 3:
0337d704 716 hfr.append(('X-Spam-Flag: Yes, tests=bogofilter', mm_cfg.DISCARD, False))
717 if mlist.header_filter_rules != hfr:
718 mlist.Lock()
719 mlist.header_filter_rules = hfr
720 mlist.Save()
721 mlist.Unlock()
722 return 1
723 except:
724 mlist.Unlock()
725 return 0
726
727#-------------------------------------------------------------------------------
728# admin procedures [ soptions.php ]
729#
730
731admin_opts = [ 'advertised', 'archive', \
732 'max_message_size', 'msg_footer', 'msg_header']
733
ae6c293b 734def get_admin_options(userdesc, perms, vhost, listname):
0337d704 735 if perms != 'admin':
736 return 0
ae6c293b 737 return get_options(userdesc, perms, vhost, listname.lower(), admin_opts)
0337d704 738
ae6c293b 739def set_admin_options(userdesc, perms, vhost, listname, values):
0337d704 740 if perms != 'admin':
741 return 0
ae6c293b 742 return set_options(userdesc, perms, vhost, listname.lower(), admin_opts, values)
0337d704 743
744#-------------------------------------------------------------------------------
745# admin procedures [ check.php ]
746#
747
748check_opts = {
749 'acceptable_aliases' : '',
750 'admin_immed_notify' : True,
751 'administrivia' : True,
752 'anonymous_list' : False,
753 'autorespond_admin' : False,
754 'autorespond_postings' : False,
755 'autorespond_requests' : False,
756 'available_languages' : ['fr'],
757 'ban_list' : [],
758 'bounce_matching_headers' : '',
759 'bounce_processing' : False,
760 'convert_html_to_plaintext' : False,
761 'digestable' : False,
762 'digest_is_default' : False,
763 'discard_these_nonmembers' : [],
764 'emergency' : False,
765 'encode_ascii_prefixes' : 2,
766 'filter_content' : False,
767 'first_strip_reply_to' : False,
768 'forward_auto_discards' : True,
769 'hold_these_nonmembers' : [],
770 'host_name' : 'listes.polytechnique.org',
771 'include_list_post_header' : False,
772 'include_rfc2369_headers' : False,
773 'max_num_recipients' : 0,
774 'new_member_options' : 256,
775 'nondigestable' : True,
776 'obscure_addresses' : True,
777 'preferred_language' : 'fr',
778 'reject_these_nonmembers' : [],
779 'reply_goes_to_list' : 0,
780 'reply_to_address' : '',
781 'require_explicit_destination' : False,
782 'send_reminders' : 0,
783 'send_welcome_msg' : True,
784 'topics_enabled' : False,
785 'umbrella_list' : False,
786 'unsubscribe_policy' : 0,
787}
788
ae6c293b 789def check_options(userdesc, perms, vhost, listname, correct=False):
88f7a3f1 790 listname = listname.lower()
0337d704 791 try:
88f7a3f1 792 mlist = MailList.MailList(vhost+VHOST_SEP+listname, lock=0)
0337d704 793 except:
794 return 0
795 try:
796 if perms != 'admin': return 0
797 if correct:
798 mlist.Lock()
799 options = { }
ae6c293b 800 for (k, v) in check_opts.iteritems():
0337d704 801 if mlist.__dict__[k] != v:
ae6c293b 802 options[k] = v, mlist.__dict__[k]
0337d704 803 if correct: mlist.__dict__[k] = v
804 if mlist.real_name.lower() != listname:
805 options['real_name'] = listname, mlist.real_name
806 if correct: mlist.real_name = listname
807 if correct:
808 mlist.Save()
809 mlist.Unlock()
ae6c293b 810 details = get_list_info(userdesc, perms, mlist)[0]
811 return (details, options)
0337d704 812 except:
813 if correct: mlist.Unlock()
814 return 0
815
816#-------------------------------------------------------------------------------
817# super-admin procedures
818#
819
ae6c293b 820def get_all_lists(userdesc, perms, vhost):
0337d704 821 prefix = vhost.lower()+VHOST_SEP
822 names = Utils.list_names()
823 names.sort()
824 result = []
825 for name in names:
826 if not name.startswith(prefix):
827 continue
ae6c293b 828 result.append(name.replace(prefix, ''))
0337d704 829 return result
830
ae6c293b 831def create_list(userdesc, perms, vhost, listname, desc, advertise, modlevel, inslevel, owners, members):
0337d704 832 if perms != 'admin':
833 return 0
834 name = vhost.lower()+VHOST_SEP+listname.lower();
835 if Utils.list_exists(name):
836 return 0
ae6c293b 837
0337d704 838 owner = []
839 for o in owners:
840 email = to_forlife(o)[0]
841 if email is not None:
842 owner.append(email)
843 if len(owner) is 0:
844 return 0
845
846 mlist = MailList.MailList()
847 try:
848 oldmask = os.umask(002)
849 pw = sha.new('foobar').hexdigest()
ae6c293b 850
0337d704 851 try:
852 mlist.Create(name, owner[0], pw)
853 finally:
854 os.umask(oldmask)
855
856 mlist.real_name = listname
857 mlist.host_name = 'listes.polytechnique.org'
858 mlist.description = desc
859
860 mlist.advertised = int(advertise) is 0
861 mlist.default_member_moderation = int(modlevel) is 2
862 mlist.generic_nonmember_action = int(modlevel) > 0
863 mlist.subscribe_policy = 2 * (int(inslevel) is 1)
864 mlist.admin_notify_mchanges = (mlist.subscribe_policy or mlist.generic_nonmember_action or mlist.default_member_moderation or not mlist.advertised)
ae6c293b 865
0337d704 866 mlist.owner = owner
ae6c293b 867
0337d704 868 mlist.subject_prefix = '['+listname+'] '
869 mlist.max_message_size = 0
870
e480db84 871 inverted_listname = listname.lower() + '_' + vhost.lower()
0337d704 872 mlist.msg_footer = "_______________________________________________\n" \
31f2df6a 873 + "Liste de diffusion %(real_name)s\n" \
874 + "http://listes.polytechnique.org/members/" + inverted_listname
ae6c293b 875
0337d704 876 mlist.header_filter_rules = []
877 mlist.header_filter_rules.append(('X-Spam-Flag: Yes, tests=bogofilter', mm_cfg.HOLD, False))
878
879 mlist.Save()
880
881 mlist.Unlock()
882
98c79ede 883 if ON_CREATE_CMD != '':
884 try: os.system(ON_CREATE_CMD + ' ' + name)
885 except: pass
886
ae6c293b 887 check_options(userdesc, perms, vhost, listname.lower(), True)
888 mass_subscribe(userdesc, perms, vhost, listname.lower(), members)
0337d704 889
890 # avoid the "-1 mail to moderate" bug
891 mlist = MailList.MailList(name)
892 mlist._UpdateRecords()
893 mlist.Save()
894 mlist.Unlock()
0337d704 895 except:
896 try:
897 mlist.Unlock()
898 except:
899 pass
900 return 0
901 return 1
902
ae6c293b 903def delete_list(userdesc, perms, vhost, listname, del_archives=0):
0337d704 904 lname = vhost+VHOST_SEP+listname.lower()
905 try:
ae6c293b 906 mlist = MailList.MailList(lname, lock=0)
0337d704 907 except:
908 return 0
909 try:
910 if not is_admin_on(userdesc, perms, mlist):
911 return 0
912 # remove the list
913 REMOVABLES = [ os.path.join('lists', lname), ]
914 # remove stalled locks
915 for filename in os.listdir(mm_cfg.LOCK_DIR):
916 fn_lname = filename.split('.')[0]
917 if fn_lname == lname:
918 REMOVABLES.append(os.path.join(mm_cfg.LOCK_DIR, filename))
919 # remove archives ?
920 if del_archives:
921 REMOVABLES.extend([
922 os.path.join('archives', 'private', lname),
923 os.path.join('archives', 'private', lname+'.mbox'),
924 os.path.join('archives', 'public', lname),
925 os.path.join('archives', 'public', lname+'.mbox')
926 ])
927 map(lambda dir: remove_it(lname, os.path.join(mm_cfg.VAR_PREFIX, dir)), REMOVABLES)
928 return 1
929 except:
930 return 0
931
ae6c293b 932def kill(userdesc, perms, vhost, alias, del_from_promo):
0337d704 933 exclude = []
934 if not del_from_promo:
935 exclude.append(PLATAL_DOMAIN+VHOST_SEP+'promo'+alias[-4:])
936 for list in Utils.list_names():
937 if list in exclude: continue
938 try:
ae6c293b 939 mlist = MailList.MailList(list, lock=0)
0337d704 940 except:
941 continue
942 try:
943 mlist.Lock()
ae6c293b 944 mlist.ApprovedDeleteMember(alias+'@'+PLATAL_DOMAIN, None, 0, 0)
0337d704 945 mlist.Save()
946 mlist.Unlock()
947 except:
948 mlist.Unlock()
949 return 1
950
951
952#-------------------------------------------------------------------------------
953# server
954#
955class FastXMLRPCServer(SocketServer.ThreadingMixIn, SimpleXMLRPCServer):
ae6c293b 956 allow_reuse_address = True
0337d704 957
958################################################################################
959#
ae6c293b 960# INIT
0337d704 961#
962#-------------------------------------------------------------------------------
963# use Mailman user and group (not root)
964# fork in background if asked to
965#
966
967uid = getpwnam(mm_cfg.MAILMAN_USER)[2]
968gid = getgrnam(mm_cfg.MAILMAN_GROUP)[2]
969
970if not os.getuid():
ae6c293b 971 os.setregid(gid, gid)
972 os.setreuid(uid, uid)
0337d704 973
974signal.signal(signal.SIGHUP, signal.SIG_IGN)
975
976if ( os.getuid() is not uid ) or ( os.getgid() is not gid):
977 sys.exit(0)
978
979opts, args = getopt.getopt(sys.argv[1:], 'f')
980for o, a in opts:
981 if o == '-f' and os.fork():
982 sys.exit(0)
983
984i18n.set_language('fr')
985mysql = connectDB()
986lock = Lock()
987
988#-------------------------------------------------------------------------------
989# server
990#
991server = FastXMLRPCServer(("localhost", 4949), BasicAuthXMLRPCRequestHandler)
992
993# index.php
994server.register_function(get_lists)
995server.register_function(subscribe)
996server.register_function(unsubscribe)
997# members.php
998server.register_function(get_members)
999# trombi.php
1000server.register_function(get_members_limit)
1001server.register_function(get_owners)
1002# admin.php
c4d57bd8 1003server.register_function(replace_email)
0337d704 1004server.register_function(mass_subscribe)
1005server.register_function(mass_unsubscribe)
1006server.register_function(add_owner)
1007server.register_function(del_owner)
1008# moderate.php
1009server.register_function(get_pending_ops)
1010server.register_function(handle_request)
4b0d9ef3 1011server.register_function(get_pending_sub)
0337d704 1012server.register_function(get_pending_mail)
1013# options.php
1014server.register_function(get_owner_options)
1015server.register_function(set_owner_options)
1016server.register_function(add_to_wl)
1017server.register_function(del_from_wl)
1018server.register_function(get_bogo_level)
1019server.register_function(set_bogo_level)
1020# soptions.php
1021server.register_function(get_admin_options)
1022server.register_function(set_admin_options)
1023# check.php
1024server.register_function(check_options)
1025# create + del
1026server.register_function(get_all_lists)
1027server.register_function(create_list)
1028server.register_function(delete_list)
1029# utilisateurs.php
1030server.register_function(kill)
1031
1032server.serve_forever()
1033
1034# vim:set et:
plat/al