1 files changed, 144 insertions, 0 deletions
diff --git a/sandbox/dougsleite/implementation-guardian/src/main/java/org/apache/tuscany/sca/implementation/guardian/xml/GuardianGroupImplementationProcessor.java b/sandbox/dougsleite/implementation-guardian/src/main/java/org/apache/tuscany/sca/implementation/guardian/xml/GuardianGroupImplementationProcessor.java
new file mode 100644
index 0000000000..048ef7b9c8
--- /dev/null
+++ b/sandbox/dougsleite/implementation-guardian/src/main/java/org/apache/tuscany/sca/implementation/guardian/xml/GuardianGroupImplementationProcessor.java
@@ -0,0 +1,144 @@
+/*
+ * 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.implementation.guardian.xml;
+
+import org.apache.tuscany.sca.implementation.guardian.*;
+import java.util.Iterator;
+import javax.xml.namespace.QName;
+import javax.xml.stream.XMLStreamException;
+import javax.xml.stream.XMLStreamReader;
+import javax.xml.stream.XMLStreamWriter;
+import org.apache.axiom.om.OMAbstractFactory;
+import org.apache.axiom.om.OMAttribute;
+import org.apache.axiom.om.OMElement;
+import org.apache.axiom.om.OMFactory;
+import org.apache.tuscany.sca.assembly.AssemblyFactory;
+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.assembly.xml.Constants;
+import org.apache.tuscany.sca.contribution.ModelFactoryExtensionPoint;
+import org.apache.tuscany.sca.implementation.guardian.impl.GuardianGroupImplementationFactoryImpl;
+import org.apache.tuscany.sca.interfacedef.java.JavaInterfaceFactory;
+import org.apache.tuscany.sca.monitor.Monitor;
+
+public class GuardianGroupImplementationProcessor implements StAXArtifactProcessor<GuardianGroupImplementation> {
+
+    protected static final QName IMPLEMENTATION_GUARDIAN = new QName(Constants.SCA10_TUSCANY_NS, "implementation.guardian");
+    protected static final QName GUARDIAN_PROPERTIES = new QName(Constants.SCA10_TUSCANY_NS, "guardianProperties");
+    private GuardianGroupImplementationFactory guardianGroupImplementationFactory;
+
+    private AssemblyFactory assemblyFactor;
+    private JavaInterfaceFactory javaFactory;
+
+    //public GuardianGroupImplementationProcessor(ModelFactoryExtensionPoint modelFactories, Monitor monitor) {
+    //public GuardianGroupImplementationProcessor(ModelFactoryExtensionPoint modelFactories) {
+    public GuardianGroupImplementationProcessor(ModelFactoryExtensionPoint modelFactories, Monitor monitor) {
+
+        assemblyFactor = modelFactories.getFactory(AssemblyFactory.class);
+        javaFactory = modelFactories.getFactory(JavaInterfaceFactory.class);
+
+        guardianGroupImplementationFactory = new GuardianGroupImplementationFactoryImpl(assemblyFactor, javaFactory);
+        //guardianGroupImplementationFactory = modelFactories.getFactory(GuardianGroupImplementationFactory.class);
+    }
+
+    public GuardianGroupImplementation read(XMLStreamReader reader) throws ContributionReadException, XMLStreamException {
+        assert IMPLEMENTATION_GUARDIAN.equals(reader.getName());
+
+        GuardianGroupImplementation implementation = guardianGroupImplementationFactory.createGuardianGroupImplementation();
+
+        while (reader.hasNext()) {
+            reader.next();
+
+            if (reader.isStartElement() && reader.getName().equals(GUARDIAN_PROPERTIES)) {
+                OMElement guardianPropertiesElement = readGuardianProperties(reader);
+
+                //REVIEW
+                implementation.setGuardianProperties(guardianPropertiesElement);
+
+                break;
+            }
+        }
+
+        return implementation;
+    }
+
+    private OMElement readGuardianProperties(XMLStreamReader reader) {
+        OMFactory fac = OMAbstractFactory.getOMFactory();
+        OMElement element = fac.createOMElement(reader.getName());
+
+        for (int i = 0; i < reader.getAttributeCount(); i++) {
+
+            String ns = reader.getAttributeNamespace(i);
+            String prefix = reader.getAttributePrefix(i);
+            String qname = reader.getAttributeLocalName(i);
+            String value = reader.getAttributeValue(i);
+
+            if (ns != null) {
+                element.addAttribute(qname, value, fac.createOMNamespace(ns, prefix));
+                element.declareNamespace(ns, prefix);
+            } else {
+                element.addAttribute(qname, value, null);
+            }
+        }
+
+        return element;
+    }
+
+    public void write(GuardianGroupImplementation implementation, XMLStreamWriter writer) throws ContributionWriteException, XMLStreamException {
+        writer.writeStartElement(IMPLEMENTATION_GUARDIAN.getNamespaceURI(), IMPLEMENTATION_GUARDIAN.getLocalPart());
+
+        OMElement guardianProperties = implementation.getGuardianProperties();
+        if (guardianProperties != null) {
+            writeGuardianProperties(guardianProperties, writer);
+        }
+
+        writer.writeEndElement();
+    }
+
+    private void writeGuardianProperties(OMElement guardianProperties, XMLStreamWriter writer) throws XMLStreamException {
+
+        OMAttribute at;
+
+        //write the element's name
+        writer.writeStartElement(guardianProperties.getLocalName());
+
+        //write the attributes
+        Iterator attributes = guardianProperties.getAllAttributes();
+        while (attributes.hasNext()) {
+            at = (OMAttribute) attributes.next();
+            writer.writeAttribute(at.getLocalName(), at.getAttributeValue());
+        }
+
+        writer.writeEndElement();
+    }
+
+    public QName getArtifactType() {
+        return IMPLEMENTATION_GUARDIAN;
+    }
+
+    public void resolve(GuardianGroupImplementation arg0, ModelResolver arg1) throws ContributionResolveException {
+    }
+
+    public Class<GuardianGroupImplementation> getModelType() {
+        return GuardianGroupImplementation.class;
+    }
+}