introduce splitTopicExcludingSeparatorIncludingLeagingSlash to inclus…

…e first leading slash

dynamic-mapping-service/src/main/java/dynamic/mapping/model/Mapping.java

@@ -255,11 +255,34 @@ public static String[] splitTopicExcludingSeparatorAsArray(String topic) {
         return topic.split("\\/");
     }
 
+    public static String[] splitTopicExcludingSeparatorIncludingLeagingSlashAsArray(String topic) {
+        String topix = topic.trim().replaceAll("\\/{1,}$", ""); // Remove trailing slashes only
+        if (topix.startsWith("//")) {                           // If multiple leading slashes
+            topix = "/" + topix.replaceAll("^/+", "");         // Replace with single slash
+        }
+
+        // Special handling for the first slash
+        if (topix.startsWith("/")) {
+            String[] parts = topix.substring(1).split("\\/");
+            String[] result = new String[parts.length + 1];
+            result[0] = "/";
+            System.arraycopy(parts, 0, result, 1, parts.length);
+            return result;
+        }
+
+        return topix.split("\\/");
+    }
+
     public static List<String> splitTopicExcludingSeparatorAsList(String topic) {
         return new ArrayList<String>(
                 Arrays.asList(Mapping.splitTopicExcludingSeparatorAsArray(topic)));
     }
 
+    public static List<String> splitTopicExcludingSeparatorIncludingLeagingSlashAsList(String topic) {
+        return new ArrayList<String>(
+                Arrays.asList(Mapping.splitTopicExcludingSeparatorIncludingLeagingSlashAsArray(topic)));
+    }
+
     /*
      * only one substitution can be marked with definesIdentifier == true
      */

dynamic-mapping-service/src/main/java/dynamic/mapping/processor/inbound/BaseProcessorInbound.java

