Method getDatasets

api/api_datasets.go:10–54

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

)

func (api *API) getDatasets(_ 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 datasets WHERE config_hash = $1", hash)
	if err != nil {
		return Response{
			Status: http.StatusInternalServerError,
			Error:  err.Error(),
		}
	}
	defer rows.Close()

	type datasetResponse struct {
		Text string
		config.Dataset
	}
	datasets := []datasetResponse{}
	for rows.Next() {
		dataset := datasetResponse{}
		err = rows.Scan(&dataset.ID, &dataset.Text)
		if err != nil {
			return Response{
				Status: http.StatusInternalServerError,
				Error:  err.Error(),
			}
		}
		err = yaml.Unmarshal([]byte(dataset.Text), &dataset.Dataset)
		if err != nil {
			return Response{
				Status: http.StatusInternalServerError,
				Error:  err.Error(),
			}
		}
		datasets = append(datasets, dataset)
	}
	return Response{
		Response: datasets,
	}
}