]> git.basschouten.com Git - openhab-addons.git/blob
38432d552aab429326ef8c6e9b0c193703eeef86
[openhab-addons.git] /
1 /**
2  * Copyright (c) 2010-2022 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.boschshc.internal.devices;
14
15 import static org.junit.jupiter.api.Assertions.*;
16 import static org.mockito.ArgumentMatchers.eq;
17 import static org.mockito.Mockito.*;
18
19 import java.util.concurrent.ExecutionException;
20 import java.util.concurrent.TimeoutException;
21
22 import javax.measure.quantity.Energy;
23 import javax.measure.quantity.Power;
24
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;
36
37 import com.google.gson.JsonElement;
38 import com.google.gson.JsonParser;
39
40 /**
41  * Abstract unit test implementation for devices with power switches and energy monitoring.
42  *
43  * @author David Pace - Initial contribution
44  *
45  * @param <T> type of the handler to be tested
46  */
47 public abstract class AbstractPowerSwitchHandlerTest<T extends AbstractPowerSwitchHandler>
48         extends AbstractBoschSHCDeviceHandlerTest<T> {
49
50     @Captor
51     private ArgumentCaptor<PowerSwitchServiceState> serviceStateCaptor;
52
53     @Captor
54     private ArgumentCaptor<QuantityType<Power>> powerCaptor;
55
56     @Captor
57     private ArgumentCaptor<QuantityType<Energy>> energyCaptor;
58
59     @Test
60     public void testHandleCommand()
61             throws InterruptedException, TimeoutException, ExecutionException, BoschSHCException {
62
63         when(getThing().getUID()).thenReturn(new ThingUID("boschshc", "abcdef"));
64
65         getFixture().handleCommand(new ChannelUID(getThing().getUID(), BoschSHCBindingConstants.CHANNEL_POWER_SWITCH),
66                 OnOffType.ON);
67         verify(getBridgeHandler()).putState(eq(getDeviceID()), eq("PowerSwitch"), serviceStateCaptor.capture());
68         PowerSwitchServiceState state = serviceStateCaptor.getValue();
69         assertSame(PowerSwitchState.ON, state.switchState);
70
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);
77     }
78
79     protected abstract ThingTypeUID getThingTypeUID();
80
81     @Test
82     public void testUpdateChannel_PowerSwitchState() {
83         when(getThing().getUID()).thenReturn(new ThingUID("boschshc", "abcdef"));
84
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);
90
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);
96     }
97
98     @Test
99     public void testUpdateChannel_PowerMeterServiceState() {
100         when(getThing().getUID()).thenReturn(new ThingUID("boschshc", "abcdef"));
101
102         JsonElement jsonObject = JsonParser.parseString("{\n" + "  \"@type\": \"powerMeterState\",\n"
103                 + "  \"powerConsumption\": \"23\",\n" + "  \"energyConsumption\": 42\n" + "}");
104         getFixture().processUpdate("PowerMeter", jsonObject);
105
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());
111
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());
117     }
118 }