import org.alfresco.service.cmr.audit.AuditQueryParameters; //导入依赖的package包/类
/**
 * Ensure that only the correct application's audit entries are deleted.
 * @throws Exception 
 */
public void testAuditDeleteEntriesForApplication() throws Exception
{
    final String app1 = doAuditEntryImpl(6);
    final String app2 = doAuditEntryImpl(18);
    
    final AuditQueryCallbackImpl resultsCallback = new AuditQueryCallbackImpl();
    
    RetryingTransactionCallback<Void> deletedCallback = new RetryingTransactionCallback<Void>()
    {
        public Void execute() throws Throwable
        {
            Long app1Id = auditDAO.getAuditApplication(app1).getId();
            auditDAO.deleteAuditEntries(app1Id, null, null);
            // There should be no entries for app1
            // but still entries for app2
            auditDAO.findAuditEntries(resultsCallback, new AuditQueryParameters(), Integer.MAX_VALUE);
            assertEquals("All entries should have been deleted from app1", 0, resultsCallback.numEntries(app1));
            assertEquals("No entries should have been deleted from app2", 18, resultsCallback.numEntries(app2));
            return null;
        }
    };
    txnHelper.doInTransaction(deletedCallback);
}
 

import org.alfresco.service.cmr.audit.AuditQueryParameters; //导入依赖的package包/类
private AuditQueryParameters createAuditParameters(String appName,
		String user, Long fromTime, Long toTime, Boolean forward) {
	final AuditQueryParameters params = new AuditQueryParameters();

	if (forward != null) {
		params.setForward(forward);
	}

	if (StringUtils.isNotBlank(appName)) {
		params.setApplicationName(appName);
	}

	if (StringUtils.isNotBlank(user)) {
		params.setUser(user);
	}

	if (fromTime != null) {
		params.setFromTime(fromTime);
	}

	if (toTime != null) {
		params.setToTime(toTime);
	}
	return params;
}
 

import org.alfresco.service.cmr.audit.AuditQueryParameters; //导入依赖的package包/类
/**
 * {@inheritDoc}
 */
public void auditQuery(AuditQueryCallback callback, AuditQueryParameters parameters, int maxResults)
{
    ParameterCheck.mandatory("callback", callback);
    ParameterCheck.mandatory("parameters", parameters);
    
    // Shortcuts
    if (parameters.isZeroResultQuery())
    {
        return;
    }
    
    auditDAO.findAuditEntries(callback, parameters, maxResults);
}
 

import org.alfresco.service.cmr.audit.AuditQueryParameters; //导入依赖的package包/类
/**
 * Query the audit log as 'admin'
 */
private void queryAuditLog(final AuditQueryCallback callback, final AuditQueryParameters parameters, final int maxResults)
{
    RunAsWork<Void> work = new RunAsWork<Void>()
    {
        @Override
        public Void doWork() throws Exception
        {
            auditService.auditQuery(callback, parameters, maxResults);
            return null;
        }
    };
    AuthenticationUtil.runAs(work, AuthenticationUtil.getAdminRoleName());
}
 

import org.alfresco.service.cmr.audit.AuditQueryParameters; //导入依赖的package包/类
public void testMaxResults() throws Exception
{
    try
    {
        AuditQueryCallbackImpl callback = new AuditQueryCallbackImpl();
        auditDAO.findAuditEntries(callback, new AuditQueryParameters(), -1);
        fail("maxResults == -1 should be disallowed");
    }
    catch(IllegalArgumentException e)
    {
        // ok
    }
}
 

import org.alfresco.service.cmr.audit.AuditQueryParameters; //导入依赖的package包/类
/**
 * Clearn the audit log as 'admin'
 */
private void queryAuditLog(final AuditQueryCallback callback, final AuditQueryParameters parameters, final int maxResults)
{
    RunAsWork<Void> work = new RunAsWork<Void>()
    {
        @Override
        public Void doWork() throws Exception
        {
            auditService.auditQuery(callback, parameters, maxResults);
            return null;
        }
    };
    AuthenticationUtil.runAs(work, AuthenticationUtil.getAdminRoleName());
}
 

import org.alfresco.service.cmr.audit.AuditQueryParameters; //导入依赖的package包/类
/**
 * {@inheritDoc}
 * @since 3.3
 */
public void auditQuery(AuditQueryCallback callback, AuditQueryParameters parameters, int maxResults)
{
    auditComponent.auditQuery(callback, parameters, maxResults);
}
 

import org.alfresco.service.cmr.audit.AuditQueryParameters; //导入依赖的package包/类
/**
 * Returns content changes.
 */
