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.freeboxos.internal.handler;
  14
  15 import static org.openhab.binding.freeboxos.internal.FreeboxOsBindingConstants.*;
  16 import static org.openhab.core.library.unit.Units.*;
  17
  18 import java.math.BigDecimal;
  19 import java.util.ArrayList;
  20 import java.util.Collection;
  21 import java.util.List;
  22 import java.util.Map;
  23 import java.util.Set;
  24
  25 import org.eclipse.jdt.annotation.NonNullByDefault;
  26 import org.openhab.binding.freeboxos.internal.action.ServerActions;
  27 import org.openhab.binding.freeboxos.internal.api.FreeboxException;
  28 import org.openhab.binding.freeboxos.internal.api.rest.AfpManager;
  29 import org.openhab.binding.freeboxos.internal.api.rest.AirMediaManager;
  30 import org.openhab.binding.freeboxos.internal.api.rest.ConnectionManager;
  31 import org.openhab.binding.freeboxos.internal.api.rest.ConnectionManager.Status;
  32 import org.openhab.binding.freeboxos.internal.api.rest.FtpManager;
  33 import org.openhab.binding.freeboxos.internal.api.rest.LanBrowserManager.Source;
  34 import org.openhab.binding.freeboxos.internal.api.rest.LanManager;
  35 import org.openhab.binding.freeboxos.internal.api.rest.LanManager.LanConfig;
  36 import org.openhab.binding.freeboxos.internal.api.rest.SambaManager;
  37 import org.openhab.binding.freeboxos.internal.api.rest.SambaManager.Samba;
  38 import org.openhab.binding.freeboxos.internal.api.rest.SystemManager;
  39 import org.openhab.binding.freeboxos.internal.api.rest.SystemManager.Config;
  40 import org.openhab.binding.freeboxos.internal.api.rest.UPnPAVManager;
  41 import org.openhab.binding.freeboxos.internal.api.rest.WifiManager;
  42 import org.openhab.core.library.types.QuantityType;
  43 import org.openhab.core.library.unit.SIUnits;
  44 import org.openhab.core.library.unit.Units;
  45 import org.openhab.core.thing.Channel;
  46 import org.openhab.core.thing.ChannelUID;
  47 import org.openhab.core.thing.Thing;
  48 import org.openhab.core.thing.binding.ThingHandlerService;
  49 import org.openhab.core.thing.binding.builder.ChannelBuilder;
  50 import org.openhab.core.thing.type.ChannelTypeUID;
  51 import org.openhab.core.types.Command;
  52 import org.slf4j.Logger;
  53 import org.slf4j.LoggerFactory;
  54
  55 /**
  56  * The {@link ServerHandler} handle common parts of Freebox bridges.
  57  *
  58  * @author Gaël L'hopital - Initial contribution
  59  */
  60 @NonNullByDefault
  61 public class ServerHandler extends ApiConsumerHandler implements FreeDeviceIntf {
  62     private static final BigDecimal HUNDRED = BigDecimal.valueOf(100);
  63
  64     private final Logger logger = LoggerFactory.getLogger(ServerHandler.class);
  65     private final ChannelUID eventChannelUID;
  66
  67     private long uptime = -1;
  68
  69     public ServerHandler(Thing thing) {
  70         super(thing);
  71         eventChannelUID = new ChannelUID(getThing().getUID(), SYS_INFO, BOX_EVENT);
  72     }
  73
  74     @Override
  75     void initializeProperties(Map<String, String> properties) throws FreeboxException {
  76         LanConfig lanConfig = getManager(LanManager.class).getConfig();
  77         Config config = getManager(SystemManager.class).getConfig();
  78         properties.put(Thing.PROPERTY_SERIAL_NUMBER, config.serial());
  79         properties.put(Thing.PROPERTY_FIRMWARE_VERSION, config.firmwareVersion());
  80         properties.put(Thing.PROPERTY_HARDWARE_VERSION, config.modelInfo().prettyName());
  81         properties.put(Thing.PROPERTY_MAC_ADDRESS, config.mac().toColonDelimitedString());
  82         properties.put(Source.UPNP.name(), lanConfig.name());
  83
  84         List<Channel> channels = new ArrayList<>(getThing().getChannels());
  85         int nbInit = channels.size();
  86         config.sensors().forEach(sensor -> {
  87             ChannelUID sensorId = new ChannelUID(thing.getUID(), GROUP_SENSORS, sensor.id());
  88             if (getThing().getChannel(sensorId) == null) {
  89                 String label = sensor.name();
  90                 // For revolution, API returns only "Disque dur" so we patch it to have naming consistency with other
  91                 // temperature sensors
  92                 if ("Disque dur".equals(label)) {
  93                     label = "Température " + label;
  94                 }
  95                 channels.add(ChannelBuilder.create(sensorId).withLabel(label).withAcceptedItemType("Number:Temperature")
  96                         .withType(new ChannelTypeUID(BINDING_ID, "temperature")).build());
  97             }
  98         });
  99         config.fans().forEach(sensor -> {
 100             ChannelUID sensorId = new ChannelUID(thing.getUID(), GROUP_FANS, sensor.id());
 101             if (getThing().getChannel(sensorId) == null) {
 102                 channels.add(ChannelBuilder.create(sensorId).withLabel(sensor.name())
 103                         .withAcceptedItemType("Number:Frequency").withType(new ChannelTypeUID(BINDING_ID, "fanspeed"))
 104                         .build());
 105             }
 106         });
 107         if (nbInit != channels.size()) {
 108             updateThing(editThing().withChannels(channels).build());
 109         }
 110     }
 111
 112     @Override
 113     protected void internalPoll() throws FreeboxException {
 114         logger.debug("Polling server state...");
 115         fetchConnectionStatus();
 116         fetchSystemConfig();
 117
 118         updateChannelOnOff(ACTIONS, WIFI_STATUS, getManager(WifiManager.class).getStatus());
 119         updateChannelOnOff(ACTIONS, AIRMEDIA_STATUS, getManager(AirMediaManager.class).getStatus());
 120         updateChannelOnOff(ACTIONS, UPNPAV_STATUS, getManager(UPnPAVManager.class).getStatus());
 121
 122         Samba response = getManager(SambaManager.class).getConfig();
 123         updateChannelOnOff(FILE_SHARING, SAMBA_FILE_STATUS, response.fileShareEnabled());
 124         updateChannelOnOff(FILE_SHARING, SAMBA_PRINTER_STATUS, response.printShareEnabled());
 125         updateChannelOnOff(FILE_SHARING, FTP_STATUS, getManager(FtpManager.class).getStatus());
 126         updateChannelOnOff(FILE_SHARING, AFP_FILE_STATUS, getManager(AfpManager.class).getStatus());
 127     }
 128
 129     private void fetchSystemConfig() throws FreeboxException {
 130         Config config = getManager(SystemManager.class).getConfig();
 131
 132         config.sensors().forEach(s -> updateChannelQuantity(GROUP_SENSORS, s.id(), s.value(), SIUnits.CELSIUS));
 133         config.fans().forEach(f -> updateChannelQuantity(GROUP_FANS, f.id(), f.value(), Units.RPM));
 134
 135         uptime = checkUptimeAndFirmware(config.uptimeVal(), uptime, config.firmwareVersion());
 136         updateChannelQuantity(SYS_INFO, UPTIME, uptime, Units.SECOND);
 137
 138         LanConfig lanConfig = getManager(LanManager.class).getConfig();
 139         updateChannelString(SYS_INFO, IP_ADDRESS, lanConfig.ip());
 140     }
 141
 142     private void fetchConnectionStatus() throws FreeboxException {
 143         Status status = getManager(ConnectionManager.class).getConfig();
 144         updateChannelString(CONNECTION_STATUS, LINE_STATUS, status.state());
 145         updateChannelString(CONNECTION_STATUS, LINE_TYPE, status.type());
 146         updateChannelString(CONNECTION_STATUS, LINE_MEDIA, status.media());
 147         updateChannelString(CONNECTION_STATUS, IP_ADDRESS, status.ipv4());
 148         updateChannelString(CONNECTION_STATUS, IPV6_ADDRESS, status.ipv6());
 149
 150         updateRateBandwidth(status.rateUp(), status.bandwidthUp(), "up");
 151         updateRateBandwidth(status.rateDown(), status.bandwidthDown(), "down");
 152
 153         updateChannelQuantity(CONNECTION_STATUS, BYTES_UP, new QuantityType<>(status.bytesUp(), OCTET), GIBIOCTET);
 154         updateChannelQuantity(CONNECTION_STATUS, BYTES_DOWN, new QuantityType<>(status.bytesDown(), OCTET), GIBIOCTET);
 155     }
 156
 157     private void updateRateBandwidth(long rate, long bandwidth, String orientation) {
 158         QuantityType<?> rateUp = new QuantityType<>(rate * 8, Units.BIT_PER_SECOND);
 159         QuantityType<?> bandwidthUp = new QuantityType<>(bandwidth, BIT_PER_SECOND);
 160         updateChannelQuantity(CONNECTION_STATUS, RATE + "-" + orientation, rateUp, KILOBIT_PER_SECOND);
 161         updateChannelQuantity(CONNECTION_STATUS, BW + "-" + orientation, bandwidthUp, KILOBIT_PER_SECOND);
 162         updateChannelQuantity(CONNECTION_STATUS, PCT_BW + "-" + orientation,
 163                 !bandwidthUp.equals(QuantityType.ZERO) ? rateUp.multiply(HUNDRED).divide(bandwidthUp)
 164                         : QuantityType.ZERO,
 165                 Units.PERCENT);
 166     }
 167
 168     @Override
 169     protected boolean internalHandleCommand(String channelId, Command command) throws FreeboxException {
 170         if (ON_OFF_CLASSES.contains(command.getClass())) {
 171             boolean enable = TRUE_COMMANDS.contains(command);
 172             switch (channelId) {
 173                 case WIFI_STATUS:
 174                     updateChannelOnOff(ACTIONS, WIFI_STATUS, getManager(WifiManager.class).setStatus(enable));
 175                     return true;
 176                 case FTP_STATUS:
 177                     updateChannelOnOff(FILE_SHARING, FTP_STATUS, getManager(FtpManager.class).setStatus(enable));
 178                     return true;
 179                 case SAMBA_FILE_STATUS:
 180                     updateChannelOnOff(FILE_SHARING, SAMBA_FILE_STATUS,
 181                             getManager(SambaManager.class).setFileShare(enable));
 182                     return true;
 183                 case SAMBA_PRINTER_STATUS:
 184                     updateChannelOnOff(FILE_SHARING, SAMBA_PRINTER_STATUS,
 185                             getManager(SambaManager.class).setPrintShare(enable));
 186                     return true;
 187                 case UPNPAV_STATUS:
 188                     updateChannelOnOff(ACTIONS, UPNPAV_STATUS, getManager(UPnPAVManager.class).setStatus(enable));
 189                     return true;
 190                 case AFP_FILE_STATUS:
 191                     updateChannelOnOff(FILE_SHARING, AFP_FILE_STATUS, getManager(AfpManager.class).setStatus(enable));
 192                     return true;
 193                 case AIRMEDIA_STATUS:
 194                     updateChannelOnOff(ACTIONS, AIRMEDIA_STATUS, getManager(AirMediaManager.class).setStatus(enable));
 195                     return true;
 196                 default:
 197                     break;
 198             }
 199         }
 200         return super.internalHandleCommand(channelId, command);
 201     }
 202
 203     public void reboot() {
 204         processReboot(() -> {
 205             try {
 206                 getManager(SystemManager.class).reboot();
 207             } catch (FreeboxException e) {
 208                 logger.warn("Error rebooting: {}", e.getMessage());
 209             }
 210         });
 211     }
 212
 213     @Override
 214     public Collection<Class<? extends ThingHandlerService>> getServices() {
 215         return Set.of(ServerActions.class);
 216     }
 217
 218     @Override
 219     public ChannelUID getEventChannelUID() {
 220         return eventChannelUID;
 221     }
 222
 223     @Override
 224     public void triggerChannel(ChannelUID channelUID, String event) {
 225         super.triggerChannel(channelUID, event);
 226     }
 227 }