- Added update and inboundAndUpdate as example rule types that can be commented in.

- Added parameter to content update policy to indicate whether it is new content being updated
- Added triigers to support update rule type

git-svn-id: https://svn.alfresco.com/repos/alfresco-enterprise/alfresco/HEAD/root@2275 c4b6b30b-aa2e-2d43-bbcb-ca4b014f7261
This commit is contained in:
Roy Wetherall
2006-02-01 14:26:17 +00:00
parent b8bad79ca5
commit 2bdace676d
12 changed files with 322 additions and 25 deletions

View File

@@ -2,3 +2,5 @@
inbound.display-label=Inbound inbound.display-label=Inbound
outbound.display-label=Outbound outbound.display-label=Outbound
update.display-label=Update
inboundAndUpdate.display-label=Inbound and Update

View File

@@ -66,11 +66,43 @@
<list> <list>
<ref bean="on-create-node-trigger"/> <ref bean="on-create-node-trigger"/>
<ref bean="on-create-child-association-trigger"/> <ref bean="on-create-child-association-trigger"/>
<ref bean="on-content-create-trigger"/>
<!-- NOTE: if you do not want hte inbound rule to rile on content update -->
<!-- remove the following line -->
<ref bean="on-content-update-trigger"/> <ref bean="on-content-update-trigger"/>
</list> </list>
</constructor-arg> </constructor-arg>
</bean> </bean>
<!-- NOTE: Adding the following will provide an update policy. This will cause -->
<!-- rules to be fired on content or meta-data update. -->
<!-- WARNING: This is at present working but not fully QA'ed. -->
<!--
<bean id="update" class="org.alfresco.repo.rule.RuleTypeImpl" parent="rule-type-base">
<constructor-arg>
<list>
<ref bean="on-property-update-trigger"/>
</list>
</constructor-arg>
</bean>
-->
<!-- NOTE: Multiple rule types are not currently support so if you require inbound and update -->
<!-- behaviour then add the following rule type -->
<!--
<bean id="inboundAndUpdate" class="org.alfresco.repo.rule.RuleTypeImpl" parent="rule-type-base">
<constructor-arg>
<list>
<ref bean="on-create-node-trigger"/>
<ref bean="on-create-child-association-trigger"/>
<ref bean="on-content-create-trigger"/>
<ref bean="on-update-node-trigger"/>
<ref bean="on-content-update-trigger"/>
</list>
</constructor-arg>
</bean>
-->
<bean id="outbound" class="org.alfresco.repo.rule.RuleTypeImpl" parent="rule-type-base"> <bean id="outbound" class="org.alfresco.repo.rule.RuleTypeImpl" parent="rule-type-base">
<constructor-arg> <constructor-arg>
<list> <list>
@@ -111,6 +143,9 @@
</property> </property>
</bean> </bean>
<bean id="on-property-update-trigger" class="org.alfresco.repo.rule.ruletrigger.OnPropertyUpdateRuleTrigger" parent="rule-trigger-base">
</bean>
<bean id="on-delete-node-trigger" class="org.alfresco.repo.rule.ruletrigger.SingleChildAssocRefPolicyRuleTrigger" parent="rule-trigger-base"> <bean id="on-delete-node-trigger" class="org.alfresco.repo.rule.ruletrigger.SingleChildAssocRefPolicyRuleTrigger" parent="rule-trigger-base">
<property name="policyName"> <property name="policyName">
<value>onDeleteNode</value> <value>onDeleteNode</value>
@@ -144,9 +179,15 @@
</property> </property>
</bean> </bean>
<bean id="on-content-update-trigger" class="org.alfresco.repo.rule.ruletrigger.SingleNodeRefPolicyRuleTrigger" parent="rule-trigger-base"> <bean id="on-content-update-trigger" class="org.alfresco.repo.rule.ruletrigger.OnContentUpdateRuleTrigger" parent="rule-trigger-base">
<property name="policyName"> <property name="onNewContent">
<value>onContentUpdate</value> <value>false</value>
</property>
</bean>
<bean id="on-content-create-trigger" class="org.alfresco.repo.rule.ruletrigger.OnContentUpdateRuleTrigger" parent="rule-trigger-base">
<property name="onNewContent">
<value>true</value>
</property> </property>
</bean> </bean>

