45 lines
2.2 KiB
C#
45 lines
2.2 KiB
C#
using PostFundManagement.Domain.Errors;
|
|
using PostFundManagement.Domain.Security.Configuration;
|
|
using PostFundManagement.Domain.Security.Models;
|
|
using PostFundManagement.Domain.Security.Sdk;
|
|
|
|
namespace PostFundManagement.Application.Services.Shared;
|
|
|
|
public sealed class TokenService(ISecurityConnectApi connectApi, IOptions<SecurityClientSettings> clientOptions)
|
|
{
|
|
private readonly SecurityClientSettings clientSettings = clientOptions.Value;
|
|
|
|
public async ValueTask<Result<Domain.Security.Models.TokenResponse>> GenerateAsync(CancellationToken cancellationToken = default) =>
|
|
await Result.Try((Func<ValueTask<Result<Domain.Security.Models.TokenResponse>>>)(async () =>
|
|
{
|
|
using var response = await connectApi.GetToken(new Domain.Security.Models.TokenRequest
|
|
{
|
|
ClientId = clientSettings.ClientId,
|
|
ClientSecret = clientSettings.ClientSecret,
|
|
GrantType = clientSettings.GrantType,
|
|
Scope = clientSettings.Scope,
|
|
}, cancellationToken);
|
|
|
|
var contentRaw = await response.Content.ReadAsStringAsync(cancellationToken);
|
|
|
|
if (string.IsNullOrWhiteSpace(contentRaw))
|
|
return Result.Fail(ValidationError.Create($"The authentication endpoint returned an empty payload. Status code: {response.StatusCode}"));
|
|
|
|
if (response.IsSuccessStatusCode)
|
|
{
|
|
var tokenResponse = JsonSerializer.Deserialize<Domain.Security.Models.TokenResponse>(contentRaw);
|
|
|
|
return !string.IsNullOrWhiteSpace(tokenResponse?.AccessToken)
|
|
? Result.Ok(tokenResponse)
|
|
: Result.Fail<Domain.Security.Models.TokenResponse>(NotFoundError.Create("Authentication succeeded, but no access token was found in the response payload."));
|
|
}
|
|
|
|
return await Result.Try((Func<ValueTask<Result<Domain.Security.Models.TokenResponse>>>)(async () =>
|
|
{
|
|
var errorResult = JsonSerializer.Deserialize<TokenErrorResponse>(contentRaw);
|
|
|
|
return Result.FailIf(errorResult != null,
|
|
CreateError.Create($"{errorResult!.Error}: {errorResult.ErrorDescription}"));
|
|
}));
|
|
}));
|
|
} |