Update login handler

internal/app/api/auth/auth.go

@@ -5,6 +5,7 @@ import (
 	"time"
 
 	"github.com/golang-jwt/jwt/v5"
+	"github.com/voltgizerz/POS-restaurant/internal/app/entity"
 	"github.com/voltgizerz/POS-restaurant/internal/app/ports"
 )
 
@@ -18,11 +19,11 @@ func NewAuthJWT(secretKey string) ports.IAuth {
 	}
 }
 
-func (a *Auth) CreateToken(username string) (string, error) {
+func (a *Auth) CreateToken(user *entity.User) (string, error) {
 	token := jwt.NewWithClaims(jwt.SigningMethodHS256,
 		jwt.MapClaims{
-			"username": username,
-			"exp":      time.Now().Add(time.Hour * 24).Unix(),
+			"id":         user.ID,
+			"expired_at": time.Now().Add(time.Hour * 24).Unix(),
 		})
 
 	tokenString, err := token.SignedString(a.SecretKey)

internal/app/api/handler/request.go

@@ -0,0 +1,8 @@
+package handler
+
+type (
+	loginRequest struct {
+		Username string `json:"username"`
+		Password string `json:"password"`
+	}
+)

internal/app/api/handler/response.go

@@ -0,0 +1,37 @@
+package handler
+
+import "github.com/gofiber/fiber/v3"
+
+type (
+	errorResponse struct {
+		Code    int    `json:"code"`
+		Message string `json:"message"`
+	}
+
+	successResponse struct {
+		Code    int         `json:"code"`
+		Message string      `json:"message"`
+		Data    interface{} `json:"data"`
+	}
+)
+
+// sendErrorResponse generates and sends error response
+func sendErrorResponse(c fiber.Ctx, statusCode int, errorMessage string) error {
+	response := errorResponse{
+		Code:    statusCode,
+		Message: errorMessage,
+	}
+
+	return c.Status(statusCode).JSON(response)
+}
+
+// sendSuccessResponse generates and sends success response with dynamic data
+func sendSuccessResponse(c fiber.Ctx, statusCode int, message string, data interface{}) error {
+	response := successResponse{
+		Code:    statusCode,
+		Message: message,
+		Data:    data,
+	}
+
+	return c.Status(statusCode).JSON(response)
+}

internal/app/api/handler/user_handler.go

@@ -1,7 +1,10 @@
 package handler
 
 import (
+	"database/sql"
+
 	"github.com/gofiber/fiber/v3"
+	"github.com/opentracing/opentracing-go"
 	"github.com/voltgizerz/POS-restaurant/internal/app/interactor"
 	"github.com/voltgizerz/POS-restaurant/internal/app/ports"
 )
@@ -19,17 +22,42 @@ func NewUserHandler(i interactor.UserHandler) *UserHandler {
 }
 
 func (h *UserHandler) Login(c fiber.Ctx) error {
-	// TODO
+	span, ctx := opentracing.StartSpanFromContext(c.Context(), "handler.UserHandler.Login")
+	defer span.Finish()
+
+	req := &loginRequest{}
 
-	//  Hit db check user and password
+	err := c.Bind().Body(req)
+	if err != nil {
+		return sendErrorResponse(c, fiber.StatusBadRequest, "Invalid request body. Please provide both username and password.")
+	}
 
-	// success ?
-	// h.userService
+	// Check if the username and password are provided
+	if req.Username == "" || req.Password == "" {
+		return sendErrorResponse(c, fiber.StatusBadRequest, "Username and password are required.")
+	}
 
-	return nil
+	dataUser, err := h.userService.Login(ctx, req.Username, req.Password)
+	if err != nil {
+		if err == sql.ErrNoRows {
+			return sendErrorResponse(c, fiber.StatusUnauthorized, "Username not found.")
+		}
+
+		return sendErrorResponse(c, fiber.StatusUnauthorized, "Invalid username or password.")
+	}
+
+	token, err := h.authService.CreateToken(dataUser)
+	if err != nil {
+		return sendErrorResponse(c, fiber.StatusInternalServerError, "Failed create user token.")
+	}
+
+	return sendSuccessResponse(c, fiber.StatusOK, "Login successful.", token)
 }
 
 func (h *UserHandler) Register(c fiber.Ctx) error {
+	span, _ := opentracing.StartSpanFromContext(c.Context(), "handler.UserHandler.Register")
+	defer span.Finish()
+
 	// TODO
 	return nil
 }

internal/app/ports/auth_ports.go

@@ -1,6 +1,8 @@
 package ports
 
+import "github.com/voltgizerz/POS-restaurant/internal/app/entity"
+
 type IAuth interface {
-	CreateToken(username string) (string, error)
+	CreateToken(user *entity.User) (string, error)
 	VerifyToken(tokenString string) error
 }

internal/app/ports/user_ports.go

@@ -12,6 +12,7 @@ type IUserRepository interface {
 }
 
 type IUserService interface {
+	Login(ctx context.Context, username string, password string) (*entity.User, error)
 }
 
 type IUserHandler interface {

internal/app/repository/user_repository.go

@@ -10,7 +10,8 @@ import (
 )
 
 const (
-	queryLogin = "SELECT * FROM users WHERE username=$1 and hash_password=$2"
+	queryGetUserByUsernameAndPassword = `SELECT id, name, username, email, password_hashed, is_active, created_at, updated_at 
+		FROM users WHERE username=? AND password_hashed=?`
 )
 
 type UserRepository struct {
@@ -24,11 +25,11 @@ func NewUserRepository(opts RepositoryOpts) ports.IUserRepository {
 }
 
 func (r *UserRepository) GetUserByUsernameAndPassword(ctx context.Context, username string, hashPassword string) (*entity.UserORM, error) {
-	span, _ := opentracing.StartSpanFromContext(ctx, "repo.UserRepository.GetUserByUsernameAndPassword")
+	span, ctx := opentracing.StartSpanFromContext(ctx, "repo.UserRepository.GetUserByUsernameAndPassword")
 	defer span.Finish()
 
 	user := entity.UserORM{}
-	err := r.MasterDB.Get(&user, queryLogin, username, hashPassword)
+	err := r.MasterDB.GetContext(ctx, &user, queryGetUserByUsernameAndPassword, username, hashPassword)
 	if err != nil {
 		return nil, err
 	}