Por favor haz click en el siguiente link para acceder al chat
+ // ${title} + // `; + const html = (0, chatMessages_1.chatMessages)(link); + const options = { + to: email, + subject: title, + htmlBody: html, + }; + const isSent = yield this.sendEmail(options); + if (!isSent) + return false; + return true; + }); + } + /** + * Sends a notification when an animal of interest changes. + * @param options Options for sending animal changed notification. + * @returns A boolean indicating whether the email was sent successfully. + */ + sendAnimalChangedNotification({ link, email, }) { + return __awaiter(this, void 0, void 0, function* () { + const title = 'Un animal de tus favoritos ha cambiado!'; + // const html = ` + //Por favor haz click en el siguiente link para ver el animal
+ // ${title} + // `; + const html = (0, petChanged_1.petChanged)(this.webServiceUrl, link); + const options = { + to: email, + subject: title, + htmlBody: html, + }; + const isSent = yield this.sendEmail(options); + if (!isSent) + return false; + return true; + }); + } + /** + * Sends an email validation link. + * @param options Options for sending email validation link. + * @returns A boolean indicating whether the email was sent successfully. + */ + sendEmailValidationLink({ email, verificationToken, type, }) { + return __awaiter(this, void 0, void 0, function* () { + const { html, title } = this.generateEmailContent(type, verificationToken, email); + const options = { + to: email, + subject: title, + htmlBody: html, + }; + const isSent = yield this.sendEmail(options); + if (!isSent) + return false; + return true; + }); + } + /** + * Generates email content based on the type of email and token provided. + * @param type The type of email (either 'email' or 'reset-password'). + * @param token The token to include in the email link. + * @param email The recipient's email address. + * @returns An object containing the HTML content of the email and its title. + */ + generateEmailContent(type, token, email) { + const endPoint = type === 'email' ? 'verify-email' : 'reset-password'; + const title = type === 'email' ? 'Valida tu Email' : 'Cambia tu password'; + const action = type === 'email' ? 'validar tu email' : 'cambiar tu password'; + const link = `${this.webServiceUrl}/${endPoint}/${token}`; + // const html = ` + //Por favor haz click en el siguiente link para ${action}
+ // ${title} + // `; + const html = (0, mailValidation_1.mailValidation)(title, action, link); + return { html, title }; + } + /** + * Sends an email based on the provided options. + * @param options The options for sending the email. + * @returns A boolean indicating whether the email was sent successfully. + */ + sendEmail(options) { + return __awaiter(this, void 0, void 0, function* () { + const { to, subject, htmlBody, attachments: attachments = [] } = options; + if ((typeof to === 'string' && to === 'test@test.com') || + to.includes('test@test.com')) + return false; + try { + const sentInformation = yield this.transporter.sendMail({ + to: to, + subject: subject, + html: htmlBody, + attachments: attachments, + }); + return true; + } + catch (error) { + console.log({ error }); + this.errorLogsService.addMessageToQueue({ + message: `Error sending email: ${error}`, + level: 'high', + origin: 'Email Service', + }, 'error-logs'); + return false; + } + }); + } +} +exports.EmailService = EmailService; diff --git a/dist/services/queue.service.js b/dist/services/queue.service.js new file mode 100644 index 0000000..c0588e0 --- /dev/null +++ b/dist/services/queue.service.js @@ -0,0 +1,60 @@ +"use strict"; +var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) { + function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); } + return new (P || (P = Promise))(function (resolve, reject) { + function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } } + function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } } + function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); } + step((generator = generator.apply(thisArg, _arguments || [])).next()); + }); +}; +var __importDefault = (this && this.__importDefault) || function (mod) { + return (mod && mod.__esModule) ? mod : { "default": mod }; +}; +Object.defineProperty(exports, "__esModule", { value: true }); +exports.QueueService = void 0; +const amqp_connection_manager_1 = __importDefault(require("amqp-connection-manager")); +/** + * ProducerService class for sending messages to RabbitMQ queues. + */ +class QueueService { + /** + * Constructs an instance of ProducerService. + * @param rabbitmqUrl - URL of the RabbitMQ server. + * @param exchange - Name of the exchange to publish messages. + */ + constructor(rabbitmqUrl, exchange) { + this.rabbitmqUrl = rabbitmqUrl; + this.exchange = exchange; + // Establishes connection to RabbitMQ server and creates a channel wrapper. + const connection = amqp_connection_manager_1.default.connect(this.rabbitmqUrl); + this.channelWrapper = connection.createChannel({ + // Ensures the exchange is declared upon channel creation. + setup: (channel) => { + return channel.assertExchange(this.exchange, 'direct', { + durable: true, + }); + }, + }); + console.log(`${this.exchange} exchange created`); + } + /** + * Adds a message to the specified queue in the exchange. + * @param payload - Data to be sent in the message. + * @param queue - Name of the queue to send the message. + */ + addMessageToQueue(payload, queue) { + return __awaiter(this, void 0, void 0, function* () { + try { + console.log({ payload, queue }); + // Publishes the message to the specified queue in the exchange. + yield this.channelWrapper.publish('email-request', queue, Buffer.from(JSON.stringify(payload)), { persistent: true }); + console.log('Message sent to queue'); + } + catch (error) { + console.log('Error sending message to queue', error); + } + }); + } +} +exports.QueueService = QueueService; diff --git a/src/templates/chatMessages.js b/dist/templates/chatMessages.js similarity index 94% rename from src/templates/chatMessages.js rename to dist/templates/chatMessages.js index 5751a93..3f0275e 100644 --- a/src/templates/chatMessages.js +++ b/dist/templates/chatMessages.js @@ -1,5 +1,8 @@ -export const chatMessages = link => { - return ` +"use strict"; +Object.defineProperty(exports, "__esModule", { value: true }); +exports.chatMessages = void 0; +const chatMessages = (link) => { + return `
+ 
+ |
+ ||||||
+
|
+ ||||||
+ 
+ |
+ ||||||
|
+ Copyright (C) 2024 {JP:2} software. Todos los derechos reservados. + |
+ ||||||
|
+
+ |
+ ||||||
+
|
+ ||||||
|
+
+ |
+ ||||||
|
+ Copyright (C) 2024 {JP:2} software. Todos los derechos reservados. + |
+ ||||||
|
+
+ |
+ ||||||
+
|
+ ||||||
|
+
+ |
+ ||||||
|
+ Copyright (C) 2024 {JP:2} software. Todos los derechos reservados. + |
+ ||||||