mirror of
https://github.com/Alfresco/alfresco-community-repo.git
synced 2025-10-08 14:51:49 +00:00
Compare commits
52 Commits
Author | SHA1 | Date | |
---|---|---|---|
|
8d790ed1cb | ||
|
87c7bd2877 | ||
|
9125f889b0 | ||
|
2fb74d2691 | ||
|
d671162dae | ||
|
bfaa629da7 | ||
|
719d73a558 | ||
|
a2aa867f3f | ||
|
8d745c536a | ||
|
b0f4c21ae3 | ||
|
72494e34fa | ||
|
792b7024ea | ||
|
40a1371f0d | ||
|
c22c47e63f | ||
|
232299d42d | ||
|
aca7969849 | ||
|
4ab2bbd3d6 | ||
|
f68f02372d | ||
|
9b0eedc8c1 | ||
|
f164dedcee | ||
|
9cdaa0a265 | ||
|
ef034e596b | ||
|
1251081a69 | ||
|
2d16eb6f42 | ||
|
e577134875 | ||
|
510eadd565 | ||
|
187646895c | ||
|
f9515e336f | ||
|
828dd20576 | ||
|
3372e20c35 | ||
|
64b5cace27 | ||
|
83acf26cf4 | ||
|
b3be0f2b7f | ||
|
7a6ebb9a05 | ||
|
fa0f239618 | ||
|
43799408a8 | ||
|
e7305006f0 | ||
|
40c30411af | ||
|
91f8b43237 | ||
|
6fccf828e1 | ||
|
3fac3373c9 | ||
|
ee857ce1de | ||
|
483d7fab21 | ||
|
590209b299 | ||
|
376514df67 | ||
|
7144a2dd94 | ||
|
b4da3d8c20 | ||
|
62de9ff0c0 | ||
|
a11acce720 | ||
|
1128011e15 | ||
|
d0cb45de0d | ||
|
2b48195896 |
@@ -7,7 +7,7 @@
|
|||||||
<parent>
|
<parent>
|
||||||
<groupId>org.alfresco</groupId>
|
<groupId>org.alfresco</groupId>
|
||||||
<artifactId>alfresco-community-repo-amps</artifactId>
|
<artifactId>alfresco-community-repo-amps</artifactId>
|
||||||
<version>23.6.0.13</version>
|
<version>23.6.0.29</version>
|
||||||
</parent>
|
</parent>
|
||||||
|
|
||||||
<modules>
|
<modules>
|
||||||
|
@@ -7,7 +7,7 @@
|
|||||||
<parent>
|
<parent>
|
||||||
<groupId>org.alfresco</groupId>
|
<groupId>org.alfresco</groupId>
|
||||||
<artifactId>alfresco-governance-services-community-parent</artifactId>
|
<artifactId>alfresco-governance-services-community-parent</artifactId>
|
||||||
<version>23.6.0.13</version>
|
<version>23.6.0.29</version>
|
||||||
</parent>
|
</parent>
|
||||||
|
|
||||||
<modules>
|
<modules>
|
||||||
|
@@ -7,7 +7,7 @@
|
|||||||
<parent>
|
<parent>
|
||||||
<groupId>org.alfresco</groupId>
|
<groupId>org.alfresco</groupId>
|
||||||
<artifactId>alfresco-governance-services-automation-community-repo</artifactId>
|
<artifactId>alfresco-governance-services-automation-community-repo</artifactId>
|
||||||
<version>23.6.0.13</version>
|
<version>23.6.0.29</version>
|
||||||
</parent>
|
</parent>
|
||||||
|
|
||||||
<build>
|
<build>
|
||||||
|
@@ -7,7 +7,7 @@
|
|||||||
<parent>
|
<parent>
|
||||||
<groupId>org.alfresco</groupId>
|
<groupId>org.alfresco</groupId>
|
||||||
<artifactId>alfresco-governance-services-community-parent</artifactId>
|
<artifactId>alfresco-governance-services-community-parent</artifactId>
|
||||||
<version>23.6.0.13</version>
|
<version>23.6.0.29</version>
|
||||||
</parent>
|
</parent>
|
||||||
|
|
||||||
<modules>
|
<modules>
|
||||||
|
@@ -15,6 +15,13 @@
|
|||||||
<parameter property="end" jdbcType="BIGINT" javaType="java.lang.Long"/>
|
<parameter property="end" jdbcType="BIGINT" javaType="java.lang.Long"/>
|
||||||
</parameterMap>
|
</parameterMap>
|
||||||
|
|
||||||
|
<parameterMap id="parameter_NodeIdsWhichReferenceContentUrl" type="map">
|
||||||
|
<parameter property="contentUrlShort" jdbcType="VARCHAR" javaType="java.lang.String"/>
|
||||||
|
<parameter property="contentUrlCrc" jdbcType="BIGINT" javaType="java.lang.Long"/>
|
||||||
|
<parameter property="localName" jdbcType="VARCHAR" javaType="java.lang.String"/>
|
||||||
|
<parameter property="uri" jdbcType="VARCHAR" javaType="java.lang.String"/>
|
||||||
|
</parameterMap>
|
||||||
|
|
||||||
<resultMap id="result_NodeRefEntity" type="org.alfresco.module.org_alfresco_module_rm.query.NodeRefEntity">
|
<resultMap id="result_NodeRefEntity" type="org.alfresco.module.org_alfresco_module_rm.query.NodeRefEntity">
|
||||||
<result property="row" column="row" jdbcType="BIGINT" javaType="java.lang.Long"/>
|
<result property="row" column="row" jdbcType="BIGINT" javaType="java.lang.Long"/>
|
||||||
<result property="protocol" column="protocol" jdbcType="VARCHAR" javaType="java.lang.String"/>
|
<result property="protocol" column="protocol" jdbcType="VARCHAR" javaType="java.lang.String"/>
|
||||||
@@ -55,18 +62,21 @@
|
|||||||
|
|
||||||
<!-- Get list of node ids which reference given content url -->
|
<!-- Get list of node ids which reference given content url -->
|
||||||
<select id="select_NodeIdsWhichReferenceContentUrl"
|
<select id="select_NodeIdsWhichReferenceContentUrl"
|
||||||
parameterType="ContentUrl"
|
parameterMap="parameter_NodeIdsWhichReferenceContentUrl"
|
||||||
resultMap="result_NodeIds">
|
resultMap="result_NodeIds">
|
||||||
select
|
select
|
||||||
p.node_id
|
p.node_id
|
||||||
from
|
from
|
||||||
alf_content_url cu
|
alf_content_url cu
|
||||||
LEFT OUTER JOIN alf_content_data cd ON (cd.content_url_id = cu.id)
|
left outer join alf_content_data cd ON (cd.content_url_id = cu.id)
|
||||||
LEFT OUTER JOIN alf_node_properties p ON (p.long_value = cd.id)
|
left outer join alf_node_properties p ON (p.long_value = cd.id)
|
||||||
WHERE
|
left outer join alf_qname q ON (q.id = p.qname_id)
|
||||||
content_url_short = #{contentUrlShort} and
|
left outer join alf_namespace n ON (n.id = q.ns_id)
|
||||||
content_url_crc = #{contentUrlCrc}
|
where
|
||||||
|
cu.content_url_short = ? and
|
||||||
|
cu.content_url_crc = ? and
|
||||||
|
q.local_name = ? and
|
||||||
|
n.uri = ?
|
||||||
</select>
|
</select>
|
||||||
|
|
||||||
<select id="select_RecordFoldersWithSchedules"
|
<select id="select_RecordFoldersWithSchedules"
|
||||||
|
@@ -8,7 +8,7 @@
|
|||||||
<parent>
|
<parent>
|
||||||
<groupId>org.alfresco</groupId>
|
<groupId>org.alfresco</groupId>
|
||||||
<artifactId>alfresco-governance-services-community-repo-parent</artifactId>
|
<artifactId>alfresco-governance-services-community-repo-parent</artifactId>
|
||||||
<version>23.6.0.13</version>
|
<version>23.6.0.29</version>
|
||||||
</parent>
|
</parent>
|
||||||
|
|
||||||
<properties>
|
<properties>
|
||||||
|
@@ -27,7 +27,6 @@
|
|||||||
|
|
||||||
package org.alfresco.module.org_alfresco_module_rm.query;
|
package org.alfresco.module.org_alfresco_module_rm.query;
|
||||||
|
|
||||||
|
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
import java.util.Collections;
|
import java.util.Collections;
|
||||||
import java.util.HashMap;
|
import java.util.HashMap;
|
||||||
@@ -36,6 +35,11 @@ import java.util.List;
|
|||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
|
||||||
|
import org.apache.commons.logging.Log;
|
||||||
|
import org.apache.commons.logging.LogFactory;
|
||||||
|
import org.mybatis.spring.SqlSessionTemplate;
|
||||||
|
|
||||||
|
import org.alfresco.model.ContentModel;
|
||||||
import org.alfresco.module.org_alfresco_module_rm.model.RecordsManagementModel;
|
import org.alfresco.module.org_alfresco_module_rm.model.RecordsManagementModel;
|
||||||
import org.alfresco.repo.domain.contentdata.ContentUrlEntity;
|
import org.alfresco.repo.domain.contentdata.ContentUrlEntity;
|
||||||
import org.alfresco.repo.domain.node.NodeDAO;
|
import org.alfresco.repo.domain.node.NodeDAO;
|
||||||
@@ -47,9 +51,6 @@ import org.alfresco.service.cmr.repository.InvalidNodeRefException;
|
|||||||
import org.alfresco.service.cmr.repository.NodeRef;
|
import org.alfresco.service.cmr.repository.NodeRef;
|
||||||
import org.alfresco.service.namespace.QName;
|
import org.alfresco.service.namespace.QName;
|
||||||
import org.alfresco.util.Pair;
|
import org.alfresco.util.Pair;
|
||||||
import org.apache.commons.logging.Log;
|
|
||||||
import org.apache.commons.logging.LogFactory;
|
|
||||||
import org.mybatis.spring.SqlSessionTemplate;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Records management query DAO implementation
|
* Records management query DAO implementation
|
||||||
@@ -89,7 +90,8 @@ public class RecordsManagementQueryDAOImpl implements RecordsManagementQueryDAO,
|
|||||||
protected TenantService tenantService;
|
protected TenantService tenantService;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @param sqlSessionTemplate SQL session template
|
* @param sqlSessionTemplate
|
||||||
|
* SQL session template
|
||||||
*/
|
*/
|
||||||
public final void setSqlSessionTemplate(SqlSessionTemplate sqlSessionTemplate)
|
public final void setSqlSessionTemplate(SqlSessionTemplate sqlSessionTemplate)
|
||||||
{
|
{
|
||||||
@@ -97,7 +99,8 @@ public class RecordsManagementQueryDAOImpl implements RecordsManagementQueryDAO,
|
|||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @param qnameDAO qname DAO
|
* @param qnameDAO
|
||||||
|
* qname DAO
|
||||||
*/
|
*/
|
||||||
public final void setQnameDAO(QNameDAO qnameDAO)
|
public final void setQnameDAO(QNameDAO qnameDAO)
|
||||||
{
|
{
|
||||||
@@ -173,7 +176,8 @@ public class RecordsManagementQueryDAOImpl implements RecordsManagementQueryDAO,
|
|||||||
/**
|
/**
|
||||||
* Get a set of node reference which reference the provided content URL
|
* Get a set of node reference which reference the provided content URL
|
||||||
*
|
*
|
||||||
* @param String contentUrl content URL
|
* @param String
|
||||||
|
* contentUrl content URL
|
||||||
* @return Set<NodeRef> set of nodes that reference the provided content URL
|
* @return Set<NodeRef> set of nodes that reference the provided content URL
|
||||||
*/
|
*/
|
||||||
@Override
|
@Override
|
||||||
@@ -188,13 +192,19 @@ public class RecordsManagementQueryDAOImpl implements RecordsManagementQueryDAO,
|
|||||||
ContentUrlEntity contentUrlEntity = new ContentUrlEntity();
|
ContentUrlEntity contentUrlEntity = new ContentUrlEntity();
|
||||||
contentUrlEntity.setContentUrl(contentUrl.toLowerCase());
|
contentUrlEntity.setContentUrl(contentUrl.toLowerCase());
|
||||||
|
|
||||||
|
Map<String, Object> params = new HashMap<>(4);
|
||||||
|
params.put("contentUrlShort", contentUrlEntity.getContentUrlShort());
|
||||||
|
params.put("contentUrlCrc", contentUrlEntity.getContentUrlCrc());
|
||||||
|
params.put("localName", ContentModel.PROP_CONTENT.getLocalName());
|
||||||
|
params.put("uri", ContentModel.PROP_CONTENT.getNamespaceURI());
|
||||||
|
|
||||||
if (logger.isDebugEnabled())
|
if (logger.isDebugEnabled())
|
||||||
{
|
{
|
||||||
logger.debug("Executing query " + SELECT_NODE_IDS_WHICH_REFERENCE_CONTENT_URL);
|
logger.debug("Executing query " + SELECT_NODE_IDS_WHICH_REFERENCE_CONTENT_URL);
|
||||||
}
|
}
|
||||||
|
|
||||||
// Get all the node ids which reference the given content url
|
// Get all the node ids which reference the given content url
|
||||||
List<Long> nodeIds = template.selectList(SELECT_NODE_IDS_WHICH_REFERENCE_CONTENT_URL, contentUrlEntity);
|
List<Long> nodeIds = template.selectList(SELECT_NODE_IDS_WHICH_REFERENCE_CONTENT_URL, params);
|
||||||
|
|
||||||
if (logger.isDebugEnabled())
|
if (logger.isDebugEnabled())
|
||||||
{
|
{
|
||||||
@@ -289,7 +299,8 @@ public class RecordsManagementQueryDAOImpl implements RecordsManagementQueryDAO,
|
|||||||
/**
|
/**
|
||||||
* @see org.alfresco.module.org_alfresco_module_rm.query.RecordsManagementQueryDAO#getPropertyStringValueEntity(String stringValue)
|
* @see org.alfresco.module.org_alfresco_module_rm.query.RecordsManagementQueryDAO#getPropertyStringValueEntity(String stringValue)
|
||||||
*/
|
*/
|
||||||
public PropertyStringValueEntity getPropertyStringValueEntity(String stringValue){
|
public PropertyStringValueEntity getPropertyStringValueEntity(String stringValue)
|
||||||
|
{
|
||||||
|
|
||||||
PropertyStringValueEntity propertyStringValueEntity = new PropertyStringValueEntity();
|
PropertyStringValueEntity propertyStringValueEntity = new PropertyStringValueEntity();
|
||||||
propertyStringValueEntity.setValue(stringValue);
|
propertyStringValueEntity.setValue(stringValue);
|
||||||
|
@@ -36,6 +36,7 @@ import java.util.Set;
|
|||||||
|
|
||||||
import org.springframework.context.ApplicationListener;
|
import org.springframework.context.ApplicationListener;
|
||||||
import org.springframework.context.event.ContextRefreshedEvent;
|
import org.springframework.context.event.ContextRefreshedEvent;
|
||||||
|
import org.springframework.dao.ConcurrencyFailureException;
|
||||||
import org.springframework.extensions.webscripts.ui.common.StringUtils;
|
import org.springframework.extensions.webscripts.ui.common.StringUtils;
|
||||||
|
|
||||||
import org.alfresco.model.ContentModel;
|
import org.alfresco.model.ContentModel;
|
||||||
@@ -649,8 +650,8 @@ public class ExtendedSecurityServiceImpl extends ServiceBaseImpl
|
|||||||
}
|
}
|
||||||
catch (DuplicateChildNodeNameException ex)
|
catch (DuplicateChildNodeNameException ex)
|
||||||
{
|
{
|
||||||
// the group was concurrently created
|
// Rethrow as ConcurrencyFailureException so that is can be retried and linked to the group created by the concurrent transaction
|
||||||
group = authorityService.getName(AuthorityType.GROUP, groupShortName);
|
throw new ConcurrencyFailureException("IPR group creation failed due to concurrent duplicate group name creation: " + groupShortName);
|
||||||
}
|
}
|
||||||
|
|
||||||
return group;
|
return group;
|
||||||
|
@@ -29,14 +29,23 @@ package org.alfresco.module.org_alfresco_module_rm.test.legacy.service;
|
|||||||
|
|
||||||
import java.util.HashSet;
|
import java.util.HashSet;
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
import java.util.concurrent.CompletableFuture;
|
||||||
|
|
||||||
|
import org.junit.Assert;
|
||||||
|
import org.springframework.dao.ConcurrencyFailureException;
|
||||||
|
|
||||||
import org.alfresco.model.ContentModel;
|
import org.alfresco.model.ContentModel;
|
||||||
import org.alfresco.module.org_alfresco_module_rm.test.util.BaseRMTestCase;
|
import org.alfresco.module.org_alfresco_module_rm.test.util.BaseRMTestCase;
|
||||||
|
import org.alfresco.query.PagingRequest;
|
||||||
|
import org.alfresco.query.PagingResults;
|
||||||
import org.alfresco.repo.security.authentication.AuthenticationUtil;
|
import org.alfresco.repo.security.authentication.AuthenticationUtil;
|
||||||
import org.alfresco.repo.security.authentication.AuthenticationUtil.RunAsWork;
|
import org.alfresco.repo.security.authentication.AuthenticationUtil.RunAsWork;
|
||||||
import org.alfresco.repo.site.SiteModel;
|
import org.alfresco.repo.site.SiteModel;
|
||||||
|
import org.alfresco.repo.transaction.RetryingTransactionHelper.RetryingTransactionCallback;
|
||||||
import org.alfresco.service.cmr.repository.NodeRef;
|
import org.alfresco.service.cmr.repository.NodeRef;
|
||||||
|
import org.alfresco.service.cmr.security.AccessPermission;
|
||||||
import org.alfresco.service.cmr.security.AccessStatus;
|
import org.alfresco.service.cmr.security.AccessStatus;
|
||||||
|
import org.alfresco.service.cmr.security.AuthorityType;
|
||||||
import org.alfresco.service.cmr.site.SiteService;
|
import org.alfresco.service.cmr.site.SiteService;
|
||||||
import org.alfresco.service.cmr.site.SiteVisibility;
|
import org.alfresco.service.cmr.site.SiteVisibility;
|
||||||
import org.alfresco.util.GUID;
|
import org.alfresco.util.GUID;
|
||||||
@@ -73,8 +82,7 @@ public class ExtendedSecurityServiceImplTest extends BaseRMTestCase
|
|||||||
|
|
||||||
private String createTestUser()
|
private String createTestUser()
|
||||||
{
|
{
|
||||||
return doTestInTransaction(new Test<String>()
|
return doTestInTransaction(new Test<String>() {
|
||||||
{
|
|
||||||
public String run()
|
public String run()
|
||||||
{
|
{
|
||||||
String userName = GUID.generate();
|
String userName = GUID.generate();
|
||||||
@@ -90,8 +98,7 @@ public class ExtendedSecurityServiceImplTest extends BaseRMTestCase
|
|||||||
final String elephant = createTestUser();
|
final String elephant = createTestUser();
|
||||||
final String snake = createTestUser();
|
final String snake = createTestUser();
|
||||||
|
|
||||||
doTestInTransaction(new Test<Void>()
|
doTestInTransaction(new Test<Void>() {
|
||||||
{
|
|
||||||
public Void run()
|
public Void run()
|
||||||
{
|
{
|
||||||
assertFalse(extendedSecurityService.hasExtendedSecurity(filePlan));
|
assertFalse(extendedSecurityService.hasExtendedSecurity(filePlan));
|
||||||
@@ -133,8 +140,7 @@ public class ExtendedSecurityServiceImplTest extends BaseRMTestCase
|
|||||||
final String monkey = createTestUser();
|
final String monkey = createTestUser();
|
||||||
final String elephant = createTestUser();
|
final String elephant = createTestUser();
|
||||||
|
|
||||||
doTestInTransaction(new Test<Void>()
|
doTestInTransaction(new Test<Void>() {
|
||||||
{
|
|
||||||
Set<String> extendedReaders = new HashSet<>(2);
|
Set<String> extendedReaders = new HashSet<>(2);
|
||||||
|
|
||||||
public Void run() throws Exception
|
public Void run() throws Exception
|
||||||
@@ -189,8 +195,7 @@ public class ExtendedSecurityServiceImplTest extends BaseRMTestCase
|
|||||||
final String userWrite = createTestUser();
|
final String userWrite = createTestUser();
|
||||||
final String siteShortName = GUID.generate();
|
final String siteShortName = GUID.generate();
|
||||||
|
|
||||||
doTestInTransaction(new Test<Void>()
|
doTestInTransaction(new Test<Void>() {
|
||||||
{
|
|
||||||
public Void run() throws Exception
|
public Void run() throws Exception
|
||||||
{
|
{
|
||||||
siteService.createSite(null, siteShortName, "test", "test", SiteVisibility.PRIVATE);
|
siteService.createSite(null, siteShortName, "test", "test", SiteVisibility.PRIVATE);
|
||||||
@@ -198,8 +203,7 @@ public class ExtendedSecurityServiceImplTest extends BaseRMTestCase
|
|||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
final NodeRef documentLibrary = doTestInTransaction(new Test<NodeRef>()
|
final NodeRef documentLibrary = doTestInTransaction(new Test<NodeRef>() {
|
||||||
{
|
|
||||||
public NodeRef run() throws Exception
|
public NodeRef run() throws Exception
|
||||||
{
|
{
|
||||||
siteService.setMembership(siteShortName, userRead, SiteModel.SITE_CONSUMER);
|
siteService.setMembership(siteShortName, userRead, SiteModel.SITE_CONSUMER);
|
||||||
@@ -208,22 +212,20 @@ public class ExtendedSecurityServiceImplTest extends BaseRMTestCase
|
|||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
final NodeRef record = doTestInTransaction(new Test<NodeRef>()
|
final NodeRef record = doTestInTransaction(new Test<NodeRef>() {
|
||||||
{
|
|
||||||
public NodeRef run() throws Exception
|
public NodeRef run() throws Exception
|
||||||
{
|
{
|
||||||
NodeRef record = fileFolderService.create(documentLibrary, GUID.generate(), ContentModel.TYPE_CONTENT).getNodeRef();
|
NodeRef record = fileFolderService.create(documentLibrary, GUID.generate(), ContentModel.TYPE_CONTENT)
|
||||||
|
.getNodeRef();
|
||||||
recordService.createRecord(filePlan, record);
|
recordService.createRecord(filePlan, record);
|
||||||
return record;
|
return record;
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
doTestInTransaction(new Test<Void>()
|
doTestInTransaction(new Test<Void>() {
|
||||||
{
|
|
||||||
public Void run() throws Exception
|
public Void run() throws Exception
|
||||||
{
|
{
|
||||||
AuthenticationUtil.runAs(new RunAsWork<Void>()
|
AuthenticationUtil.runAs(new RunAsWork<Void>() {
|
||||||
{
|
|
||||||
public Void doWork() throws Exception
|
public Void doWork() throws Exception
|
||||||
{
|
{
|
||||||
// check permissions
|
// check permissions
|
||||||
@@ -233,8 +235,7 @@ public class ExtendedSecurityServiceImplTest extends BaseRMTestCase
|
|||||||
}
|
}
|
||||||
}, userNone);
|
}, userNone);
|
||||||
|
|
||||||
AuthenticationUtil.runAs(new RunAsWork<Void>()
|
AuthenticationUtil.runAs(new RunAsWork<Void>() {
|
||||||
{
|
|
||||||
public Void doWork() throws Exception
|
public Void doWork() throws Exception
|
||||||
{
|
{
|
||||||
// check permissions
|
// check permissions
|
||||||
@@ -244,8 +245,7 @@ public class ExtendedSecurityServiceImplTest extends BaseRMTestCase
|
|||||||
}
|
}
|
||||||
}, userRead);
|
}, userRead);
|
||||||
|
|
||||||
AuthenticationUtil.runAs(new RunAsWork<Void>()
|
AuthenticationUtil.runAs(new RunAsWork<Void>() {
|
||||||
{
|
|
||||||
public Void doWork() throws Exception
|
public Void doWork() throws Exception
|
||||||
{
|
{
|
||||||
// check permissions
|
// check permissions
|
||||||
@@ -255,8 +255,7 @@ public class ExtendedSecurityServiceImplTest extends BaseRMTestCase
|
|||||||
}
|
}
|
||||||
}, userWrite);
|
}, userWrite);
|
||||||
|
|
||||||
AuthenticationUtil.runAs(new RunAsWork<Void>()
|
AuthenticationUtil.runAs(new RunAsWork<Void>() {
|
||||||
{
|
|
||||||
public Void doWork() throws Exception
|
public Void doWork() throws Exception
|
||||||
{
|
{
|
||||||
// check permissions
|
// check permissions
|
||||||
@@ -266,8 +265,7 @@ public class ExtendedSecurityServiceImplTest extends BaseRMTestCase
|
|||||||
}
|
}
|
||||||
}, userNone);
|
}, userNone);
|
||||||
|
|
||||||
AuthenticationUtil.runAs(new RunAsWork<Void>()
|
AuthenticationUtil.runAs(new RunAsWork<Void>() {
|
||||||
{
|
|
||||||
public Void doWork() throws Exception
|
public Void doWork() throws Exception
|
||||||
{
|
{
|
||||||
// check permissions
|
// check permissions
|
||||||
@@ -277,8 +275,7 @@ public class ExtendedSecurityServiceImplTest extends BaseRMTestCase
|
|||||||
}
|
}
|
||||||
}, userRead);
|
}, userRead);
|
||||||
|
|
||||||
AuthenticationUtil.runAs(new RunAsWork<Void>()
|
AuthenticationUtil.runAs(new RunAsWork<Void>() {
|
||||||
{
|
|
||||||
public Void doWork() throws Exception
|
public Void doWork() throws Exception
|
||||||
{
|
{
|
||||||
// check permissions
|
// check permissions
|
||||||
@@ -292,4 +289,238 @@ public class ExtendedSecurityServiceImplTest extends BaseRMTestCase
|
|||||||
}
|
}
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public void testConcurrentSetWithRetry()
|
||||||
|
{
|
||||||
|
Set<String> extendedReaders = new HashSet<>(2);
|
||||||
|
Set<String> extendedWriters = new HashSet<>(2);
|
||||||
|
|
||||||
|
Set<NodeRef> documents = setupConcurrentTestCase(10, extendedReaders, extendedWriters);
|
||||||
|
|
||||||
|
// For each record created previously, spawn a thread to set extended security so we cause concurrency
|
||||||
|
// failure trying to create IPR groups with the same name
|
||||||
|
fireParallelExecutionOfSetExtendedSecurity(documents, extendedReaders, extendedWriters, true);
|
||||||
|
|
||||||
|
// Look for duplicated IPR groups and verify all documents have the same groups assigned
|
||||||
|
verifyCreatedGroups(documents, false);
|
||||||
|
|
||||||
|
AuthenticationUtil.clearCurrentSecurityContext();
|
||||||
|
}
|
||||||
|
|
||||||
|
public void testConcurrentSetWithoutRetry()
|
||||||
|
{
|
||||||
|
Set<String> extendedReaders = new HashSet<>(2);
|
||||||
|
Set<String> extendedWriters = new HashSet<>(2);
|
||||||
|
|
||||||
|
Set<NodeRef> documents = setupConcurrentTestCase(10, extendedReaders, extendedWriters);
|
||||||
|
|
||||||
|
// For each record created previously, spawn a thread to set extended security so we cause concurrency
|
||||||
|
// failure trying to create IPR groups with the same name.
|
||||||
|
// Since there is no retry, we expect to get a ConcurrencyFailureException
|
||||||
|
Assert.assertThrows(ConcurrencyFailureException.class, () -> {
|
||||||
|
fireParallelExecutionOfSetExtendedSecurity(documents, extendedReaders, extendedWriters, false);
|
||||||
|
});
|
||||||
|
|
||||||
|
// Look for duplicated IPR groups and verify all documents have the same groups assigned
|
||||||
|
// Since there was a ConcurrencyFailureException some threads failed to set extended security so some
|
||||||
|
// documents may not have IPR groups created.
|
||||||
|
verifyCreatedGroups(documents, true);
|
||||||
|
|
||||||
|
AuthenticationUtil.clearCurrentSecurityContext();
|
||||||
|
}
|
||||||
|
|
||||||
|
private Set<NodeRef> setupConcurrentTestCase(int concurrentThreads, Set<String> extendedReaders, Set<String> extendedWriters)
|
||||||
|
{
|
||||||
|
final String usera = createTestUser();
|
||||||
|
final String userb = createTestUser();
|
||||||
|
final String owner = createTestUser();
|
||||||
|
|
||||||
|
extendedReaders.add(usera);
|
||||||
|
extendedReaders.add(userb);
|
||||||
|
extendedWriters.add(usera);
|
||||||
|
extendedWriters.add(userb);
|
||||||
|
|
||||||
|
AuthenticationUtil.setAdminUserAsFullyAuthenticatedUser();
|
||||||
|
|
||||||
|
// Create a site
|
||||||
|
NodeRef documentLib = createSite(new HashSet<>(), new HashSet<>());
|
||||||
|
|
||||||
|
// Create records in the site document library
|
||||||
|
return createRecords(concurrentThreads, documentLib, owner);
|
||||||
|
}
|
||||||
|
|
||||||
|
private NodeRef createSite(Set<String> readers, Set<String> writers)
|
||||||
|
{
|
||||||
|
return retryingTransactionHelper.doInTransaction(new RetryingTransactionCallback<NodeRef>() {
|
||||||
|
@Override
|
||||||
|
public NodeRef execute() throws Throwable
|
||||||
|
{
|
||||||
|
final String siteShortName = GUID.generate();
|
||||||
|
siteService.createSite(null, siteShortName, "test", "test", SiteVisibility.PRIVATE);
|
||||||
|
readers.forEach(reader -> siteService.setMembership(siteShortName, reader, SiteModel.SITE_CONSUMER));
|
||||||
|
writers.forEach(writer -> siteService.setMembership(siteShortName, writer, SiteModel.SITE_COLLABORATOR));
|
||||||
|
return siteService.createContainer(siteShortName, SiteService.DOCUMENT_LIBRARY, null, null);
|
||||||
|
}
|
||||||
|
}, false, true);
|
||||||
|
}
|
||||||
|
|
||||||
|
private Set<NodeRef> createRecords(int numRecords, NodeRef parent, String owner)
|
||||||
|
{
|
||||||
|
return retryingTransactionHelper.doInTransaction(new RetryingTransactionCallback<Set<NodeRef>>() {
|
||||||
|
@Override
|
||||||
|
public Set<NodeRef> execute() throws Throwable
|
||||||
|
{
|
||||||
|
int createdRecords = 0;
|
||||||
|
Set<NodeRef> documents = new HashSet<>();
|
||||||
|
while (createdRecords < numRecords)
|
||||||
|
{
|
||||||
|
final NodeRef doc = fileFolderService.create(parent, GUID.generate(), ContentModel.TYPE_CONTENT).getNodeRef();
|
||||||
|
ownableService.setOwner(doc, owner);
|
||||||
|
recordService.createRecord(filePlan, doc, rmFolder, true);
|
||||||
|
recordService.file(doc);
|
||||||
|
recordService.complete(doc);
|
||||||
|
documents.add(doc);
|
||||||
|
createdRecords++;
|
||||||
|
}
|
||||||
|
return documents;
|
||||||
|
}
|
||||||
|
}, false, true);
|
||||||
|
}
|
||||||
|
|
||||||
|
private void setExtendedSecurity(NodeRef doc, Set<String> readers, Set<String> writers, boolean useRetry)
|
||||||
|
{
|
||||||
|
if (!useRetry)
|
||||||
|
{
|
||||||
|
setExtendedSecurity(doc, readers, writers);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
retryingTransactionHelper.doInTransaction(new RetryingTransactionCallback<Void>() {
|
||||||
|
@Override
|
||||||
|
public Void execute() throws Throwable
|
||||||
|
{
|
||||||
|
setExtendedSecurity(doc, readers, writers);
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
}, false, true);
|
||||||
|
}
|
||||||
|
|
||||||
|
private void setExtendedSecurity(NodeRef doc, Set<String> readers, Set<String> writers)
|
||||||
|
{
|
||||||
|
AuthenticationUtil.setAdminUserAsFullyAuthenticatedUser();
|
||||||
|
extendedSecurityService.set(doc, readers, writers);
|
||||||
|
}
|
||||||
|
|
||||||
|
private void fireParallelExecutionOfSetExtendedSecurity(Set<NodeRef> documents, Set<String> extendedReaders, Set<String> extendedWriters, boolean useRetry)
|
||||||
|
{
|
||||||
|
CompletableFuture<?>[] futures = documents.stream()
|
||||||
|
.map(doc -> CompletableFuture.runAsync(() -> setExtendedSecurity(doc, extendedReaders, extendedWriters, useRetry)))
|
||||||
|
.toArray(CompletableFuture[]::new);
|
||||||
|
|
||||||
|
try
|
||||||
|
{
|
||||||
|
CompletableFuture.allOf(futures).join();
|
||||||
|
}
|
||||||
|
catch (Exception e)
|
||||||
|
{
|
||||||
|
Throwable cause = e.getCause();
|
||||||
|
if (cause instanceof ConcurrencyFailureException)
|
||||||
|
{
|
||||||
|
throw (ConcurrencyFailureException) cause;
|
||||||
|
}
|
||||||
|
throw new RuntimeException("Error during parallel execution", e);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private void verifyCreatedGroups(Set<NodeRef> documents, boolean onlyDuplicatesValidation)
|
||||||
|
{
|
||||||
|
retryingTransactionHelper.doInTransaction(new RetryingTransactionCallback<Void>() {
|
||||||
|
@Override
|
||||||
|
public Void execute() throws Throwable
|
||||||
|
{
|
||||||
|
Set<String> expectedAuthorities = null;
|
||||||
|
Set<Set<String>> errors = new HashSet<>();
|
||||||
|
for (NodeRef doc : documents)
|
||||||
|
{
|
||||||
|
Set<AccessPermission> permissions = permissionService.getAllSetPermissions(doc);
|
||||||
|
Set<String> authorities = getDocumentAuthorities(permissions);
|
||||||
|
Set<String> authoritiesById = getAuthorityIds(authorities);
|
||||||
|
|
||||||
|
verifyIPRGroups(authorities, onlyDuplicatesValidation);
|
||||||
|
|
||||||
|
if (onlyDuplicatesValidation)
|
||||||
|
{
|
||||||
|
// Some documents may not have IPR groups created if there was a ConcurrencyFailureException
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
|
||||||
|
// All documents should have the same exact set of groups assigned
|
||||||
|
if (expectedAuthorities == null)
|
||||||
|
{
|
||||||
|
expectedAuthorities = authoritiesById;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (!expectedAuthorities.equals(authoritiesById))
|
||||||
|
{
|
||||||
|
errors.add(authoritiesById);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
assertTrue("Unexpected authorities linked to document", errors.isEmpty());
|
||||||
|
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
}, false, true);
|
||||||
|
}
|
||||||
|
|
||||||
|
private Set<String> getDocumentAuthorities(Set<AccessPermission> permissions)
|
||||||
|
{
|
||||||
|
Set<String> authorities = new HashSet<>();
|
||||||
|
|
||||||
|
for (AccessPermission accessPermission : permissions)
|
||||||
|
{
|
||||||
|
String authority = accessPermission.getAuthority();
|
||||||
|
String authName = authorityService.getName(AuthorityType.GROUP, authority);
|
||||||
|
authorities.add(authName);
|
||||||
|
|
||||||
|
}
|
||||||
|
return authorities;
|
||||||
|
}
|
||||||
|
|
||||||
|
private Set<String> getAuthorityIds(Set<String> authorities)
|
||||||
|
{
|
||||||
|
Set<String> authorityIds = new HashSet<>();
|
||||||
|
for (String authority : authorities)
|
||||||
|
{
|
||||||
|
String authId = authorityService.getAuthorityNodeRef(authority) != null
|
||||||
|
? authorityService.getAuthorityNodeRef(authority).getId()
|
||||||
|
: null;
|
||||||
|
authorityIds.add(authId);
|
||||||
|
}
|
||||||
|
return authorityIds;
|
||||||
|
}
|
||||||
|
|
||||||
|
private void verifyIPRGroups(Set<String> authorities, boolean onlyDuplicatesValidation)
|
||||||
|
{
|
||||||
|
boolean hasGroupIPR = false;
|
||||||
|
|
||||||
|
for (String authorityName : authorities)
|
||||||
|
{
|
||||||
|
String shortName = authorityService.getShortName(authorityName);
|
||||||
|
|
||||||
|
if (authorityName.startsWith("GROUP_IPR"))
|
||||||
|
{
|
||||||
|
hasGroupIPR = true;
|
||||||
|
PagingResults<String> results = authorityService.getAuthorities(AuthorityType.GROUP, null, shortName, false,
|
||||||
|
false, new PagingRequest(0, 10));
|
||||||
|
|
||||||
|
assertEquals("No duplicated IPR group expected", 1, results.getPage().size());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if (!onlyDuplicatesValidation)
|
||||||
|
{
|
||||||
|
assertTrue("No IPR Groups created", hasGroupIPR);
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
@@ -7,7 +7,7 @@
|
|||||||
<parent>
|
<parent>
|
||||||
<groupId>org.alfresco</groupId>
|
<groupId>org.alfresco</groupId>
|
||||||
<artifactId>alfresco-governance-services-community-repo-parent</artifactId>
|
<artifactId>alfresco-governance-services-community-repo-parent</artifactId>
|
||||||
<version>23.6.0.13</version>
|
<version>23.6.0.29</version>
|
||||||
</parent>
|
</parent>
|
||||||
|
|
||||||
<build>
|
<build>
|
||||||
|
@@ -7,7 +7,7 @@
|
|||||||
<parent>
|
<parent>
|
||||||
<groupId>org.alfresco</groupId>
|
<groupId>org.alfresco</groupId>
|
||||||
<artifactId>alfresco-community-repo</artifactId>
|
<artifactId>alfresco-community-repo</artifactId>
|
||||||
<version>23.6.0.13</version>
|
<version>23.6.0.29</version>
|
||||||
</parent>
|
</parent>
|
||||||
|
|
||||||
<modules>
|
<modules>
|
||||||
|
@@ -8,7 +8,7 @@
|
|||||||
<parent>
|
<parent>
|
||||||
<groupId>org.alfresco</groupId>
|
<groupId>org.alfresco</groupId>
|
||||||
<artifactId>alfresco-community-repo-amps</artifactId>
|
<artifactId>alfresco-community-repo-amps</artifactId>
|
||||||
<version>23.6.0.13</version>
|
<version>23.6.0.29</version>
|
||||||
</parent>
|
</parent>
|
||||||
|
|
||||||
<properties>
|
<properties>
|
||||||
|
@@ -91,6 +91,15 @@ function doclist_getAllNodes(parsedArgs, filterParams, query, totalItemCount)
|
|||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
|
function sanitizeJunkFavouriteKeys(favourites){
|
||||||
|
for (var key in favourites) {
|
||||||
|
if (!key || key.trim() === "") {
|
||||||
|
delete favourites[key];
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return favourites;
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Main entry point: Create collection of documents and folders in the given space
|
* Main entry point: Create collection of documents and folders in the given space
|
||||||
*
|
*
|
||||||
@@ -124,6 +133,28 @@ function doclist_main()
|
|||||||
if (logger.isLoggingEnabled())
|
if (logger.isLoggingEnabled())
|
||||||
logger.log("doclist.lib.js - NodeRef: " + parsedArgs.nodeRef + " Query: " + query);
|
logger.log("doclist.lib.js - NodeRef: " + parsedArgs.nodeRef + " Query: " + query);
|
||||||
|
|
||||||
|
favourites = sanitizeJunkFavouriteKeys(favourites);
|
||||||
|
|
||||||
|
if(Object.keys(favourites).length === 0 && query === null)
|
||||||
|
{
|
||||||
|
return {
|
||||||
|
luceneQuery: "",
|
||||||
|
paging: {
|
||||||
|
totalRecords: 0,
|
||||||
|
startIndex: 0
|
||||||
|
},
|
||||||
|
container: parsedArgs.rootNode,
|
||||||
|
parent: null,
|
||||||
|
onlineEditing: utils.moduleInstalled("org.alfresco.module.vti"),
|
||||||
|
itemCount: {
|
||||||
|
folders: 0,
|
||||||
|
documents: 0
|
||||||
|
},
|
||||||
|
items: [],
|
||||||
|
customJSON: slingshotDocLib.getJSON()
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
var totalItemCount = filterParams.limitResults ? parseInt(filterParams.limitResults, 10) : -1;
|
var totalItemCount = filterParams.limitResults ? parseInt(filterParams.limitResults, 10) : -1;
|
||||||
// For all sites documentLibrary query we pull in all available results and post filter
|
// For all sites documentLibrary query we pull in all available results and post filter
|
||||||
if (totalItemCount === 0) totalItemCount = -1;
|
if (totalItemCount === 0) totalItemCount = -1;
|
||||||
|
@@ -181,6 +181,8 @@ var Filters =
|
|||||||
|
|
||||||
case "favourites":
|
case "favourites":
|
||||||
for (var favourite in favourites)
|
for (var favourite in favourites)
|
||||||
|
{
|
||||||
|
if (favourite && favourite.trim() !== "")
|
||||||
{
|
{
|
||||||
if (filterQuery)
|
if (filterQuery)
|
||||||
{
|
{
|
||||||
@@ -188,6 +190,7 @@ var Filters =
|
|||||||
}
|
}
|
||||||
filterQuery += "ID:\"" + favourite + "\"";
|
filterQuery += "ID:\"" + favourite + "\"";
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
if (filterQuery.length !== 0)
|
if (filterQuery.length !== 0)
|
||||||
{
|
{
|
||||||
@@ -201,7 +204,13 @@ var Filters =
|
|||||||
else
|
else
|
||||||
{
|
{
|
||||||
// empty favourites query
|
// empty favourites query
|
||||||
filterQuery = "+ID:\"\"";
|
logger.warn("No favourites found for user: " + person.properties.userName);
|
||||||
|
return {
|
||||||
|
query: null,
|
||||||
|
limitResults: 0,
|
||||||
|
sort: [],
|
||||||
|
language: "lucene"
|
||||||
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
filterParams.query = filterQuery;
|
filterParams.query = filterQuery;
|
||||||
|
@@ -7,7 +7,7 @@
|
|||||||
<parent>
|
<parent>
|
||||||
<groupId>org.alfresco</groupId>
|
<groupId>org.alfresco</groupId>
|
||||||
<artifactId>alfresco-community-repo</artifactId>
|
<artifactId>alfresco-community-repo</artifactId>
|
||||||
<version>23.6.0.13</version>
|
<version>23.6.0.29</version>
|
||||||
</parent>
|
</parent>
|
||||||
|
|
||||||
<dependencies>
|
<dependencies>
|
||||||
|
@@ -7,7 +7,7 @@
|
|||||||
<parent>
|
<parent>
|
||||||
<groupId>org.alfresco</groupId>
|
<groupId>org.alfresco</groupId>
|
||||||
<artifactId>alfresco-community-repo</artifactId>
|
<artifactId>alfresco-community-repo</artifactId>
|
||||||
<version>23.6.0.13</version>
|
<version>23.6.0.29</version>
|
||||||
</parent>
|
</parent>
|
||||||
|
|
||||||
<properties>
|
<properties>
|
||||||
|
@@ -7,7 +7,7 @@
|
|||||||
<parent>
|
<parent>
|
||||||
<groupId>org.alfresco</groupId>
|
<groupId>org.alfresco</groupId>
|
||||||
<artifactId>alfresco-community-repo</artifactId>
|
<artifactId>alfresco-community-repo</artifactId>
|
||||||
<version>23.6.0.13</version>
|
<version>23.6.0.29</version>
|
||||||
</parent>
|
</parent>
|
||||||
|
|
||||||
<dependencies>
|
<dependencies>
|
||||||
|
@@ -9,6 +9,6 @@
|
|||||||
<parent>
|
<parent>
|
||||||
<groupId>org.alfresco</groupId>
|
<groupId>org.alfresco</groupId>
|
||||||
<artifactId>alfresco-community-repo-packaging</artifactId>
|
<artifactId>alfresco-community-repo-packaging</artifactId>
|
||||||
<version>23.6.0.13</version>
|
<version>23.6.0.29</version>
|
||||||
</parent>
|
</parent>
|
||||||
</project>
|
</project>
|
||||||
|
@@ -7,7 +7,7 @@
|
|||||||
<parent>
|
<parent>
|
||||||
<groupId>org.alfresco</groupId>
|
<groupId>org.alfresco</groupId>
|
||||||
<artifactId>alfresco-community-repo-packaging</artifactId>
|
<artifactId>alfresco-community-repo-packaging</artifactId>
|
||||||
<version>23.6.0.13</version>
|
<version>23.6.0.29</version>
|
||||||
</parent>
|
</parent>
|
||||||
|
|
||||||
<properties>
|
<properties>
|
||||||
|
@@ -7,7 +7,7 @@
|
|||||||
<parent>
|
<parent>
|
||||||
<groupId>org.alfresco</groupId>
|
<groupId>org.alfresco</groupId>
|
||||||
<artifactId>alfresco-community-repo</artifactId>
|
<artifactId>alfresco-community-repo</artifactId>
|
||||||
<version>23.6.0.13</version>
|
<version>23.6.0.29</version>
|
||||||
</parent>
|
</parent>
|
||||||
|
|
||||||
<modules>
|
<modules>
|
||||||
|
@@ -6,7 +6,7 @@
|
|||||||
<parent>
|
<parent>
|
||||||
<groupId>org.alfresco</groupId>
|
<groupId>org.alfresco</groupId>
|
||||||
<artifactId>alfresco-community-repo-packaging</artifactId>
|
<artifactId>alfresco-community-repo-packaging</artifactId>
|
||||||
<version>23.6.0.13</version>
|
<version>23.6.0.29</version>
|
||||||
</parent>
|
</parent>
|
||||||
|
|
||||||
<modules>
|
<modules>
|
||||||
|
@@ -7,7 +7,7 @@
|
|||||||
<parent>
|
<parent>
|
||||||
<groupId>org.alfresco</groupId>
|
<groupId>org.alfresco</groupId>
|
||||||
<artifactId>alfresco-community-repo-tests</artifactId>
|
<artifactId>alfresco-community-repo-tests</artifactId>
|
||||||
<version>23.6.0.13</version>
|
<version>23.6.0.29</version>
|
||||||
</parent>
|
</parent>
|
||||||
|
|
||||||
<organization>
|
<organization>
|
||||||
|
@@ -9,7 +9,7 @@
|
|||||||
<parent>
|
<parent>
|
||||||
<groupId>org.alfresco</groupId>
|
<groupId>org.alfresco</groupId>
|
||||||
<artifactId>alfresco-community-repo-tests</artifactId>
|
<artifactId>alfresco-community-repo-tests</artifactId>
|
||||||
<version>23.6.0.13</version>
|
<version>23.6.0.29</version>
|
||||||
</parent>
|
</parent>
|
||||||
|
|
||||||
<developers>
|
<developers>
|
||||||
|
@@ -9,7 +9,7 @@
|
|||||||
<parent>
|
<parent>
|
||||||
<groupId>org.alfresco</groupId>
|
<groupId>org.alfresco</groupId>
|
||||||
<artifactId>alfresco-community-repo-tests</artifactId>
|
<artifactId>alfresco-community-repo-tests</artifactId>
|
||||||
<version>23.6.0.13</version>
|
<version>23.6.0.29</version>
|
||||||
</parent>
|
</parent>
|
||||||
|
|
||||||
<developers>
|
<developers>
|
||||||
|
@@ -8,7 +8,7 @@
|
|||||||
<parent>
|
<parent>
|
||||||
<groupId>org.alfresco</groupId>
|
<groupId>org.alfresco</groupId>
|
||||||
<artifactId>alfresco-community-repo-tests</artifactId>
|
<artifactId>alfresco-community-repo-tests</artifactId>
|
||||||
<version>23.6.0.13</version>
|
<version>23.6.0.29</version>
|
||||||
</parent>
|
</parent>
|
||||||
|
|
||||||
<properties>
|
<properties>
|
||||||
|
@@ -9,7 +9,7 @@
|
|||||||
<parent>
|
<parent>
|
||||||
<groupId>org.alfresco</groupId>
|
<groupId>org.alfresco</groupId>
|
||||||
<artifactId>alfresco-community-repo-tests</artifactId>
|
<artifactId>alfresco-community-repo-tests</artifactId>
|
||||||
<version>23.6.0.13</version>
|
<version>23.6.0.29</version>
|
||||||
</parent>
|
</parent>
|
||||||
|
|
||||||
<developers>
|
<developers>
|
||||||
|
@@ -7,7 +7,7 @@
|
|||||||
<parent>
|
<parent>
|
||||||
<groupId>org.alfresco</groupId>
|
<groupId>org.alfresco</groupId>
|
||||||
<artifactId>alfresco-community-repo-packaging</artifactId>
|
<artifactId>alfresco-community-repo-packaging</artifactId>
|
||||||
<version>23.6.0.13</version>
|
<version>23.6.0.29</version>
|
||||||
</parent>
|
</parent>
|
||||||
|
|
||||||
<properties>
|
<properties>
|
||||||
|
32
pom.xml
32
pom.xml
@@ -2,7 +2,7 @@
|
|||||||
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
|
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
|
||||||
<modelVersion>4.0.0</modelVersion>
|
<modelVersion>4.0.0</modelVersion>
|
||||||
<artifactId>alfresco-community-repo</artifactId>
|
<artifactId>alfresco-community-repo</artifactId>
|
||||||
<version>23.6.0.13</version>
|
<version>23.6.0.29</version>
|
||||||
<packaging>pom</packaging>
|
<packaging>pom</packaging>
|
||||||
<name>Alfresco Community Repo Parent</name>
|
<name>Alfresco Community Repo Parent</name>
|
||||||
|
|
||||||
@@ -51,17 +51,17 @@
|
|||||||
<dependency.alfresco-server-root.version>7.0.1</dependency.alfresco-server-root.version>
|
<dependency.alfresco-server-root.version>7.0.1</dependency.alfresco-server-root.version>
|
||||||
<dependency.activiti-engine.version>5.23.0</dependency.activiti-engine.version>
|
<dependency.activiti-engine.version>5.23.0</dependency.activiti-engine.version>
|
||||||
<dependency.activiti.version>5.23.0</dependency.activiti.version>
|
<dependency.activiti.version>5.23.0</dependency.activiti.version>
|
||||||
<dependency.alfresco-transform-core.version>5.1.5</dependency.alfresco-transform-core.version>
|
<dependency.alfresco-transform-core.version>5.2.2</dependency.alfresco-transform-core.version>
|
||||||
<dependency.alfresco-transform-service.version>4.1.5</dependency.alfresco-transform-service.version>
|
<dependency.alfresco-transform-service.version>4.2.2</dependency.alfresco-transform-service.version>
|
||||||
<dependency.alfresco-greenmail.version>7.0</dependency.alfresco-greenmail.version>
|
<dependency.alfresco-greenmail.version>7.0</dependency.alfresco-greenmail.version>
|
||||||
<dependency.acs-event-model.version>0.0.33</dependency.acs-event-model.version>
|
<dependency.acs-event-model.version>0.0.33</dependency.acs-event-model.version>
|
||||||
|
|
||||||
<dependency.aspectj.version>1.9.22.1</dependency.aspectj.version>
|
<dependency.aspectj.version>1.9.22.1</dependency.aspectj.version>
|
||||||
<dependency.spring.version>6.2.8</dependency.spring.version>
|
<dependency.spring.version>6.2.11</dependency.spring.version>
|
||||||
<dependency.spring-security.version>6.3.9</dependency.spring-security.version>
|
<dependency.spring-security.version>6.4.11</dependency.spring-security.version>
|
||||||
<dependency.antlr.version>3.5.3</dependency.antlr.version>
|
<dependency.antlr.version>3.5.3</dependency.antlr.version>
|
||||||
<dependency.jackson.version>2.17.2</dependency.jackson.version>
|
<dependency.jackson.version>2.17.2</dependency.jackson.version>
|
||||||
<dependency.cxf.version>4.1.0</dependency.cxf.version>
|
<dependency.cxf.version>4.1.2</dependency.cxf.version>
|
||||||
<dependency.opencmis.version>1.0.0-jakarta-1</dependency.opencmis.version>
|
<dependency.opencmis.version>1.0.0-jakarta-1</dependency.opencmis.version>
|
||||||
<dependency.webscripts.version>10.2</dependency.webscripts.version>
|
<dependency.webscripts.version>10.2</dependency.webscripts.version>
|
||||||
<dependency.bouncycastle.version>1.78.1</dependency.bouncycastle.version>
|
<dependency.bouncycastle.version>1.78.1</dependency.bouncycastle.version>
|
||||||
@@ -81,7 +81,7 @@
|
|||||||
<dependency.slf4j.version>2.0.16</dependency.slf4j.version>
|
<dependency.slf4j.version>2.0.16</dependency.slf4j.version>
|
||||||
<dependency.log4j.version>2.23.1</dependency.log4j.version>
|
<dependency.log4j.version>2.23.1</dependency.log4j.version>
|
||||||
<dependency.groovy.version>3.0.22</dependency.groovy.version>
|
<dependency.groovy.version>3.0.22</dependency.groovy.version>
|
||||||
<dependency.tika.version>2.9.2</dependency.tika.version>
|
<dependency.tika.version>3.2.3</dependency.tika.version>
|
||||||
<dependency.truezip.version>7.7.10</dependency.truezip.version>
|
<dependency.truezip.version>7.7.10</dependency.truezip.version>
|
||||||
<dependency.poi.version>5.4.1</dependency.poi.version>
|
<dependency.poi.version>5.4.1</dependency.poi.version>
|
||||||
<dependency.jboss.logging.version>3.5.0.Final</dependency.jboss.logging.version>
|
<dependency.jboss.logging.version>3.5.0.Final</dependency.jboss.logging.version>
|
||||||
@@ -113,7 +113,7 @@
|
|||||||
<dependency.jakarta-json-path.version>2.9.0</dependency.jakarta-json-path.version>
|
<dependency.jakarta-json-path.version>2.9.0</dependency.jakarta-json-path.version>
|
||||||
<dependency.json-smart.version>2.5.2</dependency.json-smart.version>
|
<dependency.json-smart.version>2.5.2</dependency.json-smart.version>
|
||||||
<alfresco.googledrive.version>4.1.0</alfresco.googledrive.version>
|
<alfresco.googledrive.version>4.1.0</alfresco.googledrive.version>
|
||||||
<alfresco.aos-module.version>3.3.0</alfresco.aos-module.version>
|
<alfresco.aos-module.version>3.4.0-A.1</alfresco.aos-module.version>
|
||||||
<alfresco.api-explorer.version>23.4.0</alfresco.api-explorer.version> <!-- Also in alfresco-enterprise-share -->
|
<alfresco.api-explorer.version>23.4.0</alfresco.api-explorer.version> <!-- Also in alfresco-enterprise-share -->
|
||||||
|
|
||||||
<alfresco.maven-plugin.version>2.2.0</alfresco.maven-plugin.version>
|
<alfresco.maven-plugin.version>2.2.0</alfresco.maven-plugin.version>
|
||||||
@@ -154,7 +154,7 @@
|
|||||||
<connection>scm:git:https://github.com/Alfresco/alfresco-community-repo.git</connection>
|
<connection>scm:git:https://github.com/Alfresco/alfresco-community-repo.git</connection>
|
||||||
<developerConnection>scm:git:https://github.com/Alfresco/alfresco-community-repo.git</developerConnection>
|
<developerConnection>scm:git:https://github.com/Alfresco/alfresco-community-repo.git</developerConnection>
|
||||||
<url>https://github.com/Alfresco/alfresco-community-repo</url>
|
<url>https://github.com/Alfresco/alfresco-community-repo</url>
|
||||||
<tag>23.6.0.13</tag>
|
<tag>23.6.0.29</tag>
|
||||||
</scm>
|
</scm>
|
||||||
|
|
||||||
<distributionManagement>
|
<distributionManagement>
|
||||||
@@ -170,6 +170,12 @@
|
|||||||
|
|
||||||
<dependencyManagement>
|
<dependencyManagement>
|
||||||
<dependencies>
|
<dependencies>
|
||||||
|
<!-- v1.10 has 0BSD license it must be consulted with Legal -->
|
||||||
|
<dependency>
|
||||||
|
<groupId>org.tukaani</groupId>
|
||||||
|
<artifactId>xz</artifactId>
|
||||||
|
<version>1.9</version>
|
||||||
|
</dependency>
|
||||||
<!-- Jakarta... -->
|
<!-- Jakarta... -->
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>jakarta.xml.bind</groupId>
|
<groupId>jakarta.xml.bind</groupId>
|
||||||
@@ -1132,16 +1138,10 @@
|
|||||||
<exclude>jakarta.xml.soap:jakarta.xml.soap-api:(, 2.0.1)</exclude>
|
<exclude>jakarta.xml.soap:jakarta.xml.soap-api:(, 2.0.1)</exclude>
|
||||||
<exclude>jakarta.jws:jakarta.jws-api:(, 3.0.0)</exclude>
|
<exclude>jakarta.jws:jakarta.jws-api:(, 3.0.0)</exclude>
|
||||||
<!-- Enforce ban bouncycastle dependencies other than specified under <includes> section-->
|
<!-- Enforce ban bouncycastle dependencies other than specified under <includes> section-->
|
||||||
<exclude>org.bouncycastle</exclude>
|
<exclude>org.bouncycastle:(,1.81)</exclude>
|
||||||
<!-- Enforce one version of Jaxb-->
|
<!-- Enforce one version of Jaxb-->
|
||||||
<exclude>com.sun.xml.bind</exclude>
|
<exclude>com.sun.xml.bind</exclude>
|
||||||
</excludes>
|
</excludes>
|
||||||
<includes>
|
|
||||||
<include>org.bouncycastle:bcprov-jdk18on:[1.78.1,)</include>
|
|
||||||
<include>org.bouncycastle:bcmail-jdk18on:[1.78.1,)</include>
|
|
||||||
<include>org.bouncycastle:bcpkix-jdk18on:[1.78.1,)</include>
|
|
||||||
<include>org.bouncycastle:bcutil-jdk18on:[1.78.1,)</include>
|
|
||||||
</includes>
|
|
||||||
</bannedDependencies>
|
</bannedDependencies>
|
||||||
</rules>
|
</rules>
|
||||||
<fail>true</fail>
|
<fail>true</fail>
|
||||||
|
@@ -7,7 +7,7 @@
|
|||||||
<parent>
|
<parent>
|
||||||
<groupId>org.alfresco</groupId>
|
<groupId>org.alfresco</groupId>
|
||||||
<artifactId>alfresco-community-repo</artifactId>
|
<artifactId>alfresco-community-repo</artifactId>
|
||||||
<version>23.6.0.13</version>
|
<version>23.6.0.29</version>
|
||||||
</parent>
|
</parent>
|
||||||
|
|
||||||
<dependencies>
|
<dependencies>
|
||||||
|
@@ -7,7 +7,7 @@
|
|||||||
<parent>
|
<parent>
|
||||||
<groupId>org.alfresco</groupId>
|
<groupId>org.alfresco</groupId>
|
||||||
<artifactId>alfresco-community-repo</artifactId>
|
<artifactId>alfresco-community-repo</artifactId>
|
||||||
<version>23.6.0.13</version>
|
<version>23.6.0.29</version>
|
||||||
</parent>
|
</parent>
|
||||||
|
|
||||||
<dependencies>
|
<dependencies>
|
||||||
|
File diff suppressed because it is too large
Load Diff
@@ -2,7 +2,7 @@
|
|||||||
* #%L
|
* #%L
|
||||||
* Alfresco Repository
|
* Alfresco Repository
|
||||||
* %%
|
* %%
|
||||||
* Copyright (C) 2005 - 2016 Alfresco Software Limited
|
* Copyright (C) 2005 - 2025 Alfresco Software Limited
|
||||||
* %%
|
* %%
|
||||||
* This file is part of the Alfresco software.
|
* This file is part of the Alfresco software.
|
||||||
* If the software was purchased under a paid Alfresco license, the terms of
|
* If the software was purchased under a paid Alfresco license, the terms of
|
||||||
@@ -36,8 +36,7 @@ import org.alfresco.service.cmr.repository.datatype.DefaultTypeConverter;
|
|||||||
import org.alfresco.service.namespace.QName;
|
import org.alfresco.service.namespace.QName;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Class holding properties associated with the <b>sys:referenceable</b> aspect.
|
* Class holding properties associated with the <b>sys:referenceable</b> aspect. This aspect is common enough to warrant direct inclusion on the <b>Node</b> entity.
|
||||||
* This aspect is common enough to warrant direct inclusion on the <b>Node</b> entity.
|
|
||||||
*
|
*
|
||||||
* @author Derek Hulley
|
* @author Derek Hulley
|
||||||
* @since 3.4
|
* @since 3.4
|
||||||
@@ -87,10 +86,8 @@ public class ReferenceablePropertiesEntity
|
|||||||
/**
|
/**
|
||||||
* Adds all {@link ContentModel#ASPECT_REFERENCEABLE referencable} properties.
|
* Adds all {@link ContentModel#ASPECT_REFERENCEABLE referencable} properties.
|
||||||
*/
|
*/
|
||||||
public static void addReferenceableProperties(Node node, Map<QName, Serializable> properties)
|
public static void addReferenceableProperties(Long nodeId, NodeRef nodeRef, Map<QName, Serializable> properties)
|
||||||
{
|
{
|
||||||
Long nodeId = node.getId();
|
|
||||||
NodeRef nodeRef = node.getNodeRef();
|
|
||||||
properties.put(ContentModel.PROP_STORE_PROTOCOL, nodeRef.getStoreRef().getProtocol());
|
properties.put(ContentModel.PROP_STORE_PROTOCOL, nodeRef.getStoreRef().getProtocol());
|
||||||
properties.put(ContentModel.PROP_STORE_IDENTIFIER, nodeRef.getStoreRef().getIdentifier());
|
properties.put(ContentModel.PROP_STORE_IDENTIFIER, nodeRef.getStoreRef().getIdentifier());
|
||||||
properties.put(ContentModel.PROP_NODE_UUID, nodeRef.getId());
|
properties.put(ContentModel.PROP_NODE_UUID, nodeRef.getId());
|
||||||
|
@@ -116,7 +116,7 @@ public class NodeDAOImpl extends AbstractNodeDAOImpl
|
|||||||
private static final String SELECT_NODE_MAX_ID = "alfresco.node.select_NodeMaxId";
|
private static final String SELECT_NODE_MAX_ID = "alfresco.node.select_NodeMaxId";
|
||||||
private static final String SELECT_NODE_INTERVAL_BY_TYPE = "alfresco.node.select_MinMaxNodeIdForNodeType";
|
private static final String SELECT_NODE_INTERVAL_BY_TYPE = "alfresco.node.select_MinMaxNodeIdForNodeType";
|
||||||
private static final String SELECT_NODES_WITH_ASPECT_IDS = "alfresco.node.select_NodesWithAspectIds";
|
private static final String SELECT_NODES_WITH_ASPECT_IDS = "alfresco.node.select_NodesWithAspectIds";
|
||||||
private static final String SELECT_NODES_WITH_ASPECT_IDS_LIMITED = "alfresco.node.select_NodesWithAspectIds_Limited";
|
private static final String SELECT_NODES_WITH_ASPECT_IDS_LIMITED = "alfresco.node.select.select_NodesWithAspectIds_Limited";
|
||||||
private static final String INSERT_NODE_ASSOC = "alfresco.node.insert.insert_NodeAssoc";
|
private static final String INSERT_NODE_ASSOC = "alfresco.node.insert.insert_NodeAssoc";
|
||||||
private static final String UPDATE_NODE_ASSOC = "alfresco.node.update_NodeAssoc";
|
private static final String UPDATE_NODE_ASSOC = "alfresco.node.update_NodeAssoc";
|
||||||
private static final String DELETE_NODE_ASSOC = "alfresco.node.delete_NodeAssoc";
|
private static final String DELETE_NODE_ASSOC = "alfresco.node.delete_NodeAssoc";
|
||||||
|
@@ -2,7 +2,7 @@
|
|||||||
* #%L
|
* #%L
|
||||||
* Alfresco Repository
|
* Alfresco Repository
|
||||||
* %%
|
* %%
|
||||||
* Copyright (C) 2005 - 2023 Alfresco Software Limited
|
* Copyright (C) 2005 - 2025 Alfresco Software Limited
|
||||||
* %%
|
* %%
|
||||||
* This file is part of the Alfresco software.
|
* This file is part of the Alfresco software.
|
||||||
* If the software was purchased under a paid Alfresco license, the terms of
|
* If the software was purchased under a paid Alfresco license, the terms of
|
||||||
@@ -39,8 +39,10 @@ import org.alfresco.service.namespace.QName;
|
|||||||
/**
|
/**
|
||||||
* Encapsulates events occurred in a single transaction.
|
* Encapsulates events occurred in a single transaction.
|
||||||
*
|
*
|
||||||
* @param <REF> entity (e.g. node, child association, peer association) reference type
|
* @param <REF>
|
||||||
* @param <RES> entity resource type
|
* entity (e.g. node, child association, peer association) reference type
|
||||||
|
* @param <RES>
|
||||||
|
* entity resource type
|
||||||
*/
|
*/
|
||||||
public abstract class EventConsolidator<REF extends EntityRef, RES extends Resource>
|
public abstract class EventConsolidator<REF extends EntityRef, RES extends Resource>
|
||||||
{
|
{
|
||||||
@@ -90,23 +92,31 @@ public abstract class EventConsolidator<REF extends EntityRef, RES extends Resou
|
|||||||
/**
|
/**
|
||||||
* Builds and returns the {@link RepoEvent} instance.
|
* Builds and returns the {@link RepoEvent} instance.
|
||||||
*
|
*
|
||||||
* @param eventInfo the object holding the event information
|
* @param eventInfo
|
||||||
|
* the object holding the event information
|
||||||
* @return the {@link RepoEvent} instance
|
* @return the {@link RepoEvent} instance
|
||||||
*/
|
*/
|
||||||
public RepoEvent<DataAttributes<RES>> getRepoEvent(EventInfo eventInfo)
|
public RepoEvent<DataAttributes<RES>> getRepoEvent(EventInfo eventInfo)
|
||||||
|
{
|
||||||
|
final RepoEvent.Builder<DataAttributes<RES>> builder = RepoEvent.builder();
|
||||||
|
|
||||||
|
configureRepoEventBuilder(builder, eventInfo);
|
||||||
|
|
||||||
|
return builder.build();
|
||||||
|
}
|
||||||
|
|
||||||
|
protected void configureRepoEventBuilder(RepoEvent.Builder<DataAttributes<RES>> builder, EventInfo eventInfo)
|
||||||
{
|
{
|
||||||
EventType eventType = getDerivedEvent();
|
EventType eventType = getDerivedEvent();
|
||||||
|
|
||||||
DataAttributes<RES> eventData = buildEventData(eventInfo, resource, eventType);
|
DataAttributes<RES> eventData = buildEventData(eventInfo, resource, eventType);
|
||||||
|
|
||||||
return RepoEvent.<DataAttributes<RES>>builder()
|
builder.setId(eventInfo.getId())
|
||||||
.setId(eventInfo.getId())
|
|
||||||
.setSource(eventInfo.getSource())
|
.setSource(eventInfo.getSource())
|
||||||
.setTime(eventInfo.getTimestamp())
|
.setTime(eventInfo.getTimestamp())
|
||||||
.setType(eventType.getType())
|
.setType(eventType.getType())
|
||||||
.setData(eventData)
|
.setData(eventData)
|
||||||
.setDataschema(EventJSONSchema.getSchemaV1(eventType))
|
.setDataschema(EventJSONSchema.getSchemaV1(eventType));
|
||||||
.build();
|
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
@@ -2,7 +2,7 @@
|
|||||||
* #%L
|
* #%L
|
||||||
* Alfresco Repository
|
* Alfresco Repository
|
||||||
* %%
|
* %%
|
||||||
* Copyright (C) 2005 - 2016 Alfresco Software Limited
|
* Copyright (C) 2005 - 2025 Alfresco Software Limited
|
||||||
* %%
|
* %%
|
||||||
* This file is part of the Alfresco software.
|
* This file is part of the Alfresco software.
|
||||||
* If the software was purchased under a paid Alfresco license, the terms of
|
* If the software was purchased under a paid Alfresco license, the terms of
|
||||||
@@ -125,6 +125,9 @@ public class RhinoScriptProcessor extends BaseProcessor implements ScriptProcess
|
|||||||
/** Number of (bytecode) instructions that will trigger the observer */
|
/** Number of (bytecode) instructions that will trigger the observer */
|
||||||
private int observerInstructionCount = 100;
|
private int observerInstructionCount = 100;
|
||||||
|
|
||||||
|
/** Flag to enable or disable scope cleaning at the end of each script execution */
|
||||||
|
private boolean cleanScope = true;
|
||||||
|
|
||||||
/** Custom context factory */
|
/** Custom context factory */
|
||||||
public static AlfrescoContextFactory contextFactory;
|
public static AlfrescoContextFactory contextFactory;
|
||||||
|
|
||||||
@@ -208,6 +211,15 @@ public class RhinoScriptProcessor extends BaseProcessor implements ScriptProcess
|
|||||||
this.observerInstructionCount = observerInstructionCount;
|
this.observerInstructionCount = observerInstructionCount;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @param cleanScope
|
||||||
|
* true to enable scope cleaning at the end of each script execution - set to false to disable this feature.
|
||||||
|
*/
|
||||||
|
public void setCleanScope(boolean cleanScope)
|
||||||
|
{
|
||||||
|
this.cleanScope = cleanScope;
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @see org.alfresco.service.cmr.repository.ScriptProcessor#reset()
|
* @see org.alfresco.service.cmr.repository.ScriptProcessor#reset()
|
||||||
*/
|
*/
|
||||||
@@ -614,7 +626,7 @@ public class RhinoScriptProcessor extends BaseProcessor implements ScriptProcess
|
|||||||
}
|
}
|
||||||
finally
|
finally
|
||||||
{
|
{
|
||||||
if (!secure)
|
if (!secure && cleanScope)
|
||||||
{
|
{
|
||||||
unsetScope(model, scope);
|
unsetScope(model, scope);
|
||||||
}
|
}
|
||||||
|
@@ -2,7 +2,7 @@
|
|||||||
* #%L
|
* #%L
|
||||||
* Alfresco Repository
|
* Alfresco Repository
|
||||||
* %%
|
* %%
|
||||||
* Copyright (C) 2005 - 2016 Alfresco Software Limited
|
* Copyright (C) 2005 - 2025 Alfresco Software Limited
|
||||||
* %%
|
* %%
|
||||||
* This file is part of the Alfresco software.
|
* This file is part of the Alfresco software.
|
||||||
* If the software was purchased under a paid Alfresco license, the terms of
|
* If the software was purchased under a paid Alfresco license, the terms of
|
||||||
@@ -28,8 +28,10 @@ package org.alfresco.repo.node.getchildren;
|
|||||||
import java.util.List;
|
import java.util.List;
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
|
||||||
import org.alfresco.repo.domain.node.NodeEntity;
|
import org.alfresco.repo.domain.node.AuditablePropertiesEntity;
|
||||||
import org.alfresco.repo.domain.node.NodePropertyEntity;
|
import org.alfresco.repo.domain.node.NodePropertyEntity;
|
||||||
|
import org.alfresco.service.cmr.repository.NodeRef;
|
||||||
|
import org.alfresco.service.cmr.repository.StoreRef;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Filterable/Sortable Node Entity
|
* Filterable/Sortable Node Entity
|
||||||
@@ -42,12 +44,17 @@ import org.alfresco.repo.domain.node.NodePropertyEntity;
|
|||||||
public class FilterSortNodeEntity
|
public class FilterSortNodeEntity
|
||||||
{
|
{
|
||||||
private Long id; // node id
|
private Long id; // node id
|
||||||
|
private String nodeUuid;
|
||||||
|
private Long typeQNameId;
|
||||||
|
|
||||||
private NodeEntity node;
|
private AuditablePropertiesEntity auditablePropertiesEntity;
|
||||||
private NodePropertyEntity prop1;
|
private NodePropertyEntity prop1;
|
||||||
private NodePropertyEntity prop2;
|
private NodePropertyEntity prop2;
|
||||||
private NodePropertyEntity prop3;
|
private NodePropertyEntity prop3;
|
||||||
|
|
||||||
|
private String storeProtocol;
|
||||||
|
private String storeIdentifier;
|
||||||
|
|
||||||
// Supplemental query-related parameters
|
// Supplemental query-related parameters
|
||||||
private Long parentNodeId;
|
private Long parentNodeId;
|
||||||
private Long prop1qnameId;
|
private Long prop1qnameId;
|
||||||
@@ -80,6 +87,26 @@ public class FilterSortNodeEntity
|
|||||||
this.id = id;
|
this.id = id;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public String getNodeUuid()
|
||||||
|
{
|
||||||
|
return nodeUuid;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setNodeUuid(String nodeUuid)
|
||||||
|
{
|
||||||
|
this.nodeUuid = nodeUuid;
|
||||||
|
}
|
||||||
|
|
||||||
|
public Long getTypeQNameId()
|
||||||
|
{
|
||||||
|
return typeQNameId;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setTypeQNameId(Long typeQNameId)
|
||||||
|
{
|
||||||
|
this.typeQNameId = typeQNameId;
|
||||||
|
}
|
||||||
|
|
||||||
public String getPattern()
|
public String getPattern()
|
||||||
{
|
{
|
||||||
return pattern;
|
return pattern;
|
||||||
@@ -100,8 +127,7 @@ public class FilterSortNodeEntity
|
|||||||
sb.append(escapeChar);
|
sb.append(escapeChar);
|
||||||
offset = idx + 1;
|
offset = idx + 1;
|
||||||
}
|
}
|
||||||
}
|
} while (idx != -1);
|
||||||
while(idx != -1);
|
|
||||||
sb.append(s.substring(offset));
|
sb.append(s.substring(offset));
|
||||||
return sb.toString();
|
return sb.toString();
|
||||||
}
|
}
|
||||||
@@ -137,6 +163,16 @@ public class FilterSortNodeEntity
|
|||||||
this.namePropertyQNameId = namePropertyQNameId;
|
this.namePropertyQNameId = namePropertyQNameId;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public AuditablePropertiesEntity getAuditablePropertiesEntity()
|
||||||
|
{
|
||||||
|
return auditablePropertiesEntity;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setAuditablePropertiesEntity(AuditablePropertiesEntity auditablePropertiesEntity)
|
||||||
|
{
|
||||||
|
this.auditablePropertiesEntity = auditablePropertiesEntity;
|
||||||
|
}
|
||||||
|
|
||||||
public NodePropertyEntity getProp1()
|
public NodePropertyEntity getProp1()
|
||||||
{
|
{
|
||||||
return prop1;
|
return prop1;
|
||||||
@@ -167,14 +203,24 @@ public class FilterSortNodeEntity
|
|||||||
this.prop3 = prop3;
|
this.prop3 = prop3;
|
||||||
}
|
}
|
||||||
|
|
||||||
public NodeEntity getNode()
|
public String getStoreProtocol()
|
||||||
{
|
{
|
||||||
return node;
|
return storeProtocol;
|
||||||
}
|
}
|
||||||
|
|
||||||
public void setNode(NodeEntity childNode)
|
public void setStoreProtocol(String storeProtocol)
|
||||||
{
|
{
|
||||||
this.node = childNode;
|
this.storeProtocol = storeProtocol;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getStoreIdentifier()
|
||||||
|
{
|
||||||
|
return storeIdentifier;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setStoreIdentifier(String storeIdentifier)
|
||||||
|
{
|
||||||
|
this.storeIdentifier = storeIdentifier;
|
||||||
}
|
}
|
||||||
|
|
||||||
// Supplemental query-related parameters
|
// Supplemental query-related parameters
|
||||||
@@ -258,4 +304,9 @@ public class FilterSortNodeEntity
|
|||||||
{
|
{
|
||||||
this.isPrimary = isPrimary;
|
this.isPrimary = isPrimary;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public NodeRef createNodeRef()
|
||||||
|
{
|
||||||
|
return new NodeRef(new StoreRef(storeProtocol, storeIdentifier), nodeUuid);
|
||||||
|
}
|
||||||
}
|
}
|
@@ -2,7 +2,7 @@
|
|||||||
* #%L
|
* #%L
|
||||||
* Alfresco Repository
|
* Alfresco Repository
|
||||||
* %%
|
* %%
|
||||||
* Copyright (C) 2005 - 2016 Alfresco Software Limited
|
* Copyright (C) 2005 - 2025 Alfresco Software Limited
|
||||||
* %%
|
* %%
|
||||||
* This file is part of the Alfresco software.
|
* This file is part of the Alfresco software.
|
||||||
* If the software was purchased under a paid Alfresco license, the terms of
|
* If the software was purchased under a paid Alfresco license, the terms of
|
||||||
@@ -38,13 +38,16 @@ import java.util.List;
|
|||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
import java.util.Set;
|
import java.util.Set;
|
||||||
|
|
||||||
|
import org.apache.commons.logging.Log;
|
||||||
|
import org.apache.commons.logging.LogFactory;
|
||||||
|
import org.springframework.extensions.surf.util.I18NUtil;
|
||||||
|
|
||||||
import org.alfresco.error.AlfrescoRuntimeException;
|
import org.alfresco.error.AlfrescoRuntimeException;
|
||||||
import org.alfresco.model.ContentModel;
|
import org.alfresco.model.ContentModel;
|
||||||
import org.alfresco.query.CannedQueryParameters;
|
import org.alfresco.query.CannedQueryParameters;
|
||||||
import org.alfresco.query.CannedQuerySortDetails;
|
import org.alfresco.query.CannedQuerySortDetails;
|
||||||
import org.alfresco.query.CannedQuerySortDetails.SortOrder;
|
import org.alfresco.query.CannedQuerySortDetails.SortOrder;
|
||||||
import org.alfresco.repo.domain.node.AuditablePropertiesEntity;
|
import org.alfresco.repo.domain.node.AuditablePropertiesEntity;
|
||||||
import org.alfresco.repo.domain.node.Node;
|
|
||||||
import org.alfresco.repo.domain.node.NodeDAO;
|
import org.alfresco.repo.domain.node.NodeDAO;
|
||||||
import org.alfresco.repo.domain.node.NodeEntity;
|
import org.alfresco.repo.domain.node.NodeEntity;
|
||||||
import org.alfresco.repo.domain.node.NodePropertyEntity;
|
import org.alfresco.repo.domain.node.NodePropertyEntity;
|
||||||
@@ -69,15 +72,11 @@ import org.alfresco.service.namespace.QName;
|
|||||||
import org.alfresco.util.AlfrescoCollator;
|
import org.alfresco.util.AlfrescoCollator;
|
||||||
import org.alfresco.util.Pair;
|
import org.alfresco.util.Pair;
|
||||||
import org.alfresco.util.ParameterCheck;
|
import org.alfresco.util.ParameterCheck;
|
||||||
import org.apache.commons.logging.Log;
|
|
||||||
import org.apache.commons.logging.LogFactory;
|
|
||||||
import org.springframework.extensions.surf.util.I18NUtil;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* GetChildren canned query
|
* GetChildren canned query
|
||||||
*
|
*
|
||||||
* To get paged list of children of a parent node filtered by child type.
|
* To get paged list of children of a parent node filtered by child type. Also optionally filtered and/or sorted by one or more properties (up to three).
|
||||||
* Also optionally filtered and/or sorted by one or more properties (up to three).
|
|
||||||
*
|
*
|
||||||
* @author janv
|
* @author janv
|
||||||
* @since 4.0
|
* @since 4.0
|
||||||
@@ -100,7 +99,6 @@ public class GetChildrenCannedQuery extends AbstractCannedQueryPermissions<NodeR
|
|||||||
|
|
||||||
public static final QName FILTER_QNAME_NODE_IS_PRIMARY = QName.createQName("", "IS_PRIMARY");
|
public static final QName FILTER_QNAME_NODE_IS_PRIMARY = QName.createQName("", "IS_PRIMARY");
|
||||||
|
|
||||||
|
|
||||||
private NodeDAO nodeDAO;
|
private NodeDAO nodeDAO;
|
||||||
private QNameDAO qnameDAO;
|
private QNameDAO qnameDAO;
|
||||||
private CannedQueryDAO cannedQueryDAO;
|
private CannedQueryDAO cannedQueryDAO;
|
||||||
@@ -246,7 +244,6 @@ public class GetChildrenCannedQuery extends AbstractCannedQueryPermissions<NodeR
|
|||||||
|
|
||||||
filterSortPropCnt = setFilterSortParams(sortFilterProps, params);
|
filterSortPropCnt = setFilterSortParams(sortFilterProps, params);
|
||||||
|
|
||||||
|
|
||||||
List<NodeRef> result = new ArrayList<>(0);
|
List<NodeRef> result = new ArrayList<>(0);
|
||||||
|
|
||||||
try
|
try
|
||||||
@@ -777,7 +774,8 @@ public class GetChildrenCannedQuery extends AbstractCannedQueryPermissions<NodeR
|
|||||||
if (results.size() >= BATCH_SIZE)
|
if (results.size() >= BATCH_SIZE)
|
||||||
{
|
{
|
||||||
// batch
|
// batch
|
||||||
preloadFilterSort();
|
preloadNodes();
|
||||||
|
filterSort();
|
||||||
}
|
}
|
||||||
|
|
||||||
results.add(result);
|
results.add(result);
|
||||||
@@ -790,24 +788,27 @@ public class GetChildrenCannedQuery extends AbstractCannedQueryPermissions<NodeR
|
|||||||
if (results.size() >= 0)
|
if (results.size() >= 0)
|
||||||
{
|
{
|
||||||
// finish batch
|
// finish batch
|
||||||
preloadFilterSort();
|
preloadNodes();
|
||||||
|
filterSort();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
private void preloadFilterSort()
|
private void preloadNodes()
|
||||||
{
|
{
|
||||||
List<NodeRef> nodeRefs = new ArrayList<>(results.size());
|
List<NodeRef> nodeRefs = new ArrayList<>(results.size());
|
||||||
for (FilterSortNodeEntity result : results)
|
for (FilterSortNodeEntity result : results)
|
||||||
{
|
{
|
||||||
nodeRefs.add(result.getNode().getNodeRef());
|
nodeRefs.add(result.createNodeRef());
|
||||||
}
|
}
|
||||||
|
|
||||||
preload(nodeRefs);
|
preload(nodeRefs);
|
||||||
|
}
|
||||||
|
|
||||||
|
private void filterSort()
|
||||||
|
{
|
||||||
for (FilterSortNodeEntity result : results)
|
for (FilterSortNodeEntity result : results)
|
||||||
{
|
{
|
||||||
Node node = result.getNode();
|
NodeRef nodeRef = result.createNodeRef();
|
||||||
NodeRef nodeRef = node.getNodeRef();
|
|
||||||
|
|
||||||
Map<NodePropertyKey, NodePropertyValue> propertyValues = new HashMap<NodePropertyKey, NodePropertyValue>(3);
|
Map<NodePropertyKey, NodePropertyValue> propertyValues = new HashMap<NodePropertyKey, NodePropertyValue>(3);
|
||||||
|
|
||||||
@@ -832,7 +833,7 @@ public class GetChildrenCannedQuery extends AbstractCannedQueryPermissions<NodeR
|
|||||||
Map<QName, Serializable> propVals = nodePropertyHelper.convertToPublicProperties(propertyValues);
|
Map<QName, Serializable> propVals = nodePropertyHelper.convertToPublicProperties(propertyValues);
|
||||||
|
|
||||||
// Add referenceable / spoofed properties (including spoofed name if null)
|
// Add referenceable / spoofed properties (including spoofed name if null)
|
||||||
ReferenceablePropertiesEntity.addReferenceableProperties(node, propVals);
|
ReferenceablePropertiesEntity.addReferenceableProperties(result.getId(), nodeRef, propVals);
|
||||||
|
|
||||||
// special cases
|
// special cases
|
||||||
|
|
||||||
@@ -854,7 +855,7 @@ public class GetChildrenCannedQuery extends AbstractCannedQueryPermissions<NodeR
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Auditable props (eg. cm:creator, cm:created, cm:modifier, cm:modified, ...)
|
// Auditable props (eg. cm:creator, cm:created, cm:modifier, cm:modified, ...)
|
||||||
AuditablePropertiesEntity auditableProps = node.getAuditableProperties();
|
AuditablePropertiesEntity auditableProps = result.getAuditablePropertiesEntity();
|
||||||
if (auditableProps != null)
|
if (auditableProps != null)
|
||||||
{
|
{
|
||||||
for (Map.Entry<QName, Serializable> entry : auditableProps.getAuditableProperties().entrySet())
|
for (Map.Entry<QName, Serializable> entry : auditableProps.getAuditableProperties().entrySet())
|
||||||
@@ -864,7 +865,7 @@ public class GetChildrenCannedQuery extends AbstractCannedQueryPermissions<NodeR
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Node type
|
// Node type
|
||||||
Long nodeTypeQNameId = node.getTypeQNameId();
|
Long nodeTypeQNameId = result.getTypeQNameId();
|
||||||
if (nodeTypeQNameId != null)
|
if (nodeTypeQNameId != null)
|
||||||
{
|
{
|
||||||
Pair<Long, QName> pair = qnameDAO.getQName(nodeTypeQNameId);
|
Pair<Long, QName> pair = qnameDAO.getQName(nodeTypeQNameId);
|
||||||
|
@@ -133,6 +133,14 @@
|
|||||||
<resultMap id="result_FilterSortNode" type="FilterSortNode">
|
<resultMap id="result_FilterSortNode" type="FilterSortNode">
|
||||||
|
|
||||||
<id property="id" column="id" jdbcType="BIGINT" javaType="java.lang.Long"/>
|
<id property="id" column="id" jdbcType="BIGINT" javaType="java.lang.Long"/>
|
||||||
|
<result property="nodeUuid" column="uuid" jdbcType="VARCHAR" javaType="java.lang.String"/>
|
||||||
|
<result property="typeQNameId" column="type_qname_id" jdbcType="BIGINT" javaType="java.lang.Long"/>
|
||||||
|
|
||||||
|
<result property="auditablePropertiesEntity.auditCreator" column="audit_creator" jdbcType="VARCHAR" javaType="java.lang.String"/>
|
||||||
|
<result property="auditablePropertiesEntity.auditCreated" column="audit_created" jdbcType="VARCHAR" javaType="java.lang.String"/>
|
||||||
|
<result property="auditablePropertiesEntity.auditModifier" column="audit_modifier" jdbcType="VARCHAR" javaType="java.lang.String"/>
|
||||||
|
<result property="auditablePropertiesEntity.auditModified" column="audit_modified" jdbcType="VARCHAR" javaType="java.lang.String"/>
|
||||||
|
<result property="auditablePropertiesEntity.auditAccessed" column="audit_accessed" jdbcType="VARCHAR" javaType="java.lang.String"/>
|
||||||
|
|
||||||
<result property="prop1.nodeId" column="prop1_node_id" jdbcType="BIGINT" javaType="java.lang.Long"/>
|
<result property="prop1.nodeId" column="prop1_node_id" jdbcType="BIGINT" javaType="java.lang.Long"/>
|
||||||
<result property="prop1.key.qnameId" column="prop1_qname_id" jdbcType="BIGINT" javaType="java.lang.Long"/>
|
<result property="prop1.key.qnameId" column="prop1_qname_id" jdbcType="BIGINT" javaType="java.lang.Long"/>
|
||||||
@@ -170,7 +178,8 @@
|
|||||||
<result property="prop3.value.doubleValue" column="prop3_double_value" jdbcType="FLOAT" javaType="java.lang.Double"/>
|
<result property="prop3.value.doubleValue" column="prop3_double_value" jdbcType="FLOAT" javaType="java.lang.Double"/>
|
||||||
<result property="prop3.value.stringValue" column="prop3_string_value" jdbcType="VARCHAR" javaType="java.lang.String"/>
|
<result property="prop3.value.stringValue" column="prop3_string_value" jdbcType="VARCHAR" javaType="java.lang.String"/>
|
||||||
|
|
||||||
<association property="node" resultMap="alfresco.node.result_Node"/>
|
<result property="storeProtocol" column="protocol" jdbcType="VARCHAR" javaType="java.lang.String"/>
|
||||||
|
<result property="storeIdentifier" column="identifier" jdbcType="VARCHAR" javaType="java.lang.String"/>
|
||||||
|
|
||||||
</resultMap>
|
</resultMap>
|
||||||
|
|
||||||
@@ -782,25 +791,6 @@
|
|||||||
<if test="ordered == true">order by node.id ASC</if>
|
<if test="ordered == true">order by node.id ASC</if>
|
||||||
</select>
|
</select>
|
||||||
|
|
||||||
<select id="select_NodesWithAspectIds_Limited" parameterType="Ids" resultMap="result_NodeRef" >
|
|
||||||
select
|
|
||||||
node.id as id,
|
|
||||||
store.protocol as protocol,
|
|
||||||
store.identifier as identifier,
|
|
||||||
node.uuid as uuid
|
|
||||||
from
|
|
||||||
alf_node_aspects na
|
|
||||||
join alf_node node on (na.node_id = node.id)
|
|
||||||
left join alf_store store on (store.id = node.store_id)
|
|
||||||
where
|
|
||||||
<![CDATA[na.node_id >= #{idOne}]]>
|
|
||||||
<if test="idTwo != null"><![CDATA[and na.node_id < #{idTwo}]]></if>
|
|
||||||
and na.qname_id in
|
|
||||||
<foreach item="item" index="i" collection="ids" open="(" separator="," close=")">#{item}</foreach>
|
|
||||||
<if test="ordered == true">order by node.id ASC</if>
|
|
||||||
<if test="maxResults != null"><![CDATA[limit #{maxResults}]]></if>
|
|
||||||
</select>
|
|
||||||
|
|
||||||
<!-- Common results for result_NodeAssoc -->
|
<!-- Common results for result_NodeAssoc -->
|
||||||
<sql id="select_NodeAssoc_Results">
|
<sql id="select_NodeAssoc_Results">
|
||||||
select
|
select
|
||||||
@@ -991,8 +981,8 @@
|
|||||||
</select>
|
</select>
|
||||||
|
|
||||||
<!-- GetChildren - with explicit prop filtering and/or sorting -->
|
<!-- GetChildren - with explicit prop filtering and/or sorting -->
|
||||||
<select id="select_GetChildrenCannedQueryWithProps" parameterType="FilterSortNode" resultMap="result_FilterSortNode">
|
<select id="select_GetChildrenCannedQueryWithProps" parameterType="FilterSortNode" resultMap="result_FilterSortNode" flushCache="true">
|
||||||
select
|
select distinct
|
||||||
childNode.id as id,
|
childNode.id as id,
|
||||||
childNode.version as version,
|
childNode.version as version,
|
||||||
childStore.id as store_id,
|
childStore.id as store_id,
|
||||||
@@ -1086,9 +1076,6 @@
|
|||||||
#{item}
|
#{item}
|
||||||
</foreach>
|
</foreach>
|
||||||
</if>
|
</if>
|
||||||
<if test="prop1qnameId == null and auditableProps == false">
|
|
||||||
<include refid="alfresco.node.select_ChildAssoc_OrderBy"/>
|
|
||||||
</if>
|
|
||||||
</select>
|
</select>
|
||||||
|
|
||||||
<!-- GetChildren - with no explicit sorting (or prop filtering) - note: still filtered by child type (and optionally primary or secondary) -->
|
<!-- GetChildren - with no explicit sorting (or prop filtering) - note: still filtered by child type (and optionally primary or secondary) -->
|
||||||
|
@@ -30,4 +30,23 @@
|
|||||||
<![CDATA[and commit_time_ms <= #{maxCommitTime}]]>
|
<![CDATA[and commit_time_ms <= #{maxCommitTime}]]>
|
||||||
</select>
|
</select>
|
||||||
|
|
||||||
|
<select id="select_NodesWithAspectIds_Limited" parameterType="Ids" resultMap="alfresco.node.result_NodeRef" >
|
||||||
|
select
|
||||||
|
node.id as id,
|
||||||
|
store.protocol as protocol,
|
||||||
|
store.identifier as identifier,
|
||||||
|
node.uuid as uuid
|
||||||
|
from
|
||||||
|
alf_node_aspects na
|
||||||
|
join alf_node node on (na.node_id = node.id)
|
||||||
|
left join alf_store store on (store.id = node.store_id)
|
||||||
|
where
|
||||||
|
<![CDATA[na.node_id >= #{idOne}]]>
|
||||||
|
<if test="idTwo != null"><![CDATA[and na.node_id < #{idTwo}]]></if>
|
||||||
|
and na.qname_id in
|
||||||
|
<foreach item="item" index="i" collection="ids" open="(" separator="," close=")">#{item}</foreach>
|
||||||
|
<if test="ordered == true">order by node.id ASC</if>
|
||||||
|
<if test="maxResults != null"><![CDATA[limit #{maxResults}]]></if>
|
||||||
|
</select>
|
||||||
|
|
||||||
</mapper>
|
</mapper>
|
@@ -30,4 +30,23 @@
|
|||||||
<![CDATA[and commit_time_ms <= #{maxCommitTime}]]>
|
<![CDATA[and commit_time_ms <= #{maxCommitTime}]]>
|
||||||
</select>
|
</select>
|
||||||
|
|
||||||
|
<select id="select_NodesWithAspectIds_Limited" parameterType="Ids" resultMap="alfresco.node.result_NodeRef" >
|
||||||
|
select
|
||||||
|
node.id as id,
|
||||||
|
store.protocol as protocol,
|
||||||
|
store.identifier as identifier,
|
||||||
|
node.uuid as uuid
|
||||||
|
from
|
||||||
|
alf_node_aspects na
|
||||||
|
join alf_node node on (na.node_id = node.id)
|
||||||
|
left join alf_store store on (store.id = node.store_id)
|
||||||
|
where
|
||||||
|
<![CDATA[na.node_id >= #{idOne}]]>
|
||||||
|
<if test="idTwo != null"><![CDATA[and na.node_id < #{idTwo}]]></if>
|
||||||
|
and na.qname_id in
|
||||||
|
<foreach item="item" index="i" collection="ids" open="(" separator="," close=")">#{item}</foreach>
|
||||||
|
<if test="ordered == true">order by node.id ASC</if>
|
||||||
|
<if test="maxResults != null"><![CDATA[limit #{maxResults}]]></if>
|
||||||
|
</select>
|
||||||
|
|
||||||
</mapper>
|
</mapper>
|
@@ -1394,6 +1394,9 @@ scripts.execution.maxMemoryUsedInBytes=-1
|
|||||||
# Number of instructions that will trigger the observer
|
# Number of instructions that will trigger the observer
|
||||||
scripts.execution.observerInstructionCount=5000
|
scripts.execution.observerInstructionCount=5000
|
||||||
|
|
||||||
|
# Flag to control if the scope is cleaned at the end of script execution
|
||||||
|
scripts.execution.clean.scope=true
|
||||||
|
|
||||||
# Default value being used in POST/size-details endpoint to partition a huge folder into smaller chunks
|
# Default value being used in POST/size-details endpoint to partition a huge folder into smaller chunks
|
||||||
# so that we can compute more efficiently and consolidate all sizes into a single unit.
|
# so that we can compute more efficiently and consolidate all sizes into a single unit.
|
||||||
default.async.folder.items=1000
|
default.async.folder.items=1000
|
||||||
|
@@ -60,6 +60,9 @@
|
|||||||
<property name="observerInstructionCount">
|
<property name="observerInstructionCount">
|
||||||
<value>${scripts.execution.observerInstructionCount}</value>
|
<value>${scripts.execution.observerInstructionCount}</value>
|
||||||
</property>
|
</property>
|
||||||
|
<property name="cleanScope">
|
||||||
|
<value>${scripts.execution.clean.scope}</value>
|
||||||
|
</property>
|
||||||
</bean>
|
</bean>
|
||||||
|
|
||||||
<!-- base config implementation that script extension beans extend from - for auto registration
|
<!-- base config implementation that script extension beans extend from - for auto registration
|
||||||
|
Reference in New Issue
Block a user