2 * Copyright (c) 2010-2023 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.io.homekit.internal.accessories;
15 import static org.openhab.io.homekit.internal.HomekitCharacteristicType.LEAK_DETECTED_STATE;
17 import java.util.List;
18 import java.util.concurrent.CompletableFuture;
20 import org.openhab.io.homekit.internal.HomekitAccessoryUpdater;
21 import org.openhab.io.homekit.internal.HomekitSettings;
22 import org.openhab.io.homekit.internal.HomekitTaggedItem;
24 import io.github.hapjava.accessories.LeakSensorAccessory;
25 import io.github.hapjava.characteristics.HomekitCharacteristicChangeCallback;
26 import io.github.hapjava.characteristics.impl.leaksensor.LeakDetectedStateEnum;
27 import io.github.hapjava.services.impl.LeakSensorService;
31 * @author Tim Harper - Initial contribution
33 public class HomekitLeakSensorImpl extends AbstractHomekitAccessoryImpl implements LeakSensorAccessory {
34 private final BooleanItemReader leakDetectedReader;
36 public HomekitLeakSensorImpl(HomekitTaggedItem taggedItem, List<HomekitTaggedItem> mandatoryCharacteristics,
37 HomekitAccessoryUpdater updater, HomekitSettings settings) throws IncompleteAccessoryException {
38 super(taggedItem, mandatoryCharacteristics, updater, settings);
39 leakDetectedReader = createBooleanReader(LEAK_DETECTED_STATE);
40 getServices().add(new LeakSensorService(this));
44 public CompletableFuture<LeakDetectedStateEnum> getLeakDetected() {
45 return CompletableFuture.completedFuture(leakDetectedReader.getValue() ? LeakDetectedStateEnum.LEAK_DETECTED
46 : LeakDetectedStateEnum.LEAK_NOT_DETECTED);
50 public void subscribeLeakDetected(HomekitCharacteristicChangeCallback callback) {
51 subscribe(LEAK_DETECTED_STATE, callback);
55 public void unsubscribeLeakDetected() {
56 unsubscribe(LEAK_DETECTED_STATE);