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

   1 /**
   2  * Copyright (c) 2010-2024 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.netatmo.internal.handler.capability;
  14
  15 import static org.openhab.binding.netatmo.internal.NetatmoBindingConstants.*;
  16
  17 import java.time.Duration;
  18 import java.util.ArrayList;
  19 import java.util.HashSet;
  20 import java.util.List;
  21 import java.util.Set;
  22 import java.util.stream.Collectors;
  23
  24 import org.eclipse.jdt.annotation.NonNullByDefault;
  25 import org.openhab.binding.netatmo.internal.api.HomeApi;
  26 import org.openhab.binding.netatmo.internal.api.NetatmoException;
  27 import org.openhab.binding.netatmo.internal.api.data.NetatmoConstants.FeatureArea;
  28 import org.openhab.binding.netatmo.internal.api.dto.HomeData;
  29 import org.openhab.binding.netatmo.internal.api.dto.Location;
  30 import org.openhab.binding.netatmo.internal.api.dto.NAError;
  31 import org.openhab.binding.netatmo.internal.api.dto.NAObject;
  32 import org.openhab.binding.netatmo.internal.config.HomeConfiguration;
  33 import org.openhab.binding.netatmo.internal.handler.CommonInterface;
  34 import org.openhab.binding.netatmo.internal.providers.NetatmoDescriptionProvider;
  35 import org.openhab.core.thing.Bridge;
  36 import org.slf4j.Logger;
  37 import org.slf4j.LoggerFactory;
  38
  39 /**
  40  * The {@link HomeCapability} is the base class for handler able to manage persons and modules
  41  *
  42  * @author Gaël L'hopital - Initial contribution
  43  *
  44  */
  45 @NonNullByDefault
  46 public class HomeCapability extends CacheCapability<HomeApi> {
  47
  48     private final Logger logger = LoggerFactory.getLogger(HomeCapability.class);
  49     private final Set<FeatureArea> featureAreas = new HashSet<>();
  50     private final NetatmoDescriptionProvider descriptionProvider;
  51     private final Set<String> homeIds = new HashSet<>(3);
  52
  53     public HomeCapability(CommonInterface handler, NetatmoDescriptionProvider descriptionProvider) {
  54         super(handler, Duration.ofSeconds(2), HomeApi.class);
  55         this.descriptionProvider = descriptionProvider;
  56     }
  57
  58     @Override
  59     public void initialize() {
  60         super.initialize();
  61         HomeConfiguration config = handler.getThingConfigAs(HomeConfiguration.class);
  62         homeIds.add(config.getId());
  63         if (!config.energyId.isBlank()) {
  64             homeIds.add(config.energyId);
  65         }
  66         if (!config.securityId.isBlank()) {
  67             homeIds.add(config.securityId);
  68         }
  69     }
  70
  71     @Override
  72     public void dispose() {
  73         homeIds.clear();
  74         super.dispose();
  75     }
  76
  77     @Override
  78     protected void updateHomeData(HomeData home) {
  79         if (firstLaunch) {
  80             if (featureAreas.contains(FeatureArea.SECURITY)) {
  81                 handler.getCapabilities().put(new SecurityCapability(handler));
  82             } else {
  83                 handler.removeChannels(thing.getChannelsOfGroup(GROUP_SECURITY));
  84             }
  85             if (featureAreas.contains(FeatureArea.ENERGY)) {
  86                 handler.getCapabilities().put(new EnergyCapability(handler, descriptionProvider));
  87             } else {
  88                 handler.removeChannels(thing.getChannelsOfGroup(GROUP_ENERGY));
  89             }
  90             home.getCountry().map(country -> properties.put(PROPERTY_COUNTRY, country));
  91             home.getTimezone().map(tz -> properties.put(PROPERTY_TIMEZONE, tz));
  92             properties.put(GROUP_LOCATION, ((Location) home).getLocation().toString());
  93             properties.put(PROPERTY_FEATURE,
  94                     featureAreas.stream().map(FeatureArea::name).collect(Collectors.joining(",")));
  95         }
  96     }
  97
  98     /**
  99      * Errored equipments are reported at home level - so we need to explore all the tree to identify modules
 100      * depending from a child device.
 101      */
 102     @Override
 103     protected void updateErrors(NAError error) {
 104         handler.getAllActiveChildren((Bridge) thing).stream().filter(handler -> handler.getId().equals(error.getId()))
 105                 .findFirst().ifPresent(handler -> handler.setNewData(error));
 106     }
 107
 108     @Override
 109     protected List<NAObject> getFreshData(HomeApi api) {
 110         List<NAObject> result = new ArrayList<>();
 111         homeIds.stream().filter(id -> !id.isEmpty()).forEach(id -> {
 112             try {
 113                 if (firstLaunch) {
 114                     HomeData homeData = api.getHomeData(id);
 115                     if (homeData != null) {
 116                         result.add(homeData);
 117                         featureAreas.addAll(homeData.getFeatures());
 118                     }
 119                 }
 120
 121                 api.getHomeStatus(id).ifPresent(body -> {
 122                     body.getHomeStatus().ifPresent(result::add);
 123                     result.addAll(body.getErrors());
 124                 });
 125             } catch (NetatmoException e) {
 126                 logger.warn("Error getting Home informations: {}", e.getMessage());
 127             }
 128         });
 129         return result;
 130     }
 131 }