inteligr8/alfresco-community-repo
1
0
Fork 0
mirror of https://github.com/Alfresco/alfresco-community-repo.git synced 2025-08-07 17:49:17 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merged DEV/BELARUS/IMAP-3 to HEAD

Browse Source 
15059: ALFCOM-3087 (IMAP load tester fixes)


git-svn-id: https://svn.alfresco.com/repos/alfresco-enterprise/alfresco/HEAD/root@15103 c4b6b30b-aa2e-2d43-bbcb-ca4b014f7261
This commit is contained in:
Derek Hulley
2009-07-08 12:33:37 +00:00
parent a929a7fd74
commit 33f260e05f
2 changed files with 103 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

116
source/java/org/alfresco/repo/imap/LoadTester.java
View File

@@ -2,23 +2,34 @@ package org.alfresco.repo.imap;
import java.io.IOException; import java.io.IOException;
import java.util.Date; import java.util.Date;
import java.util.LinkedList;
import java.util.List; import java.util.List;
import javax.mail.Flags; import javax.mail.Flags;
import javax.transaction.UserTransaction;
import junit.framework.TestCase; import junit.framework.TestCase;
import org.alfresco.model.ContentModel;
import org.alfresco.repo.importer.ACPImportPackageHandler; import org.alfresco.repo.importer.ACPImportPackageHandler;
import org.alfresco.repo.management.subsystems.ChildApplicationContextFactory;
import org.alfresco.repo.model.filefolder.FileFolderServiceImpl;
import org.alfresco.service.ServiceRegistry; import org.alfresco.service.ServiceRegistry;
import org.alfresco.service.cmr.model.FileFolderService;
import org.alfresco.service.cmr.repository.NodeRef; import org.alfresco.service.cmr.repository.NodeRef;
import org.alfresco.service.cmr.repository.NodeService; import org.alfresco.service.cmr.repository.NodeService;
import org.alfresco.service.cmr.repository.StoreRef; import org.alfresco.service.cmr.repository.StoreRef;
import org.alfresco.service.cmr.search.SearchService; import org.alfresco.service.cmr.search.SearchService;
import org.alfresco.service.cmr.security.AuthenticationService; 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.ImporterService;
import org.alfresco.service.cmr.view.Location; import org.alfresco.service.cmr.view.Location;
import org.alfresco.service.namespace.NamespaceService; import org.alfresco.service.namespace.NamespaceService;
import org.alfresco.service.transaction.TransactionService;
import org.alfresco.util.ApplicationContextHelper; import org.alfresco.util.ApplicationContextHelper;
import org.alfresco.util.PropertyMap;
import org.alfresco.util.config.RepositoryFolderConfigBean;
import org.apache.commons.logging.Log; import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory; import org.apache.commons.logging.LogFactory;
import org.springframework.context.ApplicationContext; import org.springframework.context.ApplicationContext;
@@ -35,55 +46,121 @@ public class LoadTester extends TestCase
private ImapService imapService; private ImapService imapService;
private ImporterService importerService; private ImporterService importerService;
private AuthenticationService authenticationService;
private AlfrescoImapUser user; private AlfrescoImapUser user;
// DH: Do not assume the presence of any specific user or password. Create a new user for the test. // DH: Do not assume the presence of any specific user or password. Create a new user for the test.
private static final String USER_NAME = "admin"; private static final String USER_NAME = "admin";
private static final String USER_PASSWORD = "admin"; private static final String USER_PASSWORD = "admin";
private static final String TEST_IMAP_ROOT_FOLDER_NAME = "aaa";
private static final String TEST_DATA_FOLDER_NAME = "test_data"; private static final String TEST_DATA_FOLDER_NAME = "test_data";
private static final String TEST_FOLDER_NAME = "test_imap1000"; private static final String TEST_FOLDER_NAME = "test_imap1000";
private static final long MESSAGE_QUANTITY = 1000; private static final long MESSAGE_QUANTITY = 1000;
private String anotherUserName;
@Override @Override
public void setUp() throws Exception public void setUp() throws Exception
{ {
ServiceRegistry serviceRegistry = (ServiceRegistry) ctx.getBean("ServiceRegistry"); ServiceRegistry serviceRegistry = (ServiceRegistry) ctx.getBean("ServiceRegistry");
AuthenticationService authenticationService = serviceRegistry.getAuthenticationService(); authenticationService = serviceRegistry.getAuthenticationService();
imapService = serviceRegistry.getImapService(); imapService = serviceRegistry.getImapService();
importerService = serviceRegistry.getImporterService(); importerService = serviceRegistry.getImporterService();
NodeService nodeService = serviceRegistry.getNodeService(); NodeService nodeService = serviceRegistry.getNodeService();
SearchService searchService = serviceRegistry.getSearchService(); SearchService searchService = serviceRegistry.getSearchService();
NamespaceService namespaceService = serviceRegistry.getNamespaceService(); NamespaceService namespaceService = serviceRegistry.getNamespaceService();
PersonService personService = serviceRegistry.getPersonService();
FileFolderService fileFolderService = serviceRegistry.getFileFolderService();
TransactionService transactionService = serviceRegistry.getTransactionService();
PermissionService permissionService = serviceRegistry.getPermissionService();
user = new AlfrescoImapUser(USER_NAME + "@alfresco.com", USER_NAME, USER_PASSWORD);
// start the transaction
UserTransaction txn = transactionService.getUserTransaction();
txn.begin();
authenticationService.authenticate(USER_NAME, USER_PASSWORD.toCharArray()); authenticationService.authenticate(USER_NAME, USER_PASSWORD.toCharArray());
StoreRef storeRef = new StoreRef("workspace://SpacesStore"); anotherUserName = "test_imap_user";
NodeRef rootRef = nodeService.getRootNode(storeRef);
NodeRef person = personService.getPerson(anotherUserName);
// Delete test folder if (person != null)
List<NodeRef> nodeRefs = searchService.selectNodes(rootRef, "/app:company_home/imap:imap_home/cm:admin/cm:" + TEST_FOLDER_NAME, null, namespaceService, false);
if (nodeRefs.size() == 1)
{ {
NodeRef ch = nodeRefs.get(0); personService.deletePerson(anotherUserName);
nodeService.deleteNode(ch); 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);
} }
// Delete test data folder if (authenticationService.authenticationExists(anotherUserName))
nodeRefs = searchService.selectNodes(rootRef, "/app:company_home/imap:imap_home/cm:admin/cm:" + TEST_DATA_FOLDER_NAME, null, namespaceService, false); {
authenticationService.deleteAuthentication(anotherUserName);
}
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");
// Delete test folder
nodeRefs = searchService.selectNodes(storeRootNodeRef,
companyHomePathInStore + "/" + NamespaceService.CONTENT_MODEL_PREFIX + ":" + TEST_IMAP_ROOT_FOLDER_NAME,
null, namespaceService, false);
if (nodeRefs.size() == 1) if (nodeRefs.size() == 1)
{ {
NodeRef ch = nodeRefs.get(0); NodeRef ch = nodeRefs.get(0);
nodeService.deleteNode(ch); nodeService.deleteNode(ch);
} }
// DH: Do not assume the presence of a path for the IMAP home. Create the IMAP home and set it on the service.
NodeRef adminNodeRef = searchService.selectNodes(rootRef, "/app:company_home/imap:imap_home/cm:admin", null, namespaceService, false).get(0); // Creating IMAP test folder for IMAP root
importTestData("test-resources/imap/load_test_data.acp", adminNodeRef); LinkedList<String> folders = new LinkedList<String>();
folders.add(TEST_IMAP_ROOT_FOLDER_NAME);
FileFolderServiceImpl.makeFolders(fileFolderService, companyHomeNodeRef, folders, ContentModel.TYPE_FOLDER);
// Setting IMAP root
RepositoryFolderConfigBean imapHome = new RepositoryFolderConfigBean();
imapHome.setStore(storePath);
imapHome.setRootPath(companyHomePathInStore);
imapHome.setFolderPath(TEST_IMAP_ROOT_FOLDER_NAME);
imapServiceImpl.setImapHome(imapHome);
// Starting IMAP
imapServiceImpl.startup();
nodeRefs = searchService.selectNodes(storeRootNodeRef,
companyHomePathInStore + "/" + NamespaceService.CONTENT_MODEL_PREFIX + ":" + TEST_IMAP_ROOT_FOLDER_NAME,
null,
namespaceService,
false);
// Used to create User's folder
NodeRef userFolderRef = imapService.getMailboxRootRef(TEST_DATA_FOLDER_NAME, anotherUserName);
permissionService.setPermission(userFolderRef, anotherUserName, PermissionService.ALL_PERMISSIONS, true);
importTestData("imap/load_test_data.acp", userFolderRef);
reauthenticate(anotherUserName, anotherUserName);
AlfrescoImapFolder testDataFolder = imapService.getFolder(user, TEST_DATA_FOLDER_NAME); AlfrescoImapFolder testDataFolder = imapService.getFolder(user, TEST_DATA_FOLDER_NAME);
SimpleStoredMessage m = testDataFolder.getMessages().get(0); SimpleStoredMessage m = testDataFolder.getMessages().get(0);
@@ -109,9 +186,18 @@ public class LoadTester extends TestCase
t = System.currentTimeMillis() - t; t = System.currentTimeMillis() - t;
logger.info("Create time: " + t + " ms (" + t/1000 + " s (" + t/60000 + " min))"); logger.info("Create time: " + t + " ms (" + t/1000 + " s (" + t/60000 + " min))");
txn.commit();
} }
private void reauthenticate(String name, String password)
{
authenticationService.invalidateTicket(authenticationService.getCurrentTicket());
authenticationService.clearCurrentSecurityContext();
authenticationService.authenticate(name, password.toCharArray());
}
public void tearDown() throws Exception public void tearDown() throws Exception
{ {

4
source/java/org/alfresco/repo/imap/RemoteLoadTester.java
View File

@@ -25,8 +25,8 @@ public class RemoteLoadTester extends TestCase
private Log logger = LogFactory.getLog(RemoteLoadTester.class); private Log logger = LogFactory.getLog(RemoteLoadTester.class);
private static final String USER_NAME = "admin"; private static final String USER_NAME = "test_imap_user";
private static final String USER_PASSWORD = "admin"; private static final String USER_PASSWORD = "test_imap_user";
private static final String TEST_FOLDER_NAME = "test_imap1000"; private static final String TEST_FOLDER_NAME = "test_imap1000";
@Override @Override