test: add the testcase of devices

Signed-off-by: zhiheng123 <[email protected]>

Author: zhiheng123

mtconnect-client/src/main/java/io/github/protocol/mtconnect/client/MTConnectClient.java

@@ -6,7 +6,9 @@
 import io.github.openfacade.http.HttpClientFactory;
 import io.github.openfacade.http.HttpResponse;
 import io.github.protocol.mtconnect.api.MTConnectDevices;
+import io.github.protocol.mtconnect.common.XmlUtil;
 
+import java.nio.charset.StandardCharsets;
 import java.util.Arrays;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.ExecutionException;
@@ -40,9 +42,10 @@ public MTConnectDevices deivces() throws ExecutionException, InterruptedExceptio
         CompletableFuture<MTConnectDevices> resp = future.thenCompose(response -> {
             if (response.statusCode() >= 200 && response.statusCode() < 300) {
                 try {
-                    MTConnectDevices body = toObject(Arrays.toString(response.body()), MTConnectDevices.class);
+                    String string = new String(response.body(), StandardCharsets.UTF_8);
+                    MTConnectDevices body = XmlUtil.fromXml(string, MTConnectDevices.class);
                     return CompletableFuture.completedFuture(body);
-                } catch (JsonProcessingException e) {
+                } catch (Exception e) {
                     return CompletableFuture.failedFuture(e);
                 }
             } else {

mtconnect-server/src/main/java/io/github/protocol/mtconnect/server/MTConnectServer.java

@@ -7,7 +7,9 @@
 import io.github.openfacade.http.HttpServerFactory;
 import io.github.openfacade.http.SyncRequestHandler;
 import io.github.protocol.mtconnect.api.AssetRequest;
+import io.github.protocol.mtconnect.api.DeviceRequest;
 import io.github.protocol.mtconnect.api.MTConnectAssets;
+import io.github.protocol.mtconnect.api.MTConnectDevices;
 import io.github.protocol.mtconnect.common.XmlUtil;
 import io.netty.handler.codec.http.HttpResponseStatus;
 
@@ -29,13 +31,30 @@ public MTConnectServer(MTConnectServerConfiguration configuration) {
 
     public CompletableFuture<Void> start() {
         this.httpServer.addSyncRoute("/assets", HttpMethod.GET, new MtAssetsHandler());
+        this.httpServer.addSyncRoute("/devices", HttpMethod.GET, new MtDevicesHandler());
         return httpServer.start();
     }
 
     public int getHttpPort() {
         return httpServer.listenPort();
     }
 
+    class MtDevicesHandler implements SyncRequestHandler {
+        @Override
+        public HttpResponse handle(HttpRequest request) {
+            MTConnectDevices devices = mtProcessor.device(new DeviceRequest());
+            // convert the response to http response
+            String body;
+            try {
+                body = XmlUtil.toXml(devices);
+            } catch (Exception e) {
+                throw new RuntimeException(e);
+            }
+
+            return new HttpResponse(HttpResponseStatus.OK.code(), body.getBytes(StandardCharsets.UTF_8));
+        }
+    }
+
     class MtAssetsHandler implements SyncRequestHandler {
         @Override
         public HttpResponse handle(HttpRequest request) {

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

@@ -24,7 +24,7 @@ public MTConnectAssets asset(AssetRequest assetRequest) {
 
     @Override
     public MTConnectDevices device(DeviceRequest deviceRequest) {
-        return null;
+        return devices;
     }
 
     public void updateDevice(MTConnectDevices devices) {

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

@@ -8,6 +8,7 @@
 import io.github.protocol.mtconnect.client.MTConnectClient;
 import io.github.protocol.mtconnect.client.MTConnectClientConfiguration;
 import io.github.protocol.mtconnect.server.impl.MemoryMtProcessor;
+import org.junit.jupiter.api.Assertions;
 import org.junit.jupiter.api.Test;
 
 import java.util.ArrayList;
@@ -43,6 +44,7 @@ public void testDevices() throws ExecutionException, InterruptedException {
         MemoryMtProcessor memoryMtProcessor = startMemoryServer();
         MTConnectDevices devices = new MTConnectDevices();
         Device device = new Device();
+        device.setId("test_id");
 
         devices.setDevices(Collections.singletonList(device));
         memoryMtProcessor.updateDevice(devices);
@@ -54,8 +56,7 @@ public void testDevices() throws ExecutionException, InterruptedException {
         configuration.setPort(port);
         MTConnectClient mtConnectClient = new MTConnectClient(configuration);
 
-        // use client show device
         MTConnectDevices resp = mtConnectClient.deivces();
-        System.out.println(resp.getDevices());
+        Assertions.assertEquals(device.getId(), resp.getDevices().get(0).getId());
     }
 }