Function handleDeleteJob

cmd/dash.go:2213–2269

handleDeleteJob handles DELETE requests to delete a job

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

// handleDeleteJob handles DELETE requests to delete a job
func handleDeleteJob(w http.ResponseWriter, r *http.Request) {
	if r.Method != "DELETE" {
		http.Error(w, "Method not allowed", http.StatusMethodNotAllowed)
		return
	}

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

	crontab, err := lib.GetCrontab(job.CrontabFilename)
	if err != nil {
		http.Error(w, err.Error(), http.StatusInternalServerError)
		return
	}

	var foundLine *lib.Line
	var foundLineIndex int

	// Find the matching line
	for i, line := range crontab.Lines {
		if (job.Code != "" && line.Code == job.Code) || (job.Key != "" && line.Key(crontab.CanonicalName()) == job.Key) {
			foundLine = line
			foundLineIndex = i
			break
		}
	}

	if foundLine == nil {
		http.Error(w, "Job not found", http.StatusNotFound)
		return
	}

	// If the job is monitored, pause it indefinitely
	if job.Monitored {
		if err := getCronitorApi().PauseMonitor(job.Code, ""); err != nil {
			http.Error(w, fmt.Sprintf("Failed to pause monitor: %v", err), http.StatusInternalServerError)
			return
		}
	}

	// Remove the line from the crontab
	crontab.Lines = append(crontab.Lines[:foundLineIndex], crontab.Lines[foundLineIndex+1:]...)

	// Save the crontab
	if err := crontab.Save(crontab.Write()); err != nil {
		http.Error(w, "Failed to save crontab", http.StatusInternalServerError)
		return
	}

	// Invalidate cache since we modified a crontab
	invalidateCrontabCache()

	w.WriteHeader(http.StatusOK)
}