77 lines
2.0 KiB
JavaScript
77 lines
2.0 KiB
JavaScript
"use strict";
|
|
|
|
const {
|
|
findSearchRequestsForRealEstate
|
|
} = require("../helpers/db/searchRequest");
|
|
const { findRealEstatesForSearchRequest } = require("../helpers/db/realEstate");
|
|
const { addMatches } = require("../helpers/db/searchRequestMatch");
|
|
const { MAX_REAL_ESTATES_IN_FIRST_EMAIL } = require("../config/appConfig");
|
|
|
|
const matchRealEstates = async realEstates => {
|
|
if (Array.isArray(realEstates)) {
|
|
const asyncMatchActions = [];
|
|
const matches = {};
|
|
const matchingRecords = [];
|
|
for (const realEstate of realEstates) {
|
|
const searchRequestsPromise = findSearchRequestsForRealEstate(realEstate);
|
|
asyncMatchActions.push(searchRequestsPromise);
|
|
|
|
searchRequestsPromise.then(searchRequests => {
|
|
for (const searchRequest of searchRequests) {
|
|
const { id } = searchRequest;
|
|
if (!matches[id]) {
|
|
matches[id] = {
|
|
searchRequest,
|
|
realEstates: []
|
|
};
|
|
}
|
|
matches[id].realEstates.push(realEstate);
|
|
matchingRecords.push({
|
|
searchRequestId: searchRequest.id,
|
|
realEstateId: realEstate.id,
|
|
notified: false
|
|
});
|
|
}
|
|
});
|
|
}
|
|
|
|
await Promise.all(asyncMatchActions);
|
|
|
|
await addMatches(matchingRecords);
|
|
return matches;
|
|
}
|
|
};
|
|
|
|
const matchSearchRequest = async searchRequest => {
|
|
const { id: searchRequestId } = searchRequest;
|
|
|
|
const realEstates = await findRealEstatesForSearchRequest(
|
|
searchRequest,
|
|
MAX_REAL_ESTATES_IN_FIRST_EMAIL
|
|
);
|
|
const matches = {
|
|
[searchRequestId]: {
|
|
searchRequest,
|
|
realEstates: []
|
|
}
|
|
};
|
|
const matchingRecords = [];
|
|
|
|
for (const realEstate of realEstates) {
|
|
matches[searchRequestId].realEstates.push(realEstate);
|
|
matchingRecords.push({
|
|
searchRequestId,
|
|
realEstateId: realEstate.id,
|
|
notified: false
|
|
});
|
|
}
|
|
|
|
await addMatches(matchingRecords);
|
|
return matches;
|
|
};
|
|
|
|
module.exports = {
|
|
matchRealEstates,
|
|
matchSearchRequest
|
|
};
|