diff --git a/app/helpers/db/searchRequestMatch.js b/app/helpers/db/searchRequestMatch.js new file mode 100644 index 0000000..152880f --- /dev/null +++ b/app/helpers/db/searchRequestMatch.js @@ -0,0 +1,23 @@ +"use strict"; +const db = require("../../models/index"); + +const findRealEstatesForSearchRequest = async searchRequestId => { + const query = { + searchRequestId + }; + + const include = [{ model: db.RealEstate }]; + + return await db.SearchRequestMatch.findAll({ where: query, include }); +}; + +const addMatches = async matchingRecords => { + return await db.SearchRequestMatch.bulkCreate(matchingRecords, { + ignoreDuplicates: true + }); +}; + +module.exports = { + findRealEstatesForSearchRequest, + addMatches +};