Function handleUpdatePerform

cmd/dash.go:2935–3019

handleUpdatePerform handles POST requests to perform an update

(w http.ResponseWriter, r *http.Request)

// handleUpdatePerform handles POST requests to perform an update
func handleUpdatePerform(w http.ResponseWriter, r *http.Request) {
	if r.Method != "POST" {
		http.Error(w, "Method not allowed", http.StatusMethodNotAllowed)
		return
	}

	if isSafeModeEnabled {
		http.Error(w, "Updates are disabled in safe mode", http.StatusForbidden)
		return
	}

	// Check for update first
	status, err := checkForUpdate()
	if err != nil {
		http.Error(w, err.Error(), http.StatusInternalServerError)
		return
	}

	if !status.HasUpdate {
		http.Error(w, "No update available", http.StatusBadRequest)
		return
	}

	// Set up SSE headers for streaming progress
	w.Header().Set("Content-Type", "text/event-stream")
	w.Header().Set("Cache-Control", "no-cache")
	w.Header().Set("Connection", "keep-alive")

	// Function to send progress updates
	sendProgress := func(message string) {
		defer func() {
			if r := recover(); r != nil {
				// Connection was likely closed during update, silently ignore
				log(fmt.Sprintf("Progress update failed (connection closed): %v", r))
			}
		}()

		// Check if w is nil
		if w == nil {
			return
		}

		progressData, _ := json.Marshal(map[string]string{"progress": message})
		if _, err := fmt.Fprintf(w, "data: %s\n\n", progressData); err != nil {
			return
		}

		// Simple flush without nested defer
		if flusher, ok := w.(http.Flusher); ok && flusher != nil {
			flusher.Flush() // This will be caught by the main defer/recover if it panics
		}
	}

	sendProgress("Starting update process...")

	// Perform the update in a goroutine
	go func() {
		if err := performUpdateWithRestart(status, sendProgress); err != nil {