blob: 10a4bb7d2491c4d086ba329a074bcbebc3025986 [file] [log] [blame]
package org.eclipse.basyx.examples.snippets.undoc.aas.connection.servlet;
import static org.junit.Assert.assertTrue;
import java.util.Map;
import org.eclipse.basyx.aas.manager.ConnectedAssetAdministrationShellManager;
import org.eclipse.basyx.aas.metamodel.map.descriptor.ModelUrn;
import org.eclipse.basyx.components.servlet.submodel.SubmodelServlet;
import org.eclipse.basyx.examples.contexts.BaSyxExamplesContext_Empty;
import org.eclipse.basyx.examples.deployment.BaSyxDeployment;
import org.eclipse.basyx.examples.support.directory.ExampleAASRegistry;
import org.eclipse.basyx.examples.support.directory.ExamplesPreconfiguredDirectory;
import org.eclipse.basyx.submodel.metamodel.api.ISubModel;
import org.eclipse.basyx.submodel.metamodel.api.submodelelement.ISubmodelElementCollection;
import org.eclipse.basyx.submodel.metamodel.map.SubModel;
import org.eclipse.basyx.submodel.metamodel.map.submodelelement.SubmodelElementCollection;
import org.eclipse.basyx.submodel.metamodel.map.submodelelement.dataelement.property.Property;
import org.eclipse.basyx.submodel.restapi.MultiSubmodelElementProvider;
import org.eclipse.basyx.vab.manager.VABConnectionManager;
import org.eclipse.basyx.vab.modelprovider.VABElementProxy;
import org.eclipse.basyx.vab.protocol.http.connector.HTTPConnectorProvider;
import org.junit.ClassRule;
import org.junit.Test;
/**
* Export sub model through a servlet and connect to that servlet
*
* @author kuhn
*
*/
public class AASServletConnection {
/**
* Example sub model. This example sub model is created with the BaSyx SDK factory and defines the AAS meta model properties
*/
static class SampleSubModelFactory extends SubModel {
/**
* Constructor - create sub model property
*/
@SuppressWarnings("unchecked")
public SampleSubModelFactory() {
// Set sub model ID
setIdShort("sm-001");
// Add example properties
// - Add simple property
Property prop1 = new Property(234);
prop1.setIdShort("prop1");
addSubModelElement(prop1);
Property prop11 = new Property(123);
prop11.setIdShort("prop11");
// - Add container property that holds other properties
SubmodelElementCollection container = new SubmodelElementCollection();
container.setIdShort("prop2");
container.addSubModelElement(prop11);
// - Add container to property map
addSubModelElement(container);
// Add another property manually to sub model container "properties"
Property prop3 = new Property(17);
prop3.setIdShort("prop3");
{
((Map<String, Object>) this.get("submodelElements")).put("prop3", prop3);
}
}
}
/**
* Create manager using the directory stub an the HTTPConnectorProvider
*/
ConnectedAssetAdministrationShellManager manager = new ConnectedAssetAdministrationShellManager(
// Add example specific mappings
new ExampleAASRegistry()
.addAASMapping("aas-001", "") // No AAS is provided in this example
.addSubmodelMapping("aas-001", "sm-001", "http://localhost:8080/basys.examples/Testsuite/components/BaSys/1.0/SampleModel/submodel"),
// We connect via HTTP
new HTTPConnectorProvider());
/**
* VAB connection manager backend
*/
protected VABConnectionManager connManager = new VABConnectionManager(
// Add example specific mappings
new ExamplesPreconfiguredDirectory()
// - VAB needs to know the relative path of the sub model that is defined by AAS meta model
.addMapping("sm-001VAB", "http://localhost:8080/basys.examples/Testsuite/components/BaSys/1.0/SampleModel/submodel"),
// We connect via HTTP
new HTTPConnectorProvider());
/**
* Instantiate and start context elements for this example. BaSyxDeployment contexts instantiate all
* components on the IP address of the host. Therefore, all components use the same IP address.
*/
@ClassRule
public static BaSyxDeployment context = new BaSyxDeployment(
// Servlets for example snippet
new BaSyxExamplesContext_Empty().
// Deploy example specific servlets to Tomcat server in this context
addServletMapping("/Testsuite/components/BaSys/1.0/SampleModel/*", new SubmodelServlet(new SampleSubModelFactory())));
/**
* Connect to sub model, query, and set property values
*/
@Test @SuppressWarnings("unchecked")
public void accessSubModel() throws Exception {
// Create and connect SDK connector
ISubModel subModel = manager.retrieveSubModel(new ModelUrn("aas-001"), new ModelUrn("sm-001"));
// - Retrieve sub model values and compare to expected values
assertTrue(subModel.getIdShort().equals("sm-001"));
assertTrue(subModel.getProperties().get("prop1").getIdShort().equals("prop1"));
assertTrue((int) subModel.getProperties().get("prop1").getValue() == 234);
assertTrue((int) subModel.getProperties().get("prop3").getValue() == 17);
assertTrue(subModel.getSubmodelElements().get("prop2").getIdShort().equals("prop2"));
assertTrue((int) ((ISubmodelElementCollection) subModel.getSubmodelElements().get("prop2")).getProperties().get("prop11").getValue() == 123);
// Connect to sub model using lower-level VAB interface
VABElementProxy connSubModel1 = this.connManager.connectToVABElement("sm-001VAB");
// - Read property values and compare with expected values
assertTrue((int) ((Map<String, Object>) connSubModel1.getModelPropertyValue(MultiSubmodelElementProvider.ELEMENTS + "/prop1")).get("value") == 234);
assertTrue((int) ((Map<String, Object>) connSubModel1.getModelPropertyValue(MultiSubmodelElementProvider.ELEMENTS + "/prop3")).get("value") == 17);
assertTrue(((Map<String, Object>) connSubModel1.getModelPropertyValue(MultiSubmodelElementProvider.ELEMENTS + "/prop1")).get("idShort").equals("prop1"));
assertTrue(((Map<String, Object>) connSubModel1.getModelPropertyValue(MultiSubmodelElementProvider.ELEMENTS + "/prop2")).get("idShort").equals("prop2"));
assertTrue((int) ((Map<String, Object>) connSubModel1.getModelPropertyValue("submodelElements/prop2/prop11")).get("value") == 123);
// - Change property value using VAB primitive
connSubModel1.setModelPropertyValue(MultiSubmodelElementProvider.ELEMENTS + "/prop1/value", 456);
// - Read value back using VAB primitive
assertTrue((int) ((Map<String, Object>) connSubModel1.getModelPropertyValue(MultiSubmodelElementProvider.ELEMENTS + "/prop1")).get("value") == 456);
// Read changed value back using SDK connector
assertTrue((int) subModel.getProperties().get("prop1").getValue() == 456);
}
}