| | | 1 | | namespace Elsa.Secrets.Services; |
| | | 2 | | |
| | 45 | 3 | | public class DefaultSecretResolver(ISecretManager secretManager) : ISecretResolver |
| | | 4 | | { |
| | 7 | 5 | | public Task<string> ResolveAsync(string name, CancellationToken cancellationToken = default) => ResolveAsync(new Sec |
| | | 6 | | |
| | | 7 | | public async Task<string> ResolveAsync(SecretReference reference, CancellationToken cancellationToken = default) |
| | | 8 | | { |
| | 12 | 9 | | var secret = await secretManager.GetAsync(reference.Name, cancellationToken); |
| | 12 | 10 | | if (secret == null) |
| | 1 | 11 | | throw new InvalidOperationException($"Secret '{reference.Name}' was not found."); |
| | | 12 | | |
| | 11 | 13 | | if (!string.IsNullOrWhiteSpace(reference.TypeName) && !string.Equals(secret.TypeName, reference.TypeName, String |
| | 2 | 14 | | throw new InvalidOperationException($"Secret '{reference.Name}' is not compatible with required type '{refer |
| | | 15 | | |
| | 9 | 16 | | if (!string.IsNullOrWhiteSpace(reference.Scope) && !string.Equals(secret.Scope, reference.Scope, StringCompariso |
| | 1 | 17 | | throw new InvalidOperationException($"Secret '{reference.Name}' is not compatible with required scope '{refe |
| | | 18 | | |
| | 8 | 19 | | var payload = await secretManager.ResolvePayloadAsync(secret, cancellationToken); |
| | 7 | 20 | | return payload.Value!; |
| | 7 | 21 | | } |
| | | 22 | | } |