Function findInstances

cmd/dash.go:1702–1741

findInstances finds running instances of commands using cached ps output

(commandStrings []string)

// findInstances finds running instances of commands using cached ps output
func findInstances(commandStrings []string) []JobInstance {
	if len(commandStrings) == 0 {
		return []JobInstance{}
	}

	lines := getCachedProcessList()
	instances := make([]JobInstance, 0)
	seenPGIDs := make(map[string]bool) // To avoid duplicate entries

	for _, line := range lines {
		fields := strings.Fields(line)
		if len(fields) < 8 {
			continue
		}

		pgid := fields[0] // Process group ID
		// The start time is fields[1:6] (day month date time year)
		started := strings.Join(fields[1:6], " ")
		args := strings.Join(fields[6:], " ")

		// Skip if this is a cronitor exec command
		if strings.Contains(args, "cronitor exec") {
			continue
		}

		// Check if any of the command strings match
		for _, cmdStr := range commandStrings {
			if strings.Contains(args, cmdStr) && !seenPGIDs[pgid] {
				instances = append(instances, JobInstance{
					PID:     pgid,
					Started: started,
				})
				seenPGIDs[pgid] = true
				break
			}
		}
	}

	return instances
}

// handleRunJob handles POST requests to run a job
func handleRunJob(w http.ResponseWriter, r *http.Request) {