@@ -88,7 +88,7 @@ public void enrichPayload(ProcessingContext<T> context) {
         String tenant = context.getTenant();
         Object payloadObject = context.getPayload();
 
-        List<String> splitTopicAsList = Mapping.splitTopicExcludingSeparatorAsList(context.getTopic());
+        List<String> splitTopicAsList = Mapping.splitTopicExcludingSeparatorIncludingLeagingSlashAsList(context.getTopic());
         if (payloadObject instanceof Map) {
             ((Map) payloadObject).put(Mapping.TOKEN_TOPIC_LEVEL, splitTopicAsList);
             if (context.isSupportsMessageContext() && context.getKey() != null) {

dynamic-mapping-service/src/main/java/dynamic/mapping/processor/outbound/BaseProcessorOutbound.java

@@ -123,7 +123,7 @@ public ProcessingContext<T> substituteInTargetAndSend(ProcessingContext<T> conte
          * step 0 patch payload with dummy property _TOPIC_LEVEL_ in case the content
          * is required in the payload for a substitution
          */
-        List<String> splitTopicExAsList = Mapping.splitTopicExcludingSeparatorAsList(context.getTopic());
+        List<String> splitTopicExAsList = Mapping.splitTopicExcludingSeparatorIncludingLeagingSlashAsList(context.getTopic());
         payloadTarget.put("$", Mapping.TOKEN_TOPIC_LEVEL, splitTopicExAsList);
         if (mapping.supportsMessageContext) {
             Map<String, String> cod = new HashMap<String, String>() {

dynamic-mapping-ui/src/mapping/core/processor/base-processor-inbound.service.ts

@@ -31,7 +31,7 @@ import {
   RepairStrategy,
   getPathTargetForDeviceIdentifiers, transformGenericPath2C8YPath
 } from '../../../shared';
-import { splitTopicExcludingSeparator } from '../../shared/util';
+import { splitTopicExcludingSeparatorIncludingLeagingSlash } from '../../shared/util';
 import { C8YAgent } from '../c8y-agent.service';
 import {
   IDENTITY,
@@ -65,7 +65,7 @@ export abstract class BaseProcessorInbound {
 
   enrichPayload(context: ProcessingContext): void {
     const { payload } = context;
-    const topicLevels = splitTopicExcludingSeparator(context.topic);
+    const topicLevels = splitTopicExcludingSeparatorIncludingLeagingSlash(context.topic);
     payload[TOKEN_TOPIC_LEVEL] = topicLevels;
   }
 

dynamic-mapping-ui/src/mapping/core/processor/base-processor-outbound.service.ts

@@ -24,7 +24,7 @@ import * as _ from 'lodash';
 import { API, Mapping, MappingType, RepairStrategy } from '../../../shared';
 import {
   TOKEN_TOPIC_LEVEL,
-  splitTopicExcludingSeparator,
+  splitTopicExcludingSeparatorIncludingLeagingSlash,
   splitTopicIncludingSeparator
 } from '../../shared/util';
 import { C8YAgent } from '../c8y-agent.service';
@@ -72,7 +72,7 @@ export abstract class BaseProcessorOutbound {
      * step 0 patch payload with dummy property _TOPIC_LEVEL_ in case the content
      * is required in the payload for a substitution
      */
-    const splitTopicExAsList: string[] = splitTopicExcludingSeparator(
+    const splitTopicExAsList: string[] = splitTopicExcludingSeparatorIncludingLeagingSlash(
       context.topic
     );
     payloadTarget[TOKEN_TOPIC_LEVEL] = splitTopicExAsList;

dynamic-mapping-ui/src/mapping/shared/util.ts

@@ -34,13 +34,13 @@ export const TOKEN_CONTEXT_DATA = '_CONTEXT_DATA_';
 export const CONTEXT_DATA_KEY_NAME = 'key';
 export const TIME = 'time';
 
-// export function splitTopicExcludingSeparator(topic: string): string[] {
-//   let topix = topic;
-//   topix = topix.trim().replace(/(\/{1,}$)|(^\/{1,})/g, '');
-//   return topix.split(/\//g);
-// }
-
 export function splitTopicExcludingSeparator(topic: string): string[] {
+  let topix = topic;
+  topix = topix.trim().replace(/(\/{1,}$)|(^\/{1,})/g, '');
+  return topix.split(/\//g);
+}
+
+export function splitTopicExcludingSeparatorIncludingLeagingSlash(topic: string): string[] {
   let topix = topic;
   topix = topix.trim().replace(/(\/{1,}$)/g, ''); // Remove trailing slashes
   if (topix.startsWith('//')) {                    // If there are multiple leading slashes

dynamic-mapping-ui/src/mapping/stepper-mapping/mapping-stepper.component.ts

@@ -66,7 +66,7 @@ import {
   expandExternalTemplate,
   isTypeOf,
   reduceSourceTemplate,
-  splitTopicExcludingSeparator
+  splitTopicExcludingSeparatorIncludingLeagingSlash
 } from '../shared/util';
 import { EditSubstitutionComponent } from '../substitution/edit/edit-substitution-modal.component';
 import { SubstitutionRendererComponent } from '../substitution/substitution-grid.component';
@@ -566,7 +566,7 @@ export class MappingStepperComponent implements OnInit, OnDestroy {
         this.mapping
       );
     } else {
-      const levels: string[] = splitTopicExcludingSeparator(
+      const levels: string[] = splitTopicExcludingSeparatorIncludingLeagingSlash(
         this.mapping.mappingTopicSample
       );
       this.targetTemplate = expandExternalTemplate(
@@ -694,7 +694,7 @@ export class MappingStepperComponent implements OnInit, OnDestroy {
   }
 
   private expandTemplates() {
-    const levels: string[] = splitTopicExcludingSeparator(
+    const levels: string[] = splitTopicExcludingSeparatorIncludingLeagingSlash(
       this.mapping.direction == Direction.INBOUND
         ? this.mapping.mappingTopicSample
         : this.mapping.publishTopicSample
@@ -772,7 +772,7 @@ export class MappingStepperComponent implements OnInit, OnDestroy {
       this.sourceTemplate = expandExternalTemplate(
         this.sourceTemplate,
         this.mapping,
-        splitTopicExcludingSeparator(this.mapping.mappingTopicSample)
+        splitTopicExcludingSeparatorIncludingLeagingSlash(this.mapping.mappingTopicSample)
       );
     } else {
       this.sourceTemplate = expandC8YTemplate(
@@ -800,7 +800,7 @@ export class MappingStepperComponent implements OnInit, OnDestroy {
       this.sourceTemplate = expandExternalTemplate(
         this.sourceTemplate,
         this.mapping,
-        splitTopicExcludingSeparator(this.mapping.mappingTopicSample)
+        splitTopicExcludingSeparatorIncludingLeagingSlash(this.mapping.mappingTopicSample)
       );
     } else {
       this.sourceTemplate = expandC8YTemplate(

resources/samples/mappings-INBOUND.json

@@ -12,13 +12,13 @@
     "mappingType": "JSON",
     "substitutions": [
       {
-        "pathSource": "_TOPIC_LEVEL_[0]&\"_\"&_TOPIC_LEVEL_[1]&\"_\"&$substringBefore(_TOPIC_LEVEL_[2],\"_\")",
+        "pathSource": "_TOPIC_LEVEL_[1]&\"_\"&_TOPIC_LEVEL_[2]&\"_\"&$substringBefore(_TOPIC_LEVEL_[3],\"_\")",
         "pathTarget": "_IDENTITY_.externalId",
         "repairStrategy": "DEFAULT",
         "expandArray": false
       },
       {
-        "pathSource": "$substringAfter(_TOPIC_LEVEL_[2],\"_\")",
+        "pathSource": "$substringAfter(_TOPIC_LEVEL_[3],\"_\")",
         "pathTarget": "type",
         "repairStrategy": "DEFAULT",
         "expandArray": false