Erlang binding sandbox

git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@746388 13f79535-47bb-0310-9956-ffa450edef68

8 files changed, 465 insertions, 0 deletions

diff --git a/sandbox/wjaniszewski/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/ErlangBinding.java b/sandbox/wjaniszewski/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/ErlangBinding.java
new file mode 100644
index 0000000000..c1c699cffe
--- /dev/null
+++ b/sandbox/wjaniszewski/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/ErlangBinding.java
@@ -0,0 +1,46 @@
+/*

+ * 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 org.apache.tuscany.sca.binding.erlang;

+

+import javax.xml.namespace.QName;

+

+import org.apache.tuscany.sca.assembly.Binding;

+import org.apache.tuscany.sca.assembly.xml.Constants;

+

+/**

+ * @version $Rev: $ $Date: $

+ */

+public interface ErlangBinding extends Binding {

+

+    QName BINDING_ERLANG_QNAME = new QName(Constants.SCA10_TUSCANY_NS, "binding.erlang");

+

+    String getNode();

+

+    void setNode(String node);

+    

+    String getModule();

+    

+    void setModule(String module);

+    

+    boolean isMbox();

+    

+    void setMbox(boolean mbox);

+

+}

diff --git a/sandbox/wjaniszewski/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/ErlangBindingFactory.java b/sandbox/wjaniszewski/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/ErlangBindingFactory.java
new file mode 100644
index 0000000000..4c85695dd3
--- /dev/null
+++ b/sandbox/wjaniszewski/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/ErlangBindingFactory.java
@@ -0,0 +1,31 @@
+/*

+ * 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 org.apache.tuscany.sca.binding.erlang;

+

+/**

+ * @version $Rev: $ $Date: $

+ */

+public interface ErlangBindingFactory {

+    /**

+     * Create a ErlangBinding model

+     * @return The ErlangBinding model

+     */

+    ErlangBinding createErlangBinding();

+}

diff --git a/sandbox/wjaniszewski/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingFactoryImpl.java b/sandbox/wjaniszewski/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingFactoryImpl.java
new file mode 100644
index 0000000000..1d2e1eefcf
--- /dev/null
+++ b/sandbox/wjaniszewski/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingFactoryImpl.java
@@ -0,0 +1,37 @@
+/*

+ * 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 org.apache.tuscany.sca.binding.erlang.impl;

+

+import org.apache.tuscany.sca.binding.erlang.ErlangBinding;

+import org.apache.tuscany.sca.binding.erlang.ErlangBindingFactory;

+

+/**

+ * @version $Rev: $ $Date: $

+ */

+public class ErlangBindingFactoryImpl implements ErlangBindingFactory {

+

+    /**

+     * @see org.apache.tuscany.sca.binding.erlang.ErlangBindingFactory#createErlangBinding()

+     */

+    public ErlangBinding createErlangBinding() {

+        return new ErlangBindingImpl();

+    }

+

+}

diff --git a/sandbox/wjaniszewski/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingImpl.java b/sandbox/wjaniszewski/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingImpl.java
new file mode 100644
index 0000000000..36b8df9fab
--- /dev/null
+++ b/sandbox/wjaniszewski/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingImpl.java
@@ -0,0 +1,115 @@
+/*

+ * 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 org.apache.tuscany.sca.binding.erlang.impl;

+

+import java.util.ArrayList;

+import java.util.List;

+

+import org.apache.tuscany.sca.binding.erlang.ErlangBinding;

+import org.apache.tuscany.sca.policy.Intent;

+import org.apache.tuscany.sca.policy.IntentAttachPointType;

+import org.apache.tuscany.sca.policy.PolicySet;

+import org.apache.tuscany.sca.policy.PolicySetAttachPoint;

+

+/**

+ * @version $Rev: $ $Date: $

+ */

+public class ErlangBindingImpl implements ErlangBinding, PolicySetAttachPoint {

+

+    private String node;

+    private String module;

+    private boolean mbox;

+    

+    private List<Intent> requiredIntents = new ArrayList<Intent>();

+    private List<PolicySet> policySets = new ArrayList<PolicySet>();

+    private IntentAttachPointType intentAttachPointType;

+    private List<PolicySet> applicablePolicySets = new ArrayList<PolicySet>();

+

+    public String getNode() {

+        return node;

+    }

+

+    public void setNode(String nodeName) {

+        this.node = nodeName;

+    }

+

+    public String getName() {

+        return null;

+    }

+

+    public String getURI() {

+        return null;

+    }

+

+    public void setName(String arg0) {

+    }

+

+    public void setURI(String arg0) {

+    }

+

+    public boolean isUnresolved() {

+        return false;

+    }

+

+    public void setUnresolved(boolean arg0) {

+    }

+

+    public List<PolicySet> getApplicablePolicySets() {

+        return applicablePolicySets;

+    }

+

+    public List<PolicySet> getPolicySets() {

+        return policySets;

+    }

+

+    public List<Intent> getRequiredIntents() {

+        return requiredIntents;

+    }

+

+    public IntentAttachPointType getType() {

+        return intentAttachPointType;

+    }

+

+    public void setType(IntentAttachPointType intentAttachPointType) {

+        this.intentAttachPointType = intentAttachPointType;

+    }

+    

+    @Override

+    public Object clone() throws CloneNotSupportedException {

+        return super.clone();

+    }

+

+    public String getModule() {

+        return module;

+    }

+

+    public boolean isMbox() {

+        return mbox;

+    }

+

+    public void setMbox(boolean mbox) {

+        this.mbox = mbox;

+    }

+

+    public void setModule(String module) {

+        this.module = module;

+    }

+

+}

