Merge pull request #4 from 01Dri/development

0.1.0

Author: 01Dri

MapperAI.sln.DotSettings.user

@@ -1,7 +1,11 @@
 <wpf:ResourceDictionary xml:space="preserve" xmlns:x="http://schemas.microsoft.com/winfx/2006/xaml" xmlns:s="clr-namespace:System;assembly=mscorlib" xmlns:ss="urn:shemas-jetbrains-com:settings-storage-xaml" xmlns:wpf="http://schemas.microsoft.com/winfx/2006/xaml/presentation">
+	<s:String x:Key="/Default/CodeInspection/ExcludedFiles/FilesAndFoldersToSkip2/=7020124F_002D9FFC_002D4AC3_002D8F3D_002DAAB8E0240759_002Ff_003AHttpClient_002Ecs_002Fl_003A_002E_002E_003F_002E_002E_003F_002E_002E_003F_002E_002E_003FAppData_003FRoaming_003FJetBrains_003FRider2024_002E3_003Fresharper_002Dhost_003FSourcesCache_003Fc439425da351c75ac7d966a1cc8324b51a9c471865af79d2f2f3fcb65e392_003FHttpClient_002Ecs/@EntryIndexedValue">ForceIncluded</s:String>
 	<s:String x:Key="/Default/Environment/UnitTesting/UnitTestSessionStore/Sessions/=5ca51f47_002De3fa_002D40db_002D8e16_002D940aee47c197/@EntryIndexedValue">&lt;SessionState ContinuousTestingMode="0" IsActive="True" Name="Test_Should_Create_4_Files_With_CSharp_Extension" xmlns="urn:schemas-jetbrains-com:jetbrains-ut-session"&gt;&#xD;
   &lt;TestAncestor&gt;&#xD;
     &lt;TestId&gt;xUnit::8B3E109D-96CA-4B6D-B379-6AF70646DC25::net8.0::MapperAI.Test.FileMapperTests.Test_Should_Create_4_Files_With_CSharp_Extension&lt;/TestId&gt;&#xD;
+    &lt;TestId&gt;xUnit::8B3E109D-96CA-4B6D-B379-6AF70646DC25::net8.0::MapperAI.Test.ClassMapperTests.Test1&lt;/TestId&gt;&#xD;
+    &lt;TestId&gt;xUnit::8B3E109D-96CA-4B6D-B379-6AF70646DC25::net8.0::MapperAI.Test.PdfMapperTests.Test1&lt;/TestId&gt;&#xD;
+    &lt;TestId&gt;xUnit::8B3E109D-96CA-4B6D-B379-6AF70646DC25::net8.0::MapperAI.Test.FileMapperTests.Test_Should_Create_4_Files_With_Go_Extension&lt;/TestId&gt;&#xD;
   &lt;/TestAncestor&gt;&#xD;
 &lt;/SessionState&gt;</s:String>
 	<s:String x:Key="/Default/Environment/UnitTesting/UnitTestSessionStore/Sessions/=ee3fe810_002Dfb62_002D402b_002Db9c5_002D8dab803c815e/@EntryIndexedValue">&lt;SessionState ContinuousTestingMode="0" Name="Test1" xmlns="urn:schemas-jetbrains-com:jetbrains-ut-session"&gt;&#xD;

src/MapperAI.Core/Clients/ClientBaseAI.cs

