backend/account-service/src/main/java/com/drinkool/RestAPI.java

package com.drinkool;

import com.drinkool.dtos.*;
import com.drinkool.models.Customer;
import com.drinkool.services.*;
import jakarta.inject.Inject;
import jakarta.transaction.Transactional;
import jakarta.ws.rs.*;
import jakarta.ws.rs.core.*;

@Path("/api")
public class RestAPI {

	@Inject
	OtpService otpService;

	@POST
	@Path("/signup")
	@Transactional
	public Response signup(Signup input) {
		Customer newCustomer = new Customer();

		newCustomer.signup(input.name, input.phone, input.password);

		return Response.status(Response.Status.CREATED).build();
	}

	@POST
	@Path("/quickSignup")
	@Transactional
	public Response quickSignup(QuickSignup input) {
		Customer newCustomer = new Customer();

		newCustomer.signup(input.phone);

		return Response.status(Response.Status.CREATED).build();
	}

	@POST
	@Path("/login")
	public Response login(Login input) {
		Customer customer = Customer.find("phone", input.phone).firstResult();

		if (customer == null) throw new BadRequestException("InvalidPhoneNumber");

		if (!customer.login(input.password)) throw new BadRequestException(
			"InvalidPassword"
		);

		return Response.accepted().build();
	}

	@POST
	@Path("/sms_otp")
	public Response smsOtp(SmsOtp input) {
		String otp = otpService.generateAndSaveOtp(input.phone);

		// Ở đây bạn sẽ gọi Kafka để gửi SMS thực tế
		System.out.println("OTP cho " + input.phone + " là: " + otp);

		return Response.accepted().build();
	}

	@POST
	@Path("/quicklogin")
	public Response quickLogin(QuickLogin input) {
		if (otpService.verifyOtp(input.phone, input.otp)) {
			return Response.accepted().build();
		}
		return Response.status(Response.Status.UNAUTHORIZED)
			.entity("InvalidOTP")
			.build();
	}
}