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.cbus.internal.discovery;
  14
  15 import java.util.ArrayList;
  16 import java.util.HashMap;
  17 import java.util.Map;
  18
  19 import org.eclipse.jdt.annotation.NonNullByDefault;
  20 import org.openhab.binding.cbus.CBusBindingConstants;
  21 import org.openhab.binding.cbus.handler.CBusCGateHandler;
  22 import org.openhab.core.config.discovery.AbstractDiscoveryService;
  23 import org.openhab.core.config.discovery.DiscoveryResult;
  24 import org.openhab.core.config.discovery.DiscoveryResultBuilder;
  25 import org.openhab.core.thing.ThingStatus;
  26 import org.openhab.core.thing.ThingUID;
  27 import org.slf4j.Logger;
  28 import org.slf4j.LoggerFactory;
  29
  30 import com.daveoxley.cbus.CGateException;
  31 import com.daveoxley.cbus.Network;
  32
  33 /**
  34  * The {@link CBusNetworkDiscovery} class is used to discover CBus
  35  * networks that are in the CBus Project
  36  *
  37  * @author Scott Linton - Initial contribution
  38  */
  39 @NonNullByDefault
  40 public class CBusNetworkDiscovery extends AbstractDiscoveryService {
  41
  42     private final Logger logger = LoggerFactory.getLogger(CBusNetworkDiscovery.class);
  43
  44     private final CBusCGateHandler cBusCGateHandler;
  45
  46     public CBusNetworkDiscovery(CBusCGateHandler cBusCGateHandler) {
  47         super(CBusBindingConstants.NETWORK_DISCOVERY_THING_TYPES_UIDS, 60, false);
  48         this.cBusCGateHandler = cBusCGateHandler;
  49     }
  50
  51     @Override
  52     protected void startScan() {
  53         if (cBusCGateHandler.getThing().getStatus().equals(ThingStatus.ONLINE)) {
  54             try {
  55                 ArrayList<Network> networks = Network.listAll(cBusCGateHandler.getCGateSession(), false);
  56                 for (Network network : networks) {
  57                     logger.debug("Found Network: {} {}", network.getNetworkID(), network.getName());
  58                     Map<String, Object> properties = new HashMap<>(3);
  59                     properties.put(CBusBindingConstants.CONFIG_NETWORK_ID, network.getNetworkID());
  60                     properties.put(CBusBindingConstants.PROPERTY_NETWORK_NAME, network.getName());
  61                     properties.put(CBusBindingConstants.CONFIG_NETWORK_PROJECT, network.getProjectName());
  62                     ThingUID uid = new ThingUID(CBusBindingConstants.BRIDGE_TYPE_NETWORK,
  63                             network.getProjectName().toLowerCase().replace(" ", "_") + network.getNetworkID(),
  64                             cBusCGateHandler.getThing().getUID().getId());
  65                     DiscoveryResult result = DiscoveryResultBuilder.create(uid).withProperties(properties)
  66                             .withLabel(
  67                                     network.getProjectName() + "/" + network.getNetworkID() + " - " + network.getName())
  68                             .withBridge(cBusCGateHandler.getThing().getUID()).build();
  69                     thingDiscovered(result);
  70                 }
  71             } catch (CGateException e) {
  72                 logger.warn("Failed to discover networks", e);
  73             }
  74         }
  75     }
  76
  77     @Override
  78     protected synchronized void stopScan() {
  79         super.stopScan();
  80         removeOlderResults(getTimestampOfLastScan());
  81     }
  82 }