Method startScriptInBackground

control_server.go:457–513

(scriptName string, scriptCmd []string)

}

func (this *ControlServer) startScriptInBackground(scriptName string, scriptCmd []string) {
	logger := this.logger.WithField("script", scriptName)

	this.customScriptsLock.Lock()
	defer this.customScriptsLock.Unlock()

	running := this.customScriptsRunning[scriptName]
	if running {
		logger.Warn("script already running, ignoring start request")
		return
	}

	logger.Infof("running custom script %v", scriptCmd)
	this.customScriptsStatus[scriptName] = "starting"
	this.customScriptsRunning[scriptName] = true
	this.customScriptsLogs[scriptName] = ""

	go func() {
		cmd := exec.Command(scriptCmd[0], scriptCmd[1:]...)

		this.customScriptsLock.Lock()
		this.customScriptsStatus[scriptName] = "running"
		this.customScriptsLock.Unlock()

		stdoutStderr, err := cmd.CombinedOutput()

		this.customScriptsLock.Lock()
		if err != nil {
			this.customScriptsStatus[scriptName] = fmt.Sprintf("exitted with error: %v", err)

			var exitError *exec.ExitError
			defaultExitCode := 1
			if errors.As(err, &exitError) {
				this.customScriptsExitCode[scriptName] = exitError.ExitCode()
				LogWithFields(Fields{
					"scriptName": scriptName,
					"error":      err.Error(),
					"exitCode":   exitError.ExitCode(),
				}).Error("custom script ran with errors")
			} else {
				this.customScriptsExitCode[scriptName] = defaultExitCode
				LogWithFields(Fields{
					"scriptName": scriptName,
					"error":      err.Error(),
					"exitCode":   exitError.ExitCode(),
				}).Error("custom script ran with errors but could not determine the exit code")
			}
		} else {
			this.customScriptsStatus[scriptName] = "success"
			this.customScriptsExitCode[scriptName] = 0
			logger.Info("custom script ran successfully")
		}
		this.customScriptsLogs[scriptName] = string(stdoutStderr)
		this.customScriptsRunning[scriptName] = false
		this.customScriptsLock.Unlock()
	}()
}