Method getWorkflows

api/api_workflows.go:10–50

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

)

func (api *API) getWorkflows(_ http.ResponseWriter, r *http.Request) Response {
	hash, err := api.LatestConfigHash()
	if err != nil {
		return Response{
			Status: http.StatusInternalServerError,
			Error:  err.Error(),
		}
	}

	rows, err := api.db.Query("SELECT id, text FROM workflows WHERE config_hash = $1", hash)
	if err != nil {
		return Response{
			Status: http.StatusInternalServerError,
			Error:  err.Error(),
		}
	}
	defer rows.Close()
	workflows := map[string]config.Workflow{}
	for rows.Next() {
		id, text := "", ""
		err = rows.Scan(&id, &text)
		if err != nil {
			return Response{
				Status: http.StatusInternalServerError,
				Error:  err.Error(),
			}
		}
		workflow := config.Workflow{}
		err = workflow.Parse([]byte(text))
		if err != nil {
			return Response{
				Status: http.StatusInternalServerError,
				Error:  err.Error(),
			}
		}
		workflows[id] = workflow
	}
	return Response{
		Response: workflows,
	}
}

func (api *API) getWorkflow(_ http.ResponseWriter, r *http.Request) Response {
	vars := mux.Vars(r)