Pass event source to profiles

So that a user can define a profile that takes different
actions depending on what's generating the command.

Signed-off-by: Cody Cutrer <cody@cutrer.us>

Author: ccutrer

bundles/org.openhab.core.thing/src/main/java/org/openhab/core/thing/internal/CommunicationManager.java

@@ -346,10 +346,10 @@ private void receiveUpdate(ItemStateUpdatedEvent updateEvent) {
 
     @FunctionalInterface
     private interface ProfileAction<T extends Type> {
-        void applyProfile(Profile profile, Thing thing, T type);
+        void applyProfile(Profile profile, Thing thing, T type, @Nullable String source);
     }
 
-    private void applyProfileForUpdate(Profile profile, Thing thing, State convertedState) {
+    private void applyProfileForUpdate(Profile profile, Thing thing, State convertedState, @Nullable String source) {
         CacheKey key = new CacheKey("UPDATE", profile, thing);
         Profile p = profileSafeCallCache.computeIfAbsent(key, (k) -> safeCaller.create(k.profile, Profile.class) //
                 .withAsync() //
@@ -363,7 +363,8 @@ private void applyProfileForUpdate(Profile profile, Thing thing, State converted
         }
     }
 
-    private void applyProfileForCommand(Profile profile, Thing thing, Command convertedCommand) {
+    private void applyProfileForCommand(Profile profile, Thing thing, Command convertedCommand,
+            @Nullable String source) {
         if (profile instanceof StateProfile) {
             CacheKey key = new CacheKey("COMMAND", profile, thing);
             Profile p = profileSafeCallCache.computeIfAbsent(key,
@@ -373,7 +374,7 @@ private void applyProfileForCommand(Profile profile, Thing thing, Command conver
                             .withTimeout(THINGHANDLER_EVENT_TIMEOUT) //
                             .build());
             if (p instanceof StateProfile profileP) {
-                profileP.onCommandFromItem(convertedCommand);
+                profileP.onCommandFromItem(convertedCommand, source);
             } else {
                 throw new IllegalStateException("ExpiringCache didn't provide a StateProfile instance!");
             }
@@ -404,7 +405,7 @@ private <T extends Type> void handleEvent(String itemName, T type, @Nullable Str
                         @Nullable
                         T uomType = fixUoM(type, channel, item);
                         Profile profile = getProfile(link, item, thing);
-                        action.applyProfile(profile, thing, uomType != null ? uomType : type);
+                        action.applyProfile(profile, thing, uomType != null ? uomType : type, source);
                     }
                 } else {
                     logger.debug("Received  event '{}' for non-existing channel '{}', not forwarding it to the handler",

bundles/org.openhab.core.thing/src/main/java/org/openhab/core/thing/profiles/StateProfile.java

@@ -13,6 +13,7 @@
 package org.openhab.core.thing.profiles;
 
 import org.eclipse.jdt.annotation.NonNullByDefault;
+import org.eclipse.jdt.annotation.Nullable;
 import org.openhab.core.types.Command;
 import org.openhab.core.types.State;
 
@@ -31,6 +32,16 @@ public interface StateProfile extends Profile {
      */
     void onCommandFromItem(Command command);
 
+    /**
+     * Will be called if a command should be forwarded to the binding.
+     *
+     * @param command
+     * @param source the source of the command event
+     */
+    default void onCommandFromItem(Command command, @Nullable String source) {
+        onCommandFromItem(command);
+    }
+
     /**
      * If a binding issued a command to a channel, this method will be called for each linked item.
      *

itests/org.openhab.core.thing.tests/src/main/java/org/openhab/core/thing/internal/CommunicationManagerOSGiTest.java

@@ -301,9 +301,9 @@ public void testTimeSeriesMultiLink() {
 
     @Test
     public void testItemCommandEventSingleLink() {
-        manager.receive(ItemEventFactory.createCommandEvent(ITEM_NAME_2, OnOffType.ON));
+        manager.receive(ItemEventFactory.createCommandEvent(ITEM_NAME_2, OnOffType.ON, "mysource"));
         waitForAssert(() -> {
-            verify(stateProfileMock).onCommandFromItem(eq(OnOffType.ON));
+            verify(stateProfileMock).onCommandFromItem(eq(OnOffType.ON), eq("mysource"));
         });
         verifyNoMoreInteractions(stateProfileMock);
         verifyNoMoreInteractions(triggerProfileMock);