public ObjectList getContentChanges(Holder<String> changeLogToken, BigInteger maxItems)
{
    final ObjectListImpl result = new ObjectListImpl();
    result.setObjects(new ArrayList<ObjectData>());

    EntryIdCallback changeLogCollectingCallback = new EntryIdCallback(true)
    {
        @Override
        public boolean handleAuditEntry(Long entryId, String user, long time, Map<String, Serializable> values)
        {
            result.getObjects().addAll(createChangeEvents(time, values));
            return super.handleAuditEntry(entryId, user, time, values);
        }
    };

    Long from = null;
    if ((changeLogToken != null) && (changeLogToken.getValue() != null))
    {
        try
        {
            from = Long.parseLong(changeLogToken.getValue());
        }
        catch (NumberFormatException e)
        {
            throw new CmisInvalidArgumentException("Invalid change log token: " + changeLogToken);
        }
    }

    AuditQueryParameters params = new AuditQueryParameters();
    params.setApplicationName(CMIS_CHANGELOG_AUDIT_APPLICATION);
    params.setForward(true);
    params.setFromId(from);

    // So we have a BigInteger.  We need to ensure that we cut it down to an integer smaller than Integer.MAX_VALUE
    
    int maxResults = (maxItems == null ? contentChangesDefaultMaxItems : maxItems.intValue());
    maxResults = maxResults < 1 ? contentChangesDefaultMaxItems : maxResults;           // Just a double check of the unbundled contents
    maxResults = maxResults > contentChangesDefaultMaxItems ? contentChangesDefaultMaxItems : maxResults;   // cut it down
    int queryFor = maxResults + 1;                          // Query for 1 more so that we know if there are more results

    auditService.auditQuery(changeLogCollectingCallback, params, queryFor);

    String newChangeLogToken = null;
    // Check if we got more than the client requested
    if (result.getObjects().size() >= maxResults)
    {
        // Build the change log token from the last item
        StringBuilder clt = new StringBuilder();
        newChangeLogToken = (from == null ? clt.append(maxItems.intValue() + 1).toString() : clt.append(from.longValue() + maxItems.intValue()).toString());    // TODO: Make this readable
        // Remove extra item that was not actually requested
        result.getObjects().remove(result.getObjects().size() - 1).getId();
        // Note to client that there are more items
        result.setHasMoreItems(true);
    }
    else
    {
        // We got the same or fewer than the number requested, so there are no more items
        result.setHasMoreItems(false);
    }

    if (changeLogToken != null)
    {
        changeLogToken.setValue(newChangeLogToken);
    }

    return result;
}
 

import org.alfresco.service.cmr.audit.AuditQueryParameters; //导入依赖的package包/类
/**
 * Creates the repository info object.
 */
private RepositoryInfo createRepositoryInfo(CmisVersion cmisVersion)
{
    Descriptor currentDescriptor = descriptorService.getCurrentRepositoryDescriptor();

    // get change token
    boolean auditEnabled = auditService.isAuditEnabled(CMIS_CHANGELOG_AUDIT_APPLICATION, "/"
            + CMIS_CHANGELOG_AUDIT_APPLICATION);
    String latestChangeLogToken = null;

    if (auditEnabled)
    {
        EntryIdCallback auditQueryCallback = new EntryIdCallback(false);
        AuditQueryParameters params = new AuditQueryParameters();
        params.setApplicationName(CMIS_CHANGELOG_AUDIT_APPLICATION);
        params.setForward(false);
        auditService.auditQuery(auditQueryCallback, params, 1);
        String entryId = auditQueryCallback.getEntryId();
        // MNT-13529
        // add initial change log token
        latestChangeLogToken = entryId == null ? "0" : entryId;
    }

    // compile repository info
    RepositoryInfoImpl ri = new RepositoryInfoImpl();

    ri.setId(currentDescriptor.getId());
    ri.setName(currentDescriptor.getName());
    ri.setDescription(currentDescriptor.getName());
    ri.setVendorName("Alfresco");
    ri.setProductName("Alfresco " + descriptorService.getServerDescriptor().getEdition());
    ri.setProductVersion(currentDescriptor.getVersion());
    NodeRef rootNodeRef = getRootNodeRef();
    ri.setRootFolder(constructObjectId(rootNodeRef, null));
    ri.setCmisVersion(cmisVersion);

    ri.setChangesIncomplete(true);
    ri.setChangesOnType(Arrays.asList(new BaseTypeId[] { BaseTypeId.CMIS_DOCUMENT, BaseTypeId.CMIS_FOLDER }));
    ri.setLatestChangeLogToken(latestChangeLogToken);
    ri.setPrincipalAnonymous(AuthenticationUtil.getGuestUserName());
    ri.setPrincipalAnyone(PermissionService.ALL_AUTHORITIES);

    RepositoryCapabilitiesImpl repCap = new RepositoryCapabilitiesImpl();
    ri.setCapabilities(repCap);

    repCap.setAllVersionsSearchable(false);
    repCap.setCapabilityAcl(CapabilityAcl.MANAGE);
    repCap.setCapabilityChanges(auditEnabled ? CapabilityChanges.OBJECTIDSONLY : CapabilityChanges.NONE);
    repCap.setCapabilityContentStreamUpdates(CapabilityContentStreamUpdates.ANYTIME);
    repCap.setCapabilityJoin(CapabilityJoin.NONE);
    repCap.setCapabilityQuery(CapabilityQuery.BOTHCOMBINED);
    repCap.setCapabilityRendition(CapabilityRenditions.READ);
    repCap.setIsPwcSearchable(false);
    repCap.setIsPwcUpdatable(true);
    repCap.setSupportsGetDescendants(true);
    repCap.setSupportsGetFolderTree(true);
    repCap.setSupportsMultifiling(true);
    repCap.setSupportsUnfiling(false);
    repCap.setSupportsVersionSpecificFiling(false);

    AclCapabilitiesDataImpl aclCap = new AclCapabilitiesDataImpl();
    ri.setAclCapabilities(aclCap);

    aclCap.setAclPropagation(AclPropagation.PROPAGATE);
    aclCap.setSupportedPermissions(SupportedPermissions.BOTH);
    aclCap.setPermissionDefinitionData(repositoryPermissions);
    aclCap.setPermissionMappingData(permissionMappings);

    return ri;
}
 

