Skip to content

Commit 4c00da2

Browse files
committed
remove the other checkselfaccess
1 parent 1938042 commit 4c00da2

File tree

3 files changed

+1
-26
lines changed

3 files changed

+1
-26
lines changed

packages/maas/bff/internal/integrations/kubernetes/client.go

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,5 +17,4 @@ type KubernetesClientInterface interface {
1717
GetNamespaces(ctx context.Context, identity *RequestIdentity) ([]corev1.Namespace, error)
1818
IsClusterAdmin(identity *RequestIdentity) (bool, error)
1919
GetUser(identity *RequestIdentity) (string, error)
20-
CheckSelfAccess(ctx context.Context, group, resource, verb, namespace string) (bool, error)
2120
}

packages/maas/bff/internal/integrations/kubernetes/internal_k8s_client.go

Lines changed: 0 additions & 24 deletions
Original file line numberDiff line numberDiff line change
@@ -218,30 +218,6 @@ func (kc *InternalKubernetesClient) IsClusterAdmin(identity *RequestIdentity) (b
218218
return false, nil
219219
}
220220

221-
func (kc *InternalKubernetesClient) CheckSelfAccess(ctx context.Context, group, resource, verb, namespace string) (bool, error) {
222-
ctx, cancel := context.WithTimeout(ctx, 10*time.Second)
223-
defer cancel()
224-
225-
sar := &authv1.SelfSubjectAccessReview{
226-
Spec: authv1.SelfSubjectAccessReviewSpec{
227-
ResourceAttributes: &authv1.ResourceAttributes{
228-
Group: group,
229-
Resource: resource,
230-
Verb: verb,
231-
Namespace: namespace,
232-
},
233-
},
234-
}
235-
236-
resp, err := kc.Client.AuthorizationV1().SelfSubjectAccessReviews().Create(ctx, sar, metav1.CreateOptions{})
237-
if err != nil {
238-
kc.Logger.Error("failed to perform access review", "error", err)
239-
return false, fmt.Errorf("failed to perform access review: %w", err)
240-
}
241-
242-
return resp.Status.Allowed, nil
243-
}
244-
245221
func (kc *InternalKubernetesClient) GetUser(identity *RequestIdentity) (string, error) {
246222
// On internal client, we can use the identity from request directly
247223
return identity.UserID, nil

packages/maas/bff/internal/integrations/kubernetes/token_k8s_client.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,7 @@ func (kc *TokenKubernetesClient) IsClusterAdmin(_ *RequestIdentity) (bool, error
5555
}
5656

5757
// NewTokenKubernetesClient creates a Kubernetes client using a user bearer token.
58-
func NewTokenKubernetesClient(token string, logger *slog.Logger) (KubernetesClientInterface, error) {
58+
func NewTokenKubernetesClient(token string, logger *slog.Logger) (*TokenKubernetesClient, error) {
5959
baseConfig, err := helper.GetKubeconfig()
6060
if err != nil {
6161
logger.Error("failed to get kubeconfig", "error", err)

0 commit comments

Comments
 (0)