]> git.basschouten.com Git - openhab-addons.git/blob
projects / openhab-addons.git / blob
? search:


00e12f857cbbf23c2b9f79d26e67441baa61bcd0
[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
370     @Test
371     void testDpt7() {
372         helper("7.001", new byte[] { 0, 42 }, new DecimalType(42));
373         helper("7.001", new byte[] { (byte) 0xff, (byte) 0xff }, new DecimalType(65535));
374         // workaround in place, as Calimero uses "s" instead of "ms"
375         // refs: ValueEncoder::handleNumericTypes() (case 7) and DptUnits (static initialization)
376         assertTrue("s".equals(DPTXlator2ByteUnsigned.DPT_TIMEPERIOD_10.getUnit()));
377         helper("7.002", new byte[] { (byte) 0x00, (byte) 0xff }, new QuantityType<>("255 ms"));
378         helper("7.002", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 ms"));
379         helper("7.002", new byte[] { (byte) 0xff, (byte) 0xff }, new QuantityType<>("65535 ms"));
380         assertTrue("s".equals(DPTXlator2ByteUnsigned.DPT_TIMEPERIOD_100.getUnit()));
381         helper("7.003", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 ms"));
382         helper("7.003", new byte[] { (byte) 0x00, (byte) 0x64 }, new QuantityType<>("1000 ms"));
383         helper("7.003", new byte[] { (byte) 0x00, (byte) 0xff }, new QuantityType<>("2550 ms"));
384         helper("7.003", new byte[] { (byte) 0xff, (byte) 0xff }, new QuantityType<>("655350 ms"));
385         helper("7.004", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 ms"));
386         helper("7.004", new byte[] { (byte) 0x00, (byte) 0xff }, new QuantityType<>("25500 ms"));
387         helper("7.004", new byte[] { (byte) 0xff, (byte) 0xff }, new QuantityType<>("6553500 ms"));
388         helper("7.005", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 s"));
389         helper("7.005", new byte[] { (byte) 0x00, (byte) 0xff }, new QuantityType<>("255 s"));
390         helper("7.005", new byte[] { (byte) 0xff, (byte) 0xff }, new QuantityType<>("65535 s"));
391         helper("7.006", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 min"));
392         helper("7.006", new byte[] { (byte) 0x00, (byte) 0xff }, new QuantityType<>("255 min"));
393         helper("7.006", new byte[] { (byte) 0xff, (byte) 0xff }, new QuantityType<>("65535 min"));
394         helper("7.006", new byte[] { (byte) 0xff, (byte) 0xff }, new QuantityType<>("3932100 s"));
395         helper("7.007", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 h"));
396         helper("7.007", new byte[] { (byte) 0x00, (byte) 0xff }, new QuantityType<>("255 h"));
397         helper("7.007", new byte[] { (byte) 0x00, (byte) 0xff }, new QuantityType<>("918000 s"));
398         helper("7.007", new byte[] { (byte) 0xff, (byte) 0xff }, new QuantityType<>("65535 h"));
399
400         helper("7.010", new byte[] { 0, 42 }, new DecimalType(42));
401         helper("7.010", new byte[] { (byte) 0xff, (byte) 0xff }, new DecimalType(65535));
402         helper("7.011", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 mm"));
403         helper("7.011", new byte[] { (byte) 0x00, (byte) 0xff }, new QuantityType<>("255 mm"));
404         helper("7.011", new byte[] { (byte) 0xff, (byte) 0xff }, new QuantityType<>("65535 mm"));
405         helper("7.012", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 mA"));
406         helper("7.012", new byte[] { (byte) 0x00, (byte) 0xff }, new QuantityType<>("255 mA"));
407         helper("7.012", new byte[] { (byte) 0xff, (byte) 0xff }, new QuantityType<>("65535 mA"));
408         helper("7.013", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 lx"));
409         helper("7.013", new byte[] { (byte) 0x00, (byte) 0xff }, new QuantityType<>("255 lx"));
410         helper("7.013", new byte[] { (byte) 0xff, (byte) 0xff }, new QuantityType<>("65535 lx"));
411
412         helper("7.600", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 K"));
413         helper("7.600", new byte[] { (byte) 0x00, (byte) 0xff }, new QuantityType<>("255 K"));
414         helper("7.600", new byte[] { (byte) 0xff, (byte) 0xff }, new QuantityType<>("65535 K"));
415     }
416
417     @Test
418     void testDpt8() {
419         helper("8.001", new byte[] { (byte) 0x7f, (byte) 0xff }, new DecimalType(32767));
420         helper("8.001", new byte[] { (byte) 0x80, (byte) 0x00 }, new DecimalType(-32768));
421         helper("8.002", new byte[] { (byte) 0x80, (byte) 0x00 }, new QuantityType<>("-32768 ms"));
422         helper("8.002", new byte[] { (byte) 0x7f, (byte) 0xff }, new QuantityType<>("32767 ms"));
423         helper("8.002", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 ms"));
424         helper("8.003", new byte[] { (byte) 0x80, (byte) 0x00 }, new QuantityType<>("-327680 ms"));
425         helper("8.003", new byte[] { (byte) 0x7f, (byte) 0xff }, new QuantityType<>("327670 ms"));
426         helper("8.003", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 ms"));
427         helper("8.004", new byte[] { (byte) 0x80, (byte) 0x00 }, new QuantityType<>("-3276800 ms"));
428         helper("8.004", new byte[] { (byte) 0x7f, (byte) 0xff }, new QuantityType<>("3276700 ms"));
429         helper("8.004", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 ms"));
430         helper("8.005", new byte[] { (byte) 0x80, (byte) 0x00 }, new QuantityType<>("-32768 s"));
431         helper("8.005", new byte[] { (byte) 0x7f, (byte) 0xff }, new QuantityType<>("32767 s"));
432         helper("8.005", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 s"));
433         helper("8.006", new byte[] { (byte) 0x80, (byte) 0x00 }, new QuantityType<>("-32768 min"));
434         helper("8.006", new byte[] { (byte) 0x7f, (byte) 0xff }, new QuantityType<>("32767 min"));
435         helper("8.006", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 min"));
436         helper("8.007", new byte[] { (byte) 0x80, (byte) 0x00 }, new QuantityType<>("-32768 h"));
437         helper("8.007", new byte[] { (byte) 0x7f, (byte) 0xff }, new QuantityType<>("32767 h"));
438         helper("8.007", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 h"));
439
440         helper("8.011", new byte[] { (byte) 0x80, (byte) 0x00 }, new QuantityType<>("-32768 °"));
441         helper("8.011", new byte[] { (byte) 0x7f, (byte) 0xff }, new QuantityType<>("32767 °"));
442         helper("8.011", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 °"));
443         helper("8.012", new byte[] { (byte) 0x80, (byte) 0x00 }, new QuantityType<>("-32768 m"));
444         helper("8.012", new byte[] { (byte) 0x7f, (byte) 0xff }, new QuantityType<>("32767 m"));
445         helper("8.012", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 m"));
446     }
447
448     @Test
449     void testDpt9() {
450         // special float with sign, 4-bit exponent, and mantissa in two's complement notation
451         // ref: KNX spec, 03_07_02-Datapoint-Types
452         // FIXME according to spec, value 0x7fff shall be regarded as "invalid data"
453         // FIXME lower boundary not fully covered by Calimero library
454         // TODO add tests for clipping at lower boundary (e.g. absolute zero)
455         helper("9.001", new byte[] { (byte) 0x00, (byte) 0x64 }, new QuantityType<>("1 °C"));
456         helper("9.001", new byte[] { (byte) 0x87, (byte) 0x9c }, new QuantityType<>("-1 °C"));
457         helper("9.001", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 °C"));
458         helper("9.001", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 °C"));
459         // lower values than absolute zero will be set to abs. zero (-273 °C)
460         // helper("9.001", new byte[] { (byte) 0xf8, (byte) 0x00 }, new QuantityType<>("-273 °C"));
461         helper("9.002", new byte[] { (byte) 0x00, (byte) 0x64 }, new QuantityType<>("1 K"));
462         helper("9.002", new byte[] { (byte) 0x87, (byte) 0x9c }, new QuantityType<>("-1 K"));
463         helper("9.002", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 K"));
464         helper("9.002", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 K"));
465         // broken, Calimero does not allow full range
466         // helper("9.002", new byte[] { (byte) 0xf8, (byte) 0x00 }, new QuantityType<>("-671088.64 K"));
467         helper("9.003", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 K/h"));
468         helper("9.003", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 K/h"));
469         helper("9.003", new byte[] { (byte) 0x87, (byte) 0x9c }, new QuantityType<>("-1 K/h"));
470         // broken, Calimero does not allow full range
471         // helper("9.003", new byte[] { (byte) 0xf8, (byte) 0x00 }, new QuantityType<>("-671088.64 K/h"));
472         helper("9.004", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 lx"));
473         helper("9.004", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 lx"));
474         helper("9.004", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 lx"));
475         helper("9.005", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 m/s"));
476         helper("9.005", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 m/s"));
477         helper("9.005", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 m/s"));
478         // no negative values allowed for DPTs 9.005-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.006", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 Pa"));
483         helper("9.006", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 Pa"));
484         helper("9.006", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 Pa"));
485         helper("9.007", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 %"));
486         helper("9.007", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 %"));
487         helper("9.007", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 %"));
488         helper("9.008", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 ppm"));
489         helper("9.008", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 ppm"));
490         helper("9.008", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 ppm"));
491         helper("9.009", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 m³/h"));
492         helper("9.009", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 m³/h"));
493         helper("9.009", new byte[] { (byte) 0x87, (byte) 0x9c }, new QuantityType<>("-1 m³/h"));
494         // broken, Calimero does not allow full range
495         // helper("9.009", new byte[] { (byte) 0xf8, (byte) 0x00 }, new QuantityType<>("-671088.64 m³/h"));
496         helper("9.010", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 s"));
497         helper("9.010", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 s"));
498         helper("9.010", new byte[] { (byte) 0x87, (byte) 0x9c }, new QuantityType<>("-1 s"));
499         // broken, Calimero does not allow full range
500         // helper("9.010", new byte[] { (byte) 0xf8, (byte) 0x00 }, new QuantityType<>("-671088.64 s"));
501         helper("9.011", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 ms"));
502         helper("9.011", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 ms"));
503         helper("9.011", new byte[] { (byte) 0x87, (byte) 0x9c }, new QuantityType<>("-1 ms"));
504         // broken, Calimero does not allow full range
505         // helper("9.011", new byte[] { (byte) 0xf8, (byte) 0x00 }, new QuantityType<>("-671088.64 K/h"));
506
507         helper("9.020", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 mV"));
508         helper("9.020", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 mV"));
509         helper("9.020", new byte[] { (byte) 0x87, (byte) 0x9c }, new QuantityType<>("-1 mV"));
510         // broken, Calimero does not allow full range
511         // helper("9.020", new byte[] { (byte) 0xf8, (byte) 0x00 }, new QuantityType<>("-671088.64 mV"));
512         helper("9.021", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 mA"));
513         helper("9.021", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 mA"));
514         helper("9.021", new byte[] { (byte) 0x87, (byte) 0x9c }, new QuantityType<>("-1 mA"));
515         // broken, Calimero does not allow full range
516         // helper("9.021", new byte[] { (byte) 0xf8, (byte) 0x00 }, new QuantityType<>("-671088.64 mA"));
517         helper("9.022", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 W/m²"));
518         helper("9.022", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 W/m²"));
519         helper("9.022", new byte[] { (byte) 0x87, (byte) 0x9c }, new QuantityType<>("-1 W/m²"));
520         // broken, Calimero does not allow full range
521         // helper("9.022", new byte[] { (byte) 0xf8, (byte) 0x00 }, new QuantityType<>("-671088.64 W/m²"));
522         helper("9.023", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 K/%"));
523         helper("9.023", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 K/%"));
524         helper("9.023", new byte[] { (byte) 0x87, (byte) 0x9c }, new QuantityType<>("-1 K/%"));
525         // broken, Calimero does not allow full range
526         // helper("9.023", new byte[] { (byte) 0xf8, (byte) 0x00 }, new QuantityType<>("-671088.64 K/%"));
527         helper("9.024", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 kW"));
528         helper("9.024", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 kW"));
529         helper("9.024", new byte[] { (byte) 0x87, (byte) 0x9c }, new QuantityType<>("-1 kW"));
530         // broken, Calimero does not allow full range
531         // helper("9.024", new byte[] { (byte) 0xf8, (byte) 0x00 }, new QuantityType<>("-671088.64 kW"));
532         helper("9.025", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 l/h"));
533         helper("9.025", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 l/h"));
534         helper("9.025", new byte[] { (byte) 0x87, (byte) 0x9c }, new QuantityType<>("-1 l/h"));
535         // broken, Calimero does not allow full range
536         // helper("9.025", new byte[] { (byte) 0xf8, (byte) 0x00 }, new QuantityType<>("-671088.64 l/h"));
537         helper("9.026", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 l/m²"));
538         helper("9.026", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 l/m²"));
539         helper("9.026", new byte[] { (byte) 0x87, (byte) 0x9c }, new QuantityType<>("-1 l/m²"));
540         // broken, Calimero does not allow full range
541         // helper("9.026", new byte[] { (byte) 0xf8, (byte) 0x00 }, new QuantityType<>("-671088.64 l/m²"));
542         helper("9.027", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 °F"));
543         helper("9.027", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 °F"));
544         helper("9.027", new byte[] { (byte) 0x87, (byte) 0x9c }, new QuantityType<>("-1 °F"));
545         // lower values than absolute zero will be set to abs. zero (-459.6 °F)
546         helper("9.028", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 km/h"));
547         helper("9.028", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 km/h"));
548         helper("9.028", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 km/h"));
549         // no negative values allowed for DPTs 9.028-9.030
550         helper("9.029", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 g/m³"));
551         helper("9.029", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 g/m³"));
552         helper("9.029", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 g/m³"));
553         helper("9.030", new byte[] { (byte) 0x07, (byte) 0xff }, new QuantityType<>("20.47 µg/m³"));
554         helper("9.030", new byte[] { (byte) 0x7f, (byte) 0xfe }, new QuantityType<>("670433.28 µg/m³"));
555         helper("9.030", new byte[] { (byte) 0x00, (byte) 0x00 }, new QuantityType<>("0 µg/m³"));
556     }
557
558     @Test
559     void testDpt10() {
560         // TODO check handling of DPT10: date is not set to current date, but 1970-01-01 + offset if day is given
561         // maybe we should change the semantics and use current date + offset if day is given
562
563         // note: local timezone is set when creating DateTimeType, for example "1970-01-01Thh:mm:ss.000+0100"
564
565         // no-day
566         assertTrue(Objects
567                 .toString(ValueDecoder.decode("10.001", new byte[] { (byte) 0x11, (byte) 0x1e, 0 }, DecimalType.class))
568                 .startsWith("1970-01-01T17:30:00.000+"));
569         // Thursday, this is correct for 1970-01-01
570         assertTrue(Objects
571                 .toString(ValueDecoder.decode("10.001", new byte[] { (byte) 0x91, (byte) 0x1e, 0 }, DecimalType.class))
572                 .startsWith("1970-01-01T17:30:00.000+"));
573         // Monday -> 1970-01-05
574         assertTrue(Objects
575                 .toString(ValueDecoder.decode("10.001", new byte[] { (byte) 0x31, (byte) 0x1e, 0 }, DecimalType.class))
576                 .startsWith("1970-01-05T17:30:00.000+"));
577
578         // Thursday, otherwise first byte of encoded data will not match
579         helper("10.001", new byte[] { (byte) 0x91, (byte) 0x1e, (byte) 0x0 }, new DateTimeType("17:30:00"));
580         helper("10.001", new byte[] { (byte) 0x11, (byte) 0x1e, (byte) 0x0 }, new DateTimeType("17:30:00"), new byte[0],
581                 new byte[] { (byte) 0x1f, (byte) 0xff, (byte) 0xff });
582     }
583
584     @Test
585     void testDpt11() {
586         // note: local timezone and dst is set when creating DateTimeType, for example "2019-06-12T00:00:00.000+0200"
587         helper("11.001", new byte[] { (byte) 12, 6, 19 }, new DateTimeType("2019-06-12"));
588     }
589
590     @Test
591     void testDpt12() {
592         helper("12.001", new byte[] { (byte) 0xff, (byte) 0xff, (byte) 0xff, (byte) 0xfe },
593                 new DecimalType("4294967294"));
594         helper("12.100", new byte[] { 0, 0, 0, 60 }, new QuantityType<>("60 s"));
595         helper("12.100", new byte[] { 0, 0, 0, 60 }, new QuantityType<>("1 min"));
596         helper("12.101", new byte[] { 0, 0, 0, 60 }, new QuantityType<>("60 min"));
597         helper("12.101", new byte[] { 0, 0, 0, 60 }, new QuantityType<>("1 h"));
598         helper("12.102", new byte[] { 0, 0, 0, 1 }, new QuantityType<>("1 h"));
599         helper("12.102", new byte[] { 0, 0, 0, 1 }, new QuantityType<>("60 min"));
600
601         helper("12.1200", new byte[] { 0, 0, 0, 1 }, new QuantityType<>("1 l"));
602         helper("12.1200", new byte[] { (byte) 0xff, (byte) 0xff, (byte) 0xff, (byte) 0xfe },
603                 new QuantityType<>("4294967294 l"));
604         helper("12.1201", new byte[] { 0, 0, 0, 1 }, new QuantityType<>("1 m³"));
605         helper("12.1201", new byte[] { (byte) 0xff, (byte) 0xff, (byte) 0xff, (byte) 0xfe },
606                 new QuantityType<>("4294967294 m³"));
607     }
608
609     @Test
610     void testDpt13() {
611         helper("13.001", new byte[] { 0, 0, 0, 0 }, new DecimalType(0));
612         helper("13.001", new byte[] { 0, 0, 0, 42 }, new DecimalType(42));
613         helper("13.001", new byte[] { (byte) 0x7f, (byte) 0xff, (byte) 0xff, (byte) 0xff },
614                 new DecimalType(2147483647));
615         // KNX representation typically uses two's complement
616         helper("13.001", new byte[] { (byte) 0xff, (byte) 0xff, (byte) 0xff, (byte) 0xff }, new DecimalType(-1));
617         helper("13.001", new byte[] { (byte) 0x80, (byte) 0x0, (byte) 0x0, (byte) 0x0 }, new DecimalType(-2147483648));
618         helper("13.002", new byte[] { 0, 0, 0, 0 }, new QuantityType<>("0 m³/h"));
619         helper("13.002", new byte[] { (byte) 0x80, (byte) 0x0, (byte) 0x0, (byte) 0x0 },
620                 new QuantityType<>("-2147483648 m³/h"));
621         helper("13.002", new byte[] { (byte) 0x7f, (byte) 0xff, (byte) 0xff, (byte) 0xff },
622                 new QuantityType<>("2147483647 m³/h"));
623
624         helper("13.010", new byte[] { 0, 0, 0, 0 }, new QuantityType<>("0 Wh"));
625         helper("13.010", new byte[] { (byte) 0x80, (byte) 0x0, (byte) 0x0, (byte) 0x0 },
626                 new QuantityType<>("-2147483648 Wh"));
627         helper("13.010", new byte[] { (byte) 0x7f, (byte) 0xff, (byte) 0xff, (byte) 0xff },
628                 new QuantityType<>("2147483647 Wh"));
629         helper("13.011", new byte[] { 0, 0, 0, 0 }, new QuantityType<>("0 VAh"));
630         helper("13.011", new byte[] { (byte) 0x80, (byte) 0x0, (byte) 0x0, (byte) 0x0 },
631                 new QuantityType<>("-2147483648 VAh"));
632         helper("13.011", new byte[] { (byte) 0x7f, (byte) 0xff, (byte) 0xff, (byte) 0xff },
633                 new QuantityType<>("2147483647 VAh"));
634         helper("13.012", new byte[] { 0, 0, 0, 0 }, new QuantityType<>("0 varh"));
635         helper("13.012", new byte[] { (byte) 0x80, (byte) 0x0, (byte) 0x0, (byte) 0x0 },
636                 new QuantityType<>("-2147483648 varh"));
637         helper("13.012", new byte[] { (byte) 0x7f, (byte) 0xff, (byte) 0xff, (byte) 0xff },
638                 new QuantityType<>("2147483647 varh"));
639         helper("13.013", new byte[] { 0, 0, 0, 0 }, new QuantityType<>("0 kWh"));
640         helper("13.013", new byte[] { (byte) 0x80, (byte) 0x0, (byte) 0x0, (byte) 0x0 },
641                 new QuantityType<>("-2147483648 kWh"));
642         helper("13.013", new byte[] { (byte) 0x7f, (byte) 0xff, (byte) 0xff, (byte) 0xff },
643                 new QuantityType<>("2147483647 kWh"));
644         helper("13.014", new byte[] { 0, 0, 0, 0 }, new QuantityType<>("0 VAh"));
645         helper("13.014", new byte[] { (byte) 0x80, (byte) 0x0, (byte) 0x0, (byte) 0x0 },
646                 new QuantityType<>("-2147483648000 VAh"));
647         helper("13.014", new byte[] { (byte) 0x7f, (byte) 0xff, (byte) 0xff, (byte) 0xff },
648                 new QuantityType<>("2147483647000 VAh"));
649         helper("13.015", new byte[] { 0, 0, 0, 0 }, new QuantityType<>("0 kvarh"));
650         helper("13.015", new byte[] { (byte) 0x80, (byte) 0x0, (byte) 0x0, (byte) 0x0 },
651                 new QuantityType<>("-2147483648 kvarh"));
652         helper("13.015", new byte[] { (byte) 0x7f, (byte) 0xff, (byte) 0xff, (byte) 0xff },
653                 new QuantityType<>("2147483647 kvarh"));
654         helper("13.016", new byte[] { 0, 0, 0, 0 }, new QuantityType<>("0 MWh"));
655         helper("13.016", new byte[] { (byte) 0x80, (byte) 0x0, (byte) 0x0, (byte) 0x0 },
656                 new QuantityType<>("-2147483648 MWh"));
657         helper("13.016", new byte[] { (byte) 0x7f, (byte) 0xff, (byte) 0xff, (byte) 0xff },
658                 new QuantityType<>("2147483647 MWh"));
659
660         helper("13.100", new byte[] { 0, 0, 0, 0 }, new QuantityType<>("0 s"));
661         helper("13.100", new byte[] { (byte) 0x80, (byte) 0x0, (byte) 0x0, (byte) 0x0 },
662                 new QuantityType<>("-2147483648 s"));
663         helper("13.100", new byte[] { (byte) 0x7f, (byte) 0xff, (byte) 0xff, (byte) 0xff },
664                 new QuantityType<>("2147483647 s"));
665
666         helper("13.1200", new byte[] { 0, 0, 0, 0 }, new QuantityType<>("0 l"));
667         helper("13.1200", new byte[] { (byte) 0x80, (byte) 0x0, (byte) 0x0, (byte) 0x0 },
668                 new QuantityType<>("-2147483648 l"));
669         helper("13.1200", new byte[] { (byte) 0x7f, (byte) 0xff, (byte) 0xff, (byte) 0xff },
670                 new QuantityType<>("2147483647 l"));
671         helper("13.1201", new byte[] { 0, 0, 0, 0 }, new QuantityType<>("0 m³"));
672         helper("13.1201", new byte[] { (byte) 0x80, (byte) 0x0, (byte) 0x0, (byte) 0x0 },
673                 new QuantityType<>("-2147483648 m³"));
674         helper("13.1201", new byte[] { (byte) 0x7f, (byte) 0xff, (byte) 0xff, (byte) 0xff },
675                 new QuantityType<>("2147483647 m³"));
676     }
677
678     @Test
679     void testDpt14() {
680         helper("14.000", new byte[] { (byte) 0x3f, (byte) 0x80, 0, 0 }, new QuantityType<>("1 m/s²"));
681         helper("14.000", F32_MINUS_ONE, new QuantityType<>("-1 m/s²"));
682         helper("14.001", F32_MINUS_ONE, new QuantityType<>("-1 rad/s²"));
683         helper("14.002", F32_MINUS_ONE, new QuantityType<>("-1 J/mol"));
684         helper("14.003", F32_MINUS_ONE, new QuantityType<>("-1 /s"));
685         helper("14.004", F32_MINUS_ONE, new QuantityType<>("-1 mol"));
686         helper("14.005", F32_MINUS_ONE, new DecimalType("-1"));
687         helper("14.006", F32_MINUS_ONE, new QuantityType<>("-1 rad"));
688         helper("14.007", F32_MINUS_ONE, new QuantityType<>("-1 °"));
689         helper("14.008", F32_MINUS_ONE, new QuantityType<>("-1 J*s"));
690         helper("14.009", F32_MINUS_ONE, new QuantityType<>("-1 rad/s"));
691         helper("14.010", F32_MINUS_ONE, new QuantityType<>("-1 m²"));
692         helper("14.011", F32_MINUS_ONE, new QuantityType<>("-1 F"));
693         helper("14.012", F32_MINUS_ONE, new QuantityType<>("-1 C/m²"));
694         helper("14.013", F32_MINUS_ONE, new QuantityType<>("-1 C/m³"));
695         helper("14.014", F32_MINUS_ONE, new QuantityType<>("-1 m²/N"));
696         helper("14.015", F32_MINUS_ONE, new QuantityType<>("-1 S"));
697         helper("14.016", F32_MINUS_ONE, new QuantityType<>("-1 S/m"));
698         helper("14.017", F32_MINUS_ONE, new QuantityType<>("-1 kg/m³"));
699         helper("14.018", F32_MINUS_ONE, new QuantityType<>("-1 C"));
700         helper("14.019", F32_MINUS_ONE, new QuantityType<>("-1 A"));
701         helper("14.020", F32_MINUS_ONE, new QuantityType<>("-1 A/m²"));
702         helper("14.021", F32_MINUS_ONE, new QuantityType<>("-1 C*m"));
703         helper("14.022", F32_MINUS_ONE, new QuantityType<>("-1 C/m²"));
704         helper("14.023", F32_MINUS_ONE, new QuantityType<>("-1 V/m"));
705         helper("14.024", F32_MINUS_ONE, new QuantityType<>("-1 V*m")); // SI unit is Vm
706         helper("14.025", F32_MINUS_ONE, new QuantityType<>("-1 C/m²"));
707         helper("14.026", F32_MINUS_ONE, new QuantityType<>("-1 C/m²"));
708         helper("14.027", F32_MINUS_ONE, new QuantityType<>("-1 V"));
709         helper("14.028", F32_MINUS_ONE, new QuantityType<>("-1 V"));
710         helper("14.029", F32_MINUS_ONE, new QuantityType<>("-1 A*m²"));
711         helper("14.030", F32_MINUS_ONE, new QuantityType<>("-1 V"));
712         helper("14.031", F32_MINUS_ONE, new QuantityType<>("-1 J"));
713         helper("14.032", F32_MINUS_ONE, new QuantityType<>("-1 N"));
714         helper("14.033", F32_MINUS_ONE, new QuantityType<>("-1 /s"));
715         helper("14.034", F32_MINUS_ONE, new QuantityType<>("-1 rad/s"));
716         helper("14.035", F32_MINUS_ONE, new QuantityType<>("-1 J/K"));
717         helper("14.036", F32_MINUS_ONE, new QuantityType<>("-1 W"));
718         helper("14.037", F32_MINUS_ONE, new QuantityType<>("-1 J"));
719         helper("14.038", F32_MINUS_ONE, new QuantityType<>("-1 Ohm"));
720         helper("14.039", F32_MINUS_ONE, new QuantityType<>("-1 m"));
721         helper("14.040", F32_MINUS_ONE, new QuantityType<>("-1 J"));
722         helper("14.041", F32_MINUS_ONE, new QuantityType<>("-1 cd/m²"));
723         helper("14.042", F32_MINUS_ONE, new QuantityType<>("-1 lm"));
724         helper("14.043", F32_MINUS_ONE, new QuantityType<>("-1 cd"));
725         helper("14.044", F32_MINUS_ONE, new QuantityType<>("-1 A/m"));
726         helper("14.045", F32_MINUS_ONE, new QuantityType<>("-1 Wb"));
727         helper("14.046", F32_MINUS_ONE, new QuantityType<>("-1 T"));
728         helper("14.047", F32_MINUS_ONE, new QuantityType<>("-1 A*m²"));
729         helper("14.048", F32_MINUS_ONE, new QuantityType<>("-1 T"));
730         helper("14.049", F32_MINUS_ONE, new QuantityType<>("-1 A/m"));
731         helper("14.050", F32_MINUS_ONE, new QuantityType<>("-1 A"));
732         helper("14.051", F32_MINUS_ONE, new QuantityType<>("-1 kg"));
733         helper("14.052", F32_MINUS_ONE, new QuantityType<>("-1 kg/s"));
734         helper("14.053", F32_MINUS_ONE, new QuantityType<>("-1 N/s"));
735         helper("14.054", F32_MINUS_ONE, new QuantityType<>("-1 rad"));
736         helper("14.055", F32_MINUS_ONE, new QuantityType<>("-1 °"));
737         helper("14.056", F32_MINUS_ONE, new QuantityType<>("-1 W"));
738         helper("14.057", F32_MINUS_ONE, new DecimalType("-1"));
739         helper("14.058", F32_MINUS_ONE, new QuantityType<>("-1 Pa"));
740         helper("14.059", F32_MINUS_ONE, new QuantityType<>("-1 Ohm"));
741         helper("14.060", F32_MINUS_ONE, new QuantityType<>("-1 Ohm"));
742         helper("14.061", F32_MINUS_ONE, new QuantityType<>("-1 Ohm*m"));
743         helper("14.062", F32_MINUS_ONE, new QuantityType<>("-1 H"));
744         helper("14.063", F32_MINUS_ONE, new QuantityType<>("-1 sr"));
745         helper("14.064", F32_MINUS_ONE, new QuantityType<>("-1 W/m²"));
746         helper("14.065", F32_MINUS_ONE, new QuantityType<>("-1 m/s"));
747         helper("14.066", F32_MINUS_ONE, new QuantityType<>("-1 Pa"));
748         helper("14.067", F32_MINUS_ONE, new QuantityType<>("-1 N/m"));
749         helper("14.068", new byte[] { (byte) 0x3f, (byte) 0x80, 0, 0 }, new QuantityType<>("1 °C"));
750         helper("14.068", F32_MINUS_ONE, new QuantityType<>("-1 °C"));
751         helper("14.069", F32_MINUS_ONE, new QuantityType<>("-1 K"));
752         helper("14.070", F32_MINUS_ONE, new QuantityType<>("-1 K"));
753         helper("14.071", F32_MINUS_ONE, new QuantityType<>("-1 J/K"));
754         helper("14.072", F32_MINUS_ONE, new QuantityType<>("-1 W/m/K"));
755         helper("14.073", F32_MINUS_ONE, new QuantityType<>("-1 V/K"));
756         helper("14.074", F32_MINUS_ONE, new QuantityType<>("-1 s"));
757         helper("14.075", F32_MINUS_ONE, new QuantityType<>("-1 N*m"));
758         helper("14.076", F32_MINUS_ONE, new QuantityType<>("-1 m³"));
759         helper("14.077", F32_MINUS_ONE, new QuantityType<>("-1 m³/s"));
760         helper("14.078", F32_MINUS_ONE, new QuantityType<>("-1 N"));
761         helper("14.079", F32_MINUS_ONE, new QuantityType<>("-1 J"));
762         helper("14.080", F32_MINUS_ONE, new QuantityType<>("-1 VA"));
763
764         helper("14.1200", F32_MINUS_ONE, new QuantityType<>("-1 m³/h"));
765         helper("14.1201", F32_MINUS_ONE, new QuantityType<>("-1 l/s"));
766     }
767
768     @Test
769     void testDpt16() {
770         helper("16.000", new byte[] { (byte) 0x4B, (byte) 0x4E, 0x58, 0x20, 0x69, 0x73, 0x20, (byte) 0x4F, (byte) 0x4B,
771                 0x0, 0x0, 0x0, 0x0, 0x0 }, new StringType("KNX is OK"));
772         helper("16.001", new byte[] { (byte) 0x4B, (byte) 0x4E, 0x58, 0x20, 0x69, 0x73, 0x20, (byte) 0x4F, (byte) 0x4B,
773                 0x0, 0x0, 0x0, 0x0, 0x0 }, new StringType("KNX is OK"));
774     }
775
776     @Test
777     void testDpt17() {
778         helper("17.001", new byte[] { 0 }, new DecimalType(0));
779         helper("17.001", new byte[] { 42 }, new DecimalType(42));
780         helper("17.001", new byte[] { 63 }, new DecimalType(63));
781     }
782
783     @Test
784     void testDpt18() {
785         // scene, activate 0..63
786         helper("18.001", new byte[] { 0 }, new DecimalType(0));
787         helper("18.001", new byte[] { 42 }, new DecimalType(42));
788         helper("18.001", new byte[] { 63 }, new DecimalType(63));
789         // scene, learn += 0x80
790         helper("18.001", new byte[] { (byte) (0x80 + 0) }, new DecimalType(0x80));
791         helper("18.001", new byte[] { (byte) (0x80 + 42) }, new DecimalType(0x80 + 42));
792         helper("18.001", new byte[] { (byte) (0x80 + 63) }, new DecimalType(0x80 + 63));
793     }
794
795     @Test
796     void testDpt19() {
797         // 2019-01-15 17:30:00
798         helper("19.001", new byte[] { (byte) (2019 - 1900), 1, 15, 17, 30, 0, (byte) 0x25, (byte) 0x00 },
799                 new DateTimeType("2019-01-15T17:30:00"));
800         helper("19.001", new byte[] { (byte) (2019 - 1900), 1, 15, 17, 30, 0, (byte) 0x24, (byte) 0x00 },
801                 new DateTimeType("2019-01-15T17:30:00"));
802         // 2019-07-15 17:30:00
803         helper("19.001", new byte[] { (byte) (2019 - 1900), 7, 15, 17, 30, 0, (byte) 0x25, (byte) 0x00 },
804                 new DateTimeType("2019-07-15T17:30:00"), new byte[0], new byte[] { 0, 0, 0, 0, 0, 0, 0, 1 });
805         helper("19.001", new byte[] { (byte) (2019 - 1900), 7, 15, 17, 30, 0, (byte) 0x24, (byte) 0x00 },
806                 new DateTimeType("2019-07-15T17:30:00"), new byte[0], new byte[] { 0, 0, 0, 0, 0, 0, 0, 1 });
807     }
808
809     @Test
810     void testDpt20() {
811         // test default String representation of enum (incomplete)
812         helper("20.001", new byte[] { 0 }, new StringType("autonomous"));
813         helper("20.001", new byte[] { 1 }, new StringType("slave"));
814         helper("20.001", new byte[] { 2 }, new StringType("master"));
815
816         helper("20.002", new byte[] { 0 }, new StringType("building in use"));
817         helper("20.002", new byte[] { 1 }, new StringType("building not used"));
818         helper("20.002", new byte[] { 2 }, new StringType("building protection"));
819
820         // test DecimalType representation of enum
821         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,
822                 106, 107, 108, 109, 110, 111, 112, 113, 114, 120, 121, 122, 600, 601, 602, 603, 604, 605, 606, 607, 608,
823                 609, 610, 801, 802, 803, 804, 1000, 1001, 1002, 1003, 1004, 1005, 1200, 1202 };
824         for (int subType : subTypes) {
825             helper("20." + String.format("%03d", subType), new byte[] { 1 }, new DecimalType(1));
826         }
827         // once these DPTs are available in Calimero, add to check above
828         int[] unsupportedSubTypes = new int[] { 22, 115, 611, 612, 613, 1203, 1204, 1205, 1206, 1207, 1208, 1209 };
829         for (int subType : unsupportedSubTypes) {
830             assertNull(ValueDecoder.decode("20." + String.format("%03d", subType), new byte[] { 0 }, StringType.class));
831         }
832     }
833
834     @Test
835     void testDpt21() {
836         // test default String representation of bitfield (incomplete)
837         helper("21.001", new byte[] { 5 }, new StringType("overridden, out of service"));
838
839         // test DecimalType representation of bitfield
840         int[] subTypes = new int[] { 1, 2, 100, 101, 102, 103, 104, 105, 106, 601, 1000, 1001, 1002, 1010 };
841         for (int subType : subTypes) {
842             helper("21." + String.format("%03d", subType), new byte[] { 1 }, new DecimalType(1));
843         }
844         // once these DPTs are available in Calimero, add to check above
845         assertNull(ValueDecoder.decode("21.1200", new byte[] { 0 }, StringType.class));
846         assertNull(ValueDecoder.decode("21.1201", new byte[] { 0 }, StringType.class));
847     }
848
849     @Test
850     void testDpt22() {
851         // test default String representation of bitfield (incomplete)
852         helper("22.101", new byte[] { 1, 0 }, new StringType("heating mode"));
853         helper("22.101", new byte[] { 1, 2 }, new StringType("heating mode, heating eco mode"));
854
855         // test DecimalType representation of bitfield
856         helper("22.101", new byte[] { 0, 2 }, new DecimalType(2));
857         helper("22.1000", new byte[] { 0, 2 }, new DecimalType(2));
858         // once these DPTs are available in Calimero, add to check above
859         assertNull(ValueDecoder.decode("22.100", new byte[] { 0, 2 }, StringType.class));
860         assertNull(ValueDecoder.decode("22.1010", new byte[] { 0, 2 }, StringType.class));
861     }
862
863     @Test
864     void testDpt28() {
865         // null terminated strings, UTF8
866         helper("28.001", new byte[] { 0x31, 0x32, 0x33, 0x34, 0x0 }, new StringType("1234"));
867         helper("28.001", new byte[] { (byte) 0xce, (byte) 0xb5, 0x34, 0x0 }, new StringType("\u03b54"));
868     }
869
870     @Test
871     void testDpt29() {
872         helper("29.010", new byte[] { 0, 0, 0, 0, 0, 0, 0, 42 }, new QuantityType<>("42 Wh"));
873         helper("29.010", new byte[] { (byte) 0x80, 0, 0, 0, 0, 0, 0, 0 },
874                 new QuantityType<>("-9223372036854775808 Wh"));
875         helper("29.010", new byte[] { (byte) 0xff, 0, 0, 0, 0, 0, 0, 0 }, new QuantityType<>("-72057594037927936 Wh"));
876         helper("29.010", new byte[] { 0, 0, 0, 0, 0, 0, 0, 42 }, new QuantityType<>("42 Wh"));
877         helper("29.011", new byte[] { 0, 0, 0, 0, 0, 0, 0, 42 }, new QuantityType<>("42 VAh"));
878         helper("29.012", new byte[] { 0, 0, 0, 0, 0, 0, 0, 42 }, new QuantityType<>("42 varh"));
879     }
880
881     @Test
882     void testDpt229() {
883         // special DPT for metering, allows several units and different scaling
884         // -> Calimero uses scaling, but always encodes as dimensionless value
885         final int dimensionlessCounter = 0b10111010;
886         helper("229.001", new byte[] { 0, 0, 0, 0, (byte) dimensionlessCounter, 0 }, new DecimalType(0));
887     }
888
889     @Test
890     void testColorDpts() {
891         // HSB
892         helper("232.600", new byte[] { 123, 45, 67 }, ColorUtil.rgbToHsb(new int[] { 123, 45, 67 }));
893         // RGB, MDT specific
894         helper("232.60000", new byte[] { 123, 45, 67 }, new HSBType("173.6, 17.6, 26.3"));
895
896         // xyY
897         int x = (int) (14.65 * 65535.0 / 100.0);
898         int y = (int) (11.56 * 65535.0 / 100.0);
899         // encoding is always xy and brightness (C+B, 0x03), do not test other combinations
900         helper("242.600", new byte[] { (byte) ((x >> 8) & 0xff), (byte) (x & 0xff), (byte) ((y >> 8) & 0xff),
901                 (byte) (y & 0xff), (byte) 0x28, 0x3 }, new HSBType("220,90,50"), new byte[] { 0, 8, 0, 8, 0, 0 },
902                 new byte[0]);
903         // TODO check brightness
904
905         // RGBW, only RGB part
906         helper("251.600", new byte[] { 0x26, 0x2b, 0x31, 0x00, 0x00, 0x0e }, new HSBType("207, 23, 19"),
907                 new byte[] { 1, 1, 1, 0, 0, 0 }, new byte[0]);
908         // RGBW, only RGB part
909         helper("251.600", new byte[] { (byte) 0xff, (byte) 0xff, (byte) 0xff, 0x00, 0x00, 0x0e },
910                 new HSBType("0, 0, 100"), new byte[] { 1, 1, 1, 0, 0, 0 }, new byte[0]);
911         // RGBW, only W part
912         helper("251.600", new byte[] { 0x0, 0x0, 0x0, 0x1A, 0x00, 0x01 }, new PercentType("10.2"));
913         // RGBW, all
914         helper("251.60600", new byte[] { (byte) 0x0, (byte) 0x0, (byte) 0x0, (byte) 0xff, 0x00, 0x0f },
915                 new HSBType("0, 0, 100"), new byte[] { 1, 1, 1, 2, 0, 0 }, new byte[0]);
916         // RGBW, mixed
917         int[] rgbw = new int[] { 240, 0x0, 0x0, 0x0f };
918         HSBType hsb = ColorUtil.rgbToHsb(rgbw);
919         helper("251.60600", new byte[] { (byte) rgbw[0], (byte) rgbw[1], (byte) rgbw[2], (byte) rgbw[3], 0x00, 0x0f },
920                 hsb, new byte[] { 2, 2, 2, 2, 0, 0 }, new byte[0]);
921     }
922
923     @Test
924     void testColorTransitionDpts() {
925         // DPT 243.600 DPT_Colour_Transition_xyY
926         // time(2) y(2) x(2), %brightness(1), flags(1)
927         helper("243.600", new byte[] { 0, 5, 0x7F, 0, (byte) 0xfe, 0, 42, 3 },
928                 new StringType("(0.9922, 0.4961) 16.5 % 0.5 s"));
929         // DPT 249.600 DPT_Brightness_Colour_Temperature_Transition
930         // time(2) colortemp(2), brightness(1), flags(1)
931         helper("249.600", new byte[] { 0, 5, 0, 40, 127, 7 }, new StringType("49.8 % 40 K 0.5 s"));
932         // DPT 250.600 DPT_Brightness_Colour_Temperature_Control
933         // cct(1) cb(1) flags(1)
934         helper("250.600", new byte[] { 0x0f, 0x0e, 3 }, new StringType("CT increase 7 steps BRT increase 6 steps"));
935         // DPT 252.600 DPT_Relative_Control_RGBW
936         // r(1) g(1) b(1) w(1) flags(1)
937         helper("252.600", new byte[] { 0x0f, 0x0e, 0x0d, 0x0c, 0x0f },
938                 new StringType("R increase 7 steps G increase 6 steps B increase 5 steps W increase 4 steps"));
939         // DPT 253.600 DPT_Relative_Control_xyY
940         // cs(1) ct(1) cb(1) flags(1)
941         helper("253.600", new byte[] { 0x0f, 0x0e, 0x0d, 0x7 },
942                 new StringType("x increase 7 steps y increase 6 steps Y increase 5 steps"));
943         // DPT 254.600 DPT_Relative_Control_RGB
944         // cr(1) cg(1) cb(1)
945         helper("254.600", new byte[] { 0x0f, 0x0e, 0x0d },
946                 new StringType("R increase 7 steps G increase 6 steps B increase 5 steps"));
947     }
948
949     @Test
950     @AfterAll
951     static void checkForMissingMainTypes() {
952         // checks if we have itests for all main DPT types supported by Calimero library,
953         // data is collected within method helper()
954         var wrapper = new Object() {
955             boolean testsMissing = false;
956         };
957         TranslatorTypes.getAllMainTypes().forEach((i, t) -> {
958             if (!dptTested.contains(i)) {
959                 LOGGER.warn("missing tests for main DPT type " + i);
960                 wrapper.testsMissing = true;
961             }
962         });
963         assertEquals(false, wrapper.testsMissing, "add tests for new DPT main types");
964     }
965 }
Unnamed repository; edit this file 'description' to name the repository.