feat: update some errorhandling #161
This commit is contained in:
14
handler.go
14
handler.go
@@ -13,6 +13,10 @@ import (
|
|||||||
func getHandler(db *sql.DB) http.Handler {
|
func getHandler(db *sql.DB) http.Handler {
|
||||||
var router = http.NewServeMux()
|
var router = http.NewServeMux()
|
||||||
|
|
||||||
|
if utils.Environment == "dev" {
|
||||||
|
router.HandleFunc("/mail/", handleMails)
|
||||||
|
}
|
||||||
|
|
||||||
router.HandleFunc("/", service.HandleIndexAnd404(db))
|
router.HandleFunc("/", service.HandleIndexAnd404(db))
|
||||||
|
|
||||||
// Serve static files (CSS, JS and images)
|
// Serve static files (CSS, JS and images)
|
||||||
@@ -33,11 +37,11 @@ func getHandler(db *sql.DB) http.Handler {
|
|||||||
router.Handle("/api/auth/signout", service.HandleSignOutComp(db))
|
router.Handle("/api/auth/signout", service.HandleSignOutComp(db))
|
||||||
router.Handle("/api/auth/verify-resend", service.HandleVerifyResendComp(db))
|
router.Handle("/api/auth/verify-resend", service.HandleVerifyResendComp(db))
|
||||||
|
|
||||||
if utils.Environment == "dev" {
|
return middleware.Logging(middleware.EnableCors(router))
|
||||||
router.HandleFunc("/mail/", handleMails)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
return middleware.Logging(middleware.EnableCors(router))
|
func auth(db *sql.DB, h http.Handler) http.Handler {
|
||||||
|
return middleware.EnsureValidSession(db, h)
|
||||||
}
|
}
|
||||||
|
|
||||||
func handleMails(w http.ResponseWriter, r *http.Request) {
|
func handleMails(w http.ResponseWriter, r *http.Request) {
|
||||||
@@ -45,7 +49,3 @@ func handleMails(w http.ResponseWriter, r *http.Request) {
|
|||||||
mail.Register("test-code").Render(r.Context(), w)
|
mail.Register("test-code").Render(r.Context(), w)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func auth(db *sql.DB, h http.Handler) http.Handler {
|
|
||||||
return middleware.EnsureValidSession(db, h)
|
|
||||||
}
|
|
||||||
|
|||||||
@@ -22,7 +22,7 @@ func EnsureValidSession(db *sql.DB, next http.Handler) http.Handler {
|
|||||||
// }
|
// }
|
||||||
|
|
||||||
user := utils.GetUserFromSession(db, r)
|
user := utils.GetUserFromSession(db, r)
|
||||||
if user == nil || !user.SessionValid {
|
if user == nil {
|
||||||
utils.DoRedirect(w, r, "/auth/signin")
|
utils.DoRedirect(w, r, "/auth/signin")
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
@@ -45,7 +45,7 @@ func EnsureValidSession(db *sql.DB, next http.Handler) http.Handler {
|
|||||||
//
|
//
|
||||||
// sessionId := getSessionID(r)
|
// sessionId := getSessionID(r)
|
||||||
// user := verifySession(db, sessionId)
|
// user := verifySession(db, sessionId)
|
||||||
// if user == nil || !user.SessionValid {
|
// if user == nil {
|
||||||
// return true, false
|
// return true, false
|
||||||
// }
|
// }
|
||||||
//
|
//
|
||||||
|
|||||||
@@ -24,17 +24,21 @@ import (
|
|||||||
func HandleSignInPage(db *sql.DB) http.HandlerFunc {
|
func HandleSignInPage(db *sql.DB) http.HandlerFunc {
|
||||||
return func(w http.ResponseWriter, r *http.Request) {
|
return func(w http.ResponseWriter, r *http.Request) {
|
||||||
user := utils.GetUserFromSession(db, r)
|
user := utils.GetUserFromSession(db, r)
|
||||||
if user == nil || !user.SessionValid {
|
|
||||||
|
if user == nil {
|
||||||
userComp := UserInfoComp(nil)
|
userComp := UserInfoComp(nil)
|
||||||
signIn := auth.SignInOrUpComp(true)
|
signIn := auth.SignInOrUpComp(true)
|
||||||
template.Layout(signIn, userComp).Render(r.Context(), w)
|
err := template.Layout(signIn, userComp).Render(r.Context(), w)
|
||||||
return
|
|
||||||
|
if err != nil {
|
||||||
|
utils.LogError("Failed to render sign in page", err)
|
||||||
|
http.Error(w, "Internal Server Error", http.StatusInternalServerError)
|
||||||
|
}
|
||||||
|
|
||||||
} else if !user.EmailVerified {
|
} else if !user.EmailVerified {
|
||||||
utils.DoRedirect(w, r, "/auth/verify")
|
utils.DoRedirect(w, r, "/auth/verify")
|
||||||
return
|
|
||||||
} else {
|
} else {
|
||||||
utils.DoRedirect(w, r, "/")
|
utils.DoRedirect(w, r, "/")
|
||||||
return
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -42,17 +46,21 @@ func HandleSignInPage(db *sql.DB) http.HandlerFunc {
|
|||||||
func HandleSignUpPage(db *sql.DB) http.HandlerFunc {
|
func HandleSignUpPage(db *sql.DB) http.HandlerFunc {
|
||||||
return func(w http.ResponseWriter, r *http.Request) {
|
return func(w http.ResponseWriter, r *http.Request) {
|
||||||
user := utils.GetUserFromSession(db, r)
|
user := utils.GetUserFromSession(db, r)
|
||||||
if user == nil || !user.SessionValid {
|
|
||||||
|
if user == nil {
|
||||||
userComp := UserInfoComp(nil)
|
userComp := UserInfoComp(nil)
|
||||||
signUpComp := auth.SignInOrUpComp(false)
|
signUpComp := auth.SignInOrUpComp(false)
|
||||||
template.Layout(signUpComp, userComp).Render(r.Context(), w)
|
err := template.Layout(signUpComp, userComp).Render(r.Context(), w)
|
||||||
return
|
|
||||||
|
if err != nil {
|
||||||
|
utils.LogError("Failed to render sign up page", err)
|
||||||
|
http.Error(w, "Internal Server Error", http.StatusInternalServerError)
|
||||||
|
}
|
||||||
|
|
||||||
} else if !user.EmailVerified {
|
} else if !user.EmailVerified {
|
||||||
utils.DoRedirect(w, r, "/auth/verify")
|
utils.DoRedirect(w, r, "/auth/verify")
|
||||||
return
|
|
||||||
} else {
|
} else {
|
||||||
utils.DoRedirect(w, r, "/")
|
utils.DoRedirect(w, r, "/")
|
||||||
return
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -60,17 +68,18 @@ func HandleSignUpPage(db *sql.DB) http.HandlerFunc {
|
|||||||
func HandleSignUpVerifyPage(db *sql.DB) http.HandlerFunc {
|
func HandleSignUpVerifyPage(db *sql.DB) http.HandlerFunc {
|
||||||
return func(w http.ResponseWriter, r *http.Request) {
|
return func(w http.ResponseWriter, r *http.Request) {
|
||||||
user := utils.GetUserFromSession(db, r)
|
user := utils.GetUserFromSession(db, r)
|
||||||
if user == nil || !user.SessionValid {
|
if user == nil {
|
||||||
utils.DoRedirect(w, r, "/auth/signin")
|
utils.DoRedirect(w, r, "/auth/signin")
|
||||||
return
|
} else if user.EmailVerified {
|
||||||
}
|
|
||||||
if user.EmailVerified {
|
|
||||||
utils.DoRedirect(w, r, "/")
|
utils.DoRedirect(w, r, "/")
|
||||||
return
|
|
||||||
} else {
|
} else {
|
||||||
userComp := UserInfoComp(user)
|
userComp := UserInfoComp(user)
|
||||||
signIn := auth.VerifyComp()
|
signIn := auth.VerifyComp()
|
||||||
template.Layout(signIn, userComp).Render(r.Context(), w)
|
err := template.Layout(signIn, userComp).Render(r.Context(), w)
|
||||||
|
if err != nil {
|
||||||
|
utils.LogError("Failed to render verify page", err)
|
||||||
|
http.Error(w, "Internal Server Error", http.StatusInternalServerError)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -95,12 +104,15 @@ func HandleSignUpVerifyResponsePage(db *sql.DB) http.HandlerFunc {
|
|||||||
`, token)
|
`, token)
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
utils.LogError("Could not update user", err)
|
utils.LogError("Could not update user on verify response", err)
|
||||||
|
http.Error(w, "Internal Server Error", http.StatusInternalServerError)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
i, err := result.RowsAffected()
|
i, err := result.RowsAffected()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
utils.LogError("Could not get rows affected", err)
|
utils.LogError("Could not get rows affected on verify response", err)
|
||||||
|
http.Error(w, "Internal Server Error", http.StatusInternalServerError)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -170,8 +182,8 @@ func HandleSignUpComp(db *sql.DB) http.HandlerFunc {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
auth.Error("Internal Server Error").Render(r.Context(), w)
|
|
||||||
utils.LogError("Could not insert user", err)
|
utils.LogError("Could not insert user", err)
|
||||||
|
auth.Error("Internal Server Error").Render(r.Context(), w)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -249,7 +261,8 @@ func HandleSignOutComp(db *sql.DB) http.HandlerFunc {
|
|||||||
if user != nil {
|
if user != nil {
|
||||||
_, err := db.Exec("DELETE FROM session WHERE session_id = ?", user.SessionId)
|
_, err := db.Exec("DELETE FROM session WHERE session_id = ?", user.SessionId)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
utils.LogError("Could not delete session%v", err)
|
utils.LogError("Could not delete session", err)
|
||||||
|
utils.TriggerToast(w, r, "error", "Internal Server Error")
|
||||||
http.Error(w, err.Error(), http.StatusInternalServerError)
|
http.Error(w, err.Error(), http.StatusInternalServerError)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
@@ -266,19 +279,19 @@ func HandleSignOutComp(db *sql.DB) http.HandlerFunc {
|
|||||||
}
|
}
|
||||||
|
|
||||||
http.SetCookie(w, &c)
|
http.SetCookie(w, &c)
|
||||||
w.Header().Add("HX-Redirect", "/")
|
utils.DoRedirect(w, r, "/")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func HandleVerifyResendComp(db *sql.DB) http.HandlerFunc {
|
func HandleVerifyResendComp(db *sql.DB) http.HandlerFunc {
|
||||||
return func(w http.ResponseWriter, r *http.Request) {
|
return func(w http.ResponseWriter, r *http.Request) {
|
||||||
user := utils.GetUserFromSession(db, r)
|
user := utils.GetUserFromSession(db, r)
|
||||||
if user == nil || !user.SessionValid || user.EmailVerified {
|
if user == nil || user.EmailVerified {
|
||||||
utils.DoRedirect(w, r, "/auth/signin")
|
utils.DoRedirect(w, r, "/auth/signin")
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
sendVerificationEmail(db, r, user.Id.String(), user.Email)
|
go sendVerificationEmail(db, r, user.Id.String(), user.Email)
|
||||||
|
|
||||||
w.Write([]byte("<p class=\"mt-8\">Verification email sent</p>"))
|
w.Write([]byte("<p class=\"mt-8\">Verification email sent</p>"))
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -23,6 +23,10 @@ func HandleIndexAnd404(db *sql.DB) http.HandlerFunc {
|
|||||||
comp = template.Layout(template.Index(), userComp)
|
comp = template.Layout(template.Index(), userComp)
|
||||||
}
|
}
|
||||||
|
|
||||||
comp.Render(r.Context(), w)
|
err := comp.Render(r.Context(), w)
|
||||||
|
if err != nil {
|
||||||
|
utils.LogError("Failed to render index", err)
|
||||||
|
http.Error(w, "Failed to render index", http.StatusInternalServerError)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,6 +1,7 @@
|
|||||||
package service
|
package service
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"log/slog"
|
||||||
"me-fit/template"
|
"me-fit/template"
|
||||||
"me-fit/template/workout"
|
"me-fit/template/workout"
|
||||||
"me-fit/utils"
|
"me-fit/utils"
|
||||||
@@ -22,7 +23,11 @@ func HandleWorkoutPage(db *sql.DB) http.HandlerFunc {
|
|||||||
currentDate := time.Now().Format("2006-01-02")
|
currentDate := time.Now().Format("2006-01-02")
|
||||||
inner := workout.WorkoutComp(currentDate)
|
inner := workout.WorkoutComp(currentDate)
|
||||||
userComp := UserInfoComp(user)
|
userComp := UserInfoComp(user)
|
||||||
template.Layout(inner, userComp).Render(r.Context(), w)
|
err := template.Layout(inner, userComp).Render(r.Context(), w)
|
||||||
|
if err != nil {
|
||||||
|
utils.LogError("Failed to render workout page", err)
|
||||||
|
http.Error(w, "Internal Server Error", http.StatusInternalServerError)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -40,24 +45,26 @@ func HandleWorkoutNewComp(db *sql.DB) http.HandlerFunc {
|
|||||||
var repsStr = r.FormValue("reps")
|
var repsStr = r.FormValue("reps")
|
||||||
|
|
||||||
if dateStr == "" || typeStr == "" || setsStr == "" || repsStr == "" {
|
if dateStr == "" || typeStr == "" || setsStr == "" || repsStr == "" {
|
||||||
|
utils.TriggerToast(w, r, "error", "Missing required fields")
|
||||||
http.Error(w, "Missing required fields", http.StatusBadRequest)
|
http.Error(w, "Missing required fields", http.StatusBadRequest)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
date, err := time.Parse("2006-01-02", dateStr)
|
date, err := time.Parse("2006-01-02", dateStr)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
utils.TriggerToast(w, r, "error", "Invalid date")
|
||||||
http.Error(w, err.Error(), http.StatusBadRequest)
|
http.Error(w, err.Error(), http.StatusBadRequest)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
sets, err := strconv.Atoi(setsStr)
|
sets, err := strconv.Atoi(setsStr)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
utils.TriggerToast(w, r, "error", "Invalid number")
|
||||||
http.Error(w, err.Error(), http.StatusBadRequest)
|
http.Error(w, err.Error(), http.StatusBadRequest)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
reps, err := strconv.Atoi(repsStr)
|
reps, err := strconv.Atoi(repsStr)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
utils.TriggerToast(w, r, "error", "Invalid number")
|
||||||
http.Error(w, err.Error(), http.StatusBadRequest)
|
http.Error(w, err.Error(), http.StatusBadRequest)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
@@ -66,9 +73,11 @@ func HandleWorkoutNewComp(db *sql.DB) http.HandlerFunc {
|
|||||||
err = db.QueryRow("INSERT INTO workout (user_id, date, type, sets, reps) VALUES (?, ?, ?, ?, ?) RETURNING rowid", user.Id, date, typeStr, sets, reps).Scan(&rowId)
|
err = db.QueryRow("INSERT INTO workout (user_id, date, type, sets, reps) VALUES (?, ?, ?, ?, ?) RETURNING rowid", user.Id, date, typeStr, sets, reps).Scan(&rowId)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
utils.LogError("Could not insert workout", err)
|
utils.LogError("Could not insert workout", err)
|
||||||
|
utils.TriggerToast(w, r, "error", "Internal Server Error")
|
||||||
http.Error(w, err.Error(), http.StatusInternalServerError)
|
http.Error(w, err.Error(), http.StatusInternalServerError)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
wo := workout.Workout{
|
wo := workout.Workout{
|
||||||
Id: strconv.Itoa(rowId),
|
Id: strconv.Itoa(rowId),
|
||||||
Date: renderDate(date),
|
Date: renderDate(date),
|
||||||
@@ -77,8 +86,12 @@ func HandleWorkoutNewComp(db *sql.DB) http.HandlerFunc {
|
|||||||
Reps: r.FormValue("reps"),
|
Reps: r.FormValue("reps"),
|
||||||
}
|
}
|
||||||
|
|
||||||
w.Header().Set("HX-Trigger", `{"toast": "none|Workout added"}`)
|
err = workout.WorkoutItemComp(wo, true).Render(r.Context(), w)
|
||||||
workout.WorkoutItemComp(wo, true).Render(r.Context(), w)
|
if err != nil {
|
||||||
|
utils.LogError("Could not render workoutitem", err)
|
||||||
|
utils.TriggerToast(w, r, "error", "Internal Server Error")
|
||||||
|
http.Error(w, err.Error(), http.StatusInternalServerError)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -92,6 +105,8 @@ func HandleWorkoutGetComp(db *sql.DB) http.HandlerFunc {
|
|||||||
|
|
||||||
rows, err := db.Query("SELECT rowid, date, type, sets, reps FROM workout WHERE user_id = ? ORDER BY date desc", user.Id)
|
rows, err := db.Query("SELECT rowid, date, type, sets, reps FROM workout WHERE user_id = ? ORDER BY date desc", user.Id)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
utils.LogError("Could not get workouts", err)
|
||||||
|
utils.TriggerToast(w, r, "error", "Internal Server Error")
|
||||||
http.Error(w, err.Error(), http.StatusInternalServerError)
|
http.Error(w, err.Error(), http.StatusInternalServerError)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
@@ -102,12 +117,16 @@ func HandleWorkoutGetComp(db *sql.DB) http.HandlerFunc {
|
|||||||
|
|
||||||
err = rows.Scan(&workout.Id, &workout.Date, &workout.Type, &workout.Sets, &workout.Reps)
|
err = rows.Scan(&workout.Id, &workout.Date, &workout.Type, &workout.Sets, &workout.Reps)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
utils.LogError("Could not scan workout", err)
|
||||||
|
utils.TriggerToast(w, r, "error", "Internal Server Error")
|
||||||
http.Error(w, err.Error(), http.StatusInternalServerError)
|
http.Error(w, err.Error(), http.StatusInternalServerError)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
workout.Date, err = renderDateStr(workout.Date)
|
workout.Date, err = renderDateStr(workout.Date)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
utils.LogError("Could not render date", err)
|
||||||
|
utils.TriggerToast(w, r, "error", "Internal Server Error")
|
||||||
http.Error(w, err.Error(), http.StatusInternalServerError)
|
http.Error(w, err.Error(), http.StatusInternalServerError)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
@@ -130,23 +149,31 @@ func HandleWorkoutDeleteComp(db *sql.DB) http.HandlerFunc {
|
|||||||
rowId := r.PathValue("id")
|
rowId := r.PathValue("id")
|
||||||
if rowId == "" {
|
if rowId == "" {
|
||||||
http.Error(w, "Missing required fields", http.StatusBadRequest)
|
http.Error(w, "Missing required fields", http.StatusBadRequest)
|
||||||
|
slog.Warn("Missing required fields for workout delete")
|
||||||
|
utils.TriggerToast(w, r, "error", "Missing ID field")
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
res, err := db.Exec("DELETE FROM workout WHERE user_id = ? AND rowid = ?", user.Id, rowId)
|
res, err := db.Exec("DELETE FROM workout WHERE user_id = ? AND rowid = ?", user.Id, rowId)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
http.Error(w, err.Error(), http.StatusInternalServerError)
|
http.Error(w, err.Error(), http.StatusInternalServerError)
|
||||||
|
utils.LogError("Could not delete workout", err)
|
||||||
|
utils.TriggerToast(w, r, "error", "Internal Server Error")
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
rows, err := res.RowsAffected()
|
rows, err := res.RowsAffected()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
http.Error(w, err.Error(), http.StatusInternalServerError)
|
http.Error(w, err.Error(), http.StatusInternalServerError)
|
||||||
|
utils.LogError("Could not get rows affected", err)
|
||||||
|
utils.TriggerToast(w, r, "error", "Internal Server Error")
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
if rows == 0 {
|
if rows == 0 {
|
||||||
http.Error(w, "Not found", http.StatusNotFound)
|
http.Error(w, "Not found", http.StatusNotFound)
|
||||||
|
slog.Warn("Could not find workout to delete")
|
||||||
|
utils.TriggerToast(w, r, "error", "Not found. Refresh the page.")
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -7,5 +7,4 @@ type User struct {
|
|||||||
Email string
|
Email string
|
||||||
SessionId string
|
SessionId string
|
||||||
EmailVerified bool
|
EmailVerified bool
|
||||||
SessionValid bool
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -2,6 +2,7 @@ package utils
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"database/sql"
|
"database/sql"
|
||||||
|
"fmt"
|
||||||
"log/slog"
|
"log/slog"
|
||||||
"me-fit/types"
|
"me-fit/types"
|
||||||
"net/http"
|
"net/http"
|
||||||
@@ -35,9 +36,16 @@ func LogErrorMsg(message string) {
|
|||||||
errorMetric.Inc()
|
errorMetric.Inc()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func TriggerToast(w http.ResponseWriter, r *http.Request, class string, message string) {
|
||||||
|
if isHtmx(r) {
|
||||||
|
w.Header().Set("HX-Trigger", fmt.Sprintf(`{"toast": "%v|%v"}`, class, message))
|
||||||
|
} else {
|
||||||
|
LogErrorMsg("Trying to trigger toast in non-HTMX request")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
func DoRedirect(w http.ResponseWriter, r *http.Request, url string) {
|
func DoRedirect(w http.ResponseWriter, r *http.Request, url string) {
|
||||||
isHtmx := r.Header.Get("HX-Request") == "true"
|
if isHtmx(r) {
|
||||||
if isHtmx {
|
|
||||||
w.Header().Add("HX-Redirect", url)
|
w.Header().Add("HX-Redirect", url)
|
||||||
} else {
|
} else {
|
||||||
http.Redirect(w, r, url, http.StatusSeeOther)
|
http.Redirect(w, r, url, http.StatusSeeOther)
|
||||||
@@ -75,12 +83,11 @@ func GetUserFromSession(db *sql.DB, r *http.Request) *types.User {
|
|||||||
}
|
}
|
||||||
|
|
||||||
if createdAt.Add(time.Duration(8 * time.Hour)).Before(time.Now()) {
|
if createdAt.Add(time.Duration(8 * time.Hour)).Before(time.Now()) {
|
||||||
user.SessionValid = false
|
return nil
|
||||||
} else {
|
} else {
|
||||||
user.SessionValid = true
|
return &user
|
||||||
}
|
}
|
||||||
|
|
||||||
return &user
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func getSessionID(r *http.Request) string {
|
func getSessionID(r *http.Request) string {
|
||||||
@@ -91,3 +98,7 @@ func getSessionID(r *http.Request) string {
|
|||||||
}
|
}
|
||||||
return ""
|
return ""
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func isHtmx(r *http.Request) bool {
|
||||||
|
return r.Header.Get("HX-Request") == "true"
|
||||||
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user