Added get ticketing info by reference number endpoint and update payment methods to dynamic

apps/edr-passenger-api/src/modules/payments/payments.module.ts

@@ -1,60 +1,23 @@
 import { Module } from "@nestjs/common";
 import { HttpModule } from "@nestjs/axios";
-import { ConfigService } from "@nestjs/config";
-import { RabbitMQModule } from "@golevelup/nestjs-rabbitmq";
-import {
-  PAYMENT_EVENTS_DLX,
-  PAYMENT_EVENTS_EXCHANGE,
-  PAYMENT_QUEUES,
-  PaymentService,
-  paymentServiceBindingPattern,
-} from "@edr/types";
 import { PaymentsController } from "./payments.controller";
 import { PaymentsService } from "./payments.service";
 import { InternalPaymentsController } from "./internal-payments.controller";
 import { PaymentClientService } from "./payment-client.service";
-import { PaymentEventsConsumer } from "./payment-events.consumer";
 import { ServiceAuthGuard } from "../../common/guards/service-auth.guard";
 import { SeatsModule } from "../seats/seats.module";
 import { TicketsModule } from "../tickets/tickets.module";
 
-const PASSENGER_QUEUE = PAYMENT_QUEUES[PaymentService.PASSENGER];
-
 @Module({
   imports: [
     SeatsModule,
     TicketsModule,
     HttpModule.register({ timeout: 10_000 }),
-    RabbitMQModule.forRootAsync({
-      inject: [ConfigService],
-      useFactory: (config: ConfigService) => ({
-        uri: config.get<string>("rabbitmq.url") as string,
-        exchanges: [
-          {
-            name: PAYMENT_EVENTS_EXCHANGE,
-            type: "topic",
-            options: { durable: true },
-          },
-          { name: PAYMENT_EVENTS_DLX, type: "topic", options: { durable: true } },
-        ],
-        queues: [
-          {
-            name: PASSENGER_QUEUE.dlq,
-            exchange: PAYMENT_EVENTS_DLX,
-            routingKey: paymentServiceBindingPattern(PaymentService.PASSENGER),
-            options: { durable: true },
-          },
-        ],
-        prefetchCount: config.get<number>("rabbitmq.prefetch") ?? 10,
-        connectionInitOptions: { wait: false },
-      }),
-    }),
   ],
   controllers: [PaymentsController, InternalPaymentsController],
   providers: [
     PaymentsService,
     PaymentClientService,
-    PaymentEventsConsumer,
     ServiceAuthGuard,
   ],
 })

apps/edr-passenger-api/src/modules/tickets/tickets.controller.ts

@@ -44,6 +44,17 @@ export class TicketsController {
     });
   }
   
+  @Get('by-order/:merchantOrderId')
+  @UseGuards(JwtGuard)
+  @ApiBearerAuth('JWT-auth')
+  @ApiOperation({
+    summary: 'Get ticket by merchant order ID',
+    description: 'Looks up the booking ID from the PaymentIntent using merchantOrderId, then returns the full ticket information.'
+  })
+  getByMerchantOrderId(@Param('merchantOrderId') merchantOrderId: string) {
+    return this.service.getByMerchantOrderId(merchantOrderId);
+  }
+
   @Get(':bookingRef')
   @UseGuards(JwtGuard)
   @ApiBearerAuth('JWT-auth')

apps/edr-passenger-api/src/modules/tickets/tickets.service.ts

@@ -157,6 +157,28 @@ export class TicketsService {
     return { success: true, updatedSeats: newSeatIds.length };
   }
 
+  async getByMerchantOrderId(merchantOrderId: string) {
+    const intent = await this.prisma.paymentIntent.findUnique({
+      where: { merchantOrderId },
+      select: { bookingId: true },
+    });
+    if (!intent) throw new NotFoundException(`No payment intent found for order ${merchantOrderId}`);
+    const booking = await this.prisma.booking.findUnique({
+      where: { id: intent.bookingId },
+      include: { schedule: { include: { originStation: true, destinationStation: true, train: true } }, seats: { include: { seat: { include: { coach: true } } } }, ticket: true },
+    });
+    if (!booking?.ticket) throw new NotFoundException('Ticket not found');
+    const seat = booking.seats[0];
+    return {
+      id: booking.ticket.id, bookingId: booking.id, bookingRef: booking.bookingRef, status: booking.status,
+      fromStationName: booking.schedule.originStation.name, toStationName: booking.schedule.destinationStation.name,
+      departureAt: booking.schedule.departureAt, trainName: booking.schedule.train.name,
+      coachLabel: seat?.seat.coach.number, seatLabel: seat?.seat.seatNumber, passengerName: seat?.passengerName,
+      priceMinor: booking.totalMinor, currency: booking.currency, qrPayload: booking.ticket.qrPayload,
+      barcodePayload: booking.ticket.barcodePayload,
+    };
+  }
+
   async getByRef(bookingRef: string) {
     const booking = await this.prisma.booking.findUnique({
       where: { bookingRef },