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

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