Implement Remaining MQTTSubmodelRepo Methods

basyx.common/basyx.mqttcore/src/main/java/org/eclipse/digitaltwin/basyx/common/mqttcore/serializer/SubmodelElementSerializer.java

@@ -25,6 +25,8 @@
 
 package org.eclipse.digitaltwin.basyx.common.mqttcore.serializer;
 
+import java.util.ArrayList;
+import java.util.List;
 import java.util.Optional;
 
 import org.eclipse.digitaltwin.aas4j.v3.dataformat.core.DeserializationException;
@@ -72,6 +74,34 @@ public static String serializeSubmodelElement(SubmodelElement submodelElement) {
 			throw new RuntimeException(e);
 		}
 	}
+
+	/**
+	 * Serializer to create a JSON String for the given submodel elements.
+	 * 
+	 * @param submodelElement
+	 * @return serialized list of submodelElements as JSON String
+	 */
+	public static String serializeSubmodelElements(List<SubmodelElement> submodelElements) {
+		try {
+			List<SubmodelElement> updatedSubmodelElements = new ArrayList<>();
+
+			for(int i = 0; i < submodelElements.size(); i++) {
+				SubmodelElement elem = submodelElements.get(i);
+				SubmodelElement localElement;
+				if (shouldSendEmptyValueEvent(elem)) {
+					localElement = getSubmodelElementWithoutValue(elem);
+				} else {
+					localElement = elem;
+				}
+
+				updatedSubmodelElements.add(localElement);
+			}
+
+			return new JsonSerializer().writeList(updatedSubmodelElements);
+		} catch (SerializationException | DeserializationException e) {
+			throw new RuntimeException(e);
+		}
+	}
 
 	/**
 	 * Generator to create a copy of a submodelElement without its value.

basyx.submodelrepository/basyx.submodelrepository-feature-mqtt/Readme.md

@@ -9,5 +9,8 @@ This feature provides hierarchical MQTT eventing for a multitude of events:
 | SubmodelElement Created | sm-repository/$repoId/submodels/$submodelIdBase64URLEncoded/submodelElements/$idShortPath/created | Created SubmodelElement JSON  |
 | SubmodelElement Updated | sm-repository/$repoId/submodels/$submodelIdBase64URLEncoded/submodelElements/$idShortPath/updated | Updated SubmodelElement JSON  |
 | SubmodelElement Deleted | sm-repository/$repoId/submodels/$submodelIdBase64URLEncoded/submodelElements/$idShortPath/deleted | Deleted SubmodelElement JSON  |
+| SubmodelElements Patched | sm-repository/$repoId/submodels/$submodelIdBase64URLEncoded/submodelElements/patched | Patched SubmodelElements JSON  |
+| FileValue Updated | sm-repository/$repoId/submodels/$submodelIdBase64URLEncoded/submodelElements/$idShortPath/fileValue/$fileName/updated | Updated SubmodelElement JSON  |
+| FileValue Deleted | sm-repository/$repoId/submodels/$submodelIdBase64URLEncoded/submodelElements/$idShortPath/fileValue/deleted | Deleted SubmodelElement JSON  |
 
 Per default, the SubmodelElement topic payloads include the SubmodelElement's value. If this is not desired, the SubmodelElement can be annotated with a Qualifier of type *emptyValueUpdateEvent* and value *true* 

basyx.submodelrepository/basyx.submodelrepository-feature-mqtt/src/main/java/org/eclipse/digitaltwin/basyx/submodelrepository/feature/mqtt/MqttSubmodelRepository.java

@@ -1,5 +1,6 @@
 package org.eclipse.digitaltwin.basyx.submodelrepository.feature.mqtt;
 
+import java.io.File;
 import java.io.InputStream;
 import java.util.List;
 
@@ -126,6 +127,13 @@ public void deleteSubmodelElement(String submodelId, String idShortPath) throws
 		submodelElementDeleted(submodelElement, getName(), submodelId, idShortPath);
 	}
 
+	@Override
+	public void patchSubmodelElements(String submodelId, List<SubmodelElement> submodelElementList) {
+		decorated.patchSubmodelElements(submodelId, submodelElementList);
+		List<SubmodelElement> patchedSubmodelElements = decorated.getSubmodelElements(submodelId, PaginationInfo.NO_LIMIT).getResult();
+		submodelElementsPatched(patchedSubmodelElements, getName(), submodelId);
+	}
+
 	@Override
 	public String getName() {
 		return decorated.getName();
@@ -141,6 +149,35 @@ public Submodel getSubmodelByIdMetadata(String submodelId) {
 		return decorated.getSubmodelByIdMetadata(submodelId);
 	}
 
+	@Override
+	public OperationVariable[] invokeOperation(String submodelId, String idShortPath, OperationVariable[] input) throws ElementDoesNotExistException {
+		return decorated.invokeOperation(submodelId, idShortPath, input);
+	}
+
+	@Override
+	public java.io.File getFileByPathSubmodel(String submodelId, String idShortPath) {
+		return decorated.getFileByPathSubmodel(submodelId, idShortPath);
+	}
+
+	@Override
+	public void deleteFileValue(String identifier, String idShortPath) {
+		SubmodelElement submodelElement = decorated.getSubmodelElement(identifier, idShortPath);	
+		decorated.deleteFileValue(identifier, idShortPath);
+		fileValueDeleted(submodelElement, getName(), identifier, idShortPath);
+	}
+
+	@Override
+	public void setFileValue(String submodelId, String idShortPath, String fileName, InputStream inputStream){
+		decorated.setFileValue(submodelId, idShortPath, fileName, inputStream);
+		SubmodelElement submodelElement = decorated.getSubmodelElement(submodelId, idShortPath);
+		fileValueUpdated(submodelElement, getName(), submodelId, idShortPath, fileName);
+	}
+
+	@Override
+	public InputStream getFileByFilePath(String submodelId, String filePath) {
+		return decorated.getFileByFilePath(submodelId, filePath);
+	}
+
 	private void submodelCreated(Submodel submodel, String repoId) {
 		sendMqttMessage(topicFactory.createCreateSubmodelTopic(repoId), SubmodelSerializer.serializeSubmodel(submodel));
 	}
@@ -164,6 +201,18 @@ private void submodelElementUpdated(SubmodelElement submodelElement, String repo
 	private void submodelElementDeleted(SubmodelElement submodelElement, String repoId, String submodelId, String submodelElementId) {
 		sendMqttMessage(topicFactory.createDeleteSubmodelElementTopic(repoId, submodelId, submodelElementId), SubmodelElementSerializer.serializeSubmodelElement(submodelElement));
 	}
+
+	private void submodelElementsPatched(List<SubmodelElement> submodelElements, String repoId, String submodelId) {
+		sendMqttMessage(topicFactory.createPatchSubmodelElementsTopic(repoId, submodelId), SubmodelElementSerializer.serializeSubmodelElements(submodelElements));
+	}
+
+	private void fileValueDeleted(SubmodelElement submodelElement, String repoId, String submodelId, String submodelElementId) {
+		sendMqttMessage(topicFactory.createDeleteFileValueTopic(repoId, submodelId, submodelElementId), SubmodelElementSerializer.serializeSubmodelElement(submodelElement));
+	}
+
+	private void fileValueUpdated(SubmodelElement submodelElement, String repoId, String submodelId, String submodelElementId, String fileName) {
+		sendMqttMessage(topicFactory.createUpdateFileValueTopic(repoId, submodelId, submodelElementId, fileName), SubmodelElementSerializer.serializeSubmodelElement(submodelElement));
+	}
 
 	/**
 	 * Sends MQTT message to connected broker
@@ -194,37 +243,4 @@ private MqttMessage createMqttMessage(String payload) {
 		}
 	}
 
-	@Override
-	public OperationVariable[] invokeOperation(String submodelId, String idShortPath, OperationVariable[] input) throws ElementDoesNotExistException {
-		return decorated.invokeOperation(submodelId, idShortPath, input);
-	}
-
-	@Override
-	public java.io.File getFileByPathSubmodel(String submodelId, String idShortPath) {
-		return decorated.getFileByPathSubmodel(submodelId, idShortPath);
-	}
-
-	@Override
-	public void deleteFileValue(String identifier, String idShortPath) {
-		// TODO: Eventing
-		decorated.deleteFileValue(identifier, idShortPath);
-	}
-
-	@Override
-	public void setFileValue(String submodelId, String idShortPath, String fileName, InputStream inputStream){
-		// TODO: Eventing
-		decorated.setFileValue(submodelId, idShortPath, fileName, inputStream);
-	}
-
-	@Override
-	public void patchSubmodelElements(String submodelId, List<SubmodelElement> submodelElementList) {
-		// TODO: Eventing
-		decorated.patchSubmodelElements(submodelId, submodelElementList);
-	}
-
-	@Override
-	public InputStream getFileByFilePath(String submodelId, String filePath) {
-		return decorated.getFileByFilePath(submodelId, filePath);
-	}
-
 }

basyx.submodelrepository/basyx.submodelrepository-feature-mqtt/src/main/java/org/eclipse/digitaltwin/basyx/submodelrepository/feature/mqtt/MqttSubmodelRepositoryTopicFactory.java

@@ -41,7 +41,9 @@ public class MqttSubmodelRepositoryTopicFactory extends AbstractMqttTopicFactory
 	private static final String CREATED = "created";
 	private static final String UPDATED = "updated";
 	private static final String DELETED = "deleted";
+	private static final String PATCHED = "patched";
 	private static final String SUBMODELELEMENTS = "submodelElements";
+	private static final String FILEVALUE = "fileValue";
 
 	/**
 	 * @param encoder
@@ -104,4 +106,34 @@ public String createUpdateSubmodelElementTopic(String repoId, String submodelId,
 	public String createDeleteSubmodelElementTopic(String repoId, String submodelId, String submodelElementId) {
 		return new StringJoiner("/", "", "").add(SUBMODELREPOSITORY).add(repoId).add(SUBMODELS).add(encodeId(submodelId)).add(SUBMODELELEMENTS).add(submodelElementId).add(DELETED).toString();
 	}
+
+	/**
+	 * Creates the hierarchical topic for the patch event of submodelElements
+	 * 
+	 * @param repoId
+	 * @param submodelId
+	 */
+	public String createPatchSubmodelElementsTopic(String repoId, String submodelId) {
+		return new StringJoiner("/", "", "").add(SUBMODELREPOSITORY).add(repoId).add(SUBMODELS).add(encodeId(submodelId)).add(SUBMODELELEMENTS).add(PATCHED).toString();
+	}
+
+	/**
+	 * Creates the hierarchical topic for the delete event of a file of a file element
+	 * 
+	 * @param repoId
+	 * 
+	 */
+	public String createDeleteFileValueTopic(String repoId, String submodelId, String submodelElementId) {
+		return new StringJoiner("/", "", "").add(SUBMODELREPOSITORY).add(repoId).add(SUBMODELS).add(encodeId(submodelId)).add(SUBMODELELEMENTS).add(submodelElementId).add(FILEVALUE).add(DELETED).toString();
+	}
+
+	/**
+	 * Creates the hierarchical topic for the update event of a file of a file element
+	 * 
+	 * @param repoId
+	 * 
+	 */
+	public String createUpdateFileValueTopic(String repoId, String submodelId, String submodelElementId, String fileName) {
+		return new StringJoiner("/", "", "").add(SUBMODELREPOSITORY).add(repoId).add(SUBMODELS).add(encodeId(submodelId)).add(SUBMODELELEMENTS).add(submodelElementId).add(FILEVALUE).add(fileName).add(UPDATED).toString();
+	}
 }