mirror of
https://github.com/Alfresco/alfresco-community-repo.git
synced 2025-08-07 17:49:17 +00:00
Merge IMAP in
git-svn-id: https://svn.alfresco.com/repos/alfresco-enterprise/alfresco/HEAD/root@14947 c4b6b30b-aa2e-2d43-bbcb-ca4b014f7261
This commit is contained in:
Derek Hulley
452
source/java/org/alfresco/repo/imap/ImapServiceImplTest.java
Executable file
452
source/java/org/alfresco/repo/imap/ImapServiceImplTest.java
Executable file
@@ -0,0 +1,452 @@
|
||||
package org.alfresco.repo.imap;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.io.Serializable;
|
||||
import java.util.LinkedList;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
|
||||
import javax.mail.Flags;
|
||||
import javax.transaction.UserTransaction;
|
||||
|
||||
import junit.framework.TestCase;
|
||||
|
||||
import org.alfresco.error.AlfrescoRuntimeException;
|
||||
import org.alfresco.model.ContentModel;
|
||||
import org.alfresco.model.ImapModel;
|
||||
import org.alfresco.repo.importer.ACPImportPackageHandler;
|
||||
import org.alfresco.repo.management.subsystems.ChildApplicationContextFactory;
|
||||
import org.alfresco.repo.model.filefolder.FileFolderServiceImpl;
|
||||
import org.alfresco.repo.node.integrity.IntegrityChecker;
|
||||
import org.alfresco.repo.security.permissions.AccessDeniedException;
|
||||
import org.alfresco.service.ServiceRegistry;
|
||||
import org.alfresco.service.cmr.model.FileFolderService;
|
||||
import org.alfresco.service.cmr.model.FileInfo;
|
||||
import org.alfresco.service.cmr.repository.NodeRef;
|
||||
import org.alfresco.service.cmr.repository.NodeService;
|
||||
import org.alfresco.service.cmr.repository.StoreRef;
|
||||
import org.alfresco.service.cmr.search.SearchService;
|
||||
import org.alfresco.service.cmr.security.AuthenticationService;
|
||||
import org.alfresco.service.cmr.security.PermissionService;
|
||||
import org.alfresco.service.cmr.security.PersonService;
|
||||
import org.alfresco.service.cmr.view.ImporterService;
|
||||
import org.alfresco.service.cmr.view.Location;
|
||||
import org.alfresco.service.namespace.NamespaceService;
|
||||
import org.alfresco.service.namespace.QName;
|
||||
import org.alfresco.service.transaction.TransactionService;
|
||||
import org.alfresco.util.ApplicationContextHelper;
|
||||
import org.alfresco.util.PropertyMap;
|
||||
import org.springframework.context.ApplicationContext;
|
||||
import org.springframework.core.io.ClassPathResource;
|
||||
|
||||
public class ImapServiceImplTest extends TestCase
|
||||
{
|
||||
|
||||
private static final String USER_NAME = "admin";
|
||||
private static final String USER_PASSWORD = "admin";
|
||||
|
||||
private static final String TEST_IMAP_FOLDER_NAME = "aaa";
|
||||
|
||||
private static final String MAILBOX_NAME_A = "mailbox_a";
|
||||
private static final String MAILBOX_NAME_B = "mailbox_b";
|
||||
private static final String MAILBOX_PATTERN = "mailbox*";
|
||||
private static final String FOLDER_PATTERN = "___-___folder*";
|
||||
private static final String FILE_PATTERN = "___-___file*";
|
||||
|
||||
private static ApplicationContext ctx = ApplicationContextHelper.getApplicationContext();
|
||||
private TransactionService transactionService;
|
||||
private NodeService nodeService;
|
||||
private ImporterService importerService;
|
||||
private PersonService personService;
|
||||
private AuthenticationService authenticationService;
|
||||
private PermissionService permissionService;
|
||||
private SearchService searchService;
|
||||
private NamespaceService namespaceService;
|
||||
private FileFolderService fileFolderService;
|
||||
|
||||
private AlfrescoImapUser user;
|
||||
private ImapService imapService;
|
||||
private UserTransaction txn;
|
||||
|
||||
private NodeRef testImapFolderNodeRef;
|
||||
private Flags flags;
|
||||
|
||||
String anotherUserName;
|
||||
|
||||
|
||||
@Override
|
||||
public void setUp() throws Exception
|
||||
{
|
||||
ServiceRegistry serviceRegistry = (ServiceRegistry) ctx.getBean("ServiceRegistry");
|
||||
transactionService = serviceRegistry.getTransactionService();
|
||||
nodeService = serviceRegistry.getNodeService();
|
||||
importerService = serviceRegistry.getImporterService();
|
||||
personService = serviceRegistry.getPersonService();
|
||||
authenticationService = serviceRegistry.getAuthenticationService();
|
||||
permissionService = serviceRegistry.getPermissionService();
|
||||
imapService = serviceRegistry.getImapService();
|
||||
searchService = serviceRegistry.getSearchService();
|
||||
namespaceService = serviceRegistry.getNamespaceService();
|
||||
fileFolderService = serviceRegistry.getFileFolderService();
|
||||
|
||||
|
||||
flags = new Flags();
|
||||
flags.add(Flags.Flag.SEEN);
|
||||
flags.add(Flags.Flag.FLAGGED);
|
||||
flags.add(Flags.Flag.ANSWERED);
|
||||
flags.add(Flags.Flag.DELETED);
|
||||
|
||||
// start the transaction
|
||||
txn = transactionService.getUserTransaction();
|
||||
txn.begin();
|
||||
authenticationService.authenticate(USER_NAME, USER_PASSWORD.toCharArray());
|
||||
|
||||
// downgrade integrity
|
||||
IntegrityChecker.setWarnInTransaction();
|
||||
|
||||
anotherUserName = "user" + System.currentTimeMillis();
|
||||
|
||||
PropertyMap testUser = new PropertyMap();
|
||||
testUser.put(ContentModel.PROP_USERNAME, anotherUserName);
|
||||
testUser.put(ContentModel.PROP_FIRSTNAME, anotherUserName);
|
||||
testUser.put(ContentModel.PROP_LASTNAME, anotherUserName);
|
||||
testUser.put(ContentModel.PROP_EMAIL, anotherUserName + "@alfresco.com");
|
||||
testUser.put(ContentModel.PROP_JOBTITLE, "jobTitle");
|
||||
|
||||
personService.createPerson(testUser);
|
||||
|
||||
// create the ACEGI Authentication instance for the new user
|
||||
authenticationService.createAuthentication(anotherUserName, anotherUserName.toCharArray());
|
||||
|
||||
user = new AlfrescoImapUser(anotherUserName + "@alfresco.com", anotherUserName, anotherUserName);
|
||||
|
||||
String storePath = "workspace://SpacesStore";
|
||||
String companyHomePathInStore = "/app:company_home";
|
||||
|
||||
StoreRef storeRef = new StoreRef(storePath);
|
||||
|
||||
NodeRef storeRootNodeRef = nodeService.getRootNode(storeRef);
|
||||
|
||||
List<NodeRef> nodeRefs = searchService.selectNodes(storeRootNodeRef, companyHomePathInStore, null, namespaceService, false);
|
||||
NodeRef companyHomeNodeRef = nodeRefs.get(0);
|
||||
|
||||
|
||||
|
||||
ChildApplicationContextFactory imap = (ChildApplicationContextFactory) ctx.getBean("imap");
|
||||
ApplicationContext imapCtx = imap.getApplicationContext();
|
||||
ImapServiceImpl imapServiceImpl = (ImapServiceImpl)imapCtx.getBean("imapService");
|
||||
|
||||
// Creating IMAP test folder for IMAP root
|
||||
LinkedList<String> folders = new LinkedList<String>();
|
||||
folders.add(TEST_IMAP_FOLDER_NAME);
|
||||
FileFolderServiceImpl.makeFolders(fileFolderService, companyHomeNodeRef, folders, ContentModel.TYPE_FOLDER);
|
||||
|
||||
// Setting IMAP root
|
||||
String imapRoot = storePath + companyHomePathInStore + "/" + NamespaceService.CONTENT_MODEL_PREFIX + ":" + TEST_IMAP_FOLDER_NAME;
|
||||
imapServiceImpl.setImapRoot(imapRoot);
|
||||
|
||||
// Starting IMAP
|
||||
imapServiceImpl.startup();
|
||||
|
||||
nodeRefs = searchService.selectNodes(storeRootNodeRef,
|
||||
companyHomePathInStore + "/" + NamespaceService.CONTENT_MODEL_PREFIX + ":" + TEST_IMAP_FOLDER_NAME,
|
||||
null,
|
||||
namespaceService,
|
||||
false);
|
||||
testImapFolderNodeRef = nodeRefs.get(0);
|
||||
|
||||
|
||||
/*
|
||||
* Importing test folders:
|
||||
*
|
||||
* Test folder contains: "___-___folder_a"
|
||||
*
|
||||
* "___-___folder_a" contains: "___-___folder_a_a",
|
||||
* "___-___file_a",
|
||||
* "Message_485.eml" (this is IMAP Message)
|
||||
*
|
||||
* "___-___folder_a_a" contains: "____-____file_a_a"
|
||||
*
|
||||
*/
|
||||
importInternal("imapservice_test_folder_a.acp", testImapFolderNodeRef);
|
||||
|
||||
reauthenticate(anotherUserName, anotherUserName);
|
||||
}
|
||||
|
||||
public void tearDown() throws Exception
|
||||
{
|
||||
try
|
||||
{
|
||||
txn.rollback();
|
||||
}
|
||||
catch (Throwable e)
|
||||
{
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
|
||||
private void importInternal(String acpName, NodeRef space)
|
||||
throws IOException
|
||||
{
|
||||
ClassPathResource acpResource = new ClassPathResource(acpName);
|
||||
ACPImportPackageHandler acpHandler = new ACPImportPackageHandler(acpResource.getFile(), null);
|
||||
Location importLocation = new Location(space);
|
||||
importerService.importView(acpHandler, importLocation, null, null);
|
||||
}
|
||||
|
||||
private boolean checkMailbox(AlfrescoImapUser user, String mailboxName)
|
||||
{
|
||||
AlfrescoImapFolder mailFolder = (AlfrescoImapFolder)imapService.getFolder(user, mailboxName);
|
||||
|
||||
if (mailFolder.getFolderInfo() == null)
|
||||
{
|
||||
return false;
|
||||
}
|
||||
return true;
|
||||
}
|
||||
|
||||
private boolean checkSubscribedMailbox(AlfrescoImapUser user, String mailboxName)
|
||||
{
|
||||
List<AlfrescoImapFolder> aifs = imapService.listSubscribedMailboxes(user, mailboxName);
|
||||
boolean present = false;
|
||||
for (AlfrescoImapFolder aif : aifs)
|
||||
{
|
||||
if (aif.getName().equals(mailboxName))
|
||||
{
|
||||
present = true;
|
||||
break;
|
||||
}
|
||||
}
|
||||
return present;
|
||||
}
|
||||
|
||||
private void reauthenticate(String name, String password)
|
||||
{
|
||||
authenticationService.invalidateTicket(authenticationService.getCurrentTicket());
|
||||
authenticationService.clearCurrentSecurityContext();
|
||||
authenticationService.authenticate(name, password.toCharArray());
|
||||
}
|
||||
|
||||
public void testGetFolder() throws Exception
|
||||
{
|
||||
imapService.createMailbox(user, MAILBOX_NAME_A);
|
||||
assertTrue(checkMailbox(user, MAILBOX_NAME_A));
|
||||
}
|
||||
|
||||
public void testListMailbox() throws Exception
|
||||
{
|
||||
imapService.createMailbox(user, MAILBOX_NAME_A);
|
||||
imapService.createMailbox(user, MAILBOX_NAME_B);
|
||||
List<AlfrescoImapFolder> mf = imapService.listMailboxes(user, MAILBOX_PATTERN);
|
||||
assertEquals(mf.size(), 2);
|
||||
}
|
||||
|
||||
public void testListSubscribedMailbox() throws Exception
|
||||
{
|
||||
imapService.createMailbox(user, MAILBOX_NAME_A);
|
||||
imapService.createMailbox(user, MAILBOX_NAME_B);
|
||||
imapService.subscribe(user, MAILBOX_NAME_A);
|
||||
imapService.subscribe(user, MAILBOX_NAME_B);
|
||||
List<AlfrescoImapFolder> aif = imapService.listSubscribedMailboxes(user, MAILBOX_PATTERN);
|
||||
assertEquals(aif.size(), 2);
|
||||
}
|
||||
|
||||
public void testCreateMailbox() throws Exception
|
||||
{
|
||||
imapService.createMailbox(user, MAILBOX_NAME_A);
|
||||
assertTrue("Mailbox isn't created", checkMailbox(user, MAILBOX_NAME_A));
|
||||
}
|
||||
|
||||
public void testDuplicateMailboxes() throws Exception
|
||||
{
|
||||
imapService.createMailbox(user, MAILBOX_NAME_A);
|
||||
try
|
||||
{
|
||||
imapService.createMailbox(user, MAILBOX_NAME_A);
|
||||
fail("Duplicate Mailbox was created");
|
||||
}
|
||||
catch (AlfrescoRuntimeException e)
|
||||
{
|
||||
// expected
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
public void testRenameMailbox() throws Exception
|
||||
{
|
||||
imapService.createMailbox(user, MAILBOX_NAME_A);
|
||||
imapService.renameMailbox(user, MAILBOX_NAME_A, MAILBOX_NAME_B);
|
||||
assertFalse("Can't rename mailbox", checkMailbox(user, MAILBOX_NAME_A));
|
||||
assertTrue("Can't rename mailbox", checkMailbox(user, MAILBOX_NAME_B));
|
||||
}
|
||||
|
||||
public void testRenameMailboxDuplicate() throws Exception
|
||||
{
|
||||
imapService.createMailbox(user, MAILBOX_NAME_A);
|
||||
imapService.createMailbox(user, MAILBOX_NAME_B);
|
||||
try
|
||||
{
|
||||
imapService.renameMailbox(user, MAILBOX_NAME_A, MAILBOX_NAME_B);
|
||||
fail("Mailbox was renamed to existing one but shouldn't");
|
||||
}
|
||||
catch (AlfrescoRuntimeException e)
|
||||
{
|
||||
// expected
|
||||
}
|
||||
}
|
||||
|
||||
public void testDeleteMailbox() throws Exception
|
||||
{
|
||||
imapService.createMailbox(user, MAILBOX_NAME_B);
|
||||
imapService.deleteMailbox(user, MAILBOX_NAME_B);
|
||||
assertFalse("Can't delete mailbox", checkMailbox(user, MAILBOX_NAME_B));
|
||||
}
|
||||
|
||||
public void testSearchFoldersInArchive() throws Exception
|
||||
{
|
||||
List<FileInfo> fi = imapService.searchFolders(testImapFolderNodeRef, FOLDER_PATTERN, true, AlfrescoImapConst.MODE_ARCHIVE);
|
||||
assertNotNull("Can't find folders in Archive Mode", fi);
|
||||
assertEquals("Can't find folders in Archive Mode", fi.size(), 2);
|
||||
|
||||
fi = imapService.searchFolders(testImapFolderNodeRef, FOLDER_PATTERN, false, AlfrescoImapConst.MODE_ARCHIVE);
|
||||
assertNotNull("Can't find folders in Archive Mode", fi);
|
||||
assertEquals("Can't find folders in Archive Mode", fi.size(), 1);
|
||||
}
|
||||
|
||||
public void testSearchFoldersInVirtual() throws Exception
|
||||
{
|
||||
List<FileInfo> fi = imapService.searchFolders(testImapFolderNodeRef, FOLDER_PATTERN, true, AlfrescoImapConst.MODE_VIRTUAL);
|
||||
assertNotNull("Can't find folders in Virtual Mode", fi);
|
||||
assertEquals("Can't find folders in Virtual Mode", fi.size(), 2);
|
||||
|
||||
fi = imapService.searchFolders(testImapFolderNodeRef, FOLDER_PATTERN, false, AlfrescoImapConst.MODE_VIRTUAL);
|
||||
assertNotNull("Can't find folders in Virtual Mode", fi);
|
||||
assertEquals("Can't find folders in Virtual Mode", fi.size(), 1);
|
||||
}
|
||||
|
||||
public void testSearchFoldersInMixed() throws Exception
|
||||
{
|
||||
List<FileInfo> fi = imapService.searchFolders(testImapFolderNodeRef, FOLDER_PATTERN, true, AlfrescoImapConst.MODE_MIXED);
|
||||
assertNotNull("Can't find folders in Mixed Mode", fi);
|
||||
assertEquals("Can't find folders in Mixed Mode", fi.size(), 2);
|
||||
|
||||
fi = imapService.searchFolders(testImapFolderNodeRef, FOLDER_PATTERN, false, AlfrescoImapConst.MODE_MIXED);
|
||||
assertNotNull("Can't find folders in Mixed Mode", fi);
|
||||
assertEquals("Can't find folders in Mixed Mode", fi.size(), 1);
|
||||
}
|
||||
|
||||
public void testSearchFiles() throws Exception
|
||||
{
|
||||
List<FileInfo> fi = imapService.searchFiles(testImapFolderNodeRef, FILE_PATTERN, true);
|
||||
assertNotNull(fi);
|
||||
assertTrue(fi.size() > 0);
|
||||
}
|
||||
|
||||
public void testSearchMails() throws Exception
|
||||
{
|
||||
List<FileInfo> fi = imapService.searchMails(testImapFolderNodeRef, "*", AlfrescoImapConst.MODE_MIXED, true);
|
||||
assertNotNull(fi);
|
||||
assertTrue(fi.size() > 0);
|
||||
}
|
||||
|
||||
public void testSubscribe() throws Exception
|
||||
{
|
||||
imapService.createMailbox(user, MAILBOX_NAME_A);
|
||||
|
||||
imapService.subscribe(user, MAILBOX_NAME_A);
|
||||
assertTrue("Can't subscribe mailbox", checkSubscribedMailbox(user, MAILBOX_NAME_A));
|
||||
}
|
||||
|
||||
public void testUnsubscribe() throws Exception
|
||||
{
|
||||
imapService.createMailbox(user, MAILBOX_NAME_A);
|
||||
imapService.subscribe(user, MAILBOX_NAME_A);
|
||||
imapService.unsubscribe(user, MAILBOX_NAME_A);
|
||||
assertFalse("Can't unsubscribe mailbox", checkSubscribedMailbox(user, MAILBOX_NAME_A));
|
||||
}
|
||||
|
||||
private void setFlags(FileInfo messageFileInfo) throws Exception
|
||||
{
|
||||
imapService.setFlags(messageFileInfo, flags, true);
|
||||
NodeRef messageNodeRef = messageFileInfo.getNodeRef();
|
||||
Map<QName, Serializable> props = nodeService.getProperties(messageNodeRef);
|
||||
|
||||
assertTrue("Can't set SEEN flag", props.containsKey(ImapModel.PROP_FLAG_SEEN));
|
||||
assertTrue("Can't set FLAGGED flag", props.containsKey(ImapModel.PROP_FLAG_FLAGGED));
|
||||
assertTrue("Can't set ANSWERED flag", props.containsKey(ImapModel.PROP_FLAG_ANSWERED));
|
||||
assertTrue("Can't set DELETED flag", props.containsKey(ImapModel.PROP_FLAG_DELETED));
|
||||
}
|
||||
|
||||
public void testSetFlags() throws Exception
|
||||
{
|
||||
List<FileInfo> fis = imapService.searchMails(testImapFolderNodeRef, "*", AlfrescoImapConst.MODE_ARCHIVE, true);
|
||||
if (fis != null && fis.size() > 0)
|
||||
{
|
||||
FileInfo messageFileInfo = fis.get(0);
|
||||
try
|
||||
{
|
||||
setFlags(messageFileInfo);
|
||||
fail("Can't set flags");
|
||||
}
|
||||
catch (Exception e)
|
||||
{
|
||||
if (e instanceof AccessDeniedException)
|
||||
{
|
||||
// expected
|
||||
}
|
||||
else
|
||||
{
|
||||
throw e;
|
||||
}
|
||||
}
|
||||
|
||||
reauthenticate(USER_NAME, USER_PASSWORD);
|
||||
|
||||
permissionService.setPermission(testImapFolderNodeRef, anotherUserName, PermissionService.WRITE, true);
|
||||
|
||||
reauthenticate(anotherUserName, anotherUserName);
|
||||
|
||||
setFlags(messageFileInfo);
|
||||
}
|
||||
}
|
||||
|
||||
public void testSetFlag() throws Exception
|
||||
{
|
||||
List<FileInfo> fis = imapService.searchMails(testImapFolderNodeRef, "*", AlfrescoImapConst.MODE_ARCHIVE, true);
|
||||
if (fis != null && fis.size() > 0)
|
||||
{
|
||||
FileInfo messageFileInfo = fis.get(0);
|
||||
|
||||
reauthenticate(USER_NAME, USER_PASSWORD);
|
||||
|
||||
permissionService.setPermission(testImapFolderNodeRef, anotherUserName, PermissionService.WRITE, true);
|
||||
|
||||
reauthenticate(anotherUserName, anotherUserName);
|
||||
|
||||
imapService.setFlag(messageFileInfo, Flags.Flag.RECENT, true);
|
||||
|
||||
Serializable prop = nodeService.getProperty(messageFileInfo.getNodeRef(), ImapModel.PROP_FLAG_RECENT);
|
||||
assertNotNull("Can't set RECENT flag", prop);
|
||||
}
|
||||
}
|
||||
|
||||
public void testGetFlags() throws Exception
|
||||
{
|
||||
List<FileInfo> fis = imapService.searchMails(testImapFolderNodeRef, "*", AlfrescoImapConst.MODE_ARCHIVE, true);
|
||||
if (fis != null && fis.size() > 0)
|
||||
{
|
||||
FileInfo messageFileInfo = fis.get(0);
|
||||
|
||||
reauthenticate(USER_NAME, USER_PASSWORD);
|
||||
|
||||
permissionService.setPermission(testImapFolderNodeRef, anotherUserName, PermissionService.WRITE, true);
|
||||
|
||||
imapService.setFlags(messageFileInfo, flags, true);
|
||||
|
||||
reauthenticate(anotherUserName, anotherUserName);
|
||||
|
||||
Flags fl = imapService.getFlags(messageFileInfo);
|
||||
assertTrue(fl.contains(flags));
|
||||
}
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user