Added jwt generator

.github/workflows/deploy.yml

@@ -27,6 +27,7 @@ jobs:
           sed -i 's/"__S3_BUCKET_NAME",/"${{ vars.S3_BUCKET_NAME }}",/g' ${{env.PRODUCTION_SETTINGS_FILE}}
           sed -i 's/"__TELEGRAM_BOT_KEY",/"${{ secrets.TELEGRAM_BOT_KEY }}",/g' ${{env.PRODUCTION_SETTINGS_FILE}}
           sed -i 's/"__SENDGRID_API_KEY",/"${{ secrets.SENDGRID_API_KEY }}",/g' ${{env.PRODUCTION_SETTINGS_FILE}}
+          sed -i 's/"__OPEN_AI_SECRET",/"${{ secrets.OPEN_AI_SECRET }}",/g' ${{env.PRODUCTION_SETTINGS_FILE}}
           cd src
           docker login -u ${{ env.DO_TOKEN }} -p ${{ env.DO_TOKEN }} registry.digitalocean.com/techinterview
           docker build -f Dockerfile -t ${{ secrets.CR }}/backend:${{ github.sha }} .

src/.env.example

@@ -1,3 +1,4 @@
 SendGridApiKey=''
 IdentityServer_Audience=''
-Telegram__BotToken=''
+Telegram__BotToken=''
+OpenAiApi__Secret=''

src/Domain/Entities/StatData/SalaryBaseData.cs

@@ -0,0 +1,15 @@
+using System;
+using Domain.Entities.Enums;
+
+namespace Domain.Entities.StatData;
+
+public record SalaryBaseData
+{
+    public long? ProfessionId { get; init; }
+
+    public DeveloperGrade Grade { get; init; }
+
+    public double Value { get; init; }
+
+    public DateTimeOffset CreatedAt { get; init; }
+}

src/Domain/Entities/StatData/StatDataCacheItemSalaryData.cs

@@ -19,13 +19,18 @@ public StatDataCacheItemSalaryData()
     }
 
     public StatDataCacheItemSalaryData(
-        List<SalaryGraveValue> values,
+        List<SalaryBaseData> values,
         int totalCount)
     {
-        var salaryValues = values.Select(x => x.Value).ToList();
+        var salaryValues = values
+            .Select(x => x.Value)
+            .ToList();
+
         MedianLocalSalary = salaryValues.Median();
         AverageLocalSalary = salaryValues.Count > 0 ? salaryValues.Average() : 0;
         TotalSalaryCount = totalCount;
+        MinLocalSalary = salaryValues.Count > 0 ? salaryValues.Min() : null;
+        MaxLocalSalary = salaryValues.Count > 0 ? salaryValues.Max() : null;
 
         MedianLocalSalaryByGrade = new Dictionary<GradeGroup, double>();
 
@@ -51,6 +56,10 @@ public StatDataCacheItemSalaryData(
 
     public double AverageLocalSalary { get; init; }
 
+    public double? MinLocalSalary { get; init; }
+
+    public double? MaxLocalSalary { get; init; }
+
     public Dictionary<GradeGroup, double> MedianLocalSalaryByGrade { get; init; } = new ();
 
     public int TotalSalaryCount { get; init; }

src/Domain/ValueObjects/ISalariesChartQueryParams.cs

@@ -9,7 +9,7 @@ public interface ISalariesChartQueryParams
 {
     public DeveloperGrade? Grade { get; }
 
-    public List<long> ProfessionsToInclude { get; }
+    public List<long> SelectedProfessionIds { get; }
 
     public List<long> Skills { get; }
 
@@ -22,7 +22,7 @@ public interface ISalariesChartQueryParams
     public int? YearTo { get; }
 
     public bool HasAnyFilter =>
-        Grade.HasValue || ProfessionsToInclude.Count > 0 || Cities.Count > 0;
+        Grade.HasValue || SelectedProfessionIds.Count > 0 || Cities.Count > 0;
 
     string GetKeyPostfix();
 }

src/Infrastructure/Currencies/Contracts/ICurrencyService.cs

@@ -4,7 +4,7 @@ namespace Infrastructure.Currencies.Contracts
 {
     public interface ICurrencyService
     {
-        Task<CurrencyContent> GetCurrencyAsync(
+        Task<CurrencyContent> GetCurrencyOrNullAsync(
             Currency currency,
             CancellationToken cancellationToken);
 

src/Infrastructure/Currencies/CurrencyService.cs

@@ -29,7 +29,7 @@ public CurrencyService(
             _logger = logger;
         }
 
-        public async Task<CurrencyContent> GetCurrencyAsync(
+        public async Task<CurrencyContent> GetCurrencyOrNullAsync(
             Currency currency,
             CancellationToken cancellationToken)
         {

src/Infrastructure/Infrastructure.csproj

@@ -21,6 +21,7 @@
         <PackageReference Include="QuestPDF" Version="2025.1.2" />
         <PackageReference Include="QuestPDF.Markdown" Version="1.31.0" />
         <PackageReference Include="SendGrid" Version="9.29.3" />
+        <PackageReference Include="System.IdentityModel.Tokens.Jwt" Version="8.9.0" />
         <PackageReference Include="System.Net.Http" Version="4.3.4" />
         <PackageReference Include="System.Text.Encodings.Web" Version="9.0.2" />
         <PackageReference Include="System.Text.RegularExpressions" Version="4.3.1" />

src/Infrastructure/Jwt/TechinterviewJwtTokenGenerator.cs

@@ -0,0 +1,44 @@
+using System.IdentityModel.Tokens.Jwt;
+using System.Security.Claims;
+using System.Text;
+using Microsoft.IdentityModel.Tokens;
+
+namespace Infrastructure.Jwt;
+
+public record TechinterviewJwtTokenGenerator
+{
+    private readonly string _secretKey;
+
+    private string _result;
+
+    public TechinterviewJwtTokenGenerator(
+        string secretKey)
+    {
+        _secretKey = secretKey;
+    }
+
+    public override string ToString()
+    {
+        return _result ??= GenerateInternal();
+    }
+
+    private string GenerateInternal()
+    {
+        var securityKey = new SymmetricSecurityKey(Encoding.ASCII.GetBytes(_secretKey));
+        var credentials = new SigningCredentials(securityKey, SecurityAlgorithms.HmacSha256Signature);
+
+        var claims = new List<Claim>
+        {
+            new Claim(JwtRegisteredClaimNames.Sub, Guid.NewGuid().ToString()),
+            new Claim(JwtRegisteredClaimNames.Name, "TechInterview.space Bot"),
+            new Claim(JwtRegisteredClaimNames.Iat, DateTimeOffset.UtcNow.ToUnixTimeSeconds().ToString(), ClaimValueTypes.Integer64)
+        };
+
+        var token = new JwtSecurityToken(
+            claims: claims,
+            expires: DateTime.UtcNow.AddHours(1),
+            signingCredentials: credentials);
+
+        return new JwtSecurityTokenHandler().WriteToken(token);
+    }
+}

src/Infrastructure/Salaries/ChartPageLink.cs

@@ -45,9 +45,9 @@ public override string ToString()
         if (_requestOrNull != null || _additionalQueryParams.Count > 0)
         {
             string queryParams = null;
-            if (_requestOrNull?.ProfessionsToInclude.Count > 0)
+            if (_requestOrNull?.SelectedProfessionIds.Count > 0)
             {
-                queryParams += $"?profsInclude={string.Join(",", _requestOrNull.ProfessionsToInclude)}";
+                queryParams += $"?profsInclude={string.Join(",", _requestOrNull.SelectedProfessionIds)}";
             }
 
             if (_requestOrNull?.Grade != null)

src/Infrastructure/Salaries/SalariesForChartQuery.cs

@@ -12,12 +12,12 @@ namespace Infrastructure.Salaries;
 
 public record SalariesForChartQuery
 {
+    public const int MonthsToShow = 18;
+
     public DateQuarter CurrentQuarter { get; }
 
     public DeveloperGrade? Grade { get; }
 
-    public List<long> ProfessionsToInclude { get; }
-
     public List<long> Skills { get; }
 
     public List<KazakhstanCity> Cities { get; }
@@ -32,6 +32,7 @@ public record SalariesForChartQuery
 
     public int? YearTo { get; }
 
+    private readonly List<long> _selectedProfessionIds;
     private readonly DatabaseContext _context;
 
     public SalariesForChartQuery(
@@ -48,7 +49,7 @@ public SalariesForChartQuery(
     {
         _context = context;
         Grade = grade;
-        ProfessionsToInclude = professionsToInclude ?? new List<long>();
+        _selectedProfessionIds = professionsToInclude ?? new List<long>();
         Skills = skills ?? new List<long>();
 
         Cities = cities ?? new List<KazakhstanCity>();
@@ -69,7 +70,7 @@ public SalariesForChartQuery(
         : this(
             context,
             request,
-            now.AddMonths(-18),
+            now.AddMonths(-MonthsToShow),
             now)
     {
     }
@@ -82,7 +83,7 @@ public SalariesForChartQuery(
         : this(
             context,
             request.Grade,
-            request.ProfessionsToInclude,
+            request.SelectedProfessionIds,
             request.Skills,
             request.Cities,
             from,
@@ -179,8 +180,8 @@ private IQueryable<UserSalary> BuildQuery(
                 Skills.Count > 0,
                 x => x.SkillId != null && Skills.Contains(x.SkillId.Value))
             .When(
-                ProfessionsToInclude.Count > 0,
-                x => x.ProfessionId != null && ProfessionsToInclude.Contains(x.ProfessionId.Value));
+                _selectedProfessionIds.Count > 0,
+                x => x.ProfessionId != null && _selectedProfessionIds.Contains(x.ProfessionId.Value));
 
         return query;
     }

src/Infrastructure/Services/OpenAi/IOpenAiService.cs

@@ -0,0 +1,9 @@
+namespace Infrastructure.Services.OpenAi;
+
+public interface IOpenAiService
+{
+    string GetBearer();
+
+    Task<string> GetAnalysisAsync(
+        CancellationToken cancellationToken = default);
+}

src/Infrastructure/Services/OpenAi/OpenAiService.cs

@@ -0,0 +1,63 @@
+using System.Net.Http.Headers;
+using Infrastructure.Jwt;
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.Logging;
+
+namespace Infrastructure.Services.OpenAi;
+
+public class OpenAiService : IOpenAiService
+{
+    private readonly IHttpClientFactory _httpClientFactory;
+    private readonly IConfiguration _configuration;
+    private readonly ILogger<OpenAiService> _logger;
+
+    public OpenAiService(
+        IHttpClientFactory httpClientFactory,
+        IConfiguration configuration,
+        ILogger<OpenAiService> logger)
+    {
+        _httpClientFactory = httpClientFactory;
+        _configuration = configuration;
+        _logger = logger;
+    }
+
+    public string GetBearer()
+    {
+        var secret = _configuration["OpenAiApi:Secret"];
+        return new TechinterviewJwtTokenGenerator(secret).ToString();
+    }
+
+    public async Task<string> GetAnalysisAsync(
+        CancellationToken cancellationToken = default)
+    {
+        var apiUrl = _configuration["OpenAiApi:Url"];
+        if (string.IsNullOrEmpty(apiUrl))
+        {
+            throw new InvalidOperationException("OpenAI API url is not set");
+        }
+
+        var responseContent = string.Empty;
+        try
+        {
+            using var client = _httpClientFactory.CreateClient();
+
+            client.BaseAddress = new Uri(apiUrl);
+            client.DefaultRequestHeaders.Authorization =
+                new AuthenticationHeaderValue("Bearer", GetBearer());
+
+            responseContent = await client.GetStringAsync(string.Empty, cancellationToken);
+            return responseContent;
+        }
+        catch (Exception e)
+        {
+            _logger.LogError(
+                e,
+                "Error while getting OpenAI response from {Url}. Message {Message}. Response {Response}",
+                apiUrl,
+                e.Message,
+                responseContent);
+
+            return string.Empty;
+        }
+    }
+}

src/InfrastructureTests/Jwt/TechinterviewJwtTokenGeneratorTests.cs

@@ -0,0 +1,17 @@
+using Infrastructure.Jwt;
+using Xunit;
+
+namespace InfrastructureTests.Jwt;
+
+public class TechinterviewJwtTokenGeneratorTests
+{
+    [Fact]
+    public void ToString_ShouldReturnToken()
+    {
+        const string secretKey = "hey-girl-its-super-secret-key-for-jwt";
+        var generator = new TechinterviewJwtTokenGenerator(secretKey);
+
+        var result = generator.ToString();
+        Assert.Contains("eyJhbGciOiJodHRwOi8vd3d3LnczLm9yZy8y", result);
+    }
+}

src/TestUtils/Mocks/CurrenciesServiceFake.cs

@@ -38,7 +38,7 @@ public CurrenciesServiceFake(
         _currencies = currencies;
     }
 
-    public Task<CurrencyContent> GetCurrencyAsync(
+    public Task<CurrencyContent> GetCurrencyOrNullAsync(
         Currency currency,
         CancellationToken cancellationToken)
     {

src/Web.Api.Tests/Features/Telegram/ProcessMessage/UserCommands/QaAndTestersTelegramBotUserCommandParametersTests.cs

@@ -21,9 +21,9 @@ public void Ctor_TestersProfessions_Ok()
 
         var target = new QaAndTestersTelegramBotUserCommandParameters(professions);
 
-        Assert.Equal(3, target.ProfessionsToInclude.Count);
-        Assert.Equal(professions[0].Id, target.ProfessionsToInclude[0]);
-        Assert.Equal(professions[1].Id, target.ProfessionsToInclude[1]);
-        Assert.Equal(professions[2].Id, target.ProfessionsToInclude[2]);
+        Assert.Equal(3, target.SelectedProfessionIds.Count);
+        Assert.Equal(professions[0].Id, target.SelectedProfessionIds[0]);
+        Assert.Equal(professions[1].Id, target.SelectedProfessionIds[1]);
+        Assert.Equal(professions[2].Id, target.SelectedProfessionIds[2]);
     }
 }