Function proxyInternal

registry/app/pkg/base/wrapper.go:61–100

(
	ctx context.Context,
	registryDao store.RegistryRepository,
	f func(registry registrytypes.Registry, a pkg.Artifact) response.Response,
	info pkg.PackageArtifactInfo,
	useUpstream bool,
)

}

func proxyInternal(
	ctx context.Context,
	registryDao store.RegistryRepository,
	f func(registry registrytypes.Registry, a pkg.Artifact) response.Response,
	info pkg.PackageArtifactInfo,
	useUpstream bool,
) (response.Response, error) {
	var r response.Response
	requestRepoKey := info.BaseArtifactInfo().RegIdentifier
	registries, skipped, err := filterRegs(ctx, registryDao, requestRepoKey, info, useUpstream)
	if err != nil {
		return r, err
	}

	for _, registry := range registries {
		log.Ctx(ctx).Info().Msgf("Using Registry: %s, Type: %s", registry.Name, registry.Type)
		art := GetArtifactRegistry(registry)
		if art != nil {
			r = f(registry, art)
			if r.GetError() == nil {
				return r, nil
			}
			log.Ctx(ctx).Warn().Msgf("Repository: %s, Type: %s, error: %v", registry.Name, registry.Type,
				r.GetError())
		}
	}

	if !pkg.IsEmpty(skipped) {
		var skippedRegNames []string
		for _, registry := range skipped {
			skippedRegNames = append(skippedRegNames, registry.Name)
		}
		return r, errors.InvalidArgument("no matching artifacts found in registry %s, skipped registries: [%s] "+
			"due to allowed/blocked policies",
			requestRepoKey, pkg.JoinWithSeparator(", ", skippedRegNames...))
	}

	//todo: fix error message
	return r, errors.NotFound("no matching artifacts found in registry %s", requestRepoKey)
}

func factory(key string) pkg.Artifact {
	return TypeRegistry[key]