File size: 1,815 Bytes
9853396 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 | package api
import (
"errors"
"net/http"
"github.com/gin-gonic/gin"
"go.uber.org/fx"
"github.com/looplj/axonhub/internal/objects"
"github.com/looplj/axonhub/internal/server/biz"
)
type AuthHandlersParams struct {
fx.In
AuthService *biz.AuthService
}
func NewAuthHandlers(params AuthHandlersParams) *AuthHandlers {
return &AuthHandlers{
AuthService: params.AuthService,
}
}
type AuthHandlers struct {
AuthService *biz.AuthService
}
// SignInRequest 登录请求.
type SignInRequest struct {
Email string `json:"email" binding:"required,email"`
Password string `json:"password" binding:"required"`
}
// SignInResponse 登录响应.
type SignInResponse struct {
User *objects.UserInfo `json:"user"`
Token string `json:"token"`
}
// SignIn handles user authentication.
func (h *AuthHandlers) SignIn(c *gin.Context) {
var (
ctx = c.Request.Context()
req SignInRequest
)
err := c.ShouldBindJSON(&req)
if err != nil {
JSONError(c, http.StatusBadRequest, errors.New("Invalid request format"))
return
}
// Authenticate user
user, err := h.AuthService.AuthenticateUser(ctx, req.Email, req.Password)
if err != nil {
if errors.Is(err, biz.ErrInvalidPassword) {
JSONError(c, http.StatusUnauthorized, errors.New("Invalid email or password"))
return
}
JSONError(c, http.StatusInternalServerError, errors.New("Internal server error"))
return
}
// Generate JWT token
token, err := h.AuthService.GenerateJWTToken(ctx, user)
if err != nil {
JSONError(c, http.StatusInternalServerError, errors.New("Internal server error"))
return
}
response := SignInResponse{
User: biz.ConvertUserToUserInfo(ctx, user),
Token: token,
}
c.JSON(http.StatusOK, response)
}
|