Allow characteristic setters to get the username of the triggering connection

Author: ccutrer

CHANGES.md

@@ -1,3 +1,6 @@
+# HAP-Java 2.0.7
+* Add overloads to characteristics so that the username can be passed through.
+
 # HAP-Java 2.0.6
 * Several methods allowing library users to manipulate characteristics themselves
 * Allow library users to provider their own implementation of AccessoryInformationService

src/main/java/io/github/hapjava/characteristics/Characteristic.java

@@ -44,4 +44,14 @@ public interface Characteristic {
    * @param jsonValue the JSON serialized value to set.
    */
   void setValue(JsonValue jsonValue);
+
+  /**
+   * Invoked by the remote client, this updates the current value of the characteristic.
+   *
+   * @param jsonValue the JSON serialized value to set.
+   * @param username the authenticated username making the request
+   */
+  default void setValue(JsonValue jsonValue, String username) {
+    setValue(jsonValue);
+  }
 }

src/main/java/io/github/hapjava/characteristics/ExceptionalConsumer.java

@@ -2,4 +2,8 @@
 
 public interface ExceptionalConsumer<T> {
   void accept(T t) throws Exception;
+
+  default void accept(T t, String username) throws Exception {
+    accept(t);
+  }
 }

src/main/java/io/github/hapjava/characteristics/impl/base/BaseCharacteristic.java

@@ -128,13 +128,20 @@ protected CompletableFuture<JsonObjectBuilder> makeBuilder(int instanceId) {
   /** {@inheritDoc} */
   @Override
   public final void setValue(JsonValue jsonValue) {
+    setValue(jsonValue, null);
+  }
+
+  /** {@inheritDoc} */
+  @Override
+  public final void setValue(JsonValue jsonValue, String username) {
     try {
-      setValue(convert(jsonValue));
+      setValue(convert(jsonValue), username);
     } catch (Exception e) {
       logger.warn(
-          "Error while setting JSON value {} for characteristic {}",
+          "Error while setting JSON value {} for characteristic {} from user {}",
           jsonValue,
           getClass().getName(),
+          username,
           e);
     }
   }
@@ -185,6 +192,17 @@ public void unsubscribe() {
    */
   public abstract void setValue(T value) throws Exception;
 
+  /**
+   * Update the characteristic value using a new value supplied by the connected client.
+   *
+   * @param value the new value to set.
+   * @param username the authenticated username making the request
+   * @throws Exception if the value cannot be set.
+   */
+  public void setValue(T value, String username) throws Exception {
+    setValue(value);
+  }
+
   /**
    * Retrieves the current value of the characteristic.
    *

src/main/java/io/github/hapjava/characteristics/impl/base/BooleanCharacteristic.java

@@ -66,7 +66,12 @@ public CompletableFuture<Boolean> getValue() {
 
   @Override
   public void setValue(Boolean value) throws Exception {
-    if (setter.isPresent()) setter.get().accept(value);
+    setValue(value, null);
+  }
+
+  @Override
+  public void setValue(Boolean value, String username) throws Exception {
+    if (setter.isPresent()) setter.get().accept(value, username);
   }
 
   /** {@inheritDoc} */

src/main/java/io/github/hapjava/characteristics/impl/base/EnumCharacteristic.java

@@ -113,15 +113,24 @@ public CompletableFuture<Integer> getValue() {
   }
 
   public void setValue(T value) throws Exception {
+    setValue(value, null);
+  }
+
+  public void setValue(T value, String username) throws Exception {
     if (!setter.isPresent()) {
       return;
     }
 
-    setter.get().accept(value);
+    setter.get().accept(value, username);
   }
 
   @Override
   public void setValue(Integer value) throws Exception {
+    setValue(value, null);
+  }
+
+  @Override
+  public void setValue(Integer value, String username) throws Exception {
     if (!setter.isPresent()) {
       return;
     }
@@ -130,7 +139,7 @@ public void setValue(Integer value) throws Exception {
     if (validValues != null && value != null) {
       for (T valid : validValues) {
         if (valid.getCode() == value) {
-          setValue(valid);
+          setValue(valid, username);
           return;
         }
       }

src/main/java/io/github/hapjava/characteristics/impl/base/FloatCharacteristic.java

@@ -130,7 +130,12 @@ public final CompletableFuture<Double> getValue() {
 
   @Override
   public void setValue(Double value) throws Exception {
-    if (setter.isPresent()) setter.get().accept(value);
+    setValue(value, null);
+  }
+
+  @Override
+  public void setValue(Double value, String username) throws Exception {
+    if (setter.isPresent()) setter.get().accept(value, username);
   }
 
   /** {@inheritDoc} */

src/main/java/io/github/hapjava/characteristics/impl/base/IntegerCharacteristic.java

@@ -77,7 +77,12 @@ public CompletableFuture<Integer> getValue() {
 
   @Override
   public void setValue(Integer value) throws Exception {
-    if (setter.isPresent()) setter.get().accept(value);
+    setValue(value, null);
+  }
+
+  @Override
+  public void setValue(Integer value, String username) throws Exception {
+    if (setter.isPresent()) setter.get().accept(value, username);
   }
 
   /** {@inheritDoc} */

src/main/java/io/github/hapjava/characteristics/impl/base/StringCharacteristic.java

@@ -63,7 +63,13 @@ public String convert(JsonValue jsonValue) {
   /** {@inheritDoc} */
   @Override
   public void setValue(String value) throws Exception {
-    if (setter.isPresent()) setter.get().accept(value);
+    setValue(value, null);
+  }
+
+  /** {@inheritDoc} */
+  @Override
+  public void setValue(String value, String username) throws Exception {
+    if (setter.isPresent()) setter.get().accept(value, username);
   }
 
   /** {@inheritDoc} */

src/main/java/io/github/hapjava/server/impl/HomekitServer.java

@@ -117,13 +117,15 @@ public HomekitStandaloneAccessoryServer createStandaloneAccessory(
       return new HomekitStandaloneAccessoryServer(accessory, http, localAddress, authInfo);
     }
   }
+
   public HomekitStandaloneAccessoryServer createStandaloneAccessory(
       HomekitAuthInfo authInfo, HomekitAccessory accessory, int category)
       throws IOException, ExecutionException, InterruptedException {
     if (jmdns != null) {
       return new HomekitStandaloneAccessoryServer(accessory, http, jmdns, authInfo, category);
     } else {
-      return new HomekitStandaloneAccessoryServer(accessory, http, localAddress, authInfo, category);
+      return new HomekitStandaloneAccessoryServer(
+          accessory, http, localAddress, authInfo, category);
     }
   }