Function handlePutJob

cmd/dash.go:2714–2902

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

}

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

	if job.CrontabFilename == "" {
		http.Error(w, "Crontab filename is required", 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
	}

	// Update the line
	hasChanges := false

	// Handle suspended status
	if job.Suspended != nil && *job.Suspended != foundLine.IsComment {
		foundLine.IsComment = *job.Suspended
		hasChanges = true

		// If the job is monitored, handle pause/unpause
		if job.Monitored {
			if *job.Suspended {
				// Pause the monitor when suspending
				if err := getCronitorApi().PauseMonitor(job.Code, job.PauseHours); err != nil {
					http.Error(w, fmt.Sprintf("Failed to pause monitor: %v", err), http.StatusInternalServerError)
					return
				}
			} else {
				// Unpause the monitor when unsuspending
				if err := getCronitorApi().PauseMonitor(job.Code, "0"); err != nil {
					http.Error(w, fmt.Sprintf("Failed to unpause monitor: %v", err), http.StatusInternalServerError)
					return
				}
			}