...
1 package secret
2
3 import (
4 "context"
5
6 "google.golang.org/grpc/codes"
7 "google.golang.org/grpc/status"
8
9 "edge-infra.dev/pkg/edge/api/types"
10 "edge-infra.dev/pkg/edge/k8objectsutils"
11 secretMgrApi "edge-infra.dev/pkg/lib/gcp/secretmanager"
12 "edge-infra.dev/pkg/sds/remoteaccess/constants"
13 )
14
15 func SaveStoreSecret(ctx context.Context, clusterEdgeID string, secretData []byte, sm types.SecretManagerService) error {
16 smSecretName := k8objectsutils.NameWithPrefix(constants.StoreName, clusterEdgeID)
17 labels := map[string]string{
18 secretMgrApi.SecretLabel: constants.WireguardControllerName,
19 secretMgrApi.SecretTypeLabel: constants.StoreName,
20 secretMgrApi.SecretOwnerLabel: constants.WireguardControllerName,
21 secretMgrApi.SecretNamespaceSelectorLabel: constants.WireguardControllerName,
22 }
23 return sm.AddSecret(ctx, smSecretName, secretData, labels, true, ExpireAt(), "")
24 }
25
26 func RemoveStoreSecret(ctx context.Context, clusterEdgeID string, sm types.SecretManagerService) error {
27 smSecretName := k8objectsutils.NameWithPrefix(constants.StoreName, clusterEdgeID)
28 err := sm.DeleteSecret(ctx, smSecretName)
29 if status.Code(err) == codes.NotFound {
30 return nil
31 }
32 return err
33 }
34
View as plain text