package v1 import ( "errors" "net/http" "strconv" "strings" "time" "github.com/hay-kot/homebox/backend/internal/core/services" "github.com/hay-kot/homebox/backend/internal/sys/validate" "github.com/hay-kot/httpkit/errchain" "github.com/hay-kot/httpkit/server" "github.com/rs/zerolog/log" ) const ( cookieNameToken = "hb.auth.token" cookieNameRemember = "hb.auth.remember" cookieNameSession = "hb.auth.session" ) type ( TokenResponse struct { Token string `json:"token"` ExpiresAt time.Time `json:"expiresAt"` AttachmentToken string `json:"attachmentToken"` } LoginForm struct { Username string `json:"username"` Password string `json:"password"` StayLoggedIn bool `json:"stayLoggedIn"` } ) type CookieContents struct { Token string ExpiresAt time.Time Remember bool } func GetCookies(r *http.Request) (*CookieContents, error) { cookie, err := r.Cookie(cookieNameToken) if err != nil { return nil, errors.New("authorization cookie is required") } rememberCookie, err := r.Cookie(cookieNameRemember) if err != nil { return nil, errors.New("remember cookie is required") } return &CookieContents{ Token: cookie.Value, ExpiresAt: cookie.Expires, Remember: rememberCookie.Value == "true", }, nil } // HandleAuthLogin godoc // // @Summary User Login // @Tags Authentication // @Accept x-www-form-urlencoded // @Accept application/json // @Param username formData string false "string" example(admin@admin.com) // @Param password formData string false "string" example(admin) // @Param payload body LoginForm true "Login Data" // @Produce json // @Success 200 {object} TokenResponse // @Router /v1/users/login [POST] func (ctrl *V1Controller) HandleAuthLogin() errchain.HandlerFunc { return func(w http.ResponseWriter, r *http.Request) error { loginForm := &LoginForm{} switch r.Header.Get("Content-Type") { case "application/x-www-form-urlencoded": err := r.ParseForm() if err != nil { return errors.New("failed to parse form") } loginForm.Username = r.PostFormValue("username") loginForm.Password = r.PostFormValue("password") loginForm.StayLoggedIn = r.PostFormValue("stayLoggedIn") == "true" case "application/json": err := server.Decode(r, loginForm) if err != nil { log.Err(err).Msg("failed to decode login form") return errors.New("failed to decode login form") } default: return server.JSON(w, http.StatusBadRequest, errors.New("invalid content type")) } if loginForm.Username == "" || loginForm.Password == "" { return validate.NewFieldErrors( validate.FieldError{ Field: "username", Error: "username or password is empty", }, validate.FieldError{ Field: "password", Error: "username or password is empty", }, ) } newToken, err := ctrl.svc.User.Login(r.Context(), strings.ToLower(loginForm.Username), loginForm.Password, loginForm.StayLoggedIn) if err != nil { return validate.NewRequestError(errors.New("authentication failed"), http.StatusInternalServerError) } ctrl.setCookies(w, noPort(r.Host), newToken.Raw, newToken.ExpiresAt, loginForm.StayLoggedIn) return server.JSON(w, http.StatusOK, TokenResponse{ Token: "Bearer " + newToken.Raw, ExpiresAt: newToken.ExpiresAt, AttachmentToken: newToken.AttachmentToken, }) } } // HandleAuthLogout godoc // // @Summary User Logout // @Tags Authentication // @Success 204 // @Router /v1/users/logout [POST] // @Security Bearer func (ctrl *V1Controller) HandleAuthLogout() errchain.HandlerFunc { return func(w http.ResponseWriter, r *http.Request) error { token := services.UseTokenCtx(r.Context()) if token == "" { return validate.NewRequestError(errors.New("no token within request context"), http.StatusUnauthorized) } err := ctrl.svc.User.Logout(r.Context(), token) if err != nil { return validate.NewRequestError(err, http.StatusInternalServerError) } ctrl.unsetCookies(w, noPort(r.Host)) return server.JSON(w, http.StatusNoContent, nil) } } // HandleAuthLogout godoc // // @Summary User Token Refresh // @Description handleAuthRefresh returns a handler that will issue a new token from an existing token. // @Description This does not validate that the user still exists within the database. // @Tags Authentication // @Success 200 // @Router /v1/users/refresh [GET] // @Security Bearer func (ctrl *V1Controller) HandleAuthRefresh() errchain.HandlerFunc { return func(w http.ResponseWriter, r *http.Request) error { requestToken := services.UseTokenCtx(r.Context()) if requestToken == "" { return validate.NewRequestError(errors.New("no token within request context"), http.StatusUnauthorized) } newToken, err := ctrl.svc.User.RenewToken(r.Context(), requestToken) if err != nil { return validate.NewUnauthorizedError() } ctrl.setCookies(w, noPort(r.Host), newToken.Raw, newToken.ExpiresAt, false) return server.JSON(w, http.StatusOK, newToken) } } func noPort(host string) string { return strings.Split(host, ":")[0] } func (ctrl *V1Controller) setCookies(w http.ResponseWriter, domain, token string, expires time.Time, remember bool) { http.SetCookie(w, &http.Cookie{ Name: cookieNameRemember, Value: strconv.FormatBool(remember), Expires: expires, Domain: domain, Secure: ctrl.cookieSecure, HttpOnly: true, Path: "/", }) // Set HTTP only cookie http.SetCookie(w, &http.Cookie{ Name: cookieNameToken, Value: token, Expires: expires, Domain: domain, Secure: ctrl.cookieSecure, HttpOnly: true, Path: "/", }) // Set Fake Session cookie http.SetCookie(w, &http.Cookie{ Name: cookieNameSession, Value: "true", Expires: expires, Domain: domain, Secure: ctrl.cookieSecure, HttpOnly: false, Path: "/", }) } func (ctrl *V1Controller) unsetCookies(w http.ResponseWriter, domain string) { http.SetCookie(w, &http.Cookie{ Name: cookieNameToken, Value: "", Expires: time.Unix(0, 0), Domain: domain, Secure: ctrl.cookieSecure, HttpOnly: true, Path: "/", }) http.SetCookie(w, &http.Cookie{ Name: cookieNameRemember, Value: "false", Expires: time.Unix(0, 0), Domain: domain, Secure: ctrl.cookieSecure, HttpOnly: true, Path: "/", }) // Set Fake Session cookie http.SetCookie(w, &http.Cookie{ Name: cookieNameSession, Value: "false", Expires: time.Unix(0, 0), Domain: domain, Secure: ctrl.cookieSecure, HttpOnly: false, Path: "/", }) }