Method Tasks

service/admin/task.go:82–189

(c *gin.Context)

)

func (s *AdminListService) Tasks(c *gin.Context) (*ListTaskResponse, error) {
	dep := dependency.FromContext(c)
	taskClient := dep.TaskClient()
	hasher := dep.HashIDEncoder()
	var (
		err           error
		userID        int
		correlationID *uuid.UUID
		status        []task.Status
		taskType      []string
	)

	if s.Conditions[taskTypeCondition] != "" {
		taskType = []string{s.Conditions[taskTypeCondition]}
	}

	if s.Conditions[taskStatusCondition] != "" {
		status = []task.Status{task.Status(s.Conditions[taskStatusCondition])}
	}

	if s.Conditions[taskCorrelationIDCondition] != "" {
		cid, err := uuid.FromString(s.Conditions[taskCorrelationIDCondition])
		if err != nil {
			return nil, serializer.NewError(serializer.CodeParamErr, "Invalid task correlation ID", err)
		}
		correlationID = &cid
	}

	if s.Conditions[taskUserIDCondition] != "" {
		userID, err = strconv.Atoi(s.Conditions[taskUserIDCondition])
		if err != nil {
			return nil, serializer.NewError(serializer.CodeParamErr, "Invalid task user ID", err)
		}
	}

	ctx := context.WithValue(c, inventory.LoadTaskUser{}, true)
	res, err := taskClient.List(ctx, &inventory.ListTaskArgs{
		PaginationArgs: &inventory.PaginationArgs{
			Page:     s.Page - 1,
			PageSize: s.PageSize,
			OrderBy:  s.OrderBy,
			Order:    inventory.OrderDirection(s.OrderDirection),
		},
		UserID:        userID,
		CorrelationID: correlationID,
		Types:         taskType,
		Status:        status,
	})

	if err != nil {
		return nil, serializer.NewError(serializer.CodeDBError, "Failed to list tasks", err)
	}

	tasks := make([]queue.Task, 0, len(res.Tasks))
	nodeMap := make(map[int]*ent.Node)
	for _, t := range res.Tasks {
		task, err := queue.NewTaskFromModel(t)
		if err != nil {