[miio] sending device in MiIoSendCommand (openhab#11475)

* [miio] sending device in MiIoSendCommand Signed-off-by: Marcel Verpaalen <[email protected]> * [miio] spotless reformatting Signed-off-by: Marcel Verpaalen <[email protected]>
jpg0 · Nov 10, 2021 · 718fe51 · 718fe51
1 parent 50a1d05
commit 718fe51
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 3 deletions.
diff --git a/...openhab.binding.miio/src/main/java/org/openhab/binding/miio/internal/MiIoSendCommand.java b/...openhab.binding.miio/src/main/java/org/openhab/binding/miio/internal/MiIoSendCommand.java
@@ -30,24 +30,27 @@ public class MiIoSendCommand {
     private final int id;
     private final MiIoCommand command;
     private final JsonObject commandJson;
+    private final String sender;
     private @Nullable JsonObject response;
     private String cloudServer = "";
 
     public void setResponse(JsonObject response) {
         this.response = response;
     }
 
-    public MiIoSendCommand(int id, MiIoCommand command, JsonObject fullCommand) {
+    public MiIoSendCommand(int id, MiIoCommand command, JsonObject fullCommand, String sender) {
         this.id = id;
         this.command = command;
         this.commandJson = fullCommand;
+        this.sender = sender;
     }
 
-    public MiIoSendCommand(int id, MiIoCommand command, JsonObject fullCommand, String cloudServer) {
+    public MiIoSendCommand(int id, MiIoCommand command, JsonObject fullCommand, String cloudServer, String sender) {
         this.id = id;
         this.command = command;
         this.commandJson = fullCommand;
         this.cloudServer = cloudServer;
+        this.sender = sender;
     }
 
     public int getId() {
@@ -102,4 +105,8 @@ public String getCloudServer() {
     public void setCloudServer(String cloudServer) {
         this.cloudServer = cloudServer;
     }
+
+    public String getSender() {
+        return sender;
+    }
 }
diff --git a/...iio/src/main/java/org/openhab/binding/miio/internal/transport/MiIoAsyncCommunication.java b/...iio/src/main/java/org/openhab/binding/miio/internal/transport/MiIoAsyncCommunication.java
@@ -148,7 +148,7 @@ public int queueCommand(String command, String params, String cloudServer, Strin
                 fullCommand.add("params", JsonParser.parseString(params));
             }
             MiIoSendCommand sendCmd = new MiIoSendCommand(cmdId, MiIoCommand.getCommand(command), fullCommand,
-                    cloudServer);
+                    cloudServer, sender);
             concurrentLinkedQueue.add(sendCmd);
             if (logger.isDebugEnabled()) {
                 // Obfuscate part of the token to allow sharing of the logfiles