mirror of
https://github.com/Alfresco/alfresco-community-repo.git
synced 2025-10-08 14:51:49 +00:00
c9c30849f9
- Added two JUnit tests that test that the audit records are added when using SearchService query(SearchParameters): one in the AuditMethodInterceptorTest and another one in AuditWebScriptTest that is using the Rest-API get audit method to query the audit - Refactored also an existing test in AuditMethodInterceptorTest git-svn-id: https://svn.alfresco.com/repos/alfresco-enterprise/alfresco/BRANCHES/DEV/5.2.N/root@135899 c4b6b30b-aa2e-2d43-bbcb-ca4b014f7261
314 lines
12 KiB
Java
314 lines
12 KiB
Java
/*
|
|
* #%L
|
|
* Alfresco Repository
|
|
* %%
|
|
* Copyright (C) 2005 - 2016 Alfresco Software Limited
|
|
* %%
|
|
* This file is part of the Alfresco software.
|
|
* If the software was purchased under a paid Alfresco license, the terms of
|
|
* the paid license agreement will prevail. Otherwise, the software is
|
|
* provided under the following open source license terms:
|
|
*
|
|
* Alfresco is free software: you can redistribute it and/or modify
|
|
* it under the terms of the GNU Lesser General Public License as published by
|
|
* the Free Software Foundation, either version 3 of the License, or
|
|
* (at your option) any later version.
|
|
*
|
|
* Alfresco is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
* GNU Lesser General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU Lesser General Public License
|
|
* along with Alfresco. If not, see <http://www.gnu.org/licenses/>.
|
|
* #L%
|
|
*/
|
|
package org.alfresco.repo.audit;
|
|
|
|
import java.io.Serializable;
|
|
import java.net.URL;
|
|
import java.util.Date;
|
|
import java.util.Map;
|
|
|
|
import junit.framework.TestCase;
|
|
|
|
import org.alfresco.error.AlfrescoRuntimeException;
|
|
import org.alfresco.repo.audit.model.AuditModelRegistryImpl;
|
|
import org.alfresco.repo.security.authentication.AuthenticationUtil;
|
|
import org.alfresco.repo.transaction.RetryingTransactionHelper.RetryingTransactionCallback;
|
|
import org.alfresco.repo.transaction.TransactionServiceImpl;
|
|
import org.alfresco.service.ServiceRegistry;
|
|
import org.alfresco.service.cmr.audit.AuditQueryParameters;
|
|
import org.alfresco.service.cmr.audit.AuditService;
|
|
import org.alfresco.service.cmr.audit.AuditService.AuditQueryCallback;
|
|
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.ResultSet;
|
|
import org.alfresco.service.cmr.search.SearchParameters;
|
|
import org.alfresco.service.cmr.search.SearchService;
|
|
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.apache.commons.lang.mutable.MutableInt;
|
|
import org.apache.commons.logging.Log;
|
|
import org.apache.commons.logging.LogFactory;
|
|
import org.springframework.context.ApplicationContext;
|
|
import org.springframework.util.ResourceUtils;
|
|
|
|
/**
|
|
* Tests AuditMethodInterceptor
|
|
*
|
|
* @see AuditMethodInterceptor
|
|
* @author alex.mukha
|
|
* @since 4.2.3
|
|
*/
|
|
public class AuditMethodInterceptorTest extends TestCase
|
|
{
|
|
private static ApplicationContext ctx = ApplicationContextHelper.getApplicationContext();
|
|
|
|
private AuditModelRegistryImpl auditModelRegistry;
|
|
private TransactionServiceImpl transactionServiceImpl;
|
|
private NodeService nodeService;
|
|
private SearchService searchService;
|
|
private ServiceRegistry serviceRegistry;
|
|
private AuditComponent auditComponent;
|
|
private AuditService auditService;
|
|
private TransactionService transactionService;
|
|
|
|
private NodeRef nodeRef;
|
|
|
|
private static String APPLICATION_NAME_MNT_11072 = "alfresco-mnt-11072";
|
|
private static String APPLICATION_NAME_MNT_16748 = "SearchAudit";
|
|
private static final Log logger = LogFactory.getLog(AuditMethodInterceptorTest.class);
|
|
|
|
@SuppressWarnings("deprecation")
|
|
@Override
|
|
public void setUp() throws Exception
|
|
{
|
|
auditModelRegistry = (AuditModelRegistryImpl) ctx.getBean("auditModel.modelRegistry");
|
|
serviceRegistry = (ServiceRegistry) ctx.getBean(ServiceRegistry.SERVICE_REGISTRY);
|
|
auditComponent = (AuditComponent) ctx.getBean("auditComponent");
|
|
auditService = serviceRegistry.getAuditService();
|
|
transactionService = serviceRegistry.getTransactionService();
|
|
transactionServiceImpl = (TransactionServiceImpl) ctx.getBean("transactionService");
|
|
nodeService = serviceRegistry.getNodeService();
|
|
searchService = serviceRegistry.getSearchService();
|
|
|
|
AuthenticationUtil.setFullyAuthenticatedUser(AuthenticationUtil.getSystemUserName());
|
|
nodeRef = nodeService.getRootNode(StoreRef.STORE_REF_WORKSPACE_SPACESSTORE);
|
|
|
|
// Register the models
|
|
URL modelUrlMnt11072 = ResourceUtils.getURL("classpath:alfresco/testaudit/alfresco-audit-test-mnt-11072.xml");
|
|
URL modelUrlMnt16748 = ResourceUtils.getURL("classpath:alfresco/testaudit/alfresco-audit-test-mnt-16748.xml");
|
|
auditModelRegistry.registerModel(modelUrlMnt11072);
|
|
auditModelRegistry.registerModel(modelUrlMnt16748);
|
|
auditModelRegistry.loadAuditModels();
|
|
}
|
|
|
|
@Override
|
|
public void tearDown()
|
|
{
|
|
auditService.clearAudit(APPLICATION_NAME_MNT_11072, null, null);
|
|
auditService.clearAudit(APPLICATION_NAME_MNT_16748, null, null);
|
|
auditModelRegistry.destroy();
|
|
AuthenticationUtil.clearCurrentSecurityContext();
|
|
}
|
|
|
|
/**
|
|
* Test for <a href="https://issues.alfresco.com/jira/browse/MNT-11072">MNT-11072</a> <br>
|
|
* Use NodeService, as it is wrapped by the AuditMethodInterceptor, to get node props in read-only server mode.
|
|
*/
|
|
public void testAuditInReadOnly_MNT11072() throws Exception
|
|
{
|
|
// Run as admin
|
|
AuthenticationUtil.setAdminUserAsFullyAuthenticatedUser();
|
|
|
|
QName veto = QName.createQName(NamespaceService.APP_MODEL_1_0_URI, "TestVeto");
|
|
transactionServiceImpl.setAllowWrite(false, veto);
|
|
try
|
|
{
|
|
// Access the node in read-only transaction
|
|
Map<QName, Serializable> props = transactionService.getRetryingTransactionHelper()
|
|
.doInTransaction(new RetryingTransactionCallback<Map<QName, Serializable>>()
|
|
{
|
|
|
|
@Override
|
|
public Map<QName, Serializable> execute() throws Throwable
|
|
{
|
|
return nodeService.getProperties(nodeRef);
|
|
}
|
|
|
|
}, true, false);
|
|
|
|
assertNotNull("The props should exsist.", props);
|
|
|
|
// Search for audit
|
|
final StringBuilder sb = new StringBuilder();
|
|
final MutableInt rowCount = new MutableInt();
|
|
AuditQueryCallback callback = new AuditQueryCallback()
|
|
{
|
|
@Override
|
|
public boolean valuesRequired()
|
|
{
|
|
return true;
|
|
}
|
|
|
|
@Override
|
|
public boolean handleAuditEntry(Long entryId, String applicationName,
|
|
String user, long time, Map<String, Serializable> values)
|
|
{
|
|
assertNotNull(applicationName);
|
|
assertNotNull(user);
|
|
|
|
sb.append("Row: ").append(entryId).append(" | ")
|
|
.append(applicationName).append(" | ")
|
|
.append(user).append(" | ")
|
|
.append(new Date(time)).append(" | ")
|
|
.append(values).append(" | ").append("\n");
|
|
rowCount.setValue(rowCount.intValue() + 1);
|
|
return true;
|
|
}
|
|
|
|
@Override
|
|
public boolean handleAuditEntryError(Long entryId, String errorMsg, Throwable error)
|
|
{
|
|
throw new AlfrescoRuntimeException(errorMsg, error);
|
|
}
|
|
};
|
|
|
|
AuditQueryParameters params = new AuditQueryParameters();
|
|
params.setForward(true);
|
|
params.setUser(AuthenticationUtil.getAdminUserName());
|
|
params.setApplicationName(APPLICATION_NAME_MNT_11072);
|
|
|
|
rowCount.setValue(0);
|
|
auditComponent.auditQuery(callback, params, Integer.MAX_VALUE);
|
|
|
|
assertEquals("There should be one audit entry.", 1, rowCount.intValue());
|
|
assertTrue("The requested nodeRef should be in the audit entry.",
|
|
sb.toString().contains(nodeRef.toString()));
|
|
if (logger.isDebugEnabled())
|
|
{
|
|
logger.debug(sb.toString());
|
|
}
|
|
}
|
|
finally
|
|
{
|
|
transactionServiceImpl.setAllowWrite(true, veto);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Test for <a href="https://issues.alfresco.com/jira/browse/MNT-16748">MNT-16748</a> <br>
|
|
* Use {@link SearchService#query(StoreRef, String, String)} to perform a query.
|
|
*/
|
|
public void testAuditSearchServiceQuery() throws Exception
|
|
{
|
|
// Run as admin
|
|
AuthenticationUtil.setAdminUserAsFullyAuthenticatedUser();
|
|
|
|
// Perform a search
|
|
@SuppressWarnings("unused")
|
|
ResultSet rs = transactionService.getRetryingTransactionHelper().doInTransaction(new RetryingTransactionCallback<ResultSet>()
|
|
{
|
|
@Override
|
|
public ResultSet execute() throws Throwable
|
|
{
|
|
return searchService.query(StoreRef.STORE_REF_WORKSPACE_SPACESSTORE, SearchService.LANGUAGE_XPATH, "/app:company_home");
|
|
}
|
|
|
|
}, true, false);
|
|
|
|
// Check the audit entries
|
|
checkAuditEntries(APPLICATION_NAME_MNT_16748, SearchService.LANGUAGE_XPATH, "/app:company_home", 1);
|
|
}
|
|
|
|
/**
|
|
* Test for <a href="https://issues.alfresco.com/jira/browse/MNT-16748">MNT-16748</a> <br>
|
|
* Use {@link SearchService#query(SearchParameters)} to perform a query.
|
|
*/
|
|
public void testAuditSearchServiceSearchParametersQuery() throws Exception
|
|
{
|
|
// Run as admin
|
|
AuthenticationUtil.setAdminUserAsFullyAuthenticatedUser();
|
|
|
|
// Create SearchParameters to be used in query
|
|
SearchParameters sp = new SearchParameters();
|
|
sp.setLanguage(SearchService.LANGUAGE_XPATH);
|
|
sp.setQuery("/app:company_home/app:dictionary");
|
|
sp.addStore(StoreRef.STORE_REF_WORKSPACE_SPACESSTORE);
|
|
|
|
// Perform a search
|
|
@SuppressWarnings("unused")
|
|
ResultSet rs = transactionService.getRetryingTransactionHelper().doInTransaction(new RetryingTransactionCallback<ResultSet>()
|
|
{
|
|
@Override
|
|
public ResultSet execute() throws Throwable
|
|
{
|
|
return searchService.query(sp);
|
|
}
|
|
|
|
}, true, false);
|
|
|
|
// Check the audit entries
|
|
checkAuditEntries(APPLICATION_NAME_MNT_16748, SearchService.LANGUAGE_XPATH, "/app:company_home/app:dictionary", 1);
|
|
}
|
|
|
|
private void checkAuditEntries(String applicationName, String language, String query, int resultsNumber)
|
|
{
|
|
final StringBuilder sb = new StringBuilder();
|
|
final MutableInt rowCount = new MutableInt();
|
|
AuditQueryCallback callback = new AuditQueryCallback()
|
|
{
|
|
@Override
|
|
public boolean valuesRequired()
|
|
{
|
|
return true;
|
|
}
|
|
|
|
@Override
|
|
public boolean handleAuditEntry(Long entryId, String applicationName,
|
|
String user, long time, Map<String, Serializable> values)
|
|
{
|
|
assertNotNull(applicationName);
|
|
assertNotNull(user);
|
|
|
|
sb.append("Row: ").append(entryId).append(" | ")
|
|
.append(applicationName).append(" | ")
|
|
.append(user).append(" | ")
|
|
.append(new Date(time)).append(" | ")
|
|
.append(values).append(" | ").append("\n");
|
|
rowCount.setValue(rowCount.intValue() + 1);
|
|
return true;
|
|
}
|
|
|
|
@Override
|
|
public boolean handleAuditEntryError(Long entryId, String errorMsg, Throwable error)
|
|
{
|
|
throw new AlfrescoRuntimeException(errorMsg, error);
|
|
}
|
|
};
|
|
|
|
AuditQueryParameters params = new AuditQueryParameters();
|
|
params.setForward(true);
|
|
params.setUser(AuthenticationUtil.getAdminUserName());
|
|
params.setApplicationName(applicationName);
|
|
|
|
rowCount.setValue(0);
|
|
auditComponent.auditQuery(callback, params, Integer.MAX_VALUE);
|
|
|
|
assertEquals("Incorrect number of audit entries", resultsNumber, rowCount.intValue());
|
|
assertTrue("The requested language should be in the audit entry.",
|
|
sb.toString().contains(language));
|
|
assertTrue("The used query should be in the audit entry.",
|
|
sb.toString().contains(query));
|
|
if (logger.isDebugEnabled())
|
|
{
|
|
logger.debug(sb.toString());
|
|
}
|
|
}
|
|
|
|
}
|