2 * Copyright (c) 2010-2020 Contributors to the openHAB project
4 * See the NOTICE file(s) distributed with this work for additional
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
11 * SPDX-License-Identifier: EPL-2.0
13 package org.openhab.binding.insteon.internal.handler;
15 import java.lang.reflect.Type;
16 import java.math.BigDecimal;
17 import java.util.ArrayList;
18 import java.util.Collections;
19 import java.util.HashMap;
20 import java.util.HashSet;
21 import java.util.List;
24 import java.util.stream.Collectors;
25 import java.util.stream.Stream;
27 import org.eclipse.jdt.annotation.NonNullByDefault;
28 import org.eclipse.jdt.annotation.Nullable;
29 import org.openhab.binding.insteon.internal.InsteonBinding;
30 import org.openhab.binding.insteon.internal.InsteonBindingConstants;
31 import org.openhab.binding.insteon.internal.config.InsteonChannelConfiguration;
32 import org.openhab.binding.insteon.internal.config.InsteonDeviceConfiguration;
33 import org.openhab.binding.insteon.internal.device.DeviceFeature;
34 import org.openhab.binding.insteon.internal.device.DeviceTypeLoader;
35 import org.openhab.binding.insteon.internal.device.InsteonAddress;
36 import org.openhab.binding.insteon.internal.device.InsteonDevice;
37 import org.openhab.core.thing.Bridge;
38 import org.openhab.core.thing.Channel;
39 import org.openhab.core.thing.ChannelUID;
40 import org.openhab.core.thing.Thing;
41 import org.openhab.core.thing.ThingStatus;
42 import org.openhab.core.thing.ThingStatusDetail;
43 import org.openhab.core.thing.binding.BaseThingHandler;
44 import org.openhab.core.thing.binding.ThingHandlerCallback;
45 import org.openhab.core.thing.type.ChannelTypeUID;
46 import org.openhab.core.types.Command;
47 import org.slf4j.Logger;
48 import org.slf4j.LoggerFactory;
50 import com.google.gson.Gson;
51 import com.google.gson.JsonParseException;
52 import com.google.gson.reflect.TypeToken;
55 * The {@link InsteonDeviceHandler} is responsible for handling commands, which are
56 * sent to one of the channels.
58 * @author Rob Nielsen - Initial contribution
61 public class InsteonDeviceHandler extends BaseThingHandler {
63 private static final Set<String> ALL_CHANNEL_IDS = Collections.unmodifiableSet(Stream.of(
64 InsteonBindingConstants.AC_DELAY, InsteonBindingConstants.BACKLIGHT_DURATION,
65 InsteonBindingConstants.BATTERY_LEVEL, InsteonBindingConstants.BATTERY_PERCENT,
66 InsteonBindingConstants.BATTERY_WATERMARK_LEVEL, InsteonBindingConstants.BEEP,
67 InsteonBindingConstants.BOTTOM_OUTLET, InsteonBindingConstants.BUTTON_A, InsteonBindingConstants.BUTTON_B,
68 InsteonBindingConstants.BUTTON_C, InsteonBindingConstants.BUTTON_D, InsteonBindingConstants.BUTTON_E,
69 InsteonBindingConstants.BUTTON_F, InsteonBindingConstants.BUTTON_G, InsteonBindingConstants.BUTTON_H,
70 InsteonBindingConstants.BROADCAST_ON_OFF, InsteonBindingConstants.CONTACT,
71 InsteonBindingConstants.COOL_SET_POINT, InsteonBindingConstants.DIMMER, InsteonBindingConstants.FAN,
72 InsteonBindingConstants.FAN_MODE, InsteonBindingConstants.FAST_ON_OFF,
73 InsteonBindingConstants.FAST_ON_OFF_BUTTON_A, InsteonBindingConstants.FAST_ON_OFF_BUTTON_B,
74 InsteonBindingConstants.FAST_ON_OFF_BUTTON_C, InsteonBindingConstants.FAST_ON_OFF_BUTTON_D,
75 InsteonBindingConstants.FAST_ON_OFF_BUTTON_E, InsteonBindingConstants.FAST_ON_OFF_BUTTON_F,
76 InsteonBindingConstants.FAST_ON_OFF_BUTTON_G, InsteonBindingConstants.FAST_ON_OFF_BUTTON_H,
77 InsteonBindingConstants.HEAT_SET_POINT, InsteonBindingConstants.HUMIDITY,
78 InsteonBindingConstants.HUMIDITY_HIGH, InsteonBindingConstants.HUMIDITY_LOW,
79 InsteonBindingConstants.IS_COOLING, InsteonBindingConstants.IS_HEATING,
80 InsteonBindingConstants.KEYPAD_BUTTON_A, InsteonBindingConstants.KEYPAD_BUTTON_B,
81 InsteonBindingConstants.KEYPAD_BUTTON_C, InsteonBindingConstants.KEYPAD_BUTTON_D,
82 InsteonBindingConstants.KEYPAD_BUTTON_E, InsteonBindingConstants.KEYPAD_BUTTON_F,
83 InsteonBindingConstants.KEYPAD_BUTTON_G, InsteonBindingConstants.KEYPAD_BUTTON_H,
84 InsteonBindingConstants.KWH, InsteonBindingConstants.LAST_HEARD_FROM,
85 InsteonBindingConstants.LED_BRIGHTNESS, InsteonBindingConstants.LED_ONOFF,
86 InsteonBindingConstants.LIGHT_DIMMER, InsteonBindingConstants.LIGHT_LEVEL,
87 InsteonBindingConstants.LIGHT_LEVEL_ABOVE_THRESHOLD, InsteonBindingConstants.LOAD_DIMMER,
88 InsteonBindingConstants.LOAD_SWITCH, InsteonBindingConstants.LOAD_SWITCH_FAST_ON_OFF,
89 InsteonBindingConstants.LOAD_SWITCH_MANUAL_CHANGE, InsteonBindingConstants.LOWBATTERY,
90 InsteonBindingConstants.MANUAL_CHANGE, InsteonBindingConstants.MANUAL_CHANGE_BUTTON_A,
91 InsteonBindingConstants.MANUAL_CHANGE_BUTTON_B, InsteonBindingConstants.MANUAL_CHANGE_BUTTON_C,
92 InsteonBindingConstants.MANUAL_CHANGE_BUTTON_D, InsteonBindingConstants.MANUAL_CHANGE_BUTTON_E,
93 InsteonBindingConstants.MANUAL_CHANGE_BUTTON_F, InsteonBindingConstants.MANUAL_CHANGE_BUTTON_G,
94 InsteonBindingConstants.MANUAL_CHANGE_BUTTON_H, InsteonBindingConstants.NOTIFICATION,
95 InsteonBindingConstants.ON_LEVEL, InsteonBindingConstants.RAMP_DIMMER, InsteonBindingConstants.RAMP_RATE,
96 InsteonBindingConstants.RESET, InsteonBindingConstants.STAGE1_DURATION, InsteonBindingConstants.SWITCH,
97 InsteonBindingConstants.SYSTEM_MODE, InsteonBindingConstants.TAMPER_SWITCH,
98 InsteonBindingConstants.TEMPERATURE, InsteonBindingConstants.TEMPERATURE_LEVEL,
99 InsteonBindingConstants.TOP_OUTLET, InsteonBindingConstants.UPDATE, InsteonBindingConstants.WATTS)
100 .collect(Collectors.toSet()));
102 public static final String BROADCAST_GROUPS = "broadcastGroups";
103 public static final String BROADCAST_ON_OFF = "broadcastonoff";
104 public static final String CMD = "cmd";
105 public static final String CMD_RESET = "reset";
106 public static final String CMD_UPDATE = "update";
107 public static final String DATA = "data";
108 public static final String FIELD = "field";
109 public static final String FIELD_BATTERY_LEVEL = "battery_level";
110 public static final String FIELD_BATTERY_PERCENTAGE = "battery_percentage";
111 public static final String FIELD_BATTERY_WATERMARK_LEVEL = "battery_watermark_level";
112 public static final String FIELD_KWH = "kwh";
113 public static final String FIELD_LIGHT_LEVEL = "light_level";
114 public static final String FIELD_TEMPERATURE_LEVEL = "temperature_level";
115 public static final String FIELD_WATTS = "watts";
116 public static final String GROUP = "group";
117 public static final String METER = "meter";
119 public static final String HIDDEN_DOOR_SENSOR_PRODUCT_KEY = "F00.00.03";
120 public static final String MOTION_SENSOR_II_PRODUCT_KEY = "F00.00.24";
121 public static final String MOTION_SENSOR_PRODUCT_KEY = "0x00004A";
122 public static final String PLM_PRODUCT_KEY = "0x000045";
123 public static final String POWER_METER_PRODUCT_KEY = "F00.00.17";
125 private final Logger logger = LoggerFactory.getLogger(InsteonDeviceHandler.class);
127 private @Nullable InsteonDeviceConfiguration config;
129 public InsteonDeviceHandler(Thing thing) {
134 public void initialize() {
135 config = getConfigAs(InsteonDeviceConfiguration.class);
137 scheduler.execute(() -> {
138 if (getBridge() == null) {
139 String msg = "An Insteon network bridge has not been selected for this device.";
140 logger.warn("{} {}", thing.getUID().getAsString(), msg);
142 updateStatus(ThingStatus.OFFLINE, ThingStatusDetail.CONFIGURATION_ERROR, msg);
146 InsteonDeviceConfiguration config = this.config;
147 if (config == null) {
148 String msg = "Insteon device configuration is null.";
149 logger.warn("{} {}", thing.getUID().getAsString(), msg);
151 updateStatus(ThingStatus.OFFLINE, ThingStatusDetail.CONFIGURATION_ERROR, msg);
154 String address = config.getAddress();
155 if (!InsteonAddress.isValid(address)) {
156 String msg = "Unable to start Insteon device, the insteon or X10 address '" + address
157 + "' is invalid. It must be in the format 'AB.CD.EF' or 'H.U' (X10).";
158 logger.warn("{} {}", thing.getUID().getAsString(), msg);
160 updateStatus(ThingStatus.OFFLINE, ThingStatusDetail.CONFIGURATION_ERROR, msg);
164 DeviceTypeLoader instance = DeviceTypeLoader.instance();
165 if (instance == null) {
166 String msg = "Device type loader is null.";
167 logger.warn("{} {}", thing.getUID().getAsString(), msg);
169 updateStatus(ThingStatus.OFFLINE, ThingStatusDetail.CONFIGURATION_ERROR, msg);
173 String productKey = config.getProductKey();
174 if (instance.getDeviceType(productKey) == null) {
175 String msg = "Unable to start Insteon device, invalid product key '" + productKey + "'.";
176 logger.warn("{} {}", thing.getUID().getAsString(), msg);
178 updateStatus(ThingStatus.OFFLINE, ThingStatusDetail.CONFIGURATION_ERROR, msg);
182 String deviceConfig = config.getDeviceConfig();
183 Map<String, Object> deviceConfigMap;
184 if (deviceConfig != null) {
185 Type mapType = new TypeToken<Map<String, Object>>() {
188 deviceConfigMap = new Gson().fromJson(deviceConfig, mapType);
189 } catch (JsonParseException e) {
190 String msg = "The device configuration parameter is not valid JSON.";
191 logger.warn("{} {}", thing.getUID().getAsString(), msg);
193 updateStatus(ThingStatus.OFFLINE, ThingStatusDetail.CONFIGURATION_ERROR, msg);
197 deviceConfigMap = Collections.emptyMap();
200 InsteonBinding insteonBinding = getInsteonBinding();
201 InsteonAddress insteonAddress = new InsteonAddress(address);
202 if (insteonBinding.getDevice(insteonAddress) != null) {
203 String msg = "A device already exists with the address '" + address + "'.";
204 logger.warn("{} {}", thing.getUID().getAsString(), msg);
206 updateStatus(ThingStatus.OFFLINE, ThingStatusDetail.CONFIGURATION_ERROR, msg);
210 InsteonDevice device = insteonBinding.makeNewDevice(insteonAddress, productKey, deviceConfigMap);
211 if (device == null) {
212 String msg = "Unable to create a device with the product key '" + productKey + "' with the address'"
214 logger.warn("{} {}", thing.getUID().getAsString(), msg);
216 updateStatus(ThingStatus.OFFLINE, ThingStatusDetail.CONFIGURATION_ERROR, msg);
220 ThingHandlerCallback callback = getCallback();
221 if (callback == null) {
222 String msg = "Unable to get thing handler callback.";
223 logger.warn("{} {}", thing.getUID().getAsString(), msg);
225 updateStatus(ThingStatus.OFFLINE, ThingStatusDetail.CONFIGURATION_ERROR, msg);
229 StringBuilder channelList = new StringBuilder();
230 List<Channel> channels = new ArrayList<>();
231 String thingId = getThing().getUID().getAsString();
232 for (String channelId : ALL_CHANNEL_IDS) {
233 String feature = channelId.toLowerCase();
235 if (productKey.equals(HIDDEN_DOOR_SENSOR_PRODUCT_KEY)) {
236 if (feature.equalsIgnoreCase(InsteonBindingConstants.BATTERY_LEVEL)
237 || feature.equalsIgnoreCase(InsteonBindingConstants.BATTERY_WATERMARK_LEVEL)) {
240 } else if (productKey.equals(MOTION_SENSOR_PRODUCT_KEY)) {
241 if (feature.equalsIgnoreCase(InsteonBindingConstants.BATTERY_LEVEL)
242 || feature.equalsIgnoreCase(InsteonBindingConstants.LIGHT_LEVEL)) {
245 } else if (productKey.equals(MOTION_SENSOR_II_PRODUCT_KEY)) {
246 if (feature.equalsIgnoreCase(InsteonBindingConstants.BATTERY_LEVEL)
247 || feature.equalsIgnoreCase(InsteonBindingConstants.BATTERY_PERCENT)
248 || feature.equalsIgnoreCase(InsteonBindingConstants.LIGHT_LEVEL)
249 || feature.equalsIgnoreCase(InsteonBindingConstants.TEMPERATURE_LEVEL)) {
252 } else if (productKey.equals(PLM_PRODUCT_KEY)) {
253 String parts[] = feature.split("#");
254 if (parts.length == 2 && parts[0].equalsIgnoreCase(InsteonBindingConstants.BROADCAST_ON_OFF)
255 && parts[1].matches("^\\d+$")) {
256 feature = BROADCAST_ON_OFF;
258 } else if (productKey.equals(POWER_METER_PRODUCT_KEY)) {
259 if (feature.equalsIgnoreCase(InsteonBindingConstants.KWH)
260 || feature.equalsIgnoreCase(InsteonBindingConstants.RESET)
261 || feature.equalsIgnoreCase(InsteonBindingConstants.UPDATE)
262 || feature.equalsIgnoreCase(InsteonBindingConstants.WATTS)) {
267 DeviceFeature f = device.getFeature(feature);
269 if (!f.isFeatureGroup()) {
270 if (channelId.equals(InsteonBindingConstants.BROADCAST_ON_OFF)) {
271 Set<String> broadcastChannels = new HashSet<>();
272 for (Channel channel : thing.getChannels()) {
273 String id = channel.getUID().getId();
274 if (id.startsWith(InsteonBindingConstants.BROADCAST_ON_OFF)) {
275 addChannel(channel, id, channels, channelList);
276 broadcastChannels.add(id);
280 Object groups = deviceConfigMap.get(BROADCAST_GROUPS);
281 if (groups != null) {
282 boolean valid = false;
283 if (groups instanceof List<?>) {
285 for (Object o : (List<?>) groups) {
286 if (o instanceof Double && (Double) o % 1 == 0) {
287 String id = InsteonBindingConstants.BROADCAST_ON_OFF + "#"
288 + ((Double) o).intValue();
289 if (!broadcastChannels.contains(id)) {
290 ChannelUID channelUID = new ChannelUID(thing.getUID(), id);
291 ChannelTypeUID channelTypeUID = new ChannelTypeUID(
292 InsteonBindingConstants.BINDING_ID,
293 InsteonBindingConstants.SWITCH);
294 Channel channel = callback
295 .createChannelBuilder(channelUID, channelTypeUID).withLabel(id)
298 addChannel(channel, id, channels, channelList);
299 broadcastChannels.add(id);
309 String msg = "The value for key " + BROADCAST_GROUPS
310 + " must be an array of integers in the device configuration parameter.";
311 logger.warn("{} {}", thing.getUID().getAsString(), msg);
313 updateStatus(ThingStatus.OFFLINE, ThingStatusDetail.CONFIGURATION_ERROR, msg);
318 ChannelUID channelUID = new ChannelUID(thing.getUID(), channelId);
319 ChannelTypeUID channelTypeUID = new ChannelTypeUID(InsteonBindingConstants.BINDING_ID,
321 Channel channel = thing.getChannel(channelUID);
322 if (channel == null) {
323 channel = callback.createChannelBuilder(channelUID, channelTypeUID).build();
326 addChannel(channel, channelId, channels, channelList);
329 logger.debug("{} is a feature group for {}. It will not be added as a channel.", feature,
335 if (!channels.isEmpty() || device.isModem()) {
336 if (!channels.isEmpty()) {
337 updateThing(editThing().withChannels(channels).build());
340 StringBuilder builder = new StringBuilder(thingId);
341 builder.append(" address = ");
342 builder.append(address);
343 builder.append(" productKey = ");
344 builder.append(productKey);
345 builder.append(" channels = ");
346 builder.append(channelList.toString());
347 String msg = builder.toString();
348 logger.debug("{}", msg);
350 getInsteonNetworkHandler().initialized(getThing().getUID(), msg);
352 channels.forEach(channel -> {
353 if (isLinked(channel.getUID())) {
354 channelLinked(channel.getUID());
358 updateStatus(ThingStatus.ONLINE);
360 String msg = "Product key '" + productKey
361 + "' does not have any features that match existing channels.";
363 logger.warn("{} {}", thing.getUID().getAsString(), msg);
365 updateStatus(ThingStatus.OFFLINE, ThingStatusDetail.CONFIGURATION_ERROR, msg);
370 private void addChannel(Channel channel, String channelId, List<Channel> channels, StringBuilder channelList) {
371 channels.add(channel);
373 if (channelList.length() > 0) {
374 channelList.append(", ");
376 channelList.append(channelId);
380 public void dispose() {
381 InsteonDeviceConfiguration config = this.config;
382 if (config != null) {
383 String address = config.getAddress();
384 if (getBridge() != null && InsteonAddress.isValid(address)) {
385 getInsteonBinding().removeDevice(new InsteonAddress(address));
387 logger.debug("removed {} address = {}", getThing().getUID().getAsString(), address);
390 getInsteonNetworkHandler().disposed(getThing().getUID());
397 public void handleCommand(ChannelUID channelUID, Command command) {
398 logger.debug("channel {} was triggered with the command {}", channelUID.getAsString(), command);
400 getInsteonBinding().sendCommand(channelUID.getAsString(), command);
404 public void channelLinked(ChannelUID channelUID) {
405 if (getInsteonNetworkHandler().isChannelLinked(channelUID)) {
409 Map<String, String> params = new HashMap<>();
410 Channel channel = getThing().getChannel(channelUID.getId());
411 if (channel == null) {
412 logger.warn("channel is null");
416 Map<String, Object> channelProperties = channel.getConfiguration().getProperties();
417 for (String key : channelProperties.keySet()) {
418 Object value = channelProperties.get(key);
419 if (value instanceof String) {
420 params.put(key, (String) value);
421 } else if (value instanceof BigDecimal) {
422 String s = ((BigDecimal) value).toPlainString();
425 logger.warn("not a string or big decimal value key '{}' value '{}' {}", key, value,
426 value != null ? value.getClass().getName() : "unknown");
430 String feature = channelUID.getId().toLowerCase();
431 InsteonDeviceConfiguration config = this.config;
432 if (config == null) {
433 logger.warn("insteon device config is null");
436 String productKey = config.getProductKey();
437 if (productKey.equals(HIDDEN_DOOR_SENSOR_PRODUCT_KEY)) {
438 if (feature.equalsIgnoreCase(InsteonBindingConstants.BATTERY_LEVEL)) {
439 params.put(FIELD, FIELD_BATTERY_LEVEL);
441 } else if (feature.equalsIgnoreCase(InsteonBindingConstants.BATTERY_WATERMARK_LEVEL)) {
442 params.put(FIELD, FIELD_BATTERY_WATERMARK_LEVEL);
445 } else if (productKey.equals(MOTION_SENSOR_PRODUCT_KEY)) {
446 if (feature.equalsIgnoreCase(InsteonBindingConstants.BATTERY_LEVEL)) {
447 params.put(FIELD, FIELD_BATTERY_LEVEL);
449 } else if (feature.equalsIgnoreCase(InsteonBindingConstants.LIGHT_LEVEL)) {
450 params.put(FIELD, FIELD_LIGHT_LEVEL);
453 } else if (productKey.equals(MOTION_SENSOR_II_PRODUCT_KEY)) {
454 if (feature.equalsIgnoreCase(InsteonBindingConstants.BATTERY_LEVEL)) {
455 params.put(FIELD, FIELD_BATTERY_LEVEL);
457 } else if (feature.equalsIgnoreCase(InsteonBindingConstants.BATTERY_PERCENT)) {
458 params.put(FIELD, FIELD_BATTERY_PERCENTAGE);
460 } else if (feature.equalsIgnoreCase(InsteonBindingConstants.LIGHT_LEVEL)) {
461 params.put(FIELD, FIELD_LIGHT_LEVEL);
463 } else if (feature.equalsIgnoreCase(InsteonBindingConstants.TEMPERATURE_LEVEL)) {
464 params.put(FIELD, FIELD_TEMPERATURE_LEVEL);
467 } else if (productKey.equals(PLM_PRODUCT_KEY)) {
468 String parts[] = feature.split("#");
469 if (parts.length == 2 && parts[0].equalsIgnoreCase(InsteonBindingConstants.BROADCAST_ON_OFF)
470 && parts[1].matches("^\\d+$")) {
471 params.put(GROUP, parts[1]);
472 feature = BROADCAST_ON_OFF;
474 } else if (productKey.equals(POWER_METER_PRODUCT_KEY)) {
475 if (feature.equalsIgnoreCase(InsteonBindingConstants.KWH)) {
476 params.put(FIELD, FIELD_KWH);
477 } else if (feature.equalsIgnoreCase(InsteonBindingConstants.WATTS)) {
478 params.put(FIELD, FIELD_WATTS);
479 } else if (feature.equalsIgnoreCase(InsteonBindingConstants.RESET)) {
480 params.put(CMD, CMD_RESET);
481 } else if (feature.equalsIgnoreCase(InsteonBindingConstants.UPDATE)) {
482 params.put(CMD, CMD_UPDATE);
488 InsteonChannelConfiguration bindingConfig = new InsteonChannelConfiguration(channelUID, feature,
489 new InsteonAddress(config.getAddress()), productKey, params);
490 getInsteonBinding().addFeatureListener(bindingConfig);
492 StringBuilder builder = new StringBuilder(channelUID.getAsString());
493 builder.append(" feature = ");
494 builder.append(feature);
495 builder.append(" parameters = ");
496 builder.append(params);
497 String msg = builder.toString();
498 logger.debug("{}", msg);
500 getInsteonNetworkHandler().linked(channelUID, msg);
504 public void channelUnlinked(ChannelUID channelUID) {
505 getInsteonBinding().removeFeatureListener(channelUID);
506 getInsteonNetworkHandler().unlinked(channelUID);
508 logger.debug("channel {} unlinked ", channelUID.getAsString());
511 private InsteonNetworkHandler getInsteonNetworkHandler() {
512 Bridge bridge = getBridge();
513 if (bridge == null) {
514 throw new IllegalArgumentException("insteon network bridge is null");
516 InsteonNetworkHandler handler = (InsteonNetworkHandler) bridge.getHandler();
517 if (handler == null) {
518 throw new IllegalArgumentException("insteon network handler is null");
523 private InsteonBinding getInsteonBinding() {
524 return getInsteonNetworkHandler().getInsteonBinding();