feat: add device interface

mtconnect-api/src/main/java/io/github/protocol/mtconnect/api/AssetResponse.java → mtconnect-api/src/main/java/io/github/protocol/mtconnect/api/DeviceRequest.java

@@ -5,6 +5,6 @@
 
 @Getter
 @Setter
-public class AssetResponse {
-    MTConnectAssets assets;
+public class DeviceRequest {
+    private String id;
 }

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

@@ -7,7 +7,7 @@
 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.AssetResponse;
+import io.github.protocol.mtconnect.api.MTConnectAssets;
 import io.github.protocol.mtconnect.common.XmlUtil;
 import io.netty.handler.codec.http.HttpResponseStatus;
 
@@ -35,11 +35,11 @@
     class MtAssetsHandler implements SyncRequestHandler {
         @Override
         public HttpResponse handle(HttpRequest request) {
-            AssetResponse assetResponse = mtProcessor.asset(new AssetRequest());
+            MTConnectAssets mtConnectAssets = mtProcessor.asset(new AssetRequest());
             // convert the response to http response
             String body;
             try {
-                body = XmlUtil.toXml(assetResponse.getAssets());
+                body = XmlUtil.toXml(mtConnectAssets);
             } catch (Exception e) {
                 throw new RuntimeException(e);
             }

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

@@ -1,8 +1,11 @@
 package io.github.protocol.mtconnect.server;
 
 import io.github.protocol.mtconnect.api.AssetRequest;
-import io.github.protocol.mtconnect.api.AssetResponse;
+import io.github.protocol.mtconnect.api.DeviceRequest;
+import io.github.protocol.mtconnect.api.MTConnectAssets;
+import io.github.protocol.mtconnect.api.MTConnectDevices;
 
 public interface MtProcessor {
-    AssetResponse asset(AssetRequest assetRequest);
+    MTConnectAssets asset(AssetRequest assetRequest);
+    MTConnectDevices device(DeviceRequest deviceRequest);
 }

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

@@ -1,7 +1,9 @@
 package io.github.protocol.mtconnect.server.impl;
 
 import io.github.protocol.mtconnect.api.AssetRequest;
-import io.github.protocol.mtconnect.api.AssetResponse;
+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.server.MtProcessor;
 
 public class IoTDAMtProcessor implements MtProcessor {
@@ -15,7 +17,12 @@
     }
 
     @Override
-    public AssetResponse asset(AssetRequest assetRequest) {
+    public MTConnectAssets asset(AssetRequest assetRequest) {
+        return null;
+    }
+
+    @Override
+    public MTConnectDevices device(DeviceRequest deviceRequest) {
         return null;
     }
 }

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

@@ -1,8 +1,9 @@
 package io.github.protocol.mtconnect.server.impl;
 
 import io.github.protocol.mtconnect.api.AssetRequest;
-import io.github.protocol.mtconnect.api.AssetResponse;
+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.server.MtProcessor;
 
 import java.util.HashMap;
@@ -16,10 +17,12 @@
     Map<String, MTConnectAssets> mtConnectAssetsMap = new HashMap<>();
 
     @Override
-    public AssetResponse asset(AssetRequest assetRequest) {
-        MTConnectAssets assets = mtConnectAssetsMap.get(assetRequest.getId());
-        AssetResponse assetResponse = new AssetResponse();
-        assetResponse.setAssets(assets);
-        return assetResponse;
+    public MTConnectAssets asset(AssetRequest assetRequest) {
+        return mtConnectAssetsMap.get(assetRequest.getId());
+    }
+
+    @Override
+    public MTConnectDevices device(DeviceRequest deviceRequest) {
+        return null;
     }
 }