git.basschouten.com Git - openhab-addons.git/blob

   1 /**
   2  * Copyright (c) 2010-2023 Contributors to the openHAB project
   3  *
   4  * See the NOTICE file(s) distributed with this work for additional
   5  * information.
   6  *
   7  * This program and the accompanying materials are made available under the
   8  * terms of the Eclipse Public License 2.0 which is available at
   9  * http://www.eclipse.org/legal/epl-2.0
  10  *
  11  * SPDX-License-Identifier: EPL-2.0
  12  */
  13 package org.openhab.binding.samsungtv.internal.protocol;
  14
  15 import java.util.stream.Collectors;
  16
  17 import org.eclipse.jdt.annotation.NonNullByDefault;
  18 import org.eclipse.jdt.annotation.Nullable;
  19 import org.openhab.binding.samsungtv.internal.config.SamsungTvConfiguration;
  20 import org.openhab.binding.samsungtv.internal.protocol.RemoteControllerWebSocket.App;
  21 import org.slf4j.Logger;
  22 import org.slf4j.LoggerFactory;
  23
  24 import com.google.gson.JsonSyntaxException;
  25
  26 /**
  27  * Websocket class for remote control
  28  *
  29  * @author Arjan Mels - Initial contribution
  30  */
  31 @NonNullByDefault
  32 class WebSocketRemote extends WebSocketBase {
  33     private final Logger logger = LoggerFactory.getLogger(WebSocketRemote.class);
  34
  35     @SuppressWarnings("unused")
  36     @NonNullByDefault({})
  37     private static class JSONMessage {
  38         String event;
  39
  40         @NonNullByDefault({})
  41         static class App {
  42             String appId;
  43             String name;
  44             int app_type;
  45         }
  46
  47         @NonNullByDefault({})
  48         static class Data {
  49             String update_type;
  50             App[] data;
  51
  52             String id;
  53             String token;
  54         }
  55
  56         Data data;
  57
  58         @NonNullByDefault({})
  59         static class Params {
  60             String params;
  61
  62             @NonNullByDefault({})
  63             static class Data {
  64                 String appId;
  65             }
  66
  67             Data data;
  68         }
  69
  70         Params params;
  71     }
  72
  73     /**
  74      * @param remoteControllerWebSocket
  75      */
  76     WebSocketRemote(RemoteControllerWebSocket remoteControllerWebSocket) {
  77         super(remoteControllerWebSocket);
  78     }
  79
  80     @Override
  81     public void onWebSocketError(@Nullable Throwable error) {
  82         super.onWebSocketError(error);
  83         remoteControllerWebSocket.callback.connectionError(error);
  84     }
  85
  86     @Override
  87     public void onWebSocketText(@Nullable String msgarg) {
  88         if (msgarg == null) {
  89             return;
  90         }
  91         String msg = msgarg.replace('\n', ' ');
  92         super.onWebSocketText(msg);
  93         try {
  94             JSONMessage jsonMsg = remoteControllerWebSocket.gson.fromJson(msg, JSONMessage.class);
  95             switch (jsonMsg.event) {
  96                 case "ms.channel.connect":
  97                     logger.debug("Remote channel connected. Token = {}", jsonMsg.data.token);
  98                     if (jsonMsg.data.token != null) {
  99                         this.remoteControllerWebSocket.callback.putConfig(SamsungTvConfiguration.WEBSOCKET_TOKEN,
 100                                 jsonMsg.data.token);
 101                         // try opening additional websockets
 102                         try {
 103                             this.remoteControllerWebSocket.openConnection();
 104                         } catch (RemoteControllerException e) {
 105                             logger.warn("{}: Error ({})", this.getClass().getSimpleName(), e.getMessage());
 106                         }
 107                     }
 108                     getApps();
 109                     break;
 110                 case "ms.channel.clientConnect":
 111                     logger.debug("Remote client connected");
 112                     break;
 113                 case "ms.channel.clientDisconnect":
 114                     logger.debug("Remote client disconnected");
 115                     break;
 116                 case "ed.edenTV.update":
 117                     logger.debug("edenTV update: {}", jsonMsg.data.update_type);
 118                     remoteControllerWebSocket.updateCurrentApp();
 119                     break;
 120                 case "ed.apps.launch":
 121                     logger.debug("App launched: {}", jsonMsg.params.data.appId);
 122                     break;
 123                 case "ed.installedApp.get":
 124                     handleInstalledApps(jsonMsg);
 125                     break;
 126                 default:
 127                     logger.debug("WebSocketRemote Unknown event: {}", msg);
 128
 129             }
 130         } catch (JsonSyntaxException e) {
 131             logger.warn("{}: Error ({}) in message: {}", this.getClass().getSimpleName(), e.getMessage(), msg, e);
 132         }
 133     }
 134
 135     private void handleInstalledApps(JSONMessage jsonMsg) {
 136         remoteControllerWebSocket.apps.clear();
 137
 138         for (JSONMessage.App jsonApp : jsonMsg.data.data) {
 139             App app = remoteControllerWebSocket.new App(jsonApp.appId, jsonApp.name, jsonApp.app_type);
 140             remoteControllerWebSocket.apps.put(app.name, app);
 141         }
 142         if (logger.isDebugEnabled()) {
 143             logger.debug("Installed Apps: {}", remoteControllerWebSocket.apps.entrySet().stream()
 144                     .map(entry -> entry.getValue().appId + " = " + entry.getKey()).collect(Collectors.joining(", ")));
 145         }
 146
 147         remoteControllerWebSocket.updateCurrentApp();
 148     }
 149
 150     @NonNullByDefault({})
 151     static class JSONAppInfo {
 152         @NonNullByDefault({})
 153         static class Params {
 154             String event = "ed.installedApp.get";
 155             String to = "host";
 156         }
 157
 158         String method = "ms.channel.emit";
 159         Params params = new Params();
 160     }
 161
 162     void getApps() {
 163         sendCommand(remoteControllerWebSocket.gson.toJson(new JSONAppInfo()));
 164     }
 165
 166     @NonNullByDefault({})
 167     static class JSONSourceApp {
 168         public JSONSourceApp(String appName, boolean deepLink) {
 169             this(appName, deepLink, null);
 170         }
 171
 172         public JSONSourceApp(String appName, boolean deepLink, String metaTag) {
 173             params.data.appId = appName;
 174             params.data.action_type = deepLink ? "DEEP_LINK" : "NATIVE_LAUNCH";
 175             params.data.metaTag = metaTag;
 176         }
 177
 178         @NonNullByDefault({})
 179         static class Params {
 180             @NonNullByDefault({})
 181             static class Data {
 182                 String appId;
 183                 String action_type;
 184                 String metaTag;
 185             }
 186
 187             String event = "ed.apps.launch";
 188             String to = "host";
 189             Data data = new Data();
 190         }
 191
 192         String method = "ms.channel.emit";
 193         Params params = new Params();
 194     }
 195
 196     public void sendSourceApp(String appName, boolean deepLink) {
 197         sendCommand(remoteControllerWebSocket.gson.toJson(new JSONSourceApp(appName, deepLink)));
 198     }
 199
 200     public void sendSourceApp(String appName, boolean deepLink, String metaTag) {
 201         sendCommand(remoteControllerWebSocket.gson.toJson(new JSONSourceApp(appName, deepLink, metaTag)));
 202     }
 203
 204     @NonNullByDefault({})
 205     static class JSONRemoteControl {
 206         public JSONRemoteControl(boolean press, String key) {
 207             params.Cmd = press ? "Press" : "Click";
 208             params.DataOfCmd = key;
 209         }
 210
 211         @NonNullByDefault({})
 212         static class Params {
 213             String Cmd;
 214             String DataOfCmd;
 215             String Option = "false";
 216             String TypeOfRemote = "SendRemoteKey";
 217         }
 218
 219         String method = "ms.remote.control";
 220         Params params = new Params();
 221     }
 222
 223     void sendKeyData(boolean press, String key) {
 224         sendCommand(remoteControllerWebSocket.gson.toJson(new JSONRemoteControl(press, key)));
 225     }
 226 }