git.basschouten.com Git - openhab-addons.git/blob

   1 /**
   2  * Copyright (c) 2010-2023 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.nibeheatpump.internal.message;
  14
  15 import static org.junit.jupiter.api.Assertions.*;
  16
  17 import java.util.ArrayList;
  18 import java.util.Arrays;
  19 import java.util.List;
  20 import java.util.concurrent.TimeUnit;
  21
  22 import org.junit.jupiter.api.BeforeEach;
  23 import org.junit.jupiter.api.Test;
  24 import org.junit.jupiter.api.Timeout;
  25 import org.openhab.binding.nibeheatpump.internal.protocol.NibeHeatPumpProtocolContext;
  26 import org.openhab.binding.nibeheatpump.internal.protocol.NibeHeatPumpProtocolDefaultContext;
  27 import org.openhab.core.util.HexUtils;
  28
  29 /**
  30  * @author Pauli Anttila - Initial contribution
  31  */
  32 public class NibeHeatPumpProtocolTest {
  33
  34     int ackRequestCount = 0;
  35     int nakRequestCount = 0;
  36     int sendWriteMsgCount = 0;
  37     int sendReadMsgCount = 0;
  38     List<byte[]> receivedMsgs = null;
  39
  40     final NibeHeatPumpProtocolContext mockupContext = new NibeHeatPumpProtocolDefaultContext() {
  41         @Override
  42         public void sendAck() {
  43             ackRequestCount++;
  44         }
  45
  46         @Override
  47         public void sendNak() {
  48             nakRequestCount++;
  49         }
  50
  51         @Override
  52         public void msgReceived(byte[] data) {
  53             receivedMsgs.add(Arrays.copyOf(data, data.length));
  54         }
  55
  56         @Override
  57         public void sendWriteMsg() {
  58             sendWriteMsgCount++;
  59         }
  60
  61         @Override
  62         public void sendReadMsg() {
  63             sendReadMsgCount++;
  64         }
  65     };
  66
  67     @BeforeEach
  68     public void Before() {
  69         ackRequestCount = 0;
  70         nakRequestCount = 0;
  71         sendWriteMsgCount = 0;
  72         sendReadMsgCount = 0;
  73         receivedMsgs = new ArrayList<>();
  74         mockupContext.buffer().clear();
  75         mockupContext.msg().clear();
  76     }
  77
  78     @Test
  79     @Timeout(value = 1, unit = TimeUnit.SECONDS)
  80     public void test() {
  81         //@formatter:off
  82         final String strTestData =
  83                 // RMU40 message, acknowledge should be send
  84                 """
  85                 5C001962189600E1010200000000800000000000020914340001000005B8\
  86                 5C001962189600E1010200000000800000000000020914340001000005B9\
  87                 5C00206B004B\
  88                 3EAABB\
  89                 5C0020690049\
  90                 F0561939F6\
  91                 5C00206850449C9600489C88014C9C2D014E9CCF004D9CE0014F9C3200509C0400519C8201529C6B02569C3E00C9AF000001A8F600FDA77E02FAA90F0098A9DC27FFFF0000A0A93A04FFFF00009CA9FD19FFFF000081\
  92                 F0349823\
  93                 5C00206850449C9600489C88014C9C2D014E9CCF004D9CE0014F9C3200509C0400519C8201529C6B02569C3E00C9AF000001A8F600FDA77E02FAA90F0098A9DC27FFFF0000A0A93A04FFFF00009CA9FD19FFFF000080\
  94                 5C001962189600DF01020000000080000000000002091434000100000586\
  95                 123490\
  96                 5C0019600079\
  97                 5C00206851449C2500489CFC004C9CF1004E9CC7014D9C0B024F9C2500509C3300519C0B01529C5C5C01569C3100C9AF000001A80C01FDA716FAFAA9070098A91B1BFFFF0000A0A9CA02FFFF00009CA99212FFFF0000BE\
  98                 5C00206852449C2500489CFE004C9CF2004E9CD4014D9CFB014F9C2500509C3700519C0D01529C5C5C01569C3200C9AF000001A80C01FDA712FAFAA9070098A95C5C1BFFFF0000A0A9D102FFFF00009CA9B412FFFF00007F\
  99                 5C00206850449C2600489CF6004C9CF1004E9CD6014D9C0C024F9C4500509C3F00519CF100529C0401569CD500C9AF000001A80C01FDA799FAFAA9020098A91A1BFFFF0000A0A9CA02FFFF00009CA99212FFFF0000C5\
 100                 5C41C9F7007F\
 101                 """;
 102         //@formatter:on
 103
 104         // create byte data from hex string
 105         final byte[] rawData = HexUtils.hexToBytes(strTestData);
 106
 107         // put byte data to protocol state machine
 108         mockupContext.buffer().put(rawData);
 109         mockupContext.buffer().flip();
 110
 111         // run protocol state machine to process test data
 112         while (mockupContext.state().process(mockupContext)) {
 113         }
 114
 115         // test results
 116
 117         assertEquals(8, ackRequestCount);
 118         assertEquals(2, nakRequestCount);
 119         assertEquals(1, sendWriteMsgCount);
 120         assertEquals(1, sendReadMsgCount);
 121         assertEquals(8, receivedMsgs.size());
 122
 123         String expect;
 124
 125         expect = "5C001962189600E1010200000000800000000000020914340001000005B8";
 126         assertArrayEquals(HexUtils.hexToBytes(expect), receivedMsgs.get(0));
 127
 128         expect = "5C00206850449C9600489C88014C9C2D014E9CCF004D9CE0014F9C3200509C0400519C8201529C6B02569C3E00C9AF000001A8F600FDA77E02FAA90F0098A9DC27FFFF0000A0A93A04FFFF00009CA9FD19FFFF000081";
 129         assertArrayEquals(HexUtils.hexToBytes(expect), receivedMsgs.get(1));
 130
 131         expect = "5C001962189600DF01020000000080000000000002091434000100000586";
 132         assertArrayEquals(HexUtils.hexToBytes(expect), receivedMsgs.get(2));
 133
 134         expect = "5C0019600079";
 135         assertArrayEquals(HexUtils.hexToBytes(expect), receivedMsgs.get(3));
 136
 137         expect = "5C00206851449C2500489CFC004C9CF1004E9CC7014D9C0B024F9C2500509C3300519C0B01529C5C5C01569C3100C9AF000001A80C01FDA716FAFAA9070098A91B1BFFFF0000A0A9CA02FFFF00009CA99212FFFF0000BE";
 138         assertArrayEquals(HexUtils.hexToBytes(expect), receivedMsgs.get(4));
 139
 140         expect = "5C00206852449C2500489CFE004C9CF2004E9CD4014D9CFB014F9C2500509C3700519C0D01529C5C5C01569C3200C9AF000001A80C01FDA712FAFAA9070098A95C5C1BFFFF0000A0A9D102FFFF00009CA9B412FFFF00007F";
 141         assertArrayEquals(HexUtils.hexToBytes(expect), receivedMsgs.get(5));
 142
 143         expect = "5C00206850449C2600489CF6004C9CF1004E9CD6014D9C0C024F9C4500509C3F00519CF100529C0401569CD500C9AF000001A80C01FDA799FAFAA9020098A91A1BFFFF0000A0A9CA02FFFF00009CA99212FFFF0000C5";
 144         assertArrayEquals(HexUtils.hexToBytes(expect), receivedMsgs.get(6));
 145
 146         expect = "5C41C9F7007F";
 147         assertArrayEquals(HexUtils.hexToBytes(expect), receivedMsgs.get(7));
 148     }
 149 }