feat: allow for reserving

App/Modules/Bookings/API/V1/BookingController.cs

@@ -1,6 +1,7 @@
 using System.Net.Mime;
 using App.Error.V1;
 using App.Modules.Common;
+using App.Modules.Timings.API.V1;
 using App.StartUp.Registry;
 using App.StartUp.Services.Auth;
 using App.Utility;
@@ -21,6 +22,7 @@ public class BookingController(
   IBookingService service,
   CreateBookingReqValidator createBookingReqValidator,
   BookingSearchQueryValidator bookingSearchQueryValidator,
+  ReserveBookingQueryValidator reserveBookingQueryValidator,
   IAuthHelper authHelper,
   ILogger<BookingController> logger,
   IBookingImageEnricher enrich
@@ -39,6 +41,18 @@ public async Task<ActionResult<IEnumerable<BookingPrincipalRes>>> Search([FromQu
     return this.ReturnResult(x);
   }
 
+  [Authorize(Policy = AuthPolicies.AdminOrTin)]
+  [HttpGet("reserve/{Direction}/{Date}/{Time}")]
+  public async Task<ActionResult<BookingPrincipalRes>> Reserve([FromRoute] ReserveBookingQuery query)
+  {
+    var book = await reserveBookingQueryValidator.ValidateAsyncResult(query, "Invalid ReserveBookingQuery")
+      .ThenAwait(q => service.Reserve(
+        q.Direction.DirectionToDomain(), q.Date.ToDate(), q.Time.ToTime()))
+      .Then(x => x?.ToRes(), Errors.MapAll)
+      .ThenAwait(x => Utils.ToNullableTaskResultOr(x, r => enrich.Enrich(r)));
+    return this.ReturnNullableResult(book, new EntityNotFound("Booking not found", typeof(Booking), $"{query.Direction}-{query.Date}-{query.Time}"));
+  }
+
   [Authorize, HttpGet("{userId}/{id:guid}")]
   public async Task<ActionResult<BookingRes>> Get(string userId, Guid id)
   {

App/Modules/Bookings/API/V1/BookingModel.cs

@@ -4,6 +4,8 @@ namespace App.Modules.Bookings.API.V1;
 
 public record SearchBookingQuery(string? Date, string? Direction, string? Time, string? UserId, int? Limit, int? Skip);
 
+public record ReserveBookingQuery(string Date, string Direction, string Time);
+
 // REQ
 public record BookingPassengerReq(string FullName, string Gender, string PassportExpiry, string PassportNumber);
 

App/Modules/Bookings/API/V1/BookingValidator.cs

@@ -75,3 +75,17 @@ public BookingSearchQueryValidator()
       .Skip();
   }
 }
+
+public class ReserveBookingQueryValidator : AbstractValidator<ReserveBookingQuery>
+{
+  public ReserveBookingQueryValidator()
+  {
+    this.RuleFor(x => x.Date)
+      .DateValid();
+    this.RuleFor(x => x.Time)
+      .TimeValid();
+    this.RuleFor(x => x.Direction)
+      .NotNull()
+      .TrainDirectionValid();
+  }
+}

App/Modules/Bookings/Data/BookingRepository.cs

@@ -4,6 +4,7 @@
 using App.Utility;
 using CSharp_Result;
 using Domain.Booking;
+using Domain.Timings;
 using EntityFramework.Exceptions.Common;
 using Microsoft.EntityFrameworkCore;
 
@@ -156,6 +157,32 @@ public async Task<Result<BookingPrincipal>> Create(string userId, BookingRecord
     }
   }
 
+  public async Task<Result<BookingPrincipal?>> Reserve(TrainDirection direction, DateOnly date, TimeOnly time)
+  {
+    try
+    {
+      logger.LogInformation("Reserve Booking '{direction}' '{Date}' '{Time}'", direction, date, time);
+
+      var v1 = await db.Bookings
+        .Where(x =>
+          x.Direction == direction.ToData()
+          && x.Date == date
+          && x.Time == time
+          && x.Status == (int)BookStatus.Pending
+        )
+        .OrderBy(x => x.CreatedAt)
+        .FirstOrDefaultAsync();
+      return v1?.ToPrincipal();
+    }
+
+    catch (Exception e)
+    {
+      logger.LogError(e, "Failed to reserve Booking '{direction}' '{Date}' '{Time}'", direction,
+        date, time);
+      return e;
+    }
+  }
+
   public async Task<Result<Unit?>> Delete(string? userId, Guid id)
   {
     try

Domain/Booking/IService.cs

@@ -1,4 +1,5 @@
 using CSharp_Result;
+using Domain.Timings;
 
 namespace Domain.Booking;
 
@@ -12,6 +13,8 @@ public interface IBookingService
 
   Task<Result<BookingPrincipal?>> Update(string? userId, Guid id, BookingRecord record);
 
+  Task<Result<BookingPrincipal?>> Reserve(TrainDirection direction, DateOnly date, TimeOnly time);
+
   Task<Result<BookingPrincipal?>> Buying(Guid id);
 
   Task<Result<BookingPrincipal?>> Complete(Guid id, Stream ticketFile);

Domain/Booking/Model.cs

@@ -12,6 +12,8 @@ public enum BookStatus
   Cancelled = 3,
 }
 
+
+
 public record BookingSearch
 {
   public DateOnly? Date { get; init; }

Domain/Booking/Repository.cs

@@ -1,4 +1,5 @@
 using CSharp_Result;
+using Domain.Timings;
 
 namespace Domain.Booking;
 
@@ -10,7 +11,10 @@ public interface IBookingRepository
 
   Task<Result<BookingPrincipal>> Create(string userId, BookingRecord record);
 
-  Task<Result<BookingPrincipal?>> Update(string? userId, Guid id, BookingStatus? status, BookingRecord? record, BookingComplete? complete);
+  Task<Result<BookingPrincipal?>> Update(string? userId, Guid id, BookingStatus? status, BookingRecord? record,
+    BookingComplete? complete);
+
+  Task<Result<BookingPrincipal?>> Reserve(TrainDirection direction, DateOnly date, TimeOnly Time);
 
   Task<Result<Unit?>> Delete(string? userId, Guid id);
 

Domain/Booking/Service.cs

@@ -1,4 +1,5 @@
 using CSharp_Result;
+using Domain.Timings;
 using Microsoft.Extensions.Logging;
 
 namespace Domain.Booking;
@@ -26,6 +27,11 @@ public Task<Result<BookingPrincipal>> Create(string userId, BookingRecord record
     return repo.Update(userId, id, null, record, null);
   }
 
+  public Task<Result<BookingPrincipal?>> Reserve(TrainDirection direction, DateOnly date, TimeOnly time)
+  {
+    return repo.Reserve(direction, date, time);
+  }
+
   public Task<Result<BookingPrincipal?>> Buying(Guid id)
   {
     return repo.Update(null, id, new BookingStatus() { Status = BookStatus.Buying, CompletedAt = null }, null, null);