archive/apache-tuscany
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Fix up appliesTo processing. Need to save each separate composite document as a dom and check endpoints

Browse source 
git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@979157 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
bdaniel 2010-07-26 04:40:48 +00:00
commit 7a90e1e944
1 changed files with 37 additions and 33 deletions
Download patch file Download diff file Expand all files Collapse all files

70
sca-java-2.x/trunk/modules/builder/src/main/java/org/apache/tuscany/sca/builder/impl/PolicyAppliesToBuilderImpl.java
View file

@ -83,44 +83,47 @@ public class PolicyAppliesToBuilderImpl extends PolicyAttachmentBuilderImpl {
}
}
private Composite checkAppliesTo(Document document, Map<PolicySet, List<PolicySubject>> appliesToSubjects, Composite composite, BuilderContext context) throws Exception {
// look at policies recursively
for (Component component : composite.getComponents()) {
Implementation implementation = component.getImplementation();
if (implementation instanceof Composite) {
checkAppliesTo(document, appliesToSubjects, (Composite)implementation, context);
}
}
private Composite checkAppliesTo(Document document, Map<PolicySet, List<PolicySubject>> appliesToSubjects, Composite topComposite, BuilderContext context) throws Exception {
for ( Component component : topComposite.getComponents() ) {
if ( component.getImplementation() instanceof Composite ) {
Composite nested = (Composite) component.getImplementation();
checkAppliesTo(saveAsDOM(nested),new HashMap<PolicySet, List<PolicySubject>>(), nested, context );
}
}
for (Component component : composite.getComponents()) {
for (Component component : topComposite.getComponents()) {
for (ComponentService componentService : component.getServices()) {
for (Endpoint ep : componentService.getEndpoints()) {
if (ep.getBinding() instanceof PolicySubject) {
checkAppliesToSubject(document, appliesToSubjects, composite, (PolicySubject)ep.getBinding(), ep.getPolicySets());
}
}
}
for (ComponentService componentService : component.getServices()) {
for (Endpoint ep : componentService.getEndpoints()) {
checkAppliesToSubject(document, appliesToSubjects, topComposite, (PolicySubject)ep, ep.getPolicySets());
if (ep.getBinding() instanceof PolicySubject) {
checkAppliesToSubject(document, appliesToSubjects, topComposite, (PolicySubject)ep.getBinding(), ep.getPolicySets());
}
}
}
for (ComponentReference componentReference : component.getReferences()) {
for (EndpointReference epr : componentReference.getEndpointReferences()) {
if (epr.getBinding() instanceof PolicySubject) {
checkAppliesToSubject(document, appliesToSubjects, composite, (PolicySubject)epr.getBinding(), epr.getPolicySets());
}
}
}
for (ComponentReference componentReference : component.getReferences()) {
for (EndpointReference epr : componentReference.getEndpointReferences()) {
checkAppliesToSubject(document, appliesToSubjects, topComposite, (PolicySubject)epr, epr.getPolicySets());
if (epr.getBinding() instanceof PolicySubject) {
checkAppliesToSubject(document, appliesToSubjects, topComposite, (PolicySubject)epr.getBinding(), epr.getPolicySets());
}
}
}
Implementation implementation = component.getImplementation();
if (implementation != null &&
implementation instanceof PolicySubject) {
checkAppliesToSubject(document, appliesToSubjects, composite, implementation, implementation.getPolicySets());
}
}
return composite;
Implementation implementation = component.getImplementation();
if (implementation != null &&
implementation instanceof PolicySubject) {
checkAppliesToSubject(document, appliesToSubjects, topComposite, implementation, implementation.getPolicySets());
}
}
return topComposite;
}
/**
/**
* Checks that all the provided policy sets apply to the provided policy subject
*
* @param document
@ -150,7 +153,8 @@ public class PolicyAppliesToBuilderImpl extends PolicyAttachmentBuilderImpl {
Node node = nodes.item(i);
String index = getStructuralURI(node);
PolicySubject subject = lookup(composite, index);
subjects.add(subject);
if ( subject != null )
subjects.add(subject);
}
}
}