Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Add submodelReference eventing to MqttAasRepository PR #515

Merged
merged 3 commits into from
Nov 12, 2024
Merged

Add submodelReference eventing to MqttAasRepository PR #515

Show file tree
Hide file tree
Changes from 2 commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
6132a4c
feat: Events + Tests
ShehriyarShariq-Fraunhofer Nov 5, 2024
c65b680
fix: remove extra line
ShehriyarShariq-Fraunhofer Nov 5, 2024
5af8fd4
style: bump header date
mateusmolina-iese Nov 12, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 3 additions & 1 deletion basyx.aasrepository/basyx.aasrepository-feature-mqtt/Readme.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -5,4 +5,6 @@ This feature provides hierarchical MQTT eventing for a multitude of events:
| ----------- | ----------- | --- |
| AAS Created | aas-repository/\$repoId/shells/created| Created AAS JSON |
| AAS Updated | aas-repository/\$repoId/shells/updated| Updated AAS JSON|
| AAS Deleted | aas-repository/\$repoId/shells/deleted| Deleted AAS JSON|
| AAS Deleted | aas-repository/\$repoId/shells/deleted| Deleted AAS JSON|
| Submodel Reference Created | aas-repository/\$repoId/shells/submodels/\$submodelId/created| Created AAS JSON |
| Submodel Reference Deleted | aas-repository/\$repoId/shells/submodels/\$submodelId/deleted| Deleted AAS JSON|
15 changes: 15 additions & 0 deletions ...main/java/org/eclipse/digitaltwin/basyx/aasrepository/feature/mqtt/MqttAasRepository.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -107,12 +107,19 @@ public CursorResult<List<Reference>> getSubmodelReferences(String aasId, Paginat

@Override
public void addSubmodelReference(String aasId, Reference submodelReference) {
AssetAdministrationShell shell = decorated.getAas(aasId);
decorated.addSubmodelReference(aasId, submodelReference);

String referenceId = submodelReference.getKeys().get(0).getValue();

submodelReferenceCreated(shell, getName(), referenceId);
}

@Override
public void removeSubmodelReference(String aasId, String submodelId) {
AssetAdministrationShell shell = decorated.getAas(aasId);
decorated.removeSubmodelReference(aasId, submodelId);
submodelReferenceDeleted(shell, getName(), submodelId);
}

@Override
Expand All @@ -136,6 +143,14 @@ private void aasUpdated(AssetAdministrationShell shell, String repoId) {
private void aasDeleted(AssetAdministrationShell shell, String repoId) {
sendMqttMessage(topicFactory.createDeleteAASTopic(repoId), serializePayload(shell));
}

private void submodelReferenceCreated(AssetAdministrationShell shell, String repoId, String referenceId) {
sendMqttMessage(topicFactory.createCreateAASSubmodelReferenceTopic(repoId, referenceId), serializePayload(shell));
}

private void submodelReferenceDeleted(AssetAdministrationShell shell, String repoId, String referenceId) {
sendMqttMessage(topicFactory.createDeleteAASSubmodelReferenceTopic(repoId, referenceId), serializePayload(shell));
}

private String serializePayload(AssetAdministrationShell shell) {
try {
Expand Down
37 changes: 37 additions & 0 deletions ...g/eclipse/digitaltwin/basyx/aasrepository/feature/mqtt/MqttAasRepositoryTopicFactory.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -37,6 +37,7 @@
public class MqttAasRepositoryTopicFactory extends AbstractMqttTopicFactory {
private static final String AASREPOSITORY = "aas-repository";
private static final String SHELLS = "shells";
private static final String SUBMODELS = "submodels";
private static final String CREATED = "created";
private static final String UPDATED = "updated";
private static final String DELETED = "deleted";
Expand Down Expand Up @@ -93,4 +94,40 @@ public String createDeleteAASTopic(String repoId) {
.add(DELETED)
.toString();
}

/**
* Creates the hierarchical topic for the submodel reference create event
*
* @param repoId
* @param referenceId
* @return
*/
public String createCreateAASSubmodelReferenceTopic(String repoId, String referenceId) {
return new StringJoiner("/", "", "")
.add(AASREPOSITORY)
.add(repoId)
.add(SHELLS)
.add(SUBMODELS)
.add(referenceId)
.add(CREATED)
.toString();
}

/**
* Creates the hierarchical topic for the submodel reference delete event
*
* @param repoId
* @param referenceId
* @return
*/
public String createDeleteAASSubmodelReferenceTopic(String repoId, String referenceId) {
return new StringJoiner("/", "", "")
.add(AASREPOSITORY)
.add(repoId)
.add(SHELLS)
.add(SUBMODELS)
.add(referenceId)
.add(DELETED)
.toString();
}
}
36 changes: 35 additions & 1 deletion ...eclipse/digitaltwin/basyx/aasrepository/feature/mqtt/TestMqttV2AASAggregatorObserver.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -28,6 +28,7 @@
import static org.junit.Assert.assertEquals;

import java.io.IOException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;

Expand Down Expand Up @@ -94,7 +95,7 @@ public static void tearDownClass() {
public void createAasEvent() throws DeserializationException {
AssetAdministrationShell shell = createAasDummy("createAasEventId");
aasRepository.createAas(shell);

assertEquals(topicFactory.createCreateAASTopic(aasRepository.getName()), listener.lastTopic);
assertEquals(shell, deserializePayload(listener.lastPayload));
}
Expand All @@ -121,6 +122,29 @@ public void deleteAasEvent() throws DeserializationException {
assertEquals(topicFactory.createDeleteAASTopic(aasRepository.getName()), listener.lastTopic);
assertEquals(shell, deserializePayload(listener.lastPayload));
}

@Test
public void addSubmodelReferenceEvent() throws DeserializationException {
AssetAdministrationShell shell = createAasDummy("createAasSubmodelRefEventId");
aasRepository.createAas(shell);

Reference submodelReference = DummyAasFactory.createDummyReference(DummyAasFactory.DUMMY_SUBMODEL_ID);
aasRepository.addSubmodelReference(shell.getId(), submodelReference);

assertEquals(topicFactory.createCreateAASSubmodelReferenceTopic(aasRepository.getName(), DummyAasFactory.DUMMY_SUBMODEL_ID), listener.lastTopic);
assertEquals(shell, deserializePayload(listener.lastPayload));
}

@Test
public void removeSubmodelReferenceEvent() throws DeserializationException {
AssetAdministrationShell shell = createAasWithSubmodelReference("removeAasSubmodelRefEventId");
aasRepository.createAas(shell);

aasRepository.removeSubmodelReference(shell.getId(), DummyAasFactory.DUMMY_SUBMODEL_ID);

assertEquals(topicFactory.createDeleteAASSubmodelReferenceTopic(aasRepository.getName(), DummyAasFactory.DUMMY_SUBMODEL_ID), listener.lastTopic);
assertEquals(shell, deserializePayload(listener.lastPayload));
}

private AssetAdministrationShell deserializePayload(String payload) throws DeserializationException {
return new JsonDeserializer().read(payload, AssetAdministrationShell.class);
Expand All @@ -135,6 +159,16 @@ private AssetAdministrationShell createAasDummy(String aasId) {
return new DefaultAssetAdministrationShell.Builder().id(aasId)
.build();
}

private AssetAdministrationShell createAasWithSubmodelReference(String aasId) {
Reference submodelReference = DummyAasFactory.createDummyReference(DummyAasFactory.DUMMY_SUBMODEL_ID);

List<Reference> submodelReferences = new ArrayList<Reference>();
submodelReferences.add(submodelReference);

return new DefaultAssetAdministrationShell.Builder().id(aasId).submodels(submodelReferences)
.build();
}

private static AasRepository createMqttAasRepository(MqttClient client) {
AasRepositoryFactory repoFactory = new SimpleAasRepositoryFactory(new AasInMemoryBackendProvider(), new InMemoryAasServiceFactory(new InMemoryFileRepository()));
Expand Down