WA-api/util/refreshMessage.js

"use strict";
const moment = require("moment");

const refreshMessage = async function (message, chat) {
	var Exist = await strapi.api["message"].services["message"].findOne({
		messageId: message["id"].id,
	});
	if (!Exist) {
		// console.log(chatId);
		await strapi.query("message").create({
			messageId: message["id"].id,
			to: message["to"],
			from: message["from"],
			body: message["body"],
			state: message["fromMe"] ? "SENT" : "RECIEVED",
			isForwarded:
				message["isForwarded"] == undefined
					? false
					: message["isForwarded"],
			chat_key: chat.id,
			timestamp: moment.unix(message["timestamp"]).toDate(),
		});
		// console.log("message added");
	} else {
		let id = Exist.id;
		await strapi.query("message").update(
			{ id },
			{
				chat_key: chat.id,
			}
		);
	}
};

module.exports = refreshMessage;