sms-api.service.ts

import { HttpStatus, Injectable } from '@nestjs/common';
import { InjectModel } from '@nestjs/mongoose';
import { Model } from 'mongoose';
import { v4 as uuidv4 } from 'uuid';

import {
    ApiKey,
    NotificationLog,
    RK_NOTIFICATION_SMS,
    RabbitmqService,
    User,
} from '@app/common';
import { InjectRepository } from '@nestjs/typeorm';
import { Repository } from 'typeorm';
import { SmsInputDto } from './dtos/sms.dto';

interface smsLog {
    _id: string;
    readonly channel: string;
    readonly status: string;
    readonly message: string;
    readonly sender: string;
    readonly recipient: string[];
    readonly scheduleDate: Date;
    readonly secretKey: string;
    readonly user: {
        readonly userId: string;
        readonly organisationId: string;
    };
}

@Injectable()
export class SmsApiService {
    constructor(
        private readonly rabbitMQService: RabbitmqService,
        @InjectModel(NotificationLog.name)
        private notificationLogModel: Model<NotificationLog>,
        @InjectRepository(ApiKey, 'postgres')
        private apiKeyRepo: Repository<ApiKey>,
        @InjectRepository(User, 'postgres')
        private userRepo: Repository<User>,
    ) {}
    async publishSMS(body: SmsInputDto, secretKey: string) {
        let _id = uuidv4();
        const payload = { _id, ...body };
        try {
            const response = await this.rabbitMQService.publish(
                RK_NOTIFICATION_SMS,
                payload,
            );

            const { userId } = await this.apiKeyRepo.findOneBy({ secretKey });
            const { organisationId } = await this.userRepo.findOne({
                where: { userId },
            });
            const log: smsLog = {
                _id,
                channel: 'SMS',
                status: response === true ? 'QUEUING' : 'QUEUE FAIL',
                message: body.body,
                sender: body.sender,
                recipient: body.recipient,
                scheduleDate: new Date(),
                secretKey,
                user: {
                    userId,
                    organisationId,
                },
            };
            const notificationLog = new this.notificationLogModel(log);
            await notificationLog.save();

            if (response === false) {
                return {
                    status: HttpStatus.INTERNAL_SERVER_ERROR,
                    message: 'SMS failed to add to the queue',
                };
            }
            return {
                status: HttpStatus.CREATED,
                message: 'SMS added to the queue successfully',
            };
        } catch (error) {
            return {
                status: HttpStatus.INTERNAL_SERVER_ERROR,
                message: 'Something went wrong',
            };
        }
    }
}