Open AI integrated

.github/workflows/deploy.yml

@@ -30,6 +30,7 @@ jobs:
           sed -i 's/"__SENDGRID_API_KEY",/"${{ secrets.SENDGRID_API_KEY }}",/g' ${{env.PRODUCTION_SETTINGS_FILE}}
           sed -i 's/"__SENDGRID_WEBHOOK_SIGNATURE",/"${{ secrets.SENDGRID_WEBHOOK_SIGNATURE }}",/g' ${{env.PRODUCTION_SETTINGS_FILE}}
           sed -i 's/"__OPEN_AI_SECRET",/"${{ secrets.OPEN_AI_SECRET }}",/g' ${{env.PRODUCTION_SETTINGS_FILE}}
+          sed -i 's/"__OPENAI_API_KEY",/"${{ secrets.OPENAI_API_KEY }}",/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

@@ -3,4 +3,5 @@ IdentityServer_Audience=''
 Telegram__SalariesBotToken=''
 Telegram__GithubProfileBotToken=''
 OpenAiApi__Secret=''
-Telegram__GithubPATForLocalDevelopment=''
+Telegram__GithubPATForLocalDevelopment=''
+OpenAI__ApiKey=''

src/Domain/Entities/Companies/Company.cs

@@ -69,6 +69,16 @@ public List<CompanyReview> GetRelevantReviews()
             .ToList();
     }
 
