Function GetOrderedRepos

registry/app/pkg/base/wrapper.go:147–181

(
	ctx context.Context,
	registryDao store.RegistryRepository,
	repoKey string,
	parentID int64,
	upstream bool,
)

}

func GetOrderedRepos(
	ctx context.Context,
	registryDao store.RegistryRepository,
	repoKey string,
	parentID int64,
	upstream bool,
) ([]registrytypes.Registry, error) {
	var result []registrytypes.Registry
	registry, err := registryDao.GetByParentIDAndName(ctx, parentID, repoKey)
	if err != nil {
		return result, errors.NotFound("registry %s not found", repoKey)
	}
	result = append(result, *registry)
	if !upstream {
		return result, nil
	}
	proxies := registry.UpstreamProxies
	if len(proxies) > 0 {
		upstreamRepos, err2 := registryDao.GetByIDIn(ctx, proxies)
		if err2 != nil {
			log.Ctx(ctx).Error().Msgf("Failed to get upstream proxies for %s: %v", repoKey, err2)
			return result, err2
		}
		repoMap := make(map[int64]registrytypes.Registry)
		for _, repo := range *upstreamRepos {
			repoMap[repo.ID] = repo
		}
		for _, proxyID := range proxies {
			if repo, ok := repoMap[proxyID]; ok {
				result = append(result, repo)
			}
		}
	}
	return result, nil
}

func SearchPackagesProxyWrapper(
	ctx context.Context,