From f44e3bdd2b2c8aa61b4f4d48c68f84339853dd71 Mon Sep 17 00:00:00 2001
From: Alejandro Sarmiento <alejandrosarsan@protonmail.com>
Date: Mon, 1 Apr 2024 14:33:28 +0200
Subject: [PATCH] revisar que se ha hecho aqui

---
 .../Contracts/Persistence/IAsyncRepository.cs    |   4 ++--
 .../Contracts/Persistence/IUnitOfWork.cs         |   2 +-
 .../Commands/CreateVideo/CreateVideoCommand.cs   |   1 +
 .../CreateVideo/CreateVideoCommandHandler.cs     |   2 +-
 .../UpdateVideo/UpdateStreamerCommand.cs         |   2 ++
 .../UpdateVideo/UpdateStreamerCommandHandler.cs  |   2 +-
 .../Persistence/StreamerDbContext.cs             |  10 ++++++----
 .../Persistence/StreamerDbContextSeed.cs         |   4 ++--
 .../Repositories/RepositoryBase.cs               |   8 ++++----
 .../Repositories/UnitOfWork.cs                   |   4 ++--
 CleanArchitecture/comandos.txt                   | Bin 0 -> 2254 bytes
 CleanArchitecture/kubernetes-deploy.yaml         |   4 ++--
 12 files changed, 24 insertions(+), 19 deletions(-)
 create mode 100644 CleanArchitecture/comandos.txt

diff --git a/CleanArchitecture/CleanArchitecture.Application/Contracts/Persistence/IAsyncRepository.cs b/CleanArchitecture/CleanArchitecture.Application/Contracts/Persistence/IAsyncRepository.cs
index 8b81289..5af9010 100644
--- a/CleanArchitecture/CleanArchitecture.Application/Contracts/Persistence/IAsyncRepository.cs
+++ b/CleanArchitecture/CleanArchitecture.Application/Contracts/Persistence/IAsyncRepository.cs
@@ -17,8 +17,8 @@ namespace CleanArchitecture.Application.Contracts.Persistence
                                                                 bool disableTracking = true);
         Task<T> GetByIdAsync(Guid id);
 
-        Task<T> AddAsync(T entity);
-        Task<T> UpdateAsync(T entity);
+        Task<T> AddAsync(T entity, string userThatMakesAction = "");
+        Task<T> UpdateAsync(T entity, string userThatMakesAction = "");
         Task DeleteAsync(T entity);
 
         void AddEntity(T entity);
diff --git a/CleanArchitecture/CleanArchitecture.Application/Contracts/Persistence/IUnitOfWork.cs b/CleanArchitecture/CleanArchitecture.Application/Contracts/Persistence/IUnitOfWork.cs
index 1c5bacb..a1c071b 100644
--- a/CleanArchitecture/CleanArchitecture.Application/Contracts/Persistence/IUnitOfWork.cs
+++ b/CleanArchitecture/CleanArchitecture.Application/Contracts/Persistence/IUnitOfWork.cs
@@ -9,6 +9,6 @@ namespace CleanArchitecture.Application.Contracts.Persistence
         IVideoRepository VideoRepository { get; }
         IAsyncRepository<T> Repository<T>() where T : BaseDomainModel;
 
-        Task<int> Complete();
+        Task<int> Complete(string userThatMakesAction = "");
     }
 }
diff --git a/CleanArchitecture/CleanArchitecture.Application/Features/Videos/Commands/CreateVideo/CreateVideoCommand.cs b/CleanArchitecture/CleanArchitecture.Application/Features/Videos/Commands/CreateVideo/CreateVideoCommand.cs
index 985e283..f930b46 100644
--- a/CleanArchitecture/CleanArchitecture.Application/Features/Videos/Commands/CreateVideo/CreateVideoCommand.cs
+++ b/CleanArchitecture/CleanArchitecture.Application/Features/Videos/Commands/CreateVideo/CreateVideoCommand.cs
@@ -7,5 +7,6 @@ namespace CleanArchitecture.Application.Features.Videos.Commands.CreateVideo
     {
         public string Nombre { get; set; } = string.Empty;
         public Guid StreamerId { get; set; }
+        public string UserThatMakesAction { get; set; } = string.Empty; 
     }
 }
