| 119 | } |
| 120 | |
| 121 | func validateReaderClient(kv *vault.KVv2, pathPrefix string) error { |
| 122 | ctx := context.Background() |
| 123 | // try to retrieve a non-existing key |
| 124 | // if we get 404 means that we have permissions to read in that path |
| 125 | keyPath := strings.Join([]string{pathPrefix, healthCheckNonExisting}, "/") |
| 126 | _, err := kv.Get(ctx, keyPath) |
| 127 | if err != nil { |
| 128 | if errors.Is(err, vault.ErrSecretNotFound) { |
| 129 | // Everything is ok |
| 130 | return nil |
| 131 | } |
| 132 | |
| 133 | return err |
| 134 | } |
| 135 | |
| 136 | return nil |
| 137 | } |
| 138 | |
| 139 | func (m *Manager) SaveCredentials(ctx context.Context, orgID string, creds any, opts ...credentials.SaveOption) (string, error) { |
| 140 | credsM, err := structToMap(creds) |