Connect Booking Service with Gateway

.env

@@ -10,7 +10,7 @@ DB_USER=user
 DB_PASSWORD=user
 DB_CHARSET=utf8mb4
 
-# Keeping these for dev perposes, will remove at the end
+# Keeping these for dev purposes, will remove at the end
 #DB_PORT=3308
 #DB_NAME=AspNetCoreDb
 #DB_USER=root

GatewayAPI/Clients/BookingService/BookingServiceClient.cs

+using GatewayAPI.Models;
+using Microsoft.AspNetCore.WebUtilities;
+
+namespace GatewayAPI.Clients.BookingService
+{
+    public class BookingServiceClient : IBookingServiceClient
+    {
+        private readonly HttpClient httpClient;
+        private const string API_PATH = "api/Booking";
+
+        public BookingServiceClient(HttpClient httpClient)
+        {
+            this.httpClient = httpClient;
+        }
+
+        public Task<HttpResponseMessage> GetBookingAsync(int id)
+        {
+            return httpClient.GetAsync($"{API_PATH}/{id}");
+        }
+
+        public Task<HttpResponseMessage> GetBookingsAsync(int? flightId = null, int? userId = null, int? bookingClass = null)
+        {
+            Dictionary<string, string?> queryParams = new Dictionary<string, string?>();
+
+            if (flightId.HasValue)
+                queryParams.Add("flightId", flightId.Value.ToString());
+            
+            if (userId.HasValue)
+                queryParams.Add("userId", userId.Value.ToString());
+
+            if (bookingClass.HasValue)
+                queryParams.Add("bookingClass", bookingClass.Value.ToString());
+
+            string url = QueryHelpers.AddQueryString(API_PATH, queryParams);
+
+            return httpClient.GetAsync(url);
+        }
+
+        public Task<HttpResponseMessage> MakeBookingAsync(BookingCreation bookingModel)
+        {
+            return httpClient.PostAsJsonAsync($"{API_PATH}", bookingModel);
+        }
+
+        public Task<HttpResponseMessage> UpdateBookingAsync(int bookindId, BookingUpdate bookingModel)
+        {
+            return httpClient.PutAsJsonAsync($"{API_PATH}/{bookindId}", bookingModel);
+        }
+
+
+    }
+}

GatewayAPI/Clients/BookingService/IBookingServiceClient.cs

+using GatewayAPI.Models;
+
+namespace GatewayAPI.Clients.BookingService
+{
+    public interface IBookingServiceClient
+    {
+        Task<HttpResponseMessage> GetBookingAsync(int id);
+        Task<HttpResponseMessage> GetBookingsAsync(int? flightId = null, int? userId = null, int? bookingClass = null);
+        Task<HttpResponseMessage> MakeBookingAsync(BookingCreation bookingModel);
+        Task<HttpResponseMessage> UpdateBookingAsync(int bookindId, BookingUpdate bookingModel);    }
+}

GatewayAPI/Controllers/BookingController.cs

+using GatewayAPI.Clients.BookingService;
+using GatewayAPI.Models;
+using Microsoft.AspNetCore.Mvc;
+
+namespace GatewayAPI.Controllers
+{
+
+    [ApiController]
+    [Route("api/[Controller]")]
+    public class BookingController : ControllerBase
+    {
+        private readonly IBookingServiceClient bookingServiceClient;
+
+        public BookingController(IBookingServiceClient bookingServiceClient)
+        {
+            this.bookingServiceClient = bookingServiceClient;
+        }
+
+        [HttpGet("{id}")]
+        public async Task<IActionResult> GetBooking(int id) 
+        {
+            HttpResponseMessage response = await bookingServiceClient.GetBookingAsync(id);
+            return new HttpResponseMessageResult(response);
+        }
+
+        [HttpGet()]
+        public async Task<IActionResult> GetBookings(int? flightId = null, int? userId = null, int? bookingClass = null)
+        {
+            HttpResponseMessage response = await bookingServiceClient.GetBookingsAsync(flightId, userId, bookingClass);
+            return new HttpResponseMessageResult(response);
+        }
+
+        [HttpPost()]
+        public async Task<IActionResult> MakeBooking([FromBody] BookingCreation bookingCreationModel)
+        {
+            HttpResponseMessage response = await bookingServiceClient.MakeBookingAsync(bookingCreationModel);
+            return new HttpResponseMessageResult(response);
+        }
+
+        [HttpPut("{id}")]
+        public async Task<IActionResult> UpdateBooking([FromRoute] int id, [FromBody] BookingUpdate bookingUpdateModel)
+        {
+            HttpResponseMessage response = await bookingServiceClient.UpdateBookingAsync(id, bookingUpdateModel);
+            return new HttpResponseMessageResult(response);
+        }
+    }
+}

GatewayAPI/Models/BookingCreation.cs

+namespace GatewayAPI.Models
+{
+    public class BookingCreation
+    {
+        public required int FlightId { get; set; }
+        public required int BookingClass { get; set; }
+        public int? SeatId { get; set; }
+
+    }
+}

GatewayAPI/Models/BookingUpdate.cs

+namespace GatewayAPI.Models
+{
+    public class BookingUpdate
+    {
+        public required int SeatId { get; set; }
+    }
+}

GatewayAPI/ServiceCollectionExtensions.cs

-using GatewayAPI.Clients.FlightService;
+using GatewayAPI.Clients.BookingService;
+using GatewayAPI.Clients.FlightService;
 using GatewayAPI.Clients.UserService;
 using System.Runtime.CompilerServices;
 
@@ -20,6 +21,12 @@ namespace GatewayAPI
                 client.BaseAddress = new Uri(baseUrl.EndsWith("/") ? baseUrl : baseUrl + "/");
             }).AddHttpMessageHandler<RequestCookieHandler>();
 
+            services.AddHttpClient<IBookingServiceClient, BookingServiceClient>(client =>
+            {
+                string baseUrl = configurationManager["BookingMicroservice:BaseUrl"] ?? throw new InvalidOperationException("BookingMicroservice BaseUrl is not configured.");
+                client.BaseAddress = new Uri(baseUrl.EndsWith("/") ? baseUrl : baseUrl + "/");
+            }).AddHttpMessageHandler<RequestCookieHandler>();
+
             return services;
         }
     }