import org.alfresco.service.cmr.audit.AuditQueryParameters; //导入依赖的package包/类
/**
 * Ensure that an application's audit entries can be deleted between 2 times.
 * @throws Exception
 */
public void testAuditDeleteEntriesForApplicationBetweenTimes() throws Exception
{
    RetryingTransactionCallback<Void> deletedCallback = new RetryingTransactionCallback<Void>()
    {
        AuditQueryCallbackImpl preDeleteCallback = new AuditQueryCallbackImpl();
        AuditQueryCallbackImpl resultsCallback = new AuditQueryCallbackImpl();
 
        
        public Void execute() throws Throwable
        {
            AuditApplicationInfo info1 = createAuditApp();
            String app1 = info1.getName();
            Long app1Id = info1.getId();
            AuditApplicationInfo info2 = createAuditApp();
            String app2 = info2.getName();
            
            // Create items 10, 11, 12, 13, 14 for application 1
            // Create items 21, 22 for application 2
            createItem(info1, 10);
            createItem(info1, 11);
            Thread.sleep(10); // stop previous statements being executed during t1
            Thread.sleep(10);
            final long t1 = System.currentTimeMillis();
            Thread.sleep(10);
            Thread.sleep(10);
            createItem(info2, 21);
            createItem(info1, 12);
            createItem(info1, 13);
            Thread.sleep(10);
            Thread.sleep(10);
            final long t2 = System.currentTimeMillis();
            Thread.sleep(10); // stop next statements being executed during t2
            Thread.sleep(10);
            createItem(info2, 22);
            createItem(info1, 14);
            
            
            auditDAO.findAuditEntries(preDeleteCallback, new AuditQueryParameters(), Integer.MAX_VALUE);
            assertEquals(5, preDeleteCallback.numEntries(app1));
            assertEquals(2, preDeleteCallback.numEntries(app2));
            
            auditDAO.deleteAuditEntries(app1Id, t1, t2);
            
            auditDAO.findAuditEntries(resultsCallback, new AuditQueryParameters(), Integer.MAX_VALUE);
            assertEquals("Two entries should have been deleted from app1", 3, resultsCallback.numEntries(app1));
            assertEquals("No entries should have been deleted from app2", 2, resultsCallback.numEntries(app2));
            return null;
        }
    };
    txnHelper.doInTransaction(deletedCallback);
}
 

import org.alfresco.service.cmr.audit.AuditQueryParameters; //导入依赖的package包/类
/**
 * Ensure audit entries can be deleted between two times - for all applications.
 * @throws Exception
 */