+    public bool HasRelevantReviews()
+    {
+        if (Reviews == null)
+        {
+            throw new InvalidOperationException("Reviews are not initialized.");
+        }
+
+        return Reviews.Any(x => x.IsRelevant());
+    }
+
     public bool IsUserAllowedToLeaveReview(
         long userId)
     {

src/Infrastructure/Services/OpenAi/Custom/CustomOpenAiService.cs

@@ -0,0 +1,84 @@
+using System.Net.Http.Headers;
+using System.Text;
+using System.Text.Json;
+using Infrastructure.Jwt;
+using Infrastructure.Services.OpenAi.Custom.Models;
+using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.Logging;
+
+namespace Infrastructure.Services.OpenAi.Custom;
+
+public class CustomOpenAiService : ICustomOpenAiService
+{
+    private readonly IHttpClientFactory _httpClientFactory;
+    private readonly IConfiguration _configuration;
+    private readonly ILogger<CustomOpenAiService> _logger;
+
+    public CustomOpenAiService(
+        IHttpClientFactory httpClientFactory,
+        IConfiguration configuration,
+        ILogger<CustomOpenAiService> logger)
+    {
+        _httpClientFactory = httpClientFactory;
+        _configuration = configuration;
+        _logger = logger;
+    }
+
+    public string GetBearer()
+    {
+        var secret = _configuration["OpenAiApiSecret"];
+        return new TechinterviewJwtTokenGenerator(secret).ToString();
+    }
+
+    public async Task<string> GetAnalysisAsync(
+        OpenAiBodyReport report,
+        CancellationToken cancellationToken = default)
+    {
+        var apiUrl = _configuration["OpenAiApiUrl"];
+        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);
+            var request = new HttpRequestMessage(HttpMethod.Post, apiUrl);
+            request.Headers.Authorization = new AuthenticationHeaderValue("Bearer", GetBearer());
+            request.Content = new StringContent(
+                JsonSerializer.Serialize(report),
+                Encoding.UTF8,
+                "application/json");
+
+            var response = await client.SendAsync(request, cancellationToken);
+
+            responseContent = await response.Content.ReadAsStringAsync(cancellationToken);
+            if (response.IsSuccessStatusCode)
+            {
+                return responseContent;
+            }
+
+            _logger.LogError(
+                "Failed request to OpenAI {Url}. Status {Status}, Response {Response}",
+                apiUrl,
+                response.StatusCode,
+                responseContent);
+
+            return string.Empty;
+        }
+        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/Infrastructure/Services/OpenAi/Custom/ICustomOpenAiService.cs

@@ -0,0 +1,12 @@
+using Infrastructure.Services.OpenAi.Custom.Models;
+
+namespace Infrastructure.Services.OpenAi.Custom;
+
+public interface ICustomOpenAiService
+{
+    string GetBearer();
+
+    Task<string> GetAnalysisAsync(
+        OpenAiBodyReport report,
+        CancellationToken cancellationToken = default);
+}

src/Infrastructure/Services/OpenAi/Models/OpenAiBodyReport.cs → src/Infrastructure/Services/OpenAi/Custom/Models/OpenAiBodyReport.cs

@@ -1,7 +1,7 @@
 using Domain.Entities.Salaries;
 using Infrastructure.Salaries;
 
-namespace Infrastructure.Services.OpenAi.Models;
+namespace Infrastructure.Services.OpenAi.Custom.Models;
 
 public record OpenAiBodyReport
 {

src/Infrastructure/Services/OpenAi/Models/OpenAiBodyReportMetadata.cs → src/Infrastructure/Services/OpenAi/Custom/Models/OpenAiBodyReportMetadata.cs

@@ -1,6 +1,6 @@
 using Domain.Entities.Salaries;
 
-namespace Infrastructure.Services.OpenAi.Models;
+namespace Infrastructure.Services.OpenAi.Custom.Models;
 
 public record OpenAiBodyReportMetadata
 {

src/Infrastructure/Services/OpenAi/Models/OpenAiBodyReportRole.cs → src/Infrastructure/Services/OpenAi/Custom/Models/OpenAiBodyReportRole.cs

@@ -1,7 +1,7 @@
 using Domain.Entities.Salaries;
 using Domain.Entities.StatData;
 
-namespace Infrastructure.Services.OpenAi.Models;
+namespace Infrastructure.Services.OpenAi.Custom.Models;
 
 public record OpenAiBodyReportRole
 {

src/Infrastructure/Services/OpenAi/Models/OpenAiBodyReportRoleHistoricalDataItem.cs → src/Infrastructure/Services/OpenAi/Custom/Models/OpenAiBodyReportRoleHistoricalDataItem.cs

@@ -1,7 +1,7 @@
 using Domain.Entities.StatData;
 using Domain.Extensions;
 
-namespace Infrastructure.Services.OpenAi.Models;
+namespace Infrastructure.Services.OpenAi.Custom.Models;
 
 public record OpenAiBodyReportRoleHistoricalDataItem
 {

src/Infrastructure/Services/OpenAi/Models/OpenAiBodyReportRoleSalaryData.cs → src/Infrastructure/Services/OpenAi/Custom/Models/OpenAiBodyReportRoleSalaryData.cs

@@ -1,7 +1,7 @@
 using Domain.Entities.StatData;
 using Domain.Extensions;
 
-namespace Infrastructure.Services.OpenAi.Models;
+namespace Infrastructure.Services.OpenAi.Custom.Models;
 
 public record OpenAiBodyReportRoleSalaryData
 {

src/Infrastructure/Services/OpenAi/IOpenAiService.cs

@@ -1,12 +1,17 @@
-using Infrastructure.Services.OpenAi.Models;
+using Domain.Entities.Companies;
+using Infrastructure.Services.OpenAi.Models;
 
 namespace Infrastructure.Services.OpenAi;
 
 public interface IOpenAiService
 {
-    string GetBearer();
+    Task<OpenAiChatResult> AnalyzeCompanyAsync(
+        Company company,
+        string correlationId = null,
+        CancellationToken cancellationToken = default);
 
-    Task<string> GetAnalysisAsync(
-        OpenAiBodyReport report,
+    Task<OpenAiChatResult> AnalyzeChatAsync(
+        string input,
+        string correlationId = null,
         CancellationToken cancellationToken = default);
 }

src/Infrastructure/Services/OpenAi/Models/ChatMessage.cs

@@ -0,0 +1,24 @@
+using System.Text.Json.Serialization;
+
+namespace Infrastructure.Services.OpenAi.Models;
+
+public record ChatMessage
+{
+    public ChatMessage(
+        string role,
+        string content)
+    {
+        Role = role;
+        Content = content;
+    }
+
+    public ChatMessage()
+    {
+    }
+
+    [JsonPropertyName("role")]
+    public string Role { get; set; } // "user", "assistant", or "system"
+
+    [JsonPropertyName("content")]
+    public string Content { get; set; }
+}

src/Infrastructure/Services/OpenAi/Models/ChatRequest.cs

@@ -0,0 +1,15 @@
+using System.Text.Json.Serialization;
+
+namespace Infrastructure.Services.OpenAi.Models;
+
+public record ChatRequest
+{
+    [JsonPropertyName("model")]
+    public string Model { get; set; }
+
+    [JsonPropertyName("messages")]
+    public List<ChatMessage> Messages { get; set; }
+
+    [JsonPropertyName("temperature")]
+    public double Temperature { get; set; } = 0.7;
+}

src/Infrastructure/Services/OpenAi/Models/ChatResponse.cs

@@ -0,0 +1,9 @@
+using System.Text.Json.Serialization;
+
+namespace Infrastructure.Services.OpenAi.Models;
+
+public record ChatResponse
+{
+    [JsonPropertyName("choices")]
+    public List<Choice> Choices { get; set; }
+}

src/Infrastructure/Services/OpenAi/Models/Choice.cs

@@ -0,0 +1,9 @@
+using System.Text.Json.Serialization;
+
+namespace Infrastructure.Services.OpenAi.Models;
+
+public record Choice
+{
+    [JsonPropertyName("message")]
+    public ChatMessage Message { get; set; }
+}

src/Infrastructure/Services/OpenAi/Models/CompanyAnalyzeRequest.cs

@@ -0,0 +1,84 @@
+using Domain.Entities.Companies;
+
+namespace Infrastructure.Services.OpenAi.Models;
+
+internal record CompanyAnalyzeRequest
+{
+    public CompanyAnalyzeRequest(
+        Company company)
+    {
+        Name = company.Name;
+        Rating = company.Rating;
+        RatingHistoryRecords = company.RatingHistory?
+            .Select(history => new CompanyRatingHistoryItem(history))
+            .ToList();
+
+        Reviews = company.Reviews
+            .Select(x => new CompanyReviewData(x))
+            .ToList();
+    }
+
+    public double Rating { get; }
+
+    public string Name { get; }
+
+    public List<CompanyRatingHistoryItem> RatingHistoryRecords { get; }
+
+    public List<CompanyReviewData> Reviews { get; }
+}
+
+internal record CompanyReviewData
+{
+    public CompanyReviewData(
+        CompanyReview review)
+    {
+        Pros = review.Pros;
+        Cons = review.Cons;
+        CultureAndValues = review.CultureAndValues;
+        CodeQuality = review.CodeQuality;
+        WorkLifeBalance = review.WorkLifeBalance;
+        Management = review.Management;
+        CompensationAndBenefits = review.CompensationAndBenefits;
+        CareerOpportunities = review.CareerOpportunities;
+        TotalRating = review.TotalRating;
+        LikesCount = review.LikesCount;
+        DislikesCount = review.DislikesCount;
+        TotalRating = review.TotalRating;
+    }
+
+    public string Pros { get; }
+
+    public string Cons { get; }
+
+    public int CultureAndValues { get; }
+
+    public int? CodeQuality { get; }
+
+    public int WorkLifeBalance { get; }
+
+    public int Management { get; }
+
+    public int CompensationAndBenefits { get; }
+
+    public int CareerOpportunities { get; }
+
+    public double TotalRating { get; }
+
+    public int LikesCount { get; }
+
+    public int DislikesCount { get; }
+}
+
+internal record CompanyRatingHistoryItem
+{
+    public CompanyRatingHistoryItem(
+        CompanyRatingHistory history)
+    {
+        CreatedAt = history.CreatedAt;
+        Rating = history.Rating;
+    }
+
+    public DateTime CreatedAt { get; }
+
+    public double Rating { get; }
+}

src/Infrastructure/Services/OpenAi/Models/OpenAiChatResult.cs

@@ -0,0 +1,26 @@
+namespace Infrastructure.Services.OpenAi.Models;
+
+public record OpenAiChatResult
+{
+    public static OpenAiChatResult Success(List<Choice> choices)
+    {
+        return new OpenAiChatResult(true, choices);
+    }
+
+    public static OpenAiChatResult Failure()
+    {
+        return new OpenAiChatResult(false, new List<Choice>());
+    }
+
+    private OpenAiChatResult(
+        bool isSuccess,
+        List<Choice> choices)
+    {
+        IsSuccess = isSuccess;
+        Choices = choices;
+    }
+
+    public bool IsSuccess { get; }
+
+    public List<Choice> Choices { get; }
+}