Method List

server-source-code/internal/store/repositories.go:32–104

List returns all repositories with host counts and host details.

(ctx context.Context, params RepoListParams)

// List returns all repositories with host counts and host details.
func (s *RepositoriesStore) List(ctx context.Context, params RepoListParams) ([]RepositoryWithHosts, error) {
	d := s.db.DB(ctx)
	arg := db.ListRepositoriesParams{}
	if params.HostID != "" {
		arg.HostID = &params.HostID
	}
	if params.Search != "" {
		arg.Search = &params.Search
	}
	if params.Status != "" {
		arg.Status = &params.Status
	}
	if params.Type != "" {
		arg.Type = &params.Type
	}

	repos, err := d.Queries.ListRepositories(ctx, arg)
	if err != nil {
		return nil, err
	}
	if len(repos) == 0 {
		return []RepositoryWithHosts{}, nil
	}

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

	hostRows, err := d.Queries.GetHostCountsForRepos(ctx, ids)
	if err != nil {
		return nil, err
	}

	hostsByRepo := make(map[string][]HostRepoHost)
	for _, r := range hostRows {
		h := HostRepoHost{
			ID:           r.ID,
			FriendlyName: r.FriendlyName,
			Status:       r.Status,
			IsEnabled:    r.IsEnabled,
		}
		if r.LastChecked.Valid {
			t := r.LastChecked.Time.Format("2006-01-02T15:04:05Z07:00")
			h.LastChecked = &t
		}
		hostsByRepo[r.RepositoryID] = append(hostsByRepo[r.RepositoryID], h)
	}

	out := make([]RepositoryWithHosts, len(repos))
	for i := range repos {
		rid := repos[i].ID
		hosts := hostsByRepo[rid]
		hostCount := len(hosts)
		enabledCount, activeCount := 0, 0
		for _, h := range hosts {
			if h.IsEnabled {
				enabledCount++