Method Get

service/admin/task.go:198–235

(c *gin.Context)

)

func (s *SingleTaskService) Get(c *gin.Context) (*GetTaskResponse, error) {
	dep := dependency.FromContext(c)
	taskClient := dep.TaskClient()
	hasher := dep.HashIDEncoder()

	ctx := context.WithValue(c, inventory.LoadTaskUser{}, true)
	task, err := taskClient.GetTaskByID(ctx, s.ID)
	if err != nil {
		return nil, serializer.NewError(serializer.CodeDBError, "Failed to get task", err)
	}

	t, err := queue.NewTaskFromModel(task)
	if err != nil {
		return nil, serializer.NewError(serializer.CodeDBError, "Failed to parse task", err)
	}

	summary := t.Summarize(hasher)
	var (
		node       *ent.Node
		userHashID string
	)

	if summary != nil && summary.NodeID > 0 {
		node, _ = dep.NodeClient().GetNodeById(c, summary.NodeID)
	}

	if task.Edges.User != nil {
		userHashID = hashid.EncodeUserID(hasher, task.Edges.User.ID)
	}

	return &GetTaskResponse{
		Task:       task,
		Summary:    summary,
		Node:       node,
		UserHashID: userHashID,
		TaskHashID: hashid.EncodeTaskID(hasher, task.ID),
	}, nil
}

type (
	BatchTaskService struct {