1 files changed, 132 insertions, 0 deletions
diff --git a/modules/mm_admin.py b/modules/mm_admin.py
new file mode 100644
index 000000000..2accb3371
--- /dev/null
+++ b/modules/mm_admin.py
@@ -0,0 +1,132 @@
+# When an operation can't be completed, and is sent to the list admin for
+# Handling, we consider that an error condition, and raise MMNeedApproval
+
+import mm_err, mm_cfg, mm_message
+import os, marshal, time, string
+
+class ListAdmin:
+    def InitVars(self):
+	# Non-configurable data:
+	self.requests = {}
+	self.next_request_id = 1
+
+    def AddRequest(self, request, *args):
+	now = time.time()
+	request_id = self.GetRequestId()
+	if not self.requests.has_key(request):
+	    self.requests[request] = [(request_id, now) + args]
+	else:
+	    self.requests[request].append( (request_id, now) + args )
+	self.Save()
+	if request == 'add_member':
+	    raise mm_err.MMNeedApproval, "Admin approval required to subscribe"
+	elif request == 'post':
+	    raise mm_err.MMNeedApproval, args[1]
+
+    def CleanRequests(self):
+	for (key, val) in self.requests.items():
+	    if not len(val):
+		del self.requests[key]
+
+    def GetRequest(self, id):
+	for (key, val) in self.requests.items():
+	    for i in range(len(val)):
+		if val[i][0] == id:
+		    return (key, i)
+	raise mm_err.MMBadRequestId
+
+    def RemoveRequest(self, id):
+	for (key, val) in self.requests.items():
+	    for item in val:
+		if item[0] == id:
+		    val.remove(item)
+		    return
+	raise mm_err.MMBadRequestId
+
+    def RequestsPending(self):
+	self.CleanRequests()
+	total = 0
+	for (k,v) in self.requests.items():
+	    total = total + len(v)
+	return total
+
+    def HandleRequest(self, request_info, value, comment=None):
+	request = request_info[0]
+	index = request_info[1]
+	request_data = self.requests[request][index]
+	if request == 'add_member':
+	    self.HandleAddMemberRequest(request_data[2:], value, comment)
+	elif request == 'post':
+	    self.HandlePostRequest(request_data[2:], value, comment)
+	self.RemoveRequest(request_data[0])
+
+    def HandlePostRequest(self, data, value, comment):
+	destination_email = data[0][0]
+	msg = mm_message.IncomingMessage(data[0][1])
+	if not value:
+	    request = 'Posting of your message entitled:\n\t\t %s' % \
+		      msg.getheader('subject')
+	    if not comment:
+		comment = data[1]
+	    # If there's an extra arg on data, we don't send an error message.
+	    # This is because if people are posting to a moderated list, they
+	    # Are expecting to wait on approval.
+	    if len(data) < 3:
+		if not self.dont_respond_to_post_requests:
+		    self.RefuseRequest(request, destination_email, comment, msg)
+	else:
+	    self.Post(msg, 1)
+
+    def HandleAddMemberRequest(self, data, value, comment):
+	digest = data[0]
+	destination_email = data[1]
+	pw = data[2]
+	if value == 0:
+	    if digest:
+		digest_text = 'digest'
+	    else:
+		digest_text = 'nodigest'
+	    self.RefuseRequest('subscribe %s %s' % (pw, digest_text),
+			       destination_email, comment)
+	else:
+	    self.ApprovedAddMember(destination_email, pw, digest)
+
+
+
+# Don't call any methods below this point from outside this mixin.
+
+    def GetRequestId(self):
+	id = self.next_request_id
+	self.next_request_id = self.next_request_id + 1
+	# No need to save, we know it's about to be done.
+	return id
+
+    def RefuseRequest(self, request, destination_email, comment, msg=None):
+	text = '''Your request to the '%s' mailing-list:
+
+	%s
+
+Has been rejected by the list moderator.
+''' % (self.real_name, request)
+        if comment:
+	    text = text + '''
+The moderator gave the following reason for rejecting your request:
+
+        %s
+
+''' % comment
+        text = text + 'Any questions or comments should be directed to %s.\n' \
+	       % self.GetAdminEmail()
+        if msg:
+	    text = text  + '''
+Your original message follows:
+
+%s
+
+%s
+''' % (string.join(msg.headers, ''), msg.body)
+	
+        self.SendTextToUser(subject = '%s request rejected' % self.real_name,
+                            recipient = destination_email,
+			    text = text)
+