Tria/edr-platform
1
0
Fork 0
mirror of https://github.com/Tria-plc/edr-platform.git synced 2026-08-26 18:42:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #157 from Tria-plc/feat/payment-microservice

Browse Source 
Revert "refactor: ( rabbitmq ) temporary remove the rabbitmq"
This commit is contained in:
Abubeker Yasin
2026-06-14 21:55:15 +03:00
committed by GitHub
parent 74e3791ab6 4ab987e8fe
commit 3a9f0dd0a8
1 changed files with 36 additions and 43 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -1,67 +1,60 @@
import { Module } from "@nestjs/common";
import { HttpModule } from "@nestjs/axios";
// --- TEMPORARILY DISABLED: payment-event RabbitMQ consumer ----------------------------------
// The payment broker is currently unreachable (DevOps is fixing it). @golevelup awaits the
// @RabbitSubscribe registration during bootstrap, so an unreachable broker hangs the whole API
// and it never finishes starting. Disabled so the server boots without the broker.
// TO RE-ENABLE (once the broker is back): uncomment the imports below, the RabbitMQModule entry
// in `imports`, and PaymentEventsConsumer in `providers`.
// 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 { 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 { 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];
const PASSENGER_QUEUE = PAYMENT_QUEUES[PaymentService.PASSENGER];
@Module({
imports: [
SeatsModule,
TicketsModule,
HttpModule.register({ timeout: 10_000 }),
// --- TEMPORARILY DISABLED (broker unreachable) — re-enable with the imports above. -------
// 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 },
// }),
// }),
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, // TEMPORARILY DISABLED — re-enable with RabbitMQModule above.
PaymentEventsConsumer,
ServiceAuthGuard,
],
})