path: root/handlers/admin.go

package handlers

import (
	"auth-proxy/config"
	"auth-proxy/logging"
	"auth-proxy/middleware"
	"auth-proxy/models"
	"auth-proxy/types"
	"auth-proxy/utils"
	"auth-proxy/worker"
	"encoding/json"
	"fmt"
	"net/http"
	"sync"
	"time"
)

var workerPool *types.WorkerPool

// SetWorkerPool sets the package-level worker pool instance.
func SetWorkerPool(pool *types.WorkerPool) {
	workerPool = pool
}

// AdminPageHandler serves the admin dashboard page.
func AdminPageHandler(w http.ResponseWriter, r *http.Request) {
	// Fetch all users to render on the page
	users, err := models.GetAllUsers()
	if err != nil {
		logging.AppLog.Error("Failed to retrieve users for admin page", "error", err)
		http.Error(w, "Could not load user data.", http.StatusInternalServerError)
		return
	}

	data := map[string]interface{}{
		"Paths":     config.Paths,
		"Users":     users,
		"XSRFToken": middleware.GetXSRFToken(r),
	}
	if err := templates.ExecuteTemplate(w, "admin.html", data); err != nil {
		logging.AppLog.Error("Failed to execute admin template", "error", err)
	}
}

// GetUsersHandler returns a list of all users with enriched information.
// It uses a worker pool to calculate extra information for each user in parallel.
func GetUsersHandler(w http.ResponseWriter, r *http.Request) {
	ip := logging.GetClientIP(r)
	users, err := models.GetAllUsers()
	if err != nil {
		logging.AppLog.Error("Failed to retrieve users", "error", err, "ip", ip)
		http.Error(w, "Failed to retrieve users", http.StatusInternalServerError)
		return
	}

	enrichedUsers := make([]types.EnrichedUser, len(users))
	var wg sync.WaitGroup

	for i, user := range users {
		wg.Add(1)
		// Create copies of loop variables to avoid race conditions in the closure
		index := i
		userCopy := user

		task := func() {
			defer wg.Done()
			// Simulate some work, e.g., calculating a value or fetching related data.
			time.Sleep(5 * time.Millisecond)

			timeSinceLogin := "N/A"
			if userCopy.LastLoginAt != nil {
				timeSinceLogin = fmt.Sprintf("%.0fm ago", time.Since(*userCopy.LastLoginAt).Minutes())
			}

			enrichedUsers[index] = types.EnrichedUser{
				User:           &userCopy,
				TimeSinceLogin: timeSinceLogin,
			}
		}
		worker.Submit(workerPool, task)
	}

	wg.Wait() // Wait for all tasks to complete

	w.Header().Set("Content-Type", "application/json")
	if err := json.NewEncoder(w).Encode(enrichedUsers); err != nil {
		logging.AppLog.Error("Failed to encode users to JSON", "error", err, "ip", ip)
	}
}

// UpdateUserRoleHandler updates a user's role.
func UpdateUserRoleHandler(w http.ResponseWriter, r *http.Request) {
	ip := logging.GetClientIP(r)
	// Get admin user from context
	adminUser, ok := r.Context().Value(types.SessionDataContextKey).(*types.User)
	if !ok || adminUser == nil {
		logging.AppLog.Error("Failed to get user from context for admin action", "ip", ip)
		http.Error(w, "Unauthorized", http.StatusUnauthorized)
		return
	}
	adminUsername := adminUser.Username

	id := r.URL.Path[len(config.Paths.AdminUsersAPI+"/") : len(r.URL.Path)-len("/role")]
	if id == "" {
		logging.AppLog.Warn("Invalid user ID in request", "path", r.URL.Path, "ip", ip)
		http.Error(w, "Invalid user ID", http.StatusBadRequest)
		return
	}

	var req struct {
		Role string `json:"role"`
	}

	if err := json.NewDecoder(r.Body).Decode(&req); err != nil {
		logging.AppLog.Warn("Invalid request body for role update", "error", err, "ip", ip)
		http.Error(w, "Invalid request body", http.StatusBadRequest)
		return
	}

	if req.Role != "admin" && req.Role != "user" {
		logging.AppLog.Warn("Invalid role provided for update", "role", req.Role, "ip", ip)
		http.Error(w, "Invalid role", http.StatusBadRequest)
		return
	}

	if err := models.UpdateUserRole(id, req.Role); err != nil {
		logging.AppLog.Error("Failed to update user role in database", "error", err, "target_user_id", id, "ip", ip)
		http.Error(w, "Failed to update role", http.StatusInternalServerError)
		return
	}

	logging.SecurityLog.Info("ADMIN ACTION", "action", "update_role", "performed_by", adminUsername, "target_user_id", id, "new_role", req.Role, "ip", ip)
	w.WriteHeader(http.StatusOK)
}

