2 #***************************************************************************
3 #* Copyright (C) 2004-2008 polytechnique.org *
4 #* http://opensource.polytechnique.org/ *
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. *
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. *
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 #***************************************************************************
22 import base64
, MySQLdb
, os
, getopt
, sys
, sha
, signal
, re
, shutil
, ConfigParser
23 import MySQLdb
.converters
26 sys
.path
.append('/usr/lib/mailman/bin')
28 from pwd
import getpwnam
29 from grp
import getgrnam
31 from SimpleXMLRPCServer
import SimpleXMLRPCServer
32 from SimpleXMLRPCServer
import SimpleXMLRPCRequestHandler
35 from Mailman
import MailList
36 from Mailman
import Utils
37 from Mailman
import Message
38 from Mailman
import Errors
39 from Mailman
import mm_cfg
40 from Mailman
import i18n
41 from Mailman
.UserDesc
import UserDesc
42 from Mailman
.ListAdmin
import readMessage
43 from email
.Iterators
import typed_subpart_iterator
44 from threading
import Lock
46 class AuthFailed(Exception): pass
48 ################################################################################
52 #------------------------------------------------
54 config
= ConfigParser
.ConfigParser()
55 config
.read(os
.path
.dirname(__file__
)+'/../configs/platal.ini')
56 config
.read(os
.path
.dirname(__file__
)+'/../configs/platal.conf')
58 def get_config(sec
, val
, default
=None):
60 return config
.get(sec
, val
)[1:-1]
61 except ConfigParser
.NoOptionError
, e
:
63 sys
.stderr
.write('%s\n' % str
(e
))
68 MYSQL_USER
= get_config('Core', 'dbuser')
69 MYSQL_PASS
= get_config('Core', 'dbpwd')
71 PLATAL_DOMAIN
= get_config('Mail', 'domain')
72 PLATAL_DOMAIN2
= get_config('Mail', 'domain2', '')
73 sys
.stderr
.write('PLATAL_DOMAIN = %s\n' % PLATAL_DOMAIN
)
75 VHOST_SEP
= get_config('Lists', 'vhost_sep', '_')
76 ON_CREATE_CMD
= get_config('Lists', 'on_create', '')
78 SRV_HOST
= get_config('Lists', 'rpchost', 'localhost')
79 SRV_PORT
= int(get_config('Lists', 'rpcport', '4949'))
81 ################################################################################
85 #------------------------------------------------
86 # Manage Basic authentication
89 class BasicAuthXMLRPCRequestHandler(SimpleXMLRPCRequestHandler
):
91 """XMLRPC Request Handler
92 This request handler is used to provide BASIC HTTP user authentication.
93 It first overloads the do_POST() function, authenticates the user, then
94 calls the super.do_POST().
96 Moreover, we override _dispatch, so that we call functions with as first
97 argument a UserDesc taken from the database, containing name, email and perms
100 def _get_function(self
, method
):
102 # check to see if a matching function has been registered
103 return self
.server
.funcs
[method
]
105 raise Exception('method "%s" is not supported' % method
)
108 def _dispatch(self
, method
, params
):
109 new_params
= list(params
)
110 return list_call_dispatcher(self
._get_function(method
), self
.data
[0], self
.data
[1], self
.data
[2], *params
)
114 _
, auth
= self
.headers
["authorization"].split()
115 uid
, md5
= base64
.decodestring(auth
).strip().split(':')
116 vhost
= self
.path
.split('/')[1].lower()
117 self
.data
= self
.getUser(uid
, md5
, vhost
)
118 if self
.data
is None:
120 # Call super.do_POST() to do the actual work
121 SimpleXMLRPCRequestHandler
.do_POST(self
)
123 self
.send_response(401)
126 def getUser(self
, uid
, md5
, vhost
):
127 res
= mysql_fetchone ("""SELECT CONCAT(u.prenom, ' ', u.nom), a.alias, u.perms
128 FROM auth_user_md5 AS u
129 INNER JOIN aliases AS a ON ( a.id=u.user_id AND a.type='a_vie' )
130 WHERE u.user_id = '%s' AND u.password = '%s' AND u.perms IN ('admin', 'user')
131 LIMIT 1""" %( uid
, md5
) )
133 name
, forlife
, perms
= res
134 if vhost
!= PLATAL_DOMAIN
:
135 res
= mysql_fetchone ("""SELECT uid
136 FROM groupex.membres AS m
137 INNER JOIN groupex.asso AS a ON (m.asso_id = a.id)
138 WHERE perms='admin' AND uid='%s' AND mail_domain='%s'""" %( uid
, vhost
) )
139 if res
: perms
= 'admin'
140 userdesc
= UserDesc(forlife
+'@'+PLATAL_DOMAIN
, name
, None, 0)
141 return (userdesc
, perms
, vhost
)
145 ################################################################################
149 #-------------------------------------------------------------------------------
154 db
= MySQLdb
.connect(
158 unix_socket
='/var/run/mysqld/mysqld.sock')
162 def mysql_fetchone(query
):
167 if int(mysql
.rowcount
) > 0:
168 ret
= mysql
.fetchone()
173 def is_admin_on(userdesc
, perms
, mlist
):
174 return ( perms
== 'admin' ) or ( userdesc
.address
in mlist
.owner
)
177 def quote(s
, is_header
=False):
179 h
= Utils
.oneline(s
, 'iso-8859-1')
182 h
= str('').join(re
.split('[\x00-\x08\x0B-\x1f]+', h
))
183 return Utils
.uquote(h
.replace('&', '&').replace('>', '>').replace('<', '<'))
185 def to_forlife(email
):
187 mbox
, fqdn
= email
.split('@')
191 if ( fqdn
== PLATAL_DOMAIN
) or ( fqdn
== PLATAL_DOMAIN2
):
192 res
= mysql_fetchone("""SELECT CONCAT(f.alias, '@%s'), CONCAT(u.prenom, ' ', u.nom)
193 FROM auth_user_md5 AS u
194 INNER JOIN aliases AS f ON (f.id=u.user_id AND f.type='a_vie')
195 INNER JOIN aliases AS a ON (a.id=u.user_id AND a.alias='%s' AND a.type!='homonyme')
196 WHERE u.perms IN ('admin', 'user')
197 LIMIT 1""" %( PLATAL_DOMAIN
, mbox
) )
202 return (email
.lower(), mbox
)
205 # see /usr/lib/mailman/bin/rmlist
207 def remove_it(listname
, filename
):
208 if os
.path
.islink(filename
) or os
.path
.isfile(filename
):
210 elif os
.path
.isdir(filename
):
211 shutil
.rmtree(filename
)
217 def has_annotation(method
, name
):
218 """ Check if the method contains the given annoation.
220 return method
.__doc__
and method
.__doc__
.find("@%s" % name
) > -1
222 def list_call_dispatcher(method
, userdesc
, perms
, vhost
, *arg
):
223 """Dispatch the call to the right handler.
224 This function checks the options of the called method the set the environment of the call.
225 The dispatcher uses method annotation (special tokens in the documentation of the method) to
226 guess the requested environment:
227 @mlist: the handler requires a mlist object instead of the vhost/listname couple
228 @lock: the handler requires the mlist to be locked (@mlist MUST be specified)
229 @edit: the handler edit the mlist (@mlist MUST be specified)
230 @admin: the handler requires admin rights on the list (@mlist MUST be specified)
231 @root: the handler requires site admin rights
234 if has_annotation(method
, "root") and perms
!= "admin":
236 if has_annotation(method
, "mlist"):
239 mlist
= MailList
.MailList(vhost
+ VHOST_SEP
+ listname
.lower(), lock
=0)
240 if has_annotation(method
, "admin") and not is_admin_on(userdesc
, perms
, mlist
):
242 if has_annotation(method
, "edit") or has_annotation(method
, "lock"):
243 return list_call_locked(method
, userdesc
, perms
, mlist
, has_annotation(method
, "edit"), *arg
)
245 return method(userdesc
, perms
, mlist
, *arg
)
247 return method(userdesc
, perms
, vhost
, *arg
)
249 sys
.stderr
.write('Exception in dispatcher %s\n' % str
(e
))
253 def list_call_locked(method
, userdesc
, perms
, mlist
, edit
, *arg
):
254 """Call the given method after locking the mlist.
258 ret
= method(userdesc
, perms
, mlist
, *arg
)
264 sys
.stderr
.write('Exception in locked call %s: %s\n' %
(method
.__name__
, str(e
)))
267 # TODO: use finally when switching to python 2.5
269 #-------------------------------------------------------------------------------
273 def is_subscription_pending(userdesc
, perms
, mlist
):
274 for id in mlist
.GetSubscriptionIds():
275 if userdesc
.address
== mlist
.GetRecord(id)[1]:
279 def get_list_info(userdesc
, perms
, mlist
, front_page
=0):
280 members
= mlist
.getRegularMemberKeys()
281 is_member
= userdesc
.address
in members
282 is_owner
= userdesc
.address
in mlist
.owner
283 if mlist
.advertised
or is_member
or is_owner
or (not front_page
and perms
== 'admin'):
285 if not is_member
and (mlist
.subscribe_policy
> 1):
286 is_pending
= list_call_locked(is_subscription_pending
, userdesc
, perms
, mlist
, False)
290 host
= mlist
.internal_name().split(VHOST_SEP
)[0].lower()
292 'list' : mlist
.real_name
,
293 'addr' : mlist
.real_name
.lower() + '@' + host
,
295 'desc' : quote(mlist
.description
),
296 'info' : quote(mlist
.info
),
297 'diff' : (mlist
.default_member_moderation
>0) + (mlist
.generic_nonmember_action
>0),
298 'ins' : mlist
.subscribe_policy
> 1,
299 'priv' : 1-mlist
.advertised
,
300 'sub' : 2*is_member
+ is_pending
,
302 'nbsub': len(members
)
304 return (details
, members
)
307 def get_options(userdesc
, perms
, mlist
, opts
):
308 """ Get the options of a list.
313 for (k
, v
) in mlist
.__dict__
.iteritems():
316 options
[k
] = quote(v
)
318 details
= get_list_info(userdesc
, perms
, mlist
)[0]
319 return (details
, options
)
321 def set_options(userdesc
, perms
, mlist
, vals
):
322 """ Set the options of a list.
327 for (k
, v
) in vals
.iteritems():
330 if k
== 'default_member_moderation':
331 for member
in mlist
.getMembers():
332 mlist
.setMemberOption(member
, mm_cfg
.Moderate
, int(v
))
333 t
= type(mlist
.__dict__
[k
])
334 if t
is bool: mlist
.__dict__
[k
] = bool(v
)
335 elif t
is int: mlist
.__dict__
[k
] = int(v
)
336 elif t
is str: mlist
.__dict__
[k
] = Utils
.uncanonstr(v
, 'fr')
337 else: mlist
.__dict__
[k
] = v
340 #-------------------------------------------------------------------------------
341 # users procedures for [ index.php ]
344 def get_lists(userdesc
, perms
, vhost
, email
=None):
345 """ List available lists for the given vhost
350 udesc
= UserDesc(email
.lower(), email
.lower(), None, 0)
351 prefix
= vhost
.lower()+VHOST_SEP
352 names
= Utils
.list_names()
356 if not name
.startswith(prefix
):
359 mlist
= MailList
.MailList(name
, lock
=0)
363 details
= get_list_info(udesc
, perms
, mlist
, (email
is None and vhost
== PLATAL_DOMAIN
))[0]
364 result
.append(details
)
366 sys
.stderr
.write('Can\'t get list %s: %s\n' %
(name
, str(e
)))
370 def subscribe(userdesc
, perms
, mlist
):
371 """ Subscribe to a list.
375 if ( mlist
.subscribe_policy
in (0, 1) ) or userdesc
.address
in mlist
.owner
:
376 mlist
.ApprovedAddMember(userdesc
)
381 mlist
.AddMember(userdesc
)
382 except Errors
.MMNeedApproval
:
386 def unsubscribe(userdesc
, perms
, mlist
):
387 """ Unsubscribe from a list
391 mlist
.ApprovedDeleteMember(userdesc
.address
)
394 #-------------------------------------------------------------------------------
395 # users procedures for [ index.php ]
398 def get_name(member
):
400 return quote(mlist
.getMemberName(member
))
404 def get_members(userdesc
, perms
, mlist
):
405 """ List the members of a list.
408 details
, members
= get_list_info(userdesc
, perms
, mlist
)
410 members
= map(lambda member
: (get_name(member
), member
), members
)
411 return (details
, members
, mlist
.owner
)
414 #-------------------------------------------------------------------------------
415 # users procedures for [ trombi.php ]
418 def get_members_limit(userdesc
, perms
, mlist
, page
, nb_per_page
):
419 """ Get a range of members of the list.
422 members
= get_members(userdesc
, perms
, mlist
)[1]
423 i
= int(page
) * int(nb_per_page
)
424 return (len(members
), members
[i
:i
+int(nb_per_page
)])
426 def get_owners(userdesc
, perms
, mlist
):
427 """ Get the owners of the list.
430 details
, members
, owners
= get_members(userdesc
, perms
, mlist
)
431 return (details
, owners
)
434 #-------------------------------------------------------------------------------
435 # owners procedures [ admin.php ]
438 def replace_email(userdesc
, perms
, mlist
, from_email
, to_email
):
439 """ Replace the address of a member by another one.
444 mlist
.ApprovedChangeMemberAddress(from_email
.lower(), to_email
.lower(), 0)
447 def mass_subscribe(userdesc
, perms
, mlist
, users
):
448 """ Add a list of users to the list.
453 members
= mlist
.getRegularMemberKeys()
456 email
, name
= to_forlife(user
)
457 if ( email
is None ) or ( email
in members
):
459 userd
= UserDesc(email
, name
, None, 0)
460 mlist
.ApprovedAddMember(userd
)
461 added
.append( (quote(userd
.fullname
), userd
.address
) )
464 def mass_unsubscribe(userdesc
, perms
, mlist
, users
):
465 """ Remove a list of users from the list.
470 map(lambda user
: mlist
.ApprovedDeleteMember(user
), users
)
473 def add_owner(userdesc
, perms
, mlist
, user
):
474 """ Add a owner to the list.
479 email
= to_forlife(user
)[0]
482 if email
not in mlist
.owner
:
483 mlist
.owner
.append(email
)
486 def del_owner(userdesc
, perms
, mlist
, user
):
487 """ Remove a owner of the list.
492 if len(mlist
.owner
) < 2:
494 mlist
.owner
.remove(user
)
497 #-------------------------------------------------------------------------------
498 # owners procedures [ admin.php ]
501 def get_pending_ops(userdesc
, perms
, mlist
):
502 """ Get the list of operation waiting for an action from the owners.
510 for id in mlist
.GetSubscriptionIds():
511 time
, addr
, fullname
, passwd
, digest
, lang
= mlist
.GetRecord(id)
513 mlist
.HandleRequest(id, mm_cfg
.DISCARD
)
518 login
= re
.match("^[^.]*\.[^.]*\.\d\d\d\d$", addr
.split('@')[0]).group()
519 subs
.append({'id': id, 'name': quote(fullname
), 'addr': addr
, 'login': login
})
521 subs
.append({'id': id, 'name': quote(fullname
), 'addr': addr
})
524 for id in mlist
.GetHeldMessageIds():
525 ptime
, sender
, subject
, reason
, filename
, msgdata
= mlist
.GetRecord(id)
526 fpath
= os
.path
.join(mm_cfg
.DATA_DIR
, filename
)
528 size
= os
.path
.getsize(fpath
)
530 if e
.errno
<> errno
.ENOENT
: raise
533 msg
= readMessage(fpath
)
534 fromX
= msg
.has_key("X-Org-Mail")
539 'sender': quote(sender
, True),
541 'subj' : quote(subject
, True),
549 def handle_request(userdesc
, perms
, mlist
, id, value
, comment
):
550 """ Handle a moderation request.
555 mlist
.HandleRequest(int(id), int(value
), comment
)
558 def get_pending_sub(userdesc
, perms
, mlist
, id):
559 """ Get informations about a given subscription moderation.
566 if id in mlist
.GetSubscriptionIds():
567 time
, addr
, fullname
, passwd
, digest
, lang
= mlist
.GetRecord(id)
569 login
= re
.match("^[^.]*\.[^.]*\.\d\d\d\d$", addr
.split('@')[0]).group()
570 sub
= {'id': id, 'name': quote(fullname
), 'addr': addr
, 'login': login
}
572 sub
= {'id': id, 'name': quote(fullname
), 'addr': addr
}
575 def get_pending_mail(userdesc
, perms
, mlist
, id, raw
=0):
576 """ Get informations about a given mail moderation.
581 ptime
, sender
, subject
, reason
, filename
, msgdata
= mlist
.GetRecord(int(id))
582 fpath
= os
.path
.join(mm_cfg
.DATA_DIR
, filename
)
583 size
= os
.path
.getsize(fpath
)
584 msg
= readMessage(fpath
)
587 return quote(str(msg
))
590 for part
in typed_subpart_iterator(msg
, 'text', 'plain'):
591 c
= part
.get_payload()
592 if c
is not None: results_plain
.append (c
)
593 results_plain
= map(lambda x
: quote(x
), results_plain
)
594 for part
in typed_subpart_iterator(msg
, 'text', 'html'):
595 c
= part
.get_payload()
596 if c
is not None: results_html
.append (c
)
597 results_html
= map(lambda x
: quote(x
), results_html
)
599 'sender': quote(sender
, True),
601 'subj' : quote(subject
, True),
603 'parts_plain' : results_plain
,
604 'parts_html': results_html
}
606 #-------------------------------------------------------------------------------
607 # owner options [ options.php ]
610 owner_opts
= ['accept_these_nonmembers', 'admin_notify_mchanges', 'description', \
611 'default_member_moderation', 'generic_nonmember_action', 'info', \
612 'subject_prefix', 'goodbye_msg', 'send_goodbye_msg', 'subscribe_policy', \
615 def get_owner_options(userdesc
, perms
, mlist
):
616 """ Get the owner options of a list.
620 return get_options(userdesc
, perms
, mlist
, owner_opts
)
622 def set_owner_options(userdesc
, perms
, mlist
, values
):
623 """ Set the owner options of a list.
628 return set_options(userdesc
, perms
, mlist
, owner_opts
, values
)
630 def add_to_wl(userdesc
, perms
, mlist
, addr
):
631 """ Add addr to the whitelist
636 mlist
.accept_these_nonmembers
.append(addr
)
639 def del_from_wl(userdesc
, perms
, mlist
, addr
):
640 """ Remove an address from the whitelist
645 mlist
.accept_these_nonmembers
.remove(addr
)
648 def get_bogo_level(userdesc
, perms
, mlist
):
649 """ Compute bogo level from the filtering rules set up on the list.
653 if len(mlist
.header_filter_rules
) == 0:
660 # The first rule filters Unsure mails
661 if mlist
.header_filter_rules
[0][0] == 'X-Spam-Flag: Unsure, tests=bogofilter':
665 # Check the other rules:
666 # - we have 2 rules: this is level 2 (drop > 0.999999, moderate Yes)
667 # - we have only one rule with HOLD directive : this is level 1 (moderate spams)
668 # - we have only one rule with DISCARD directive : this is level 3 (drop spams)
670 action
= mlist
.header_filter_rules
[filterbase
+ 1][1]
673 action
= mlist
.header_filter_rules
[filterbase
][1]
674 if action
== mm_cfg
.HOLD
:
676 elif action
== mm_cfg
.DISCARD
:
678 return (filterlevel
<< 1) + unsurelevel
680 def set_bogo_level(userdesc
, perms
, vhost
, listname
, level
):
681 """ Set filter to the specified level.
688 # The level is a combination of a spam filtering level and unsure filtering level
689 # - the unsure filtering level is only 1 bit (1 = HOLD unsures, 0 = Accept unsures)
690 # - the spam filtering level is a number growing with filtering strength
691 # (0 = no filtering, 1 = moderate spam, 2 = drop 0.999999 and moderate others, 3 = drop spams)
692 bogolevel
= int(level
)
693 filterlevel
= bogolevel
>> 1
694 unsurelevel
= bogolevel
& 1
696 # Set up unusre filtering
698 hfr
.append(('X-Spam-Flag: Unsure, tests=bogofilter', mm_cfg
.HOLD
, False))
700 # Set up spam filtering
702 hfr
.append(('X-Spam-Flag: Yes, tests=bogofilter', mm_cfg
.HOLD
, False))
703 elif filterlevel
is 2:
704 hfr
.append(('X-Spam-Flag: Yes, tests=bogofilter, spamicity=(0\.999999|1\.000000)', mm_cfg
.DISCARD
, False))
705 hfr
.append(('X-Spam-Flag: Yes, tests=bogofilter', mm_cfg
.HOLD
, False))
706 elif filterlevel
is 3:
707 hfr
.append(('X-Spam-Flag: Yes, tests=bogofilter', mm_cfg
.DISCARD
, False))
710 if mlist
.header_filter_rules
!= hfr
:
711 mlist
.header_filter_rules
= hfr
714 #-------------------------------------------------------------------------------
715 # admin procedures [ soptions.php ]
718 admin_opts
= [ 'advertised', 'archive', \
719 'max_message_size', 'msg_footer', 'msg_header']
721 def get_admin_options(userdesc
, perms
, mlist
):
722 """ Get administrator options.
726 return get_options(userdesc
, perms
, mlist
, admin_opts
)
728 def set_admin_options(userdesc
, perms
, mlist
, values
):
729 """ Set administrator options.
734 return set_options(userdesc
, perms
, mlist
, admin_opts
, values
)
736 #-------------------------------------------------------------------------------
737 # admin procedures [ check.php ]
741 'acceptable_aliases' : '',
742 'admin_immed_notify' : True,
743 'administrivia' : True,
744 'anonymous_list' : False,
745 'autorespond_admin' : False,
746 'autorespond_postings' : False,
747 'autorespond_requests' : False,
748 'available_languages' : ['fr'],
750 'bounce_matching_headers' : '',
751 'bounce_processing' : False,
752 'convert_html_to_plaintext' : False,
753 'digestable' : False,
754 'digest_is_default' : False,
755 'discard_these_nonmembers' : [],
757 'encode_ascii_prefixes' : 2,
758 'filter_content' : False,
759 'first_strip_reply_to' : False,
760 'forward_auto_discards' : True,
761 'hold_these_nonmembers' : [],
762 'host_name' : 'listes.polytechnique.org',
763 'include_list_post_header' : False,
764 'include_rfc2369_headers' : False,
765 'max_num_recipients' : 0,
766 'new_member_options' : 256,
767 'nondigestable' : True,
768 'obscure_addresses' : True,
769 'preferred_language' : 'fr',
770 'reject_these_nonmembers' : [],
771 'reply_goes_to_list' : 0,
772 'reply_to_address' : '',
773 'require_explicit_destination' : False,
774 'send_reminders' : 0,
775 'send_welcome_msg' : True,
776 'topics_enabled' : False,
777 'umbrella_list' : False,
778 'unsubscribe_policy' : 0,
781 def check_options_runner(userdesc
, perms
, mlist
, listname
, correct
):
783 for (k
, v
) in check_opts
.iteritems():
784 if mlist
.__dict__
[k
] != v
:
785 options
[k
] = v
, mlist
.__dict__
[k
]
786 if correct
: mlist
.__dict__
[k
] = v
787 if mlist
.real_name
.lower() != listname
:
788 options
['real_name'] = listname
, mlist
.real_name
789 if correct
: mlist
.real_name
= listname
793 def check_options(userdesc
, perms
, vhost
, listname
, correct
=False):
797 listname
= listname
.lower()
798 mlist
= MailList
.MailList(vhost
+ VHOST_SEP
+ listname
, lock
=0)
800 return list_call_locked(check_options_runner
, userdesc
, perms
, mlist
, True, listname
, True)
802 return check_options_runner(userdesc
, perms
, mlist
, listname
, False)
804 #-------------------------------------------------------------------------------
805 # super-admin procedures
808 def get_all_lists(userdesc
, perms
, vhost
):
809 """ Get all the list for the given vhost
811 prefix
= vhost
.lower()+VHOST_SEP
812 names
= Utils
.list_names()
816 if not name
.startswith(prefix
):
818 result
.append(name
.replace(prefix
, ''))
821 def create_list(userdesc
, perms
, vhost
, listname
, desc
, advertise
, modlevel
, inslevel
, owners
, members
):
822 """ Create a new list.
825 name
= vhost
.lower() + VHOST_SEP
+ listname
.lower();
826 if Utils
.list_exists(name
):
831 email
= to_forlife(o
)[0]
832 if email
is not None:
837 mlist
= MailList
.MailList()
839 oldmask
= os
.umask(002)
840 pw
= sha
.new('foobar').hexdigest()
843 mlist
.Create(name
, owner
[0], pw
)
847 mlist
.real_name
= listname
848 mlist
.host_name
= 'listes.polytechnique.org'
849 mlist
.description
= desc
851 mlist
.advertised
= int(advertise
) is 0
852 mlist
.default_member_moderation
= int(modlevel
) is 2
853 mlist
.generic_nonmember_action
= int(modlevel
) > 0
854 mlist
.subscribe_policy
= 2 * (int(inslevel
) is 1)
855 mlist
.admin_notify_mchanges
= (mlist
.subscribe_policy
or mlist
.generic_nonmember_action
or mlist
.default_member_moderation
or not mlist
.advertised
)
859 mlist
.subject_prefix
= '['+listname
+'] '
860 mlist
.max_message_size
= 0
862 inverted_listname
= listname
.lower() + '_' + vhost
.lower()
863 mlist
.msg_footer
= "_______________________________________________\n" \
864 + "Liste de diffusion %(real_name)s\n" \
865 + "http://listes.polytechnique.org/members/" + inverted_listname
867 mlist
.header_filter_rules
= []
868 mlist
.header_filter_rules
.append(('X-Spam-Flag: Unsure, tests=bogofilter', mm_cfg
.HOLD
, False))
869 mlist
.header_filter_rules
.append(('X-Spam-Flag: Yes, tests=bogofilter', mm_cfg
.HOLD
, False))
871 if ON_CREATE_CMD
!= '':
872 try: os
.system(ON_CREATE_CMD
+ ' ' + name
)
875 check_options_runner(userdesc
, perms
, mlist
, listname
.lower(), True)
876 mass_subscribe(userdesc
, perms
, mlist
, members
)
881 # avoid the "-1 mail to moderate" bug
882 mlist
= MailList
.MailList(name
)
883 mlist
._UpdateRecords()
887 def delete_list(userdesc
, perms
, mlist
, del_archives
=0):
892 lname
= mlist
.internal_name()
894 REMOVABLES
= [ os
.path
.join('lists', lname
), ]
895 # remove stalled locks
896 for filename
in os
.listdir(mm_cfg
.LOCK_DIR
):
897 fn_lname
= filename
.split('.')[0]
898 if fn_lname
== lname
:
899 REMOVABLES
.append(os
.path
.join(mm_cfg
.LOCK_DIR
, filename
))
903 os
.path
.join('archives', 'private', lname
),
904 os
.path
.join('archives', 'private', lname
+'.mbox'),
905 os
.path
.join('archives', 'public', lname
),
906 os
.path
.join('archives', 'public', lname
+'.mbox')
908 map(lambda dir: remove_it(lname
, os
.path
.join(mm_cfg
.VAR_PREFIX
, dir)), REMOVABLES
)
911 def kill(userdesc
, perms
, vhost
, alias
, del_from_promo
):
912 """ Remove a user from all the lists.
915 if not del_from_promo
:
916 exclude
.append(PLATAL_DOMAIN
+ VHOST_SEP
+ 'promo' + alias
[-4:])
917 for list in Utils
.list_names():
921 mlist
= MailList
.MailList(list, lock
=0)
926 mlist
.ApprovedDeleteMember(alias
+'@'+PLATAL_DOMAIN
, None, 0, 0)
934 #-------------------------------------------------------------------------------
937 class FastXMLRPCServer(SocketServer
.ThreadingMixIn
, SimpleXMLRPCServer
):
938 allow_reuse_address
= True
940 ################################################################################
944 #-------------------------------------------------------------------------------
945 # use Mailman user and group (not root)
946 # fork in background if asked to
949 uid
= getpwnam(mm_cfg
.MAILMAN_USER
)[2]
950 gid
= getgrnam(mm_cfg
.MAILMAN_GROUP
)[2]
953 os
.setregid(gid
, gid
)
954 os
.setreuid(uid
, uid
)
956 signal
.signal(signal
.SIGHUP
, signal
.SIG_IGN
)
958 if ( os
.getuid() is not uid
) or ( os
.getgid() is not gid
):
961 opts
, args
= getopt
.getopt(sys
.argv
[1:], 'f')
963 if o
== '-f' and os
.fork():
966 i18n
.set_language('fr')
970 #-------------------------------------------------------------------------------
973 server
= FastXMLRPCServer((SRV_HOST
, SRV_PORT
), BasicAuthXMLRPCRequestHandler
)
976 server
.register_function(get_lists
)
977 server
.register_function(subscribe
)
978 server
.register_function(unsubscribe
)
980 server
.register_function(get_members
)
982 server
.register_function(get_members_limit
)
983 server
.register_function(get_owners
)
985 server
.register_function(replace_email
)
986 server
.register_function(mass_subscribe
)
987 server
.register_function(mass_unsubscribe
)
988 server
.register_function(add_owner
)
989 server
.register_function(del_owner
)
991 server
.register_function(get_pending_ops
)
992 server
.register_function(handle_request
)
993 server
.register_function(get_pending_sub
)
994 server
.register_function(get_pending_mail
)
996 server
.register_function(get_owner_options
)
997 server
.register_function(set_owner_options
)
998 server
.register_function(add_to_wl
)
999 server
.register_function(del_from_wl
)
1000 server
.register_function(get_bogo_level
)
1001 server
.register_function(set_bogo_level
)
1003 server
.register_function(get_admin_options
)
1004 server
.register_function(set_admin_options
)
1006 server
.register_function(check_options
)
1008 server
.register_function(get_all_lists
)
1009 server
.register_function(create_list
)
1010 server
.register_function(delete_list
)
1012 server
.register_function(kill
)
1014 server
.serve_forever()
1016 # vim:set et sw=4 sts=4 sws=4: