| | | 1 | | using KicktippIntegration; |
| | | 2 | | using KicktippIntegration.Authentication; |
| | | 3 | | using Microsoft.Extensions.Caching.Memory; |
| | | 4 | | using Microsoft.Extensions.Logging; |
| | | 5 | | using Microsoft.Extensions.Options; |
| | | 6 | | using Orchestrator.Commands.Utility.Snapshots; |
| | | 7 | | |
| | | 8 | | namespace Orchestrator.Infrastructure.Factories; |
| | | 9 | | |
| | | 10 | | /// <summary> |
| | | 11 | | /// Default implementation of <see cref="IKicktippClientFactory"/>. |
| | | 12 | | /// </summary> |
| | | 13 | | /// <remarks> |
| | | 14 | | /// Reads credentials from KICKTIPP_USERNAME and KICKTIPP_PASSWORD environment variables. |
| | | 15 | | /// </remarks> |
| | | 16 | | public sealed class KicktippClientFactory : IKicktippClientFactory |
| | | 17 | | { |
| | | 18 | | private readonly IMemoryCache _memoryCache; |
| | | 19 | | private readonly ILoggerFactory _loggerFactory; |
| | | 20 | | private readonly Lazy<IKicktippClient> _client; |
| | | 21 | | private readonly Lazy<KicktippOptions> _credentials; |
| | | 22 | | |
| | 1 | 23 | | public KicktippClientFactory( |
| | 1 | 24 | | IMemoryCache memoryCache, |
| | 1 | 25 | | ILoggerFactory loggerFactory) |
| | | 26 | | { |
| | 1 | 27 | | _memoryCache = memoryCache; |
| | 1 | 28 | | _loggerFactory = loggerFactory; |
| | 1 | 29 | | _credentials = new Lazy<KicktippOptions>(LoadCredentials); |
| | 1 | 30 | | _client = new Lazy<IKicktippClient>(InitializeClient); |
| | 1 | 31 | | } |
| | | 32 | | |
| | | 33 | | /// <inheritdoc /> |
| | 1 | 34 | | public IKicktippClient CreateClient() => _client.Value; |
| | | 35 | | |
| | | 36 | | /// <inheritdoc /> |
| | | 37 | | public HttpClient CreateAuthenticatedHttpClient() |
| | | 38 | | { |
| | 1 | 39 | | var options = Options.Create(_credentials.Value); |
| | | 40 | | |
| | | 41 | | // Create the authentication handler |
| | 1 | 42 | | var authLogger = _loggerFactory.CreateLogger<KicktippAuthenticationHandler>(); |
| | 1 | 43 | | var authHandler = new KicktippAuthenticationHandler(options, authLogger) |
| | 1 | 44 | | { |
| | 1 | 45 | | InnerHandler = new HttpClientHandler() |
| | 1 | 46 | | }; |
| | | 47 | | |
| | | 48 | | // Create HttpClient with the auth handler |
| | 1 | 49 | | var httpClient = new HttpClient(authHandler) |
| | 1 | 50 | | { |
| | 1 | 51 | | BaseAddress = new Uri("https://www.kicktipp.de"), |
| | 1 | 52 | | Timeout = TimeSpan.FromMinutes(2) |
| | 1 | 53 | | }; |
| | 1 | 54 | | httpClient.DefaultRequestHeaders.Add("User-Agent", |
| | 1 | 55 | | "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/91.0.4472.124 Safar |
| | | 56 | | |
| | 1 | 57 | | return httpClient; |
| | | 58 | | } |
| | | 59 | | |
| | | 60 | | /// <inheritdoc /> |
| | | 61 | | public ISnapshotClient CreateSnapshotClient() |
| | | 62 | | { |
| | 1 | 63 | | var httpClient = CreateAuthenticatedHttpClient(); |
| | 1 | 64 | | var logger = _loggerFactory.CreateLogger<SnapshotClient>(); |
| | 1 | 65 | | return new SnapshotClient(httpClient, logger); |
| | | 66 | | } |
| | | 67 | | |
| | | 68 | | private static KicktippOptions LoadCredentials() |
| | | 69 | | { |
| | 1 | 70 | | var username = Environment.GetEnvironmentVariable("KICKTIPP_USERNAME"); |
| | 1 | 71 | | var password = Environment.GetEnvironmentVariable("KICKTIPP_PASSWORD"); |
| | | 72 | | |
| | 1 | 73 | | if (string.IsNullOrWhiteSpace(username)) |
| | | 74 | | { |
| | 1 | 75 | | throw new InvalidOperationException("KICKTIPP_USERNAME environment variable is required"); |
| | | 76 | | } |
| | | 77 | | |
| | 1 | 78 | | if (string.IsNullOrWhiteSpace(password)) |
| | | 79 | | { |
| | 0 | 80 | | throw new InvalidOperationException("KICKTIPP_PASSWORD environment variable is required"); |
| | | 81 | | } |
| | | 82 | | |
| | 1 | 83 | | return new KicktippOptions |
| | 1 | 84 | | { |
| | 1 | 85 | | Username = username, |
| | 1 | 86 | | Password = password |
| | 1 | 87 | | }; |
| | | 88 | | } |
| | | 89 | | |
| | | 90 | | private IKicktippClient InitializeClient() |
| | | 91 | | { |
| | 1 | 92 | | var options = Options.Create(_credentials.Value); |
| | | 93 | | |
| | | 94 | | // Create the authentication handler |
| | 1 | 95 | | var authLogger = _loggerFactory.CreateLogger<KicktippAuthenticationHandler>(); |
| | 1 | 96 | | var authHandler = new KicktippAuthenticationHandler(options, authLogger) |
| | 1 | 97 | | { |
| | 1 | 98 | | InnerHandler = new HttpClientHandler() |
| | 1 | 99 | | }; |
| | | 100 | | |
| | | 101 | | // Create HttpClient with the auth handler |
| | 1 | 102 | | var httpClient = new HttpClient(authHandler) |
| | 1 | 103 | | { |
| | 1 | 104 | | BaseAddress = new Uri("https://www.kicktipp.de"), |
| | 1 | 105 | | Timeout = TimeSpan.FromMinutes(2) |
| | 1 | 106 | | }; |
| | 1 | 107 | | httpClient.DefaultRequestHeaders.Add("User-Agent", |
| | 1 | 108 | | "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/91.0.4472.124 Safar |
| | | 109 | | |
| | | 110 | | // Create and return the client |
| | 1 | 111 | | var clientLogger = _loggerFactory.CreateLogger<KicktippClient>(); |
| | 1 | 112 | | return new KicktippClient(httpClient, clientLogger, _memoryCache); |
| | | 113 | | } |
| | | 114 | | } |