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.mihome.internal.discovery;
  14
  15 import static org.openhab.binding.mihome.internal.XiaomiGatewayBindingConstants.*;
  16
  17 import java.util.HashMap;
  18 import java.util.Map;
  19 import java.util.Set;
  20
  21 import org.eclipse.jdt.annotation.NonNullByDefault;
  22 import org.openhab.binding.mihome.internal.socket.XiaomiDiscoverySocket;
  23 import org.openhab.binding.mihome.internal.socket.XiaomiSocketListener;
  24 import org.openhab.core.config.discovery.AbstractDiscoveryService;
  25 import org.openhab.core.config.discovery.DiscoveryResultBuilder;
  26 import org.openhab.core.config.discovery.DiscoveryService;
  27 import org.openhab.core.thing.ThingTypeUID;
  28 import org.openhab.core.thing.ThingUID;
  29 import org.osgi.service.component.annotations.Component;
  30 import org.slf4j.Logger;
  31 import org.slf4j.LoggerFactory;
  32
  33 import com.google.gson.JsonObject;
  34
  35 /**
  36  * Discovery service for the Xiaomi bridge.
  37  *
  38  * @author Patrick Boos - Initial contribution
  39  * @author Kuba Wolanin - logger fixes
  40  */
  41 @NonNullByDefault
  42 @Component(service = DiscoveryService.class, configurationPid = "discovery.mihome")
  43 public class XiaomiBridgeDiscoveryService extends AbstractDiscoveryService implements XiaomiSocketListener {
  44
  45     private static final Set<ThingTypeUID> SUPPORTED_THING_TYPES = Set.of(THING_TYPE_BRIDGE);
  46     private static final int DISCOVERY_TIMEOUT_SEC = 30;
  47
  48     private final Logger logger = LoggerFactory.getLogger(XiaomiBridgeDiscoveryService.class);
  49     private final XiaomiDiscoverySocket socket = new XiaomiDiscoverySocket("discovery");
  50
  51     public XiaomiBridgeDiscoveryService() {
  52         super(SUPPORTED_THING_TYPES, DISCOVERY_TIMEOUT_SEC, false);
  53     }
  54
  55     @Override
  56     protected void startScan() {
  57         socket.initialize();
  58         logger.debug("Start scan for bridges");
  59         socket.registerListener(this);
  60         discoverGateways();
  61     }
  62
  63     @Override
  64     protected synchronized void stopScan() {
  65         super.stopScan();
  66         logger.debug("Stop scan");
  67         removeOlderResults(getTimestampOfLastScan());
  68         socket.unregisterListener(this);
  69     }
  70
  71     @Override
  72     public void deactivate() {
  73         super.deactivate();
  74         socket.unregisterListener(this);
  75     }
  76
  77     @Override
  78     public void onDataReceived(JsonObject data) {
  79         logger.debug("Received message {}", data);
  80         if ("iam".equals(data.get("cmd").getAsString())) {
  81             getGatewayInfo(data);
  82         }
  83     }
  84
  85     @Override
  86     public int getScanTimeout() {
  87         return DISCOVERY_TIMEOUT_SEC;
  88     }
  89
  90     private void discoverGateways() {
  91         socket.sendMessage("{\"cmd\":\"whois\"}");
  92     }
  93
  94     private void getGatewayInfo(JsonObject jobject) {
  95         Map<String, Object> properties = new HashMap<>(4);
  96         String serialNumber = jobject.get("sid").getAsString();
  97         String ipAddress = jobject.get("ip").getAsString();
  98         int port = jobject.get("port").getAsInt();
  99
 100         // It is reported that the gateway is sometimes providing the serial number without the leading 0
 101         // This is a workaround for a bug in the gateway
 102         if (serialNumber.length() == 11) {
 103             serialNumber = "0" + serialNumber;
 104         }
 105
 106         properties.put(SERIAL_NUMBER, serialNumber);
 107         properties.put(HOST, ipAddress);
 108         properties.put(PORT, port);
 109
 110         logger.debug("Discovered Xiaomi Gateway - sid: {} ip: {} port: {}", serialNumber, ipAddress, port);
 111
 112         ThingUID thingUID = new ThingUID(THING_TYPE_BRIDGE, serialNumber);
 113
 114         thingDiscovered(
 115                 DiscoveryResultBuilder.create(thingUID).withThingType(THING_TYPE_BRIDGE).withProperties(properties)
 116                         .withLabel("Xiaomi Gateway").withRepresentationProperty(SERIAL_NUMBER).build());
 117     }
 118 }