53 lines
1.6 KiB
JavaScript
53 lines
1.6 KiB
JavaScript
"use strict";
|
|
const {
|
|
matchRealEstates,
|
|
matchSearchRequest
|
|
} = require("../services/searchMatchService");
|
|
const {
|
|
generateNotificationEmail,
|
|
generateNewSearchRequestEmail
|
|
} = require("../helpers/emailContentGenerator");
|
|
const { sendEmail } = require("../services/emailService");
|
|
|
|
const notifyForNewRealEstates = async newRealEstates => {
|
|
const matches = await matchRealEstates(newRealEstates);
|
|
await notifyMatches(matches);
|
|
};
|
|
|
|
const notifyForNewSearchRequest = async searchRequest => {
|
|
const matches = await matchSearchRequest(searchRequest);
|
|
|
|
const searchRequestId = searchRequest.id;
|
|
const matchingRealEstates = matches[searchRequestId].realEstates;
|
|
|
|
const emailContent = generateNewSearchRequestEmail(
|
|
searchRequest,
|
|
matchingRealEstates
|
|
);
|
|
const { email } = searchRequest;
|
|
await sendEmail(email, "Market Alert", emailContent);
|
|
};
|
|
|
|
const notifyMatches = async matches => {
|
|
const searchRequestsToNotify = Object.keys(matches);
|
|
|
|
const asyncSendEmailActions = [];
|
|
for (const id of searchRequestsToNotify) {
|
|
const { searchRequest } = matches[id];
|
|
const { email } = searchRequest;
|
|
const allMatchingRealEstates = matches[id].realEstates || [];
|
|
const emailContent = generateNotificationEmail(allMatchingRealEstates, id);
|
|
|
|
const sendEmailPromise = sendEmail(email, "Nove nekretnine", emailContent);
|
|
asyncSendEmailActions.push(sendEmailPromise);
|
|
sendEmailPromise.catch(err => console.log("[Email Sending Failed]", err));
|
|
}
|
|
|
|
await Promise.all(asyncSendEmailActions);
|
|
};
|
|
|
|
module.exports = {
|
|
notifyForNewRealEstates,
|
|
notifyForNewSearchRequest
|
|
};
|