Event Store

Author: brunobritodev

src/Backend/Jp.Application/AutoMapper/DomainToViewModelMappingProfile.cs

@@ -22,7 +22,7 @@ public DomainToViewModelMappingProfile()
             CreateMap<User, UserViewModel>(MemberList.Destination);//.ForMember(x => x.LockoutEnd, opt => opt.MapFrom(src => src.LockoutEnd != null ? src.LockoutEnd.Value.DateTime.ToShortDateString() : string.Empty));
             CreateMap<User, UserListViewModel>(MemberList.Destination);
 
-            CreateMap<StoredEvent, EventHistoryData>().ConstructUsing(a => new EventHistoryData() { Action = a.Message, Id = a.Id.ToString(), Details = a.Data, When = a.Timestamp.ToString(CultureInfo.InvariantCulture), Who = a.User, Category = a.MessageType });
+            CreateMap<StoredEvent, EventHistoryData>().ConstructUsing(a => new EventHistoryData(a.Message, a.Id.ToString(), a.Details, a.Timestamp.ToString(CultureInfo.InvariantCulture), a.User, a.MessageType, a.RemoteIpAddress));
             CreateMap<Client, ClientListViewModel>(MemberList.Destination);
             CreateMap<IdentityServer4.EntityFramework.Entities.Secret, SecretViewModel>(MemberList.Destination);
             CreateMap<IdentityServer4.EntityFramework.Entities.ClientProperty, ClientPropertyViewModel>();

src/Backend/Jp.Application/EventSourcedNormalizers/EventHistoryData.cs

@@ -1,12 +1,26 @@
-namespace Jp.Application.EventSourcedNormalizers
+using Jp.Domain.Core.Events;
+
+namespace Jp.Application.EventSourcedNormalizers
 {
     public class EventHistoryData
     {
-        public string Category { get; set; }
-        public string Action { get; set; }
-        public string Id { get; set; }
-        public string When { get; set; }
-        public string Who { get; set; }
-        public string Details { get; set; }
+        public EventHistoryData(string action, string id, EventDetails details, string when, string who, string category, string ip)
+        {
+            Action = action;
+            Id = id;
+            When = when;
+            Who = who;
+            Category = category;
+            Ip = ip;
+            Details = details?.Metadata;
+        }
+
+        public string Category { get; }
+        public string Ip { get; }
+        public string Action { get; }
+        public string Id { get; }
+        public string When { get; }
+        public string Who { get; }
+        public string Details { get; }
     }
 }

src/Backend/Jp.Application/Interfaces/IUserManageAppService.cs

@@ -17,7 +17,7 @@ public interface IUserManageAppService : IDisposable
         Task CreatePassword(SetPasswordViewModel model);
         Task RemoveAccount(RemoveAccountViewModel model);
         Task<bool> HasPassword(Guid userId);
-        Task<IEnumerable<EventHistoryData>> GetHistoryLogs(string username);
+        Task<ListOf<EventHistoryData>> GetEvents(string username, PagingViewModel paging);
 
         Task<UserViewModel> GetUserDetails(string username);
         Task<UserViewModel> GetUserAsync(Guid value);
@@ -33,6 +33,6 @@ public interface IUserManageAppService : IDisposable
         Task RemoveLogin(RemoveUserLoginViewModel model);
         Task<IEnumerable<UserListViewModel>> GetUsersInRole(string role);
         Task ResetPassword(AdminChangePasswordViewodel model);
-        Task<ListOfUsersViewModel> GetUsers(PagingViewModel page);
+        Task<ListOf<UserListViewModel>> GetUsers(PagingViewModel page);
     }
 }

src/Backend/Jp.Application/Services/UserManagerAppService.cs

@@ -80,17 +80,18 @@ public Task<bool> HasPassword(Guid userId)
             return _userService.HasPassword(userId);
         }
 
-        public async Task<IEnumerable<EventHistoryData>> GetHistoryLogs(string username)
+        public async Task<ListOf<EventHistoryData>> GetEvents(string username, PagingViewModel paging)
         {
-            var history = await _eventStoreRepository.All(username);
-            return _mapper.Map<IEnumerable<EventHistoryData>>(history);
+            var history = await _eventStoreRepository.GetEvents(username, paging);
+            var total = await _eventStoreRepository.Count(username, paging.Search);
+            return new ListOf<EventHistoryData>(_mapper.Map<IEnumerable<EventHistoryData>>(history), total);
         }
 
-        public async Task<ListOfUsersViewModel> GetUsers(PagingViewModel paging)
+        public async Task<ListOf<UserListViewModel>> GetUsers(PagingViewModel paging)
         {
             var users = await _userService.GetUsers(paging);
             var total = await _userService.Count(paging.Search);
-            return new ListOfUsersViewModel(_mapper.Map<IEnumerable<UserListViewModel>>(users), total);
+            return new ListOf<UserListViewModel>(_mapper.Map<IEnumerable<UserListViewModel>>(users), total);
         }
 
         public async Task<UserViewModel> GetUserDetails(string username)