diff --git a/sandbox/wjaniszewski/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingProcessor.java b/sandbox/wjaniszewski/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingProcessor.java
new file mode 100644
index 0000000000..f601e3327c
--- /dev/null
+++ b/sandbox/wjaniszewski/binding-erlang/src/main/java/org/apache/tuscany/sca/binding/erlang/impl/ErlangBindingProcessor.java
@@ -0,0 +1,106 @@
+/*

+ * 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 org.apache.tuscany.sca.binding.erlang.impl;

+

+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.assembly.xml.Constants;

+import org.apache.tuscany.sca.assembly.xml.PolicyAttachPointProcessor;

+import org.apache.tuscany.sca.binding.erlang.ErlangBinding;

+import org.apache.tuscany.sca.contribution.ModelFactoryExtensionPoint;

+import org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor;

+import org.apache.tuscany.sca.contribution.resolver.ModelResolver;

+import org.apache.tuscany.sca.contribution.service.ContributionReadException;

+import org.apache.tuscany.sca.contribution.service.ContributionResolveException;

+import org.apache.tuscany.sca.contribution.service.ContributionWriteException;

+import org.apache.tuscany.sca.policy.PolicyFactory;

+

+/**

+ * @version $Rev: $ $Date: $

+ */

+public class ErlangBindingProcessor implements StAXArtifactProcessor<ErlangBinding> {

+

+    private PolicyFactory policyFactory;

+    private PolicyAttachPointProcessor policyProcessor;

+    

+    public ErlangBindingProcessor(ModelFactoryExtensionPoint modelFactories) {

+        this.policyFactory = modelFactories.getFactory(PolicyFactory.class);

+        this.policyProcessor = new PolicyAttachPointProcessor(policyFactory);

+    }

+

+    /**

+     * @see org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor#getArtifactType()

+     */

+    public QName getArtifactType() {

+        return ErlangBinding.BINDING_ERLANG_QNAME;

+    }

+

+    /**

+     * @see org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor#read(javax.xml.stream.XMLStreamReader)

+     */

+    public ErlangBinding read(XMLStreamReader reader) throws ContributionReadException, XMLStreamException {

+        ErlangBinding binding = new ErlangBindingImpl();

+

+        // Read the policies

+        policyProcessor.readPolicies(binding, reader);

+        binding.setNode(reader.getAttributeValue(null, "node"));

+        String mboxValue = reader.getAttributeValue(null, "mbox");

+        if (mboxValue != null && mboxValue.length() > 0) {

+            boolean boolMboxValue = false;

+            try {

+                boolMboxValue = Boolean.parseBoolean(mboxValue);

+                binding.setMbox(boolMboxValue);

+            } catch (Exception e) {

+                e.printStackTrace();

+            }

+        }

+        binding.setModule(reader.getAttributeValue(null, "module"));

+        return binding;

+    }

+

+    /**

+     * @see org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor#write(java.lang.Object,

+     *      javax.xml.stream.XMLStreamWriter)

+     */

+    public void write(ErlangBinding model, XMLStreamWriter writer) throws ContributionWriteException,

+        XMLStreamException {

+        writer.writeStartElement(Constants.SCA10_TUSCANY_NS, "binding.erlang");

+        //TODO: implement

+        writer.writeEndElement();

+    }

+

+    /**

+     * @see org.apache.tuscany.sca.contribution.processor.ArtifactProcessor#getModelType()

+     */

+    public Class<ErlangBinding> getModelType() {

+        return ErlangBinding.class;

+    }

+

+    /**

+     * @see org.apache.tuscany.sca.contribution.processor.ArtifactProcessor#resolve(java.lang.Object,

+     *      org.apache.tuscany.sca.contribution.resolver.ModelResolver)

+     */

+    public void resolve(ErlangBinding model, ModelResolver resolver) throws ContributionResolveException {

+    }

+

+}

diff --git a/sandbox/wjaniszewski/binding-erlang/src/main/resources/META-INF/services/org.apache.tuscany.sca.binding.erlang.ErlangBindingFactory b/sandbox/wjaniszewski/binding-erlang/src/main/resources/META-INF/services/org.apache.tuscany.sca.binding.erlang.ErlangBindingFactory
new file mode 100644
index 0000000000..c7872d89c9
--- /dev/null
+++ b/sandbox/wjaniszewski/binding-erlang/src/main/resources/META-INF/services/org.apache.tuscany.sca.binding.erlang.ErlangBindingFactory
@@ -0,0 +1,19 @@
+# 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. 

+

+# Implementation class for the model factory

