fix: add send review and get reviews (#45)

Co-authored-by: TakahashiNg <83152264+TakahashiNguyen@users.noreply.github.com>
Reviewed-on: #45

.gitea/workflows/test.yaml

@@ -23,6 +23,17 @@ jobs:
         with:
           fetch-depth: 0
 
+      - name: Install dependencies with Proxy
+        env:
+          http_proxy: "http://host.docker.internal:3142"
+          https_proxy: "http://host.docker.internal:3142"
+        run: |
+          # Kiểm tra proxy có hoạt động không
+          echo "Acquire::http::Proxy \"$http_proxy\";" > /etc/apt/apt.conf.d/80proxy
+          apt-get update
+          apt-get install -y --no-install-recommends --no-install-suggests \
+            openjdk-25-jdk-headless docker-cli docker-buildx zstd
+
       - uses: shogo82148/actions-setup-redis@v1
         with:
           redis-version: "7.x"
@@ -38,17 +49,6 @@ jobs:
           restore-keys: |
             ${{ runner.os }}-maven-
 
-      - name: Install dependencies with Proxy
-        env:
-          http_proxy: "http://host.docker.internal:3142"
-          https_proxy: "http://host.docker.internal:3142"
-        run: |
-          # Kiểm tra proxy có hoạt động không
-          echo "Acquire::http::Proxy \"$http_proxy\";" > /etc/apt/apt.conf.d/80proxy
-          apt-get update
-          apt-get install -y --no-install-recommends --no-install-suggests \
-            openjdk-25-jdk-headless docker-cli docker-buildx
-
       - name: Build and Test all module
         env:
           TESTCONTAINERS_RYUK_DISABLED: true

.gitignore

@@ -22,7 +22,6 @@ bin/
 nb-configuration.xml
 
 # Visual Studio Code
-.vscode
 .factorypath
 *.rdb
 

.releaserc.yaml

@@ -11,7 +11,7 @@ plugins:
   - - "@semantic-release/exec"
     - prepareCmd: |
         ./mvnw versions:set -DnewVersion=${nextRelease.version} &&
-        sed -i "/image:.*-service:/ s|:[^:]*$|:${nextRelease.version}|" k8s/*.yaml &&
+        sed -i "/image:.*-service:/ s|:[^:]*$|:${nextRelease.version}|" k8s/base/*.yaml &&
         if [ "${branch.name}" = "main" ]; then
           ./mvnw package -B -Pnative -Dquarkus.container-image.tag=${nextRelease.version} -DskipTests
         fi

.vscode/launch.json

@@ -0,0 +1,15 @@
+{
+	// Use IntelliSense to learn about possible attributes.
+	// Hover to view descriptions of existing attributes.
+	// For more information, visit: https://go.microsoft.com/fwlink/?linkid=830387
+	"version": "0.2.0",
+	"configurations": [
+		{
+			"type": "java",
+			"name": "Attach to Quarkus",
+			"request": "attach",
+			"hostName": "localhost",
+			"port": 5005
+		}
+	]
+}

.vscode/settings.json

@@ -0,0 +1,13 @@
+{
+	"files.exclude": {
+		"**/.git": true,
+		"**/.svn": true,
+		"**/.hg": true,
+		"**/.DS_Store": true,
+		"**/Thumbs.db": true,
+		"**/target": true,
+		"**/docker": true,
+		"node_modules": true
+	},
+	"explorerExclude.backup": {}
+}

CHANGELOG.md

