Skip to content

Commit 944b5f9

Browse files
committed
fixes
1 parent fd6d3fe commit 944b5f9

File tree

4 files changed

+34
-10
lines changed

4 files changed

+34
-10
lines changed

pkg/cmd/updateglobalimages.go

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -92,6 +92,14 @@ func updateGlobalImages(cmd *cobra.Command, args []string) {
9292
showCmd = showCmd + fmt.Sprintf(" --namespace %s", namespace)
9393
}
9494
fmt.Printf("Please run \"%s\" before running this command\n", showCmd)
95+
os.Exit(1)
96+
}
97+
98+
if !rac.IsAdmin(ctx) {
99+
fmt.Println("Error: not an admin")
100+
fmt.Println("Please make sure you are a Renku admin before running this command")
101+
fmt.Println("See: rdu make-me-admin --help")
102+
os.Exit(1)
95103
}
96104

97105
rsc, err := rac.Session()

pkg/renkuapi/client.go

Lines changed: 13 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -54,8 +54,20 @@ func (rac *RenkuApiClient) IsLoggedIn(ctx context.Context) bool {
5454
return token != ""
5555
}
5656

57+
func (rac *RenkuApiClient) IsAdmin(ctx context.Context) bool {
58+
ruc, err := rac.Users()
59+
if err != nil {
60+
return false
61+
}
62+
userInfo, err := ruc.GetUser(ctx)
63+
if err != nil {
64+
return false
65+
}
66+
return userInfo.IsAdmin
67+
}
68+
5769
func (rac *RenkuApiClient) Session() (rsc *session.RenkuSessionClient, err error) {
58-
if rac.ruc == nil {
70+
if rac.rsc == nil {
5971
rsc, err = session.NewRenkuSessionClient(rac.baseURL.String(), session.WithRequestEditors(session.RequestEditorFn(rac.auth.RequestEditor())))
6072
if err != nil {
6173
return nil, err

pkg/renkuapi/session/session.go

Lines changed: 10 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@ import (
1313
//go:generate go run github.com/oapi-codegen/oapi-codegen/v2/cmd/oapi-codegen -generate types,client,spec -package session -o session_gen.go api.spec.yaml
1414

1515
type RenkuSessionClient struct {
16-
bacseClient *ClientWithResponses
16+
baseClient *ClientWithResponses
1717
httpClient *http.Client
1818
requestEditors []RequestEditorFn
1919
}
@@ -47,7 +47,7 @@ func NewRenkuSessionClient(apiURL string, options ...RenkuSessionClientOption) (
4747
if err != nil {
4848
return nil, err
4949
}
50-
c.bacseClient = client
50+
c.baseClient = client
5151
return c, nil
5252
}
5353

@@ -68,7 +68,7 @@ func WithRequestEditors(editors ...RequestEditorFn) RenkuSessionClientOption {
6868
}
6969

7070
func (c *RenkuSessionClient) GetGlobalEnvironments(ctx context.Context) (environments EnvironmentList, err error) {
71-
res, err := c.bacseClient.GetEnvironmentsWithResponse(ctx, nil)
71+
res, err := c.baseClient.GetEnvironmentsWithResponse(ctx, nil)
7272
if err != nil {
7373
return environments, err
7474
}
@@ -86,7 +86,7 @@ func (c *RenkuSessionClient) GetGlobalEnvironments(ctx context.Context) (environ
8686
}
8787

8888
func (c *RenkuSessionClient) PostGlobalEnvironment(ctx context.Context, body EnvironmentPost) (environment Environment, err error) {
89-
res, err := c.bacseClient.PostEnvironmentsWithResponse(ctx, body)
89+
res, err := c.baseClient.PostEnvironmentsWithResponse(ctx, body)
9090
if err != nil {
9191
return environment, err
9292
}
@@ -104,7 +104,7 @@ func (c *RenkuSessionClient) PostGlobalEnvironment(ctx context.Context, body Env
104104
}
105105

106106
func (c *RenkuSessionClient) PatchGlobalEnvironment(ctx context.Context, environmentId Ulid, body EnvironmentPatch) (environment Environment, err error) {
107-
res, err := c.bacseClient.PatchEnvironmentsEnvironmentIdWithResponse(ctx, environmentId, body)
107+
res, err := c.baseClient.PatchEnvironmentsEnvironmentIdWithResponse(ctx, environmentId, body)
108108
if err != nil {
109109
return environment, err
110110
}
@@ -125,7 +125,11 @@ func (c *RenkuSessionClient) PatchGlobalEnvironment(ctx context.Context, environ
125125
}
126126

127127
func (c *RenkuSessionClient) UpdateGlobalImages(ctx context.Context, images []string, tag string, existingEnvironments EnvironmentList, dryRun bool) error {
128-
fmt.Println("Performing the following updates:")
128+
if dryRun {
129+
fmt.Println("The following updates would be performed:")
130+
} else {
131+
fmt.Println("Performing the following updates:")
132+
}
129133
for _, image := range images {
130134
_, err := c.updateGlobalImage(ctx, image, tag, existingEnvironments, dryRun)
131135
if err != nil {

pkg/renkuapi/users/users.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@ import (
1111
//go:generate go run github.com/oapi-codegen/oapi-codegen/v2/cmd/oapi-codegen -generate types,client,spec -package users -o users_gen.go api.spec.yaml
1212

1313
type RenkuUsersClient struct {
14-
bacseClient *ClientWithResponses
14+
baseClient *ClientWithResponses
1515
httpClient *http.Client
1616
requestEditors []RequestEditorFn
1717
}
@@ -45,7 +45,7 @@ func NewRenkuUsersClient(apiURL string, options ...RenkuUsersClientOption) (c *R
4545
if err != nil {
4646
return nil, err
4747
}
48-
c.bacseClient = client
48+
c.baseClient = client
4949
return c, nil
5050
}
5151

@@ -66,7 +66,7 @@ func WithRequestEditors(editors ...RequestEditorFn) RenkuUsersClientOption {
6666
}
6767

6868
func (c *RenkuUsersClient) GetUser(ctx context.Context) (userInfo SelfUserInfo, err error) {
69-
res, err := c.bacseClient.GetUserWithResponse(ctx)
69+
res, err := c.baseClient.GetUserWithResponse(ctx)
7070
if err != nil {
7171
return userInfo, err
7272
}

0 commit comments

Comments
 (0)