]> git.basschouten.com Git - openhab-addons.git/blob
3d96e7bcfa16c53cabc9b5f14eed3ee40040cdda
[openhab-addons.git] /
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.knx.internal.itests;
14
15 import static org.junit.jupiter.api.Assertions.assertEquals;
16 import static org.junit.jupiter.api.Assertions.assertNotNull;
17 import static org.junit.jupiter.api.Assertions.assertNull;
18 import static org.junit.jupiter.api.Assertions.assertTrue;
19
20 import java.util.Arrays;
21 import java.util.HashSet;
22 import java.util.Objects;
23 import java.util.Set;
24
25 import org.eclipse.jdt.annotation.NonNullByDefault;
26 import org.junit.jupiter.api.AfterAll;
27 import org.junit.jupiter.api.Assertions;
28 import org.junit.jupiter.api.Test;
29 import org.openhab.binding.knx.internal.client.DummyKNXNetworkLink;
30 import org.openhab.binding.knx.internal.client.DummyProcessListener;
31 import org.openhab.binding.knx.internal.dpt.DPTUtil;
32 import org.openhab.binding.knx.internal.dpt.ValueDecoder;
33 import org.openhab.binding.knx.internal.dpt.ValueEncoder;
34 import org.openhab.core.library.types.DateTimeType;
35 import org.openhab.core.library.types.DecimalType;
36 import org.openhab.core.library.types.HSBType;
37 import org.openhab.core.library.types.IncreaseDecreaseType;
38 import org.openhab.core.library.types.OnOffType;
39 import org.openhab.core.library.types.OpenClosedType;
40 import org.openhab.core.library.types.PercentType;
41 import org.openhab.core.library.types.QuantityType;
42 import org.openhab.core.library.types.StopMoveType;
43 import org.openhab.core.library.types.StringType;
44 import org.openhab.core.library.types.UpDownType;
45 import org.openhab.core.types.Type;
46 import org.openhab.core.util.ColorUtil;
47 import org.openhab.core.util.HexUtils;
48 import org.slf4j.Logger;
49 import org.slf4j.LoggerFactory;
50
51 import tuwien.auto.calimero.DataUnitBuilder;
52 import tuwien.auto.calimero.GroupAddress;
53 import tuwien.auto.calimero.KNXException;
54 import tuwien.auto.calimero.datapoint.CommandDP;
55 import tuwien.auto.calimero.datapoint.Datapoint;
56 import tuwien.auto.calimero.dptxlator.DPTXlator2ByteUnsigned;
57 import tuwien.auto.calimero.dptxlator.TranslatorTypes;
58 import tuwien.auto.calimero.process.ProcessCommunicator;
59 import tuwien.auto.calimero.process.ProcessCommunicatorImpl;
60
61 /**
62  * Integration test to check conversion from raw KNX frame data to OH data types and back.
63  *
64  * This test checks
65  * <ul>
66  * <li>if OH can properly decode raw data payload from KNX frames using {@link ValueDecoder#decode()},
67  * <li>if OH can properly encode the data for handover to Calimero using {@link ValueEncoder#encode()},
68  * <li>if Calimero supports and correctly handles the data conversion to raw bytes for sending.
69  * </ul>
70  *
71  * In addition, it checks if newly integrated releases of Calimero introduce new DPT types not yet
72  * handled by this test. However, new subtypes are not detected.
73  *
74  * @see DummyKNXNetworkLink
75  * @see DummyClient
76  * @author Holger Friedrich - Initial contribution
77  *
78  */
79 @NonNullByDefault
80 public class Back2BackTest {
81     public static final Logger LOGGER = LoggerFactory.getLogger(Back2BackTest.class);
82     static Set<Integer> dptTested = new HashSet<>();
83     static final byte[] F32_MINUS_ONE = new byte[] { (byte) 0xbf, (byte) 0x80, 0, 0 };
84     boolean testsMissing = false;
85
86     /**
87      * helper method for integration tests
88      *
89      * @param dpt DPT type, e.g. "251.600", see 03_07_02-Datapoint-Types-v02.02.01-AS.pdf
90      * @param rawData byte array containing raw data, known content
91      * @param ohReferenceData OpenHAB data type, initialized to known good value
92      * @param maxDistance byte array containing maximal deviations when comparing byte arrays (rawData against created
93      *            KNX frame), may be empty if no deviation is considered
94      * @param bitmask to mask certain bits in the raw to raw comparison, required for multi-valued KNX frames
95      */
96     void helper(String dpt, byte[] rawData, Type ohReferenceData, byte[] maxDistance, byte[] bitmask) {
97         try {
98             DummyKNXNetworkLink link = new DummyKNXNetworkLink();
99             ProcessCommunicator pc = new ProcessCommunicatorImpl(link);
100             DummyProcessListener processListener = new DummyProcessListener();
101             pc.addProcessListener(processListener);
102
103             GroupAddress groupAddress = new GroupAddress(2, 4, 6);
104             Datapoint datapoint = new CommandDP(groupAddress, "dummy GA", 0,
105                     DPTUtil.NORMALIZED_DPT.getOrDefault(dpt, dpt));
106
107             // 0) check usage of helper()
108             assertEquals(true, rawData.length > 0);
109             if (maxDistance.length == 0) {
110                 maxDistance = new byte[rawData.length];
111             }
112             assertEquals(rawData.length, maxDistance.length, "incorrect length of maxDistance array");
113             if (bitmask.length == 0) {
114                 bitmask = new byte[rawData.length];
115                 Arrays.fill(bitmask, (byte) 0xff);
116             }
117             assertEquals(rawData.length, bitmask.length, "incorrect length of bitmask array");
118             int mainType = Integer.parseUnsignedInt(dpt.substring(0, dpt.indexOf('.')));
119             dptTested.add(Integer.valueOf(mainType));
120             // check if OH would be able to send out a frame, given the type
121             Set<Integer> knownWorking = Set.of(1, 3, 5);
122             if (!knownWorking.contains(mainType)) {
123                 Set<Class<? extends Type>> allowedTypes = DPTUtil.getAllowedTypes("" + mainType);
124                 if (!allowedTypes.contains(ohReferenceData.getClass())) {
125                     LOGGER.warn(
126                             "test for DPT {} uses type {} which is not contained in DPT_TYPE_MAP, sending may not be allowed",
127                             dpt, ohReferenceData.getClass());
128                 }
129             }
130
131             // 1) check if the decoder works (rawData to known good type ohReferenceData)
132             //
133             // This test is based on known raw data. The mapping to openHAB type is known and confirmed.
134             // In this test, only ValueDecoder.decode() is involved.
135
136             // raw data of the DPT on application layer, without all headers from the layers below
137             // see 03_07_02-Datapoint-Types-v02.02.01-AS.pdf
138             Type ohData = (Type) ValueDecoder.decode(dpt, rawData, ohReferenceData.getClass());
139             assertNotNull(ohData, "could not decode frame data for DPT " + dpt);
140             if ((ohReferenceData instanceof HSBType hsbReferenceData) && (ohData instanceof HSBType hsbData)) {
141                 assertTrue(hsbReferenceData.closeTo(hsbData, 0.001),
142                         "comparing reference to decoded value for DPT " + dpt);
143             } else {
144                 assertEquals(ohReferenceData, ohData, "comparing reference to decoded value: failed for DPT " + dpt
145                         + ", check ValueEncoder.decode()");
146             }
147
148             // 2) check the encoding (ohData to raw data)
149             //
150             // Test approach is to a) encode the value into String format using ValueEncoder.encode(),
151             // b) pass it to Calimero for conversion into a raw representation, and
152             // c) finally grab raw data bytes from a custom KNXNetworkLink implementation
153             String enc = ValueEncoder.encode(ohData, dpt);
154             pc.write(datapoint, enc);
155
156             byte[] frame = link.getLastFrame();
157             assertNotNull(frame);
158             // remove header; for compact frames extract data byte from header
159             frame = DataUnitBuilder.extractASDU(frame);
160             assertEquals(rawData.length, frame.length,
161                     "unexpected length of KNX frame: " + HexUtils.bytesToHex(frame, " "));
162             for (int i = 0; i < rawData.length; i++) {
163                 assertEquals(rawData[i] & bitmask[i] & 0xff, frame[i] & bitmask[i] & 0xff, maxDistance[i],
164                         "unexpected content in encoded data, " + i);
165             }
166
167             // 3) Check date provided by Calimero library as input via loopback, it should match the initial data
168             //
169             // Deviations in some bytes of the frame may be possible due to data conversion, e.g. for HSBType.
170             // This is why maxDistance is used.
171             byte[] input = processListener.getLastFrame();
172             LOGGER.info("loopback {}", HexUtils.bytesToHex(input, " "));
173             assertNotNull(input);
174             assertEquals(rawData.length, input.length, "unexpected length of loopback frame");
175             for (int i = 0; i < rawData.length; i++) {
176                 assertEquals(rawData[i] & bitmask[i] & 0xff, input[i] & bitmask[i] & 0xff, maxDistance[i],
177                         "unexpected content in loopback data, " + i);
178             }
179
180             pc.close();
181         } catch (KNXException e) {
182             LOGGER.warn("exception occurred", e.toString());
183             assertEquals("", e.toString());
184         }
185     }
186
187     void helper(String dpt, byte[] rawData, Type ohReferenceData) {
188         helper(dpt, rawData, ohReferenceData, new byte[0], new byte[0]);
189     }
190
191     @Test
192     void testDpt1() {
193         helper("1.001", new byte[] { 0 }, OnOffType.OFF);
194         helper("1.001", new byte[] { 1 }, OnOffType.ON);
195         helper("1.001", new byte[] { 0 }, OpenClosedType.CLOSED);
196         helper("1.001", new byte[] { 1 }, OpenClosedType.OPEN);
197         helper("1.002", new byte[] { 0 }, OnOffType.OFF);
198         helper("1.002", new byte[] { 1 }, OnOffType.ON);
199         helper("1.002", new byte[] { 0 }, OpenClosedType.CLOSED);
200         helper("1.002", new byte[] { 1 }, OpenClosedType.OPEN);
201         helper("1.003", new byte[] { 0 }, OnOffType.OFF);
202         helper("1.003", new byte[] { 1 }, OnOffType.ON);
203         helper("1.003", new byte[] { 0 }, OpenClosedType.CLOSED);
204         helper("1.003", new byte[] { 1 }, OpenClosedType.OPEN);
205         helper("1.004", new byte[] { 0 }, OnOffType.OFF);
206         helper("1.004", new byte[] { 1 }, OnOffType.ON);
207         helper("1.004", new byte[] { 0 }, OpenClosedType.CLOSED);
208         helper("1.004", new byte[] { 1 }, OpenClosedType.OPEN);
209         helper("1.005", new byte[] { 0 }, OnOffType.OFF);
210         helper("1.005", new byte[] { 1 }, OnOffType.ON);
211         helper("1.005", new byte[] { 0 }, OpenClosedType.CLOSED);
212         helper("1.005", new byte[] { 1 }, OpenClosedType.OPEN);
213         helper("1.006", new byte[] { 0 }, OnOffType.OFF);
214         helper("1.006", new byte[] { 1 }, OnOffType.ON);
215         helper("1.006", new byte[] { 0 }, OpenClosedType.CLOSED);
216         helper("1.006", new byte[] { 1 }, OpenClosedType.OPEN);
217         helper("1.007", new byte[] { 0 }, OnOffType.OFF);
218         helper("1.007", new byte[] { 1 }, OnOffType.ON);
219         helper("1.007", new byte[] { 0 }, OpenClosedType.CLOSED);
220         helper("1.007", new byte[] { 1 }, OpenClosedType.OPEN);
221         helper("1.008", new byte[] { 0 }, UpDownType.UP);
222         helper("1.008", new byte[] { 1 }, UpDownType.DOWN);
223         // NOTE: This is how DPT 1.009 is defined: 0: open, 1: closed
224         // For historical reasons it is defined the other way on OH
225         helper("1.009", new byte[] { 0 }, OnOffType.OFF);
226         helper("1.009", new byte[] { 1 }, OnOffType.ON);
227         helper("1.009", new byte[] { 0 }, OpenClosedType.CLOSED);
228         helper("1.009", new byte[] { 1 }, OpenClosedType.OPEN);
229         helper("1.010", new byte[] { 0 }, StopMoveType.STOP);
230         helper("1.010", new byte[] { 1 }, StopMoveType.MOVE);
231         helper("1.011", new byte[] { 0 }, OnOffType.OFF);
232         helper("1.011", new byte[] { 1 }, OnOffType.ON);
233         helper("1.011", new byte[] { 0 }, OpenClosedType.CLOSED);
234         helper("1.011", new byte[] { 1 }, OpenClosedType.OPEN);
235         helper("1.012", new byte[] { 0 }, OnOffType.OFF);
236         helper("1.012", new byte[] { 1 }, OnOffType.ON);
237         helper("1.012", new byte[] { 0 }, OpenClosedType.CLOSED);
238         helper("1.012", new byte[] { 1 }, OpenClosedType.OPEN);
239         helper("1.013", new byte[] { 0 }, OnOffType.OFF);
240         helper("1.013", new byte[] { 1 }, OnOffType.ON);
241         helper("1.013", new byte[] { 0 }, OpenClosedType.CLOSED);
242         helper("1.013", new byte[] { 1 }, OpenClosedType.OPEN);
243         helper("1.014", new byte[] { 0 }, OnOffType.OFF);
244         helper("1.014", new byte[] { 1 }, OnOffType.ON);
245         helper("1.014", new byte[] { 0 }, OpenClosedType.CLOSED);
246         helper("1.014", new byte[] { 1 }, OpenClosedType.OPEN);
247         helper("1.015", new byte[] { 0 }, OnOffType.OFF);
248         helper("1.015", new byte[] { 1 }, OnOffType.ON);
249         helper("1.015", new byte[] { 0 }, OpenClosedType.CLOSED);
250         helper("1.015", new byte[] { 1 }, OpenClosedType.OPEN);
251         helper("1.016", new byte[] { 0 }, OnOffType.OFF);
252         helper("1.016", new byte[] { 1 }, OnOffType.ON);
253         helper("1.016", new byte[] { 0 }, OpenClosedType.CLOSED);
254         helper("1.016", new byte[] { 1 }, OpenClosedType.OPEN);
255         // DPT 1.017 is a special case, "trigger" has no "value", both 0 and 1 shall trigger
256         helper("1.017", new byte[] { 0 }, OnOffType.OFF);
257         helper("1.017", new byte[] { 0 }, OpenClosedType.CLOSED);
258         // Calimero maps it always to 0
259         // helper("1.017", new byte[] { 1 }, OnOffType.ON);
260         helper("1.018", new byte[] { 0 }, OnOffType.OFF);
261         helper("1.018", new byte[] { 1 }, OnOffType.ON);
262         helper("1.018", new byte[] { 0 }, OpenClosedType.CLOSED);
263         helper("1.018", new byte[] { 1 }, OpenClosedType.OPEN);
264         helper("1.019", new byte[] { 0 }, OnOffType.OFF);
265         helper("1.019", new byte[] { 1 }, OnOffType.ON);
266         helper("1.019", new byte[] { 0 }, OpenClosedType.CLOSED);
267         helper("1.019", new byte[] { 1 }, OpenClosedType.OPEN);
268
269         helper("1.021", new byte[] { 0 }, OnOffType.OFF);
270         helper("1.021", new byte[] { 1 }, OnOffType.ON);
271         helper("1.021", new byte[] { 0 }, OpenClosedType.CLOSED);
272         helper("1.021", new byte[] { 1 }, OpenClosedType.OPEN);
273         // DPT 1.022 is mapped to decimal, Calimero does not follow the recommendation
274         // from KNX spec to add offset 1
275         helper("1.022", new byte[] { 0 }, DecimalType.valueOf("0"));
276         helper("1.022", new byte[] { 1 }, DecimalType.valueOf("1"));
277         helper("1.023", new byte[] { 0 }, OnOffType.OFF);
278         helper("1.023", new byte[] { 1 }, OnOffType.ON);
279         helper("1.023", new byte[] { 0 }, OpenClosedType.CLOSED);
280         helper("1.023", new byte[] { 1 }, OpenClosedType.OPEN);
281         helper("1.024", new byte[] { 0 }, OnOffType.OFF);
282         helper("1.024", new byte[] { 1 }, OnOffType.ON);
283         helper("1.024", new byte[] { 0 }, OpenClosedType.CLOSED);
284         helper("1.024", new byte[] { 1 }, OpenClosedType.OPEN);
285
286         helper("1.100", new byte[] { 0 }, OnOffType.OFF);
287         helper("1.100", new byte[] { 1 }, OnOffType.ON);
288         helper("1.100", new byte[] { 0 }, OpenClosedType.CLOSED);
289         helper("1.100", new byte[] { 1 }, OpenClosedType.OPEN);
290
291         helper("1.1200", new byte[] { 0 }, OnOffType.OFF);
292         helper("1.1200", new byte[] { 1 }, OnOffType.ON);
293         helper("1.1200", new byte[] { 0 }, OpenClosedType.CLOSED);
294         helper("1.1200", new byte[] { 1 }, OpenClosedType.OPEN);
295         helper("1.1201", new byte[] { 0 }, OnOffType.OFF);
296         helper("1.1201", new byte[] { 1 }, OnOffType.ON);
297         helper("1.1201", new byte[] { 0 }, OpenClosedType.CLOSED);
298         helper("1.1201", new byte[] { 1 }, OpenClosedType.OPEN);
299     }
300
301     @Test
302     void testDpt2() {
303         for (int subType = 1; subType <= 12; subType++) {
304             helper("2." + String.format("%03d", subType), new byte[] { 3 }, new DecimalType(3));
305         }
306     }
307
308     @Test
309     void testDpt3() {
310         // DPT 3.007 and DPT 3.008 consist of a control bit (1 bit) and stepsize (3 bit)
311         // if stepsize is 0, OH will ignore the command
312         byte controlBit = 1 << 3;
313         // loop all other step sizes and check only the control bit
314         for (byte i = 1; i < 8; i++) {
315             helper("3.007", new byte[] { i }, IncreaseDecreaseType.DECREASE, new byte[0], new byte[] { controlBit });
316             helper("3.007", new byte[] { (byte) (i + controlBit) }, IncreaseDecreaseType.INCREASE, new byte[0],
317                     new byte[] { controlBit });
318             helper("3.008", new byte[] { i }, UpDownType.UP, new byte[0], new byte[] { controlBit });
319             helper("3.008", new byte[] { (byte) (i + controlBit) }, UpDownType.DOWN, new byte[0],
320                     new byte[] { controlBit });
321         }
322
323         // check if OH ignores incoming frames with mask 0 (mapped to UndefType)
324         Assertions.assertFalse(ValueDecoder.decode("3.007", new byte[] { 0 },
325                 IncreaseDecreaseType.class) instanceof IncreaseDecreaseType);
326         Assertions.assertFalse(ValueDecoder.decode("3.007", new byte[] { controlBit },
327                 IncreaseDecreaseType.class) instanceof IncreaseDecreaseType);
328         Assertions.assertFalse(ValueDecoder.decode("3.008", new byte[] { 0 }, UpDownType.class) instanceof UpDownType);
329         Assertions.assertFalse(
330                 ValueDecoder.decode("3.008", new byte[] { controlBit }, UpDownType.class) instanceof UpDownType);
331     }
332
333     @Test
334     void testDpt5() {
335         helper("5.001", new byte[] { 0 }, new QuantityType<>("0 %"));
336         helper("5.001", new byte[] { (byte) 0xff }, new QuantityType<>("100 %"));
337         // fallback: PercentType
338         helper("5.001", new byte[] { 0 }, new PercentType(0));
339         helper("5.001", new byte[] { (byte) 0x80 }, new PercentType(50));
340         helper("5.001", new byte[] { (byte) 0xff }, new PercentType(100));
341
342         helper("5.003", new byte[] { 0 }, new QuantityType<>("0 °"));
343         helper("5.003", new byte[] { (byte) 0xff }, new QuantityType<>("360 °"));
344         helper("5.004", new byte[] { 0 }, new QuantityType<>("0 %"));
345         helper("5.004", new byte[] { (byte) 0x64 }, new QuantityType<>("100 %"));
346         helper("5.004", new byte[] { (byte) 0xff }, new QuantityType<>("255 %"));
347         // PercentType cannot encode values >100%, not supported for 5.004
348         helper("5.005", new byte[] { 42 }, new DecimalType(42));
349         helper("5.005", new byte[] { (byte) 0xff }, new DecimalType(255));
350         helper("5.006", new byte[] { 0 }, new DecimalType(0));
351         helper("5.006", new byte[] { 42 }, new DecimalType(42));
352         helper("5.006", new byte[] { (byte) 0xfe }, new DecimalType(254));
353
354         helper("5.010", new byte[] { 42 }, new DecimalType(42));
355         helper("5.010", new byte[] { (byte) 0xff }, new DecimalType(255));
356     }
357
358     @Test
359     void testDpt6() {
360         helper("6.001", new byte[] { 0 }, new QuantityType<>("0 %"));
361         helper("6.001", new byte[] { (byte) 0x7f }, new QuantityType<>("127 %"));
362         helper("6.001", new byte[] { (byte) 0xff }, new QuantityType<>("-1 %"));
363         // PercentType cannot encode values >100% or <0%, not supported for 6.001
364
365         helper("6.010", new byte[] { 0 }, new DecimalType(0));
366         helper("6.010", new byte[] { (byte) 0x7f }, new DecimalType(127));
367         helper("6.010", new byte[] { (byte) 0xff }, new DecimalType(-1));
368
369         helper("6.020", new byte[] { 9 }, StringType.valueOf("0/0/0/0/1 0"));
370     }
371
372     @Test
373     void testDpt7() {
374         helper("7.001", new byte[] { 0, 42 }, new DecimalType(42));
375         helper("7.001", new byte[] { (byte) 0xff, (byte) 0xff }, new DecimalType(65535));
376         // workaround in place, as Calimero uses "s" instead of "ms"
377         // refs: ValueEncoder::handleNumericTypes() (case 7) and DptUnits (static initialization)
378         assertTrue("s".equals(DPTXlator2ByteUnsigned.DPT_TIMEPERIOD_10.getUnit()));
379         helper("7.002", new byte[] { (byte) 0x00, (byte) 0xff }, new QuantityType<>("255 ms"));
380         helper("7.002", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 ms"));
381         helper("7.002", new byte[] { (byte) 0xff, (byte) 0xff }, new QuantityType<>("65535 ms"));
382         assertTrue("s".equals(DPTXlator2ByteUnsigned.DPT_TIMEPERIOD_100.getUnit()));
383         helper("7.003", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 ms"));
384         helper("7.003", new byte[] { (byte) 0x00, (byte) 0x64 }, new QuantityType<>("1000 ms"));
385         helper("7.003", new byte[] { (byte) 0x00, (byte) 0xff }, new QuantityType<>("2550 ms"));
386         helper("7.003", new byte[] { (byte) 0xff, (byte) 0xff }, new QuantityType<>("655350 ms"));
387         helper("7.004", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 ms"));
388         helper("7.004", new byte[] { (byte) 0x00, (byte) 0xff }, new QuantityType<>("25500 ms"));
389         helper("7.004", new byte[] { (byte) 0xff, (byte) 0xff }, new QuantityType<>("6553500 ms"));
390         helper("7.005", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 s"));
391         helper("7.005", new byte[] { (byte) 0x00, (byte) 0xff }, new QuantityType<>("255 s"));
392         helper("7.005", new byte[] { (byte) 0xff, (byte) 0xff }, new QuantityType<>("65535 s"));
393         helper("7.006", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 min"));
394         helper("7.006", new byte[] { (byte) 0x00, (byte) 0xff }, new QuantityType<>("255 min"));
395         helper("7.006", new byte[] { (byte) 0xff, (byte) 0xff }, new QuantityType<>("65535 min"));
396         helper("7.006", new byte[] { (byte) 0xff, (byte) 0xff }, new QuantityType<>("3932100 s"));
397         helper("7.007", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 h"));
398         helper("7.007", new byte[] { (byte) 0x00, (byte) 0xff }, new QuantityType<>("255 h"));
399         helper("7.007", new byte[] { (byte) 0x00, (byte) 0xff }, new QuantityType<>("918000 s"));
400         helper("7.007", new byte[] { (byte) 0xff, (byte) 0xff }, new QuantityType<>("65535 h"));
401
402         helper("7.010", new byte[] { 0, 42 }, new DecimalType(42));
403         helper("7.010", new byte[] { (byte) 0xff, (byte) 0xff }, new DecimalType(65535));
404         helper("7.011", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 mm"));
405         helper("7.011", new byte[] { (byte) 0x00, (byte) 0xff }, new QuantityType<>("255 mm"));
406         helper("7.011", new byte[] { (byte) 0xff, (byte) 0xff }, new QuantityType<>("65535 mm"));
407         helper("7.012", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 mA"));
408         helper("7.012", new byte[] { (byte) 0x00, (byte) 0xff }, new QuantityType<>("255 mA"));
409         helper("7.012", new byte[] { (byte) 0xff, (byte) 0xff }, new QuantityType<>("65535 mA"));
410         helper("7.013", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 lx"));
411         helper("7.013", new byte[] { (byte) 0x00, (byte) 0xff }, new QuantityType<>("255 lx"));
412         helper("7.013", new byte[] { (byte) 0xff, (byte) 0xff }, new QuantityType<>("65535 lx"));
413
414         helper("7.600", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 K"));
415         helper("7.600", new byte[] { (byte) 0x00, (byte) 0xff }, new QuantityType<>("255 K"));
416         helper("7.600", new byte[] { (byte) 0xff, (byte) 0xff }, new QuantityType<>("65535 K"));
417     }
418
419     @Test
420     void testDpt8() {
421         helper("8.001", new byte[] { (byte) 0x7f, (byte) 0xff }, new DecimalType(32767));
422         helper("8.001", new byte[] { (byte) 0x80, (byte) 0x00 }, new DecimalType(-32768));
423         helper("8.002", new byte[] { (byte) 0x80, (byte) 0x00 }, new QuantityType<>("-32768 ms"));
424         helper("8.002", new byte[] { (byte) 0x7f, (byte) 0xff }, new QuantityType<>("32767 ms"));
425         helper("8.002", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 ms"));
426         helper("8.003", new byte[] { (byte) 0x80, (byte) 0x00 }, new QuantityType<>("-327680 ms"));
427         helper("8.003", new byte[] { (byte) 0x7f, (byte) 0xff }, new QuantityType<>("327670 ms"));
428         helper("8.003", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 ms"));
429         helper("8.004", new byte[] { (byte) 0x80, (byte) 0x00 }, new QuantityType<>("-3276800 ms"));
430         helper("8.004", new byte[] { (byte) 0x7f, (byte) 0xff }, new QuantityType<>("3276700 ms"));
431         helper("8.004", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 ms"));
432         helper("8.005", new byte[] { (byte) 0x80, (byte) 0x00 }, new QuantityType<>("-32768 s"));
433         helper("8.005", new byte[] { (byte) 0x7f, (byte) 0xff }, new QuantityType<>("32767 s"));
434         helper("8.005", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 s"));
435         helper("8.006", new byte[] { (byte) 0x80, (byte) 0x00 }, new QuantityType<>("-32768 min"));
436         helper("8.006", new byte[] { (byte) 0x7f, (byte) 0xff }, new QuantityType<>("32767 min"));
437         helper("8.006", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 min"));
438         helper("8.007", new byte[] { (byte) 0x80, (byte) 0x00 }, new QuantityType<>("-32768 h"));
439         helper("8.007", new byte[] { (byte) 0x7f, (byte) 0xff }, new QuantityType<>("32767 h"));
440         helper("8.007", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 h"));
441
442         helper("8.010", new byte[] { (byte) 0x80, (byte) 0x00 }, new QuantityType<>("-327.68 %"));
443         helper("8.011", new byte[] { (byte) 0x80, (byte) 0x00 }, new QuantityType<>("-32768 °"));
444         helper("8.011", new byte[] { (byte) 0x7f, (byte) 0xff }, new QuantityType<>("32767 °"));
445         helper("8.011", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 °"));
446         helper("8.012", new byte[] { (byte) 0x80, (byte) 0x00 }, new QuantityType<>("-32768 m"));
447         helper("8.012", new byte[] { (byte) 0x7f, (byte) 0xff }, new QuantityType<>("32767 m"));
448         helper("8.012", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 m"));
449     }
450
451     @Test
452     void testDpt9() {
453         // special float with sign, 4-bit exponent, and mantissa in two's complement notation
454         // ref: KNX spec, 03_07_02-Datapoint-Types
455         // FIXME according to spec, value 0x7fff shall be regarded as "invalid data"
456         // FIXME lower boundary not fully covered by Calimero library
457         // TODO add tests for clipping at lower boundary (e.g. absolute zero)
458         helper("9.001", new byte[] { (byte) 0x00, (byte) 0x64 }, new QuantityType<>("1 °C"));
459         helper("9.001", new byte[] { (byte) 0x87, (byte) 0x9c }, new QuantityType<>("-1 °C"));
460         helper("9.001", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 °C"));
461         helper("9.001", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 °C"));
462         // lower values than absolute zero will be set to abs. zero (-273 °C)
463         // helper("9.001", new byte[] { (byte) 0xf8, (byte) 0x00 }, new QuantityType<>("-273 °C"));
464         helper("9.002", new byte[] { (byte) 0x00, (byte) 0x64 }, new QuantityType<>("1 K"));
465         helper("9.002", new byte[] { (byte) 0x87, (byte) 0x9c }, new QuantityType<>("-1 K"));
466         helper("9.002", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 K"));
467         helper("9.002", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 K"));
468         // broken, Calimero does not allow full range
469         // helper("9.002", new byte[] { (byte) 0xf8, (byte) 0x00 }, new QuantityType<>("-671088.64 K"));
470         helper("9.003", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 K/h"));
471         helper("9.003", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 K/h"));
472         helper("9.003", new byte[] { (byte) 0x87, (byte) 0x9c }, new QuantityType<>("-1 K/h"));
473         // broken, Calimero does not allow full range
474         // helper("9.003", new byte[] { (byte) 0xf8, (byte) 0x00 }, new QuantityType<>("-671088.64 K/h"));
475         helper("9.004", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 lx"));
476         helper("9.004", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 lx"));
477         helper("9.004", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 lx"));
478         // no negative values allowed for DPTs 9.004-9.008
479         helper("9.005", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 m/s"));
480         helper("9.005", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 m/s"));
481         helper("9.005", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 m/s"));
482         helper("9.005", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 m/s"));
483         helper("9.005", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 m/s"));
484         helper("9.005", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 m/s"));
485         helper("9.006", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 Pa"));
486         helper("9.006", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 Pa"));
487         helper("9.006", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 Pa"));
488         helper("9.007", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 %"));
489         helper("9.007", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 %"));
490         helper("9.007", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 %"));
491         helper("9.008", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 ppm"));
492         helper("9.008", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 ppm"));
493         helper("9.008", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 ppm"));
494         helper("9.009", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 m³/h"));
495         helper("9.009", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 m³/h"));
496         helper("9.009", new byte[] { (byte) 0x87, (byte) 0x9c }, new QuantityType<>("-1 m³/h"));
497         // broken, Calimero does not allow full range
498         // helper("9.009", new byte[] { (byte) 0xf8, (byte) 0x00 }, new QuantityType<>("-671088.64 m³/h"));
499         helper("9.010", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 s"));
500         helper("9.010", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 s"));
501         helper("9.010", new byte[] { (byte) 0x87, (byte) 0x9c }, new QuantityType<>("-1 s"));
502         // broken, Calimero does not allow full range
503         // helper("9.010", new byte[] { (byte) 0xf8, (byte) 0x00 }, new QuantityType<>("-671088.64 s"));
504         helper("9.011", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 ms"));
505         helper("9.011", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 ms"));
506         helper("9.011", new byte[] { (byte) 0x87, (byte) 0x9c }, new QuantityType<>("-1 ms"));
507         // broken, Calimero does not allow full range
508         // helper("9.011", new byte[] { (byte) 0xf8, (byte) 0x00 }, new QuantityType<>("-671088.64 K/h"));
509
510         helper("9.020", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 mV"));
511         helper("9.020", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 mV"));
512         helper("9.020", new byte[] { (byte) 0x87, (byte) 0x9c }, new QuantityType<>("-1 mV"));
513         // broken, Calimero does not allow full range
514         // helper("9.020", new byte[] { (byte) 0xf8, (byte) 0x00 }, new QuantityType<>("-671088.64 mV"));
515         helper("9.021", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 mA"));
516         helper("9.021", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 mA"));
517         helper("9.021", new byte[] { (byte) 0x87, (byte) 0x9c }, new QuantityType<>("-1 mA"));
518         // broken, Calimero does not allow full range
519         // helper("9.021", new byte[] { (byte) 0xf8, (byte) 0x00 }, new QuantityType<>("-671088.64 mA"));
520         helper("9.022", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 W/m²"));
521         helper("9.022", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 W/m²"));
522         helper("9.022", new byte[] { (byte) 0x87, (byte) 0x9c }, new QuantityType<>("-1 W/m²"));
523         // broken, Calimero does not allow full range
524         // helper("9.022", new byte[] { (byte) 0xf8, (byte) 0x00 }, new QuantityType<>("-671088.64 W/m²"));
525         helper("9.023", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 K/%"));
526         helper("9.023", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 K/%"));
527         helper("9.023", new byte[] { (byte) 0x87, (byte) 0x9c }, new QuantityType<>("-1 K/%"));
528         // broken, Calimero does not allow full range
529         // helper("9.023", new byte[] { (byte) 0xf8, (byte) 0x00 }, new QuantityType<>("-671088.64 K/%"));
530         helper("9.024", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 kW"));
531         helper("9.024", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 kW"));
532         helper("9.024", new byte[] { (byte) 0x87, (byte) 0x9c }, new QuantityType<>("-1 kW"));
533         // broken, Calimero does not allow full range
534         // helper("9.024", new byte[] { (byte) 0xf8, (byte) 0x00 }, new QuantityType<>("-671088.64 kW"));
535         helper("9.025", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 l/h"));
536         helper("9.025", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 l/h"));
537         helper("9.025", new byte[] { (byte) 0x87, (byte) 0x9c }, new QuantityType<>("-1 l/h"));
538         // broken, Calimero does not allow full range
539         // helper("9.025", new byte[] { (byte) 0xf8, (byte) 0x00 }, new QuantityType<>("-671088.64 l/h"));
540         helper("9.026", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 l/m²"));
541         helper("9.026", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 l/m²"));
542         helper("9.026", new byte[] { (byte) 0x87, (byte) 0x9c }, new QuantityType<>("-1 l/m²"));
543         // broken, Calimero does not allow full range
544         // helper("9.026", new byte[] { (byte) 0xf8, (byte) 0x00 }, new QuantityType<>("-671088.64 l/m²"));
545         helper("9.027", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 °F"));
546         helper("9.027", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 °F"));
547         helper("9.027", new byte[] { (byte) 0x87, (byte) 0x9c }, new QuantityType<>("-1 °F"));
548         // lower values than absolute zero will be set to abs. zero (-459.6 °F)
549         helper("9.028", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 km/h"));
550         helper("9.028", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 km/h"));
551         helper("9.028", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 km/h"));
552         // no negative values allowed for DPTs 9.028-9.030
553         helper("9.029", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 g/m³"));
554         helper("9.029", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 g/m³"));
555         helper("9.029", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 g/m³"));
556         helper("9.030", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 µg/m³"));
557         helper("9.030", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 µg/m³"));
558         helper("9.030", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 µg/m³"));
559     }
560
561     @Test
562     void testDpt10() {
563         // TODO check handling of DPT10: date is not set to current date, but 1970-01-01 + offset if day is given
564         // maybe we should change the semantics and use current date + offset if day is given
565
566         // note: local timezone is set when creating DateTimeType, for example "1970-01-01Thh:mm:ss.000+0100"
567
568         // no-day
569         assertTrue(Objects
570                 .toString(ValueDecoder.decode("10.001", new byte[] { (byte) 0x11, (byte) 0x1e, 0 }, DecimalType.class))
571                 .startsWith("1970-01-01T17:30:00.000+"));
572         // Thursday, this is correct for 1970-01-01
573         assertTrue(Objects
574                 .toString(ValueDecoder.decode("10.001", new byte[] { (byte) 0x91, (byte) 0x1e, 0 }, DecimalType.class))
575                 .startsWith("1970-01-01T17:30:00.000+"));
576         // Monday -> 1970-01-05
577         assertTrue(Objects
578                 .toString(ValueDecoder.decode("10.001", new byte[] { (byte) 0x31, (byte) 0x1e, 0 }, DecimalType.class))
579                 .startsWith("1970-01-05T17:30:00.000+"));
580
581         // Thursday, otherwise first byte of encoded data will not match
582         helper("10.001", new byte[] { (byte) 0x91, (byte) 0x1e, (byte) 0x0 }, new DateTimeType("17:30:00"));
583         helper("10.001", new byte[] { (byte) 0x11, (byte) 0x1e, (byte) 0x0 }, new DateTimeType("17:30:00"), new byte[0],
584                 new byte[] { (byte) 0x1f, (byte) 0xff, (byte) 0xff });
585     }
586
587     @Test
588     void testDpt11() {
589         // note: local timezone and dst is set when creating DateTimeType, for example "2019-06-12T00:00:00.000+0200"
590         helper("11.001", new byte[] { (byte) 12, 6, 19 }, new DateTimeType("2019-06-12"));
591     }
592
593     @Test
594     void testDpt12() {
595         helper("12.001", new byte[] { (byte) 0xff, (byte) 0xff, (byte) 0xff, (byte) 0xfe },
596                 new DecimalType("4294967294"));
597         helper("12.100", new byte[] { 0, 0, 0, 60 }, new QuantityType<>("60 s"));
598         helper("12.100", new byte[] { 0, 0, 0, 60 }, new QuantityType<>("1 min"));
599         helper("12.101", new byte[] { 0, 0, 0, 60 }, new QuantityType<>("60 min"));
600         helper("12.101", new byte[] { 0, 0, 0, 60 }, new QuantityType<>("1 h"));
601         helper("12.102", new byte[] { 0, 0, 0, 1 }, new QuantityType<>("1 h"));
602         helper("12.102", new byte[] { 0, 0, 0, 1 }, new QuantityType<>("60 min"));
603
604         helper("12.1200", new byte[] { 0, 0, 0, 1 }, new QuantityType<>("1 l"));
605         helper("12.1200", new byte[] { (byte) 0xff, (byte) 0xff, (byte) 0xff, (byte) 0xfe },
606                 new QuantityType<>("4294967294 l"));
607         helper("12.1201", new byte[] { 0, 0, 0, 1 }, new QuantityType<>("1 m³"));
608         helper("12.1201", new byte[] { (byte) 0xff, (byte) 0xff, (byte) 0xff, (byte) 0xfe },
609                 new QuantityType<>("4294967294 m³"));
610     }
611
612     @Test
613     void testDpt13() {
614         helper("13.001", new byte[] { 0, 0, 0, 0 }, new DecimalType(0));
615         helper("13.001", new byte[] { 0, 0, 0, 42 }, new DecimalType(42));
616         helper("13.001", new byte[] { (byte) 0x7f, (byte) 0xff, (byte) 0xff, (byte) 0xff },
617                 new DecimalType(2147483647));
618         // KNX representation typically uses two's complement
619         helper("13.001", new byte[] { (byte) 0xff, (byte) 0xff, (byte) 0xff, (byte) 0xff }, new DecimalType(-1));
620         helper("13.001", new byte[] { (byte) 0x80, (byte) 0x0, (byte) 0x0, (byte) 0x0 }, new DecimalType(-2147483648));
621         helper("13.002", new byte[] { 0, 0, 0, 0 }, new QuantityType<>("0 m³/h"));
622         helper("13.002", new byte[] { (byte) 0x80, (byte) 0x0, (byte) 0x0, (byte) 0x0 },
623                 new QuantityType<>("-2147483648 m³/h"));
624         helper("13.002", new byte[] { (byte) 0x7f, (byte) 0xff, (byte) 0xff, (byte) 0xff },
625                 new QuantityType<>("2147483647 m³/h"));
626
627         helper("13.010", new byte[] { 0, 0, 0, 0 }, new QuantityType<>("0 Wh"));
628         helper("13.010", new byte[] { (byte) 0x80, (byte) 0x0, (byte) 0x0, (byte) 0x0 },
629                 new QuantityType<>("-2147483648 Wh"));
630         helper("13.010", new byte[] { (byte) 0x7f, (byte) 0xff, (byte) 0xff, (byte) 0xff },
631                 new QuantityType<>("2147483647 Wh"));
632         helper("13.011", new byte[] { 0, 0, 0, 0 }, new QuantityType<>("0 VAh"));
633         helper("13.011", new byte[] { (byte) 0x80, (byte) 0x0, (byte) 0x0, (byte) 0x0 },
634                 new QuantityType<>("-2147483648 VAh"));
635         helper("13.011", new byte[] { (byte) 0x7f, (byte) 0xff, (byte) 0xff, (byte) 0xff },
636                 new QuantityType<>("2147483647 VAh"));
637         helper("13.012", new byte[] { 0, 0, 0, 0 }, new QuantityType<>("0 varh"));
638         helper("13.012", new byte[] { (byte) 0x80, (byte) 0x0, (byte) 0x0, (byte) 0x0 },
639                 new QuantityType<>("-2147483648 varh"));
640         helper("13.012", new byte[] { (byte) 0x7f, (byte) 0xff, (byte) 0xff, (byte) 0xff },
641                 new QuantityType<>("2147483647 varh"));
642         helper("13.013", new byte[] { 0, 0, 0, 0 }, new QuantityType<>("0 kWh"));
643         helper("13.013", new byte[] { (byte) 0x80, (byte) 0x0, (byte) 0x0, (byte) 0x0 },
644                 new QuantityType<>("-2147483648 kWh"));
645         helper("13.013", new byte[] { (byte) 0x7f, (byte) 0xff, (byte) 0xff, (byte) 0xff },
646                 new QuantityType<>("2147483647 kWh"));
647         helper("13.014", new byte[] { 0, 0, 0, 0 }, new QuantityType<>("0 VAh"));
648         helper("13.014", new byte[] { (byte) 0x80, (byte) 0x0, (byte) 0x0, (byte) 0x0 },
649                 new QuantityType<>("-2147483648000 VAh"));
650         helper("13.014", new byte[] { (byte) 0x7f, (byte) 0xff, (byte) 0xff, (byte) 0xff },
651                 new QuantityType<>("2147483647000 VAh"));
652         helper("13.015", new byte[] { 0, 0, 0, 0 }, new QuantityType<>("0 kvarh"));
653         helper("13.015", new byte[] { (byte) 0x80, (byte) 0x0, (byte) 0x0, (byte) 0x0 },
654                 new QuantityType<>("-2147483648 kvarh"));
655         helper("13.015", new byte[] { (byte) 0x7f, (byte) 0xff, (byte) 0xff, (byte) 0xff },
656                 new QuantityType<>("2147483647 kvarh"));
657         helper("13.016", new byte[] { 0, 0, 0, 0 }, new QuantityType<>("0 MWh"));
658         helper("13.016", new byte[] { (byte) 0x80, (byte) 0x0, (byte) 0x0, (byte) 0x0 },
659                 new QuantityType<>("-2147483648 MWh"));
660         helper("13.016", new byte[] { (byte) 0x7f, (byte) 0xff, (byte) 0xff, (byte) 0xff },
661                 new QuantityType<>("2147483647 MWh"));
662
663         helper("13.100", new byte[] { 0, 0, 0, 0 }, new QuantityType<>("0 s"));
664         helper("13.100", new byte[] { (byte) 0x80, (byte) 0x0, (byte) 0x0, (byte) 0x0 },
665                 new QuantityType<>("-2147483648 s"));
666         helper("13.100", new byte[] { (byte) 0x7f, (byte) 0xff, (byte) 0xff, (byte) 0xff },
667                 new QuantityType<>("2147483647 s"));
668
669         helper("13.1200", new byte[] { 0, 0, 0, 0 }, new QuantityType<>("0 l"));
670         helper("13.1200", new byte[] { (byte) 0x80, (byte) 0x0, (byte) 0x0, (byte) 0x0 },
671                 new QuantityType<>("-2147483648 l"));
672         helper("13.1200", new byte[] { (byte) 0x7f, (byte) 0xff, (byte) 0xff, (byte) 0xff },
673                 new QuantityType<>("2147483647 l"));
674         helper("13.1201", new byte[] { 0, 0, 0, 0 }, new QuantityType<>("0 m³"));
675         helper("13.1201", new byte[] { (byte) 0x80, (byte) 0x0, (byte) 0x0, (byte) 0x0 },
676                 new QuantityType<>("-2147483648 m³"));
677         helper("13.1201", new byte[] { (byte) 0x7f, (byte) 0xff, (byte) 0xff, (byte) 0xff },
678                 new QuantityType<>("2147483647 m³"));
679     }
680
681     @Test
682     void testDpt14() {
683         helper("14.000", new byte[] { (byte) 0x3f, (byte) 0x80, 0, 0 }, new QuantityType<>("1 m/s²"));
684         helper("14.000", F32_MINUS_ONE, new QuantityType<>("-1 m/s²"));
685         helper("14.001", F32_MINUS_ONE, new QuantityType<>("-1 rad/s²"));
686         helper("14.002", F32_MINUS_ONE, new QuantityType<>("-1 J/mol"));
687         helper("14.003", F32_MINUS_ONE, new QuantityType<>("-1 /s"));
688         helper("14.004", F32_MINUS_ONE, new QuantityType<>("-1 mol"));
689         helper("14.005", F32_MINUS_ONE, new DecimalType("-1"));
690         helper("14.006", F32_MINUS_ONE, new QuantityType<>("-1 rad"));
691         helper("14.007", F32_MINUS_ONE, new QuantityType<>("-1 °"));
692         helper("14.008", F32_MINUS_ONE, new QuantityType<>("-1 J*s"));
693         helper("14.009", F32_MINUS_ONE, new QuantityType<>("-1 rad/s"));
694         helper("14.010", F32_MINUS_ONE, new QuantityType<>("-1 m²"));
695         helper("14.011", F32_MINUS_ONE, new QuantityType<>("-1 F"));
696         helper("14.012", F32_MINUS_ONE, new QuantityType<>("-1 C/m²"));
697         helper("14.013", F32_MINUS_ONE, new QuantityType<>("-1 C/m³"));
698         helper("14.014", F32_MINUS_ONE, new QuantityType<>("-1 m²/N"));
699         helper("14.015", F32_MINUS_ONE, new QuantityType<>("-1 S"));
700         helper("14.016", F32_MINUS_ONE, new QuantityType<>("-1 S/m"));
701         helper("14.017", F32_MINUS_ONE, new QuantityType<>("-1 kg/m³"));
702         helper("14.018", F32_MINUS_ONE, new QuantityType<>("-1 C"));
703         helper("14.019", F32_MINUS_ONE, new QuantityType<>("-1 A"));
704         helper("14.020", F32_MINUS_ONE, new QuantityType<>("-1 A/m²"));
705         helper("14.021", F32_MINUS_ONE, new QuantityType<>("-1 C*m"));
706         helper("14.022", F32_MINUS_ONE, new QuantityType<>("-1 C/m²"));
707         helper("14.023", F32_MINUS_ONE, new QuantityType<>("-1 V/m"));
708         helper("14.024", F32_MINUS_ONE, new QuantityType<>("-1 V*m")); // SI unit is Vm
709         helper("14.025", F32_MINUS_ONE, new QuantityType<>("-1 C/m²"));
710         helper("14.026", F32_MINUS_ONE, new QuantityType<>("-1 C/m²"));
711         helper("14.027", F32_MINUS_ONE, new QuantityType<>("-1 V"));
712         helper("14.028", F32_MINUS_ONE, new QuantityType<>("-1 V"));
713         helper("14.029", F32_MINUS_ONE, new QuantityType<>("-1 A*m²"));
714         helper("14.030", F32_MINUS_ONE, new QuantityType<>("-1 V"));
715         helper("14.031", F32_MINUS_ONE, new QuantityType<>("-1 J"));
716         helper("14.032", F32_MINUS_ONE, new QuantityType<>("-1 N"));
717         helper("14.033", F32_MINUS_ONE, new QuantityType<>("-1 /s"));
718         helper("14.034", F32_MINUS_ONE, new QuantityType<>("-1 rad/s"));
719         helper("14.035", F32_MINUS_ONE, new QuantityType<>("-1 J/K"));
720         helper("14.036", F32_MINUS_ONE, new QuantityType<>("-1 W"));
721         helper("14.037", F32_MINUS_ONE, new QuantityType<>("-1 J"));
722         helper("14.038", F32_MINUS_ONE, new QuantityType<>("-1 Ohm"));
723         helper("14.039", F32_MINUS_ONE, new QuantityType<>("-1 m"));
724         helper("14.040", F32_MINUS_ONE, new QuantityType<>("-1 J"));
725         helper("14.041", F32_MINUS_ONE, new QuantityType<>("-1 cd/m²"));
726         helper("14.042", F32_MINUS_ONE, new QuantityType<>("-1 lm"));
727         helper("14.043", F32_MINUS_ONE, new QuantityType<>("-1 cd"));
728         helper("14.044", F32_MINUS_ONE, new QuantityType<>("-1 A/m"));
729         helper("14.045", F32_MINUS_ONE, new QuantityType<>("-1 Wb"));
730         helper("14.046", F32_MINUS_ONE, new QuantityType<>("-1 T"));
731         helper("14.047", F32_MINUS_ONE, new QuantityType<>("-1 A*m²"));
732         helper("14.048", F32_MINUS_ONE, new QuantityType<>("-1 T"));
733         helper("14.049", F32_MINUS_ONE, new QuantityType<>("-1 A/m"));
734         helper("14.050", F32_MINUS_ONE, new QuantityType<>("-1 A"));
735         helper("14.051", F32_MINUS_ONE, new QuantityType<>("-1 kg"));
736         helper("14.052", F32_MINUS_ONE, new QuantityType<>("-1 kg/s"));
737         helper("14.053", F32_MINUS_ONE, new QuantityType<>("-1 N/s"));
738         helper("14.054", F32_MINUS_ONE, new QuantityType<>("-1 rad"));
739         helper("14.055", F32_MINUS_ONE, new QuantityType<>("-1 °"));
740         helper("14.056", F32_MINUS_ONE, new QuantityType<>("-1 W"));
741         helper("14.057", F32_MINUS_ONE, new DecimalType("-1"));
742         helper("14.058", F32_MINUS_ONE, new QuantityType<>("-1 Pa"));
743         helper("14.059", F32_MINUS_ONE, new QuantityType<>("-1 Ohm"));
744         helper("14.060", F32_MINUS_ONE, new QuantityType<>("-1 Ohm"));
745         helper("14.061", F32_MINUS_ONE, new QuantityType<>("-1 Ohm*m"));
746         helper("14.062", F32_MINUS_ONE, new QuantityType<>("-1 H"));
747         helper("14.063", F32_MINUS_ONE, new QuantityType<>("-1 sr"));
748         helper("14.064", F32_MINUS_ONE, new QuantityType<>("-1 W/m²"));
749         helper("14.065", F32_MINUS_ONE, new QuantityType<>("-1 m/s"));
750         helper("14.066", F32_MINUS_ONE, new QuantityType<>("-1 Pa"));
751         helper("14.067", F32_MINUS_ONE, new QuantityType<>("-1 N/m"));
752         helper("14.068", new byte[] { (byte) 0x3f, (byte) 0x80, 0, 0 }, new QuantityType<>("1 °C"));
753         helper("14.068", F32_MINUS_ONE, new QuantityType<>("-1 °C"));
754         helper("14.069", F32_MINUS_ONE, new QuantityType<>("-1 K"));
755         helper("14.070", F32_MINUS_ONE, new QuantityType<>("-1 K"));
756         helper("14.071", F32_MINUS_ONE, new QuantityType<>("-1 J/K"));
757         helper("14.072", F32_MINUS_ONE, new QuantityType<>("-1 W/m/K"));
758         helper("14.073", F32_MINUS_ONE, new QuantityType<>("-1 V/K"));
759         helper("14.074", F32_MINUS_ONE, new QuantityType<>("-1 s"));
760         helper("14.075", F32_MINUS_ONE, new QuantityType<>("-1 N*m"));
761         helper("14.076", F32_MINUS_ONE, new QuantityType<>("-1 m³"));
762         helper("14.077", F32_MINUS_ONE, new QuantityType<>("-1 m³/s"));
763         helper("14.078", F32_MINUS_ONE, new QuantityType<>("-1 N"));
764         helper("14.079", F32_MINUS_ONE, new QuantityType<>("-1 J"));
765         helper("14.080", F32_MINUS_ONE, new QuantityType<>("-1 VA"));
766
767         helper("14.1200", F32_MINUS_ONE, new QuantityType<>("-1 m³/h"));
768         helper("14.1201", F32_MINUS_ONE, new QuantityType<>("-1 l/s"));
769     }
770
771     @Test
772     void testDpt16() {
773         helper("16.000", new byte[] { (byte) 0x4B, (byte) 0x4E, 0x58, 0x20, 0x69, 0x73, 0x20, (byte) 0x4F, (byte) 0x4B,
774                 0x0, 0x0, 0x0, 0x0, 0x0 }, new StringType("KNX is OK"));
775         helper("16.001", new byte[] { (byte) 0x4B, (byte) 0x4E, 0x58, 0x20, 0x69, 0x73, 0x20, (byte) 0x4F, (byte) 0x4B,
776                 0x0, 0x0, 0x0, 0x0, 0x0 }, new StringType("KNX is OK"));
777     }
778
779     @Test
780     void testDpt17() {
781         helper("17.001", new byte[] { 0 }, new DecimalType(0));
782         helper("17.001", new byte[] { 42 }, new DecimalType(42));
783         helper("17.001", new byte[] { 63 }, new DecimalType(63));
784     }
785
786     @Test
787     void testDpt18() {
788         // scene, activate 0..63
789         helper("18.001", new byte[] { 0 }, new DecimalType(0));
790         helper("18.001", new byte[] { 42 }, new DecimalType(42));
791         helper("18.001", new byte[] { 63 }, new DecimalType(63));
792         // scene, learn += 0x80
793         helper("18.001", new byte[] { (byte) (0x80 + 0) }, new DecimalType(0x80));
794         helper("18.001", new byte[] { (byte) (0x80 + 42) }, new DecimalType(0x80 + 42));
795         helper("18.001", new byte[] { (byte) (0x80 + 63) }, new DecimalType(0x80 + 63));
796     }
797
798     @Test
799     void testDpt19() {
800         // 2019-01-15 17:30:00
801         helper("19.001", new byte[] { (byte) (2019 - 1900), 1, 15, 17, 30, 0, (byte) 0x25, (byte) 0x00 },
802                 new DateTimeType("2019-01-15T17:30:00"));
803         helper("19.001", new byte[] { (byte) (2019 - 1900), 1, 15, 17, 30, 0, (byte) 0x24, (byte) 0x00 },
804                 new DateTimeType("2019-01-15T17:30:00"));
805         // 2019-07-15 17:30:00
806         helper("19.001", new byte[] { (byte) (2019 - 1900), 7, 15, 17, 30, 0, (byte) 0x25, (byte) 0x00 },
807                 new DateTimeType("2019-07-15T17:30:00"), new byte[0], new byte[] { 0, 0, 0, 0, 0, 0, 0, 1 });
808         helper("19.001", new byte[] { (byte) (2019 - 1900), 7, 15, 17, 30, 0, (byte) 0x24, (byte) 0x00 },
809                 new DateTimeType("2019-07-15T17:30:00"), new byte[0], new byte[] { 0, 0, 0, 0, 0, 0, 0, 1 });
810         // TODO add tests for incompletly filled frames (e.g. containing only date or time)
811     }
812
813     @Test
814     void testDpt20() {
815         // test default String representation of enum (incomplete)
816         helper("20.001", new byte[] { 0 }, new StringType("autonomous"));
817         helper("20.001", new byte[] { 1 }, new StringType("slave"));
818         helper("20.001", new byte[] { 2 }, new StringType("master"));
819
820         helper("20.002", new byte[] { 0 }, new StringType("building in use"));
821         helper("20.002", new byte[] { 1 }, new StringType("building not used"));
822         helper("20.002", new byte[] { 2 }, new StringType("building protection"));
823
824         // test DecimalType representation of enum
825         int[] subTypes = new int[] { 1, 2, 3, 4, 5, 6, 7, 8, 11, 12, 13, 14, 17, 20, 21, 100, 101, 102, 103, 104, 105,
826                 106, 107, 108, 109, 110, 111, 112, 113, 114, 120, 121, 122, 600, 601, 602, 603, 604, 605, 606, 607, 608,
827                 609, 610, 801, 802, 803, 804, 1000, 1001, 1002, 1003, 1004, 1005, 1200, 1202 };
828         for (int subType : subTypes) {
829             helper("20." + String.format("%03d", subType), new byte[] { 1 }, new DecimalType(1));
830         }
831         // once these DPTs are available in Calimero, add to check above
832         int[] unsupportedSubTypes = new int[] { 22, 115, 611, 612, 613, 1203, 1204, 1205, 1206, 1207, 1208, 1209 };
833         for (int subType : unsupportedSubTypes) {
834             assertNull(ValueDecoder.decode("20." + String.format("%03d", subType), new byte[] { 0 }, StringType.class));
835         }
836     }
837
838     @Test
839     void testDpt21() {
840         // test default String representation of bitfield (incomplete)
841         helper("21.001", new byte[] { 5 }, new StringType("overridden, out of service"));
842
843         // test DecimalType representation of bitfield
844         int[] subTypes = new int[] { 1, 2, 100, 101, 102, 103, 104, 105, 106, 601, 1000, 1001, 1002, 1010 };
845         for (int subType : subTypes) {
846             helper("21." + String.format("%03d", subType), new byte[] { 1 }, new DecimalType(1));
847         }
848         // once these DPTs are available in Calimero, add to check above
849         assertNull(ValueDecoder.decode("21.1200", new byte[] { 0 }, StringType.class));
850         assertNull(ValueDecoder.decode("21.1201", new byte[] { 0 }, StringType.class));
851     }
852
853     @Test
854     void testDpt22() {
855         // test default String representation of bitfield (incomplete)
856         helper("22.101", new byte[] { 1, 0 }, new StringType("heating mode"));
857         helper("22.101", new byte[] { 1, 2 }, new StringType("heating mode, heating eco mode"));
858
859         // test DecimalType representation of bitfield
860         helper("22.101", new byte[] { 0, 2 }, new DecimalType(2));
861         helper("22.1000", new byte[] { 0, 2 }, new DecimalType(2));
862         // once these DPTs are available in Calimero, add to check above
863         assertNull(ValueDecoder.decode("22.100", new byte[] { 0, 2 }, StringType.class));
864         assertNull(ValueDecoder.decode("22.1010", new byte[] { 0, 2 }, StringType.class));
865     }
866
867     @Test
868     void testDpt28() {
869         // null terminated strings, UTF8
870         helper("28.001", new byte[] { 0x31, 0x32, 0x33, 0x34, 0x0 }, new StringType("1234"));
871         helper("28.001", new byte[] { (byte) 0xce, (byte) 0xb5, 0x34, 0x0 }, new StringType("\u03b54"));
872     }
873
874     @Test
875     void testDpt29() {
876         helper("29.010", new byte[] { 0, 0, 0, 0, 0, 0, 0, 42 }, new QuantityType<>("42 Wh"));
877         helper("29.010", new byte[] { (byte) 0x80, 0, 0, 0, 0, 0, 0, 0 },
878                 new QuantityType<>("-9223372036854775808 Wh"));
879         helper("29.010", new byte[] { (byte) 0xff, 0, 0, 0, 0, 0, 0, 0 }, new QuantityType<>("-72057594037927936 Wh"));
880         helper("29.010", new byte[] { 0, 0, 0, 0, 0, 0, 0, 42 }, new QuantityType<>("42 Wh"));
881         helper("29.011", new byte[] { 0, 0, 0, 0, 0, 0, 0, 42 }, new QuantityType<>("42 VAh"));
882         helper("29.012", new byte[] { 0, 0, 0, 0, 0, 0, 0, 42 }, new QuantityType<>("42 varh"));
883     }
884
885     @Test
886     void testDpt229() {
887         // special DPT for metering, allows several units and different scaling
888         // -> Calimero uses scaling, but always encodes as dimensionless value
889         final int dimensionlessCounter = 0b10111010;
890         helper("229.001", new byte[] { 0, 0, 0, 0, (byte) dimensionlessCounter, 0 }, new DecimalType(0));
891     }
892
893     @Test
894     void testColorDpts() {
895         // HSB
896         helper("232.600", new byte[] { 123, 45, 67 }, ColorUtil.rgbToHsb(new int[] { 123, 45, 67 }));
897         // RGB, MDT specific
898         helper("232.60000", new byte[] { 123, 45, 67 }, new HSBType("173.6, 17.6, 26.3"));
899
900         // xyY
901         int x = (int) (14.65 * 65535.0 / 100.0);
902         int y = (int) (11.56 * 65535.0 / 100.0);
903         // encoding is always xy and brightness (C+B, 0x03), do not test other combinations
904         helper("242.600", new byte[] { (byte) ((x >> 8) & 0xff), (byte) (x & 0xff), (byte) ((y >> 8) & 0xff),
905                 (byte) (y & 0xff), (byte) 0x28, 0x3 }, new HSBType("220,90,50"), new byte[] { 0, 8, 0, 8, 0, 0 },
906                 new byte[0]);
907         // TODO check brightness
908
909         // RGBW, only RGB part
910         helper("251.600", new byte[] { 0x26, 0x2b, 0x31, 0x00, 0x00, 0x0e }, new HSBType("207, 23, 19"),
911                 new byte[] { 1, 1, 1, 0, 0, 0 }, new byte[0]);
912         // RGBW, only RGB part
913         helper("251.600", new byte[] { (byte) 0xff, (byte) 0xff, (byte) 0xff, 0x00, 0x00, 0x0e },
914                 new HSBType("0, 0, 100"), new byte[] { 1, 1, 1, 0, 0, 0 }, new byte[0]);
915         // RGBW, only W part
916         helper("251.600", new byte[] { 0x0, 0x0, 0x0, 0x1A, 0x00, 0x01 }, new PercentType("10.2"));
917         // RGBW, all
918         helper("251.60600", new byte[] { (byte) 0x0, (byte) 0x0, (byte) 0x0, (byte) 0xff, 0x00, 0x0f },
919                 new HSBType("0, 0, 100"), new byte[] { 1, 1, 1, 2, 0, 0 }, new byte[0]);
920         // RGBW, mixed
921         int[] rgbw = new int[] { 240, 0x0, 0x0, 0x0f };
922         HSBType hsb = ColorUtil.rgbToHsb(rgbw);
923         helper("251.60600", new byte[] { (byte) rgbw[0], (byte) rgbw[1], (byte) rgbw[2], (byte) rgbw[3], 0x00, 0x0f },
924                 hsb, new byte[] { 2, 2, 2, 2, 0, 0 }, new byte[0]);
925     }
926
927     @Test
928     void testColorTransitionDpts() {
929         // DPT 243.600 DPT_Colour_Transition_xyY
930         // time(2) y(2) x(2), %brightness(1), flags(1)
931         helper("243.600", new byte[] { 0, 5, 0x7F, 0, (byte) 0xfe, 0, 42, 3 },
932                 new StringType("(0.9922, 0.4961) 16.5 % 0.5 s"));
933         helper("243.600", new byte[] { (byte) 0x02, (byte) 0x00, 0x7F, 0, (byte) 0xfe, 0, 42, 3 },
934                 new StringType("(0.9922, 0.4961) 16.5 % 51.2 s"));
935         helper("243.600", new byte[] { (byte) 0x40, (byte) 0x00, 0x7F, 0, (byte) 0xfe, 0, 42, 3 },
936                 new StringType("(0.9922, 0.4961) 16.5 % 1638.4 s"));
937         helper("243.600", new byte[] { (byte) 0xff, (byte) 0xff, 0x7F, 0, (byte) 0xfe, 0, 42, 3 },
938                 new StringType("(0.9922, 0.4961) 16.5 % 6553.5 s"));
939         // DPT 249.600 DPT_Brightness_Colour_Temperature_Transition
940         // time(2) colortemp(2), brightness(1), flags(1)
941         helper("249.600", new byte[] { 0, 5, 0, 40, 127, 7 }, new StringType("49.8 % 40 K 0.5 s"));
942         helper("249.600", new byte[] { (byte) 0xff, (byte) 0xfa, 0, 40, 127, 7 }, new StringType("49.8 % 40 K 6553 s"));
943         helper("249.600", new byte[] { (byte) 0xff, (byte) 0xff, 0, 40, 127, 7 },
944                 new StringType("49.8 % 40 K 6553.5 s"));
945         // DPT 250.600 DPT_Brightness_Colour_Temperature_Control
946         // cct(1) cb(1) flags(1)
947         helper("250.600", new byte[] { 0x0f, 0x0e, 3 }, new StringType("CT increase 7 steps BRT increase 6 steps"));
948         // DPT 252.600 DPT_Relative_Control_RGBW
949         // r(1) g(1) b(1) w(1) flags(1)
950         helper("252.600", new byte[] { 0x0f, 0x0e, 0x0d, 0x0c, 0x0f },
951                 new StringType("R increase 7 steps G increase 6 steps B increase 5 steps W increase 4 steps"));
952         // DPT 253.600 DPT_Relative_Control_xyY
953         // cs(1) ct(1) cb(1) flags(1)
954         helper("253.600", new byte[] { 0x0f, 0x0e, 0x0d, 0x7 },
955                 new StringType("x increase 7 steps y increase 6 steps Y increase 5 steps"));
956         // DPT 254.600 DPT_Relative_Control_RGB
957         // cr(1) cg(1) cb(1)
958         helper("254.600", new byte[] { 0x0f, 0x0e, 0x0d },
959                 new StringType("R increase 7 steps G increase 6 steps B increase 5 steps"));
960     }
961
962     @Test
963     @AfterAll
964     static void checkForMissingMainTypes() {
965         // checks if we have itests for all main DPT types supported by Calimero library,
966         // data is collected within method helper()
967         var wrapper = new Object() {
968             boolean testsMissing = false;
969         };
970         TranslatorTypes.getAllMainTypes().forEach((i, t) -> {
971             if (!dptTested.contains(i)) {
972                 LOGGER.warn("missing tests for main DPT type " + i);
973                 wrapper.testsMissing = true;
974             }
975         });
976         assertEquals(false, wrapper.testsMissing, "add tests for new DPT main types");
977     }
978 }