Spaces:
Runtime error
Runtime error
File size: 2,893 Bytes
50ca514 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 | import mongoose from "mongoose";
import User from "../model/UserModel.js";
import Message from "../model/MessagesModel.js";
export const getAllContacts = async (request, response, next) => {
try {
const users = await User.find(
{ _id: { $ne: request.userId } },
"firstName lastName _id"
);
const contacts = users.map((user) => ({
label: `${user.firstName} ${user.lastName}`,
value: user._id,
}));
return response.status(200).json({ contacts });
} catch (error) {
console.log({ error });
return response.status(500).send("Internal Server Error.");
}
};
export const searchContacts = async (request, response, next) => {
try {
const { searchTerm } = request.body;
if (searchTerm === undefined || searchTerm === null) {
return response.status(400).send("Search Term is required.");
}
const sanitizedSearchTerm = searchTerm.replace(
/[.*+?^${}()|[\]\\]/g,
"\\$&"
);
const regex = new RegExp(sanitizedSearchTerm, "i");
const contacts = await User.find({
$and: [
{ _id: { $ne: request.userId } },
{
$or: [{ firstName: regex }, { lastName: regex }, { email: regex }],
},
],
});
return response.status(200).json({ contacts });
} catch (error) {
console.log({ error });
return response.status(500).send("Internal Server Error.");
}
};
export const getContactsForList = async (req, res, next) => {
try {
let { userId } = req;
userId = new mongoose.Types.ObjectId(userId);
if (!userId) {
return res.status(400).send("User ID is required.");
}
const contacts = await Message.aggregate([
{
$match: {
$or: [{ sender: userId }, { recipient: userId }],
},
},
{
$sort: { timestamp: -1 },
},
{
$group: {
_id: {
$cond: {
if: { $eq: ["$sender", userId] },
then: "$recipient",
else: "$sender",
},
},
lastMessageTime: { $first: "$timestamp" },
},
},
{
$lookup: {
from: "users",
localField: "_id",
foreignField: "_id",
as: "contactInfo",
},
},
{
$unwind: "$contactInfo",
},
{
$project: {
_id: 1,
lastMessageTime: 1,
email: "$contactInfo.email",
firstName: "$contactInfo.firstName",
lastName: "$contactInfo.lastName",
image: "$contactInfo.image",
color: "$contactInfo.color",
},
},
{
$sort: { lastMessageTime: -1 },
},
]);
return res.status(200).json({ contacts });
} catch (error) {
console.error("Error getting user contacts:", error);
return res.status(500).send("Internal Server Error");
}
};
|