mirror of
https://github.com/portainer/portainer.git
synced 2026-06-23 06:20:12 +00:00
37 lines
1.3 KiB
Go
37 lines
1.3 KiB
Go
package registryhttp
|
|
|
|
import (
|
|
"net/http"
|
|
|
|
portainer "github.com/portainer/portainer/api"
|
|
"github.com/portainer/portainer/pkg/libhttp/ssrf"
|
|
|
|
"github.com/rs/zerolog/log"
|
|
"oras.land/oras-go/v2/registry/remote/retry"
|
|
)
|
|
|
|
// CreateClient creates an HTTP client with appropriate TLS configuration based on registry type.
|
|
// All registries use retry clients for better resilience.
|
|
// Returns the HTTP client, whether to use plainHTTP, and any error.
|
|
func CreateClient(registry *portainer.Registry) (httpClient *http.Client, usePlainHttp bool, err error) {
|
|
switch registry.Type {
|
|
case portainer.AzureRegistry, portainer.EcrRegistry, portainer.GithubRegistry, portainer.GitlabRegistry, portainer.DockerHubRegistry:
|
|
return &http.Client{Transport: retry.NewTransport(ssrf.NewTransport(nil))}, false, nil
|
|
default:
|
|
// For all other registry types, use shared helper to build transport and scheme
|
|
|
|
tlsCfg := portainer.TLSConfiguration{}
|
|
if registry.ManagementConfiguration != nil {
|
|
tlsCfg = registry.ManagementConfiguration.TLSConfig
|
|
}
|
|
|
|
transport, scheme, err := BuildTransportAndSchemeFromTLSConfig(tlsCfg)
|
|
if err != nil {
|
|
log.Error().Err(err).Msg("Failed to create TLS configuration")
|
|
return nil, false, err
|
|
}
|
|
|
|
return &http.Client{Transport: retry.NewTransport(transport)}, scheme == "http", nil
|
|
}
|
|
}
|