46 lines
1.2 KiB
TypeScript
46 lines
1.2 KiB
TypeScript
|
import { Message as WbotMessage } from "whatsapp-web.js";
|
||
|
|
import AppError from "../../errors/AppError";
|
||
|
|
import GetTicketWbot from "../../helpers/GetTicketWbot";
|
||
|
|
import GetWbotMessage from "../../helpers/GetWbotMessage";
|
||
|
|
import SerializeWbotMsgId from "../../helpers/SerializeWbotMsgId";
|
||
|
|
import Message from "../../models/Message";
|
||
|
|
import Ticket from "../../models/Ticket";
|
||
|
|
|
||
|
|
interface Request {
|
||
|
|
body: string;
|
||
|
|
ticket: Ticket;
|
||
|
|
quotedMsg?: Message;
|
||
|
|
}
|
||
|
|
|
||
|
|
const SendWhatsAppMessage = async ({
|
||
|
|
body,
|
||
|
|
ticket,
|
||
|
|
quotedMsg
|
||
|
|
}: Request): Promise<WbotMessage> => {
|
||
|
|
let quotedMsgSerializedId: string | undefined;
|
||
|
|
if (quotedMsg) {
|
||
|
|
await GetWbotMessage(ticket, quotedMsg.id);
|
||
|
|
quotedMsgSerializedId = SerializeWbotMsgId(ticket, quotedMsg);
|
||
|
|
}
|
||
|
|
|
||
|
|
const wbot = await GetTicketWbot(ticket);
|
||
|
|
|
||
|
|
try {
|
||
|
|
const sentMessage = await wbot.sendMessage(
|
||
|
|
`${ticket.contact.number}@${ticket.isGroup ? "g" : "c"}.us`,
|
||
|
|
body,
|
||
|
|
{
|
||
|
|
quotedMessageId: quotedMsgSerializedId,
|
||
|
|
linkPreview: false
|
||
|
|
}
|
||
|
|
);
|
||
|
|
|
||
|
|
await ticket.update({ lastMessage: body });
|
||
|
|
return sentMessage;
|
||
|
|
} catch (err) {
|
||
|
|
throw new AppError("ERR_SENDING_WAPP_MSG");
|
||
|
|
}
|
||
|
|
};
|
||
|
|
|
||
|
|
export default SendWhatsAppMessage;
|