feat: add device api

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

Author: zhiheng123

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

@@ -1,15 +1,55 @@
 package io.github.protocol.mtconnect.client;
 
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
 import io.github.openfacade.http.HttpClient;
 import io.github.openfacade.http.HttpClientFactory;
+import io.github.openfacade.http.HttpResponse;
+import io.github.protocol.mtconnect.api.MTConnectDevices;
+
+import java.util.Arrays;
+import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.ExecutionException;
 
 public class MTConnectClient {
     private final MTConnectClientConfiguration config;
 
     private final HttpClient httpClient;
+    private static final ObjectMapper MAPPER = new ObjectMapper();
 
     public MTConnectClient(MTConnectClientConfiguration configuration) {
         this.config = configuration;
         this.httpClient = HttpClientFactory.createHttpClient(configuration.httpConfig());
     }
+    
+    public MTConnectDevices deivce(String Id) {
+        return null;
+    };
+
+    public static <T> T toObject(String json, Class<T> type) throws JsonProcessingException {
+        if (json == null || json.isEmpty()) {
+            return null;
+        }
+        return MAPPER.readValue(json, type);
+    }
+
+    public MTConnectDevices deivces() throws ExecutionException, InterruptedException {
+        String url = String.format("http://%s:%s/devices", config.host(), config.port());
+        CompletableFuture<HttpResponse> future = httpClient.get(url);
+
+        CompletableFuture<MTConnectDevices> resp = future.thenCompose(response -> {
+            if (response.statusCode() >= 200 && response.statusCode() < 300) {
+                try {
+                    MTConnectDevices body = toObject(Arrays.toString(response.body()), MTConnectDevices.class);
+                    return CompletableFuture.completedFuture(body);
+                } catch (JsonProcessingException e) {
+                    return CompletableFuture.failedFuture(e);
+                }
+            } else {
+                return CompletableFuture.failedFuture(new Exception("http error: " + Arrays.toString(response.body())));
+            }
+        });
+
+        return resp.get();
+    };
 }

mtconnect-server/pom.xml

@@ -37,6 +37,12 @@
             <artifactId>vertx-web</artifactId>
             <version>${vertx.version}</version>
         </dependency>
+        <dependency>
+            <groupId>io.github.protocol-laboratory</groupId>
+            <artifactId>mtconnect-client</artifactId>
+            <version>0.0.1-SNAPSHOT</version>
+            <scope>test</scope>
+        </dependency>
     </dependencies>
 
 </project>

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

@@ -32,6 +32,10 @@ public CompletableFuture<Void> start() {
         return httpServer.start();
     }
 
+    public int getHttpPort() {
+        return httpServer.listenPort();
+    }
+
     class MtAssetsHandler implements SyncRequestHandler {
         @Override
         public HttpResponse handle(HttpRequest request) {

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

@@ -15,6 +15,7 @@
 public class MemoryMtProcessor implements MTProcessor {
 
     Map<String, MTConnectAssets> mtConnectAssetsMap = new HashMap<>();
+    private MTConnectDevices devices;
 
     @Override
     public MTConnectAssets asset(AssetRequest assetRequest) {
@@ -25,4 +26,8 @@ public MTConnectAssets asset(AssetRequest assetRequest) {
     public MTConnectDevices device(DeviceRequest deviceRequest) {
         return null;
     }
+
+    public void updateDevice(MTConnectDevices devices) {
+        this.devices = devices;
+    }
 }

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

@@ -0,0 +1,61 @@
+package io.github.protocol.mtconnect.server;
+
+import io.github.openfacade.http.HttpClientConfig;
+import io.github.openfacade.http.HttpServerConfig;
+import io.github.openfacade.http.HttpServerEngine;
+import io.github.protocol.mtconnect.api.Device;
+import io.github.protocol.mtconnect.api.MTConnectDevices;
+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.Test;
+
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.concurrent.ExecutionException;
+
+public class MTConnectDeviceTest {
+
+    private int port;
+    private final String localHost = "127.0.0.1";
+
+    // start memery server
+    private MemoryMtProcessor startMemoryServer() {
+        MTConnectServerConfiguration configuration = new MTConnectServerConfiguration();
+        HttpServerConfig httpServerConfig = new HttpServerConfig.Builder()
+                .engine(HttpServerEngine.Vertx)
+                .host(localHost)
+                .port(0)
+                .build();
+        configuration.setHttpConfig(httpServerConfig);
+        MemoryMtProcessor mtProcessor = new MemoryMtProcessor();
+        configuration.setMtProcessor(mtProcessor);
+        MTConnectServer mtConnectServer = new MTConnectServer(configuration);
+        mtConnectServer.start().join();
+
+        port = mtConnectServer.getHttpPort();
+
+        return mtProcessor;
+    }
+
+    @Test
+    public void testDevices() throws ExecutionException, InterruptedException {
+        MemoryMtProcessor memoryMtProcessor = startMemoryServer();
+        MTConnectDevices devices = new MTConnectDevices();
+        Device device = new Device();
+
+        devices.setDevices(Collections.singletonList(device));
+        memoryMtProcessor.updateDevice(devices);
+
+        MTConnectClientConfiguration configuration = new MTConnectClientConfiguration();
+        HttpClientConfig httpClientConfig = new HttpClientConfig.Builder().build();
+        configuration.setHttpConfig(httpClientConfig);
+        configuration.setHost(localHost);
+        configuration.setPort(port);
+        MTConnectClient mtConnectClient = new MTConnectClient(configuration);
+
+        // use client show device
+        MTConnectDevices resp = mtConnectClient.deivces();
+        System.out.println(resp.getDevices());
+    }
+}