// DeleteUserHandler deletes a user.
func DeleteUserHandler(w http.ResponseWriter, r *http.Request) {
	ip := logging.GetClientIP(r)
	// Get admin user from context
	adminUser, ok := r.Context().Value(types.SessionDataContextKey).(*types.User)
	if !ok || adminUser == nil {
		logging.AppLog.Error("Failed to get user from context for admin action", "ip", ip)
		http.Error(w, "Unauthorized", http.StatusUnauthorized)
		return
	}
	adminUsername := adminUser.Username

	id := r.URL.Path[len(config.Paths.AdminUsersAPI+"/"):]
	if id == "" {
		logging.AppLog.Warn("Invalid user ID in request", "path", r.URL.Path, "ip", ip)
		http.Error(w, "Invalid user ID", http.StatusBadRequest)
		return
	}

	if err := models.DeleteUser(id); err != nil {
		logging.AppLog.Error("Failed to delete user from database", "error", err, "target_user_id", id, "ip", ip)
		http.Error(w, "Failed to delete user", http.StatusInternalServerError)
		return
	}

	logging.SecurityLog.Info("ADMIN ACTION", "action", "delete_user", "performed_by", adminUsername, "target_user_id", id, "ip", ip)
	w.WriteHeader(http.StatusOK)
}

// SetUserActiveStatusHandler updates a user's active status.
func SetUserActiveStatusHandler(w http.ResponseWriter, r *http.Request) {
	ip := logging.GetClientIP(r)
	// Get admin user from context
	adminUser, ok := r.Context().Value(types.SessionDataContextKey).(*types.User)
	if !ok || adminUser == nil {
		logging.AppLog.Error("Failed to get user from context for admin action", "ip", ip)
		http.Error(w, "Unauthorized", http.StatusUnauthorized)
		return
	}
	adminUsername := adminUser.Username

	id := r.URL.Path[len(config.Paths.AdminUsersAPI+"/") : len(r.URL.Path)-len("/status")]
	if id == "" {
		logging.AppLog.Warn("Invalid user ID in request", "path", r.URL.Path, "ip", ip)
		http.Error(w, "Invalid user ID", http.StatusBadRequest)
		return
	}

	var req struct {
		IsActive bool `json:"is_active"`
	}

	if err := json.NewDecoder(r.Body).Decode(&req); err != nil {
		logging.AppLog.Warn("Invalid request body for status update", "error", err, "ip", ip)
		http.Error(w, "Invalid request body", http.StatusBadRequest)
		return
	}

	if err := models.SetUserActiveStatus(id, req.IsActive); err != nil {
		logging.AppLog.Error("Failed to update user status in database", "error", err, "target_user_id", id, "ip", ip)
		http.Error(w, "Failed to update status", http.StatusInternalServerError)
		return
	}

	logging.SecurityLog.Info("ADMIN ACTION", "action", "set_active_status", "performed_by", adminUsername, "target_user_id", id, "new_status", req.IsActive, "ip", ip)
	w.WriteHeader(http.StatusOK)
}

// CreateUserHandler handles creating a new user by an admin.
func CreateUserHandler(w http.ResponseWriter, r *http.Request) {
	ip := logging.GetClientIP(r)

	var reqBody struct {
		Username string `json:"username"`
		Password string `json:"password"`
		Role     string `json:"role"`
	}

	if err := json.NewDecoder(r.Body).Decode(&reqBody); err != nil {
		http.Error(w, "Invalid request body", http.StatusBadRequest)
		return
	}

	// Default role to "user" if not provided or invalid
	if reqBody.Role != "admin" && reqBody.Role != "user" {
		reqBody.Role = "user"
	}

	// Validate password policy
	if ok, message := utils.ValidatePassword(reqBody.Password); !ok {
		http.Error(w, message, http.StatusBadRequest)
		return
	}

	existingUser, err := models.GetUserByUsername(reqBody.Username)
	if err != nil {
		logging.AppLog.Error("Error checking username during admin user creation", "error", err, "ip", ip)
		http.Error(w, "Internal Server Error", http.StatusInternalServerError)
		return
	}
	if existingUser != nil {
		http.Error(w, "Username is already taken", http.StatusConflict)
		return
	}

	user, err := models.CreateUser(reqBody.Username, reqBody.Password, reqBody.Role)
	if err != nil {
		logging.AppLog.Error("Failed to create user via admin API", "error", err, "username", reqBody.Username, "ip", ip)
		http.Error(w, "Failed to create user", http.StatusInternalServerError)
		return
	}

	logging.SecurityLog.Info("USER CREATED BY ADMIN", "username", user.Username, "role", user.Role, "ip", ip)

	w.Header().Set("Content-Type", "application/json")
	w.WriteHeader(http.StatusCreated)
	if err := json.NewEncoder(w).Encode(user); err != nil {
		logging.AppLog.Error("Failed to encode user to JSON", "error", err, "ip", ip)
	}
}