xximjasonxx

// variant 1
public async Task<bool> DoWork(IList<SomeItem> items)
{
  // assume _context is our EF Context
  foreach (var item in items.Where(x => x.Id % 2 == 0))
  {
    var it = await _context.FirstOrDefaultAsync(x => x.Id == item.Id);
    _context.Remove(it);
  }
  

xximjasonxx

public async Task<bool> DoWork(IList<SomeItem> items)
{
  foreach (var item in items.Where(x => x.Id % 2 == 0))
  {
    await _someRepo.DeleteItem(item.Id);
  }
}

xximjasonxx

    public class ProcessApiResultFilter : IActionFilter
    {
        private readonly JwtTokenService _jwtTokenService;

        public ProcessApiResultFilter(JwtTokenService jwtTokenService)
        {
            _jwtTokenService = jwtTokenService;
        }
        
        public void OnActionExecuting(ActionExecutingContext context)

xximjasonxx

 
           client.DefaultRequestHeaders.Add("Client-Id", _configuration["TwitchClientId"]);
            client.DefaultRequestHeaders.Authorization =
                new AuthenticationHeaderValue("Bearer", await _getTokensFromHttpRequestService.GetAccessToken());

            var result = new ApiResult<TwitchUser>();
            var response = await client.GetAsync($"helix/users?login={loginName}");
            if (response.StatusCode == HttpStatusCode.Unauthorized)
            {
                // refresh tokens

xximjasonxx

    public class JwtSecurityTokenValidator : ISecurityTokenValidator
    {
        private readonly IConfiguration _configuration;
        private readonly KeyVaultService _keyVaultService;

        public JwtSecurityTokenValidator(IConfiguration configuration, KeyVaultService keyVaultService)
        {
            _configuration = configuration;
            _keyVaultService = keyVaultService;
        }

xximjasonxx

var keyVaultService = new KeyVaultService(new GetCredentialService(Configuration), Configuration);
var tokenSecurityValidator = new JwtSecurityTokenValidator(Configuration, keyVaultService);

services.AddTransient<CryptoService>()
  .AddTransient<JwtTokenService>()
  .AddSingleton<TwitchAuthService>()
  .AddSingleton(p => keyVaultService)
  .AddTransient(p => tokenSecurityValidator)
  .AddSingleton<GetCredentialService>()
  .AddTransient<TwitchApiService>()

xximjasonxx

        public IActionResult Get()
        {
            var redirectUri = WebUtility.UrlEncode("https://localhost:5001/home/callback");
            var urlString = @$"https://id.twitch.tv/oauth2/authorize?client_id={_configuration["TwitchClientId"]}"
                            + $"&redirect_uri={redirectUri}"
                            + "&response_type=code"
                            + "&scope=openid";

            return Redirect(urlString);
        }

xximjasonxx

// getting the key
        private KeyClient KeyClient => new KeyClient(
            vaultUri: new Uri(_configuration["KeyVaultUri"]),
            credential: _getCredentialService.GetKeyVaultCredentials());

        public async Task<KeyVaultKey> GetEncryptionKey()
        {
            var keyResponse = await KeyClient.GetKeyAsync("encryption-key");
            return keyResponse.Value;
        }

xximjasonxx

        public async Task<string> CreateJwtTokenString(string accessToken, string refreshToken)
        {
            var jwtSigningKey = await _keyVaultService.GetJwtSigningKey();
            var securityKey = new SymmetricSecurityKey(Encoding.UTF8.GetBytes(jwtSigningKey));
            var signingCredentials = new SigningCredentials(securityKey, SecurityAlgorithms.HmacSha256Signature);
            var secToken = new JwtSecurityToken(
                issuer: _configuration["Issuer"],
                audience: _configuration["Audience"],
                claims: new List<Claim>
                {

xximjasonxx

{
    "rabbitMq": {
        "host": "rabbitmq-release.rabbitmq",
        "port": 5672
    }
}