2 * Copyright (c) 2010-2022 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.binding.boschshc.internal.devices;
15 import static org.junit.jupiter.api.Assertions.*;
16 import static org.mockito.ArgumentMatchers.eq;
17 import static org.mockito.Mockito.*;
19 import java.util.concurrent.ExecutionException;
20 import java.util.concurrent.TimeoutException;
22 import javax.measure.quantity.Energy;
23 import javax.measure.quantity.Power;
25 import org.junit.jupiter.api.Test;
26 import org.mockito.ArgumentCaptor;
27 import org.mockito.Captor;
28 import org.openhab.binding.boschshc.internal.exceptions.BoschSHCException;
29 import org.openhab.binding.boschshc.internal.services.powerswitch.PowerSwitchState;
30 import org.openhab.binding.boschshc.internal.services.powerswitch.dto.PowerSwitchServiceState;
31 import org.openhab.core.library.types.OnOffType;
32 import org.openhab.core.library.types.QuantityType;
33 import org.openhab.core.thing.ChannelUID;
34 import org.openhab.core.thing.ThingTypeUID;
35 import org.openhab.core.thing.ThingUID;
37 import com.google.gson.JsonElement;
38 import com.google.gson.JsonParser;
41 * Abstract unit test implementation for devices with power switches and energy monitoring.
43 * @author David Pace - Initial contribution
45 * @param <T> type of the handler to be tested
47 public abstract class AbstractPowerSwitchHandlerTest<T extends AbstractPowerSwitchHandler>
48 extends AbstractBoschSHCDeviceHandlerTest<T> {
51 private ArgumentCaptor<PowerSwitchServiceState> serviceStateCaptor;
54 private ArgumentCaptor<QuantityType<Power>> powerCaptor;
57 private ArgumentCaptor<QuantityType<Energy>> energyCaptor;
60 public void testHandleCommand()
61 throws InterruptedException, TimeoutException, ExecutionException, BoschSHCException {
63 when(getThing().getUID()).thenReturn(new ThingUID("boschshc", "abcdef"));
65 getFixture().handleCommand(new ChannelUID(getThing().getUID(), BoschSHCBindingConstants.CHANNEL_POWER_SWITCH),
67 verify(getBridgeHandler()).putState(eq(getDeviceID()), eq("PowerSwitch"), serviceStateCaptor.capture());
68 PowerSwitchServiceState state = serviceStateCaptor.getValue();
69 assertSame(PowerSwitchState.ON, state.switchState);
71 getFixture().handleCommand(new ChannelUID(new ThingUID(getThingTypeUID(), "abcdef"),
72 BoschSHCBindingConstants.CHANNEL_POWER_SWITCH), OnOffType.OFF);
73 verify(getBridgeHandler(), times(2)).putState(eq(getDeviceID()), eq("PowerSwitch"),
74 serviceStateCaptor.capture());
75 state = serviceStateCaptor.getValue();
76 assertSame(PowerSwitchState.OFF, state.switchState);
79 protected abstract ThingTypeUID getThingTypeUID();
82 public void testUpdateChannel_PowerSwitchState() {
83 when(getThing().getUID()).thenReturn(new ThingUID("boschshc", "abcdef"));
85 JsonElement jsonObject = JsonParser
86 .parseString("{\n" + " \"@type\": \"powerSwitchState\",\n" + " \"switchState\": \"ON\"\n" + "}");
87 getFixture().processUpdate("PowerSwitch", jsonObject);
88 verify(getCallback()).stateUpdated(
89 new ChannelUID(getThing().getUID(), BoschSHCBindingConstants.CHANNEL_POWER_SWITCH), OnOffType.ON);
91 jsonObject = JsonParser
92 .parseString("{\n" + " \"@type\": \"powerSwitchState\",\n" + " \"switchState\": \"OFF\"\n" + "}");
93 getFixture().processUpdate("PowerSwitch", jsonObject);
94 verify(getCallback()).stateUpdated(
95 new ChannelUID(getThing().getUID(), BoschSHCBindingConstants.CHANNEL_POWER_SWITCH), OnOffType.OFF);
99 public void testUpdateChannel_PowerMeterServiceState() {
100 when(getThing().getUID()).thenReturn(new ThingUID("boschshc", "abcdef"));
102 JsonElement jsonObject = JsonParser.parseString("{\n" + " \"@type\": \"powerMeterState\",\n"
103 + " \"powerConsumption\": \"23\",\n" + " \"energyConsumption\": 42\n" + "}");
104 getFixture().processUpdate("PowerMeter", jsonObject);
106 verify(getCallback()).stateUpdated(
107 eq(new ChannelUID(getThing().getUID(), BoschSHCBindingConstants.CHANNEL_POWER_CONSUMPTION)),
108 powerCaptor.capture());
109 QuantityType<Power> powerValue = powerCaptor.getValue();
110 assertEquals(23, powerValue.intValue());
112 verify(getCallback()).stateUpdated(
113 eq(new ChannelUID(getThing().getUID(), BoschSHCBindingConstants.CHANNEL_ENERGY_CONSUMPTION)),
114 energyCaptor.capture());
115 QuantityType<Energy> energyValue = energyCaptor.getValue();
116 assertEquals(42, energyValue.intValue());