package routes import ( "fmt" "strings" "dk/internal/auth" "dk/internal/csrf" "dk/internal/middleware" "dk/internal/password" "dk/internal/router" "dk/internal/template" "dk/internal/template/components" "dk/internal/users" "github.com/valyala/fasthttp" ) // RegisterAuthRoutes sets up authentication routes func RegisterAuthRoutes(r *router.Router) { // Guest routes guestGroup := r.Group("") guestGroup.Use(middleware.RequireGuest()) guestGroup.Get("/login", showLogin) guestGroup.Post("/login", processLogin) guestGroup.Get("/register", showRegister) guestGroup.Post("/register", processRegister) // Authenticated routes authGroup := r.Group("") authGroup.Use(middleware.RequireAuth()) authGroup.Post("/logout", processLogout) } // showLogin displays the login form func showLogin(ctx router.Ctx, _ []string) { components.RenderPageTemplate(ctx, "Log In", "auth/login.html", map[string]any{ "csrf_token": csrf.GetToken(ctx, auth.Manager), "csrf_field": csrf.HiddenField(ctx, auth.Manager), "error_message": "", }) } // processLogin handles login form submission func processLogin(ctx router.Ctx, _ []string) { if !csrf.ValidateFormToken(ctx, auth.Manager) { ctx.SetStatusCode(fasthttp.StatusForbidden) ctx.WriteString("CSRF validation failed") return } email := strings.TrimSpace(string(ctx.PostArgs().Peek("email"))) userPassword := string(ctx.PostArgs().Peek("password")) if email == "" || userPassword == "" { showLoginError(ctx, "Email and password are required") return } user, err := auth.Manager.Authenticate(email, userPassword) if err != nil { showLoginError(ctx, "Invalid email or password") return } middleware.Login(ctx, auth.Manager, user) // Transfer CSRF token from cookie to session for authenticated user if cookieToken := csrf.GetTokenFromCookie(ctx); cookieToken != "" { if session := csrf.GetCurrentSession(ctx); session != nil { csrf.StoreToken(session, cookieToken) } } ctx.Redirect("/", fasthttp.StatusFound) } // showRegister displays the registration form func showRegister(ctx router.Ctx, _ []string) { components.RenderPageTemplate(ctx, "Register", "auth/register.html", map[string]any{ "csrf_token": csrf.GetToken(ctx, auth.Manager), "csrf_field": csrf.HiddenField(ctx, auth.Manager), "error_message": "", "username": "", "email": "", }) } // processRegister handles registration form submission func processRegister(ctx router.Ctx, _ []string) { if !csrf.ValidateFormToken(ctx, auth.Manager) { ctx.SetStatusCode(fasthttp.StatusForbidden) ctx.WriteString("CSRF validation failed") return } username := strings.TrimSpace(string(ctx.PostArgs().Peek("username"))) email := strings.TrimSpace(string(ctx.PostArgs().Peek("email"))) userPassword := string(ctx.PostArgs().Peek("password")) confirmPassword := string(ctx.PostArgs().Peek("confirm_password")) if err := validateRegistration(username, email, userPassword, confirmPassword); err != nil { showRegisterError(ctx, err.Error(), username, email) return } if _, err := users.GetByUsername(username); err == nil { showRegisterError(ctx, "Username already exists", username, email) return } if _, err := users.GetByEmail(email); err == nil { showRegisterError(ctx, "Email already registered", username, email) return } user := users.New() user.Username = username user.Email = email user.Password = password.Hash(userPassword) user.ClassID = 1 user.Auth = 1 if err := user.Insert(); err != nil { showRegisterError(ctx, "Failed to create account", username, email) return } // Auto-login after registration middleware.Login(ctx, auth.Manager, user) // Transfer CSRF token from cookie to session for authenticated user if cookieToken := csrf.GetTokenFromCookie(ctx); cookieToken != "" { if session := csrf.GetCurrentSession(ctx); session != nil { csrf.StoreToken(session, cookieToken) } } ctx.Redirect("/", fasthttp.StatusFound) } // processLogout handles logout func processLogout(ctx router.Ctx, params []string) { // Validate CSRF token if !csrf.ValidateFormToken(ctx, auth.Manager) { ctx.SetStatusCode(fasthttp.StatusForbidden) ctx.WriteString("CSRF validation failed") return } middleware.Logout(ctx, auth.Manager) ctx.Redirect("/", fasthttp.StatusFound) } // Helper functions func showLoginError(ctx router.Ctx, errorMsg string) { loginTmpl, err := template.Cache.Load("auth/login.html") if err != nil { ctx.SetStatusCode(fasthttp.StatusInternalServerError) fmt.Fprintf(ctx, "Template error: %v", err) return } var errorHTML string if errorMsg != "" { errorHTML = fmt.Sprintf(`