public void testAuditDeleteEntriesBetweenTimes() throws Exception
{
    RetryingTransactionCallback<Void> deletedCallback = new RetryingTransactionCallback<Void>()
    {
        AuditQueryCallbackImpl preDeleteCallback = new AuditQueryCallbackImpl();
        AuditQueryCallbackImpl resultsCallback = new AuditQueryCallbackImpl();
 
        
        public Void execute() throws Throwable
        {
            AuditApplicationInfo info1 = createAuditApp();
            String app1 = info1.getName();
            AuditApplicationInfo info2 = createAuditApp();
            String app2 = info2.getName();
            
            // Create items 10, 11, 12, 13, 14 for application 1
            // Create items 21, 22 for application 2
            createItem(info1, 10);
            createItem(info1, 11);
            Thread.sleep(10);
            Thread.sleep(10); // stop previous statements being executed during t1
            final long t1 = System.currentTimeMillis();
            Thread.sleep(10);
            Thread.sleep(10);
            createItem(info2, 21);
            createItem(info1, 12);
            createItem(info1, 13);
            Thread.sleep(10);
            Thread.sleep(10);
            final long t2 = System.currentTimeMillis();
            Thread.sleep(10); // stop next statements being executed during t2
            Thread.sleep(10);
            createItem(info2, 22);
            createItem(info1, 14);

            auditDAO.findAuditEntries(preDeleteCallback, new AuditQueryParameters(), Integer.MAX_VALUE);
            assertEquals(5, preDeleteCallback.numEntries(app1));
            assertEquals(2, preDeleteCallback.numEntries(app2));
            
            // Delete audit entries between times - for all applications.
            auditDAO.deleteAuditEntries(null, t1, t2);
            
            auditDAO.findAuditEntries(resultsCallback, new AuditQueryParameters(), Integer.MAX_VALUE);
            assertEquals("Two entries should have been deleted from app1", 3, resultsCallback.numEntries(app1));
            assertEquals("One entry should have been deleted from app2", 1, resultsCallback.numEntries(app2));
            return null;
        }
    };
    txnHelper.doInTransaction(deletedCallback);
}
 

import org.alfresco.service.cmr.audit.AuditQueryParameters; //导入依赖的package包/类
/**
 * Returns content changes.
 */
public ObjectList getContentChanges(Holder<String> changeLogToken, BigInteger maxItems)
{
    final ObjectListImpl result = new ObjectListImpl();
    result.setObjects(new ArrayList<ObjectData>());

    EntryIdCallback changeLogCollectingCallback = new EntryIdCallback(true)
    {
        @Override
        public boolean handleAuditEntry(Long entryId, String user, long time, Map<String, Serializable> values)
        {
            result.getObjects().addAll(createChangeEvents(time, values));
            return super.handleAuditEntry(entryId, user, time, values);
        }
    };

    Long from = null;
    if ((changeLogToken != null) && (changeLogToken.getValue() != null))
    {
        try
        {
            from = Long.parseLong(changeLogToken.getValue());
        }
        catch (NumberFormatException e)
        {
            throw new CmisInvalidArgumentException("Invalid change log token: " + changeLogToken);
        }
    }

    AuditQueryParameters params = new AuditQueryParameters();
    params.setApplicationName(CMIS_CHANGELOG_AUDIT_APPLICATION);
    params.setForward(true);
    params.setFromId(from);

    int maxResults = (maxItems == null ? 0 : maxItems.intValue());
    maxResults = (maxResults < 1 ? 0 : maxResults + 1);

    auditService.auditQuery(changeLogCollectingCallback, params, maxResults);

    String newChangeLogToken = null;
    if (maxResults > 0)
    {
        if (result.getObjects().size() >= maxResults)
        {
        	StringBuilder clt = new StringBuilder();
            newChangeLogToken = (from == null ? clt.append(maxItems.intValue() + 1).toString() : clt.append(from.longValue() + maxItems.intValue()).toString());
            result.getObjects().remove(result.getObjects().size() - 1).getId();
            result.setHasMoreItems(true);
        }
        else
        {
            result.setHasMoreItems(false);
        }
    }

    if (changeLogToken != null)
    {
        changeLogToken.setValue(newChangeLogToken);
    }

    return result;
}
 

import org.alfresco.service.cmr.audit.AuditQueryParameters; //导入依赖的package包/类
/**
 * Find audit entries using the given parameters
 * 
 * @param callback          the data callback per entry
 * @param parameters        the parameters for the query (may not be <tt>null</tt>)
 * @param maxResults        the maximum number of results to retrieve (must be greater than 0)
 * 
 * @throws IllegalArgumentException if maxResults less or equal to zero
 * 
 * @since 3.2
 */
void auditQuery(AuditQueryCallback callback, AuditQueryParameters parameters, int maxResults);
 

import org.alfresco.service.cmr.audit.AuditQueryParameters; //导入依赖的package包/类
/**
 * Find audit entries using the given parameters
 * 
 * @param callback          the data callback per entry
 * @param parameters        the parameters for the query (may not be <tt>null</tt>)
 * @param maxResults        the maximum number of results to retrieve (zero or negative to ignore)
 * 
 * @since 3.2
 */
void auditQuery(AuditQueryCallback callback, AuditQueryParameters parameters, int maxResults);