Method ListNetworks

server-source-code/internal/store/docker.go:669–726

ListNetworks returns networks with host info.

(ctx context.Context, params NetworkListParams)

// ListNetworks returns networks with host info.
func (s *DockerStore) ListNetworks(ctx context.Context, params NetworkListParams) ([]NetworkWithHost, int, error) {
	d := s.db.DB(ctx)
	skip, take := validatePagination(params.Page, params.Limit, 10000)

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

	countArg := db.CountNetworksParams{}
	if params.Driver != "" {
		countArg.Driver = &params.Driver
	}
	if params.Search != "" {
		countArg.Search = &params.Search
	}

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

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

	if len(networks) == 0 {
		return []NetworkWithHost{}, int(total), nil
	}

	hostIDs := make([]string, len(networks))
	for i := range networks {
		hostIDs[i] = networks[i].HostID
	}

	hosts, err := d.Queries.GetDockerHostsMinimalByIDs(ctx, hostIDs)
	if err != nil {
		return nil, 0, err
	}
	hostMap := make(map[string]*HostInfo)
	for i := range hosts {
		h := dockerHostRowToHostInfo(hosts[i])
		hostMap[h.ID] = h
	}

	out := make([]NetworkWithHost, len(networks))
	for i := range networks {
		out[i] = NetworkWithHost{
			DockerNetwork: dbDockerNetworkToModel(networks[i]),
			Hosts:         hostMap[networks[i].HostID],
		}
	}
	return out, int(total), nil
}