test: add iotda server testcase

Author: zhiheng123

mtconnect-server/pom.xml

@@ -23,6 +23,12 @@
             <version>0.0.1-SNAPSHOT</version>
             <scope>test</scope>
         </dependency>
+        <dependency>
+            <groupId>org.mockito</groupId>
+            <artifactId>mockito-core</artifactId>
+            <version>4.11.0</version>
+            <scope>test</scope>
+        </dependency>
         <dependency>
             <groupId>com.huaweicloud.sdk</groupId>
             <artifactId>huaweicloud-sdk-iotda</artifactId>

mtconnect-server/src/main/java/io/github/protocol/mtconnect/server/impl/IoTDAMtProcessor.java

@@ -88,7 +88,15 @@ public Builder setEndpoint(String endpoint) {
             return this;
         }
 
+        public Builder setIoTDAClient(IoTDAClient client) {
+            ioTDAMtProcessor.client = client;
+            return this;
+        }
+
         public IoTDAMtProcessor build(){
+            if (ioTDAMtProcessor.client != null) {
+                return ioTDAMtProcessor;
+            }
 
             ICredential auth = new BasicCredentials()
                     // 标准版/企业版需要使用衍生算法，基础版请删除配置"withDerivedPredicate";

mtconnect-server/src/test/java/io/github/protocol/mtconnect/server/IoTDAServerTest.java

@@ -0,0 +1,53 @@
+package io.github.protocol.mtconnect.server;
+
+import com.huaweicloud.sdk.iotda.v5.IoTDAClient;
+import io.github.openfacade.http.HttpServerConfig;
+import io.github.openfacade.http.HttpServerEngine;
+import io.github.protocol.mtconnect.server.impl.IoTDAMtProcessor;
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.mockito.Mockito;
+
+import java.util.concurrent.ExecutionException;
+
+import static org.mockito.Mockito.when;
+
+public class IoTDAServerTest {
+
+    private IoTDAClient mockClient;
+
+    @BeforeEach
+    public void setUp() {
+
+        IoTDAClient mockClient = Mockito.mock(IoTDAClient.class);
+        when(mockClient.newBuilder().build()).thenReturn(null);
+    }
+
+    // start memory server
+    private MTConnectServer startIoTDAServer() {
+
+        MTConnectServerConfiguration configuration = new MTConnectServerConfiguration();
+        HttpServerConfig httpServerConfig = new HttpServerConfig.Builder()
+                .engine(HttpServerEngine.Vertx)
+                .host("127.0.0.1")
+                .port(36633)
+                .build();
+        configuration.setHttpConfig(httpServerConfig);
+        IoTDAMtProcessor ioTDAMtProcessor = new IoTDAMtProcessor.Builder()
+                .setIoTDAClient(mockClient)
+                .build();
+
+        configuration.setMtProcessor(ioTDAMtProcessor);
+        MTConnectServer mtConnectServer = new MTConnectServer(configuration);
+        mtConnectServer.start().join();
+
+        return mtConnectServer;
+    }
+
+    @Test
+    public void testDevices() throws ExecutionException, InterruptedException {
+        MTConnectServer mtConnectServer = startIoTDAServer();
+        Assertions.assertTrue(mtConnectServer.httpPort() > 0);
+    }
+}