diff --git a/CleanArchitecture/CleanArchitecture.Application/Features/Videos/Commands/CreateVideo/CreateVideoCommandHandler.cs b/CleanArchitecture/CleanArchitecture.Application/Features/Videos/Commands/CreateVideo/CreateVideoCommandHandler.cs
index 041f36f..87edc4a 100644
--- a/CleanArchitecture/CleanArchitecture.Application/Features/Videos/Commands/CreateVideo/CreateVideoCommandHandler.cs
+++ b/CleanArchitecture/CleanArchitecture.Application/Features/Videos/Commands/CreateVideo/CreateVideoCommandHandler.cs
@@ -21,7 +21,7 @@ namespace CleanArchitecture.Application.Features.Videos.Commands.CreateVideo
         {
             var videoEntity = mapper.Map<Video>(request);
             unitOfWork.VideoRepository.AddEntity(videoEntity);
-            var response = await unitOfWork.Complete();
+            var response = await unitOfWork.Complete(request.UserThatMakesAction);
             if(response > 0)
             {
                 logger.LogInformation($"Video {videoEntity.Id} is successfully created.");
diff --git a/CleanArchitecture/CleanArchitecture.Application/Features/Videos/Commands/UpdateVideo/UpdateStreamerCommand.cs b/CleanArchitecture/CleanArchitecture.Application/Features/Videos/Commands/UpdateVideo/UpdateStreamerCommand.cs
index 7fd5233..93f839d 100644
--- a/CleanArchitecture/CleanArchitecture.Application/Features/Videos/Commands/UpdateVideo/UpdateStreamerCommand.cs
+++ b/CleanArchitecture/CleanArchitecture.Application/Features/Videos/Commands/UpdateVideo/UpdateStreamerCommand.cs
@@ -7,6 +7,8 @@ namespace CleanArchitecture.Application.Features.Videos.Commands.UpdateVideo
     {
         public Guid Id { get; set; }
         public string Nombre { get; set; } = string.Empty;
+
+        public string UserThatMakesAction { get; set; } = string.Empty;
         
     }
 }
diff --git a/CleanArchitecture/CleanArchitecture.Application/Features/Videos/Commands/UpdateVideo/UpdateStreamerCommandHandler.cs b/CleanArchitecture/CleanArchitecture.Application/Features/Videos/Commands/UpdateVideo/UpdateStreamerCommandHandler.cs
index 067fe6c..a720012 100644
--- a/CleanArchitecture/CleanArchitecture.Application/Features/Videos/Commands/UpdateVideo/UpdateStreamerCommandHandler.cs
+++ b/CleanArchitecture/CleanArchitecture.Application/Features/Videos/Commands/UpdateVideo/UpdateStreamerCommandHandler.cs
@@ -33,7 +33,7 @@ namespace CleanArchitecture.Application.Features.Videos.Commands.UpdateVideo
             mapper.Map(request, videoToUpdate, typeof(UpdateVideoCommand), typeof(Video));
 
             unitOfWork.VideoRepository.UpdateEntity(videoToUpdate);
-            await unitOfWork.Complete();
+            await unitOfWork.Complete(request.UserThatMakesAction);
 
             logger.LogInformation($"Video {videoToUpdate.Id} is successfully updated.");
 
diff --git a/CleanArchitecture/CleanArchitecture.Data/Persistence/StreamerDbContext.cs b/CleanArchitecture/CleanArchitecture.Data/Persistence/StreamerDbContext.cs
index 5d3ce1d..b8eebbf 100644
--- a/CleanArchitecture/CleanArchitecture.Data/Persistence/StreamerDbContext.cs
+++ b/CleanArchitecture/CleanArchitecture.Data/Persistence/StreamerDbContext.cs
@@ -30,19 +30,21 @@ namespace CleanArchitecture.Infrastructure.Persistence
         //        .EnableSensitiveDataLogging();
         //}
 
-        public override Task<int> SaveChangesAsync(CancellationToken cancellationToken = default)
+        public Task<int> SaveChangesAsync(string? userThatMakesAction = "", CancellationToken cancellationToken = default)
         {
+            userThatMakesAction = userThatMakesAction ?? "System";
+
             foreach (var entry in ChangeTracker.Entries<BaseDomainModel>())
             {
                 switch (entry.State)
                 {
                     case EntityState.Modified:
-                        entry.Entity.LastModifiedBy = "System";
+                        entry.Entity.LastModifiedBy = userThatMakesAction;
                         entry.Entity.LastModifiedDate = DateTime.Now;
                         break;
                     case EntityState.Added:
-                        entry.Entity.CreatedDate = DateTime.Now;
-                        entry.Entity.CreatedBy = "System";
+                        entry.Entity.CreatedBy = userThatMakesAction;
+                        entry.Entity.CreatedDate = DateTime.Now;                        
                         break;
                     case EntityState.Detached:
                         break;
diff --git a/CleanArchitecture/CleanArchitecture.Data/Persistence/StreamerDbContextSeed.cs b/CleanArchitecture/CleanArchitecture.Data/Persistence/StreamerDbContextSeed.cs
index f3899e8..644d890 100644
--- a/CleanArchitecture/CleanArchitecture.Data/Persistence/StreamerDbContextSeed.cs
+++ b/CleanArchitecture/CleanArchitecture.Data/Persistence/StreamerDbContextSeed.cs
@@ -6,12 +6,12 @@ namespace CleanArchitecture.Infrastructure.Persistence
     public class StreamerDbContextSeed
     {
 
-        public static async Task SeedAsync(StreamerDbContext context, ILogger<StreamerDbContextSeed> logger)
+        public static async Task SeedAsync(StreamerDbContext context, ILogger<StreamerDbContextSeed> logger, string userThatMakesAction = "")
         {
             if (!context.Streamers.Any())
             {
                 context.AddRange(GetPreconfiguredStreamers());
-                await context.SaveChangesAsync();
+                await context.SaveChangesAsync(userThatMakesAction);
                 logger.LogInformation("Seed database associated with context {DbContextName} executed", typeof(StreamerDbContext).Name);
             }
         }
diff --git a/CleanArchitecture/CleanArchitecture.Data/Repositories/RepositoryBase.cs b/CleanArchitecture/CleanArchitecture.Data/Repositories/RepositoryBase.cs
index 4642777..e6148ca 100644
--- a/CleanArchitecture/CleanArchitecture.Data/Repositories/RepositoryBase.cs
+++ b/CleanArchitecture/CleanArchitecture.Data/Repositories/RepositoryBase.cs
@@ -60,18 +60,18 @@ namespace CleanArchitecture.Infrastructure.Repositories
             return await context.Set<T>().FindAsync(id);
         }
 
-        public async Task<T> AddAsync(T entity)
+        public async Task<T> AddAsync(T entity, string userThatMakesAction = "")
         {
             context.Set<T>().Add(entity);
-            await context.SaveChangesAsync();
+            await context.SaveChangesAsync(userThatMakesAction);
             return entity;
         }
 
-        public async Task<T> UpdateAsync(T entity)
+        public async Task<T> UpdateAsync(T entity, string userThatMakesAction = "")
         {
             context.Set<T>().Attach(entity);
             context.Entry(entity).State = EntityState.Modified;
-            await context.SaveChangesAsync();
+            await context.SaveChangesAsync(userThatMakesAction);
             return entity;
         }
 
diff --git a/CleanArchitecture/CleanArchitecture.Data/Repositories/UnitOfWork.cs b/CleanArchitecture/CleanArchitecture.Data/Repositories/UnitOfWork.cs
index 8fa6670..6111630 100644
--- a/CleanArchitecture/CleanArchitecture.Data/Repositories/UnitOfWork.cs
+++ b/CleanArchitecture/CleanArchitecture.Data/Repositories/UnitOfWork.cs
@@ -24,9 +24,9 @@ namespace CleanArchitecture.Infrastructure.Repositories
 
         public  StreamerDbContext StreamerDbContext => context;
 
-        public async Task<int> Complete()
+        public async Task<int> Complete(string userThatMakesAction = "")
         {
-            return await context.SaveChangesAsync();
+            return await context.SaveChangesAsync(userThatMakesAction);
         }
 
         public void Dispose()
diff --git a/CleanArchitecture/comandos.txt b/CleanArchitecture/comandos.txt
new file mode 100644
index 0000000000000000000000000000000000000000..54db35ad2190034e8ce7300c5bab06eb2a77f1cc
GIT binary patch
literal 2254
zcmeH{!AiqG5QhJ=;5&pO-dbo?lok)A6%-1J=q;C+hFaZfNmHSSudaTxcFiH8UW9;U
z$n5USX0!X{pM87X)|MjdOk?~&kD6hL9vF`_rOkZa=4`A=An<Fd2_N%StG=~~1OkCy
zq&EC^d7ibS6Lj~at}fKql}>f62HNZ@*0mNWGRMcL)X~4AjhQ#chV%<RzC_6hN;U;g
z$e)wV=#RX&w{LtdVXY}Ki`;8TG*ikNj&WNpb##P3RPWEf-}~a+4ZZwObtS(JGt+ey
ze@AKvnUs^xJc+`eJf}Y=ZWJc)C>R^nfhTOYK_5=3Zr3>@v?P-KYEJmqb!<z1d+>7*
zsN*i{yQh-h{wKc{stC1|qn*s_X~E4n_BwMYZADeBe1*DyO}ylH0Ea;B;|7Z0W4D@v
PR0OXL)oL9Wzwo>Rx&qf%

literal 0
HcmV?d00001

diff --git a/CleanArchitecture/kubernetes-deploy.yaml b/CleanArchitecture/kubernetes-deploy.yaml
index 0c7c7b2..da0198c 100644
--- a/CleanArchitecture/kubernetes-deploy.yaml
+++ b/CleanArchitecture/kubernetes-deploy.yaml
@@ -3,7 +3,7 @@ kind: Deployment
 metadata:
   name: clean-architecture-deployment
 spec:
-  replicas: 2
+  replicas: 16
   selector:
     matchLabels:
       app: clean-architecture-backend
@@ -14,7 +14,7 @@ spec:
     spec:
       containers:
       - name: clean-architecture-backend
-        image: dockerregistry.alexdev.es/clean-architecture-backend:0.0.48
+        image: dockerregistry.alexdev.es/clean-architecture-backend:0.0.59
         ports:
         - containerPort: 80
       imagePullSecrets: