DCB/dcb-service-webhook
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge pull request #3 from Cameleonapp/feature/keycloak-config

Browse Source 
modification of payload
This commit is contained in:
KurtisMelkisedec 2025-11-13 10:35:24 +00:00 committed by GitHub
commit 5d7b628516
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
5 changed files with 42 additions and 37 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/config/app.config.ts
View File

@ -1,10 +1,10 @@
import { registerAs } from '@nestjs/config'; import { registerAs } from '@nestjs/config';
export default registerAs('appConfig', () => ({ export default registerAs('appConfig', () => ({
user: process.env.RABBITMQ_USER, user: process.env.RABBITMQ_USER || 'user',
pass: process.env.RABBITMQ_PASS, pass: process.env.RABBITMQ_PASS || 'passer',
host: process.env.RABBITMQ_HOST, host: process.env.RABBITMQ_HOST || 'localhost',
port: process.env.RABBITMQ_PORT, port: process.env.RABBITMQ_PORT || '5672',
apiUrl: process.env.RABBITMQ_API_URL || 'https://rabbitmq.dcb.pixpay.sn/api', apiUrl: process.env.RABBITMQ_API_URL || 'https://rabbitmq.dcb.pixpay.sn/api',
queues: { queues: {
smsmo: process.env.RABBITMQ_QUEUE_WEBHOOK || 'smsmo_queue', smsmo: process.env.RABBITMQ_QUEUE_WEBHOOK || 'smsmo_queue',

2
src/controllers/webhook.controller.ts
View File

@ -110,8 +110,8 @@ export class WebhookController {
await this.webhookService.handleHeNotification( await this.webhookService.handleHeNotification(
country, country,
operator, operator,
ise,
callback, callback,
ise,
); );
return { status: 'queued' }; return { status: 'queued' };

5
src/dtos/sms.mo.dto.ts
View File

@ -44,6 +44,11 @@ export class InboundSMSMessageNotificationDto {
@IsNotEmpty() @IsNotEmpty()
callbackData: string; callbackData: string;
@ApiProperty({ example: '1' })
@IsString()
@IsNotEmpty()
partnerId: string;
@ApiProperty({ type: InboundSMSMessageDto }) @ApiProperty({ type: InboundSMSMessageDto })
@ValidateNested() @ValidateNested()
@Type(() => InboundSMSMessageDto) @Type(() => InboundSMSMessageDto)

4
src/services/rabbit.service.ts
View File

@ -48,8 +48,8 @@ export class RabbitMQService implements OnModuleInit {
async sendToQueue(queue: string, message: any) { async sendToQueue(queue: string, message: any) {
if (!this.channel) throw new Error('RabbitMQ channel not initialized'); if (!this.channel) throw new Error('RabbitMQ channel not initialized');
//check if the queue exist and create it if not // //check if the queue exist and create it if not
await this.channel.assertQueue(queue, { durable: true }); // await this.channel.assertQueue(queue, { durable: true });
for (let attempt = 1; attempt <= this.maxRetry; attempt++) { for (let attempt = 1; attempt <= this.maxRetry; attempt++) {
try { try {