Adding Microsoft.AspNetCore.Http nuget to use IHttpCnotextAccessor to…

… get a json body from request. New customfields migration.

AzureDevopsTracker/AzureDevopsTracker.csproj

@@ -24,8 +24,9 @@
   </PropertyGroup>
 
   <ItemGroup>
+    <PackageReference Include="Microsoft.AspNetCore.Http" Version="2.2.2" />
     <PackageReference Include="Microsoft.EntityFrameworkCore.SqlServer" Version="5.0.0" />
-    <PackageReference Include="Microsoft.AspNetCore.Http.Abstractions" Version="2.0.0" />
+    <PackageReference Include="Microsoft.AspNetCore.Http.Abstractions" Version="2.2.0" />
     <PackageReference Include="System.Net.Http.Json" Version="5.0.0" />
   </ItemGroup>
 

AzureDevopsTracker/Configurations/Configuration.cs

@@ -6,6 +6,7 @@
 using AzureDevopsTracker.Interfaces.Internals;
 using AzureDevopsTracker.Services;
 using Microsoft.AspNetCore.Builder;
+using Microsoft.AspNetCore.Http;
 using Microsoft.EntityFrameworkCore;
 using Microsoft.Extensions.DependencyInjection;
 using System;
@@ -21,6 +22,8 @@ public static IServiceCollection AddAzureDevopsTracker(this IServiceCollection s
 
             services.AddMessageIntegrations();
 
+            services.AddSingleton<IHttpContextAccessor, HttpContextAccessor>();
+
             services.AddScoped<AzureDevopsTrackerContext>();
             services.AddScoped<IWorkItemAdapter, WorkItemAdapter>();
             services.AddScoped<IWorkItemRepository, WorkItemRepository>();
@@ -44,7 +47,7 @@ private static IServiceCollection AddMessageIntegrations(this IServiceCollection
                 case EMessengers.MICROSOFT_TEAMS:
                     services.AddScoped<MessageIntegration, MicrosoftTeamsIntegration>();
                     break;
-                default: 
+                default:
                     services.AddScoped<MessageIntegration, FakeIntegration>();
                     break;
             }

AzureDevopsTracker/Data/Mapping/WorkItemCustomFieldMapping.cs → AzureDevopsTracker/Data/Mapping/CustomFieldMapping.cs

@@ -4,11 +4,17 @@
 
 namespace AzureDevopsTracker.Data.Mapping
 {
-    public class WorkItemCustomFieldMapping : IEntityTypeConfiguration<WorkItemCustomField>
+    public class CustomFieldMapping : IEntityTypeConfiguration<WorkItemCustomField>
     {
         public void Configure(EntityTypeBuilder<WorkItemCustomField> builder)
         {
             builder.HasKey(k => new { k.WorkItemId, k.Key });
+
+            builder.Property(p => p.Key)
+                   .HasColumnType("varchar(1000)");
+
+            builder.Property(p => p.Value)
+                   .HasColumnType("varchar(max)");
         }
     }
 }

AzureDevopsTracker/Entities/WorkItem.cs

@@ -122,7 +122,7 @@ public void AddCustomField(WorkItemCustomField customField)
 
         public void AddCustomFields(IEnumerable<WorkItemCustomField> customFields)
         {
-            if (customFields is not null && !customFields.Any())
+            if (customFields is null || !customFields.Any())
                 return;
 
             foreach (var customField in customFields)
@@ -131,7 +131,7 @@ public void AddCustomFields(IEnumerable<WorkItemCustomField> customFields)
 
         public void UpdateCustomFields(IEnumerable<WorkItemCustomField> newCustomFields)
         {
-            if (newCustomFields is not null && !newCustomFields.Any())
+            if (newCustomFields is null || !newCustomFields.Any())
                 return;
 
             _workItemCustomFields.Clear();

AzureDevopsTracker/Entities/WorkItemCustomField.cs

@@ -14,8 +14,8 @@ public class WorkItemCustomField
         public WorkItemCustomField(string workItemId, string key, string value)
         {
             WorkItemId = workItemId;
-            Key = key;
-            Value = value;
+            Key = key.Truncate(1000);
+            Value = value.Truncate();
         }
 
         public void Update(string value)

AzureDevopsTracker/Extensions/HelperExtenions.cs

@@ -11,6 +11,12 @@ public static bool IsNullOrEmpty(this string text)
             return string.IsNullOrEmpty(text?.Trim());
         }
 
+        public static string Truncate(this string value, int maxLength = 8000)
+        {
+            if (value.IsNullOrEmpty()) return value;
+            return value.Length <= maxLength ? value : value[..maxLength];
+        }
+
         public static string ExtractEmail(this string user)
         {
             if (user is null)

AzureDevopsTracker/Migrations/20220620220028_CustomFields.cs → AzureDevopsTracker/Migrations/20220621163011_CustomFields.cs

@@ -13,8 +13,8 @@ protected override void Up(MigrationBuilder migrationBuilder)
                 columns: table => new
                 {
                     WorkItemId = table.Column<string>(type: "varchar(200)", nullable: false),
-                    Key = table.Column<string>(type: "varchar(200)", nullable: false),
-                    Value = table.Column<string>(type: "varchar(200)", nullable: true)
+                    Key = table.Column<string>(type: "varchar(1000)", nullable: false),
+                    Value = table.Column<string>(type: "varchar(max)", nullable: true)
                 },
                 constraints: table =>
                 {

AzureDevopsTracker/Migrations/AzureDevopsStateTrackerContextModelSnapshot.cs

@@ -207,10 +207,10 @@ protected override void BuildModel(ModelBuilder modelBuilder)
                         .HasColumnType("varchar(200)");
 
                     b.Property<string>("Key")
-                        .HasColumnType("varchar(200)");
+                        .HasColumnType("varchar(1000)");
 
                     b.Property<string>("Value")
-                        .HasColumnType("varchar(200)");
+                        .HasColumnType("varchar(max)");
 
                     b.HasKey("WorkItemId", "Key");
 

AzureDevopsTracker/Services/AzureDevopsTrackerService.cs

@@ -9,10 +9,10 @@
 using AzureDevopsTracker.Interfaces;
 using AzureDevopsTracker.Interfaces.Internals;
 using Microsoft.AspNetCore.Http;
-using Microsoft.Extensions.DependencyInjection;
-using Newtonsoft.Json;
 using System;
+using System.IO;
 using System.Linq;
+using System.Text;
 using System.Threading.Tasks;
 
 namespace AzureDevopsTracker.Services
@@ -22,18 +22,18 @@ public class AzureDevopsTrackerService : IAzureDevopsTrackerService
         public readonly IWorkItemRepository _workItemRepository;
         public readonly IWorkItemAdapter _workItemAdapter;
         public readonly IChangeLogItemRepository _changeLogItemRepository;
-        private readonly IServiceScopeFactory _serviceScopeFactory;
+        private readonly IHttpContextAccessor _httpContextAccessor;
 
         public AzureDevopsTrackerService(
             IWorkItemAdapter workItemAdapter,
             IWorkItemRepository workItemRepository,
             IChangeLogItemRepository changeLogItemRepository,
-            IServiceScopeFactory serviceScopeFactory)
+            IHttpContextAccessor httpContextAccessor)
         {
             _workItemAdapter = workItemAdapter;
             _workItemRepository = workItemRepository;
             _changeLogItemRepository = changeLogItemRepository;
-            _serviceScopeFactory = serviceScopeFactory;
+            _httpContextAccessor = httpContextAccessor;
         }
 
         public async Task Create(CreateWorkItemDTO create, bool addWorkItemChange = true)
@@ -60,7 +60,7 @@ public async Task Create(CreateWorkItemDTO create, bool addWorkItemChange = true
 
             CheckWorkItemAvailableToChangeLog(workItem, create.Resource.Fields);
 
-            ManipulateCustomFields(workItem);
+            AddCustomFields(workItem);
 
             await _workItemRepository.Add(workItem);
             await _workItemRepository.SaveChangesAsync();
@@ -108,7 +108,7 @@ public async Task Update(UpdatedWorkItemDTO update)
 
             CheckWorkItemAvailableToChangeLog(workItem, update.Resource.Revision.Fields);
 
-            ManipulateCustomFields(workItem);
+            AddCustomFields(workItem);
 
             _workItemRepository.Update(workItem);
             await _workItemRepository.SaveChangesAsync();
@@ -140,7 +140,7 @@ public async Task Delete(DeleteWorkItemDTO delete)
                 delete.Resource.Fields.Activity,
                 delete.Resource.Fields.Lancado);
 
-            ManipulateCustomFields(workItem);
+            AddCustomFields(workItem);
 
             _workItemRepository.Update(workItem);
             await _workItemRepository.SaveChangesAsync();
@@ -172,7 +172,7 @@ public async Task Restore(RestoreWorkItemDTO restore)
                 restore.Resource.Fields.Activity,
                 restore.Resource.Fields.Lancado);
 
-            ManipulateCustomFields(workItem);
+            AddCustomFields(workItem);
 
             _workItemRepository.Update(workItem);
             await _workItemRepository.SaveChangesAsync();
@@ -188,15 +188,15 @@ public async Task<WorkItemDTO> GetByWorkItemId(string workItemId)
         }
 
         #region Support Methods
-        public void ManipulateCustomFields(WorkItem workItem)
+        public void AddCustomFields(WorkItem workItem)
         {
             try
             {
-                var json = GetRequestBody();
-                if (json.IsNullOrEmpty())
+                var jsonText = GetRequestBody();
+                if (jsonText.IsNullOrEmpty())
                     return;
 
-                var customFields = ReadJsonHelper.ReadJson(workItem.Id, json);
+                var customFields = ReadJsonHelper.ReadJson(workItem.Id, jsonText);
                 if (customFields is null || !customFields.Any())
                     return;
 
@@ -208,9 +208,18 @@ public void ManipulateCustomFields(WorkItem workItem)
 
         public string GetRequestBody()
         {
-            using var scope = _serviceScopeFactory.CreateScope();
-            var httpContext = scope.ServiceProvider.GetService<IHttpContextAccessor>();
-            return httpContext?.HttpContext?.Request?.Body?.ToString();
+            string corpo;
+            var request = _httpContextAccessor?.HttpContext?.Request;
+            using (StreamReader reader = new(request.Body,
+                                             encoding: Encoding.UTF8,
+                                             detectEncodingFromByteOrderMarks: false,
+                                             leaveOpen: true))
+            {
+                request.Body.Position = 0;
+                corpo = reader.ReadToEndAsync()?.Result;
+            }
+
+            return corpo;
         }
 
         public WorkItemChange ToWorkItemChange(