#2096: fix entityId header was added in the wrong format

Author: thjaeckle

things/service/src/main/java/org/eclipse/ditto/things/service/enforcement/ThingEnforcerActor.java

@@ -200,7 +200,8 @@ protected CompletionStage<Signal<?>> performWotBasedSignalValidation(final Signa
             return performWotBasedMessageCommandValidation(messageCommand.setDittoHeaders(
                     DittoHeaders.of(startedSpan.propagateContext(messageCommand.getDittoHeaders()))
                             .toBuilder()
-                            .putHeader(DittoHeaderDefinition.ENTITY_ID.getKey(), entityId.toString())
+                            .putHeader(DittoHeaderDefinition.ENTITY_ID.getKey(),
+                                    entityId.getEntityType() + ":" + entityId)
                             .build()
             )).whenComplete((result, error) -> {
                         if (error instanceof DittoRuntimeException dre) {
@@ -243,7 +244,8 @@ protected CompletionStage<CommandResponse<?>> performWotBasedResponseValidation(
                 messageCommandResponse.setDittoHeaders(
                         DittoHeaders.of(startedSpan.propagateContext(messageCommandResponse.getDittoHeaders()))
                                 .toBuilder()
-                                .putHeader(DittoHeaderDefinition.ENTITY_ID.getKey(), entityId.toString())
+                                .putHeader(DittoHeaderDefinition.ENTITY_ID.getKey(),
+                                        entityId.getEntityType() + ":" + entityId)
                                 .build()
                 )
         )

things/service/src/main/java/org/eclipse/ditto/things/service/persistence/actors/strategies/commands/AbstractThingCommandStrategy.java

@@ -95,8 +95,9 @@ public Result<ThingEvent<?>> apply(final Context<ThingId> context, @Nullable fin
             final long nextRevision, final C command) {
 
         final var dittoHeaders = command.getDittoHeaders();
+        final ThingId thingId = context.getState();
         final var dittoHeadersBuilder = dittoHeaders.toBuilder()
-                .putHeader(DittoHeaderDefinition.ENTITY_ID.getKey(), context.getState().toString());
+                .putHeader(DittoHeaderDefinition.ENTITY_ID.getKey(), thingId.getEntityType() + ":" + thingId);
         final var loggerWithCorrelationId = context.getLog().withCorrelationId(command);
         final var thingConditionFailed = dittoHeaders.getCondition()
                 .flatMap(condition -> ThingConditionValidator.validate(command, condition, entity));

things/service/src/test/java/org/eclipse/ditto/things/service/persistence/actors/ETagTestUtils.java

@@ -367,7 +367,7 @@ protected static DittoHeaders appendEntityIdAndETagToDittoHeaders(final ThingId
             final DittoHeaders dittoHeaders
     ) {
         return dittoHeaders.toBuilder()
-                .putHeader(DittoHeaderDefinition.ENTITY_ID.getKey(), thingId.toString())
+                .putHeader(DittoHeaderDefinition.ENTITY_ID.getKey(), thingId.getEntityType() + ":" + thingId)
                 .eTag(EntityTag.fromEntity(object).get())
                 .build();
     }

things/service/src/test/java/org/eclipse/ditto/things/service/persistence/actors/ThingPersistenceActorCleanupTest.java

@@ -131,8 +131,9 @@ private EventsourcedEvent<?> sendModifyThing(final Thing modifiedThing, final Ac
                                 modifiedThing, null, dittoHeadersV2);
                 underTest.tell(modifyThingCommand, getRef());
 
+                final ThingId thingId = modifiedThing.getEntityId().get();
                 expectMsgEquals(modifyThingResponse(modifiedThing, dittoHeadersV2.toBuilder().putHeader(
-                        DittoHeaderDefinition.ENTITY_ID.getKey(), modifiedThing.getEntityId().get().toString())
+                        DittoHeaderDefinition.ENTITY_ID.getKey(), thingId.getEntityType() + ":" + thingId)
                         .build()
                 ));
 

things/service/src/test/java/org/eclipse/ditto/things/service/persistence/actors/ThingPersistenceActorSnapshottingTest.java

@@ -102,7 +102,7 @@ public void deletedThingIsSnapshotWithCorrectDataAndCanBeRecreated() {
                 final DeleteThing deleteThing = DeleteThing.of(thingId, dittoHeadersV2);
                 underTest.tell(deleteThing, getRef());
                 expectMsgEquals(DeleteThingResponse.of(thingId, dittoHeadersV2.toBuilder()
-                        .putHeader(DittoHeaderDefinition.ENTITY_ID.getKey(), thingId.toString())
+                        .putHeader(DittoHeaderDefinition.ENTITY_ID.getKey(), thingId.getEntityType() + ":" + thingId)
                         .build()));
 
                 final Thing expectedDeletedSnapshot = toDeletedThing(2);

things/service/src/test/java/org/eclipse/ditto/things/service/persistence/actors/ThingPersistenceActorTest.java

@@ -595,8 +595,9 @@ public void deleteThingV2() {
 
                 final DeleteThing deleteThing = DeleteThing.of(getIdOrThrow(thing), dittoHeadersV2);
                 underTest.tell(deleteThing, getRef());
+                final ThingId thingId = thing.getEntityId().get();
                 expectMsgEquals(DeleteThingResponse.of(getIdOrThrow(thing), dittoHeadersV2.toBuilder()
-                        .putHeader(DittoHeaderDefinition.ENTITY_ID.getKey(), thing.getEntityId().get().toString())
+                        .putHeader(DittoHeaderDefinition.ENTITY_ID.getKey(), thingId.getEntityType() + ":" + thingId)
                         .build()));
             }
         };
@@ -623,7 +624,7 @@ public void deleteAndRecreateThingWithMinimumData() {
                 final DeleteThing deleteThing = DeleteThing.of(thingId, dittoHeadersV2);
                 underTest.tell(deleteThing, getRef());
                 expectMsgEquals(DeleteThingResponse.of(thingId, dittoHeadersV2.toBuilder()
-                        .putHeader(DittoHeaderDefinition.ENTITY_ID.getKey(), thingId.toString())
+                        .putHeader(DittoHeaderDefinition.ENTITY_ID.getKey(), thingId.getEntityType() + ":" + thingId)
                         .build()));
 
                 final Thing minimalThing = Thing.newBuilder()
@@ -839,7 +840,7 @@ public void deleteAttribute() {
                 final ThingCommand authorizedCommand = DeleteAttribute.of(thingId, attributeKey, dittoHeadersV2);
                 underTest.tell(authorizedCommand, getRef());
                 expectMsgEquals(DeleteAttributeResponse.of(thingId, attributeKey, dittoHeadersV2.toBuilder()
-                        .putHeader(DittoHeaderDefinition.ENTITY_ID.getKey(), thingId.toString())
+                        .putHeader(DittoHeaderDefinition.ENTITY_ID.getKey(), thingId.getEntityType() + ":" + thingId)
                         .build()));
             }
         };
@@ -864,7 +865,7 @@ public void tryToRetrieveThingAfterDeletion() {
 
                 underTest.tell(deleteThingCommand, getRef());
                 expectMsgEquals(DeleteThingResponse.of(thingId, dittoHeadersV2.toBuilder()
-                        .putHeader(DittoHeaderDefinition.ENTITY_ID.getKey(), thingId.toString())
+                        .putHeader(DittoHeaderDefinition.ENTITY_ID.getKey(), thingId.getEntityType() + ":" + thingId)
                         .build()));
 
                 underTest.tell(retrieveThingCommand, getRef());
@@ -926,7 +927,7 @@ public void recoverThingDeleted() {
                 final DeleteThing deleteThing = DeleteThing.of(thingId, dittoHeadersV2);
                 underTest.tell(deleteThing, getRef());
                 expectMsgEquals(DeleteThingResponse.of(thingId, dittoHeadersV2.toBuilder()
-                        .putHeader(DittoHeaderDefinition.ENTITY_ID.getKey(), thingId.toString())
+                        .putHeader(DittoHeaderDefinition.ENTITY_ID.getKey(), thingId.getEntityType() + ":" + thingId)
                         .build()));
 
                 // restart actor to recover thing state

things/service/src/test/java/org/eclipse/ditto/things/service/persistence/actors/strategies/commands/AbstractCommandStrategyTest.java

@@ -179,8 +179,9 @@ protected static <C extends Command<?>> void assertUnhandledResult(
     }
 
     protected static DittoHeaders provideHeaders(final CommandStrategy.Context<ThingId> context) {
+        final ThingId thingId = context.getState();
         return DittoHeaders.newBuilder()
-                .putHeader(DittoHeaderDefinition.ENTITY_ID.getKey(), context.getState().toString())
+                .putHeader(DittoHeaderDefinition.ENTITY_ID.getKey(), thingId.getEntityType() + ":" + thingId)
                 .build();
     }
 

wot/validation/src/main/java/org/eclipse/ditto/wot/validation/ValidationContext.java

@@ -54,7 +54,9 @@ public static ValidationContext buildValidationContext(final DittoHeaders dittoH
     }
 
     private static Optional<ThingId> extractThingId(final DittoHeaders dittoHeaders) {
-        return Optional.ofNullable(dittoHeaders.get(DittoHeaderDefinition.ENTITY_ID.getKey()))
+        final String nullableEntityId = dittoHeaders.get(DittoHeaderDefinition.ENTITY_ID.getKey());
+        return Optional.ofNullable(nullableEntityId)
+                .map(entityId -> entityId.substring(entityId.indexOf(":") + 1)) // starts with "thing:" - cut that off!
                 .map(ThingId::of);
     }
 }