View File

@@ -18,6 +18,8 @@ package org.alfresco.repo.content;
import org.alfresco.repo.policy.ClassPolicy; import org.alfresco.repo.policy.ClassPolicy;
import org.alfresco.service.cmr.repository.NodeRef; import org.alfresco.service.cmr.repository.NodeRef;
import org.alfresco.service.namespace.NamespaceService;
import org.alfresco.service.namespace.QName;
/** /**
* Content service policies interface * Content service policies interface
@@ -26,6 +28,9 @@ import org.alfresco.service.cmr.repository.NodeRef;
*/ */
public interface ContentServicePolicies public interface ContentServicePolicies
{ {
/** The QName's of the policies */
public static final QName ON_CONTENT_UPDATE = QName.createQName(NamespaceService.ALFRESCO_URI, "onContentUpdate");
/** /**
* On content update policy interface * On content update policy interface
*/ */
@@ -34,6 +39,6 @@ public interface ContentServicePolicies
/** /**
* @param nodeRef the node reference * @param nodeRef the node reference
*/ */
public void onContentUpdate(NodeRef nodeRef); public void onContentUpdate(NodeRef nodeRef, boolean newContent);
} }
} }

View File

@@ -147,6 +147,7 @@ public class RoutingContentService implements ContentService
Map<QName, Serializable> after) Map<QName, Serializable> after)
{ {
boolean fire = false; boolean fire = false;
boolean newContent = false;
// check if any of the content properties have changed // check if any of the content properties have changed
for (QName propertyQName : after.keySet()) for (QName propertyQName : after.keySet())
{ {
@@ -173,6 +174,38 @@ public class RoutingContentService implements ContentService
} }
else if (!EqualsHelper.nullSafeEquals(beforeValue, afterValue)) else if (!EqualsHelper.nullSafeEquals(beforeValue, afterValue))
{ {
// So debug ...
if (logger.isDebugEnabled() == true)
{
String beforeString = "";
if (beforeValue != null)
{
beforeString = beforeValue.toString();
}
String afterString = "";
if (afterValue != null)
{
afterString = afterValue.toString();
}
logger.debug("onContentUpate: before = " + beforeString + "; after = " + afterString);
}
// Figure out if the content is new or not
String beforeContentUrl = null;
if (beforeValue != null)
{
beforeContentUrl = beforeValue.getContentUrl();
}
String afterContentUrl = null;
if (afterValue != null)
{
afterContentUrl = afterValue.getContentUrl();
}
if (beforeContentUrl == null && afterContentUrl != null)
{
newContent = true;
}
// the content changed // the content changed
// at the moment, we are only interested in this one change // at the moment, we are only interested in this one change
fire = true; fire = true;
@@ -192,7 +225,7 @@ public class RoutingContentService implements ContentService
Set<QName> types = new HashSet<QName>(this.nodeService.getAspects(nodeRef)); Set<QName> types = new HashSet<QName>(this.nodeService.getAspects(nodeRef));
types.add(this.nodeService.getType(nodeRef)); types.add(this.nodeService.getType(nodeRef));
OnContentUpdatePolicy policy = this.onContentUpdateDelegate.get(types); OnContentUpdatePolicy policy = this.onContentUpdateDelegate.get(types);
policy.onContentUpdate(nodeRef); policy.onContentUpdate(nodeRef, newContent);
} }
} }

View File

