Author: rdonkin
Date: Wed Aug 1 02:25:37 2007
New Revision: 561738
URL: http://svn.apache.org/viewvc?view=rev&rev=561738
Log:
Functional test framework implementation for monothread configuration. One
example test.
Added:
james/server/trunk/phoenix-deployment/src/test/org/apache/james/experimental/
james/server/trunk/phoenix-deployment/src/test/org/apache/james/experimental/imapserver/
james/server/trunk/phoenix-deployment/src/test/org/apache/james/experimental/imapserver/ExperimentalAuthenticatedStateTest.java
james/server/trunk/phoenix-deployment/src/test/org/apache/james/experimental/imapserver/ExperimentalHostSystem.java
james/server/trunk/phoenix-deployment/src/test/org/apache/james/experimental/imapserver/HostSystemFactory.java
Added:
james/server/trunk/phoenix-deployment/src/test/org/apache/james/experimental/imapserver/ExperimentalAuthenticatedStateTest.java
URL:
http://svn.apache.org/viewvc/james/server/trunk/phoenix-deployment/src/test/org/apache/james/experimental/imapserver/ExperimentalAuthenticatedStateTest.java?view=auto&rev=561738
==============================================================================
---
james/server/trunk/phoenix-deployment/src/test/org/apache/james/experimental/imapserver/ExperimentalAuthenticatedStateTest.java
(added)
+++
james/server/trunk/phoenix-deployment/src/test/org/apache/james/experimental/imapserver/ExperimentalAuthenticatedStateTest.java
Wed Aug 1 02:25:37 2007
@@ -0,0 +1,28 @@
+/****************************************************************
+ * Licensed to the Apache Software Foundation (ASF) under one *
+ * or more contributor license agreements. See the NOTICE file *
+ * distributed with this work for additional information *
+ * regarding copyright ownership. The ASF licenses this file *
+ * to you 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.experimental.imapserver;
+
+import
org.apache.james.test.functional.imap.AbstractAuthenticatedStateTestSuite;
+
+public class ExperimentalAuthenticatedStateTest extends
AbstractAuthenticatedStateTestSuite {
+ public ExperimentalAuthenticatedStateTest() throws Exception {
+ super(HostSystemFactory.createStandardImap());
+ }
+}
Added:
james/server/trunk/phoenix-deployment/src/test/org/apache/james/experimental/imapserver/ExperimentalHostSystem.java
URL:
http://svn.apache.org/viewvc/james/server/trunk/phoenix-deployment/src/test/org/apache/james/experimental/imapserver/ExperimentalHostSystem.java?view=auto&rev=561738
==============================================================================
---
james/server/trunk/phoenix-deployment/src/test/org/apache/james/experimental/imapserver/ExperimentalHostSystem.java
(added)
+++
james/server/trunk/phoenix-deployment/src/test/org/apache/james/experimental/imapserver/ExperimentalHostSystem.java
Wed Aug 1 02:25:37 2007
@@ -0,0 +1,377 @@
+/****************************************************************
+ * Licensed to the Apache Software Foundation (ASF) under one *
+ * or more contributor license agreements. See the NOTICE file *
+ * distributed with this work for additional information *
+ * regarding copyright ownership. The ASF licenses this file *
+ * to you 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.experimental.imapserver;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.OutputStream;
+import java.nio.ByteBuffer;
+import java.nio.CharBuffer;
+import java.nio.charset.Charset;
+import java.nio.charset.CharsetEncoder;
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.HashSet;
+import java.util.Iterator;
+import java.util.Set;
+
+import org.apache.james.api.imap.process.ImapProcessor;
+import org.apache.james.imapserver.codec.decode.ImapDecoder;
+import org.apache.james.imapserver.codec.encode.ImapEncoder;
+import org.apache.james.services.User;
+import org.apache.james.services.UsersRepository;
+import org.apache.james.test.functional.imap.HostSystem;
+import org.apache.james.test.mock.avalon.MockLogger;
+
+public class ExperimentalHostSystem implements HostSystem, UsersRepository {
+
+ private ImapDecoder decoder;
+ private ImapEncoder encoder;
+ private ImapProcessor processor;
+ private final Set users;
+
+ public ExperimentalHostSystem() {
+ super();
+ users = new HashSet();
+ }
+
+ public void configure(final ImapDecoder decoder, final ImapEncoder
encoder, final ImapProcessor processor) {
+ this.decoder = decoder;
+ this.encoder = encoder;
+ this.processor = processor;
+ }
+
+ public boolean addUser(String username, String password) {
+ User user = new MockUser(username, password);
+ users.add(user);
+ return true;
+
+ }
+
+ public HostSystem.Session newSession() throws Exception {
+ return new Session();
+ }
+
+ public void reset() throws Exception {
+ users.clear();
+
+ }
+
+ public String getHelloName() {
+ return "JAMES";
+ }
+
+ public ImapDecoder getImapDecoder() {
+ return decoder;
+ }
+
+ public ImapEncoder getImapEncoder() {
+ return encoder;
+ }
+
+ public ImapProcessor getImapProcessor() {
+ return processor;
+ }
+
+ public int getResetLength() {
+ return Integer.MAX_VALUE;
+ }
+
+ public boolean addUser(User user) {
+ users.add(user);
+ return true;
+ }
+
+ public void addUser(String name, Object attributes) {
+ User user = new MockUser(name, "SHA");
+ users.add(user);
+ }
+
+ public boolean contains(String name) {
+ boolean result = false;
+ if (name != null)
+ {
+ for (Iterator it=users.iterator();it.hasNext();)
+ {
+ User user = (User) it.next();
+ if (name.equals(user.getUserName())){
+ result = true;
+ break;
+ }
+ }
+ }
+ return result;
+ }
+
+ public boolean containsCaseInsensitive(String name) {
+ boolean result = false;
+ if (name != null)
+ {
+ for (Iterator it=users.iterator();it.hasNext();)
+ {
+ User user = (User) it.next();
+ if (name.equalsIgnoreCase(user.getUserName())){
+ result = true;
+ break;
+ }
+ }
+ }
+ return result;
+ }
+
+ public int countUsers() {
+ return users.size();
+ }
+
+ public String getRealName(String name) {
+ return name;
+ }
+
+ public User getUserByName(String name) {
+ User result = null;
+ if (name != null)
+ {
+ for (Iterator it=users.iterator();it.hasNext();)
+ {
+ User user = (User) it.next();
+ if (name.equals(user.getUserName())){
+ result = user;
+ break;
+ }
+ }
+ }
+ return result;
+ }
+
+ public User getUserByNameCaseInsensitive(String name) {
+ User result = null;
+ if (name != null)
+ {
+ for (Iterator it=users.iterator();it.hasNext();)
+ {
+ User user = (User) it.next();
+ if (name.equalsIgnoreCase(user.getUserName())){
+ result = user;
+ break;
+ }
+ }
+ }
+ return result;
+ }
+
+ public Iterator list() {
+ Collection results = new ArrayList();
+ for (Iterator it=users.iterator();it.hasNext();)
+ {
+ User user = (User) it.next();
+ results.add(user.getUserName());
+ }
+
+ return results.iterator();
+ }
+
+ public void removeUser(String name) {
+ if (name != null)
+ {
+ for (Iterator it=users.iterator();it.hasNext();)
+ {
+ User user = (User) it.next();
+ if (name.equals(user.getUserName())){
+ it.remove();
+ break;
+ }
+ }
+ }
+ }
+
+ public boolean test(String name, String password) {
+ boolean result = false;
+ if (name != null)
+ {
+ for (Iterator it=users.iterator();it.hasNext();)
+ {
+ User user = (User) it.next();
+ if (name.equals(user.getUserName())){
+ result = user.verifyPassword(password);
+ break;
+ }
+ }
+ }
+ return result;
+ }
+
+ public boolean updateUser(User user) {
+ users.add(user);
+ return true;
+ }
+
+ class Session implements HostSystem.Session, ImapHandlerInterface
+ {
+ ByteBufferOutputStream out;
+ ByteBufferInputStream in;
+ ImapRequestHandler handler;
+ ImapSessionImpl session;
+
+ public Session() {
+ out = new ByteBufferOutputStream();
+ in = new ByteBufferInputStream();
+ handler = new ImapRequestHandler(decoder, processor, encoder);
+ handler.enableLogging(new MockLogger());
+ session = new ImapSessionImpl(this, "localhost", "127.0.0.1");
+ }
+
+ public String readLine() throws Exception {
+ return out.nextLine();
+ }
+
+ public void start() throws Exception {
+ // Welcome message handled in the server
+ out.write("* OK IMAP4rev1 Server ready\r\n");
+ }
+
+ public void stop() throws Exception {
+
+ }
+
+ public void writeLine(String line) throws Exception {
+ in.nextLine(line);
+ handler.handleRequest(in, out, session);
+ }
+
+ public void forceConnectionClose(String byeMessage) {
+ try {
+ out.write(byeMessage);
+ } catch (IOException e) {
+ throw new RuntimeException(e);
+ }
+
+ }
+
+ }
+
+ static class ByteBufferInputStream extends InputStream {
+
+ ByteBuffer buffer = ByteBuffer.allocate(4096);
+ CharsetEncoder encoder = Charset.forName("ASCII").newEncoder();
+
+ public int read() throws IOException {
+ int result = -1;
+ if (buffer.hasRemaining()) {
+ result = buffer.get();
+ }
+ return result;
+ }
+
+ public void nextLine(String line) {
+ if (buffer.position() > 0) {
+ buffer.compact();
+ }
+ encoder.encode(CharBuffer.wrap(line), buffer, true);
+ buffer.put((byte)'\r');
+ buffer.put((byte)'\n');
+ buffer.flip();
+ }
+ }
+
+ static class ByteBufferOutputStream extends OutputStream {
+ ByteBuffer buffer = ByteBuffer.allocate(4096);
+ Charset ascii = Charset.forName("ASCII");
+
+ public void write(String message) throws IOException {
+ ascii.newEncoder().encode(CharBuffer.wrap(message), buffer, true);
+ }
+
+ public void write(int b) throws IOException {
+ buffer.put((byte) b);
+ }
+
+ public String nextLine() throws Exception {
+ buffer.flip();
+ byte last = 0;
+ while (buffer.hasRemaining()) {
+ byte next = buffer.get();
+ if (last == '\r' && next == 'n') {
+ break;
+ }
+ last = next;
+ }
+ final ByteBuffer readOnlyBuffer = buffer.asReadOnlyBuffer();
+ readOnlyBuffer.flip();
+ int limit = readOnlyBuffer.limit() - 2;
+ if (limit < 0) {
+ limit = 0;
+ }
+ readOnlyBuffer.limit(limit);
+ String result = ascii.decode(readOnlyBuffer).toString();
+ buffer.compact();
+ return result;
+ }
+ }
+
+ static class MockUser implements User {
+
+ private final String user;
+ private String password;
+
+
+
+ public MockUser(final String user, final String password) {
+ super();
+ this.user = user;
+ this.password = password;
+ }
+
+ public String getUserName() {
+ return user;
+ }
+
+ public boolean setPassword(String newPass) {
+ this.password = newPass;
+ return true;
+ }
+
+ public boolean verifyPassword(String pass) {
+ return password.equals(pass);
+ }
+
+ public int hashCode() {
+ final int PRIME = 31;
+ int result = 1;
+ result = PRIME * result + ((user == null) ? 0 : user.hashCode());
+ return result;
+ }
+
+ public boolean equals(Object obj) {
+ if (this == obj)
+ return true;
+ if (obj == null)
+ return false;
+ if (getClass() != obj.getClass())
+ return false;
+ final MockUser other = (MockUser) obj;
+ if (user == null) {
+ if (other.user != null)
+ return false;
+ } else if (!user.equals(other.user))
+ return false;
+ return true;
+ }
+ }
+}
Added:
james/server/trunk/phoenix-deployment/src/test/org/apache/james/experimental/imapserver/HostSystemFactory.java
URL:
http://svn.apache.org/viewvc/james/server/trunk/phoenix-deployment/src/test/org/apache/james/experimental/imapserver/HostSystemFactory.java?view=auto&rev=561738
==============================================================================
---
james/server/trunk/phoenix-deployment/src/test/org/apache/james/experimental/imapserver/HostSystemFactory.java
(added)
+++
james/server/trunk/phoenix-deployment/src/test/org/apache/james/experimental/imapserver/HostSystemFactory.java
Wed Aug 1 02:25:37 2007
@@ -0,0 +1,39 @@
+/****************************************************************
+ * Licensed to the Apache Software Foundation (ASF) under one *
+ * or more contributor license agreements. See the NOTICE file *
+ * distributed with this work for additional information *
+ * regarding copyright ownership. The ASF licenses this file *
+ * to you 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.experimental.imapserver;
+
+import org.apache.james.imapserver.codec.encode.main.DefaultImapEncoderFactory;
+import org.apache.james.imapserver.mock.MailboxManagerProviderSingleton;
+import org.apache.james.imapserver.processor.main.DefaultImapProcessorFactory;
+import org.apache.james.test.functional.imap.HostSystem;
+
+public class HostSystemFactory {
+
+ public static HostSystem createStandardImap() throws Exception {
+
+ ExperimentalHostSystem result = new ExperimentalHostSystem();
+ final DefaultImapProcessorFactory defaultImapProcessorFactory = new
DefaultImapProcessorFactory();
+ defaultImapProcessorFactory.configure(result,
MailboxManagerProviderSingleton.getMailboxManagerProviderInstance());
+ result.configure(new DefaultImapDecoderFactory().buildImapDecoder(),
+ new DefaultImapEncoderFactory().buildImapEncoder(),
+ defaultImapProcessorFactory.buildImapProcessor());
+ return result;
+ }
+}
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
