From a812f16a77e7a66a9e60043807a5ee6d97f5a984 Mon Sep 17 00:00:00 2001 From: lresende Date: Wed, 13 Jun 2012 16:50:00 +0000 Subject: TUSCANY-4064 - Applying patch from Nitya Doraisamy to enhance policy maven archetype git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@1349957 13f79535-47bb-0310-9956-ffa450edef68 --- .../src/main/resources/archetype-resources/pom.xml | 12 +-- .../java/__policyName__/__policyName__Policy.java | 66 ++++++++++++ .../__policyName__PolicyBuilder.java | 93 +++++++++++++++++ .../__policyName__PolicyFactory.java | 37 +++++++ .../__policyName__PolicyProcessor.java | 115 +++++++++++++++++++++ ...__policyName__ImplementationPolicyProvider.java | 63 +++++++++++ .../provider/__policyName__PolicyInterceptor.java | 71 +++++++++++++ .../__policyName__PolicyProviderFactory.java | 77 ++++++++++++++ .../__policyName__ReferencePolicyProvider.java | 54 ++++++++++ .../__policyName__ServicePolicyProvider.java | 55 ++++++++++ .../src/main/java/__policyName__Policy.java | 68 ------------ .../src/main/java/__policyName__PolicyBuilder.java | 87 ---------------- .../main/java/__policyName__PolicyProcessor.java | 113 -------------------- ...__policyName__ImplementationPolicyProvider.java | 59 ----------- .../profile/__policyName__PolicyInterceptor.java | 79 -------------- .../__policyName__PolicyProviderFactory.java | 71 ------------- .../__policyName__ReferencePolicyProvider.java | 55 ---------- .../__policyName__ServicePolicyProvider.java | 52 ---------- .../src/main/java/util/PolicyHelper.java | 74 +++++++++++++ ...ache.tuscany.sca.assembly.builder.PolicyBuilder | 2 +- ...ca.contribution.processor.StAXArtifactProcessor | 3 +- ....apache.tuscany.sca.definitions.xml.Definitions | 2 +- ...ache.tuscany.sca.provider.PolicyProviderFactory | 3 +- .../main/resources/__policyName__/definitions.xml | 34 ++++++ .../src/test/java/PolicyReadTestCase.java | 40 +++---- .../src/test/resources/mock_policies.xml | 25 +++++ .../sca/policy/logging/jdk/mock_policies.xml | 26 ----- 27 files changed, 788 insertions(+), 648 deletions(-) create mode 100644 sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__/__policyName__Policy.java create mode 100644 sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__/__policyName__PolicyBuilder.java create mode 100644 sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__/__policyName__PolicyFactory.java create mode 100644 sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__/__policyName__PolicyProcessor.java create mode 100644 sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__/provider/__policyName__ImplementationPolicyProvider.java create mode 100644 sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__/provider/__policyName__PolicyInterceptor.java create mode 100644 sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__/provider/__policyName__PolicyProviderFactory.java create mode 100644 sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__/provider/__policyName__ReferencePolicyProvider.java create mode 100644 sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__/provider/__policyName__ServicePolicyProvider.java create mode 100644 sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/util/PolicyHelper.java create mode 100644 sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/resources/__policyName__/definitions.xml create mode 100644 sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/test/resources/mock_policies.xml diff --git a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/pom.xml b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/pom.xml index d436d21970..1a60a6b70f 100644 --- a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/pom.xml +++ b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/pom.xml @@ -16,7 +16,8 @@ * KIND, either express or implied. See the License for the * specific language governing permissions and limitations * under the License. ---> +--> + 4.0.0 org.apache.tuscany.sca @@ -24,12 +25,12 @@ 2.0-SNAPSHOT ../pom.xml - ${artifactId} ${groupId} - Apache Tuscany SCA Extension Policy Logging Model + ${artifactId} + Apache Tuscany SCA Extension Policy ${policyName} + ${version} - org.apache.tuscany.sca tuscany-core-runtime-pom @@ -37,9 +38,6 @@ provided 2.0-SNAPSHOT - - ${version} - diff --git a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__/__policyName__Policy.java b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__/__policyName__Policy.java new file mode 100644 index 0000000000..dec23b38f7 --- /dev/null +++ b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__/__policyName__Policy.java @@ -0,0 +1,66 @@ +#set( $symbol_pound = '#' ) +#set( $symbol_dollar = '$' ) +#set( $symbol_escape = '\' ) +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * 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 ${package}.${policyName}; + +import javax.xml.namespace.QName; + +import org.apache.tuscany.sca.assembly.Base; + +/** + * Implementation for policies that could be injected as parameter + * into the axis2config. + * + * @version ${symbol_dollar}Rev${symbol_dollar} ${symbol_dollar}Date${symbol_dollar} + */ +public class ${policyName}Policy { + static final String SCA11_NS = Base.SCA11_NS; + static final String SCA11_TUSCANY_NS = Base.SCA11_TUSCANY_NS; + + public static final QName POLICY_QNAME = new QName(SCA11_TUSCANY_NS, "${policyName}"); + + private String configProperty; + + public String getConfigProperty() { + return configProperty; + } + + public void setConfigProperty(String configProperty) { + this.configProperty = configProperty; + } + + public QName getSchemaName() { + return POLICY_QNAME; + } + + public boolean isUnresolved() { + return false; + } + + public void setUnresolved(boolean unresolved) { + } + + @Override + public String toString() { + return "${policyName}Policy [configProperty=" + configProperty + + "]"; + } +} diff --git a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__/__policyName__PolicyBuilder.java b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__/__policyName__PolicyBuilder.java new file mode 100644 index 0000000000..ef37957a62 --- /dev/null +++ b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__/__policyName__PolicyBuilder.java @@ -0,0 +1,93 @@ +#set( $symbol_pound = '#' ) +#set( $symbol_dollar = '$' ) +#set( $symbol_escape = '\' ) +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * 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 ${package}.${policyName}; + +import java.util.ArrayList; +import java.util.List; + +import javax.xml.namespace.QName; + +import org.apache.tuscany.sca.assembly.Component; +import org.apache.tuscany.sca.assembly.Endpoint; +import org.apache.tuscany.sca.assembly.EndpointReference; +import org.apache.tuscany.sca.assembly.Implementation; +import org.apache.tuscany.sca.assembly.builder.BuilderContext; +import org.apache.tuscany.sca.assembly.builder.PolicyBuilder; +import org.apache.tuscany.sca.policy.PolicyExpression; +import org.apache.tuscany.sca.policy.PolicySet; +import org.apache.tuscany.sca.policy.PolicySubject; + +/** + * + */ +public class ${policyName}PolicyBuilder implements PolicyBuilder<${policyName}Policy> { + + @Override + public boolean build(Endpoint endpoint, BuilderContext context) { + List<${policyName}Policy> polices = getPolicies(endpoint); + System.out.println(endpoint + ": " + polices); + return true; + } + + @Override + public boolean build(EndpointReference endpointReference, BuilderContext context) { + List<${policyName}Policy> polices = getPolicies(endpointReference); + System.out.println(endpointReference + ": " + polices); + return true; + } + + @Override + public boolean build(Component component, Implementation implementation, BuilderContext context) { + List<${policyName}Policy> polices = getPolicies(implementation); + System.out.println(implementation + ": " + polices); + return true; + } + + @Override + public QName getPolicyType() { + return ${policyName}Policy.POLICY_QNAME; + } + + @Override + public List getSupportedBindings() { + return null; + } + + private List<${policyName}Policy> getPolicies(PolicySubject subject) { + List<${policyName}Policy> polices = new ArrayList<${policyName}Policy>(); + for (PolicySet ps : subject.getPolicySets()) { + for (PolicyExpression exp : ps.getPolicies()) { + if (getPolicyType().equals(exp.getName())) { + polices.add((${policyName}Policy)exp.getPolicy()); + } + } + } + return polices; + } + + @Override + public boolean build(EndpointReference endpointReference, Endpoint endpoint, BuilderContext context) { + return true; + } + +} diff --git a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__/__policyName__PolicyFactory.java b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__/__policyName__PolicyFactory.java new file mode 100644 index 0000000000..d3d760531d --- /dev/null +++ b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__/__policyName__PolicyFactory.java @@ -0,0 +1,37 @@ +#set( $symbol_pound = '#' ) +#set( $symbol_dollar = '$' ) +#set( $symbol_escape = '\' ) +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * 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 ${package}.${policyName}; + +/** + * Factory for ${policyName} Policy + * + * @version $Rev$ $Date$ + */ +public interface ${policyName}PolicyFactory { + + + /** + * Creates a new ${policyName} Policy + * @return the new ${policyName} policy + */ + ${policyName}Policy create${policyName}Policy(); +} diff --git a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__/__policyName__PolicyProcessor.java b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__/__policyName__PolicyProcessor.java new file mode 100644 index 0000000000..2a1313a115 --- /dev/null +++ b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__/__policyName__PolicyProcessor.java @@ -0,0 +1,115 @@ +#set( $symbol_pound = '#' ) +#set( $symbol_dollar = '$' ) +#set( $symbol_escape = '\' ) +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * 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 ${package}.${policyName}; + +import static javax.xml.stream.XMLStreamConstants.END_ELEMENT; +import static javax.xml.stream.XMLStreamConstants.START_ELEMENT; + +import javax.xml.namespace.QName; +import javax.xml.stream.XMLStreamException; +import javax.xml.stream.XMLStreamReader; +import javax.xml.stream.XMLStreamWriter; + +import org.apache.tuscany.sca.contribution.processor.ContributionReadException; +import org.apache.tuscany.sca.contribution.processor.ContributionResolveException; +import org.apache.tuscany.sca.contribution.processor.ContributionWriteException; +import org.apache.tuscany.sca.contribution.processor.ProcessorContext; +import org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor; +import org.apache.tuscany.sca.contribution.resolver.ModelResolver; +import org.apache.tuscany.sca.core.FactoryExtensionPoint; + +/** + * + * @version ${symbol_dollar}Rev${symbol_dollar} ${symbol_dollar}Date${symbol_dollar} + */ +public class ${policyName}PolicyProcessor implements StAXArtifactProcessor<${policyName}Policy> { + + public ${policyName}PolicyProcessor(FactoryExtensionPoint modelFactories) { + } + + @Override + public QName getArtifactType() { + return ${policyName}Policy.POLICY_QNAME; + } + + @Override + public ${policyName}Policy read(XMLStreamReader reader, ProcessorContext context) throws ContributionReadException, XMLStreamException { + ${policyName}Policy policy = new ${policyName}Policy(); + int event = reader.getEventType(); + QName name = null; + + + while (reader.hasNext()) { + event = reader.getEventType(); + switch (event) { + case START_ELEMENT : { + name = reader.getName(); + if ( name.equals(${policyName}Policy.POLICY_QNAME) ) { + String config = reader.getAttributeValue(null, "name"); + policy.setConfigProperty(config); + } + break; + } + } + + if ( event == END_ELEMENT ) { + if ( ${policyName}Policy.POLICY_QNAME.equals(reader.getName()) ) { + break; + } + } + + //Read the next element + if (reader.hasNext()) { + reader.next(); + } + } + + return policy; + } + + @Override + public void write(${policyName}Policy policy, XMLStreamWriter writer, ProcessorContext context) throws ContributionWriteException, + XMLStreamException { + String prefix = "tuscany"; + writer.writeStartElement(prefix, + ${policyName}Policy.POLICY_QNAME.getLocalPart(), + ${policyName}Policy.POLICY_QNAME.getNamespaceURI()); + writer.writeNamespace("tuscany", ${policyName}Policy.SCA11_TUSCANY_NS); + + if (policy.getConfigProperty() != null) { + writer.writeAttribute("name", policy.getConfigProperty()); + } + + writer.writeEndElement(); + } + + @Override + public Class<${policyName}Policy> getModelType() { + return ${policyName}Policy.class; + } + + @Override + public void resolve(${policyName}Policy arg0, ModelResolver arg1, ProcessorContext context) throws ContributionResolveException { + + } + +} diff --git a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__/provider/__policyName__ImplementationPolicyProvider.java b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__/provider/__policyName__ImplementationPolicyProvider.java new file mode 100644 index 0000000000..129f0add6c --- /dev/null +++ b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__/provider/__policyName__ImplementationPolicyProvider.java @@ -0,0 +1,63 @@ +#set( $symbol_pound = '#' ) +#set( $symbol_dollar = '$' ) +#set( $symbol_escape = '\' ) +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * 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 ${package}.${policyName}.provider; + +import java.util.List; + +import org.apache.tuscany.sca.policy.PolicySet; +import org.apache.tuscany.sca.interfacedef.Operation; +import org.apache.tuscany.sca.invocation.Phase; +import org.apache.tuscany.sca.invocation.PhasedInterceptor; +import org.apache.tuscany.sca.provider.BasePolicyProvider; +import org.apache.tuscany.sca.runtime.RuntimeComponent; + +import ${package}.util.PolicyHelper; +import ${package}.${policyName}.${policyName}Policy; + +/** + * @version ${symbol_dollar}Rev${symbol_dollar} ${symbol_dollar}Date${symbol_dollar} + */ +public class ${policyName}ImplementationPolicyProvider extends BasePolicyProvider<${policyName}Policy> { + private RuntimeComponent component; + + public ${policyName}ImplementationPolicyProvider(RuntimeComponent component) { + super(${policyName}Policy.class, component.getImplementation()); + this.component = component; + } + + /** + * @see ${groupId}.provider.PolicyProvider${symbol_pound}createInterceptor(${groupId}.interfacedef.Operation) + */ + @Override + public PhasedInterceptor createInterceptor(Operation operation) { + List policySets = PolicyHelper.findPolicySets(component, ${policyName}Policy.POLICY_QNAME); + + + return policySets.isEmpty() ? null : new ${policyName}PolicyInterceptor(getContext(), operation, getPhase()); + } + + public String getPhase() { + return Phase.IMPLEMENTATION_POLICY; + } + +} diff --git a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__/provider/__policyName__PolicyInterceptor.java b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__/provider/__policyName__PolicyInterceptor.java new file mode 100644 index 0000000000..164d59be90 --- /dev/null +++ b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__/provider/__policyName__PolicyInterceptor.java @@ -0,0 +1,71 @@ +#set( $symbol_pound = '#' ) +#set( $symbol_dollar = '$' ) +#set( $symbol_escape = '\' ) +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * 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 ${package}.${policyName}.provider; + +import org.apache.tuscany.sca.interfacedef.Operation; +import org.apache.tuscany.sca.invocation.Invoker; +import org.apache.tuscany.sca.invocation.Message; +import org.apache.tuscany.sca.invocation.PhasedInterceptor; + +/** + * Policy handler to handle PolicySet related to Logging with the QName + * {http://tuscany.apache.org/xmlns/sca/1.1/impl/java}${policyName}Policy + * + * @version ${symbol_dollar}Rev${symbol_dollar} ${symbol_dollar}Date${symbol_dollar} + */ +public class ${policyName}PolicyInterceptor implements PhasedInterceptor { + private Invoker next; + private Operation operation; + private String context; + private String phase; + + public ${policyName}PolicyInterceptor(String context, Operation operation, String phase) { + super(); + this.operation = operation; + this.context = context; + this.phase = phase; + } + + @Override + public Message invoke(Message msg) { + // DO SOMETHING HERE + System.out.println("Inside policy interceptor invoke method"); + + return getNext().invoke(msg); + } + + @Override + public Invoker getNext() { + return next; + } + + @Override + public void setNext(Invoker next) { + this.next = next; + } + + @Override + public String getPhase() { + return phase; + } + +} diff --git a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__/provider/__policyName__PolicyProviderFactory.java b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__/provider/__policyName__PolicyProviderFactory.java new file mode 100644 index 0000000000..44c962bc2c --- /dev/null +++ b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__/provider/__policyName__PolicyProviderFactory.java @@ -0,0 +1,77 @@ +#set( $symbol_pound = '#' ) +#set( $symbol_dollar = '$' ) +#set( $symbol_escape = '\' ) +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * 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 ${package}.${policyName}.provider; + +import org.apache.tuscany.sca.assembly.Endpoint; +import org.apache.tuscany.sca.assembly.EndpointReference; +import org.apache.tuscany.sca.core.ExtensionPointRegistry; +import org.apache.tuscany.sca.provider.PolicyProvider; +import org.apache.tuscany.sca.provider.PolicyProviderFactory; +import org.apache.tuscany.sca.runtime.RuntimeComponent; + +import ${package}.${policyName}.${policyName}Policy; + +/** + * @version ${symbol_dollar}Rev${symbol_dollar} ${symbol_dollar}Date${symbol_dollar} + */ +public class ${policyName}PolicyProviderFactory implements PolicyProviderFactory<${policyName}Policy> { + private ExtensionPointRegistry registry; + + public ${policyName}PolicyProviderFactory(ExtensionPointRegistry registry) { + super(); + this.registry = registry; + } + + /** + * @see ${groupId}.provider.PolicyProviderFactory${symbol_pound}createImplementationPolicyProvider(${groupId}.runtime.RuntimeComponent, ${groupId}.assembly.Implementation) + */ + @Override + public PolicyProvider createImplementationPolicyProvider(RuntimeComponent component) { + return new ${policyName}ImplementationPolicyProvider(component); + } + + /** + * @see ${groupId}.provider.PolicyProviderFactory${symbol_pound}createReferencePolicyProvider(${groupId}.runtime.RuntimeComponent, ${groupId}.runtime.RuntimeComponentReference, ${groupId}.assembly.Binding) + */ + @Override + public PolicyProvider createReferencePolicyProvider(EndpointReference endpointReference) { + return new ${policyName}ReferencePolicyProvider(endpointReference); + } + + /** + * @see ${groupId}.provider.PolicyProviderFactory${symbol_pound}createServicePolicyProvider(${groupId}.runtime.RuntimeComponent, ${groupId}.runtime.RuntimeComponentService, ${groupId}.assembly.Binding) + */ + @Override + public PolicyProvider createServicePolicyProvider(Endpoint endpoint) { + return new ${policyName}ServicePolicyProvider(endpoint); + } + + /** + * @see ${groupId}.provider.ProviderFactory${symbol_pound}getModelType() + */ + @Override + public Class<${policyName}Policy> getModelType() { + return ${policyName}Policy.class; + } + +} diff --git a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__/provider/__policyName__ReferencePolicyProvider.java b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__/provider/__policyName__ReferencePolicyProvider.java new file mode 100644 index 0000000000..70ea13de2f --- /dev/null +++ b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__/provider/__policyName__ReferencePolicyProvider.java @@ -0,0 +1,54 @@ +#set( $symbol_pound = '#' ) +#set( $symbol_dollar = '$' ) +#set( $symbol_escape = '\' ) +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * 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 ${package}.${policyName}.provider; + +import java.util.List; + +import org.apache.tuscany.sca.policy.PolicySet; +import org.apache.tuscany.sca.assembly.EndpointReference; +import org.apache.tuscany.sca.interfacedef.Operation; +import org.apache.tuscany.sca.invocation.Phase; +import org.apache.tuscany.sca.invocation.PhasedInterceptor; +import org.apache.tuscany.sca.provider.BasePolicyProvider; + +import ${package}.util.PolicyHelper; +import ${package}.${policyName}.${policyName}Policy; +/** + * @version ${symbol_dollar}Rev${symbol_dollar} ${symbol_dollar}Date${symbol_dollar} + */ +public class ${policyName}ReferencePolicyProvider extends BasePolicyProvider<${policyName}Policy> { + private EndpointReference endpointReference; + + public ${policyName}ReferencePolicyProvider(EndpointReference endpointReference) { + super(${policyName}Policy.class, endpointReference); + this.endpointReference = endpointReference; + } + + @Override + public PhasedInterceptor createInterceptor(Operation operation) { + List policySets = PolicyHelper.findPolicySets(endpointReference, ${policyName}Policy.POLICY_QNAME); + + return (policySets.isEmpty()) ? null : new ${policyName}PolicyInterceptor(getContext(), operation, Phase.REFERENCE_POLICY); + } + +} diff --git a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__/provider/__policyName__ServicePolicyProvider.java b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__/provider/__policyName__ServicePolicyProvider.java new file mode 100644 index 0000000000..cb23eb6dad --- /dev/null +++ b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__/provider/__policyName__ServicePolicyProvider.java @@ -0,0 +1,55 @@ +#set( $symbol_pound = '#' ) +#set( $symbol_dollar = '$' ) +#set( $symbol_escape = '\' ) +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * 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 ${package}.${policyName}.provider; + +import java.util.List; + +import org.apache.tuscany.sca.policy.PolicySet; +import org.apache.tuscany.sca.assembly.Endpoint; +import org.apache.tuscany.sca.interfacedef.Operation; +import org.apache.tuscany.sca.invocation.Phase; +import org.apache.tuscany.sca.invocation.PhasedInterceptor; +import org.apache.tuscany.sca.provider.BasePolicyProvider; + +import ${package}.util.PolicyHelper; +import ${package}.${policyName}.${policyName}Policy; + +/** + * @version ${symbol_dollar}Rev${symbol_dollar} ${symbol_dollar}Date${symbol_dollar} + */ +public class ${policyName}ServicePolicyProvider extends BasePolicyProvider<${policyName}Policy> { + private Endpoint endpoint; + + public ${policyName}ServicePolicyProvider(Endpoint endpoint) { + super(${policyName}Policy.class, endpoint); + this.endpoint = endpoint; + } + + @Override + public PhasedInterceptor createInterceptor(Operation operation) { + List policySets = PolicyHelper.findPolicySets(endpoint, ${policyName}Policy.POLICY_QNAME); + + return policySets.isEmpty() ? null : new ${policyName}PolicyInterceptor(getContext(), operation, Phase.SERVICE_POLICY); + } + +} diff --git a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__Policy.java b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__Policy.java index 921475c7b8..e69de29bb2 100644 --- a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__Policy.java +++ b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__Policy.java @@ -1,68 +0,0 @@ -#set( $symbol_pound = '#' ) -#set( $symbol_dollar = '$' ) -#set( $symbol_escape = '\' ) -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * 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 ${package}; - -import java.util.logging.Level; - -import javax.xml.namespace.QName; - -import org.apache.tuscany.sca.assembly.Base; - -/** - * Implementation for policies that could be injected as parameter - * into the axis2config. - * - * @version ${symbol_dollar}Rev${symbol_dollar} ${symbol_dollar}Date${symbol_dollar} - */ -public class ${policyName}Policy { - static final String SCA11_NS = Base.SCA11_NS; - static final String SCA11_TUSCANY_NS = Base.SCA11_TUSCANY_NS; - - static final QName POLICY_QNAME = new QName(SCA11_TUSCANY_NS, "${policyName}"); - - private String configProperty; - - public String getConfigProperty() { - return configProperty; - } - - public void setConfigProperty(String configProperty) { - this.configProperty = configProperty; - } - - public QName getSchemaName() { - return POLICY_QNAME; - } - - public boolean isUnresolved() { - return false; - } - - public void setUnresolved(boolean unresolved) { - } - - @Override - public String toString() { - return "${policyName}Policy [configProperty=" + configProperty - + "]"; - } -} diff --git a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__PolicyBuilder.java b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__PolicyBuilder.java index 146b04c7ec..e69de29bb2 100644 --- a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__PolicyBuilder.java +++ b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__PolicyBuilder.java @@ -1,87 +0,0 @@ -#set( $symbol_pound = '#' ) -#set( $symbol_dollar = '$' ) -#set( $symbol_escape = '\' ) -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * 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 ${package}; - -import java.util.ArrayList; -import java.util.List; - -import javax.xml.namespace.QName; - -import org.apache.tuscany.sca.assembly.Component; -import org.apache.tuscany.sca.assembly.Endpoint; -import org.apache.tuscany.sca.assembly.EndpointReference; -import org.apache.tuscany.sca.assembly.Implementation; -import org.apache.tuscany.sca.assembly.builder.BuilderContext; -import org.apache.tuscany.sca.assembly.builder.PolicyBuilder; -import org.apache.tuscany.sca.policy.PolicyExpression; -import org.apache.tuscany.sca.policy.PolicySet; -import org.apache.tuscany.sca.policy.PolicySubject; - -/** - * - */ -public class ${policyName}PolicyBuilder implements PolicyBuilder<${policyName}Policy> { - - public boolean build(Endpoint endpoint, BuilderContext context) { - List<${policyName}Policy> polices = getPolicies(endpoint); - System.out.println(endpoint + ": " + polices); - return true; - } - - public boolean build(EndpointReference endpointReference, BuilderContext context) { - List<${policyName}Policy> polices = getPolicies(endpointReference); - System.out.println(endpointReference + ": " + polices); - return true; - } - - public boolean build(Component component, Implementation implementation, BuilderContext context) { - List<${policyName}Policy> polices = getPolicies(implementation); - System.out.println(implementation + ": " + polices); - return true; - } - - public QName getPolicyType() { - return ${policyName}Policy.POLICY_QNAME; - } - - public List getSupportedBindings() { - return null; - } - - private List<${policyName}Policy> getPolicies(PolicySubject subject) { - List<${policyName}Policy> polices = new ArrayList<${policyName}Policy>(); - for (PolicySet ps : subject.getPolicySets()) { - for (PolicyExpression exp : ps.getPolicies()) { - if (getPolicyType().equals(exp.getName())) { - polices.add((${policyName}Policy)exp.getPolicy()); - } - } - } - return polices; - } - - public boolean build(EndpointReference endpointReference, Endpoint endpoint, BuilderContext context) { - return true; - } - -} diff --git a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__PolicyProcessor.java b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__PolicyProcessor.java index ba9169b39c..e69de29bb2 100644 --- a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__PolicyProcessor.java +++ b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/__policyName__PolicyProcessor.java @@ -1,113 +0,0 @@ -#set( $symbol_pound = '#' ) -#set( $symbol_dollar = '$' ) -#set( $symbol_escape = '\' ) -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * 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 ${package}; - -import static javax.xml.stream.XMLStreamConstants.END_ELEMENT; -import static javax.xml.stream.XMLStreamConstants.START_ELEMENT; - -import java.util.logging.Level; - -import javax.xml.namespace.QName; -import javax.xml.stream.XMLStreamException; -import javax.xml.stream.XMLStreamReader; -import javax.xml.stream.XMLStreamWriter; - -import org.apache.tuscany.sca.contribution.processor.ContributionReadException; -import org.apache.tuscany.sca.contribution.processor.ContributionResolveException; -import org.apache.tuscany.sca.contribution.processor.ContributionWriteException; -import org.apache.tuscany.sca.contribution.processor.ProcessorContext; -import org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor; -import org.apache.tuscany.sca.contribution.resolver.ModelResolver; -import org.apache.tuscany.sca.core.FactoryExtensionPoint; - -/** - * - * @version ${symbol_dollar}Rev${symbol_dollar} ${symbol_dollar}Date${symbol_dollar} - */ -public class ${policyName}PolicyProcessor implements StAXArtifactProcessor<${policyName}Policy> { - - public QName getArtifactType() { - return ${policyName}Policy.POLICY_QNAME; - } - - public ${policyName}PolicyProcessor(FactoryExtensionPoint modelFactories) { - } - - - public ${policyName}Policy read(XMLStreamReader reader, ProcessorContext context) throws ContributionReadException, XMLStreamException { - ${policyName}Policy policy = new ${policyName}Policy(); - int event = reader.getEventType(); - QName name = null; - - - while (reader.hasNext()) { - event = reader.getEventType(); - switch (event) { - case START_ELEMENT : { - name = reader.getName(); - if ( name.equals(${policyName}Policy.POLICY_QNAME) ) { - String config = reader.getAttributeValue(null, "name"); - policy.setConfigurationProperty(config); - } - break; - } - } - - if ( event == END_ELEMENT ) { - if ( ${policyName}Policy.POLICY_QNAME.equals(reader.getName()) ) { - break; - } - } - - //Read the next element - if (reader.hasNext()) { - reader.next(); - } - } - - return policy; - } - - public void write(${policyName}Policy policy, XMLStreamWriter writer, ProcessorContext context) throws ContributionWriteException, - XMLStreamException { - String prefix = "tuscany"; - writer.writeStartElement(prefix, - POLICY_QNAME.getLocalPart(), - POLICY_QNAME.getNamespaceURI()); - writer.writeNamespace("tuscany", ${policyName}Policy.SCA11_TUSCANY_NS); - - if (policy.getConfigurationProperty() != null) { - writer.writeAttribute("name", policy.getConfigurationProperty()); - } - - writer.writeEndElement(); - } - - public Class<${policyName}Policy> getModelType() { - return ${policyName}Policy.class; - } - - public void resolve(${policyName}Policy arg0, ModelResolver arg1, ProcessorContext context) throws ContributionResolveException { - - } - -} diff --git a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/profile/__policyName__ImplementationPolicyProvider.java b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/profile/__policyName__ImplementationPolicyProvider.java index 258c623f69..e69de29bb2 100644 --- a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/profile/__policyName__ImplementationPolicyProvider.java +++ b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/profile/__policyName__ImplementationPolicyProvider.java @@ -1,59 +0,0 @@ -#set( $symbol_pound = '#' ) -#set( $symbol_dollar = '$' ) -#set( $symbol_escape = '\' ) -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * 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 ${package}; - -import java.util.List; - -import org.apache.tuscany.sca.interfacedef.Operation; -import org.apache.tuscany.sca.invocation.Phase; -import org.apache.tuscany.sca.invocation.PhasedInterceptor; -import org.apache.tuscany.sca.provider.BasePolicyProvider; -import org.apache.tuscany.sca.runtime.RuntimeComponent; - -import com.shutterfly.middleware.tuscany.sca.policy.authorization.AuthorizationPolicy; -import com.shutterfly.middleware.tuscany.sca.policy.authorization.provider.PolicySet; -import com.shutterfly.middleware.tuscany.sca.policy.util.PolicyHelper; - -/** - * @version ${symbol_dollar}Rev${symbol_dollar} ${symbol_dollar}Date${symbol_dollar} - */ -public class ${policyName}ImplementationPolicyProvider extends BasePolicyProvider<${policyName}Policy> { - private RuntimeComponent component; - - public ${policyName}ImplementationPolicyProvider(RuntimeComponent component) { - super(${policyName}Policy.class, component.getImplementation()); - this.component = component; - } - - /** - * @see ${groupId}.provider.PolicyProvider${symbol_pound}createInterceptor(${groupId}.interfacedef.Operation) - */ - public PhasedInterceptor createInterceptor(Operation operation) { - List policySets = PolicyHelper.findPolicySets(component, ${policyName}Policy.POLICY_QNAME); - - - return policySets.isEmpty() ? null : new ${policyName}PolicyInterceptor(subject, getContext(), operation, - policySets, Phase.IMPLEMENTATION_POLICY); - } - -} diff --git a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/profile/__policyName__PolicyInterceptor.java b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/profile/__policyName__PolicyInterceptor.java index 7ec95aee4f..e69de29bb2 100644 --- a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/profile/__policyName__PolicyInterceptor.java +++ b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/profile/__policyName__PolicyInterceptor.java @@ -1,79 +0,0 @@ -#set( $symbol_pound = '#' ) -#set( $symbol_dollar = '$' ) -#set( $symbol_escape = '\' ) -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * 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 ${package}; - -import java.util.List; -import java.util.logging.ConsoleHandler; -import java.util.logging.Handler; -import java.util.logging.Level; -import java.util.logging.Logger; - -import javax.xml.namespace.QName; - -import org.apache.tuscany.sca.assembly.Component; -import org.apache.tuscany.sca.assembly.Endpoint; -import org.apache.tuscany.sca.assembly.EndpointReference; -import org.apache.tuscany.sca.interfacedef.Operation; -import org.apache.tuscany.sca.invocation.Invoker; -import org.apache.tuscany.sca.invocation.Message; -import org.apache.tuscany.sca.invocation.PhasedInterceptor; -import org.apache.tuscany.sca.policy.PolicySubject; - -/** - * Policy handler to handle PolicySet related to Logging with the QName - * {http://tuscany.apache.org/xmlns/sca/1.1/impl/java}${policyName}Policy - * - * @version ${symbol_dollar}Rev${symbol_dollar} ${symbol_dollar}Date${symbol_dollar} - */ -public class ${policyName}PolicyInterceptor implements PhasedInterceptor { - private Invoker next; - private Operation operation; - - public ${policyName}PolicyInterceptor(String context, Operation operation, String phase) { - - super(); - this.operation = operation; - this.context = context; - this.phase = phase; - } - - public Message invoke(Message msg) { - - // DO SOMETHING HERE - System.out.println("Inside policy interceptor invoke method"); - - return getNext.invoke(msg); - } - - public Invoker getNext() { - return next; - } - - public void setNext(Invoker next) { - this.next = next; - } - - public String getPhase() { - return phase; - } - -} diff --git a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/profile/__policyName__PolicyProviderFactory.java b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/profile/__policyName__PolicyProviderFactory.java index 796381fd7d..e69de29bb2 100644 --- a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/profile/__policyName__PolicyProviderFactory.java +++ b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/profile/__policyName__PolicyProviderFactory.java @@ -1,71 +0,0 @@ -#set( $symbol_pound = '#' ) -#set( $symbol_dollar = '$' ) -#set( $symbol_escape = '\' ) -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * 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 ${package}; - -import org.apache.tuscany.sca.assembly.Endpoint; -import org.apache.tuscany.sca.assembly.EndpointReference; -import org.apache.tuscany.sca.core.ExtensionPointRegistry; -import org.apache.tuscany.sca.provider.PolicyProvider; -import org.apache.tuscany.sca.provider.PolicyProviderFactory; -import org.apache.tuscany.sca.runtime.RuntimeComponent; - -/** - * @version ${symbol_dollar}Rev${symbol_dollar} ${symbol_dollar}Date${symbol_dollar} - */ -public class ${policyName}PolicyProviderFactory implements PolicyProviderFactory<${policyName}Policy> { - private ExtensionPointRegistry registry; - - public ${policyName}PolicyProviderFactory(ExtensionPointRegistry registry) { - super(); - this.registry = registry; - } - - /** - * @see ${groupId}.provider.PolicyProviderFactory${symbol_pound}createImplementationPolicyProvider(${groupId}.runtime.RuntimeComponent, ${groupId}.assembly.Implementation) - */ - public PolicyProvider createImplementationPolicyProvider(RuntimeComponent component) { - return new ${policyName}ImplementationPolicyProvider(component); - } - - /** - * @see ${groupId}.provider.PolicyProviderFactory${symbol_pound}createReferencePolicyProvider(${groupId}.runtime.RuntimeComponent, ${groupId}.runtime.RuntimeComponentReference, ${groupId}.assembly.Binding) - */ - public PolicyProvider createReferencePolicyProvider(EndpointReference endpointReference) { - return new ${policyName}ReferencePolicyProvider(endpointReference); - } - - /** - * @see ${groupId}.provider.PolicyProviderFactory${symbol_pound}createServicePolicyProvider(${groupId}.runtime.RuntimeComponent, ${groupId}.runtime.RuntimeComponentService, ${groupId}.assembly.Binding) - */ - public PolicyProvider createServicePolicyProvider(Endpoint endpoint) { - return new ${policyName}ServicePolicyProvider(endpoint); - } - - /** - * @see ${groupId}.provider.ProviderFactory${symbol_pound}getModelType() - */ - public Class<${policyName}Policy> getModelType() { - return ${policyName}Policy.class; - } - -} diff --git a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/profile/__policyName__ReferencePolicyProvider.java b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/profile/__policyName__ReferencePolicyProvider.java index bb93a756ce..e69de29bb2 100644 --- a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/profile/__policyName__ReferencePolicyProvider.java +++ b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/profile/__policyName__ReferencePolicyProvider.java @@ -1,55 +0,0 @@ -#set( $symbol_pound = '#' ) -#set( $symbol_dollar = '$' ) -#set( $symbol_escape = '\' ) -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * 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 ${package}; - -import java.util.List; - -import org.apache.tuscany.sca.assembly.EndpointReference; -import org.apache.tuscany.sca.interfacedef.Operation; -import org.apache.tuscany.sca.invocation.Phase; -import org.apache.tuscany.sca.invocation.PhasedInterceptor; -import org.apache.tuscany.sca.provider.BasePolicyProvider; - -import com.shutterfly.middleware.tuscany.sca.policy.authorization.provider.AuthorizationPolicyInterceptor; -import com.shutterfly.middleware.tuscany.sca.policy.authorization.provider.PolicySet; -import com.shutterfly.middleware.tuscany.sca.policy.metrics.PerformanceMetricsPolicy; -import com.shutterfly.middleware.tuscany.sca.policy.util.PolicyHelper; - -/** - * @version ${symbol_dollar}Rev${symbol_dollar} ${symbol_dollar}Date${symbol_dollar} - */ -public class ${policyName}ReferencePolicyProvider extends BasePolicyProvider<${policyName}Policy> { - private EndpointReference endpointReference; - - public ${policyName}ReferencePolicyProvider(EndpointReference endpointReference) { - super(${policyName}Policy.class, endpointReference); - this.endpointReference = endpointReference; - } - - public PhasedInterceptor createInterceptor(Operation operation) { - List policySets = PolicyHelper.findPolicySets(endpointReference, ${policyName}Policy.POLICY_QNAME); - - return (policySets.isEmpty()) ? null : new ${policyName}PolicyInterceptor(getContext(), operation, Phase.REFERENCE_POLICY); - } - -} diff --git a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/profile/__policyName__ServicePolicyProvider.java b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/profile/__policyName__ServicePolicyProvider.java index 2f019ab606..e69de29bb2 100644 --- a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/profile/__policyName__ServicePolicyProvider.java +++ b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/profile/__policyName__ServicePolicyProvider.java @@ -1,52 +0,0 @@ -#set( $symbol_pound = '#' ) -#set( $symbol_dollar = '$' ) -#set( $symbol_escape = '\' ) -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * 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 ${package}; - -import java.util.List; - -import org.apache.tuscany.sca.assembly.Endpoint; -import org.apache.tuscany.sca.interfacedef.Operation; -import org.apache.tuscany.sca.invocation.Phase; -import org.apache.tuscany.sca.invocation.PhasedInterceptor; -import org.apache.tuscany.sca.provider.BasePolicyProvider; - -import com.shutterfly.middleware.tuscany.sca.policy.authorization.provider.RuntimeComponent; - -/** - * @version ${symbol_dollar}Rev${symbol_dollar} ${symbol_dollar}Date${symbol_dollar} - */ -public class ${policyName}ServicePolicyProvider extends BasePolicyProvider<${policyName}Policy> { - private RuntimeComponent component; - - public ${policyName}ServicePolicyProvider(Endpoint endpoint) { - super(${policyName}Policy.class, endpoint); - this.component = component; - } - - public PhasedInterceptor createInterceptor(Operation operation) { - List policySets = PolicyHelper.findPolicySets(component, ${policyName}Policy.POLICY_QNAME); - - return policySets.isEmpty() ? null : new ${policyName}PolicyInterceptor(subject, getContext(), operation, policySets, Phase.SERVICE_POLICY); - } - -} diff --git a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/util/PolicyHelper.java b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/util/PolicyHelper.java new file mode 100644 index 0000000000..2f21ae2e4b --- /dev/null +++ b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/java/util/PolicyHelper.java @@ -0,0 +1,74 @@ +#set( $symbol_pound = '#' ) +#set( $symbol_dollar = '$' ) +#set( $symbol_escape = '\' ) +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * 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 ${package}.util; + +import java.util.ArrayList; +import java.util.List; + +import javax.xml.namespace.QName; + +import org.apache.tuscany.sca.policy.Intent; +import org.apache.tuscany.sca.policy.PolicyExpression; +import org.apache.tuscany.sca.policy.PolicySet; +import org.apache.tuscany.sca.policy.PolicySubject; + +public class PolicyHelper { + + /** + * Find a list of policy sets that provide the given intent + * @param subject + * @param providedIntent + * @return + */ + public static List findPolicySets(PolicySubject subject, QName providedIntent) { + List policies = new ArrayList(); + List policySets = subject.getPolicySets(); + for (PolicySet ps : policySets) { + for (Intent i : ps.getProvidedIntents()) { + if (i.getName().equals(providedIntent)) { + policies.add(ps); + } + } + } + return policies; + } + + /** + * Find a list of policies of the given type + * @param + * @param subject + * @param policyType + * @return + */ + public static List findPolicies(PolicySubject subject, QName providedIntent, Class policyType) { + List policies = new ArrayList(); + List policySets = findPolicySets(subject, providedIntent); + for (PolicySet ps : policySets) { + for (PolicyExpression exp : ps.getPolicies()) { + if (policyType.isInstance(exp.getPolicy())) { + policies.add(policyType.cast(exp.getPolicy())); + } + } + } + return policies; + } +} diff --git a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/resources/META-INF/services/org.apache.tuscany.sca.assembly.builder.PolicyBuilder b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/resources/META-INF/services/org.apache.tuscany.sca.assembly.builder.PolicyBuilder index 42b3ff5556..26ca8d5fdf 100644 --- a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/resources/META-INF/services/org.apache.tuscany.sca.assembly.builder.PolicyBuilder +++ b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/resources/META-INF/services/org.apache.tuscany.sca.assembly.builder.PolicyBuilder @@ -14,4 +14,4 @@ # KIND, either express or implied. See the License for the # specific language governing permissions and limitations # under the License. -org.apache.tuscany.sca.policy.logging.jdk.JDKLoggingPolicyBuilder;qname=http://tuscany.apache.org/xmlns/sca/1.1#jdkLogger +${package}.${policyName}.${policyName}PolicyBuilder;qname=http://tuscany.apache.org/xmlns/sca/1.1#${policyName} diff --git a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/resources/META-INF/services/org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/resources/META-INF/services/org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor index fce12e6e55..9b97157f57 100644 --- a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/resources/META-INF/services/org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor +++ b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/resources/META-INF/services/org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor @@ -16,5 +16,4 @@ # under the License. # Implementation class for the artifact processor extension -${package}.${policyName}PolicyProcessor;qname=http://tuscany.apache.org/xmlns/sca/1.1#jdkLogger,model=${package}.${policyName}Policy - +${package}.${policyName}.${policyName}PolicyProcessor;qname=http://tuscany.apache.org/xmlns/sca/1.1#${policyName}Policy,model=${package}.${policyName}.${policyName}Policy \ No newline at end of file diff --git a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/resources/META-INF/services/org.apache.tuscany.sca.definitions.xml.Definitions b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/resources/META-INF/services/org.apache.tuscany.sca.definitions.xml.Definitions index a3cc52cd3c..a186ac7367 100644 --- a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/resources/META-INF/services/org.apache.tuscany.sca.definitions.xml.Definitions +++ b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/resources/META-INF/services/org.apache.tuscany.sca.definitions.xml.Definitions @@ -14,4 +14,4 @@ # KIND, either express or implied. See the License for the # specific language governing permissions and limitations # under the License. -org/apache/tuscany/sca/policy/logging/definitions.xml +${policyName}/definitions.xml diff --git a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/resources/META-INF/services/org.apache.tuscany.sca.provider.PolicyProviderFactory b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/resources/META-INF/services/org.apache.tuscany.sca.provider.PolicyProviderFactory index 3bbbc3108c..4d41d2281c 100644 --- a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/resources/META-INF/services/org.apache.tuscany.sca.provider.PolicyProviderFactory +++ b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/resources/META-INF/services/org.apache.tuscany.sca.provider.PolicyProviderFactory @@ -16,5 +16,4 @@ # under the License. # Implementation class for the policy extension -org.apache.tuscany.sca.policy.logging.jdk.JDKLoggingPolicyProviderFactory;model=org.apache.tuscany.sca.policy.logging.jdk.JDKLoggingPolicy - +${package}.${policyName}.provider.${policyName}PolicyProviderFactory;model=${package}.${policyName}.${policyName}Policy diff --git a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/resources/__policyName__/definitions.xml b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/resources/__policyName__/definitions.xml new file mode 100644 index 0000000000..a956d3417f --- /dev/null +++ b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/main/resources/__policyName__/definitions.xml @@ -0,0 +1,34 @@ +#set( $symbol_pound = '#' ) +#set( $symbol_dollar = '$' ) +#set( $symbol_escape = '\' ) + + + + + + + + All operations should have a valid authenticated user + + + + \ No newline at end of file diff --git a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/test/java/PolicyReadTestCase.java b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/test/java/PolicyReadTestCase.java index 618dec57ce..436c429aad 100644 --- a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/test/java/PolicyReadTestCase.java +++ b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/test/java/PolicyReadTestCase.java @@ -19,14 +19,11 @@ * specific language governing permissions and limitations * under the License. */ -package ${package}; - import java.io.InputStream; import java.io.StringReader; import java.io.StringWriter; import java.net.URL; -import java.util.logging.Level; import javax.xml.stream.XMLInputFactory; import javax.xml.stream.XMLOutputFactory; @@ -35,7 +32,10 @@ import javax.xml.stream.XMLStreamWriter; import junit.framework.TestCase; -import ${groupId}.contribution.processor.ProcessorContext; +import org.apache.tuscany.sca.contribution.processor.ProcessorContext; + +import ${package}.${policyName}.${policyName}Policy; +import ${package}.${policyName}.${policyName}PolicyProcessor; /** * Test the reading of ws config params policy. @@ -54,28 +54,21 @@ public class PolicyReadTestCase extends TestCase { } public void testPolicyReading() throws Exception { - JDKLoggingPolicyProcessor processor = new JDKLoggingPolicyProcessor(null); - - URL url = getClass().getResource("mock_policies.xml"); - XMLInputFactory inputFactory = XMLInputFactory.newInstance(); - - InputStream urlStream = url.openStream(); - XMLStreamReader reader = inputFactory.createXMLStreamReader(urlStream); - - - JDKLoggingPolicy policy = processor.read(reader, context); - assertEquals(policy.getLoggerName(), "test.logger"); - assertEquals(policy.getLogLevel(), Level.INFO ); - assertEquals(policy.getResourceBundleName(), "Trace_Messages.properties"); + ${policyName}PolicyProcessor processor = new ${policyName}PolicyProcessor(null); +// URL url = getClass().getResource("mock_policies.xml"); +// XMLInputFactory inputFactory = XMLInputFactory.newInstance(); +// +// InputStream urlStream = url.openStream(); +// XMLStreamReader reader = inputFactory.createXMLStreamReader(urlStream); +// +// +// ${policyName}Policy policy = processor.read(reader, context); } public void testPolicyWriting() throws Exception { - JDKLoggingPolicyProcessor processor = new JDKLoggingPolicyProcessor(null); + ${policyName}PolicyProcessor processor = new ${policyName}PolicyProcessor(null); - JDKLoggingPolicy policy = new JDKLoggingPolicy(); - policy.setLoggerName("test.logger"); - policy.setLogLevel(Level.INFO); - policy.setResourceBundleName("Trace_Messages.properties"); + ${policyName}Policy policy = new ${policyName}Policy(); XMLOutputFactory outputFactory = XMLOutputFactory.newInstance(); StringWriter sw = new StringWriter(); @@ -88,9 +81,6 @@ public class PolicyReadTestCase extends TestCase { XMLStreamReader reader = inputFactory.createXMLStreamReader(sr); policy = processor.read(reader, context); - assertEquals(policy.getLoggerName(), "test.logger"); - assertEquals(policy.getLogLevel(), Level.INFO ); - assertEquals(policy.getResourceBundleName(), "Trace_Messages.properties"); } diff --git a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/test/resources/mock_policies.xml b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/test/resources/mock_policies.xml new file mode 100644 index 0000000000..a6071984e8 --- /dev/null +++ b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/test/resources/mock_policies.xml @@ -0,0 +1,25 @@ +#set( $symbol_pound = '#' ) +#set( $symbol_dollar = '$' ) +#set( $symbol_escape = '\' ) + + + + + \ No newline at end of file diff --git a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/test/resources/org/apache/tuscany/sca/policy/logging/jdk/mock_policies.xml b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/test/resources/org/apache/tuscany/sca/policy/logging/jdk/mock_policies.xml index 4fcfffb115..e69de29bb2 100644 --- a/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/test/resources/org/apache/tuscany/sca/policy/logging/jdk/mock_policies.xml +++ b/sca-java-2.x/trunk/maven/archetypes/policy/src/main/resources/archetype-resources/src/test/resources/org/apache/tuscany/sca/policy/logging/jdk/mock_policies.xml @@ -1,26 +0,0 @@ -#set( $symbol_pound = '#' ) -#set( $symbol_dollar = '$' ) -#set( $symbol_escape = '\' ) - - - - INFO - Trace_Messages.properties - \ No newline at end of file -- cgit v1.2.3