connected booking service with event service successfully. using FeignClient. Also created a API gateway so that we can access same port eg:8080 but Eureka does the work of finding the correct service based on the endpoint hit

Author: Yash-vs9

.idea/encodings.xml

@@ -0,0 +1,25 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>stream-seat</artifactId>
+        <groupId>com.streamseat</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>api-gateway</artifactId>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-gateway</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
+        </dependency>
+    </dependencies>
+</project>

api-gateway/pom.xml

@@ -0,0 +1,7 @@
+package com.streamseat;
+
+public class Main {
+    public static void main(String[] args) {
+        System.out.println("Hello, World!");
+    }
+}

api-gateway/src/main/java/com/streamseat/Main.java

@@ -0,0 +1,11 @@
+package com.streamseat.apigateway;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class ApiGatewayApplication {
+    public static void main(String[] args) {
+        SpringApplication.run(ApiGatewayApplication.class, args);
+    }
+}

api-gateway/src/main/java/com/streamseat/apigateway/ApiGatewayApplication.java

@@ -0,0 +1,18 @@
+spring.application.name=api-gateway
+server.port=8080
+
+# Connect to Eureka
+eureka.client.service-url.defaultZone=http://localhost:8761/eureka/
+
+# --- ROUTING RULES ---
+
+# Route 1: Events
+# "lb://" means Load Balance using Eureka!
+spring.cloud.gateway.routes[0].id=event-service
+spring.cloud.gateway.routes[0].uri=lb://event-service
+spring.cloud.gateway.routes[0].predicates[0]=Path=/api/events/**
+
+# Route 2: Bookings
+spring.cloud.gateway.routes[1].id=booking-service
+spring.cloud.gateway.routes[1].uri=lb://booking-service
+spring.cloud.gateway.routes[1].predicates[0]=Path=/api/bookings/**

api-gateway/src/main/resources/application.properties

@@ -0,0 +1,17 @@
+package com.streamseat.bookingservice.client;
+
+import com.streamseat.bookingservice.dto.EventDTO;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+
+// NAME must match the name in Eureka (EVENT-SERVICE)
+@FeignClient(name = "event-service")
+public interface EventClient {
+
+    // We are "mapping" the call to the Event Service's existing endpoint
+    // GET http://event-service/api/events/{id}
+    // (Note: We need to go add this endpoint to Event Service later if it's missing!)
+    @GetMapping("/api/events/{id}")
+    EventDTO getEventById(@PathVariable("id") Long id);
+}

booking-service/src/main/java/com/streamseat/bookingservice/client/EventClient.java

@@ -0,0 +1,45 @@
+package com.streamseat.bookingservice.controller;
+
+import com.streamseat.bookingservice.client.EventClient;
+import com.streamseat.bookingservice.dto.EventDTO;
+import com.streamseat.bookingservice.model.Booking;
+import com.streamseat.bookingservice.repository.BookingRepository;
+import org.springframework.web.bind.annotation.*;
+import java.time.LocalDateTime;
+
+@RestController
+@RequestMapping("/api/bookings")
+public class BookingController {
+
+    private final BookingRepository bookingRepository;
+    private final EventClient eventClient; // <--- The connection to Event Service
+
+    public BookingController(BookingRepository bookingRepository, EventClient eventClient) {
+        this.bookingRepository = bookingRepository;
+        this.eventClient = eventClient;
+    }
+
+    @PostMapping
+    public String bookTicket(@RequestBody Booking bookingRequest) {
+        Long eventId = bookingRequest.getEventId();
+
+        // 1. TALK to Event Service: "Does this event exist?"
+        EventDTO event = eventClient.getEventById(eventId);
+        if (event == null) {
+            return "Failed: Event not found!";
+        }
+
+        // 2. CHECK Capacity: "Are there seats left?"
+        long seatsTaken = bookingRepository.countByEventId(eventId);
+        if (seatsTaken >= event.getCapacity()) {
+            return "Failed: Housefull! Event is sold out.";
+        }
+
+        // 3. BOOK IT
+        bookingRequest.setStatus("CONFIRMED");
+        bookingRequest.setBookingTime(LocalDateTime.now());
+        bookingRepository.save(bookingRequest);
+
+        return "Success! Ticket booked for event: " + event.getTitle();
+    }
+}

booking-service/src/main/java/com/streamseat/bookingservice/controller/BookingController.java

@@ -0,0 +1,12 @@
+package com.streamseat.bookingservice.dto;
+
+import lombok.Data;
+import java.time.LocalDateTime;
+
+@Data
+public class EventDTO {
+    private Long id;
+    private String title;
+    private int capacity;
+//    private LocalDateTime eventDateTime;
+}

booking-service/src/main/java/com/streamseat/bookingservice/dto/EventDTO.java

@@ -0,0 +1,25 @@
+package com.streamseat.bookingservice.model;
+
+import jakarta.persistence.*;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import java.time.LocalDateTime;
+
+@Entity
+@Table(name = "bookings")
+@Data
+@Builder
+@NoArgsConstructor
+@AllArgsConstructor
+public class Booking {
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Long id;
+
+    private Long eventId;    // Which event?
+    private Long userId;     // Who booked it? (We'll hardcode this for now)
+    private String status;   // CONFIRMED, CANCELLED
+    private LocalDateTime bookingTime;
+}

booking-service/src/main/java/com/streamseat/bookingservice/model/Booking.java

@@ -0,0 +1,9 @@
+package com.streamseat.bookingservice.repository;
+
+import com.streamseat.bookingservice.model.Booking;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+public interface BookingRepository extends JpaRepository<Booking, Long> {
+    // Custom query to count how many tickets are sold for an event
+    long countByEventId(Long eventId);
+}