From 09aa0fe47ce37b1e6839d17f51609264013ea972 Mon Sep 17 00:00:00 2001
From: TakahashiNg <83152264+TakahashiNguyen@users.noreply.github.com>
Date: Wed, 22 Apr 2026 07:16:34 +0000
Subject: [PATCH] chore: update

---
 .../drinkool/controller/EateryController.java | 34 +++++++++++++++++++
 .../controller/GraphQlController.java         | 27 ---------------
 .../com/drinkool/services/EateryService.java  | 13 -------
 k8s/kafdrop.yaml                              | 20 +++++------
 4 files changed, 44 insertions(+), 50 deletions(-)
 create mode 100644 gateway-service/src/main/java/com/drinkool/controller/EateryController.java
 delete mode 100644 gateway-service/src/main/java/com/drinkool/controller/GraphQlController.java
 delete mode 100644 gateway-service/src/main/java/com/drinkool/services/EateryService.java

diff --git a/gateway-service/src/main/java/com/drinkool/controller/EateryController.java b/gateway-service/src/main/java/com/drinkool/controller/EateryController.java
new file mode 100644
index 0000000..3e98288
--- /dev/null
+++ b/gateway-service/src/main/java/com/drinkool/controller/EateryController.java
@@ -0,0 +1,34 @@
+package com.drinkool.controller;
+
+import io.smallrye.graphql.client.GraphQLClient;
+import io.smallrye.graphql.client.dynamic.api.DynamicGraphQLClient;
+import jakarta.ws.rs.POST;
+import jakarta.ws.rs.Path;
+import jakarta.ws.rs.core.Response;
+import java.util.concurrent.ExecutionException;
+
+@Path("/api/eatery")
+public class EateryController {
+
+	@GraphQLClient("eatery")
+	DynamicGraphQLClient dynamicClient;
+
+	@POST
+	@Path("/graphql")
+	public Response forward(String query)
+		throws ExecutionException, InterruptedException {
+		io.smallrye.graphql.client.Response response = dynamicClient.executeSync(
+			query
+		);
+
+		if (response.hasError()) {
+			return jakarta.ws.rs.core.Response.status(500)
+				.entity(response.getErrors())
+				.build();
+		}
+
+		return jakarta.ws.rs.core.Response.ok(
+			response.getData().toString()
+		).build();
+	}
+}
diff --git a/gateway-service/src/main/java/com/drinkool/controller/GraphQlController.java b/gateway-service/src/main/java/com/drinkool/controller/GraphQlController.java
deleted file mode 100644
index cb68651..0000000
--- a/gateway-service/src/main/java/com/drinkool/controller/GraphQlController.java
+++ /dev/null
@@ -1,27 +0,0 @@
-package com.drinkool.controller;
-
-import com.drinkool.services.EateryService;
-import jakarta.inject.Inject;
-import jakarta.json.JsonObject;
-import java.util.List;
-import java.util.UUID;
-import org.eclipse.microprofile.graphql.GraphQLApi;
-import org.eclipse.microprofile.graphql.Name;
-import org.eclipse.microprofile.graphql.Query;
-
-@GraphQLApi
-public class GraphQlController {
-
-	@Inject
-	EateryService eateryService;
-
-	@Query("allEateries")
-	public List<JsonObject> getAllEateries() {
-		return eateryService.getAll();
-	}
-
-	@Query("eateryById")
-	public JsonObject getEatery(@Name("id") UUID id) {
-		return eateryService.getEatery(id);
-	}
-}
diff --git a/gateway-service/src/main/java/com/drinkool/services/EateryService.java b/gateway-service/src/main/java/com/drinkool/services/EateryService.java
deleted file mode 100644
index df16575..0000000
--- a/gateway-service/src/main/java/com/drinkool/services/EateryService.java
+++ /dev/null
@@ -1,13 +0,0 @@
-package com.drinkool.services;
-
-import io.smallrye.graphql.client.typesafe.api.GraphQLClientApi;
-import jakarta.json.JsonObject;
-import java.util.*;
-import org.eclipse.microprofile.graphql.Name;
-
-@GraphQLClientApi(configKey = "eatery")
-public interface EateryService {
-	public List<JsonObject> getAll();
-
-	public JsonObject getEatery(@Name("id") UUID id);
-}
diff --git a/k8s/kafdrop.yaml b/k8s/kafdrop.yaml
index 9e0a2ed..129d0ea 100644
--- a/k8s/kafdrop.yaml
+++ b/k8s/kafdrop.yaml
@@ -13,13 +13,13 @@ spec:
         app: kafdrop
     spec:
       containers:
-      - name: kafdrop
-        image: obsidiandynamics/kafdrop
-        ports:
-        - containerPort: 9000
-        env:
-        - name: KAFKA_BROKERCONNECT
-          value: "kafka-service:9092" # Trỏ vào service Kafka của bạn
+        - name: kafdrop
+          image: obsidiandynamics/kafdrop
+          ports:
+            - containerPort: 9000
+          env:
+            - name: KAFKA_BROKERCONNECT
+              value: "kafka-service:9092"
 ---
 apiVersion: v1
 kind: Service
@@ -30,6 +30,6 @@ spec:
   selector:
     app: kafdrop
   ports:
-  - protocol: TCP
-    port: 9000
-    nodePort: 30900
\ No newline at end of file
+    - protocol: TCP
+      port: 9000
+      nodePort: 30900