From ad971718b29e3b77f355cc7841ad1b00a05bbc07 Mon Sep 17 00:00:00 2001
From: rdkartono <rdkartono@galva.co.id>
Date: Fri, 15 Nov 2024 13:44:24 +0700
Subject: [PATCH] First commit

---
 .idea/libraries/google_code_gson.xml | 11 ++++++
 ProtegeToAASMini.iml                 |  1 +
 src/Main.java                        |  5 +++
 src/Web/WebRequest.java              | 12 ++++++
 src/Web/WebResponse.java             | 12 ++++++
 src/Web/WebServer.java               | 55 +++++++++++++++++++++++-----
 6 files changed, 87 insertions(+), 9 deletions(-)
 create mode 100644 .idea/libraries/google_code_gson.xml
 create mode 100644 src/Web/WebRequest.java
 create mode 100644 src/Web/WebResponse.java

diff --git a/.idea/libraries/google_code_gson.xml b/.idea/libraries/google_code_gson.xml
new file mode 100644
index 0000000..f62abb1
--- /dev/null
+++ b/.idea/libraries/google_code_gson.xml
@@ -0,0 +1,11 @@
+<component name="libraryTable">
+  <library name="google.code.gson" type="repository">
+    <properties maven-id="com.google.code.gson:gson:2.11.0" />
+    <CLASSES>
+      <root url="jar://$MAVEN_REPOSITORY$/com/google/code/gson/gson/2.11.0/gson-2.11.0.jar!/" />
+      <root url="jar://$MAVEN_REPOSITORY$/com/google/errorprone/error_prone_annotations/2.27.0/error_prone_annotations-2.27.0.jar!/" />
+    </CLASSES>
+    <JAVADOC />
+    <SOURCES />
+  </library>
+</component>
\ No newline at end of file
diff --git a/ProtegeToAASMini.iml b/ProtegeToAASMini.iml
index deb8228..237d7ef 100644
--- a/ProtegeToAASMini.iml
+++ b/ProtegeToAASMini.iml
@@ -20,5 +20,6 @@
     <orderEntry type="library" name="tinylog" level="project" />
     <orderEntry type="library" name="io.javalin" level="project" />
     <orderEntry type="library" name="projectlombok.lombok" level="project" />
+    <orderEntry type="library" name="google.code.gson" level="project" />
   </component>
 </module>
\ No newline at end of file
diff --git a/src/Main.java b/src/Main.java
index f542808..7ea6ea8 100644
--- a/src/Main.java
+++ b/src/Main.java
@@ -1,5 +1,6 @@
 import AASMini.AASMini;
 import ProtegeGX.ProtegeGX;
+import Web.WebResponse;
 import Web.WebServer;
 import org.pmw.tinylog.Logger;
 
@@ -37,10 +38,14 @@ public class Main {
         web.setAasAPI(data -> {
             Logger.info(data);
             // Do something with AAS
+            WebResponse wr = new WebResponse();
+            return wr;
         });
         web.setProtegeGXAPI(data -> {
             Logger.info(data);
             // Do something with ProtegeGX
+            WebResponse wr = new WebResponse();
+            return wr;
         });
     }
 
diff --git a/src/Web/WebRequest.java b/src/Web/WebRequest.java
new file mode 100644
index 0000000..72ec61e
--- /dev/null
+++ b/src/Web/WebRequest.java
@@ -0,0 +1,12 @@
+package Web;
+
+public class WebRequest {
+    public String command;
+    public String data;
+    public String additional;
+    public WebRequest(){
+        command = "";
+        data = "";
+        additional = "";
+    }
+}
diff --git a/src/Web/WebResponse.java b/src/Web/WebResponse.java
new file mode 100644
index 0000000..37f8049
--- /dev/null
+++ b/src/Web/WebResponse.java
@@ -0,0 +1,12 @@
+package Web;
+
+public class WebResponse {
+    public String reply;
+    public String data;
+    public String additional;
+    public WebResponse(){
+        reply = "";
+        data = "";
+        additional = "";
+    }
+}
diff --git a/src/Web/WebServer.java b/src/Web/WebServer.java
index 9a47437..c94616a 100644
--- a/src/Web/WebServer.java
+++ b/src/Web/WebServer.java
@@ -1,24 +1,31 @@
 package Web;
 
+import com.google.gson.Gson;
 import io.javalin.Javalin;
 import lombok.Setter;
 
-import java.util.function.Consumer;
+import java.util.function.Function;
 
-import static io.javalin.apibuilder.ApiBuilder.get;
-import static io.javalin.apibuilder.ApiBuilder.path;
+import static io.javalin.apibuilder.ApiBuilder.*;
 
 @SuppressWarnings("unused")
 public class WebServer {
-    @Setter private Consumer<String> aasAPI;
-    @Setter private Consumer<String> protegeGXAPI;
+    @Setter private Function<WebRequest, WebResponse> aasAPI;
+    @Setter private Function<WebRequest, WebResponse> protegeGXAPI;
+    private final Gson gson = new Gson();
 
-    private void updateAASAPI(String data){
-        if (aasAPI!=null) aasAPI.accept(data);
+    private WebResponse ProcessAAS(WebRequest request){
+        if (aasAPI!=null){
+            return aasAPI.apply(request);
+        }
+        return null;
     }
 
-    private void updateProtegeGXAPI(String data){
-        if (protegeGXAPI!=null) protegeGXAPI.accept(data);
+    private WebResponse ProcessProtegeGX(WebRequest request){
+        if (protegeGXAPI!=null){
+            return protegeGXAPI.apply(request);
+        }
+        return null;
     }
 
     Javalin app;
@@ -31,11 +38,41 @@ public class WebServer {
                 path("aasmini", ()->{
                     //TODO implement API for AAS Mini
                     get(ctx -> ctx.result("AAS Mini API"));
+                    post(ctx -> {
+                        try{
+                            WebRequest request = gson.fromJson(ctx.body(), WebRequest.class);
+                            WebResponse response = ProcessAAS(request);
+                            if (response!=null){
+                                ctx.result(gson.toJson(response));
+                            } else {
+                                ctx.status(400);
+                                ctx.result("No response from AAS Mini");
+                            }
+                        } catch(Exception e){
+                            ctx.status(400);
+                            ctx.result("Exception: "+e.getMessage());
+                        }
+                    });
                 });
                 // API for ProtegeGX
                 path("protegegx", ()->{
                     //TODO implement API for ProtegeGX
                     get(ctx -> ctx.result("ProtegeGX API"));
+                    post(ctx -> {
+                        try{
+                            WebRequest request = gson.fromJson(ctx.body(), WebRequest.class);
+                            WebResponse response = ProcessProtegeGX(request);
+                            if (response!=null){
+                                ctx.result(gson.toJson(response));
+                            } else {
+                                ctx.status(400);
+                                ctx.result("No response from ProtegeGX");
+                            }
+                        } catch(Exception e){
+                            ctx.status(400);
+                            ctx.result("Exception: "+e.getMessage());
+                        }
+                    });
                 });
             });
         });