/
generic.go
73 lines (65 loc) · 1.7 KB
/
generic.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
package utils
import (
"encoding/json"
"io/ioutil"
"net/http"
"os"
"strings"
log "github.com/sirupsen/logrus"
"k8s.io/client-go/tools/clientcmd"
"sigs.k8s.io/controller-runtime/pkg/client/config"
"github.com/openshift/hive/pkg/resource"
)
type releasePayload struct {
PullSpec string `json:"pullSpec"`
}
func DetermineReleaseImageFromSource(sourceURL string) (string, error) {
resp, err := http.Get(sourceURL)
if err != nil {
return "", err
}
defer resp.Body.Close()
data, err := ioutil.ReadAll(resp.Body)
if err != nil {
return "", err
}
payload := &releasePayload{}
err = json.Unmarshal(data, payload)
if err != nil {
return "", err
}
return payload.PullSpec, nil
}
func GetResourceHelper(logger log.FieldLogger) (resource.Helper, error) {
cfg, err := config.GetConfig()
if err != nil {
logger.WithError(err).Error("Cannot get client config")
return nil, err
}
return resource.NewHelperFromRESTConfig(cfg, logger)
}
func DefaultNamespace() (string, error) {
rules := clientcmd.NewDefaultClientConfigLoadingRules()
kubeconfig := clientcmd.NewNonInteractiveDeferredLoadingClientConfig(rules, &clientcmd.ConfigOverrides{})
ns, _, err := kubeconfig.Namespace()
return ns, err
}
func GetPullSecret(logger log.FieldLogger, pullSecret string, pullSecretFile string) (string, error) {
envPullSecret := os.Getenv("PULL_SECRET")
if len(envPullSecret) > 0 {
return envPullSecret, nil
}
if len(pullSecret) > 0 {
return pullSecret, nil
}
if len(pullSecretFile) > 0 {
data, err := ioutil.ReadFile(pullSecretFile)
if err != nil {
logger.Error("Cannot read pull secret file")
return "", err
}
pullSecret = strings.TrimSpace(string(data))
return pullSecret, nil
}
return "", nil
}