Method List

inventory/task.go:202–241

(ctx context.Context, args *ListTaskArgs)

}

func (c *taskClient) List(ctx context.Context, args *ListTaskArgs) (*ListTaskResult, error) {
	q := c.client.Task.Query()
	if args.UserID != 0 {
		q.Where(task.UserTasks(args.UserID))
	}

	if args.Types != nil {
		q.Where(task.TypeIn(args.Types...))
	}

	if args.Status != nil {
		q.Where(task.StatusIn(args.Status...))
	}

	if args.CorrelationID != nil {
		q.Where(task.CorrelationID(*args.CorrelationID))
	}

	q = withTaskEagerLoading(ctx, q)
	var (
		tasks         []*ent.Task
		err           error
		paginationRes *PaginationResults
	)

	if args.UseCursorPagination {
		tasks, paginationRes, err = c.cursorPagination(ctx, q, args, 1)
	} else {
		tasks, paginationRes, err = c.offsetPagination(ctx, q, args, 1)
	}

	if err != nil {
		return nil, fmt.Errorf("query failed with paginiation: %w", err)
	}

	return &ListTaskResult{
		Tasks:             tasks,
		PaginationResults: paginationRes,
	}, nil
}

func (c *taskClient) cursorPagination(ctx context.Context, query *ent.TaskQuery, args *ListTaskArgs, paramMargin int) ([]*ent.Task, *PaginationResults, error) {
	pageSize := capPageSize(c.maxSQlParam, args.PageSize, paramMargin)