initial cqrs with es version added

CqrsWithEs.Tests/TestData/CarsTestData.cs

@@ -0,0 +1,18 @@
+using System;
+using CqrsWithEs.Domain;
+
+namespace CqrsWithEs.Tests
+{
+    public class CarsTestData
+    {
+        public static Car OldFordFocus()
+        {
+            return new Car
+            (
+                "Ford Focus",
+                "WAW1010",
+                2005
+            );
+        }
+    }
+}

CqrsWithEs.Tests/TestData/OffersTestData.cs

@@ -0,0 +1,46 @@
+using System;
+using System.Collections.Generic;
+using CqrsWithEs.Domain;
+using NodaMoney;
+using NodaTime;
+
+namespace CqrsWithEs.Tests
+{
+    public class OffersTestData
+    {
+        public static Offer StandardOneYearOCOfferValidUntil(DateTime validityEnd)
+        {
+            var product = ProductsTestData.StandardCarInsurance(); 
+            return new Offer
+            (
+                Guid.NewGuid(), 
+                "1",
+                product,
+                PersonsTestData.Kowalski(),
+                PersonsTestData.Kowalski(),
+                CarsTestData.OldFordFocus(),
+                TimeSpan.FromDays(365), 
+                Money.Euro(500),
+                validityEnd.AddDays(-30),
+                new Dictionary<Cover, Money>()
+                {
+                    {product.CoverWithCode("OC"), Money.Euro(500) }
+                }
+            );
+        }
+
+        public static Offer RejectedOfferValidUntil(DateTime validityEnd)
+        {
+            var offer = StandardOneYearOCOfferValidUntil(validityEnd);
+            offer.Reject();
+            return offer;
+        }
+
+        public static Offer ConvertedOfferValidUntil(DateTime validityEnd)
+        {
+            var offer = StandardOneYearOCOfferValidUntil(validityEnd);
+            offer.Convert();
+            return offer;
+        }
+    }
+}

CqrsWithEs.Tests/TestData/PersonsTestData.cs

@@ -0,0 +1,18 @@
+using System;
+using CqrsWithEs.Domain;
+
+namespace CqrsWithEs.Tests
+{
+    public class PersonsTestData
+    {
+        public static Person Kowalski()
+        {
+            return new Person
+            (
+                "Jan",
+                "Kowalski",
+                "1111111116"
+            );
+        }
+    }
+}

CqrsWithEs.Tests/TestData/PolicyTestData.cs

@@ -0,0 +1,23 @@
+using System;
+using CqrsWithEs.Domain;
+
+namespace CqrsWithEs.Tests
+{
+    /*public static class PolicyTestData
+    {
+        public static Policy StandardOneYearPolicy(DateTime policyStartDate)
+        {
+            var offer = OffersTestData.StandardOneYearOCOfferValidUntil(policyStartDate.AddDays(10));
+            return Policy.ConvertOffer(offer, "POL0001", policyStartDate.AddDays(-1), policyStartDate);
+        }
+
+        public static Policy StandardOneYearPolicyTerminated(DateTime policyStartDate, DateTime policyTerminationDate)
+        {
+            var policy = StandardOneYearPolicy(policyStartDate);
+            policy.TerminatePolicy(policyTerminationDate);
+            policy.ConfirmChanges(2);
+
+            return policy;
+        }
+    }*/
+}

CqrsWithEs.Tests/TestData/ProductsTestData.cs

@@ -0,0 +1,25 @@
+using System;
+using System.Collections.Generic;
+using CqrsWithEs.Domain;
+
+namespace CqrsWithEs.Tests
+{
+    public class ProductsTestData
+    {
+        public static Product StandardCarInsurance()
+        {
+            return new Product
+            (
+                Guid.NewGuid(),
+                "STD_CAR_INSURANCE",
+                "Standard Car Insurance",
+                new List<Cover>
+                {
+                    new Cover(Guid.NewGuid(), "OC", "Third party liability"),
+                    new Cover(Guid.NewGuid(), "AC", "Auto casco"),
+                    new Cover(Guid.NewGuid(), "ASSISTANCE", "Assistance")
+                }
+            );
+        }
+    }
+}

CqrsWithEs/Commands/CreatePolicyCommand.cs