src/Backend/Jp.Application/ViewModels/UserViewModels/UserListViewModel.cs

@@ -1,5 +1,4 @@
 using System;
-using System.Collections.Generic;
 using System.ComponentModel.DataAnnotations;
 
 namespace Jp.Application.ViewModels.UserViewModels
@@ -22,16 +21,4 @@ public class UserListViewModel
         public Guid? Id { get; set; }
     }
 
-    public class ListOfUsersViewModel
-    {
-        public ListOfUsersViewModel(IEnumerable<UserListViewModel> collection, int total) 
-        {
-            Total = total;
-            Users = collection;
-        }
-
-        public IEnumerable<UserListViewModel> Users { get; set; }
-
-        public int Total { get; set; }
-    }
 }

src/Backend/Jp.Domain.Core/Events/Event.cs

@@ -14,22 +14,7 @@ public abstract class Event : Message, INotification
         public DateTime Timestamp { get; protected set; }
 
         public EventTypes EventType { get; set; }
-        /// <summary>
-        /// Gets or sets the local ip address of the current request.
-        /// </summary>
-        /// <value>
-        /// The local ip address.
-        /// </value>
-        public string LocalIpAddress { get; set; }
-
-        /// <summary>
-        /// Gets or sets the remote ip address of the current request.
-        /// </summary>
-        /// <value>
-        /// The remote ip address.
-        /// </value>
-        public string RemoteIpAddress { get; set; }
-
+        
         /// <summary>
         /// Gets or sets the event message.
         /// </summary>
@@ -41,7 +26,7 @@ public abstract class Event : Message, INotification
         protected Event() { }
         protected Event(EventTypes eventType)
         {
-            Timestamp = DateTime.Now;
+            Timestamp = DateTime.UtcNow;
         }
     }
 }

src/Backend/Jp.Domain.Core/Events/EventDetails.cs

@@ -0,0 +1,18 @@
+using System;
+
+namespace Jp.Domain.Core.Events
+{
+    public class EventDetails
+    {
+        protected EventDetails() { }
+        public EventDetails(Guid id, string metadata)
+        {
+            EventId = id;
+            Metadata = metadata;
+        }
+
+        public Guid EventId { get; set; }
+        public string Metadata { get; set; }
+        public StoredEvent Event { get; set; }
+    }
+}

src/Backend/Jp.Domain.Core/Events/IEventStore.cs

@@ -1,7 +1,9 @@
-namespace Jp.Domain.Core.Events
+using System.Threading.Tasks;
+
+namespace Jp.Domain.Core.Events
 {
     public interface IEventStore
     {
-        void Save<T>(T theEvent) where T : Event;
+        Task Save<T>(T theEvent) where T : Event;
     }
 }

src/Backend/Jp.Domain.Core/Events/StoredEvent.cs

@@ -5,7 +5,6 @@ namespace Jp.Domain.Core.Events
     public class StoredEvent : Event
     {
         public StoredEvent(
-            string aggregateId,
             string messageType,
             EventTypes eventType,
             string customMessage,
@@ -14,13 +13,12 @@ public StoredEvent(
             string data) : base(eventType)
         {
             Id = Guid.NewGuid();
-            AggregateId = aggregateId;
             MessageType = messageType;
             EventType = eventType;
             Message = customMessage;
             LocalIpAddress = localIpAddress;
             RemoteIpAddress = remoteIpAddress;
-            Data = data;
+            Details = new EventDetails(Id, data);
         }
 
         public StoredEvent SetUser(string user)
@@ -33,14 +31,36 @@ public StoredEvent SetUser(string user)
         protected StoredEvent() { }
 
         public Guid Id { get; private set; }
+        /// <summary>
+        /// Gets or sets the local ip address of the current request.
+        /// </summary>
+        /// <value>
+        /// The local ip address.
+        /// </value>
+        public string LocalIpAddress { get; set; }
 
-        public string Data { get; private set; }
+        /// <summary>
+        /// Gets or sets the remote ip address of the current request.
+        /// </summary>
+        /// <value>
+        /// The remote ip address.
+        /// </value>
+        public string RemoteIpAddress { get; set; }
 
         public string User { get; private set; }
+        public EventDetails Details { get; set; }
+
         public StoredEvent ReplaceTimeStamp(in DateTime timeStamp)
         {
             Timestamp = timeStamp;
             return this;
         }
+
+        public StoredEvent SetAggregate(string aggregateId)
+        {
+            AggregateId = aggregateId;
+            return this;
+        }
     }
+
 }

src/Backend/Jp.Domain.Core/StringUtils/StringExtensions.cs

@@ -25,7 +25,7 @@ public static bool IsPresent(this string value)
         public static string AddSpacesToSentence(this string state)
         {
             var text = state.ToCharArray();
-            var chars = new char[text.Length + HowManyCapitalizedChars(text)];
+            var chars = new char[text.Length + HowManyCapitalizedChars(text)-1];
 
             chars[0] = text[0];
             int j = 1;