@@ -1,3 +1,32 @@
+## [1.5.20](https://git.demonkernel.io.vn/FoodSurf/backend/compare/v1.5.19...v1.5.20) (2026-05-06)
+
+
+### Bug Fixes
+
+* menu items CRUD ([#44](https://git.demonkernel.io.vn/FoodSurf/backend/issues/44)) ([43600fc](https://git.demonkernel.io.vn/FoodSurf/backend/commit/43600fc8cfa2cd93e1d33ee855a2934a49f8d663))
+
+## [1.5.19](https://git.demonkernel.io.vn/FoodSurf/backend/compare/v1.5.18...v1.5.19) (2026-05-05)
+
+
+### Bug Fixes
+
+* better graphql response type for native ([#43](https://git.demonkernel.io.vn/FoodSurf/backend/issues/43)) ([b401627](https://git.demonkernel.io.vn/FoodSurf/backend/commit/b4016275063da592a6990a86cf8652b81a63c068))
+
+## [1.5.18](https://git.demonkernel.io.vn/FoodSurf/backend/compare/v1.5.17...v1.5.18) (2026-05-04)
+
+
+### Bug Fixes
+
+* better role authorized ([#41](https://git.demonkernel.io.vn/FoodSurf/backend/issues/41)) ([9711ea0](https://git.demonkernel.io.vn/FoodSurf/backend/commit/9711ea045e70159d577922fe2d54324ca8f00e5e))
+* resolved minor issues ([#42](https://git.demonkernel.io.vn/FoodSurf/backend/issues/42)) ([be90005](https://git.demonkernel.io.vn/FoodSurf/backend/commit/be900051152ca61ac0ca1c6672e8f89339df7e7b))
+
+## [1.5.17](https://git.demonkernel.io.vn/FoodSurf/backend/compare/v1.5.16...v1.5.17) (2026-04-28)
+
+
+### Bug Fixes
+
+* better graphql handler ([#40](https://git.demonkernel.io.vn/FoodSurf/backend/issues/40)) ([89c4967](https://git.demonkernel.io.vn/FoodSurf/backend/commit/89c496786381bbe8601ea0ee9c38b8700549b704))
+
 ## [1.5.16](https://git.demonkernel.io.vn/FoodSurf/backend/compare/v1.5.15...v1.5.16) (2026-04-28)
 
 

account-service/pom.xml

@@ -9,7 +9,7 @@
     <parent>
         <groupId>com.drinkool</groupId>
         <artifactId>drinkool</artifactId>
-        <version>1.5.16</version>
+        <version>1.5.20</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
 

account-service/src/main/docker/Dockerfile.native

@@ -1,5 +1,8 @@
 ####
 # This Dockerfile is used in order to build a container that runs the Quarkus application in native (no JVM) mode.
+# It uses a micro base image, tuned for Quarkus native executables.
+# It reduces the size of the resulting container image.
+# Check https://quarkus.io/guides/quarkus-runtime-base-image for further information about this image.
 #
 # Before building the container image run:
 #
@@ -7,16 +10,16 @@
 #
 # Then, build the image with:
 #
-# docker build -f src/main/docker/Dockerfile.native -t quarkus/account-service .
+# docker build -f src/main/docker/Dockerfile.native-micro -t quarkus/account-service .
 #
 # Then run the container using:
 #
 # docker run -i --rm -p 8080:8080 quarkus/account-service
 #
-# The ` registry.access.redhat.com/ubi9/ubi-minimal:9.7` base image is based on UBI 9.
-# To use UBI 8, switch to `quay.io/ubi8/ubi-minimal:8.10`.
+# The `quay.io/quarkus/ubi9-quarkus-micro-image:2.0` base image is based on UBI 9.
+# To use UBI 8, switch to `quay.io/quarkus/quarkus-micro-image:2.0`.
 ###
-FROM registry.access.redhat.com/ubi9/ubi-minimal:9.7
+FROM quay.io/quarkus/ubi9-quarkus-micro-image:2.0
 WORKDIR /work/
 RUN chown 1001 /work \
     && chmod "g+rwX" /work \

account-service/src/main/docker/Dockerfile.native-micro

@@ -1,32 +0,0 @@
-####
-# This Dockerfile is used in order to build a container that runs the Quarkus application in native (no JVM) mode.
-# It uses a micro base image, tuned for Quarkus native executables.
-# It reduces the size of the resulting container image.
-# Check https://quarkus.io/guides/quarkus-runtime-base-image for further information about this image.
-#
-# Before building the container image run:
-#
-# ./mvnw package -Dnative
-#
-# Then, build the image with:
-#
-# docker build -f src/main/docker/Dockerfile.native-micro -t quarkus/account-service .
-#
-# Then run the container using:
-#
-# docker run -i --rm -p 8080:8080 quarkus/account-service
-#
-# The `quay.io/quarkus/ubi9-quarkus-micro-image:2.0` base image is based on UBI 9.
-# To use UBI 8, switch to `quay.io/quarkus/quarkus-micro-image:2.0`.
-###
-FROM quay.io/quarkus/ubi9-quarkus-micro-image:2.0
-WORKDIR /work/
-RUN chown 1001 /work \
-    && chmod "g+rwX" /work \
-    && chown 1001:root /work
-COPY --chown=1001:root --chmod=0755 target/*-runner /work/application
-
-EXPOSE 8080
-USER 1001
-
-ENTRYPOINT ["./application", "-Dquarkus.http.host=0.0.0.0"]

account-service/src/main/java/com/drinkool/services/AccountService.java

@@ -2,8 +2,8 @@ package com.drinkool.services;
 
 import com.drinkool.Role;
 import com.drinkool.Url;
-import com.drinkool.dtos.SmsOtp;
 import com.drinkool.entities.ManagerEntity;
+import com.drinkool.lib.dtos.SmsOtp;
 import com.drinkool.models.UserModel;
 import jakarta.inject.Inject;
 import jakarta.ws.rs.*;

account-service/src/main/java/com/drinkool/services/CustomerService.java

@@ -1,8 +1,8 @@
 package com.drinkool.services;
 
 import com.drinkool.*;
-import com.drinkool.dtos.*;
 import com.drinkool.entities.CustomerEntity;
+import com.drinkool.lib.dtos.*;
 import jakarta.inject.Inject;
 import jakarta.transaction.Transactional;
 import jakarta.ws.rs.*;

account-service/src/main/java/com/drinkool/services/ManagerService.java

@@ -1,9 +1,9 @@
 package com.drinkool.services;
 
 import com.drinkool.*;
-import com.drinkool.dtos.*;
-import com.drinkool.dtos.event.ManagerCreate;
 import com.drinkool.entities.ManagerEntity;
+import com.drinkool.lib.dtos.*;
+import com.drinkool.lib.dtos.event.ManagerCreate;
 import jakarta.enterprise.context.ApplicationScoped;
 import jakarta.transaction.Transactional;
 import jakarta.ws.rs.*;

account-service/src/test/java/com/drinkool/services/AccountServiceTest.java

@@ -3,7 +3,7 @@ package com.drinkool.services;
 import static io.restassured.RestAssured.*;
 
 import com.drinkool.*;
-import com.drinkool.dtos.*;
+import com.drinkool.lib.dtos.*;
 import io.quarkus.test.junit.QuarkusTest;
 import io.restassured.http.ContentType;
 import org.junit.jupiter.api.Test;

account-service/src/test/java/com/drinkool/services/BaseServiceTest.java

@@ -4,7 +4,7 @@ import static io.restassured.RestAssured.*;
 import static org.hamcrest.CoreMatchers.*;
 
 import com.drinkool.*;
-import com.drinkool.dtos.*;
+import com.drinkool.lib.dtos.*;
 import io.quarkus.test.junit.QuarkusTest;
 import io.restassured.http.ContentType;
 import org.junit.jupiter.api.Test;

account-service/src/test/java/com/drinkool/services/CustomerServiceTest.java

@@ -4,8 +4,8 @@ import static io.restassured.RestAssured.*;
 import static org.junit.jupiter.api.Assertions.*;
 
 import com.drinkool.*;
-import com.drinkool.dtos.*;
 import com.drinkool.entities.CustomerEntity;
+import com.drinkool.lib.dtos.*;
 import io.quarkus.test.junit.QuarkusTest;
 import io.restassured.http.ContentType;
 import jakarta.inject.Inject;

account-service/src/test/java/com/drinkool/services/ManagerServiceTest.java

@@ -4,7 +4,7 @@ import static io.restassured.RestAssured.*;
 import static org.junit.jupiter.api.Assertions.*;
 
 import com.drinkool.*;
-import com.drinkool.dtos.*;
+import com.drinkool.lib.dtos.*;
 import io.quarkus.test.common.QuarkusTestResource;
 import io.quarkus.test.junit.QuarkusTest;
 import io.quarkus.test.kafka.*;

eatery-service/pom.xml

@@ -9,7 +9,7 @@
     <parent>
         <groupId>com.drinkool</groupId>
         <artifactId>drinkool</artifactId>
-        <version>1.5.16</version>
+        <version>1.5.20</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
 
@@ -28,6 +28,8 @@
         <quarkus.platform.version>3.32.4</quarkus.platform.version>
         <skipITs>true</skipITs>
         <surefire-plugin.version>3.5.4</surefire-plugin.version>
+        <org.mapstruct.version>1.6.3</org.mapstruct.version>
+        <org.projectlombok.version>1.18.46</org.projectlombok.version>
     </properties>
 
     <dependencyManagement>
@@ -48,6 +50,27 @@
             <artifactId>lib</artifactId>
             <version>${project.version}</version>
         </dependency>
+        <dependency>
+            <groupId>io.quarkus</groupId>
+            <artifactId>quarkus-security</artifactId>
+            <scope>provided</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <version>${org.projectlombok.version}</version>
+            <scope>provided</scope>
+        </dependency>
+        <dependency>
+            <groupId>io.quarkiverse.mapstruct</groupId>
+            <artifactId>quarkus-mapstruct</artifactId>
+            <version>1.1.0</version>
+        </dependency>
+        <dependency>
+            <groupId>org.mapstruct</groupId>
+            <artifactId>mapstruct</artifactId>
+            <version>${org.mapstruct.version}</version>
+        </dependency>
         <dependency>
             <groupId>net.datafaker</groupId>
             <artifactId>datafaker</artifactId>
@@ -130,6 +153,18 @@
                 <version>${compiler-plugin.version}</version>
                 <configuration>
                     <parameters>true</parameters>
+                    <annotationProcessorPaths>
+                        <path>
+                            <groupId>org.mapstruct</groupId>
+                            <artifactId>mapstruct-processor</artifactId>
+                            <version>${org.mapstruct.version}</version>
+                        </path>
+                        <path>
+                            <groupId>org.projectlombok</groupId>
+                            <artifactId>lombok</artifactId>
+                            <version>${org.projectlombok.version}</version>
+                        </path>
+                    </annotationProcessorPaths>
                 </configuration>
             </plugin>
             <plugin>

eatery-service/src/main/docker/Dockerfile.native

@@ -1,5 +1,8 @@
 ####
 # This Dockerfile is used in order to build a container that runs the Quarkus application in native (no JVM) mode.
+# It uses a micro base image, tuned for Quarkus native executables.
+# It reduces the size of the resulting container image.
+# Check https://quarkus.io/guides/quarkus-runtime-base-image for further information about this image.
 #
 # Before building the container image run:
 #
@@ -7,16 +10,16 @@
 #
 # Then, build the image with:
 #
-# docker build -f src/main/docker/Dockerfile.native -t quarkus/eatery-service .
+# docker build -f src/main/docker/Dockerfile.native-micro -t quarkus/eatery-service .
 #
 # Then run the container using:
 #
 # docker run -i --rm -p 8080:8080 quarkus/eatery-service
 #
-# The ` registry.access.redhat.com/ubi9/ubi-minimal:9.7` base image is based on UBI 9.
-# To use UBI 8, switch to `quay.io/ubi8/ubi-minimal:8.10`.
+# The `quay.io/quarkus/ubi9-quarkus-micro-image:2.0` base image is based on UBI 9.
+# To use UBI 8, switch to `quay.io/quarkus/quarkus-micro-image:2.0`.
 ###
-FROM registry.access.redhat.com/ubi9/ubi-minimal:9.7
+FROM quay.io/quarkus/ubi9-quarkus-micro-image:2.0
 WORKDIR /work/
 RUN chown 1001 /work \
     && chmod "g+rwX" /work \

eatery-service/src/main/docker/Dockerfile.native-micro

@@ -1,32 +0,0 @@
-####
-# This Dockerfile is used in order to build a container that runs the Quarkus application in native (no JVM) mode.
-# It uses a micro base image, tuned for Quarkus native executables.
-# It reduces the size of the resulting container image.
-# Check https://quarkus.io/guides/quarkus-runtime-base-image for further information about this image.
-#
-# Before building the container image run:
-#
-# ./mvnw package -Dnative
-#
-# Then, build the image with:
-#
-# docker build -f src/main/docker/Dockerfile.native-micro -t quarkus/eatery-service .
-#
-# Then run the container using:
-#
-# docker run -i --rm -p 8080:8080 quarkus/eatery-service
-#
-# The `quay.io/quarkus/ubi9-quarkus-micro-image:2.0` base image is based on UBI 9.
-# To use UBI 8, switch to `quay.io/quarkus/quarkus-micro-image:2.0`.
-###
-FROM quay.io/quarkus/ubi9-quarkus-micro-image:2.0
-WORKDIR /work/
-RUN chown 1001 /work \
-    && chmod "g+rwX" /work \
-    && chown 1001:root /work
-COPY --chown=1001:root --chmod=0755 target/*-runner /work/application
-
-EXPOSE 8080
-USER 1001
-
-ENTRYPOINT ["./application", "-Dquarkus.http.host=0.0.0.0"]

eatery-service/src/main/java/com/drinkool/dtos/AddMenuItem.java

@@ -0,0 +1,25 @@
+package com.drinkool.dtos;
+
+import com.drinkool.interfaces.MenuItemInterface;
+import io.quarkus.runtime.annotations.RegisterForReflection;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+import org.eclipse.microprofile.graphql.Input;
+import org.eclipse.microprofile.graphql.NonNull;
+
+@Input
+@Getter
+@Setter
+@NoArgsConstructor
+@AllArgsConstructor
+@RegisterForReflection
+public class AddMenuItem implements MenuItemInterface {
+
+	@NonNull
+	private String name;
+
+	@NonNull
+	private Double price;
+}

eatery-service/src/main/java/com/drinkool/dtos/DtoMapper.java

@@ -0,0 +1,22 @@
+package com.drinkool.dtos;
+
+import com.drinkool.entities.MenuItemEntity;
+import com.drinkool.entities.ReviewEntity;
+import com.drinkool.lib.dtos.SendReview;
+import org.mapstruct.BeanMapping;
+import org.mapstruct.Mapper;
+import org.mapstruct.MappingTarget;
+import org.mapstruct.NullValuePropertyMappingStrategy;
+
+@Mapper(componentModel = "cdi")
+public interface DtoMapper {
+	@BeanMapping(
+		nullValuePropertyMappingStrategy = NullValuePropertyMappingStrategy.IGNORE
+	)
+	void updateMenuItemToEntity(
+		UpdateMenuItem input,
+		@MappingTarget MenuItemEntity entity
+	);
+
+	ReviewEntity toReviewEntity(SendReview source);
+}

eatery-service/src/main/java/com/drinkool/dtos/UpdateMenuItem.java

@@ -0,0 +1,28 @@
+package com.drinkool.dtos;
+
+import com.drinkool.interfaces.EntityInterface;
+import com.drinkool.interfaces.MenuItemInterface;
+import io.quarkus.runtime.annotations.RegisterForReflection;
+import java.util.UUID;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+import org.eclipse.microprofile.graphql.Input;
+import org.eclipse.microprofile.graphql.NonNull;
+
+@Input
+@Getter
+@Setter
+@NoArgsConstructor
+@AllArgsConstructor
+@RegisterForReflection
+public class UpdateMenuItem implements EntityInterface, MenuItemInterface {
+
+	@NonNull
+	UUID id;
+
+	String name;
+
+	Double price;
+}

eatery-service/src/main/java/com/drinkool/entities/EateryEntity.java

@@ -25,7 +25,7 @@ public class EateryEntity extends BaseEntity {
 		cascade = CascadeType.ALL,
 		orphanRemoval = true
 	)
-	public List<MenuItemEntity> menus = new ArrayList<>();
+	public List<MenuItemEntity> menuItems = new ArrayList<>();
 
 	public EateryEntity() {}
 

eatery-service/src/main/java/com/drinkool/entities/MenuItemEntity.java

@@ -1,36 +1,43 @@
 package com.drinkool.entities;
 
+import com.drinkool.dtos.AddMenuItem;
+import com.drinkool.interfaces.MenuItemInterface;
 import com.drinkool.lib.entities.BaseEntity;
 import jakarta.persistence.*;
 import jakarta.transaction.Transactional;
+import lombok.Getter;
+import lombok.Setter;
 
 @Entity
 @Table
-public class MenuItemEntity extends BaseEntity {
+@Getter
+@Setter
+public class MenuItemEntity extends BaseEntity implements MenuItemInterface {
 
 	@Column(nullable = false)
 	public String name;
 
 	@Column(nullable = false)
-	public double price;
+	public Double price;
 
 	@ManyToOne(fetch = FetchType.LAZY)
 	@JoinColumn(name = "eatery_id")
 	public EateryEntity eatery;
 
+	MenuItemEntity() {}
+
+	MenuItemEntity(MenuItemInterface input) {
+		this.setName(input.getName());
+		this.setPrice(input.getPrice());
+	}
+
 	/**
 	 * Phương thức tiện ích để tạo nhanh Menu Item từ tên
 	 */
 	@Transactional
-	public static MenuItemEntity create(
-		EateryEntity eatery,
-		String name,
-		double price
-	) {
-		MenuItemEntity menuItem = new MenuItemEntity();
+	public static MenuItemEntity create(EateryEntity eatery, AddMenuItem input) {
+		MenuItemEntity menuItem = new MenuItemEntity(input);
 
-		menuItem.name = name;
-		menuItem.price = price;
 		menuItem.eatery = eatery;
 
 		menuItem.persist();

eatery-service/src/main/java/com/drinkool/entities/ReviewEntity.java

@@ -1,35 +1,34 @@
 package com.drinkool.entities;
 
-import com.drinkool.lib.models.ReviewModel;
+import com.drinkool.interfaces.ReviewInterface;
+import com.drinkool.lib.entities.BaseEntity;
 import jakarta.persistence.*;
-import jakarta.transaction.Transactional;
 import java.util.UUID;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
 
 @Entity
+@Getter
+@Setter
+@NoArgsConstructor
+@AllArgsConstructor
 @Table(name = "reviews")
-public class ReviewEntity extends ReviewModel {
+public class ReviewEntity extends BaseEntity implements ReviewInterface {
 
 	public UUID reviewerId;
 
 	public UUID eateryId;
 
-	private ReviewEntity(ReviewModel input) {
-		super(input);
-	}
+	public Integer rating;
 
-	@Transactional
-	public static ReviewEntity create(
-		UUID reviewerId,
-		UUID eateryId,
-		ReviewModel reviewInput
-	) {
-		ReviewEntity review = new ReviewEntity(reviewInput);
+	public String comment;
 
-		review.reviewerId = reviewerId;
-		review.eateryId = eateryId;
-
-		review.persist();
-
-		return review;
+	public void setRating(Integer score) {
+		if (score < 1 || score > 5) {
+			throw new IllegalArgumentException("InvalidRatingValue");
+		}
+		this.rating = score;
 	}
 }

eatery-service/src/main/java/com/drinkool/filters/HeaderRolesFilter.java

@@ -0,0 +1,7 @@
+package com.drinkool.filters;
+
+import com.drinkool.lib.utils.BaseHeaderAuthentication;
+import jakarta.enterprise.context.ApplicationScoped;
+
+@ApplicationScoped
+public class HeaderRolesFilter extends BaseHeaderAuthentication {}

eatery-service/src/main/java/com/drinkool/services/EateryService.java

@@ -2,9 +2,12 @@ package com.drinkool.services;
 
 import com.drinkool.InternalValue;
 import com.drinkool.Role;
-import com.drinkool.dtos.event.ManagerCreate;
+import com.drinkool.dtos.AddMenuItem;
+import com.drinkool.dtos.DtoMapper;
+import com.drinkool.dtos.UpdateMenuItem;
 import com.drinkool.entities.EateryEntity;
 import com.drinkool.entities.MenuItemEntity;
+import com.drinkool.lib.dtos.event.ManagerCreate;
 import io.vertx.core.http.HttpServerRequest;
 import jakarta.annotation.security.RolesAllowed;
 import jakarta.enterprise.context.ApplicationScoped;
@@ -22,6 +25,9 @@ import org.eclipse.microprofile.reactive.messaging.Incoming;
 @GraphQLApi
 public class EateryService {
 
+	@Inject
+	DtoMapper dtoMapper;
+
 	@Inject
 	HttpServerRequest request;
 
@@ -46,20 +52,57 @@ public class EateryService {
 	@Mutation("addMenuItem")
 	@RolesAllowed(Role.Manager)
 	@Transactional
-	public MenuItemEntity addMenuItem(
-		@Name("name") String name,
-		@Name("price") double price
-	) {
+	public MenuItemEntity addMenuItem(@Name("menuItem") AddMenuItem menuItem) {
 		String ownerId = request.getHeader(InternalValue.userId);
 
 		EateryEntity eatery = EateryEntity.findByOwnerId(ownerId);
 		if (eatery == null) return null;
 
-		MenuItemEntity item = MenuItemEntity.create(eatery, name, price);
+		MenuItemEntity item = MenuItemEntity.create(eatery, menuItem);
 
 		return item;
 	}
 
+	@Mutation("updateMenuItem")
+	@RolesAllowed(Role.Manager)
+	@Transactional
+	public MenuItemEntity updateMenuItem(UpdateMenuItem menuItem) {
+		UUID ownerId = UUID.fromString(request.getHeader(InternalValue.userId));
+
+		MenuItemEntity item = MenuItemEntity.find(
+			"id = ?1 and eatery.ownerId = ?2",
+			menuItem.getId(),
+			ownerId
+		).firstResult();
+
+		if (item == null) return null;
+
+		dtoMapper.updateMenuItemToEntity(menuItem, item);
+
+		item.persist();
+
+		return item;
+	}
+
+	@Mutation("deleteMenuItem")
+	@RolesAllowed(Role.Manager)
+	@Transactional
+	public boolean deleteMenuItem(@Name("menuItemId") UUID menuItemId) {
+		UUID ownerId = UUID.fromString(request.getHeader(InternalValue.userId));
+
+		MenuItemEntity item = MenuItemEntity.find(
+			"id = ?1 and eatery.ownerId = ?2",
+			menuItemId,
+			ownerId
+		).firstResult();
+
+		if (item == null) return false;
+
+		item.delete();
+
+		return true;
+	}
+
 	@Query("menuItemsByEatery")
 	public List<MenuItemEntity> getMenuItemsByEatery(
 		@Name("eateryId") UUID eateryId

eatery-service/src/main/java/com/drinkool/services/ReviewService.java

@@ -1,20 +1,71 @@
 package com.drinkool.services;
 
-import com.drinkool.dtos.SendReview;
+import com.drinkool.InternalValue;
+import com.drinkool.Role;
+import com.drinkool.Url;
+import com.drinkool.dtos.DtoMapper;
 import com.drinkool.entities.ReviewEntity;
+import com.drinkool.enums.SortBy;
+import com.drinkool.lib.dtos.SendReview;
+import io.quarkus.panache.common.Sort;
+import io.vertx.core.http.HttpServerRequest;
+import jakarta.annotation.security.RolesAllowed;
+import jakarta.inject.Inject;
 import jakarta.transaction.Transactional;
-import jakarta.ws.rs.*;
+import jakarta.ws.rs.DefaultValue;
+import jakarta.ws.rs.GET;
+import jakarta.ws.rs.POST;
+import jakarta.ws.rs.Path;
+import jakarta.ws.rs.PathParam;
+import jakarta.ws.rs.QueryParam;
 import jakarta.ws.rs.core.Response;
+import java.util.UUID;
 
-@Path("/api/review")
+@Path(Url.Review)
 public class ReviewService {
 
-	@POST
-	@Path("/create")
-	@Transactional
-	public Response create(SendReview input) {
-		ReviewEntity.create(input.reviewerId, input.orderId, input.review);
+	@Inject
+	HttpServerRequest request;
 
-		return Response.status(201).build();
+	@Inject
+	DtoMapper dtoMapper;
+
+	@GET
+	@Transactional
+	@Path("/{eateryId}")
+	public Response getReviewsByEatery(
+		@PathParam("eateryId") UUID eateryId,
+		@QueryParam("sort") @DefaultValue("LATEST") SortBy sortBy
+	) {
+		Sort sort = switch (sortBy) {
+			case LATEST -> Sort.descending("createDate");
+			case OLDEST -> Sort.ascending("createDate");
+			case HIGHEST -> Sort.descending("rating");
+			case LOWEST -> Sort.ascending("rating");
+		};
+
+		return Response.ok()
+			.entity(ReviewEntity.find("eateryId = ?1", sort, eateryId).list())
+			.build();
+	}
+
+	@POST
+	@RolesAllowed(Role.Customer)
+	@Transactional
+	public Response receiveReview(SendReview input) {
+		UUID reviewerId = UUID.fromString(request.getHeader(InternalValue.userId));
+
+		try {
+			ReviewEntity entity = dtoMapper.toReviewEntity(input);
+			entity.setReviewerId(reviewerId);
+
+			entity.persist();
+
+			return Response.status(Response.Status.CREATED).build();
+		} catch (Exception e) {
+			return Response.status(Response.Status.BAD_REQUEST)
+				.entity(e.getMessage())
+				.build();
+		}
 	}
 }

eatery-service/src/main/resources/application.properties

@@ -27,7 +27,8 @@ quarkus.native.remote-container-build=true
 quarkus.native.additional-build-args=--future-defaults=all
 
 # Kafka
-mp.messaging.connector.smallrye-kafka.bootstrap.servers=${KAFKA_SERVICE_SERVICE_HOST:host.docker.internal}:9092
+%prod.mp.messaging.connector.smallrye-kafka.bootstrap.servers=${KAFKA_SERVICE_SERVICE_HOST:host.docker.internal}:9092
+mp.messaging.incoming.manager-in.connector=smallrye-in-memory
 
 ## Create restaurant topic
 mp.messaging.incoming.manager-in.connector=smallrye-kafka

eatery-service/src/test/java/com/drinkool/entities/ReviewEntityTest.java

@@ -1,32 +1,34 @@
 package com.drinkool.entities;
 
-import com.drinkool.lib.models.ReviewModel;
 import io.quarkus.test.junit.QuarkusTest;
 import jakarta.transaction.Transactional;
 import java.util.UUID;
+import net.datafaker.Faker;
 import org.junit.jupiter.api.Assertions;
 import org.junit.jupiter.api.Test;
 
 @QuarkusTest
 public class ReviewEntityTest {
 
+	private final Faker faker = new Faker();
+
 	@Test
 	@Transactional
 	public void testCreateReview() {
-		// 1. Chuẩn bị dữ liệu (Arrange)
 		UUID testReviewerId = UUID.randomUUID();
 		UUID testEateryId = UUID.randomUUID();
+		String comment = faker.famousLastWords().lastWords();
+		int rating = faker.random().nextInt(1, 5);
 
-		// Truyền trực tiếp rating và comment vào constructor của ReviewModel
-		ReviewModel inputModel = new ReviewModel(5, "Món ăn tuyệt vời!");
-
-		// 2. Thực thi (Act)
-		ReviewEntity savedReview = ReviewEntity.create(
+		ReviewEntity savedReview = new ReviewEntity(
 			testReviewerId,
 			testEateryId,
-			inputModel
+			rating,
+			comment
 		);
 
+		savedReview.persist();
+
 		// 3. Kiểm chứng (Assert)
 		Assertions.assertNotNull(
 			savedReview,
@@ -42,12 +44,8 @@ public class ReviewEntityTest {
 			savedReview.eateryId,
 			"Eatery ID không khớp"
 		);
-		Assertions.assertEquals(5, savedReview.rating, "Rating không khớp");
-		Assertions.assertEquals(
-			"Món ăn tuyệt vời!",
-			savedReview.comment,
-			"Comment không khớp"
-		);
+		Assertions.assertEquals(rating, savedReview.rating, "Rating không khớp");
+		Assertions.assertEquals(comment, savedReview.comment, "Comment không khớp");
 
 		Assertions.assertNotNull(
 			savedReview.id,

eatery-service/src/test/java/com/drinkool/services/EateryServiceTest.java

@@ -9,9 +9,10 @@ import static org.hamcrest.Matchers.hasSize;
 
 import com.drinkool.InternalValue;
 import com.drinkool.Role;
-import com.drinkool.dtos.event.ManagerCreate;
+import com.drinkool.dtos.AddMenuItem;
 import com.drinkool.entities.EateryEntity;
 import com.drinkool.entities.MenuItemEntity;
+import com.drinkool.lib.dtos.event.ManagerCreate;
 import io.quarkus.test.junit.QuarkusTest;
 import io.restassured.http.ContentType;
 import io.smallrye.reactive.messaging.memory.InMemoryConnector;
@@ -19,6 +20,8 @@ import jakarta.enterprise.context.control.ActivateRequestContext;
 import jakarta.enterprise.inject.Any;
 import jakarta.inject.Inject;
 import jakarta.transaction.Transactional;
+import java.util.HashMap;
+import java.util.Map;
 import java.util.UUID;
 import net.datafaker.Faker;
 import org.junit.jupiter.api.Assertions;
@@ -57,9 +60,10 @@ public class EateryServiceTest {
 		Assertions.assertEquals("Quan Bun Cha Test", eatery.name);
 	}
 
-	private UUID lastSavedId;
-	private String lastSavedName;
-	private UUID lastOwnerId = UUID.randomUUID();
+	private UUID savedEateryId;
+	private String savedEateryName;
+	private UUID savedOwnerId = UUID.randomUUID();
+	private UUID savedMenuItemId;
 
 	@BeforeEach
 	@Transactional
@@ -67,11 +71,11 @@ public class EateryServiceTest {
 		MenuItemEntity.deleteAll();
 		EateryEntity.deleteAll();
 
-		lastSavedName = faker.restaurant().name();
+		savedEateryName = faker.restaurant().name();
 
 		EateryEntity eatery = new EateryEntity();
-		eatery = eatery.create(lastOwnerId, lastSavedName);
-		lastSavedId = eatery.id;
+		eatery = eatery.create(savedOwnerId, savedEateryName);
+		savedEateryId = eatery.id;
 
 		for (int i = 0; i < 2; i++) {
 			EateryEntity e = new EateryEntity();
@@ -79,11 +83,13 @@ public class EateryServiceTest {
 		}
 
 		for (int i = 0; i < 3; i++) {
-			MenuItemEntity.create(
+			savedMenuItemId = MenuItemEntity.create(
 				eatery,
-				faker.food().dish(),
-				faker.number().randomDouble(2, 10, 100)
-			);
+				new AddMenuItem(
+					faker.food().dish(),
+					faker.number().randomDouble(2, 10, 100)
+				)
+			).id;
 		}
 	}
 
@@ -101,7 +107,7 @@ public class EateryServiceTest {
 			.statusCode(200)
 			// GraphQL trả về dữ liệu bọc trong object "data"
 			.body("data.allEateries", notNullValue())
-			.body("data.allEateries.name", hasItems(lastSavedName));
+			.body("data.allEateries.name", hasItems(savedEateryName));
 	}
 
 	@Test
@@ -110,7 +116,7 @@ public class EateryServiceTest {
 		// Lưu ý: Trong GraphQL, String/UUID phải nằm trong dấu ngoặc kép
 		String query = String.format(
 			"{ \"query\": \"{ eateryById(id: \\\"%s\\\") { ownerId name } }\" }",
-			lastSavedId
+			savedEateryId
 		);
 
 		given()
@@ -120,32 +126,35 @@ public class EateryServiceTest {
 			.post("/graphql")
 			.then()
 			.statusCode(200)
-			.body("data.eateryById.name", is(lastSavedName));
+			.body("data.eateryById.name", is(savedEateryName));
 	}
 
 	@Test
 	public void testAddMenuItemSuccess() {
 		String mutation =
-			"mutation addMenuItem($name: String!, $price: Float!) {" +
-			"  addMenuItem(name: $name, price: $price) {" +
+			"mutation addMenuItem($menuItem: AddMenuItemInput!) {" +
+			"  addMenuItem(menuItem: $menuItem) {" +
 			"    id" +
 			"    name" +
 			"    price" +
 			"  }" +
 			"}";
 
-		java.util.Map<String, Object> variables = new java.util.HashMap<>();
-		variables.put("name", "Trà Sữa");
-		variables.put("price", 30000.0);
+		Map<String, Object> menuItemData = new HashMap<>();
+		menuItemData.put("name", "Trà Sữa");
+		menuItemData.put("price", 30000.0);
 
-		java.util.Map<String, Object> requestBody = new java.util.HashMap<>();
+		Map<String, Object> variables = new HashMap<>();
+		variables.put("menuItem", menuItemData);
+
+		Map<String, Object> requestBody = new HashMap<>();
 		requestBody.put("query", mutation);
 		requestBody.put("variables", variables);
 
 		given()
 			.contentType(ContentType.JSON)
 			.header(InternalValue.role, Role.Manager)
-			.header(InternalValue.userId, lastOwnerId) // Thay "x-user-id" bằng InternalValue.userId của bạn
+			.header(InternalValue.userId, savedOwnerId) // Thay "x-user-id" bằng InternalValue.userId của bạn
 			.body(requestBody)
 			.when()
 			.post("/graphql")
@@ -158,33 +167,34 @@ public class EateryServiceTest {
 	@Test
 	public void testAddMenuItemFailInvalidRole() {
 		String mutation =
-			"mutation addMenuItem($name: String!, $price: Float!) {" +
-			"  addMenuItem(name: $name, price: $price) {" +
+			"mutation addMenuItem($menuItem: AddMenuItemInput!) {" +
+			"  addMenuItem(menuItem: $menuItem) {" +
 			"    id" +
 			"    name" +
 			"    price" +
 			"  }" +
 			"}";
 
-		java.util.Map<String, Object> variables = new java.util.HashMap<>();
-		variables.put("name", "Trà Sữa");
-		variables.put("price", 30000.0);
+		Map<String, Object> menuItemData = new HashMap<>();
+		menuItemData.put("name", "Trà Sữa");
+		menuItemData.put("price", 30000.0);
 
-		java.util.Map<String, Object> requestBody = new java.util.HashMap<>();
+		Map<String, Object> variables = new HashMap<>();
+		variables.put("menuItem", menuItemData);
+
+		Map<String, Object> requestBody = new HashMap<>();
 		requestBody.put("query", mutation);
 		requestBody.put("variables", variables);
 
 		given()
 			.contentType(ContentType.JSON)
 			.header(InternalValue.role, Role.Customer)
-			.header(InternalValue.userId, lastOwnerId)
+			.header(InternalValue.userId, savedOwnerId)
 			.body(requestBody)
 			.when()
 			.post("/graphql")
 			.then()
-			.statusCode(200)
-			.body("data.addMenuItem.name", is("Trà Sữa"))
-			.body("data.addMenuItem.id", notNullValue());
+			.statusCode(200);
 	}
 
 	@Test
@@ -192,7 +202,7 @@ public class EateryServiceTest {
 		String mutation =
 			"mutation { addMenuItem(name: \"Coffee\", price: 20000.0) { id } }";
 
-		java.util.Map<String, Object> requestBody = new java.util.HashMap<>();
+		Map<String, Object> requestBody = new HashMap<>();
 		requestBody.put("query", mutation);
 
 		given()
@@ -218,10 +228,10 @@ public class EateryServiceTest {
 			"  }" +
 			"}";
 
-		java.util.Map<String, Object> variables = new java.util.HashMap<>();
-		variables.put("id", lastSavedId.toString());
+		Map<String, Object> variables = new HashMap<>();
+		variables.put("id", savedEateryId.toString());
 
-		java.util.Map<String, Object> requestBody = new java.util.HashMap<>();
+		Map<String, Object> requestBody = new HashMap<>();
 		requestBody.put("query", query);
 		requestBody.put("variables", variables);
 
@@ -246,10 +256,10 @@ public class EateryServiceTest {
 			"  }" +
 			"}";
 
-		java.util.Map<String, Object> variables = new java.util.HashMap<>();
+		Map<String, Object> variables = new HashMap<>();
 		variables.put("id", randomId);
 
-		java.util.Map<String, Object> requestBody = new java.util.HashMap<>();
+		Map<String, Object> requestBody = new HashMap<>();
 		requestBody.put("query", query);
 		requestBody.put("variables", variables);
 
@@ -262,4 +272,69 @@ public class EateryServiceTest {
 			.statusCode(200)
 			.body("data.menuItemsByEatery", hasSize(0)); // Phải trả về List rỗng như code bạn viết
 	}
+
+	@Test
+	public void testUpdateMenuItem_Success() {
+		String mutation = """
+			    mutation updateMenuItem($menuItem: UpdateMenuItemInput!) {
+			        updateMenuItem(menuItem: $menuItem) {
+			            id
+			            name
+			            price
+			        }
+			    }
+			""";
+
+		String newValue = "Phở Bò";
+
+		Map<String, Object> menuItemData = new HashMap<>();
+		menuItemData.put("id", savedMenuItemId);
+		menuItemData.put("name", newValue);
+
+		Map<String, Object> variables = new HashMap<>();
+		variables.put("menuItem", menuItemData);
+
+		Map<String, Object> requestBody = new HashMap<>();
+		requestBody.put("query", mutation);
+		requestBody.put("variables", variables);
+
+		given()
+			.contentType(ContentType.JSON)
+			.header(InternalValue.role, Role.Manager)
+			.header(InternalValue.userId, savedOwnerId)
+			.body(requestBody)
+			.when()
+			.post("/graphql")
+			.then()
+			.body("data.updateMenuItem.name", is(newValue))
+			.body("data.updateMenuItem.id", is(savedMenuItemId.toString()))
+			.statusCode(200);
+	}
+
+	@Test
+	public void testDeleteMenuItem_Success() {
+		String mutation = """
+			    mutation deleteItem($input: String!) {
+			        deleteMenuItem(menuItemId: $input)
+			    }
+			""";
+
+		Map<String, Object> variables = new HashMap<>();
+		variables.put("input", savedMenuItemId.toString());
+
+		Map<String, Object> requestBody = new HashMap<>();
+		requestBody.put("query", mutation);
+		requestBody.put("variables", variables);
+
+		given()
+			.contentType(ContentType.JSON)
+			.header(InternalValue.role, Role.Manager)
+			.header(InternalValue.userId, savedOwnerId)
+			.body(requestBody)
+			.when()
+			.post("/graphql")
+			.then()
+			.statusCode(200)
+			.body("data.deleteMenuItem", is(true));
+	}
 }

eatery-service/src/test/java/com/drinkool/services/ReviewServiceTest.java

@@ -1,43 +1,109 @@
 package com.drinkool.services;
 
 import static io.restassured.RestAssured.given;
+import static org.hamcrest.CoreMatchers.is;
 import static org.junit.jupiter.api.Assertions.*;
 
-import com.drinkool.dtos.SendReview;
+import com.drinkool.InternalValue;
+import com.drinkool.Role;
+import com.drinkool.Url;
+import com.drinkool.entities.EateryEntity;
+import com.drinkool.entities.MenuItemEntity;
 import com.drinkool.entities.ReviewEntity;
-import com.drinkool.lib.models.ReviewModel;
+import com.drinkool.lib.dtos.SendReview;
 import io.quarkus.test.junit.QuarkusTest;
 import io.restassured.http.ContentType;
-import java.util.Random;
+import jakarta.transaction.Transactional;
+import jakarta.ws.rs.core.Response;
 import java.util.UUID;
+import net.datafaker.Faker;
 import org.junit.jupiter.api.*;
 
 @QuarkusTest
 public class ReviewServiceTest {
 
+	private final Faker faker = new Faker();
+
+	private UUID savedEateryId;
+	private String savedEateryName;
+	private UUID savedOwnerId = UUID.randomUUID();
+
+	@BeforeEach
+	@Transactional
+	void setup() {
+		ReviewEntity.deleteAll();
+		MenuItemEntity.deleteAll();
+		EateryEntity.deleteAll();
+
+		savedEateryName = faker.restaurant().name();
+
+		EateryEntity eatery = new EateryEntity();
+		eatery = eatery.create(savedOwnerId, savedEateryName);
+		savedEateryId = eatery.id;
+
+		for (int i = 0; i < 3; i++) {
+			ReviewEntity entity = new ReviewEntity(
+				UUID.randomUUID(),
+				savedEateryId,
+				faker.random().nextInt(1, 5),
+				faker.famousLastWords().lastWords()
+			);
+
+			entity.persist();
+		}
+	}
+
 	@Test
-	void receiveReview() {
-		Random random = new Random();
-
+	void receiveReview_Success() {
 		UUID reviewerId = UUID.randomUUID();
-		UUID orderId = UUID.randomUUID();
-		String comment = UUID.randomUUID().toString();
-		int rating = random.nextInt();
+		UUID eateryId = UUID.randomUUID();
+		String comment = faker.famousLastWords().lastWords();
+		int rating = faker.random().nextInt(1, 5);
 
-		SendReview input = new SendReview();
-		input.reviewerId = reviewerId;
-		input.orderId = orderId;
-		ReviewModel reviewModel = new ReviewModel(rating, comment);
-		input.review = reviewModel;
+		SendReview input = new SendReview(reviewerId, eateryId, rating, comment);
 
 		given()
+			.header(InternalValue.role, Role.Customer)
+			.header(InternalValue.userId, reviewerId)
 			.contentType(ContentType.JSON)
 			.body(input)
 			.when()
-			.post("/api/review/create")
+			.post(Url.Review)
 			.then()
-			.statusCode(201);
+			.statusCode(Response.Status.CREATED.getStatusCode());
 
 		assertEquals(1, ReviewEntity.find("reviewerId", reviewerId).count());
 	}
+
+	@Test
+	void receiveReview_FailedDueToInvalidRating() {
+		UUID reviewerId = UUID.randomUUID();
+		UUID eateryId = UUID.randomUUID();
+		String comment = faker.famousLastWords().lastWords();
+		int rating = faker.random().nextInt(6, 10);
+
+		SendReview input = new SendReview(reviewerId, eateryId, rating, comment);
+
+		given()
+			.header(InternalValue.role, Role.Customer)
+			.header(InternalValue.userId, UUID.randomUUID())
+			.contentType(ContentType.JSON)
+			.body(input)
+			.when()
+			.post(Url.Review)
+			.then()
+			.contentType(ContentType.TEXT)
+			.body(is("InvalidRatingValue"))
+			.statusCode(Response.Status.BAD_REQUEST.getStatusCode());
+	}
+
+	@Test
+	public void testGetReviews_DefaultLatest() {
+		given()
+			.when()
+			.get(Url.Review + '/' + savedEateryId.toString())
+			.then()
+			.statusCode(Response.Status.OK.getStatusCode())
+			.contentType(ContentType.JSON);
+	}
 }

gateway-service/pom.xml

@@ -9,7 +9,7 @@
     <parent>
         <groupId>com.drinkool</groupId>
         <artifactId>drinkool</artifactId>
-        <version>1.5.16</version>
+        <version>1.5.20</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
 
@@ -48,6 +48,10 @@
             <artifactId>jose4j</artifactId>
             <version>0.9.6</version>
         </dependency>
+        <dependency>
+            <groupId>io.quarkus</groupId>
+            <artifactId>quarkus-security</artifactId>
+        </dependency>
         <dependency>
             <groupId>io.quarkus</groupId>
             <artifactId>quarkus-smallrye-graphql-client</artifactId>

gateway-service/src/main/docker/Dockerfile.native

@@ -1,5 +1,8 @@
 ####
 # This Dockerfile is used in order to build a container that runs the Quarkus application in native (no JVM) mode.
+# It uses a micro base image, tuned for Quarkus native executables.
+# It reduces the size of the resulting container image.
+# Check https://quarkus.io/guides/quarkus-runtime-base-image for further information about this image.
 #
 # Before building the container image run:
 #
@@ -7,16 +10,16 @@
 #
 # Then, build the image with:
 #
-# docker build -f src/main/docker/Dockerfile.native -t quarkus/gateway-service .
+# docker build -f src/main/docker/Dockerfile.native-micro -t quarkus/gateway-service .
 #
 # Then run the container using:
 #
 # docker run -i --rm -p 8080:8080 quarkus/gateway-service
 #
-# The ` registry.access.redhat.com/ubi9/ubi-minimal:9.7` base image is based on UBI 9.
-# To use UBI 8, switch to `quay.io/ubi8/ubi-minimal:8.10`.
+# The `quay.io/quarkus/ubi9-quarkus-micro-image:2.0` base image is based on UBI 9.
+# To use UBI 8, switch to `quay.io/quarkus/quarkus-micro-image:2.0`.
 ###
-FROM registry.access.redhat.com/ubi9/ubi-minimal:9.7
+FROM quay.io/quarkus/ubi9-quarkus-micro-image:2.0
 WORKDIR /work/
 RUN chown 1001 /work \
     && chmod "g+rwX" /work \

gateway-service/src/main/docker/Dockerfile.native-micro

@@ -1,32 +0,0 @@
-####
-# This Dockerfile is used in order to build a container that runs the Quarkus application in native (no JVM) mode.
-# It uses a micro base image, tuned for Quarkus native executables.
-# It reduces the size of the resulting container image.
-# Check https://quarkus.io/guides/quarkus-runtime-base-image for further information about this image.
-#
-# Before building the container image run:
-#
-# ./mvnw package -Dnative
-#
-# Then, build the image with:
-#
-# docker build -f src/main/docker/Dockerfile.native-micro -t quarkus/gateway-service .
-#
-# Then run the container using:
-#
-# docker run -i --rm -p 8080:8080 quarkus/gateway-service
-#
-# The `quay.io/quarkus/ubi9-quarkus-micro-image:2.0` base image is based on UBI 9.
-# To use UBI 8, switch to `quay.io/quarkus/quarkus-micro-image:2.0`.
-###
-FROM quay.io/quarkus/ubi9-quarkus-micro-image:2.0
-WORKDIR /work/
-RUN chown 1001 /work \
-    && chmod "g+rwX" /work \
-    && chown 1001:root /work
-COPY --chown=1001:root --chmod=0755 target/*-runner /work/application
-
-EXPOSE 8080
-USER 1001
-
-ENTRYPOINT ["./application", "-Dquarkus.http.host=0.0.0.0"]

gateway-service/src/main/java/com/drinkool/controller/CustomerController.java

@@ -1,7 +1,7 @@
 package com.drinkool.controller;
 
 import com.drinkool.*;
-import com.drinkool.dtos.*;
+import com.drinkool.lib.dtos.*;
 import com.drinkool.services.CustomerService;
 import io.smallrye.mutiny.Uni;
 import jakarta.inject.Inject;

gateway-service/src/main/java/com/drinkool/controller/EateryController.java

@@ -1,43 +1,99 @@
 package com.drinkool.controller;
 
-import com.drinkool.dtos.GraphqlDto;
-import io.smallrye.graphql.client.GraphQLClient;
-import io.smallrye.graphql.client.GraphQLError;
+import com.drinkool.InternalValue;
+import com.drinkool.Url;
+import com.drinkool.enums.SortBy;
+import com.drinkool.lib.dtos.GraphqlDto;
+import com.drinkool.lib.dtos.SendReview;
+import com.drinkool.services.ReviewService;
 import io.smallrye.graphql.client.dynamic.api.DynamicGraphQLClient;
+import io.smallrye.graphql.client.dynamic.api.DynamicGraphQLClientBuilder;
+import io.smallrye.mutiny.Uni;
+import jakarta.inject.Inject;
+import jakarta.json.bind.Jsonb;
+import jakarta.ws.rs.DefaultValue;
+import jakarta.ws.rs.GET;
 import jakarta.ws.rs.POST;
 import jakarta.ws.rs.Path;
+import jakarta.ws.rs.PathParam;
+import jakarta.ws.rs.QueryParam;
+import jakarta.ws.rs.core.Context;
+import jakarta.ws.rs.core.HttpHeaders;
+import jakarta.ws.rs.core.MediaType;
 import jakarta.ws.rs.core.Response;
-import java.util.List;
-import java.util.concurrent.ExecutionException;
-import java.util.stream.Collectors;
+import java.util.UUID;
+import org.eclipse.microprofile.config.inject.ConfigProperty;
+import org.eclipse.microprofile.rest.client.inject.RestClient;
 
 @Path("/api/eatery")
 public class EateryController {
 
-	@GraphQLClient("eatery")
-	DynamicGraphQLClient dynamicClient;
+	@ConfigProperty(name = "quarkus.smallrye-graphql-client.eatery.url")
+	String eateryUrl;
+
+	@Inject
+	Jsonb jsonb;
+
+	@Inject
+	@RestClient
+	ReviewService reviewService;
+
+	@GET
+	@Path(Url.Review + "/{eateryId}")
+	Uni<Response> getReviewsByEatery(
+		@PathParam("eateryId") UUID eateryId,
+		@QueryParam("sort") @DefaultValue("LATEST") SortBy sortBy
+	) {
+		return reviewService.getReviewsByEatery(eateryId, sortBy);
+	}
+
+	@POST
+	@Path(Url.Review)
+	Uni<Response> receiveReview(SendReview input) {
+		return reviewService.receiveReview(input);
+	}
 
 	@POST
 	@Path("/graphql")
-	public Response forward(GraphqlDto gqlRequest)
-		throws ExecutionException, InterruptedException {
-		io.smallrye.graphql.client.Response response = dynamicClient.executeSync(
-			gqlRequest.query,
-			gqlRequest.variables
-		);
+	public Response forward(
+		GraphqlDto gqlRequest,
+		@Context HttpHeaders httpHeaders
+	) {
+		DynamicGraphQLClientBuilder builder =
+			DynamicGraphQLClientBuilder.newBuilder().url(eateryUrl);
 
-		if (response.hasError()) {
-			List<String> errorMessages = response
-				.getErrors()
-				.stream()
-				.map(GraphQLError::getMessage)
-				.collect(Collectors.toList());
+		httpHeaders
+			.getRequestHeaders()
+			.forEach((name, values) -> {
+				String headerName = name.toLowerCase();
 
-			return Response.status(400).entity(errorMessages).build();
+				if (headerName.startsWith(InternalValue.headerId.toLowerCase())) {
+					if (!values.isEmpty()) {
+						builder.header(name, values.get(0));
+					}
+				}
+			});
+
+		try (DynamicGraphQLClient tempClient = builder.build()) {
+			io.smallrye.graphql.client.Response response = tempClient.executeSync(
+				gqlRequest.query,
+				gqlRequest.variables
+			);
+
+			if (response.hasError()) {
+				return Response.status(400)
+					.entity(jsonb.toJson(response.getErrors()))
+					.build();
+			}
+
+			return Response.ok(jsonb.toJson(response.getData()))
+				.type(MediaType.APPLICATION_JSON)
+				.build();
+		} catch (Exception e) {
+			e.printStackTrace();
+			return Response.serverError()
+				.entity("Lỗi kết nối tới service Eatery")
+				.build();
 		}
-
-		return jakarta.ws.rs.core.Response.ok(
-			response.getData().toString()
-		).build();
 	}
 }

gateway-service/src/main/java/com/drinkool/controller/IndexController.java

@@ -1,7 +1,7 @@
 package com.drinkool.controller;
 
 import com.drinkool.Url;
-import com.drinkool.dtos.SmsOtp;
+import com.drinkool.lib.dtos.SmsOtp;
 import com.drinkool.services.BaseService;
 import io.smallrye.mutiny.Uni;
 import jakarta.inject.Inject;

gateway-service/src/main/java/com/drinkool/controller/MainController.java

@@ -1,7 +1,7 @@
 package com.drinkool.controller;
 
 import com.drinkool.Url;
-import com.drinkool.dtos.Login;
+import com.drinkool.lib.dtos.Login;
 import com.drinkool.services.CustomerService;
 import com.drinkool.services.ManagerService;
 import io.smallrye.mutiny.Uni;

gateway-service/src/main/java/com/drinkool/controller/ManagerController.java

@@ -1,7 +1,7 @@
 package com.drinkool.controller;
 
 import com.drinkool.*;
-import com.drinkool.dtos.*;
+import com.drinkool.lib.dtos.*;
 import com.drinkool.services.ManagerService;
 import io.smallrye.mutiny.Uni;
 import jakarta.inject.Inject;

gateway-service/src/main/java/com/drinkool/filters/HeaderRolesFilter.java

@@ -0,0 +1,92 @@
+package com.drinkool.filters;
+
+import com.drinkool.InternalValue;
+import com.drinkool.lib.utils.BaseHeaderAuthentication;
+import io.quarkus.security.identity.IdentityProviderManager;
+import io.quarkus.security.identity.SecurityIdentity;
+import io.quarkus.security.runtime.QuarkusSecurityIdentity;
+import io.smallrye.mutiny.Uni;
+import io.vertx.core.MultiMap;
+import io.vertx.ext.web.RoutingContext;
+import jakarta.enterprise.context.ApplicationScoped;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import org.eclipse.microprofile.config.inject.ConfigProperty;
+import org.jose4j.jwt.JwtClaims;
+import org.jose4j.jwt.consumer.JwtConsumer;
+import org.jose4j.jwt.consumer.JwtConsumerBuilder;
+import org.jose4j.keys.HmacKey;
+
+@ApplicationScoped
+public class HeaderRolesFilter extends BaseHeaderAuthentication {
+
+	@ConfigProperty(name = "gateway.jwt.secret")
+	String SECRET_KEY;
+
+	private boolean isSystemClaim(String key) {
+		return List.of("iss", "sub", "aud", "exp", "nbf", "iat", "jti").contains(
+			key
+		);
+	}
+
+	private void removeForeignHeader(RoutingContext context) {
+		MultiMap headers = context.request().headers();
+		List<String> keysToRemove = new ArrayList<>();
+
+		for (String key : headers.names()) {
+			if (key.toLowerCase().startsWith(InternalValue.headerId.toLowerCase())) {
+				keysToRemove.add(key);
+			}
+		}
+
+		for (String key : keysToRemove) {
+			headers.remove(key);
+		}
+	}
+
+	@Override
+	public Uni<SecurityIdentity> authenticate(
+		RoutingContext context,
+		IdentityProviderManager identityProviderManager
+	) {
+		this.removeForeignHeader(context);
+
+		var cookie = context.request().getCookie(InternalValue.cookieName);
+
+		if (cookie == null) return Uni.createFrom().nullItem();
+
+		return Uni.createFrom().item(() -> {
+			try {
+				JwtConsumer jwtConsumer = new JwtConsumerBuilder()
+					.setRequireExpirationTime()
+					.setVerificationKey(new HmacKey(SECRET_KEY.getBytes()))
+					.build();
+
+				JwtClaims claims = jwtConsumer.processToClaims(cookie.getValue());
+				Map<String, Object> allClaims = claims.getClaimsMap();
+
+				allClaims.forEach((key, value) -> {
+					if (!isSystemClaim(key) && value != null) {
+						context
+							.request()
+							.headers()
+							.add(InternalValue.headerId + key, value.toString());
+					}
+				});
+
+				String role = context.request().getHeader(InternalValue.role);
+				String userId = context.request().getHeader(InternalValue.userId);
+
+				return QuarkusSecurityIdentity.builder()
+					.setPrincipal(() -> userId)
+					.addRole(role)
+					.build();
+			} catch (Exception e) {
+				context.response().setStatusCode(401).end("InvalidToken");
+			}
+
+			return null;
+		});
+	}
+}

gateway-service/src/main/java/com/drinkool/filters/InternalHeaderGatewayFilter.java

@@ -1,19 +1,15 @@
 package com.drinkool.filters;
 
 import com.drinkool.InternalValue;
-import io.smallrye.mutiny.Uni;
 import jakarta.ws.rs.Priorities;
 import jakarta.ws.rs.container.*;
 import jakarta.ws.rs.core.*;
 import java.util.*;
 import org.eclipse.microprofile.config.inject.ConfigProperty;
-import org.jboss.resteasy.reactive.server.ServerRequestFilter;
 import org.jboss.resteasy.reactive.server.ServerResponseFilter;
 import org.jose4j.jws.AlgorithmIdentifiers;
 import org.jose4j.jws.JsonWebSignature;
 import org.jose4j.jwt.JwtClaims;
-import org.jose4j.jwt.consumer.JwtConsumer;
-import org.jose4j.jwt.consumer.JwtConsumerBuilder;
 import org.jose4j.keys.HmacKey;
 
 public class InternalHeaderGatewayFilter {
@@ -21,60 +17,6 @@ public class InternalHeaderGatewayFilter {
 	@ConfigProperty(name = "gateway.jwt.secret")
 	String SECRET_KEY;
 
-	private boolean isSystemClaim(String key) {
-		return List.of("iss", "sub", "aud", "exp", "nbf", "iat", "jti").contains(
-			key
-		);
-	}
-
-	@ServerRequestFilter(preMatching = true)
-	public Uni<Response> handleRequestHeaders(
-		ContainerRequestContext requestContext
-	) {
-		requestContext
-			.getHeaders()
-			.keySet()
-			.removeIf(
-				key ->
-					key.equalsIgnoreCase(InternalValue.headerId) ||
-					key.toLowerCase().startsWith(InternalValue.headerId.toLowerCase())
-			);
-
-		Map<String, Cookie> cookies = requestContext.getCookies();
-		Cookie authCookie = cookies.get(InternalValue.cookieName);
-
-		if (authCookie == null) return Uni.createFrom().nullItem();
-
-		return Uni.createFrom().item(() -> {
-			try {
-				String token = authCookie.getValue();
-
-				JwtConsumer jwtConsumer = new JwtConsumerBuilder()
-					.setRequireExpirationTime()
-					.setVerificationKey(new HmacKey(SECRET_KEY.getBytes()))
-					.build();
-
-				JwtClaims claims = jwtConsumer.processToClaims(token);
-
-				Map<String, Object> allClaims = claims.getClaimsMap();
-
-				allClaims.forEach((key, value) -> {
-					if (!isSystemClaim(key) && value != null) {
-						String headerName = InternalValue.headerId + (key);
-
-						requestContext.getHeaders().add(headerName, value.toString());
-					}
-				});
-			} catch (Exception e) {
-				return Response.status(Response.Status.UNAUTHORIZED)
-					.entity("InvalidToken")
-					.build();
-			}
-
-			return null;
-		});
-	}
-
 	@ServerResponseFilter(priority = Priorities.USER + 100)
 	public void handleResponseHeaders(ContainerResponseContext responseContext) {
 		JwtClaims claims = new JwtClaims();

gateway-service/src/main/java/com/drinkool/services/BaseService.java

@@ -1,7 +1,7 @@
 package com.drinkool.services;
 
 import com.drinkool.Url;
-import com.drinkool.dtos.SmsOtp;
+import com.drinkool.lib.dtos.SmsOtp;
 import io.smallrye.mutiny.Uni;
 import jakarta.ws.rs.POST;
 import jakarta.ws.rs.Path;

gateway-service/src/main/java/com/drinkool/services/CustomerService.java

@@ -3,7 +3,7 @@ package com.drinkool.services;
 import com.drinkool.InternalValue;
 import com.drinkool.Role;
 import com.drinkool.Url;
-import com.drinkool.dtos.*;
+import com.drinkool.lib.dtos.*;
 import io.smallrye.mutiny.Uni;
 import jakarta.ws.rs.*;
 import jakarta.ws.rs.core.Response;

gateway-service/src/main/java/com/drinkool/services/ManagerService.java

@@ -3,7 +3,7 @@ package com.drinkool.services;
 import com.drinkool.InternalValue;
 import com.drinkool.Role;
 import com.drinkool.Url;
-import com.drinkool.dtos.*;
+import com.drinkool.lib.dtos.*;
 import io.smallrye.mutiny.Uni;
 import jakarta.ws.rs.*;
 import jakarta.ws.rs.core.Response;

gateway-service/src/main/java/com/drinkool/services/ReviewService.java

@@ -0,0 +1,30 @@
+package com.drinkool.services;
+
+import com.drinkool.Url;
+import com.drinkool.enums.SortBy;
+import com.drinkool.lib.dtos.SendReview;
+
+import io.smallrye.mutiny.Uni;
+import jakarta.ws.rs.DefaultValue;
+import jakarta.ws.rs.GET;
+import jakarta.ws.rs.POST;
+import jakarta.ws.rs.Path;
+import jakarta.ws.rs.PathParam;
+import jakarta.ws.rs.QueryParam;
+import jakarta.ws.rs.core.Response;
+import java.util.UUID;
+import org.eclipse.microprofile.rest.client.inject.RegisterRestClient;
+
+@RegisterRestClient(configKey = "eatery")
+@Path(Url.Review)
+public interface ReviewService {
+	@GET
+	@Path("/{eateryId}")
+	public Uni<Response> getReviewsByEatery(
+		@PathParam("eateryId") UUID eateryId,
+		@QueryParam("sort") @DefaultValue("LATEST") SortBy sortBy
+	);
+
+	@POST
+	public Uni<Response> receiveReview(SendReview input);
+}

gateway-service/src/main/resources/application.properties

@@ -10,4 +10,11 @@ quarkus.container-image.additional-tags=latest
 # Build
 quarkus.native.container-build=true
 quarkus.native.remote-container-build=true
-quarkus.native.additional-build-args=--future-defaults=all
+quarkus.native.additional-build-args=--future-defaults=all
+
+# Rest Client
+quarkus.rest-client.account.url=http://account-service
+quarkus.rest-client.eatery.url=http://eatery-service
+
+# GraphQL Client
+quarkus.smallrye-graphql-client.eatery.url=http://eatery-service/graphql

k8s/base/account.yaml

@@ -14,7 +14,7 @@ spec:
     spec:
       containers:
         - name: account-pod
-          image: git.demonkernel.io.vn/foodsurf/account-service:1.5.16
+          image: git.demonkernel.io.vn/foodsurf/account-service:1.5.20
           imagePullPolicy: IfNotPresent
           ports:
             - containerPort: 8080

k8s/base/eatery.yaml

@@ -14,7 +14,7 @@ spec:
     spec:
       containers:
         - name: eatery-pod
-          image: git.demonkernel.io.vn/foodsurf/eatery-service:1.5.16
+          image: git.demonkernel.io.vn/foodsurf/eatery-service:1.5.20
           imagePullPolicy: IfNotPresent
           ports:
             - containerPort: 8080

k8s/base/gateway.yaml

@@ -14,15 +14,11 @@ spec:
     spec:
       containers:
         - name: gateway-pod
-          image: git.demonkernel.io.vn/foodsurf/gateway-service:1.5.16
+          image: git.demonkernel.io.vn/foodsurf/gateway-service:1.5.20
           imagePullPolicy: IfNotPresent
           ports:
             - containerPort: 8080
           env:
-            - name: QUARKUS_REST_CLIENT_ACCOUNT_URL
-              value: "http://account-service"
-            - name: QUARKUS_SMALLRYE_GRAPHQL_CLIENT_EATERY_URL
-              value: "http://eatery-service/graphql"
             - name: GATEWAY_JWT_SECRET
               valueFrom:
                 secretKeyRef:

k8s/base/kustomization.yaml

@@ -0,0 +1,7 @@
+resources:
+  - account.yaml
+  - eatery.yaml
+  - gateway.yaml
+  - redis.yaml
+  - kafdrop.yaml
+  - kafka.yaml

k8s/dev/kustomization.yaml

@@ -0,0 +1,10 @@
+resources:
+  - ../base
+
+patches:
+  - target:
+      kind: Deployment
+    patch: |
+      - op: add
+        path: /spec/template/spec/containers/0/resources
+        value: {}

lib/pom.xml

@@ -1,15 +1,15 @@
-<?xml version="1.0" encoding="UTF-8" ?>
+<?xml version="1.0" encoding="UTF-8"?>
 <project
-	xmlns="http://maven.apache.org/POM/4.0.0"
-	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"
+  xmlns="http://maven.apache.org/POM/4.0.0"
+  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"
 >
   <modelVersion>4.0.0</modelVersion>
 
   <parent>
     <groupId>com.drinkool</groupId>
     <artifactId>drinkool</artifactId>
-    <version>1.5.16</version>
+    <version>1.5.20</version>
     <relativePath>../pom.xml</relativePath>
   </parent>
 
@@ -18,13 +18,17 @@
     <maven.compiler.source>25</maven.compiler.source>
     <maven.compiler.target>25</maven.compiler.target>
     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+    <org.projectlombok.version>1.18.46</org.projectlombok.version>
   </properties>
 
   <dependencies>
     <dependency>
       <groupId>io.quarkus</groupId>
       <artifactId>quarkus-security</artifactId>
-      <scope>provided</scope>
+    </dependency>
+    <dependency>
+      <groupId>io.quarkus</groupId>
+      <artifactId>quarkus-vertx-http</artifactId>
     </dependency>
     <dependency>
       <groupId>com.fasterxml.jackson.core</groupId>
@@ -38,7 +42,7 @@
     <dependency>
       <groupId>org.projectlombok</groupId>
       <artifactId>lombok</artifactId>
-      <version>1.18.30</version>
+      <version>${org.projectlombok.version}</version>
       <scope>provided</scope>
     </dependency>
     <dependency>
@@ -59,5 +63,43 @@
       <version>5.10.0</version>
       <scope>test</scope>
     </dependency>
+    <dependency>
+      <groupId>io.quarkus</groupId>
+      <artifactId>quarkus-smallrye-graphql</artifactId>
+    </dependency>
   </dependencies>
-</project>
+
+  <build>
+    <plugins>
+      <plugin>
+        <groupId>org.apache.maven.plugins</groupId>
+        <artifactId>maven-compiler-plugin</artifactId>
+        <version>3.13.0</version>
+        <configuration>
+          <parameters>true</parameters>
+          <annotationProcessorPaths>
+            <path>
+              <groupId>org.projectlombok</groupId>
+              <artifactId>lombok</artifactId>
+              <version>${org.projectlombok.version}</version>
+            </path>
+          </annotationProcessorPaths>
+        </configuration>
+      </plugin>
+
+      <plugin>
+        <groupId>io.smallrye</groupId>
+        <artifactId>jandex-maven-plugin</artifactId>
+        <version>3.2.7</version>
+        <executions>
+          <execution>
+            <id>make-index</id>
+            <goals>
+              <goal>jandex</goal>
+            </goals>
+          </execution>
+        </executions>
+      </plugin>
+    </plugins>
+  </build>
+</project>

lib/src/main/java/com/drinkool/Url.java

@@ -9,4 +9,5 @@ public class Url {
 	public static final String SmsOtp = "/sms_otp";
 	public static final String Me = "/me";
 	public static final String Logout = "/logout";
+	public static final String Review = "/review";
 }

lib/src/main/java/com/drinkool/dtos/SendReview.java

@@ -1,11 +0,0 @@
-package com.drinkool.dtos;
-
-import com.drinkool.lib.models.ReviewModel;
-import java.util.UUID;
-
-public class SendReview {
-
-	public UUID reviewerId;
-	public UUID orderId;
-	public ReviewModel review;
-}

lib/src/main/java/com/drinkool/enums/SortBy.java

@@ -0,0 +1,8 @@
+package com.drinkool.enums;
+
+public enum SortBy {
+	LATEST,
+	OLDEST,
+	HIGHEST,
+	LOWEST,
+}

lib/src/main/java/com/drinkool/interfaces/EateryInterface.java

@@ -0,0 +1,12 @@
+package com.drinkool.interfaces;
+
+import java.util.UUID;
+
+public interface EateryInterface {
+	UUID getOwnerId();
+	void setOwnerId(UUID x);
+	String getName();
+	void setName(String x);
+	boolean getIsVerified();
+	void setIsVerified(boolean x);
+}

lib/src/main/java/com/drinkool/interfaces/EntityInterface.java

@@ -0,0 +1,8 @@
+package com.drinkool.interfaces;
+
+import java.util.UUID;
+
+public interface EntityInterface {
+	UUID getId();
+	void setId(UUID x);
+}

lib/src/main/java/com/drinkool/interfaces/MenuItemInterface.java

@@ -0,0 +1,8 @@
+package com.drinkool.interfaces;
+
+public interface MenuItemInterface {
+	String getName();
+	void setName(String x);
+	Double getPrice();
+	void setPrice(Double x);
+}

lib/src/main/java/com/drinkool/interfaces/ReviewInterface.java

@@ -0,0 +1,17 @@
+package com.drinkool.interfaces;
+
+import java.util.UUID;
+
+public interface ReviewInterface {
+	UUID getReviewerId();
+	void setReviewerId(UUID x);
+
+	UUID getEateryId();
+	void setEateryId(UUID x);
+
+	Integer getRating();
+	void setRating(Integer x);
+
+	String getComment();
+	void setComment(String x);
+}

lib/src/main/java/com/drinkool/lib/dtos/AddInventory.java

@@ -1,4 +1,4 @@
-package com.drinkool.dtos;
+package com.drinkool.lib.dtos;
 
 public class AddInventory {
 

lib/src/main/java/com/drinkool/lib/dtos/GraphqlDto.java

@@ -1,4 +1,4 @@
-package com.drinkool.dtos;
+package com.drinkool.lib.dtos;
 
 public class GraphqlDto {
 

lib/src/main/java/com/drinkool/lib/dtos/Login.java

@@ -1,4 +1,4 @@
-package com.drinkool.dtos;
+package com.drinkool.lib.dtos;
 
 public class Login {
 

lib/src/main/java/com/drinkool/lib/dtos/ManagerSignup.java

@@ -1,4 +1,4 @@
-package com.drinkool.dtos;
+package com.drinkool.lib.dtos;
 
 public class ManagerSignup extends Signup {
 

lib/src/main/java/com/drinkool/lib/dtos/QuickLogin.java

@@ -1,4 +1,4 @@
-package com.drinkool.dtos;
+package com.drinkool.lib.dtos;
 
 public class QuickLogin {
 

lib/src/main/java/com/drinkool/lib/dtos/QuickSignup.java

@@ -1,4 +1,4 @@
-package com.drinkool.dtos;
+package com.drinkool.lib.dtos;
 
 public class QuickSignup {
 

lib/src/main/java/com/drinkool/lib/dtos/SendReview.java

@@ -0,0 +1,26 @@
+package com.drinkool.lib.dtos;
+
+import com.drinkool.interfaces.ReviewInterface;
+import io.quarkus.runtime.annotations.RegisterForReflection;
+import java.util.UUID;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+
+@Getter
+@Setter
+@NoArgsConstructor
+@AllArgsConstructor
+@RegisterForReflection
+public class SendReview implements ReviewInterface {
+
+	private UUID reviewerId;
+	private UUID eateryId;
+	private Integer rating;
+	private String comment;
+
+	public void setReviewerId(UUID x) {
+		return;
+	}
+}

lib/src/main/java/com/drinkool/lib/dtos/Signup.java

@@ -1,4 +1,4 @@
-package com.drinkool.dtos;
+package com.drinkool.lib.dtos;
 
 public class Signup {
 

lib/src/main/java/com/drinkool/lib/dtos/SmsOtp.java

@@ -1,4 +1,4 @@
-package com.drinkool.dtos;
+package com.drinkool.lib.dtos;
 
 public class SmsOtp {
 

lib/src/main/java/com/drinkool/lib/dtos/event/ManagerCreate.java

@@ -1,4 +1,4 @@
-package com.drinkool.dtos.event;
+package com.drinkool.lib.dtos.event;
 
 import io.quarkus.runtime.annotations.RegisterForReflection;
 import java.util.UUID;

lib/src/main/java/com/drinkool/lib/entities/BaseEntity.java

@@ -1,13 +1,24 @@
 package com.drinkool.lib.entities;
 
 import io.quarkus.hibernate.orm.panache.PanacheEntityBase;
-import jakarta.persistence.*;
+import jakarta.persistence.GeneratedValue;
+import jakarta.persistence.GenerationType;
+import jakarta.persistence.MappedSuperclass;
+import java.time.LocalDateTime;
 import java.util.UUID;
+import org.hibernate.annotations.CreationTimestamp;
+import org.hibernate.annotations.UpdateTimestamp;
 
 @MappedSuperclass
 public class BaseEntity extends PanacheEntityBase {
 
-	@Id
+	@jakarta.persistence.Id
 	@GeneratedValue(strategy = GenerationType.UUID)
 	public UUID id;
+
+	@CreationTimestamp
+	public LocalDateTime createDate;
+
+	@UpdateTimestamp
+	public LocalDateTime updateDate;
 }

lib/src/main/java/com/drinkool/lib/models/ReviewModel.java

@@ -1,30 +0,0 @@
-package com.drinkool.lib.models;
-
-import com.drinkool.lib.entities.BaseEntity;
-import jakarta.persistence.*;
-import java.time.LocalDateTime;
-
-@MappedSuperclass
-public class ReviewModel extends BaseEntity {
-
-	@Column
-	public int rating;
-
-	@Column
-	public String comment;
-
-	public ReviewModel(int rating, String comment) {
-		this.rating = rating;
-		this.comment = comment;
-	}
-
-	public ReviewModel() {}
-
-	public ReviewModel(ReviewModel input) {
-		this(input.rating, input.comment);
-	}
-
-	@org.hibernate.annotations.CreationTimestamp
-	@Column(name = "review_date", updatable = false)
-	public LocalDateTime reviewDate;
-}

lib/src/main/java/com/drinkool/lib/utils/BaseHeaderAuthentication.java

@@ -0,0 +1,40 @@
+package com.drinkool.lib.utils;
+
+import com.drinkool.InternalValue;
+import io.quarkus.security.identity.IdentityProviderManager;
+import io.quarkus.security.identity.SecurityIdentity;
+import io.quarkus.security.runtime.QuarkusSecurityIdentity;
+import io.quarkus.vertx.http.runtime.security.ChallengeData;
+import io.quarkus.vertx.http.runtime.security.HttpAuthenticationMechanism;
+import io.smallrye.mutiny.Uni;
+import io.vertx.ext.web.RoutingContext;
+
+public abstract class BaseHeaderAuthentication
+	implements HttpAuthenticationMechanism
+{
+
+	@Override
+	public Uni<SecurityIdentity> authenticate(
+		RoutingContext context,
+		IdentityProviderManager identityProviderManager
+	) {
+		String role = context.request().getHeader(InternalValue.role);
+		String userId = context.request().getHeader(InternalValue.userId);
+
+		if (role != null && !role.isEmpty()) {
+			return Uni.createFrom().item(
+				QuarkusSecurityIdentity.builder()
+					.setPrincipal(() -> userId)
+					.addRole(role)
+					.build()
+			);
+		}
+
+		return Uni.createFrom().nullItem();
+	}
+
+	@Override
+	public Uni<ChallengeData> getChallenge(RoutingContext context) {
+		return Uni.createFrom().nullItem();
+	}
+}

lib/src/main/java/com/drinkool/lib/utils/HeaderIdentityProvider.java

@@ -1,38 +0,0 @@
-package com.drinkool.lib.utils;
-
-import com.drinkool.InternalValue;
-import io.quarkus.security.identity.AuthenticationRequestContext;
-import io.quarkus.security.identity.IdentityProvider;
-import io.quarkus.security.identity.SecurityIdentity;
-import io.quarkus.security.identity.request.TrustedAuthenticationRequest;
-import io.quarkus.security.runtime.QuarkusSecurityIdentity;
-import io.smallrye.mutiny.Uni;
-import io.vertx.core.http.HttpServerRequest;
-import jakarta.enterprise.context.ApplicationScoped;
-import jakarta.inject.Inject;
-
-@ApplicationScoped
-public class HeaderIdentityProvider
-	implements IdentityProvider<TrustedAuthenticationRequest>
-{
-
-	@Inject
-	HttpServerRequest httpServerRequest;
-
-	@Override
-	public Class<TrustedAuthenticationRequest> getRequestType() {
-		return TrustedAuthenticationRequest.class;
-	}
-
-	@Override
-	public Uni<SecurityIdentity> authenticate(
-		TrustedAuthenticationRequest request,
-		AuthenticationRequestContext context
-	) {
-		String role = httpServerRequest.getHeader(InternalValue.role);
-
-		return Uni.createFrom().item(
-			QuarkusSecurityIdentity.builder().addRole(role).build()
-		);
-	}
-}

pom.xml

@@ -7,7 +7,7 @@
   <modelVersion>4.0.0</modelVersion>
   <groupId>com.drinkool</groupId>
   <artifactId>drinkool</artifactId>
-  <version>1.5.16</version>
+  <version>1.5.20</version>
   <packaging>pom</packaging>
   <properties>
     <maven.compiler.source>25</maven.compiler.source>

scripts/build.sh

@@ -1,3 +1,4 @@
 mvn clean package -DskipTests \
     -Dquarkus.container-image.push=false \
-    -Dquarkus.container-image.registry=git.demonkernel.io.vn 
+    -Dquarkus.container-image.registry=git.demonkernel.io.vn \
+    "$@"

scripts/publish.sh

@@ -5,7 +5,22 @@ SCRIPT_DIR=$(cd -- "$(dirname -- "${BASH_SOURCE[0]}")" &> /dev/null && pwd)
 
 cd "$SCRIPT_DIR/.."
 
-kubectl delete all --all -n drinkool-backend
-kubectl apply -f k8s -n drinkool-backend
+TARGET="k8s/base"
 
-cd "$CURRENT_DIR"
+for arg in "$@"; do
+    if [ "$arg" == "--dev" ]; then
+        TARGET="k8s/dev" 
+        echo "🔧 Chế độ DEV: Đang chuẩn bị chạy Kustomize để dọn dẹp resources..."
+        break
+    fi
+done
+
+echo "🧹 Đang dọn dẹp namespace drinkool-backend..."
+kubectl delete all --all -n drinkool-backend
+
+echo "🚀 Đang triển khai bằng Kustomize (-k) từ: $TARGET"
+kubectl apply -k "$TARGET" -n drinkool-backend
+
+# Quay lại thư mục ban đầu
+cd "$CURRENT_DIR"
+echo "✅ Hoàn thành!"

scripts/test.sh

@@ -1 +1,33 @@
-mvn clean package -Dquarkus.container-image.push=false -Dquarkus.container-image.build=false
+#!/bin/bash
+
+# Khởi tạo giá trị mặc định
+DEBUG_FLAG=""
+TEST_FLAG=""
+
+# Duyệt qua các tham số đầu vào
+for arg in "$@"; do
+  case $arg in
+    --debug)
+      DEBUG_FLAG="-Dmaven.surefire.debug"
+      shift # Bỏ qua flag này
+      ;;
+    --test=*)
+      # Lấy giá trị sau dấu =
+      TEST_NAME="${arg#*=}"
+      TEST_FLAG="-Dtest=$TEST_NAME"
+      shift
+      ;;
+    *)
+      # Các tham số không xác định (nếu cần xử lý thêm)
+      ;;
+  esac
+done
+
+echo "Running: mvn clean package $DEBUG_FLAG $TEST_FLAG"
+
+# Chạy lệnh Maven
+mvn clean package \
+    -Dquarkus.container-image.push=false \
+    -Dquarkus.container-image.build=false \
+    $DEBUG_FLAG \
+    $TEST_FLAG