+org.apache.tuscany.sca.binding.erlang.impl.ErlangBindingFactoryImpl
\ No newline at end of file
diff --git a/sandbox/wjaniszewski/binding-erlang/src/main/resources/META-INF/services/org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor b/sandbox/wjaniszewski/binding-erlang/src/main/resources/META-INF/services/org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor
new file mode 100644
index 0000000000..6e614aac3e
--- /dev/null
+++ b/sandbox/wjaniszewski/binding-erlang/src/main/resources/META-INF/services/org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor
@@ -0,0 +1,19 @@
+# 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. 

+

+# Implementation class for the artifact processor extension

+org.apache.tuscany.sca.binding.erlang.impl.ErlangBindingProcessor;qname=http://tuscany.apache.org/xmlns/sca/1.0#binding.erlang,model=org.apache.tuscany.sca.binding.erlang.ErlangBinding,factory=org.apache.tuscany.sca.binding.erlang.ErlangBindingFactory

diff --git a/sandbox/wjaniszewski/binding-erlang/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ErlangBindingProcessorTestCase.java b/sandbox/wjaniszewski/binding-erlang/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ErlangBindingProcessorTestCase.java
new file mode 100644
index 0000000000..72574b2fb6
--- /dev/null
+++ b/sandbox/wjaniszewski/binding-erlang/src/test/java/org/apache/tuscany/sca/binding/erlang/testing/ErlangBindingProcessorTestCase.java
@@ -0,0 +1,92 @@
+/*
+ * 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 org.apache.tuscany.sca.binding.erlang.testing;
+
+import static org.junit.Assert.assertEquals;
+
+import java.io.StringReader;
+
+import javax.xml.stream.XMLInputFactory;
+import javax.xml.stream.XMLStreamReader;
+
+import org.apache.tuscany.sca.assembly.Composite;
+import org.apache.tuscany.sca.binding.erlang.ErlangBinding;
+import org.apache.tuscany.sca.contribution.processor.DefaultStAXArtifactProcessorExtensionPoint;
+import org.apache.tuscany.sca.contribution.processor.ExtensibleStAXArtifactProcessor;
+import org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessor;
+import org.apache.tuscany.sca.contribution.processor.StAXArtifactProcessorExtensionPoint;
+import org.apache.tuscany.sca.core.DefaultExtensionPointRegistry;
+import org.apache.tuscany.sca.core.UtilityExtensionPoint;
+import org.apache.tuscany.sca.monitor.Monitor;
+import org.apache.tuscany.sca.monitor.MonitorFactory;
+import org.apache.tuscany.sca.monitor.impl.DefaultMonitorFactoryImpl;
+import org.junit.BeforeClass;
+import org.junit.Test;
+
+/**
+ * General tests for binding.erlang XML processor
+ */
+public class ErlangBindingProcessorTestCase {
+
+    private static final String COMPOSITE =
+        "<?xml version=\"1.0\" encoding=\"ASCII\"?>" + "<composite xmlns=\"http://www.osoa.org/xmlns/sca/1.0\" xmlns:tuscany=\"http://tuscany.apache.org/xmlns/sca/1.0\" targetNamespace=\"http://binding-erlang\" name=\"binding-erlang\">"
+            + " <component name=\"HelloWorldComponent\">"
+            + "   <implementation.java class=\"services.HelloWorld\"/>"
+            + "      <service name=\"HelloWorldService\">"
+            + "          <tuscany:binding.erlang node=\"SomeNode\"/>"
+            + "      </service>"
+            + " </component>"
+            + "</composite>";
+
+    private static XMLInputFactory inputFactory;
+    private static StAXArtifactProcessor<Object> staxProcessor;
+    private static Monitor monitor;
+
+    @BeforeClass
+    public static void init() throws Exception {
+        DefaultExtensionPointRegistry extensionPoints = new DefaultExtensionPointRegistry();
+        inputFactory = XMLInputFactory.newInstance();
+        // Create a monitor
+        UtilityExtensionPoint utilities = extensionPoints.getExtensionPoint(UtilityExtensionPoint.class);
+        MonitorFactory monitorFactory = new DefaultMonitorFactoryImpl();
+        if (monitorFactory != null) {
+            monitor = monitorFactory.createMonitor();
+            utilities.addUtility(monitorFactory);
+        }
+        StAXArtifactProcessorExtensionPoint staxProcessors =
+            new DefaultStAXArtifactProcessorExtensionPoint(extensionPoints);
+        staxProcessor = new ExtensibleStAXArtifactProcessor(staxProcessors, inputFactory, null, monitor);
+    }
+
+    /**
+     * Tests reading "binding.erlang" element
+     * 
+     * @throws Exception
+     */
+    @Test
+    public void testLoadValidComposite() throws Exception {
+        XMLStreamReader reader = inputFactory.createXMLStreamReader(new StringReader(COMPOSITE));
+        Composite composite = (Composite)staxProcessor.read(reader);
+        ErlangBinding binding =
+            (ErlangBinding)composite.getComponents().get(0).getServices().get(0).getBindings().get(0);
+        assertEquals("SomeNode", binding.getNode());
+    }
+
+}