You are viewing a plain text version of this content. The canonical link for it is here.
Posted to server-dev@james.apache.org by no...@apache.org on 2006/05/29 12:00:51 UTC
svn commit: r410068 -
/james/server/trunk/src/test/org/apache/james/smtpserver/AddHeaderHandlerTest.java
Author: norman
Date: Mon May 29 03:00:49 2006
New Revision: 410068
URL: http://svn.apache.org/viewvc?rev=410068&view=rev
Log:
Add junit test for AddHeaderHandler
Added:
james/server/trunk/src/test/org/apache/james/smtpserver/AddHeaderHandlerTest.java
Added: james/server/trunk/src/test/org/apache/james/smtpserver/AddHeaderHandlerTest.java
URL: http://svn.apache.org/viewvc/james/server/trunk/src/test/org/apache/james/smtpserver/AddHeaderHandlerTest.java?rev=410068&view=auto
==============================================================================
--- james/server/trunk/src/test/org/apache/james/smtpserver/AddHeaderHandlerTest.java (added)
+++ james/server/trunk/src/test/org/apache/james/smtpserver/AddHeaderHandlerTest.java Mon May 29 03:00:49 2006
@@ -0,0 +1,383 @@
+/***********************************************************************
+ * Copyright (c) 2006 The Apache Software Foundation. *
+ * All rights reserved. *
+ * ------------------------------------------------------------------- *
+ * Licensed under the Apache License, Version 2.0 (the "License"); you *
+ * may not use this file except in compliance with the License. You *
+ * may obtain a copy of the License at: *
+ * *
+ * http://www.apache.org/licenses/LICENSE-2.0 *
+ * *
+ * Unless required by applicable law or agreed to in writing, software *
+ * distributed under the License is distributed on an "AS IS" BASIS, *
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or *
+ * implied. See the License for the specific language governing *
+ * permissions and limitations under the License. *
+ ***********************************************************************/
+
+package org.apache.james.smtpserver;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.Serializable;
+import java.util.Collection;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.Iterator;
+
+import javax.mail.MessagingException;
+import javax.mail.internet.InternetAddress;
+import javax.mail.internet.MimeMessage;
+import javax.mail.internet.MimeMessage.RecipientType;
+
+import org.apache.avalon.framework.container.ContainerUtil;
+import org.apache.james.test.mock.avalon.MockLogger;
+import org.apache.james.test.mock.javaxmail.MockMimeMessage;
+import org.apache.james.util.watchdog.Watchdog;
+import org.apache.mailet.Mail;
+import org.apache.mailet.MailAddress;
+
+import junit.framework.TestCase;
+
+public class AddHeaderHandlerTest extends TestCase {
+
+ private SMTPSession mockedSMTPSession;
+
+ private MimeMessage mockedMimeMessage;
+
+ private Mail mockedMail;
+
+ private final String HEADER_NAME = "JUNIT";
+
+ private final String HEADER_VALUE = "test-value";
+
+ private String headerName = "defaultHeaderName";
+
+ private String headerValue = "defaultHeaderValue";
+
+ protected void setUp() throws Exception {
+ super.setUp();
+ setupMockedMail();
+ setupMockedSMTPSession();
+ }
+
+ private void setHeaderName(String headerName) {
+ this.headerName = headerName;
+ }
+
+ private void setHeaderValue(String headerValue) {
+ this.headerValue = headerValue;
+ }
+
+ private void setupMockedMimeMessage() throws MessagingException {
+ String sender = "test@james.apache.org";
+ String rcpt = "test2@james.apache.org";
+
+ mockedMimeMessage = new MockMimeMessage();
+ mockedMimeMessage.setFrom(new InternetAddress(sender));
+ mockedMimeMessage.setRecipients(RecipientType.TO, rcpt);
+ mockedMimeMessage.setHeader(headerName, headerValue);
+ mockedMimeMessage.setSubject("testmail");
+ mockedMimeMessage.setText("testtext");
+ mockedMimeMessage.saveChanges();
+
+ }
+
+ private void setupMockedMail() {
+ mockedMail = new Mail() {
+
+ private static final long serialVersionUID = 1L;
+
+ public String getName() {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public void setName(String newName) {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public MimeMessage getMessage() throws MessagingException {
+ return mockedMimeMessage;
+ }
+
+ public Collection getRecipients() {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public void setRecipients(Collection recipients) {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public MailAddress getSender() {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public String getState() {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public String getRemoteHost() {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public String getRemoteAddr() {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public String getErrorMessage() {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public void setErrorMessage(String msg) {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public void setMessage(MimeMessage message) {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public void setState(String state) {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public Serializable getAttribute(String name) {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public Iterator getAttributeNames() {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public boolean hasAttributes() {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public Serializable removeAttribute(String name) {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public void removeAllAttributes() {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public Serializable setAttribute(String name, Serializable object) {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public long getMessageSize() throws MessagingException {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public Date getLastUpdated() {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public void setLastUpdated(Date lastUpdated) {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ };
+ }
+
+ private void setupMockedSMTPSession() {
+ mockedSMTPSession = new SMTPSession() {
+
+ public void writeResponse(String respString) {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public String readCommandLine() throws IOException {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public StringBuffer getResponseBuffer() {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public String clearResponseBuffer() {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public InputStream getInputStream() {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public String getCommandName() {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public String getCommandArgument() {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public Mail getMail() {
+ return mockedMail;
+ }
+
+ public void setMail(Mail mail) {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public String getRemoteHost() {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public String getRemoteIPAddress() {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public void abortMessage() {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public void endSession() {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public boolean isSessionEnded() {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public HashMap getState() {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public void resetState() {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public SMTPHandlerConfigurationData getConfigurationData() {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public void setBlockListed(boolean blocklisted) {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public boolean isBlockListed() {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public void setBlockListedDetail(String detail) {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public String getBlockListedDetail() {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public boolean isRelayingAllowed() {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public boolean isAuthRequired() {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public boolean useHeloEhloEnforcement() {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public String getUser() {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public void setUser(String user) {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public Watchdog getWatchdog() {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+
+ public String getSessionID() {
+ throw new UnsupportedOperationException(
+ "Unimplemented mock service");
+ }
+ };
+ }
+
+ // test if the Header was add
+ public void testHeaderIsPresent() throws MessagingException {
+ setHeaderName(HEADER_NAME);
+ setHeaderValue(HEADER_VALUE);
+ setupMockedMimeMessage();
+
+ AddHeaderHandler header = new AddHeaderHandler();
+
+ ContainerUtil.enableLogging(header, new MockLogger());
+
+ header.setHeaderName(HEADER_NAME);
+ header.setHeaderValue(HEADER_VALUE);
+ header.onMessage(mockedSMTPSession);
+
+ assertEquals(HEADER_VALUE, mockedSMTPSession.getMail().getMessage()
+ .getHeader(HEADER_NAME)[0]);
+ }
+
+ // test if the Header was replaced
+ public void testHeaderIsReplaced() throws MessagingException {
+ setHeaderName(HEADER_NAME);
+ setHeaderValue(headerValue);
+ setupMockedMimeMessage();
+
+ AddHeaderHandler header = new AddHeaderHandler();
+
+ ContainerUtil.enableLogging(header, new MockLogger());
+
+ header.setHeaderName(HEADER_NAME);
+ header.setHeaderValue(HEADER_VALUE);
+ header.onMessage(mockedSMTPSession);
+
+ assertEquals(HEADER_VALUE, mockedSMTPSession.getMail().getMessage()
+ .getHeader(HEADER_NAME)[0]);
+ }
+
+}
---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org