@@ -0,0 +1,63 @@
+using System.Text.Json;
+using MapperAI.Core.Clients.Interfaces;
+using MapperAI.Core.Clients.Models;
+using MapperAI.Core.Exceptions;
+using MapperAI.Core.Serializers.Interfaces;
+
+namespace MapperAI.Core.Clients;
+
+public class GeminiMapperMapperClient : MapperClientBase, IMapperClient
+{
+  private const string EndpointBase = "https://generativelanguage.googleapis.com/v1beta";
+
+  public GeminiMapperMapperClient(MapperClientConfiguration mapperClientConfiguration, IMapperSerializer serializer) : base(
+    mapperClientConfiguration, serializer)
+  {
+  }
+
+  public async Task<MapperClientResponse> SendAsync(string prompt, CancellationToken cancellationToken)
+  {
+    dynamic payload = CreatePayload(prompt);
+    string endpoint =
+      $"{EndpointBase}/models/{MapperClientConfiguration.Model}:generateContent?key={MapperClientConfiguration.ApiKey}";
+    using JsonDocument result = await GetAsync(endpoint, payload, cancellationToken);
+    string? resultParsed = ParseResponse(result);
+    if (resultParsed == null) throw new MapperException("Result request from AI is null.");
+    string cleanedResult = resultParsed
+      .Replace("```json", string.Empty)
+      .Replace("```", string.Empty)
+      .Replace("\\$", "\\\\$")
+      .Trim();
+
+    return new MapperClientResponse(cleanedResult);
+  }
+
+  private dynamic CreatePayload(string promptText)
+  {
+    return new
+    {
+      contents = new[]
+      {
+        new
+        {
+          parts = new[]
+          {
+            new { text = promptText }
+          }
+        }
+      }
+    };
+}
+
+
+private string? ParseResponse(JsonDocument response)
+  => response
+    .RootElement
+    .GetProperty("candidates")[0]
+    .GetProperty("content")
+    .GetProperty("parts")[0]
+    .GetProperty("text")
+    .GetString();
+  
+  
+}

src/MapperAI.Core/Clients/ClientFactoryAI.cs

@@ -0,0 +1,9 @@
+using MapperAI.Core.Clients.Models;
+
+namespace MapperAI.Core.Clients.Interfaces;
+
+public interface IMapperClient
+{
+    Task<MapperClientResponse> SendAsync(string prompt, CancellationToken cancellationToken);
+
+}

src/MapperAI.Core/Clients/GeminiClientAI.cs

@@ -0,0 +1,8 @@
+using MapperAI.Core.Clients.Models;
+
+namespace MapperAI.Core.Clients.Interfaces;
+
+public interface IMapperClientFactory
+{
+    IMapperClient CreateClient(MapperClientConfiguration configuration);
+}

src/MapperAI.Core/Clients/GeminiMapperMapperClient.cs

@@ -0,0 +1,44 @@
+using System.Text;
+using System.Text.Json;
+using MapperAI.Core.Clients.Models;
+using MapperAI.Core.Exceptions;
+using MapperAI.Core.Serializers.Interfaces;
+
+namespace MapperAI.Core.Clients;
+
+public abstract class MapperClientBase
+{
+    protected MapperClientConfiguration MapperClientConfiguration;
+    private readonly HttpClient _httpClient;
+    private readonly IMapperSerializer _serializer;
+
+    protected MapperClientBase(MapperClientConfiguration mapperClientConfiguration,  IMapperSerializer serializer)
+    {
+        MapperClientConfiguration = mapperClientConfiguration;
+        _httpClient = new HttpClient();
+        _serializer = serializer;
+    }
+
+    protected async Task<JsonDocument> GetAsync(string endpoint, object body, CancellationToken cancellationToken = default)
+    {
+        try
+        {
+            string json = _serializer.Serialize(body);
+            StringContent mediaTypeRequest = new(json, Encoding.UTF8, "application/json");
+            HttpResponseMessage response = await _httpClient.PostAsync(endpoint, mediaTypeRequest, cancellationToken);
+            if (!response.IsSuccessStatusCode)
+            {
+                throw new MapperRequestStatusException($"Request failed with status: {response.StatusCode}");
+            }
+
+            string result = await response.Content.ReadAsStringAsync();
+            return JsonDocument.Parse(result);
+        } 
+        catch (Exception ex)
+        {
+            throw new MapperException($"An error occurred during processing: {ex.Message}");
+        }
+
+    }
+    
+}