stripe working woop woop

BookingMicroservice/BookingMicroservice.csproj

@@ -18,6 +18,7 @@
     </PackageReference>
     <PackageReference Include="Microsoft.VisualStudio.Azure.Containers.Tools.Targets" Version="1.19.6" />
     <PackageReference Include="Pomelo.EntityFrameworkCore.MySql" Version="8.0.2" />
+    <PackageReference Include="Stripe.net" Version="44.1.0" />
     <PackageReference Include="Swashbuckle.AspNetCore" Version="6.4.0" />
   </ItemGroup>
 

BookingMicroservice/Controllers/BookingController.cs

@@ -5,6 +5,7 @@ using Microsoft.AspNetCore.Authorization;
 using Microsoft.AspNetCore.Mvc;
 using System.Security.Claims;
 
+
 namespace BookingMicroservice.Controllers
 {
     [ApiController]
@@ -13,11 +14,13 @@ namespace BookingMicroservice.Controllers
     {
         private readonly IReservationComplianceService reservationComplianceService;
         private readonly IBookingService bookingService;
+        private readonly IStripeService stripeService;
 
-        public BookingController(IReservationComplianceService reservationComplianceService, IBookingService bookingService)
+        public BookingController(IReservationComplianceService reservationComplianceService, IBookingService bookingService,  IStripeService stripeService)
         {
             this.reservationComplianceService = reservationComplianceService;
             this.bookingService = bookingService;
+            this.stripeService = stripeService;
         }
 
         [Authorize]
@@ -46,14 +49,20 @@ namespace BookingMicroservice.Controllers
         [HttpPost()]
         public async Task<IActionResult> MakeBooking([FromBody] BookingCreation bookingCreationModel)
         {
-            // TODO: add stripe handling
+            
             string? userIdValue = User.FindFirst(ClaimTypes.NameIdentifier)?.Value;
             if (!int.TryParse(userIdValue, out int userId))
                 return BadRequest("Unable to get User Id from Token");
 
             try
             {
-                Booking? booking = await reservationComplianceService.TryCreateBookingAsync(bookingCreationModel.FlightId, userId, bookingCreationModel.BookingClass, bookingCreationModel.SeatId);
+                bool isPaymentSuccessful = await stripeService.VerifyPaymentIntent(bookingCreationModel.PaymentIntentId);
+                if (!isPaymentSuccessful)
+                {
+                    return BadRequest("Payment verification failed.");
+                }
+
+                Booking? booking = await reservationComplianceService.TryCreateBookingAsync(bookingCreationModel.FlightId, userId, bookingCreationModel.BookingClass, bookingCreationModel.SeatId, bookingCreationModel.PaymentIntentId);
                 if (booking == null)
                     return BadRequest("Error in creating booking");
 

BookingMicroservice/Models/BookingCreation.cs

@@ -5,5 +5,6 @@
         public required int FlightId { get; set; }
         public required BookingClass BookingClass { get; set; }
         public int? SeatId { get; set; }
+        public required string PaymentIntentId { get; set; }
     }
 }

BookingMicroservice/Program.cs

@@ -13,6 +13,7 @@ builder.Services.AddHttpContextAccessor();
 builder.Services.AddTransient<RequestCookieHandler>();
 builder.Services.AddControllers();
 builder.Services.AddEndpointsApiExplorer();
+builder.Services.AddLogging();
 builder.Services.AddSwaggerGen();
 
 builder.Services.AddDbContext<ApplicationDbContext>(options =>
@@ -59,6 +60,7 @@ builder.Services.AddHttpClient<IFlightServiceClient, FlightServiceClient>(client
 
 builder.Services.AddScoped<IBookingService, BookingService>();
 builder.Services.AddScoped<IReservationComplianceService, ReservationComplianceService>();
+builder.Services.AddScoped<IStripeService, StripeService>();
 
 var app = builder.Build();
 

BookingMicroservice/Services/BookingService.cs

@@ -30,7 +30,7 @@ namespace BookingMicroservice.Services
             return bookings;
         }
 
-        public Booking CreateBooking(int flightId, int userId, BookingClass bookingClass)
+        public Booking CreateBooking(int flightId, int userId, BookingClass bookingClass, string paymentIntentId)
         {
             Booking booking = new Booking(flightId, userId, bookingClass, null);
 

BookingMicroservice/Services/IBookingService.cs

@@ -4,7 +4,7 @@ namespace BookingMicroservice.Services
 {
     public interface IBookingService
     {
-        Booking CreateBooking(int flightId, int userId, BookingClass bookingClass);
+        Booking CreateBooking(int flightId, int userId, BookingClass bookingClass, string paymentIntentId);
         List<Booking> GetBookings(int? flightId = null, int? userId = null, BookingClass? bookingClass = null);
         Booking? GetBooking(int bookingId);
         void DeleteBooking(int bookingId);

BookingMicroservice/Services/IReservationComplianceService.cs

@@ -4,7 +4,7 @@ namespace BookingMicroservice.Services
 {
     public interface IReservationComplianceService
     {
-        Task<Booking?> TryCreateBookingAsync(int flightId, int userId, BookingClass bookingClass, int? seatId);
+        Task<Booking?> TryCreateBookingAsync(int flightId, int userId, BookingClass bookingClass, int? seatId, string paymentIntentId);
         Task TryBookSeatAsync(int bookingId, int seatId);
 
     }

BookingMicroservice/Services/IStripeService.cs

+using BookingMicroservice.Models;
+using Stripe;
+
+namespace BookingMicroservice.Services
+{
+    public interface IStripeService
+    {
+        Task<bool> VerifyPaymentIntent(string paymentIntentId);
+    }
+}
\ No newline at end of file

BookingMicroservice/Services/ReservationComplianceService.cs

@@ -18,7 +18,7 @@ namespace BookingMicroservice.Services
             this.flightServiceClient = flightServiceClient;
         }
 
-        public async Task<Booking?> TryCreateBookingAsync(int flightId, int userId, BookingClass bookingClass, int? seatId)
+        public async Task<Booking?> TryCreateBookingAsync(int flightId, int userId, BookingClass bookingClass, int? seatId, string paymentIntentId)
         {
             HttpResponseMessage capacityResponse = await flightServiceClient.GetFlightCapacityAsync(flightId, (int)bookingClass);
             if (!capacityResponse.IsSuccessStatusCode)
@@ -34,7 +34,7 @@ namespace BookingMicroservice.Services
             if (currentBookings >= capacity)
                 throw new BookingException(string.Format(NO_AVAILABLE_SEAT_MSG, bookingClass.ToString().ToLower()));
 
-            Booking booking = bookingService.CreateBooking(flightId, userId, bookingClass);
+            Booking booking = bookingService.CreateBooking(flightId, userId, bookingClass, paymentIntentId);
             if(seatId.HasValue && booking?.Id != null)
             {
                 try

BookingMicroservice/Services/StripeService.cs

+using BookingMicroservice.Models;
+using Microsoft.Extensions.Logging;
+using Microsoft.Extensions.Configuration;
+using Stripe;
+using System;
+using System.Threading.Tasks;
+
+namespace BookingMicroservice.Services
+{
+    public class StripeService : IStripeService
+    {
+        private readonly ILogger<StripeService> _logger;
+
+        public StripeService(ILogger<StripeService> logger, IConfiguration configuration)
+        {
+            _logger = logger; 
+            StripeConfiguration.ApiKey = configuration["Stripe:SecretKey"];
+        }
+
+        public async Task<bool> VerifyPaymentIntent(string paymentIntentId)
+        {
+            var service = new PaymentIntentService();
+            try
+            {
+                var paymentIntent = await service.GetAsync(paymentIntentId);
+                _logger.LogInformation($"Payment Intent Status: {paymentIntent.Status}");  
+                return paymentIntent.Status == "succeeded";
+            }
+            catch (StripeException ex)
+            {
+                _logger.LogError($"Error verifying payment intent: {ex.Message}"); 
+                throw new Exception("Failed to verify payment intent: " + ex.Message);
+            }
+        }
+    }
+}

BookingMicroservice/appsettings.json

@@ -16,5 +16,8 @@
   },
   "FlightMicroservice": {
     "BaseUrl": "http://localhost:5175"
+  },
+  "Stripe": {
+    "SecretKey": "sk_test_51P5UhOExQclpActcAn0yMrhaHESmCjtM69JOhjmo4B5AK67WwZn317QZmbunbuanwytn3xxhgVh6wfxEONorblgl00rQbt1YZk"
   }
 }

GatewayAPI/Models/BookingCreation.cs

@@ -5,6 +5,6 @@
         public required int FlightId { get; set; }
         public required int BookingClass { get; set; }
         public int? SeatId { get; set; }
-
+        public required string PaymentIntentId { get; set; }
     }
 }