Method ListImages

server-source-code/internal/store/docker.go:273–336

ListImages returns images with container count and hasUpdates.

(ctx context.Context, params ImageListParams)

// ListImages returns images with container count and hasUpdates.
func (s *DockerStore) ListImages(ctx context.Context, params ImageListParams) ([]ImageWithCounts, int, error) {
	d := s.db.DB(ctx)
	skip, take := validatePagination(params.Page, params.Limit, 10000)

	arg := db.ListImagesParams{Limit: safeconv.ClampToInt32(take), Offset: safeconv.ClampToInt32(skip)}
	if params.Source != "" {
		arg.Source = &params.Source
	}
	if params.Search != "" {
		arg.Search = &params.Search
	}

	countArg := db.CountImagesParams{}
	if params.Source != "" {
		countArg.Source = &params.Source
	}
	if params.Search != "" {
		countArg.Search = &params.Search
	}

	total, err := d.Queries.CountImages(ctx, countArg)
	if err != nil {
		return nil, 0, err
	}

	images, err := d.Queries.ListImages(ctx, arg)
	if err != nil {
		return nil, 0, err
	}

	if len(images) == 0 {
		return []ImageWithCounts{}, int(total), nil
	}

	ids := make([]string, len(images))
	for i := range images {
		ids[i] = images[i].ID
	}

	containerRows, _ := d.Queries.GetContainerCountsByImageIDs(ctx, ids)
	containerCount := make(map[string]int)
	for _, r := range containerRows {
		if r.ImageID != nil {
			containerCount[*r.ImageID] = int(r.Cnt)
		}
	}

	updateRows, _ := d.Queries.GetUpdateCountsByImageIDs(ctx, ids)
	updateCount := make(map[string]int)
	for _, r := range updateRows {
		updateCount[r.ImageID] = int(r.Cnt)
	}

	out := make([]ImageWithCounts, len(images))
	for i := range images {
		out[i] = ImageWithCounts{
			DockerImage:     dbDockerImageToModel(images[i]),
			CountContainers: containerCount[images[i].ID],