Merge pull request #18 from THC-Software/reservation_cancelation_fix

Reservation cancelation fix

Author: CengoleFHV

Application/Handlers/Events/ReservationEventHandler.cs

@@ -56,6 +56,24 @@ public async Task Handle(TechnicalReservationEvent reservationEvent, Cancellatio
 
     private async Task HandleReservationCancelledEvent(TechnicalReservationEvent reservationEvent)
     {
+        var existingPlayOffer = await _playOfferRepository.GetPlayOfferByReservationId(reservationEvent.EntityId);
+        if (existingPlayOffer != null)
+        {
+            var playOfferEvent = new BaseEvent
+            {
+                EventId = Guid.NewGuid(),
+                EntityId = existingPlayOffer.Id,
+                EventType = EventType.PLAYOFFER_CANCELLED,
+                EntityType = EntityType.PLAYOFFER,
+                Timestamp = DateTime.UtcNow,
+                CorrelationId = reservationEvent.EventId,
+                EventData = new PlayOfferCancelledEvent()
+            };
+            
+            await _writeEventRepository.AppendEvent(playOfferEvent);
+            await _writeEventRepository.Update();
+        }
+        
         var existingReservation = await _reservationRepository.GetReservationById(reservationEvent.EntityId);
         existingReservation!.Apply([reservationEvent]);
     }

Domain/Repositories/PlayOfferRepository.cs

@@ -50,6 +50,14 @@ public async Task<List<PlayOffer>> GetPlayOffersByParticipantId(Guid participant
 
         return playOffer;
     }
+    
+    public async Task<PlayOffer?> GetPlayOfferByReservationId(Guid reservationId)
+    {
+        return await _context.PlayOffers
+            .Where(e => e.ReservationId == reservationId)
+            .FirstOrDefaultAsync();
+    }
+
 
     public async Task Update()
     {

PlayOfferService.Tests/IntegrationTests/PlayOfferRepositoryTest.cs

@@ -13,6 +13,7 @@ public async Task PlayOfferSetup()
                 Id = Guid.Parse("d79f0bd6-c7ec-44e5-a02f-26e1567b0992"),
                 ClubId = Guid.Parse("34f13619-14b5-4244-a74b-6a8ba210a0b1"),
                 CreatorId = Guid.Parse("9b30e631-3ad8-4437-a934-94252d6294c4"),
+                ReservationId = Guid.Parse("b5fab7b7-63f1-4847-a71c-ae37dbfed029")
             },
             new()
             {
@@ -98,6 +99,7 @@ public async Task GetPlayOffersByCreatorIdTest()
     }
 
     [Test]
+
     public async Task GetPlayOffersByOpponentIdTest()
     {
         //Given

PlayOfferService.Tests/IntegrationTests/ReservationEventHandlerTest.cs

@@ -23,6 +23,21 @@ public async Task ReservationSetup()
         };
         TestReservationRepository.CreateReservation(existingReservation);
         await TestReservationRepository.Update();
+
+        var existingPlayOffer = new PlayOffer
+        {
+            Id = Guid.Parse("f515dc74-46ad-4a7b-b4f2-8dfda4b7506f"),
+            ClubId = Guid.Parse("6031061f-86c6-459b-9260-5b4772bae9d3"),
+            CreatorId = Guid.Parse("844b93a3-fce8-4d8f-8a8d-38da07a9c11f"),
+            ProposedStartTime = DateTime.UtcNow,
+            ProposedEndTime = DateTime.UtcNow.AddHours(3),
+            AcceptedStartTime = DateTime.UtcNow.AddHours(1),
+            ReservationId = Guid.Parse("da9ff928-cfb2-4b98-9388-937905556706"),
+            OpponentId = Guid.Parse("13158d40-c04f-49e8-aa0c-b2473145ceaf"),
+            IsCancelled = false
+        };
+        TestPlayOfferRepository.CreatePlayOffer(existingPlayOffer);
+        await TestPlayOfferRepository.Update();
     }
 
     [Test]
@@ -83,6 +98,10 @@ public async Task ReservationCancelledEvent_ProjectionTest()
         await Mediator.Send(reservationCancelledEvent);
 
         // Then
+        var playOfferEvents = await TestWriteEventRepository.GetEventByEntityId(Guid.Parse("f515dc74-46ad-4a7b-b4f2-8dfda4b7506f"));
+        Assert.That(playOfferEvents, Has.Count.EqualTo(1));
+        Assert.That(playOfferEvents[0].EventType, Is.EqualTo(EventType.PLAYOFFER_CANCELLED));
+        
         var projectedReservation = await TestReservationRepository.GetReservationById(reservationCancelledEvent.EntityId);
 
         Assert.That(projectedReservation, Is.Not.Null);