Index: jakarta-james/src/java/org/apache/james/transport/mailets/Redirect.java
===================================================================
RCS file: /home/cvspublic/jakarta-james/src/java/org/apache/james/transport/mailets/Redirect.java,v
retrieving revision 1.4
diff -u -r1.4 Redirect.java
--- jakarta-james/src/java/org/apache/james/transport/mailets/Redirect.java 18 Jun 2002 21:49:53 -0000 1.4
+++ jakarta-james/src/java/org/apache/james/transport/mailets/Redirect.java 27 Jul 2002 18:34:43 -0000
@@ -1,551 +1,567 @@
-/*
- * Copyright (C) The Apache Software Foundation. All rights reserved.
- *
- * This software is published under the terms of the Apache Software License
- * version 1.1, a copy of which has been included with this distribution in
- * the LICENSE file.
- */
-package org.apache.james.transport.mailets;
-
-import java.io.PrintWriter;
-import java.io.StringWriter;
-
-import java.util.Collection;
-import java.util.Enumeration;
-import java.util.HashSet;
-import java.util.StringTokenizer;
-
-import javax.mail.Message;
-import javax.mail.MessagingException;
-import javax.mail.Session;
-import javax.mail.internet.InternetAddress;
-import javax.mail.internet.MimeBodyPart;
-import javax.mail.internet.MimeMessage;
-import javax.mail.internet.MimeMultipart;
-
-import org.apache.james.util.RFC822Date;
-
-import org.apache.mailet.GenericMailet;
-import org.apache.mailet.Mail;
-import org.apache.mailet.MailAddress;
-
-
-/**
-*A mailet providing configurable redirection services
-*This mailet can produce listserver, forward and notify behaviour, with the original
-*message intact, attached, appended or left out altogether.
-*This built in functionality is controlled by the configuration as laid out below.
-*However it is also designed to be easily subclassed to make authoring redirection
-*mailets simple.
-*By extending it and overriding one or more of these methods new behaviour can
-*be quickly created without the author having to address any other issue than
-*the relevant one:
-*
-*- attachError() , should error messages be appended to the message
-*- getAttachementType(), what should be attached to the message
-*- getInLineType(), what should be included in the message
-*- getMessage(), The text of the message itself
-*- getRecipients(), the recipients the mail is sent to
-*- getReplyTo(), where replys to this message will be sent
-*- getSender(), who the mail is from
-*- getSubjectPrefix(), a prefix to be added to the message subject
-*- getTo(), a list of people to whom the mail is *apparently* sent
-*- getPassThrough(), should this mailet GHOST the original message.
-*- isStatic(), should this mailet run the get methods for every mail, or just
-*once.
-*
-*The configuration parameters are:
-*
-*
-*| <recipients> |
-*A comma delimited list of email addresses for recipients of
-*this message, it will use the "to" list if not specified. These
-*addresses will only appear in the To: header if no "to" list is
-*supplied. |
-*
-*
-*| <to> |
-*A comma delimited list of addresses to appear in the To: header,
-*the email will only be delivered to these addresses if they are in the recipients
-*list.
-*The recipients list will be used if this is not supplied |
-*
-*
-*| <sender> |
-*A single email address to appear in the From: header
-*It can include constants "sender" and "postmaster" |
-*
-*
-*| <message> |
-*A text message to be the body of the email. Can be omitted. |
-*
-*
-*| <inline> |
-*
-* One of the following items:
-*
-*- unaltered The original message is the new
-* message, for forwarding/aliasing
-*- heads The
-* headers of the original message are appended to the message
-*- body The
-* body of the original is appended to the new message
-*- all Both
-* headers and body are appended
-*- none Neither
-* body nor headers are appended
-*
-* |
-*
-*
-*| <attachment> |
-*
-* One of the following items:
-*
-*- heads The headers of the original
-* are attached as text
-*- body The body of the original
-* is attached as text
-*- all Both
-* headers and body are attached as a single text file
-*- none Nothing is attached
-*- message The original message is attached as type message/rfc822,
-* this means that it can, in many cases, be opened, resent, fw'd, replied
-* to etc by email client software.
-*
-* |
-*
-*
-*| <passThrough> |
-*TRUE or FALSE, if true the original message continues in the
-*mailet processor after this mailet is finished. False causes the original
-*to be stopped. |
-*
-*
-*| <attachError> |
-*TRUE or FALSE, if true any error message available to the
-*mailet is appended to the message body (except in the case of inline ==
-*unaltered) |
-*
-*
-*| <replyto> |
-*A single email address to appear in the Rely-To: header, can
-*also be "sender" or "postmaster", this header is not
-*set if this is omited. |
-*
-*
-*| <prefix> |
-*An optional subject prefix prepended to the original message
-*subject, for example..
-*Undeliverable mail: |
-*
-*
-*| <static> |
-*
-* TRUE or FALSE, if this is true it hints to the mailet that none of the
-*parameters are set dynamically, and therefore they can be set once in
-*the init method.
-*False tells the mailet to call all the "getters" for every mail
-*processed.
-*This defaults to false.
-*It should be TRUE in all cases, except where one of the getter methods
-*has been overriden to provide dynamic values, such as a listserve which
-*might override getRecipients() to get a list from a users repository.
-* |
-*
-*
-*
-*Example:
-* <mailet match="RecipientIs=test@localhost" class="Redirect">
-*<recipients>x@localhost, y@localhost, z@localhost</recipients>
-*<to>list@localhost</to>
-*<sender>owner@localhost</sender>
-*<message>sent on from James</message>
-*<inline>unaltered</inline>
-*<passThrough>FALSE</passThrough>
-*<replyto>postmaster</replyto>
-*<prefix>[test mailing]</prefix>
-*<static>TRUE</static>
-*<passThrough>FALSE</passThrough>
-*</mailet>
-*
-*and:
-* <mailet match="All" class="Redirect">
-*<recipients>x@localhost</recipients>
-*<sender>postmaster</sender>
-*<message>Message marked as spam:
-*</message>
-*<inline>heads</inline>
-*<attachment>message</attachment>
-*<passThrough>FALSE</passThrough>
-*<attachError>TRUE</attachError>
-*<replyto>postmaster</replyto>
-*<prefix>[spam notification]</prefix>
-*<static>TRUE</static>
-*<passThrough>FALSE</passThrough>
-*</mailet>
- *
- * @author Danny Angus
- *
- */
-public class Redirect extends GenericMailet {
- private static int ALL = 3;
- private static int BODY = 2;
- private static int HEADS = 1;
- private static int MESSAGE = 5;
- private static int NONE = 4;
- private static int UNALTERED = 0;
- private InternetAddress[] apparentlyTo;
- private String messageText;
- private Collection recipients;
- private MailAddress replyTo;
- private MailAddress sender;
-
- /**
-* returns one of these values to indicate how to attach the original message
-*
-* - BODY : original message body is attached as plain text to the new message
-* - HEADS : original message headers are attached as plain text to the new message
-* - ALL : original is attached as plain text with all headers
-* - MESSAGE : original message is attached as type message/rfc822, a complete mail message.
-* - NONE : original is not attached
-*
-*
-*/
- public int getAttachmentType() {
- if(getInitParameter("attachment") == null) {
- return NONE;
- } else {
- return getTypeCode(getInitParameter("attachment"));
- }
- }
-
- /**
-* returns one of these values to indicate how to append the original message
-*
-* - UNALTERED : original message is the new message body
-* - BODY : original message body is appended to the new message
-* - HEADS : original message headers are appended to the new message
-* - ALL : original is appended with all headers
-* - NONE : original is not appended
-*
-*/
- public int getInLineType() {
- if(getInitParameter("inline") == null) {
- return BODY;
- } else {
- return getTypeCode(getInitParameter("inline"));
- }
- }
-
- /**
- * Add Description
- *
- * @return Document return!
- */
- public String getMailetInfo() {
- return "Resend Mailet";
- }
-
- /**
-* must return either an empty string, or a message to which the redirect can be attached/appended
-*/
- public String getMessage() {
- if(getInitParameter("message") == null) {
- return "";
- } else {
- return getInitParameter("message");
- }
- }
-
- /**
-* return true to allow thie original message to continue through the processor, false to GHOST it
-*/
- public boolean getPassThrough() {
- if(getInitParameter("passThrough") == null) {
- return false;
- } else {
- return new Boolean(getInitParameter("passThrough")).booleanValue();
- }
- }
-
- /**
-* must return a Collection of recipient MailAddress'es
-*/
- public Collection getRecipients() {
- Collection newRecipients = new HashSet();
- String addressList = (getInitParameter("recipients") == null)
- ? getInitParameter("to")
- : getInitParameter("recipients");
- StringTokenizer st = new StringTokenizer(addressList, ",", false);
- while(st.hasMoreTokens()) {
- try {
- newRecipients.add(new MailAddress(st.nextToken()));
- } catch(Exception e) {
- log("add recipient failed in getRecipients");
- }
- }
- return newRecipients;
- }
-
- /**
-* return the reply to address as a string
-*/
- public MailAddress getReplyTo() {
- String sr = getInitParameter("replyto");
- if(sr != null) {
- MailAddress rv;
- if(sr.compareTo("postmaster") == 0) {
- rv = getMailetContext().getPostmaster();
- return rv;
- }
- if(sr.compareTo("sender") == 0) {
- return null;
- }
- try {
- rv = new MailAddress(sr);
- return rv;
- } catch(Exception e) {
- log("Parse error in getReplyTo " + sr);
- }
- }
- return null;
- }
-
- /**
-* returns the senders address, as a MailAddress
-*/
- public MailAddress getSender() {
- String sr = getInitParameter("sender");
- if(sr != null) {
- MailAddress rv;
- if(sr.compareTo("postmaster") == 0) {
- rv = getMailetContext().getPostmaster();
- return rv;
- }
- if(sr.compareTo("sender") == 0) {
- return null;
- }
- try {
- rv = new MailAddress(sr);
- return rv;
- } catch(Exception e) {
- log("Parse error in getSender " + sr);
- }
- }
- return null;
- }
-
- /**
-* return true to reduce calls to getTo, getSender, getRecipients, getReplyTo amd getMessage
-* where these values don't change (eg hard coded, or got at startup from the mailet config)
-* return false where any of these methods generate their results dynamically eg in response to the message being processed,
-* or by refrence to a repository of users
-*/
- public boolean isStatic() {
- if(getInitParameter("static") == null) {
- return false;
- }
- return new Boolean(getInitParameter("static")).booleanValue();
- }
-
- /**
-* return a prefix for the message subject
-*/
- public String getSubjectPrefix() {
- if(getInitParameter("prefix") == null) {
- return "";
- } else {
- return getInitParameter("prefix");
- }
- }
-
- /**
-* returns an array of InternetAddress 'es for the To: header
-*/
- public InternetAddress[] getTo() {
- String addressList = (getInitParameter("to") == null)
- ? getInitParameter("recipients") : getInitParameter("to");
- StringTokenizer rec = new StringTokenizer(addressList, ",");
- int tokensn = rec.countTokens();
- InternetAddress[] iaarray = new InternetAddress[tokensn];
- String tokenx = "";
- for(int i = 0; i < tokensn; ++i) {
- try {
- tokenx = rec.nextToken();
- iaarray[i] = new InternetAddress(tokenx);
- } catch(Exception e) {
- log("Internet address exception in getTo()");
- }
- }
- return iaarray;
- }
-
- /**
-* return true to append a description of any error to the main body part
-* if getInlineType does not return "UNALTERED"
-*/
- public boolean attachError() {
- if(getInitParameter("attachError") == null) {
- return false;
- } else {
- return new Boolean(getInitParameter("attachError")).booleanValue();
- }
- }
-
- /**
-* init will setup static values for sender, recipients, message text, and reply to
-*
if isStatic() returns true
-* it calls getSender(), getReplyTo(), getMessage(), and getRecipients() and getTo()
-*
-*/
- public void init() throws MessagingException {
- log("redirect init");
- if(isStatic()) {
- sender = (getSender() == null) ? getMailetContext().getPostmaster() : getSender();
- replyTo = (getReplyTo() == null) ? getMailetContext().getPostmaster() : getReplyTo();
- messageText = getMessage();
- recipients = getRecipients();
- apparentlyTo = getTo();
- log("static, sender=" + sender + ", replyTo=" + replyTo + ", message=" + messageText +
- " ");
- }
- }
-
- /**
-*
-* Service does the hard work,and redirects the mail in the form specified
-*
-*
-*/
- public void service(Mail mail) throws MessagingException {
- if(!isStatic()) {
- sender = getSender();
- replyTo = getReplyTo();
- messageText = getMessage();
- recipients = getRecipients();
- apparentlyTo = getTo();
- }
- MimeMessage message = mail.getMessage();
- MimeMessage reply = new MimeMessage(Session.getDefaultInstance(System.getProperties(),
- null));
- //Create the message
- if(getInLineType() != UNALTERED) {
- log("alter message inline=:" + getInLineType());
- StringWriter sout = new StringWriter();
- PrintWriter out = new PrintWriter(sout, true);
- Enumeration heads = message.getAllHeaderLines();
- String head = "";
- while(heads.hasMoreElements()) {
- head += (heads.nextElement().toString() + "\n");
- }
- boolean all = false;
- if(messageText != null) {
- out.println(messageText);
- }
- switch(getInLineType()) {
- case 3: //ALL:
- all = true;
- case 1: //HEADS:
- out.println("Message Headers:");
- out.println(head);
- if(!all) {
- break;
- }
- case 2: //BODY:
- out.println("Message:");
- try {
- out.println(message.getContent().toString());
- } catch(Exception e) {
- out.println("body unavailable");
- }
- break;
- default:
- case 4: //NONE:
- break;
- }
- MimeMultipart multipart = new MimeMultipart();
- //Add message as the first mime body part
- MimeBodyPart part = new MimeBodyPart();
- part.setText(sout.toString());
- part.setDisposition("inline");
- multipart.addBodyPart(part);
- if(getAttachmentType() != NONE) {
- part = new MimeBodyPart();
- switch(getAttachmentType()) {
- case 1: //HEADS:
- part.setText(head);
- break;
- case 2: //BODY:
- try {
- part.setText(message.getContent().toString());
- } catch(Exception e) {
- part.setText("body unavailable");
- }
- break;
- case 3: //ALL:
- part.setText(head + "\n\n" + message.toString());
- break;
- case 5: //MESSAGE:
- part.setContent(message, "message/rfc822");
- break;
- }
- part.setDisposition("Attachment");
- multipart.addBodyPart(part);
- }
- reply.setContent(multipart);
- reply.setHeader("Content-Type", multipart.getContentType());
- } else {
- log("message resent unaltered:");
- reply = message;
- }
- //Set additional headers
- reply.setSubject(getSubjectPrefix() + message.getSubject());
- if(reply.getHeader("Date") == null) {
- reply.setHeader("Date", new RFC822Date().toString());
- }
- reply.setRecipients(Message.RecipientType.TO, apparentlyTo);
- if(replyTo != null) {
- InternetAddress[] iart = new InternetAddress[1];
- iart[0] = replyTo.toInternetAddress();
- reply.setReplyTo(iart);
- }
- if(sender == null) {
- reply.setHeader("From", message.getHeader("From", ","));
- } else {
- reply.setFrom(sender.toInternetAddress());
- }
- //Send it off...
- getMailetContext().sendMail(sender, recipients, reply);
- if(!getPassThrough()) {
- mail.setState(Mail.GHOST);
- }
- }
-
- /**
-* A private method to convert types from string to int.
-*/
- private int getTypeCode(String param) {
- int code;
- param = param.toLowerCase();
- if(param.compareTo("unaltered") == 0) {
- return 0;
- }
- if(param.compareTo("heads") == 0) {
- return 1;
- }
- if(param.compareTo("body") == 0) {
- return 2;
- }
- if(param.compareTo("all") == 0) {
- return 3;
- }
- if(param.compareTo("none") == 0) {
- return 4;
- }
- if(param.compareTo("message") == 0) {
- return 5;
- }
- return 4;
- }
-}
\ No newline at end of file
+/*
+ * Copyright (C) The Apache Software Foundation. All rights reserved.
+ *
+ * This software is published under the terms of the Apache Software License
+ * version 1.1, a copy of which has been included with this distribution in
+ * the LICENSE file.
+ */
+package org.apache.james.transport.mailets;
+
+import java.io.PrintWriter;
+import java.io.StringWriter;
+
+import java.util.Collection;
+import java.util.Date;
+import java.util.Enumeration;
+import java.util.HashSet;
+import java.util.StringTokenizer;
+
+import javax.mail.Message;
+import javax.mail.MessagingException;
+import javax.mail.Session;
+import javax.mail.internet.InternetAddress;
+import javax.mail.internet.MimeBodyPart;
+import javax.mail.internet.MimeMessage;
+import javax.mail.internet.MimeMultipart;
+
+import org.apache.james.util.RFC822DateFormat;
+
+import org.apache.mailet.GenericMailet;
+import org.apache.mailet.Mail;
+import org.apache.mailet.MailAddress;
+
+
+/**
+*A mailet providing configurable redirection services
+*This mailet can produce listserver, forward and notify behaviour, with the original
+*message intact, attached, appended or left out altogether.
+*This built in functionality is controlled by the configuration as laid out below.
+*However it is also designed to be easily subclassed to make authoring redirection
+*mailets simple.
+*By extending it and overriding one or more of these methods new behaviour can
+*be quickly created without the author having to address any other issue than
+*the relevant one:
+*
+*- attachError() , should error messages be appended to the message
+*- getAttachementType(), what should be attached to the message
+*- getInLineType(), what should be included in the message
+*- getMessage(), The text of the message itself
+*- getRecipients(), the recipients the mail is sent to
+*- getReplyTo(), where replys to this message will be sent
+*- getSender(), who the mail is from
+*- getSubjectPrefix(), a prefix to be added to the message subject
+*- getTo(), a list of people to whom the mail is *apparently* sent
+*- getPassThrough(), should this mailet GHOST the original message.
+*- isStatic(), should this mailet run the get methods for every mail, or just
+*once.
+*
+*The configuration parameters are:
+*
+*
+*| <recipients> |
+*A comma delimited list of email addresses for recipients of
+*this message, it will use the "to" list if not specified. These
+*addresses will only appear in the To: header if no "to" list is
+*supplied. |
+*
+*
+*| <to> |
+*A comma delimited list of addresses to appear in the To: header,
+*the email will only be delivered to these addresses if they are in the recipients
+*list.
+*The recipients list will be used if this is not supplied |
+*
+*
+*| <sender> |
+*A single email address to appear in the From: header
+*It can include constants "sender" and "postmaster" |
+*
+*
+*| <message> |
+*A text message to be the body of the email. Can be omitted. |
+*
+*
+*| <inline> |
+*
+* One of the following items:
+*
+*- unaltered The original message is the new
+* message, for forwarding/aliasing
+*- heads The
+* headers of the original message are appended to the message
+*- body The
+* body of the original is appended to the new message
+*- all Both
+* headers and body are appended
+*- none Neither
+* body nor headers are appended
+*
+* |
+*
+*
+*| <attachment> |
+*
+* One of the following items:
+*
+*- heads The headers of the original
+* are attached as text
+*- body The body of the original
+* is attached as text
+*- all Both
+* headers and body are attached as a single text file
+*- none Nothing is attached
+*- message The original message is attached as type message/rfc822,
+* this means that it can, in many cases, be opened, resent, fw'd, replied
+* to etc by email client software.
+*
+* |
+*
+*
+*| <passThrough> |
+*TRUE or FALSE, if true the original message continues in the
+*mailet processor after this mailet is finished. False causes the original
+*to be stopped. |
+*
+*
+*| <attachError> |
+*TRUE or FALSE, if true any error message available to the
+*mailet is appended to the message body (except in the case of inline ==
+*unaltered) |
+*
+*
+*| <replyto> |
+*A single email address to appear in the Rely-To: header, can
+*also be "sender" or "postmaster", this header is not
+*set if this is omited. |
+*
+*
+*| <prefix> |
+*An optional subject prefix prepended to the original message
+*subject, for example..
+*Undeliverable mail: |
+*
+*
+*| <static> |
+*
+* TRUE or FALSE, if this is true it hints to the mailet that none of the
+*parameters are set dynamically, and therefore they can be set once in
+*the init method.
+*False tells the mailet to call all the "getters" for every mail
+*processed.
+*This defaults to false.
+*It should be TRUE in all cases, except where one of the getter methods
+*has been overriden to provide dynamic values, such as a listserve which
+*might override getRecipients() to get a list from a users repository.
+* |
+*
+*
+*
+*Example:
+* <mailet match="RecipientIs=test@localhost" class="Redirect">
+*<recipients>x@localhost, y@localhost, z@localhost</recipients>
+*<to>list@localhost</to>
+*<sender>owner@localhost</sender>
+*<message>sent on from James</message>
+*<inline>unaltered</inline>
+*<passThrough>FALSE</passThrough>
+*<replyto>postmaster</replyto>
+*<prefix>[test mailing]</prefix>
+*<static>TRUE</static>
+*<passThrough>FALSE</passThrough>
+*</mailet>
+*
+*and:
+* <mailet match="All" class="Redirect">
+*<recipients>x@localhost</recipients>
+*<sender>postmaster</sender>
+*<message>Message marked as spam:
+*</message>
+*<inline>heads</inline>
+*<attachment>message</attachment>
+*<passThrough>FALSE</passThrough>
+*<attachError>TRUE</attachError>
+*<replyto>postmaster</replyto>
+*<prefix>[spam notification]</prefix>
+*<static>TRUE</static>
+*<passThrough>FALSE</passThrough>
+*</mailet>
+ *
+ * @author Danny Angus
+ *
+ */
+public class Redirect extends GenericMailet {
+ private static final int UNALTERED = 0;
+ private static final int HEADS = 1;
+ private static final int BODY = 2;
+ private static final int ALL = 3;
+ private static final int NONE = 4;
+ private static final int MESSAGE = 5;
+ private InternetAddress[] apparentlyTo;
+ private String messageText;
+ private Collection recipients;
+ private MailAddress replyTo;
+ private MailAddress sender;
+
+ private RFC822DateFormat rfc822DateFormat = new RFC822DateFormat();
+
+ /**
+ * returns one of these values to indicate how to attach the original message
+ *
+ * - BODY : original message body is attached as plain text to the new message
+ * - HEADS : original message headers are attached as plain text to the new message
+ * - ALL : original is attached as plain text with all headers
+ * - MESSAGE : original message is attached as type message/rfc822, a complete mail message.
+ * - NONE : original is not attached
+ *
+ *
+ */
+ public int getAttachmentType() {
+ if(getInitParameter("attachment") == null) {
+ return NONE;
+ } else {
+ return getTypeCode(getInitParameter("attachment"));
+ }
+ }
+
+ /**
+* returns one of these values to indicate how to append the original message
+*
+* - UNALTERED : original message is the new message body
+* - BODY : original message body is appended to the new message
+* - HEADS : original message headers are appended to the new message
+* - ALL : original is appended with all headers
+* - NONE : original is not appended
+*
+*/
+ public int getInLineType() {
+ if(getInitParameter("inline") == null) {
+ return BODY;
+ } else {
+ return getTypeCode(getInitParameter("inline"));
+ }
+ }
+
+ /**
+ * Add Description
+ *
+ * @return Document return!
+ */
+ public String getMailetInfo() {
+ return "Resend Mailet";
+ }
+
+ /**
+* must return either an empty string, or a message to which the redirect can be attached/appended
+*/
+ public String getMessage() {
+ if(getInitParameter("message") == null) {
+ return "";
+ } else {
+ return getInitParameter("message");
+ }
+ }
+
+ /**
+* return true to allow thie original message to continue through the processor, false to GHOST it
+*/
+ public boolean getPassThrough() {
+ if(getInitParameter("passThrough") == null) {
+ return false;
+ } else {
+ return new Boolean(getInitParameter("passThrough")).booleanValue();
+ }
+ }
+
+ /**
+* must return a Collection of recipient MailAddress'es
+*/
+ public Collection getRecipients() {
+ Collection newRecipients = new HashSet();
+ String addressList = (getInitParameter("recipients") == null)
+ ? getInitParameter("to")
+ : getInitParameter("recipients");
+ StringTokenizer st = new StringTokenizer(addressList, ",", false);
+ while(st.hasMoreTokens()) {
+ try {
+ newRecipients.add(new MailAddress(st.nextToken()));
+ } catch(Exception e) {
+ log("add recipient failed in getRecipients");
+ }
+ }
+ return newRecipients;
+ }
+
+ /**
+* return the reply to address as a string
+*/
+ public MailAddress getReplyTo() {
+ String sr = getInitParameter("replyto");
+ if(sr != null) {
+ MailAddress rv;
+ if(sr.compareTo("postmaster") == 0) {
+ rv = getMailetContext().getPostmaster();
+ return rv;
+ }
+ if(sr.compareTo("sender") == 0) {
+ return null;
+ }
+ try {
+ rv = new MailAddress(sr);
+ return rv;
+ } catch(Exception e) {
+ log("Parse error in getReplyTo " + sr);
+ }
+ }
+ return null;
+ }
+
+ /**
+* returns the senders address, as a MailAddress
+*/
+ public MailAddress getSender() {
+ String sr = getInitParameter("sender");
+ if(sr != null) {
+ MailAddress rv;
+ if(sr.compareTo("postmaster") == 0) {
+ rv = getMailetContext().getPostmaster();
+ return rv;
+ }
+ if(sr.compareTo("sender") == 0) {
+ return null;
+ }
+ try {
+ rv = new MailAddress(sr);
+ return rv;
+ } catch(Exception e) {
+ log("Parse error in getSender " + sr);
+ }
+ }
+ return null;
+ }
+
+ /**
+* return true to reduce calls to getTo, getSender, getRecipients, getReplyTo amd getMessage
+* where these values don't change (eg hard coded, or got at startup from the mailet config)
+* return false where any of these methods generate their results dynamically eg in response to the message being processed,
+* or by refrence to a repository of users
+*/
+ public boolean isStatic() {
+ if(getInitParameter("static") == null) {
+ return false;
+ }
+ return new Boolean(getInitParameter("static")).booleanValue();
+ }
+
+ /**
+* return a prefix for the message subject
+*/
+ public String getSubjectPrefix() {
+ if(getInitParameter("prefix") == null) {
+ return "";
+ } else {
+ return getInitParameter("prefix") + " ";
+ }
+ }
+
+ /**
+* returns an array of InternetAddress 'es for the To: header
+*/
+ public InternetAddress[] getTo() {
+ String addressList = (getInitParameter("to") == null)
+ ? getInitParameter("recipients") : getInitParameter("to");
+ StringTokenizer rec = new StringTokenizer(addressList, ",");
+ int tokensn = rec.countTokens();
+ InternetAddress[] iaarray = new InternetAddress[tokensn];
+ String tokenx = "";
+ for(int i = 0; i < tokensn; ++i) {
+ try {
+ tokenx = rec.nextToken();
+ iaarray[i] = new InternetAddress(tokenx);
+ } catch(Exception e) {
+ log("Internet address exception in getTo()");
+ }
+ }
+ return iaarray;
+ }
+
+ /**
+* return true to append a description of any error to the main body part
+* if getInlineType does not return "UNALTERED"
+*/
+ public boolean attachError() {
+ if(getInitParameter("attachError") == null) {
+ return false;
+ } else {
+ return new Boolean(getInitParameter("attachError")).booleanValue();
+ }
+ }
+
+ /**
+* init will setup static values for sender, recipients, message text, and reply to
+*
if isStatic() returns true
+* it calls getSender(), getReplyTo(), getMessage(), and getRecipients() and getTo()
+*
+*/
+ public void init() throws MessagingException {
+ log("redirect init");
+ if(isStatic()) {
+ sender = (getSender() == null) ? getMailetContext().getPostmaster() : getSender();
+ replyTo = (getReplyTo() == null) ? getMailetContext().getPostmaster() : getReplyTo();
+ messageText = getMessage();
+ recipients = getRecipients();
+ apparentlyTo = getTo();
+ StringBuffer logBuffer = new StringBuffer("static, sender=");
+ logBuffer.append(sender);
+ logBuffer.append(", replyTo=");
+ logBuffer.append(replyTo);
+ logBuffer.append(", message=");
+ logBuffer.append(messageText);
+ logBuffer.append(" ");
+ log(logBuffer.toString());
+ }
+ }
+
+ /**
+*
+* Service does the hard work,and redirects the mail in the form specified
+*
+*
+*/
+ public void service(Mail mail) throws MessagingException {
+ if(!isStatic()) {
+ sender = getSender();
+ replyTo = getReplyTo();
+ messageText = getMessage();
+ recipients = getRecipients();
+ apparentlyTo = getTo();
+ }
+ MimeMessage message = mail.getMessage();
+ MimeMessage reply = new MimeMessage(Session.getDefaultInstance(System.getProperties(),
+ null));
+ //Create the message
+ if(getInLineType() != UNALTERED) {
+ log("alter message inline=:" + getInLineType());
+ StringWriter sout = new StringWriter();
+ PrintWriter out = new PrintWriter(sout, true);
+ Enumeration heads = message.getAllHeaderLines();
+ String head = "";
+ StringBuffer headBuffer = new StringBuffer();
+ while(heads.hasMoreElements()) {
+ headBuffer.append(heads.nextElement().toString());
+ headBuffer.append("\n");
+ }
+ head = headBuffer.toString();
+ boolean all = false;
+ if(messageText != null) {
+ out.println(messageText);
+ }
+ switch(getInLineType()) {
+ case ALL: //ALL:
+ all = true;
+ case HEADS: //HEADS:
+ out.println("Message Headers:");
+ out.println(head);
+ if(!all) {
+ break;
+ }
+ case BODY: //BODY:
+ out.println("Message:");
+ try {
+ out.println(message.getContent().toString());
+ } catch(Exception e) {
+ out.println("body unavailable");
+ }
+ break;
+ default:
+ case NONE: //NONE:
+ break;
+ }
+ MimeMultipart multipart = new MimeMultipart();
+ //Add message as the first mime body part
+ MimeBodyPart part = new MimeBodyPart();
+ part.setText(sout.toString());
+ part.setDisposition("inline");
+ multipart.addBodyPart(part);
+ if(getAttachmentType() != NONE) {
+ part = new MimeBodyPart();
+ switch(getAttachmentType()) {
+ case HEADS: //HEADS:
+ part.setText(head);
+ break;
+ case BODY: //BODY:
+ try {
+ part.setText(message.getContent().toString());
+ } catch(Exception e) {
+ part.setText("body unavailable");
+ }
+ break;
+ case ALL: //ALL:
+ StringBuffer textBuffer = new StringBuffer(head);
+ textBuffer.append("\n\n");
+ textBuffer.append(message.toString());
+ part.setText(textBuffer.toString());
+ break;
+ case MESSAGE: //MESSAGE:
+ part.setContent(message, "message/rfc822");
+ break;
+ }
+ part.setDisposition("Attachment");
+ multipart.addBodyPart(part);
+ }
+ reply.setContent(multipart);
+ reply.setHeader("Content-Type", multipart.getContentType());
+ } else {
+ log("message resent unaltered:");
+ reply = message;
+ }
+ //Set additional headers
+ reply.setSubject(getSubjectPrefix() + message.getSubject());
+ if(reply.getHeader("Date") == null) {
+ reply.setHeader("Date", rfc822DateFormat.format(new Date()));
+ }
+ reply.setRecipients(Message.RecipientType.TO, apparentlyTo);
+ if(replyTo != null) {
+ InternetAddress[] iart = new InternetAddress[1];
+ iart[0] = replyTo.toInternetAddress();
+ reply.setReplyTo(iart);
+ }
+ if(sender == null) {
+ reply.setHeader("From", message.getHeader("From", ","));
+ sender = new MailAddress(((InternetAddress)message.getFrom()[0]).getAddress());
+ } else {
+ reply.setFrom(sender.toInternetAddress());
+ }
+ //Send it off...
+ getMailetContext().sendMail(sender, recipients, reply);
+ if(!getPassThrough()) {
+ mail.setState(Mail.GHOST);
+ }
+ }
+
+ /**
+* A private method to convert types from string to int.
+*/
+ private int getTypeCode(String param) {
+ int code;
+ param = param.toLowerCase();
+ if(param.compareTo("unaltered") == 0) {
+ return UNALTERED;
+ }
+ if(param.compareTo("heads") == 0) {
+ return HEADS;
+ }
+ if(param.compareTo("body") == 0) {
+ return BODY;
+ }
+ if(param.compareTo("all") == 0) {
+ return ALL;
+ }
+ if(param.compareTo("none") == 0) {
+ return NONE;
+ }
+ if(param.compareTo("message") == 0) {
+ return MESSAGE;
+ }
+ return NONE;
+ }
+}