@@ -257,6 +257,7 @@ public class RoutingContentServiceTest extends BaseSpringTest
} }
private boolean policyFired = false; private boolean policyFired = false;
private boolean newContent = true;
/** /**
* Tests that the content update policy firs correctly * Tests that the content update policy firs correctly
@@ -274,6 +275,8 @@ public class RoutingContentServiceTest extends BaseSpringTest
contentWriter.putContent("content update one"); contentWriter.putContent("content update one");
assertFalse(this.policyFired); assertFalse(this.policyFired);
this.newContent = false;
// Now check that the policy is fired when the versionable aspect is present // Now check that the policy is fired when the versionable aspect is present
this.nodeService.addAspect(this.contentNodeRef, ContentModel.ASPECT_VERSIONABLE, null); this.nodeService.addAspect(this.contentNodeRef, ContentModel.ASPECT_VERSIONABLE, null);
ContentWriter contentWriter2 = this.contentService.getWriter(contentNodeRef, ContentModel.PROP_CONTENT, true); ContentWriter contentWriter2 = this.contentService.getWriter(contentNodeRef, ContentModel.PROP_CONTENT, true);
@@ -287,9 +290,10 @@ public class RoutingContentServiceTest extends BaseSpringTest
assertFalse(this.policyFired); assertFalse(this.policyFired);
} }
public void onContentUpdateBehaviourTest(NodeRef nodeRef) public void onContentUpdateBehaviourTest(NodeRef nodeRef, boolean newContent)
{ {
assertEquals(this.contentNodeRef, nodeRef); assertEquals(this.contentNodeRef, nodeRef);
assertEquals(this.newContent, newContent);
assertTrue(this.nodeService.hasAspect(nodeRef, ContentModel.ASPECT_VERSIONABLE)); assertTrue(this.nodeService.hasAspect(nodeRef, ContentModel.ASPECT_VERSIONABLE));
this.policyFired = true; this.policyFired = true;
} }

View File

@@ -22,6 +22,8 @@ import java.util.Map;
import java.util.Set; import java.util.Set;
import org.alfresco.model.ContentModel; import org.alfresco.model.ContentModel;
import org.alfresco.repo.content.ContentServicePolicies;
import org.alfresco.repo.node.NodeServicePolicies;
import org.alfresco.repo.policy.JavaBehaviour; import org.alfresco.repo.policy.JavaBehaviour;
import org.alfresco.repo.policy.PolicyComponent; import org.alfresco.repo.policy.PolicyComponent;
import org.alfresco.repo.transaction.AlfrescoTransactionSupport; import org.alfresco.repo.transaction.AlfrescoTransactionSupport;
@@ -40,7 +42,9 @@ import org.alfresco.util.GUID;
* *
* @author Roy Wetherall * @author Roy Wetherall
*/ */
public class DictionaryModelType public class DictionaryModelType implements ContentServicePolicies.OnContentUpdatePolicy,
NodeServicePolicies.OnUpdatePropertiesPolicy,
NodeServicePolicies.BeforeDeleteNodePolicy
{ {
/** Key to the pending models */ /** Key to the pending models */
private static final String KEY_PENDING_MODELS = "dictionaryModelType.pendingModels"; private static final String KEY_PENDING_MODELS = "dictionaryModelType.pendingModels";
@@ -120,7 +124,7 @@ public class DictionaryModelType
{ {
// Register interest in the onContentUpdate policy for the dictionary model type // Register interest in the onContentUpdate policy for the dictionary model type
policyComponent.bindClassBehaviour( policyComponent.bindClassBehaviour(
QName.createQName(NamespaceService.ALFRESCO_URI, "onContentUpdate"), ContentServicePolicies.ON_CONTENT_UPDATE,
ContentModel.TYPE_DICTIONARY_MODEL, ContentModel.TYPE_DICTIONARY_MODEL,
new JavaBehaviour(this, "onContentUpdate")); new JavaBehaviour(this, "onContentUpdate"));
@@ -145,7 +149,7 @@ public class DictionaryModelType
* *
* @param nodeRef the node reference whose content has been updated * @param nodeRef the node reference whose content has been updated
*/ */
public void onContentUpdate(NodeRef nodeRef) public void onContentUpdate(NodeRef nodeRef, boolean newContent)
{ {
queueModel(nodeRef); queueModel(nodeRef);
} }

View File

@@ -85,7 +85,7 @@ import org.springframework.util.StopWatch;
*/ */
public class RuleServiceCoverageTest extends TestCase public class RuleServiceCoverageTest extends TestCase
{ {
private static final ContentData CONTENT_DATA_TEXT = new ContentData(null, MimetypeMap.MIMETYPE_TEXT_PLAIN, 0L, "UTF-8"); //private static final ContentData CONTENT_DATA_TEXT = new ContentData(null, MimetypeMap.MIMETYPE_TEXT_PLAIN, 0L, "UTF-8");
/** /**
* Application context used during the test * Application context used during the test
@@ -455,9 +455,9 @@ public class RuleServiceCoverageTest extends TestCase
private Map<QName, Serializable> getContentProperties() private Map<QName, Serializable> getContentProperties()
{ {
Map<QName, Serializable> properties = new HashMap<QName, Serializable>(1); // Map<QName, Serializable> properties = new HashMap<QName, Serializable>(1);
properties.put(ContentModel.PROP_CONTENT, CONTENT_DATA_TEXT); // properties.put(ContentModel.PROP_CONTENT, CONTENT_DATA_TEXT);
return properties; return null;
} }
/** /**
@@ -1105,6 +1105,8 @@ public class RuleServiceCoverageTest extends TestCase
private void addContentToNode(NodeRef nodeRef) private void addContentToNode(NodeRef nodeRef)
{ {
ContentWriter contentWriter = this.contentService.getWriter(nodeRef, ContentModel.PROP_CONTENT, true); ContentWriter contentWriter = this.contentService.getWriter(nodeRef, ContentModel.PROP_CONTENT, true);
contentWriter.setMimetype(MimetypeMap.MIMETYPE_TEXT_PLAIN);
contentWriter.setEncoding("UTF-8");
assertNotNull(contentWriter); assertNotNull(contentWriter);
contentWriter.putContent(STANDARD_TEXT_CONTENT + System.currentTimeMillis()); contentWriter.putContent(STANDARD_TEXT_CONTENT + System.currentTimeMillis());
} }
@@ -1179,7 +1181,7 @@ public class RuleServiceCoverageTest extends TestCase
// Test condition failure // Test condition failure
Map<QName, Serializable> props1 = new HashMap<QName, Serializable>(); Map<QName, Serializable> props1 = new HashMap<QName, Serializable>();
props1.put(ContentModel.PROP_NAME, "bobbins.txt"); props1.put(ContentModel.PROP_NAME, "bobbins.txt");
props1.put(ContentModel.PROP_CONTENT, CONTENT_DATA_TEXT); // props1.put(ContentModel.PROP_CONTENT, CONTENT_DATA_TEXT);
NodeRef newNodeRef = this.nodeService.createNode( NodeRef newNodeRef = this.nodeService.createNode(
this.nodeRef, this.nodeRef,
ContentModel.ASSOC_CHILDREN, ContentModel.ASSOC_CHILDREN,
@@ -1196,7 +1198,7 @@ public class RuleServiceCoverageTest extends TestCase
// Test condition success // Test condition success
Map<QName, Serializable> props2 = new HashMap<QName, Serializable>(); Map<QName, Serializable> props2 = new HashMap<QName, Serializable>();
props2.put(ContentModel.PROP_NAME, "bobbins.doc"); props2.put(ContentModel.PROP_NAME, "bobbins.doc");
props2.put(ContentModel.PROP_CONTENT, CONTENT_DATA_TEXT); //props2.put(ContentModel.PROP_CONTENT, CONTENT_DATA_TEXT);
NodeRef newNodeRef2 = this.nodeService.createNode( NodeRef newNodeRef2 = this.nodeService.createNode(
this.nodeRef, this.nodeRef,
ContentModel.ASSOC_CHILDREN, ContentModel.ASSOC_CHILDREN,
@@ -1233,7 +1235,7 @@ public class RuleServiceCoverageTest extends TestCase
this.ruleService.saveRule(this.nodeRef, rule); this.ruleService.saveRule(this.nodeRef, rule);
Map<QName, Serializable> propsx = new HashMap<QName, Serializable>(); Map<QName, Serializable> propsx = new HashMap<QName, Serializable>();
propsx.put(ContentModel.PROP_NAME, "mybobbins.doc"); propsx.put(ContentModel.PROP_NAME, "mybobbins.doc");
propsx.put(ContentModel.PROP_CONTENT, CONTENT_DATA_TEXT); //propsx.put(ContentModel.PROP_CONTENT, CONTENT_DATA_TEXT);
NodeRef newNodeRefx = this.nodeService.createNode( NodeRef newNodeRefx = this.nodeService.createNode(
this.nodeRef, this.nodeRef,
ContentModel.ASSOC_CHILDREN, ContentModel.ASSOC_CHILDREN,
@@ -1244,7 +1246,7 @@ public class RuleServiceCoverageTest extends TestCase
assertFalse(this.nodeService.hasAspect(newNodeRefx, ContentModel.ASPECT_VERSIONABLE)); assertFalse(this.nodeService.hasAspect(newNodeRefx, ContentModel.ASPECT_VERSIONABLE));
Map<QName, Serializable> propsy = new HashMap<QName, Serializable>(); Map<QName, Serializable> propsy = new HashMap<QName, Serializable>();
propsy.put(ContentModel.PROP_NAME, "bobbins.doc"); propsy.put(ContentModel.PROP_NAME, "bobbins.doc");
propsy.put(ContentModel.PROP_CONTENT, CONTENT_DATA_TEXT); //propsy.put(ContentModel.PROP_CONTENT, CONTENT_DATA_TEXT);
NodeRef newNodeRefy = this.nodeService.createNode( NodeRef newNodeRefy = this.nodeService.createNode(
this.nodeRef, this.nodeRef,
ContentModel.ASSOC_CHILDREN, ContentModel.ASSOC_CHILDREN,
@@ -1265,7 +1267,7 @@ public class RuleServiceCoverageTest extends TestCase
this.ruleService.saveRule(this.nodeRef, rule); this.ruleService.saveRule(this.nodeRef, rule);
Map<QName, Serializable> propsa = new HashMap<QName, Serializable>(); Map<QName, Serializable> propsa = new HashMap<QName, Serializable>();
propsa.put(ContentModel.PROP_NAME, "bobbins.document"); propsa.put(ContentModel.PROP_NAME, "bobbins.document");
propsa.put(ContentModel.PROP_CONTENT, CONTENT_DATA_TEXT); // propsa.put(ContentModel.PROP_CONTENT, CONTENT_DATA_TEXT);
NodeRef newNodeRefa = this.nodeService.createNode( NodeRef newNodeRefa = this.nodeService.createNode(
this.nodeRef, this.nodeRef,
ContentModel.ASSOC_CHILDREN, ContentModel.ASSOC_CHILDREN,
@@ -1276,7 +1278,7 @@ public class RuleServiceCoverageTest extends TestCase
assertFalse(this.nodeService.hasAspect(newNodeRefa, ContentModel.ASPECT_VERSIONABLE)); assertFalse(this.nodeService.hasAspect(newNodeRefa, ContentModel.ASPECT_VERSIONABLE));
Map<QName, Serializable> propsb = new HashMap<QName, Serializable>(); Map<QName, Serializable> propsb = new HashMap<QName, Serializable>();
propsb.put(ContentModel.PROP_NAME, "bobbins.doc"); propsb.put(ContentModel.PROP_NAME, "bobbins.doc");
propsb.put(ContentModel.PROP_CONTENT, CONTENT_DATA_TEXT); //propsb.put(ContentModel.PROP_CONTENT, CONTENT_DATA_TEXT);
NodeRef newNodeRefb = this.nodeService.createNode( NodeRef newNodeRefb = this.nodeService.createNode(
this.nodeRef, this.nodeRef,
ContentModel.ASSOC_CHILDREN, ContentModel.ASSOC_CHILDREN,

View File

@@ -93,6 +93,7 @@ public class RuleTypeImplTest extends BaseSpringTest
ContentModel.TYPE_CONTAINER).getChildRef(); ContentModel.TYPE_CONTAINER).getChildRef();
List<RuleTrigger> triggers = new ArrayList<RuleTrigger>(2); List<RuleTrigger> triggers = new ArrayList<RuleTrigger>(2);
triggers.add((RuleTrigger)this.applicationContext.getBean("on-content-create-trigger"));
triggers.add((RuleTrigger)this.applicationContext.getBean("on-content-update-trigger")); triggers.add((RuleTrigger)this.applicationContext.getBean("on-content-update-trigger"));
triggers.add((RuleTrigger)this.applicationContext.getBean("on-create-child-association-trigger")); triggers.add((RuleTrigger)this.applicationContext.getBean("on-create-child-association-trigger"));

View File

@@ -0,0 +1,92 @@
/*
* Copyright (C) 2005 Alfresco, Inc.
*
* Licensed under the Mozilla Public License version 1.1
* with a permitted attribution clause. You may obtain a
* copy of the License at
*
* http://www.alfresco.org/legal/license.txt
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
* either express or implied. See the License for the specific
* language governing permissions and limitations under the
* License.
*/
package org.alfresco.repo.rule.ruletrigger;
import java.util.List;
import org.alfresco.repo.content.ContentServicePolicies;
import org.alfresco.repo.policy.JavaBehaviour;
import org.alfresco.service.cmr.repository.ChildAssociationRef;
import org.alfresco.service.cmr.repository.NodeRef;
/**
* @author Roy Wetherall
*/
public class OnContentUpdateRuleTrigger extends RuleTriggerAbstractBase
implements ContentServicePolicies.OnContentUpdatePolicy
{
/** True trigger on new content, false otherwise */
private boolean onNewContent = false;
/** True trigger parent rules, false otherwier */
private boolean triggerParentRules = true;
/**
* If set to true the trigger will fire on new content, otherwise it will fire on content update
*
* @param onNewContent indicates whether to fire on content create or update
*/
public void setOnNewContent(boolean onNewContent)
{
this.onNewContent = onNewContent;
}
/**
* Indicates whether the parent rules should be triggered or the rules on the node itself
*
* @param triggerParentRules true trigger parent rules, false otherwise
*/
public void setTriggerParentRules(boolean triggerParentRules)
{
this.triggerParentRules = triggerParentRules;
}
/*
* @see org.alfresco.repo.rule.ruletrigger.RuleTrigger#registerRuleTrigger()
*/
public void registerRuleTrigger()
{
// Bind behaviour
this.policyComponent.bindClassBehaviour(
ContentServicePolicies.ON_CONTENT_UPDATE,
this,
new JavaBehaviour(this, "onContentUpdate"));
}
/**
* @see org.alfresco.repo.content.ContentServicePolicies.OnContentUpdatePolicy#onContentUpdate(org.alfresco.service.cmr.repository.NodeRef, boolean)
*/
public void onContentUpdate(NodeRef nodeRef, boolean newContent)
{
if (newContent == this.onNewContent)
{
if (triggerParentRules == true)
{
List<ChildAssociationRef> parentsAssocRefs = this.nodeService.getParentAssocs(nodeRef);
for (ChildAssociationRef parentAssocRef : parentsAssocRefs)
{
triggerRules(parentAssocRef.getParentRef(), nodeRef);
}
}
else
{
triggerRules(nodeRef, nodeRef);
}
}
}
}

View File

@@ -0,0 +1,81 @@
/*
* Copyright (C) 2005 Alfresco, Inc.
*
* Licensed under the Mozilla Public License version 1.1
* with a permitted attribution clause. You may obtain a
* copy of the License at
*
* http://www.alfresco.org/legal/license.txt
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
* either express or implied. See the License for the specific
* language governing permissions and limitations under the
* License.
*/
package org.alfresco.repo.rule.ruletrigger;
import java.io.Serializable;
import java.util.List;
import java.util.Map;
import org.alfresco.repo.node.NodeServicePolicies;
import org.alfresco.repo.policy.JavaBehaviour;
import org.alfresco.service.cmr.repository.ChildAssociationRef;
import org.alfresco.service.cmr.repository.NodeRef;
import org.alfresco.service.namespace.NamespaceService;
import org.alfresco.service.namespace.QName;
/**
* On propety update trigger
*
* @author Roy Wetherall
*/
public class OnPropertyUpdateRuleTrigger extends RuleTriggerAbstractBase
implements NodeServicePolicies.OnUpdatePropertiesPolicy
{
/** True trigger parent rules, false otherwier */
private boolean triggerParentRules = true;
/**
* Indicates whether the parent rules should be triggered or the rules on the node itself
*
* @param triggerParentRules true trigger parent rules, false otherwise
*/
public void setTriggerParentRules(boolean triggerParentRules)
{
this.triggerParentRules = triggerParentRules;
}
/*
* @see org.alfresco.repo.rule.ruletrigger.RuleTrigger#registerRuleTrigger()
*/
public void registerRuleTrigger()
{
// Bind behaviour
this.policyComponent.bindClassBehaviour(
QName.createQName(NamespaceService.ALFRESCO_URI, "onUpdateProperties"),
this,
new JavaBehaviour(this, "onUpdateProperties"));
}
public void onUpdateProperties(NodeRef nodeRef, Map<QName, Serializable> before, Map<QName, Serializable> after)
{
if (triggerParentRules == true)
{
List<ChildAssociationRef> parentsAssocRefs = this.nodeService.getParentAssocs(nodeRef);
for (ChildAssociationRef parentAssocRef : parentsAssocRefs)
{
triggerRules(parentAssocRef.getParentRef(), nodeRef);
}
}
else
{
triggerRules(nodeRef, nodeRef);
}
}
}

View File

@@ -41,6 +41,7 @@ public class RuleTriggerTest extends BaseSpringTest
private static final String ON_CREATE_ASSOCIATION_TRIGGER = "on-create-association-trigger"; private static final String ON_CREATE_ASSOCIATION_TRIGGER = "on-create-association-trigger";
private static final String ON_DELETE_ASSOCIATION_TRIGGER = "on-delete-association-trigger"; private static final String ON_DELETE_ASSOCIATION_TRIGGER = "on-delete-association-trigger";
private static final String ON_CONTENT_UPDATE_TRIGGER = "on-content-update-trigger"; private static final String ON_CONTENT_UPDATE_TRIGGER = "on-content-update-trigger";
private static final String ON_CONTENT_CREATE_TRIGGER = "on-content-create-trigger";
private NodeService nodeService; private NodeService nodeService;
private ContentService contentService; private ContentService contentService;
@@ -212,7 +213,7 @@ public class RuleTriggerTest extends BaseSpringTest
assertTrue(ruleType.rulesTriggered); assertTrue(ruleType.rulesTriggered);
} }
public void testOnContentUpdateTrigger() public void testOnContentCreateTrigger()
{ {
NodeRef nodeRef = this.nodeService.createNode( NodeRef nodeRef = this.nodeService.createNode(
this.rootNodeRef, this.rootNodeRef,
@@ -220,8 +221,8 @@ public class RuleTriggerTest extends BaseSpringTest
ContentModel.ASSOC_CHILDREN, ContentModel.ASSOC_CHILDREN,
ContentModel.TYPE_CONTENT).getChildRef(); ContentModel.TYPE_CONTENT).getChildRef();
TestRuleType ruleType = createTestRuleType(ON_CONTENT_UPDATE_TRIGGER); TestRuleType contentCreate = createTestRuleType(ON_CONTENT_CREATE_TRIGGER);
assertFalse(ruleType.rulesTriggered); assertFalse(contentCreate.rulesTriggered);
// Try and trigger the type // Try and trigger the type
ContentWriter contentWriter = this.contentService.getWriter(nodeRef, ContentModel.PROP_CONTENT, true); ContentWriter contentWriter = this.contentService.getWriter(nodeRef, ContentModel.PROP_CONTENT, true);
@@ -230,7 +231,37 @@ public class RuleTriggerTest extends BaseSpringTest
contentWriter.putContent("some content"); contentWriter.putContent("some content");
// Check to see if the rule type has been triggered // Check to see if the rule type has been triggered
assertTrue(ruleType.rulesTriggered); assertTrue(contentCreate.rulesTriggered);
}
public void testOnContentUpdateTrigger()
{
NodeRef nodeRef = this.nodeService.createNode(
this.rootNodeRef,
ContentModel.ASSOC_CHILDREN,
ContentModel.ASSOC_CHILDREN,
ContentModel.TYPE_CONTENT).getChildRef();
TestRuleType contentUpdate = createTestRuleType(ON_CONTENT_UPDATE_TRIGGER);
assertFalse(contentUpdate.rulesTriggered);
// Try and trigger the type
ContentWriter contentWriter = this.contentService.getWriter(nodeRef, ContentModel.PROP_CONTENT, true);
contentWriter.setMimetype(MimetypeMap.MIMETYPE_TEXT_PLAIN);
contentWriter.setEncoding("UTF-8");
contentWriter.putContent("some content");
// Check to see if the rule type has been triggered
assertFalse(contentUpdate.rulesTriggered);
// Try and trigger the type
ContentWriter contentWriter2 = this.contentService.getWriter(nodeRef, ContentModel.PROP_CONTENT, true);
contentWriter2.setMimetype(MimetypeMap.MIMETYPE_TEXT_PLAIN);
contentWriter2.setEncoding("UTF-8");
contentWriter2.putContent("more content some content");
// Check to see if the rule type has been triggered
assertTrue(contentUpdate.rulesTriggered);
} }
private TestRuleType createTestRuleType(String ruleTriggerName) private TestRuleType createTestRuleType(String ruleTriggerName)

View File

@@ -21,6 +21,7 @@ import java.util.Map;
import org.alfresco.model.ContentModel; import org.alfresco.model.ContentModel;
import org.alfresco.repo.action.executer.CreateVersionActionExecuter; import org.alfresco.repo.action.executer.CreateVersionActionExecuter;
import org.alfresco.repo.content.ContentServicePolicies;
import org.alfresco.repo.policy.Behaviour; import org.alfresco.repo.policy.Behaviour;
import org.alfresco.repo.policy.JavaBehaviour; import org.alfresco.repo.policy.JavaBehaviour;
import org.alfresco.repo.policy.PolicyComponent; import org.alfresco.repo.policy.PolicyComponent;
@@ -41,7 +42,7 @@ import org.alfresco.service.namespace.QName;
* *
* @author Roy Wetherall * @author Roy Wetherall
*/ */
public class VersionableAspect public class VersionableAspect implements ContentServicePolicies.OnContentUpdatePolicy
{ {
/** /**
* The policy component * The policy component
@@ -124,7 +125,7 @@ public class VersionableAspect
new JavaBehaviour(this, "onAddAspect")); new JavaBehaviour(this, "onAddAspect"));
autoVersionBehaviour = new JavaBehaviour(this, "onContentUpdate"); autoVersionBehaviour = new JavaBehaviour(this, "onContentUpdate");
this.policyComponent.bindClassBehaviour( this.policyComponent.bindClassBehaviour(
QName.createQName(NamespaceService.ALFRESCO_URI, "onContentUpdate"), ContentServicePolicies.ON_CONTENT_UPDATE,
ContentModel.ASPECT_VERSIONABLE, ContentModel.ASPECT_VERSIONABLE,
autoVersionBehaviour); autoVersionBehaviour);
@@ -212,7 +213,7 @@ public class VersionableAspect
* *
* @param nodeRef the node reference * @param nodeRef the node reference
*/ */
public void onContentUpdate(NodeRef nodeRef) public void onContentUpdate(NodeRef nodeRef, boolean newContent)
{ {
if (this.nodeService.hasAspect(nodeRef, ContentModel.ASPECT_VERSIONABLE) == true) if (this.nodeService.hasAspect(nodeRef, ContentModel.ASPECT_VERSIONABLE) == true)
{ {