Adds Href to task resources for REST API

mgmt/rest/rbody/task.go

@@ -129,6 +129,7 @@ type ScheduledTask struct {
 	FailedCount        int               `json:"failed_count,omitempty"`
 	LastFailureMessage string            `json:"last_failure_message,omitempty"`
 	State              string            `json:"task_state"`
+	Href               string            `json:"href"`
 }
 
 func (s *ScheduledTask) CreationTime() time.Time {

mgmt/rest/task.go

@@ -107,6 +107,7 @@ func (s *Server) addTask(w http.ResponseWriter, r *http.Request, _ httprouter.Pa
 	}
 
 	taskB := rbody.AddSchedulerTaskFromTask(task)
+	taskB.Href = taskURI(r.Host, task)
 	respond(201, taskB, w)
 }
 
@@ -119,6 +120,7 @@ func (s *Server) getTasks(w http.ResponseWriter, r *http.Request, _ httprouter.P
 	i := 0
 	for _, t := range sts {
 		tasks.ScheduledTasks[i] = *rbody.SchedulerTaskFromTask(t)
+		tasks.ScheduledTasks[i].Href = taskURI(r.Host, t)
 		i++
 	}
 	sort.Sort(tasks)
@@ -134,6 +136,7 @@ func (s *Server) getTask(w http.ResponseWriter, r *http.Request, p httprouter.Pa
 	}
 	task := &rbody.ScheduledTaskReturned{}
 	task.AddScheduledTask = *rbody.AddSchedulerTaskFromTask(t)
+	task.Href = taskURI(r.Host, t)
 	respond(200, task, w)
 }
 
@@ -384,3 +387,7 @@ func (t *TaskWatchHandler) CatchTaskDisabled(why string) {
 		Message:   why,
 	}
 }
+
+func taskURI(host string, t core.Task) string {
+	return fmt.Sprintf("%s://%s/v1/tasks/%s", protocolPrefix, host, t.ID())
+}