117 lines
4.6 KiB
JavaScript
117 lines
4.6 KiB
JavaScript
module.exports = function(RED) {
|
|
function WhatsappIn(config) {
|
|
RED.nodes.createNode(this,config);
|
|
var node = this;
|
|
var whatsappLinkNode = RED.nodes.getNode(config.whatsappLink);
|
|
node.waClient = whatsappLinkNode.client;
|
|
var whatsappLiteEvents = config.whatsappLiteevent;
|
|
var whatsappWebEvents = config.whatsappWebevent;
|
|
|
|
function SetStatus(WAStatus, color){
|
|
node.status({fill:color,shape:"dot",text:WAStatus});
|
|
};
|
|
|
|
if(node.waClient.clientType === "waWebClient"){
|
|
whatsappWebEvents = whatsappWebEvents?.split(",") || whatsappWebEvents ;
|
|
whatsappWebEvents?.forEach((waEvent)=>{
|
|
if (waEvent ==='message'){
|
|
node.waClient.on(waEvent, async message => {
|
|
let msg = {};
|
|
msg.event = waEvent;
|
|
msg.payload = message.body|| null;
|
|
msg.from = message.author || message.from ;
|
|
msg.chatID = message.from.replace(/\D/g, '');
|
|
msg.from = msg.from.replace(/\D/g, '');
|
|
msg.message = message ;
|
|
node.send(msg);
|
|
});
|
|
} else {
|
|
node.waClient.on(waEvent, async message => {
|
|
msg = {};
|
|
msg.event = waEvent;
|
|
msg.message = message
|
|
node.send(msg);
|
|
});
|
|
};
|
|
})
|
|
|
|
|
|
//whatsapp Status Parameters----
|
|
node.waClient.on('qr', (qr) => {
|
|
SetStatus("QR Code Generated", "yellow");
|
|
});
|
|
|
|
node.waClient.on('auth_failure', () => {
|
|
SetStatus('Not Connected','red');
|
|
});
|
|
|
|
node.waClient.on('loading_screen', () => {
|
|
SetStatus('Connecting...','yellow');
|
|
});
|
|
|
|
node.waClient.on('ready', () => {
|
|
SetStatus('Connected','green');
|
|
});
|
|
|
|
node.waClient.on('disconnected', () => {
|
|
SetStatus("Disconnected","red");
|
|
});
|
|
}
|
|
|
|
else if (node.waClient.clientType === "waSocketClient"){
|
|
var client = null
|
|
async function clientFromWhatsappLite(){
|
|
client = await node.waClient;
|
|
whatsappLiteEvents = whatsappLiteEvents?.split(",") || whatsappLiteEvents;
|
|
whatsappLiteEvents?.forEach((waEvent)=>{
|
|
if (waEvent ==='messages.upsert'){
|
|
client.ev.on('messages.upsert', msgs =>{
|
|
msgs.messages.forEach(async msg =>{
|
|
msg.event = waEvent;
|
|
msg.payload = msg.message?.conversation;
|
|
msg.from = msg.key.participant || msg.key.remoteJid;
|
|
msg.from = msg.from.replace(/\D/g, '') || msg.from;
|
|
msg.chatID = msg.key.remoteJid.replace(/\D/g, '') || msg.key.remoteJid ;
|
|
if(msg.message.extendedTextMessage){
|
|
return null
|
|
}
|
|
node.send(msg)
|
|
})
|
|
});
|
|
}
|
|
else {
|
|
client.ev.on(waEvent, msgs =>{
|
|
msgs.event = waEvent;
|
|
node.send(msgs)
|
|
});
|
|
};
|
|
})
|
|
|
|
|
|
//Setting conncetion status indication
|
|
client.ev.on('connection.update', (updates)=>{
|
|
var {connection} = updates
|
|
if(connection === 'open'){
|
|
SetStatus("Connected", "green");
|
|
}
|
|
else if(updates.isOnline){
|
|
SetStatus("Connected", "green");
|
|
}
|
|
else if(connection === 'close'){
|
|
SetStatus("Disconnected", "red");
|
|
}
|
|
else if(connection === 'connecting'){
|
|
SetStatus("Connecting...", "yellow");
|
|
}
|
|
else if(updates.qr){
|
|
SetStatus("Scan QR Code to Connect.", "yellow");
|
|
}
|
|
})
|
|
|
|
}
|
|
clientFromWhatsappLite();
|
|
};
|
|
}
|
|
RED.nodes.registerType("chats-in", WhatsappIn);
|
|
}
|