finished user store in typscript

backend/src/controllersOld/MessageController.js

@@ -0,0 +1,203 @@
+const Message = require("../models/Message");
+const Contact = require("../models/Contact");
+const User = require("../models/User");
+const Whatsapp = require("../models/Whatsapp");
+
+const Ticket = require("../models/Ticket");
+const { getIO } = require("../libs/socket");
+const { getWbot } = require("../libs/wbot");
+const Sequelize = require("sequelize");
+
+const { MessageMedia } = require("whatsapp-web.js");
+
+const setMessagesAsRead = async ticket => {
+	const io = getIO();
+	const wbot = getWbot(ticket.whatsappId);
+
+	await Message.update(
+		{ read: true },
+		{
+			where: {
+				ticketId: ticket.id,
+				read: false,
+			},
+		}
+	);
+
+	try {
+		await wbot.sendSeen(`${ticket.contact.number}@c.us`);
+	} catch (err) {
+		console.log(
+			"Could not mark messages as read. Maybe whatsapp session disconnected?"
+		);
+	}
+
+	io.to("notification").emit("ticket", {
+		action: "updateUnread",
+		ticketId: ticket.id,
+	});
+};
+
+exports.index = async (req, res, next) => {
+	const { ticketId } = req.params;
+	const { searchParam = "", pageNumber = 1 } = req.query;
+
+	const whereCondition = {
+		body: Sequelize.where(
+			Sequelize.fn("LOWER", Sequelize.col("body")),
+			"LIKE",
+			"%" + searchParam.toLowerCase() + "%"
+		),
+	};
+
+	const limit = 20;
+	const offset = limit * (pageNumber - 1);
+
+	const ticket = await Ticket.findByPk(ticketId, {
+		include: [
+			{
+				model: Contact,
+				as: "contact",
+				include: "extraInfo",
+				attributes: ["id", "name", "number", "profilePicUrl"],
+			},
+			{
+				model: User,
+				as: "user",
+			},
+		],
+	});
+
+	if (!ticket) {
+		return res.status(404).json({ error: "No ticket found with this ID" });
+	}
+
+	await setMessagesAsRead(ticket);
+
+	const ticketMessages = await ticket.getMessages({
+		where: whereCondition,
+		limit,
+		offset,
+		order: [["createdAt", "DESC"]],
+	});
+
+	const count = await ticket.countMessages();
+
+	const serializedMessages = ticketMessages.map(message => {
+		return {
+			...message.dataValues,
+			mediaUrl: `${
+				message.mediaUrl
+					? `${process.env.BACKEND_URL}:${process.env.PROXY_PORT}/public/${message.mediaUrl}`
+					: ""
+			}`,
+		};
+	});
+
+	const hasMore = count > offset + ticketMessages.length;
+
+	return res.json({
+		messages: serializedMessages.reverse(),
+		ticket,
+		count,
+		hasMore,
+	});
+};
+
+exports.store = async (req, res, next) => {
+	const io = getIO();
+
+	const { ticketId } = req.params;
+	const message = req.body;
+	const media = req.file;
+	let sentMessage;
+
+	const ticket = await Ticket.findByPk(ticketId, {
+		include: [
+			{
+				model: Contact,
+				as: "contact",
+				attributes: ["number", "name", "profilePicUrl"],
+			},
+		],
+	});
+
+	if (!ticket) {
+		return res.status(404).json({ error: "No ticket found with this ID" });
+	}
+
+	if (!ticket.whatsappId) {
+		const defaultWhatsapp = await Whatsapp.findOne({
+			where: { default: true },
+		});
+
+		if (!defaultWhatsapp) {
+			return res
+				.status(404)
+				.json({ error: "No default WhatsApp found. Check Connection page." });
+		}
+
+		await ticket.setWhatsapp(defaultWhatsapp);
+	}
+
+	const wbot = getWbot(ticket.whatsappId);
+
+	try {
+		if (media) {
+			const newMedia = MessageMedia.fromFilePath(req.file.path);
+
+			message.mediaUrl = req.file.filename;
+			if (newMedia.mimetype) {
+				message.mediaType = newMedia.mimetype.split("/")[0];
+			} else {
+				message.mediaType = "other";
+			}
+
+			sentMessage = await wbot.sendMessage(
+				`${ticket.contact.number}@c.us`,
+				newMedia
+			);
+
+			await ticket.update({ lastMessage: message.mediaUrl });
+		} else {
+			sentMessage = await wbot.sendMessage(
+				`${ticket.contact.number}@c.us`,
+				message.body
+			);
+			await ticket.update({ lastMessage: message.body });
+		}
+	} catch (err) {
+		console.log(
+			"Could not create whatsapp message. Is session details valid? "
+		);
+	}
+
+	if (sentMessage) {
+		message.id = sentMessage.id.id;
+		const newMessage = await ticket.createMessage(message);
+
+		const serialziedMessage = {
+			...newMessage.dataValues,
+			mediaUrl: `${
+				message.mediaUrl
+					? `${process.env.BACKEND_URL}:${process.env.PROXY_PORT}/public/${message.mediaUrl}`
+					: ""
+			}`,
+		};
+
+		io.to(ticketId).to("notification").emit("appMessage", {
+			action: "create",
+			message: serialziedMessage,
+			ticket: ticket,
+			contact: ticket.contact,
+		});
+
+		await setMessagesAsRead(ticket);
+
+		return res.status(200).json({ newMessage, ticket });
+	}
+
+	return res
+		.status(500)
+		.json({ error: "Cannot sent whatsapp message. Check connection page." });
+};