@@ -0,0 +1,17 @@
+using System;
+using MediatR;
+
+namespace CqrsWithEs.Commands
+{
+    public class CreatePolicyCommand : IRequest<CreatePolicyResult>
+    {
+        public string OfferNumber { get; set; }
+        public DateTime PurchaseDate { get; set; } 
+        public DateTime PolicyStartDate { get; set; }
+    }
+
+    public class CreatePolicyResult
+    {
+        public string PolicyNumber { get; set; }
+    }
+}

CqrsWithEs/Commands/CreatePolicyHandler.cs

@@ -0,0 +1,27 @@
+using System.Threading;
+using System.Threading.Tasks;
+using CqrsWithEs.Domain;
+using MediatR;
+
+namespace CqrsWithEs.Commands
+{
+    public class CreatePolicyHandler : IRequestHandler<CreatePolicyCommand, CreatePolicyResult>
+    {
+        private IOfferRepository offerRepository;
+
+        public CreatePolicyHandler(IOfferRepository offerRepository)
+        {
+            this.offerRepository = offerRepository;
+        }
+
+        public Task<CreatePolicyResult> Handle(CreatePolicyCommand request, CancellationToken cancellationToken)
+        {
+            var offer = offerRepository.WithNumber(request.OfferNumber);
+
+            return Task.FromResult(new CreatePolicyResult
+            {
+                PolicyNumber = null
+            });
+        }
+    }
+}

CqrsWithEs/Domain/AggregateRoot.cs

@@ -0,0 +1,40 @@
+using System;
+using System.Collections.Generic;
+using CqrsWithEs.Dragons;
+
+namespace CqrsWithEs.Domain
+{
+    public class AggregateRoot
+    {
+        private readonly List<Event> _changes = new List<Event>();
+
+        public Guid Id { get; protected set; }
+        public int Version { get; internal set; }
+
+        public IEnumerable<Event> GetUncommittedChanges() {
+            return _changes;
+        }
+
+        public void MarkChangesAsCommitted() {
+            _changes.Clear();
+        }
+
+        public void LoadsFromHistory(IEnumerable<Event> history) {
+            foreach (var e in history) ApplyChange(e, false);
+        }
+
+        protected void ApplyChange(Event @event) {
+            ApplyChange(@event, true);
+        }
+
+        // push atomic aggregate changes to local history for further processing (EventStore.SaveEvents)
+        private void ApplyChange(Event @event, bool isNew) {
+            this.AsDynamic().Apply(@event);
+            if (isNew) _changes.Add(@event);
+        }
+    }
+
+    public interface Message { }
+    public class Command : Message { }
+    public class Event : Message { }
+}

CqrsWithEs/Domain/Car.cs

@@ -0,0 +1,21 @@
+namespace CqrsWithEs.Domain
+{
+    public class Car
+    {
+        public string Make { get; private set; }
+        public string PlateNumber { get; private set; }
+        public int ProductionYear { get; private set; }
+
+        public Car(string make, string plateNumber, int productionYear)
+        {
+            Make = make;
+            PlateNumber = plateNumber;
+            ProductionYear = productionYear;
+        }
+
+        public Car Copy()
+        {
+            return new Car(Make, PlateNumber, ProductionYear);
+        }
+    }
+}

CqrsWithEs/Domain/Cover.cs

@@ -0,0 +1,25 @@
+using System;
+
+namespace CqrsWithEs.Domain
+{
+    public class Cover
+    {
+        public Guid Id { get; private set; }
+        public string Code { get; private set; }
+        public string Name { get; private set; }
+
+        public Cover(Guid id, string code, string name)
+        {
+            Id = id;
+            Code = code;
+            Name = name;
+        }
+
+        //required by EF
+        protected Cover()
+        {
+        }
+    }
+
+
+}

CqrsWithEs/Domain/IOfferRepository.cs

@@ -0,0 +1,14 @@
+using System.Collections.Generic;
+using System.Threading.Tasks;
+
+namespace CqrsWithEs.Domain
+{
+    public interface IOfferRepository
+    {
+        Task<Offer> WithNumber(string number);
+
+        Task<IReadOnlyList<Offer>> All();
+
+        void Add(Offer offer);
+    }
+}

CqrsWithEs/Domain/IProductRepository.cs

@@ -0,0 +1,14 @@
+using System.Collections.Generic;
+using System.Threading.Tasks;
+
+namespace CqrsWithEs.Domain
+{
+    public interface IProductRepository
+    {
+        void Add(Product product);
+
+        Task<Product> WithCode(string code);
+
+        Task<IReadOnlyList<Product>> All();
+    }
+}