Skip to content

Commit a626721

Browse files
committed
stop using factory.OpenshiftClientConfig
1 parent 8cab39d commit a626721

16 files changed

+48
-75
lines changed

pkg/oc/admin/diagnostics/config.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@ import (
1515

1616
// use the base factory to return a raw config (not specific to a context)
1717
func (o DiagnosticsOptions) buildRawConfig() (*clientcmdapi.Config, error) {
18-
kubeConfig, configErr := o.Factory.OpenShiftClientConfig().RawConfig()
18+
kubeConfig, configErr := o.Factory.RawConfig()
1919
if configErr != nil {
2020
return nil, configErr
2121
}

pkg/oc/admin/image/verify-signature.go

Lines changed: 4 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,6 @@ import (
1818
"github.com/spf13/cobra"
1919

2020
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
21-
kclientcmd "k8s.io/client-go/tools/clientcmd"
2221
kapi "k8s.io/kubernetes/pkg/apis/core"
2322
"k8s.io/kubernetes/pkg/kubectl/cmd/templates"
2423
kcmdutil "k8s.io/kubernetes/pkg/kubectl/cmd/util"
@@ -84,8 +83,6 @@ type VerifyImageSignatureOptions struct {
8483

8584
ImageClient imageclient.ImageInterface
8685

87-
clientConfig kclientcmd.ClientConfig
88-
8986
Out io.Writer
9087
ErrOut io.Writer
9188
}
@@ -96,9 +93,8 @@ const (
9693

9794
func NewCmdVerifyImageSignature(name, fullName string, f *clientcmd.Factory, out, errOut io.Writer) *cobra.Command {
9895
opts := &VerifyImageSignatureOptions{
99-
ErrOut: errOut,
100-
Out: out,
101-
clientConfig: f.OpenShiftClientConfig(),
96+
ErrOut: errOut,
97+
Out: out,
10298
// TODO: This improves the error message users get when containers/image is not able
10399
// to locate the pubring.gpg file (which is default).
104100
// This should be improved/fixed in containers/image.
@@ -169,7 +165,8 @@ func (o *VerifyImageSignatureOptions) Complete(f *clientcmd.Factory, cmd *cobra.
169165
return err
170166
} else {
171167
o.CurrentUser = me.Name
172-
if config, err := o.clientConfig.ClientConfig(); err != nil {
168+
169+
if config, err := f.ClientConfig(); err != nil {
173170
return err
174171
} else {
175172
if o.CurrentUserToken = config.BearerToken; len(o.CurrentUserToken) == 0 {

pkg/oc/cli/cmd/login/login.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -97,7 +97,7 @@ func NewCmdLogin(fullName string, f *osclientcmd.Factory, reader io.Reader, out,
9797
}
9898

9999
func (o *LoginOptions) Complete(f *osclientcmd.Factory, cmd *cobra.Command, args []string, commandName string) error {
100-
kubeconfig, err := f.OpenShiftClientConfig().RawConfig()
100+
kubeconfig, err := f.RawConfig()
101101
o.StartingKubeConfig = &kubeconfig
102102
if err != nil {
103103
if !os.IsNotExist(err) {

pkg/oc/cli/cmd/login/logout.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -80,13 +80,13 @@ func NewCmdLogout(name, fullName, ocLoginFullCommand string, f *osclientcmd.Fact
8080
}
8181

8282
func (o *LogoutOptions) Complete(f *osclientcmd.Factory, cmd *cobra.Command, args []string) error {
83-
kubeconfig, err := f.OpenShiftClientConfig().RawConfig()
83+
kubeconfig, err := f.RawConfig()
8484
o.StartingKubeConfig = &kubeconfig
8585
if err != nil {
8686
return err
8787
}
8888

89-
o.Config, err = f.OpenShiftClientConfig().ClientConfig()
89+
o.Config, err = f.ClientConfig()
9090
if err != nil {
9191
return err
9292
}

pkg/oc/cli/cmd/project.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -100,7 +100,7 @@ func (o *ProjectOptions) Complete(f *clientcmd.Factory, args []string, out io.Wr
100100
o.ProjectName = args[0]
101101
}
102102

103-
o.Config, err = f.OpenShiftClientConfig().RawConfig()
103+
o.Config, err = f.RawConfig()
104104
if err != nil {
105105
return err
106106
}
@@ -126,7 +126,7 @@ func (o *ProjectOptions) Complete(f *clientcmd.Factory, args []string, out io.Wr
126126

127127
// since we failed to retrieve ClientConfig for the current server,
128128
// fetch local OpenShift client config
129-
o.ClientConfig, err = f.OpenShiftClientConfig().ClientConfig()
129+
o.ClientConfig, err = f.ClientConfig()
130130
if err != nil {
131131
return err
132132
}

pkg/oc/cli/cmd/projects.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -92,12 +92,12 @@ func (o *ProjectsOptions) Complete(f *clientcmd.Factory, args []string, commandN
9292
o.CommandName = commandName
9393

9494
var err error
95-
o.Config, err = f.OpenShiftClientConfig().RawConfig()
95+
o.Config, err = f.RawConfig()
9696
if err != nil {
9797
return err
9898
}
9999

100-
o.ClientConfig, err = f.OpenShiftClientConfig().ClientConfig()
100+
o.ClientConfig, err = f.ClientConfig()
101101
if err != nil {
102102
return err
103103
}

pkg/oc/cli/cmd/request_project.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -115,7 +115,7 @@ func (o *NewProjectOptions) Complete(f *clientcmd.Factory, cmd *cobra.Command, a
115115
return err
116116
}
117117
} else {
118-
clientConfig, err := f.OpenShiftClientConfig().ClientConfig()
118+
clientConfig, err := f.ClientConfig()
119119
if err != nil {
120120
return err
121121
}

pkg/oc/cli/cmd/startbuild.go

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,6 @@ import (
2929
"k8s.io/apimachinery/pkg/runtime/schema"
3030
"k8s.io/apimachinery/third_party/forked/golang/netutil"
3131
restclient "k8s.io/client-go/rest"
32-
kclientcmd "k8s.io/client-go/tools/clientcmd"
3332
"k8s.io/kubernetes/pkg/api/legacyscheme"
3433
kapi "k8s.io/kubernetes/pkg/apis/core"
3534
"k8s.io/kubernetes/pkg/kubectl/cmd/templates"
@@ -158,7 +157,7 @@ type StartBuildOptions struct {
158157

159158
Mapper meta.RESTMapper
160159
BuildClient buildclient.BuildInterface
161-
ClientConfig kclientcmd.ClientConfig
160+
ClientConfig *restclient.Config
162161

163162
AsBinary bool
164163
ShortOutput bool
@@ -169,11 +168,15 @@ type StartBuildOptions struct {
169168
}
170169

171170
func (o *StartBuildOptions) Complete(f *clientcmd.Factory, in io.Reader, out, errout io.Writer, cmd *cobra.Command, cmdFullName string, args []string) error {
171+
var err error
172172
o.In = in
173173
o.Out = out
174174
o.ErrOut = errout
175175
o.Git = git.NewRepository()
176-
o.ClientConfig = f.OpenShiftClientConfig()
176+
o.ClientConfig, err = f.ClientConfig()
177+
if err != nil {
178+
return err
179+
}
177180
o.Mapper, _ = f.Object()
178181

179182
o.IncrementalOverride = cmd.Flags().Lookup("incremental").Changed
@@ -716,13 +719,10 @@ func (o *StartBuildOptions) RunStartBuildWebHook() error {
716719
// when using HTTPS, try to reuse the local config transport if possible to get a client cert
717720
// TODO: search all configs
718721
if hook.Scheme == "https" {
719-
config, err := o.ClientConfig.ClientConfig()
720-
if err == nil {
721-
if url, _, err := restclient.DefaultServerURL(config.Host, "", schema.GroupVersion{}, true); err == nil {
722-
if netutil.CanonicalAddr(url) == netutil.CanonicalAddr(hook) && url.Scheme == hook.Scheme {
723-
if rt, err := restclient.TransportFor(config); err == nil {
724-
httpClient = &http.Client{Transport: rt}
725-
}
722+
if url, _, err := restclient.DefaultServerURL(o.ClientConfig.Host, "", schema.GroupVersion{}, true); err == nil {
723+
if netutil.CanonicalAddr(url) == netutil.CanonicalAddr(hook) && url.Scheme == hook.Scheme {
724+
if rt, err := restclient.TransportFor(o.ClientConfig); err == nil {
725+
httpClient = &http.Client{Transport: rt}
726726
}
727727
}
728728
}

pkg/oc/cli/cmd/startbuild_test.go

Lines changed: 2 additions & 26 deletions
Original file line numberDiff line numberDiff line change
@@ -60,7 +60,7 @@ func TestStartBuildWebHook(t *testing.T) {
6060
buf := &bytes.Buffer{}
6161
o := &StartBuildOptions{
6262
Out: buf,
63-
ClientConfig: cfg,
63+
ClientConfig: cfg.Client,
6464
FromWebhook: server.URL + "/webhook",
6565
Mapper: legacyscheme.Registry.RESTMapper(),
6666
}
@@ -79,30 +79,6 @@ func TestStartBuildWebHook(t *testing.T) {
7979
}
8080
}
8181

82-
func TestStartBuildWebHookHTTPS(t *testing.T) {
83-
invoked := make(chan struct{}, 1)
84-
server := httptest.NewTLSServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
85-
invoked <- struct{}{}
86-
w.WriteHeader(http.StatusOK)
87-
}))
88-
defer server.Close()
89-
90-
testErr := errors.New("not enabled")
91-
cfg := &FakeClientConfig{
92-
Err: testErr,
93-
}
94-
buf := &bytes.Buffer{}
95-
o := &StartBuildOptions{
96-
Out: buf,
97-
ClientConfig: cfg,
98-
FromWebhook: server.URL + "/webhook",
99-
Mapper: legacyscheme.Registry.RESTMapper(),
100-
}
101-
if err := o.Run(); err == nil || !strings.Contains(err.Error(), "certificate signed by unknown authority") {
102-
t.Fatalf("unexpected non-error: %v", err)
103-
}
104-
}
105-
10682
func TestStartBuildHookPostReceive(t *testing.T) {
10783
invoked := make(chan *buildapi.GenericWebHookEvent, 1)
10884
server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
@@ -129,7 +105,7 @@ func TestStartBuildHookPostReceive(t *testing.T) {
129105
buf := &bytes.Buffer{}
130106
o := &StartBuildOptions{
131107
Out: buf,
132-
ClientConfig: cfg,
108+
ClientConfig: cfg.Client,
133109
FromWebhook: server.URL + "/webhook",
134110
GitPostReceive: f.Name(),
135111
Mapper: legacyscheme.Registry.RESTMapper(),

pkg/oc/cli/cmd/status.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -130,12 +130,12 @@ func (o *StatusOptions) Complete(f *clientcmd.Factory, cmd *cobra.Command, baseC
130130
return err
131131
}
132132

133-
config, err := f.OpenShiftClientConfig().ClientConfig()
133+
config, err := f.ClientConfig()
134134
if err != nil {
135135
return err
136136
}
137137

138-
rawConfig, err := f.OpenShiftClientConfig().RawConfig()
138+
rawConfig, err := f.RawConfig()
139139
if err != nil {
140140
return err
141141
}

0 commit comments

Comments
 (0)