Function handleRunJob

cmd/dash.go:1744–2005

handleRunJob handles POST requests to run a job

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

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

	var request struct {
		Command         string `json:"command"`
		CrontabFilename string `json:"crontab_filename"`
		Key             string `json:"key"`
		WithMonitoring  bool   `json:"with_monitoring"`
	}

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

	if request.Command == "" {
		http.Error(w, "Command parameter is required", http.StatusBadRequest)
		return
	}

	shell := "/bin/sh"     // Default shell
	var monitorCode string // For monitoring

	// If crontab filename and key are provided, use them to find the specific job
	if request.CrontabFilename != "" && request.Key != "" {
		crontab, err := lib.GetCrontab(request.CrontabFilename)
		if err != nil {
			http.Error(w, "Crontab not found", http.StatusForbidden)
			return
		} else {
			// Use the shell from this crontab
			if crontab.Shell != "" {
				shell = crontab.Shell
			}

			// Find the specific job by key
			var foundLine *lib.Line
			for _, line := range crontab.Lines {
				if line.IsJob && line.Key(crontab.CanonicalName()) == request.Key {
					foundLine = line
					break
				}
			}

			if foundLine != nil {
				// Validate that the command matches what's in the crontab
				if foundLine.CommandToRun != request.Command && isSafeModeEnabled {
					http.Error(w, "Command does not match the job in the crontab", http.StatusForbidden)
					return
				}
				// Get monitor code if monitoring is requested
				if request.WithMonitoring && foundLine.Code != "" {
					monitorCode = foundLine.Code
				}
			} else if isSafeModeEnabled {