task_routes.go

package tasks

import (
	"fmt"
	"net/http"

	"github.com/thecodeteam/rexray/libstorage/api/server/httputils"
	"github.com/thecodeteam/rexray/libstorage/api/server/services"
	"github.com/thecodeteam/rexray/libstorage/api/types"
	"github.com/thecodeteam/rexray/libstorage/api/utils"
)

func (r *router) tasks(
	ctx types.Context,
	w http.ResponseWriter,
	req *http.Request,
	store types.Store) error {

	tasks := map[string]*types.Task{}
	for t := range services.Tasks(ctx) {
		tasks[fmt.Sprintf("%d", t.ID)] = t
	}
	httputils.WriteJSON(w, http.StatusOK, tasks)
	return nil
}

func (r *router) taskInspect(
	ctx types.Context,
	w http.ResponseWriter,
	req *http.Request,
	store types.Store) error {

	task := services.TaskInspect(ctx, store.GetInt("taskID"))
	if task == nil {
		return utils.NewNotFoundError(store.GetString("taskID"))
	}

	httputils.WriteJSON(w, http.StatusOK, task)
	return nil
}