From 3f23af3c03768c1207620f40d2fd4338d9383161 Mon Sep 17 00:00:00 2001
From: Jochen Mader <jochen.mader@hivemq.com>
Date: Thu, 8 Aug 2024 16:08:57 +0200
Subject: [PATCH] Tests for value extraction

---
 .../model/EtherIpValueFactoryTest.java        | 91 +++++++++++++++++++
 1 file changed, 91 insertions(+)
 create mode 100644 modules/hivemq-edge-module-etherip/src/test/java/com/hivemq/edge/adapters/etherip/model/EtherIpValueFactoryTest.java

diff --git a/modules/hivemq-edge-module-etherip/src/test/java/com/hivemq/edge/adapters/etherip/model/EtherIpValueFactoryTest.java b/modules/hivemq-edge-module-etherip/src/test/java/com/hivemq/edge/adapters/etherip/model/EtherIpValueFactoryTest.java
new file mode 100644
index 0000000000..d7aa1cf334
--- /dev/null
+++ b/modules/hivemq-edge-module-etherip/src/test/java/com/hivemq/edge/adapters/etherip/model/EtherIpValueFactoryTest.java
@@ -0,0 +1,91 @@
+package com.hivemq.edge.adapters.etherip.model;
+
+import com.hivemq.edge.adapters.etherip.model.dataypes.EtherIpBool;
+import com.hivemq.edge.adapters.etherip.model.dataypes.EtherIpDouble;
+import com.hivemq.edge.adapters.etherip.model.dataypes.EtherIpInt;
+import com.hivemq.edge.adapters.etherip.model.dataypes.EtherIpLong;
+import etherip.types.CIPData;
+import org.junit.jupiter.api.Disabled;
+import org.junit.jupiter.api.Test;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.assertj.core.api.Assertions.offset;
+
+public class EtherIpValueFactoryTest {
+
+    @Test
+    public void test_EtherIpBool_False() throws Exception {
+        CIPData data = new CIPData(CIPData.Type.BOOL, 1);
+        data.set(0, 0);
+        assertThat(EtherIpValueFactory.fromTagAddressAndCipData("wullewu", data))
+                .isNotEmpty()
+                .get()
+                .isInstanceOf(EtherIpBool.class)
+                .extracting(EtherIpValue::getTagAdress, EtherIpValue::getValue)
+                .containsExactly("wullewu", false);
+    }
+
+    @Test
+    public void test_EtherIpBool_True() throws Exception {
+        CIPData data = new CIPData(CIPData.Type.BOOL, 1);
+        data.set(0, 1);
+        assertThat(EtherIpValueFactory.fromTagAddressAndCipData("wullewu", data))
+                .isNotEmpty()
+                .get()
+                .isInstanceOf(EtherIpBool.class)
+                .extracting(EtherIpValue::getTagAdress, EtherIpValue::getValue)
+                .containsExactly("wullewu", true);
+    }
+
+    @Test
+    public void test_EtherIpDouble() throws Exception {
+        CIPData data = new CIPData(CIPData.Type.REAL, 1);
+        data.set(0, 1.12);
+        assertThat(EtherIpValueFactory.fromTagAddressAndCipData("wullewu", data))
+                .isNotEmpty()
+                .get()
+                .isInstanceOf(EtherIpDouble.class)
+                .satisfies(it -> {
+                    assertThat(it.getTagAdress()).isEqualTo("wullewu");
+                    assertThat((Double)it.getValue()).isEqualTo(1.12, offset(2D));
+                });
+    }
+
+    @Test
+    public void test_EtherIpInt() throws Exception {
+        CIPData data = new CIPData(CIPData.Type.INT, 1);
+        data.set(0, 17);
+        assertThat(EtherIpValueFactory.fromTagAddressAndCipData("wullewu", data))
+                .isNotEmpty()
+                .get()
+                .isInstanceOf(EtherIpInt.class)
+                .extracting(EtherIpValue::getTagAdress, EtherIpValue::getValue)
+                .containsExactly("wullewu", 17);
+    }
+
+    @Test
+    public void test_EtherIpLong() throws Exception {
+        CIPData data = new CIPData(CIPData.Type.DINT, 1);
+        data.set(0, 17L);
+        assertThat(EtherIpValueFactory.fromTagAddressAndCipData("wullewu", data))
+                .isNotEmpty()
+                .get()
+                .isInstanceOf(EtherIpLong.class)
+                .extracting(EtherIpValue::getTagAdress, EtherIpValue::getValue)
+                .containsExactly("wullewu", 17L);
+    }
+
+    @Test
+    @Disabled("CIPData needs to be constructed using the CIPData(Type type, byte[] data) constructor")
+    //FIXME: enabled test
+    public void test_EtherIpString() throws Exception {
+        CIPData data = new CIPData(CIPData.Type.STRUCT, 1);
+        data.setString("test");
+        assertThat(EtherIpValueFactory.fromTagAddressAndCipData("wullewu", data))
+                .isNotEmpty()
+                .get()
+                .isInstanceOf(EtherIpBool.class)
+                .extracting(EtherIpValue::getTagAdress, EtherIpValue::getValue)
+                .containsExactly("wullewu", "test");
+    }
+}