Haina
/
Global-sales
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

perf: emmiter+externalId

Browse Source
dev/supplier-email-drawer
Jimmy 9 months ago
parent b954ab6ac3
commit ad3bae2eab
1 changed files with 107 additions and 89 deletions
Show Stats Download Patch File Download Diff File

196
wai-server/core/baileys/index.js
Unescape Escape View File

@ -32,7 +32,7 @@ waEmitter.on('connection:close', event => {
}); });
const createWhatsApp = async phone => { const createWhatsApp = async phone => {
let waSocket = null; // let waSocket = null;
let qrCode = null; let qrCode = null;
let connectionStatus = 'offline' let connectionStatus = 'offline'
const channelId = generateId(); const channelId = generateId();
@ -200,7 +200,7 @@ const createWhatsApp = async phone => {
} }
const start = () => { const start = () => {
waSocket = makeWASocket({ const waSocket = makeWASocket({
version, version,
logger, logger,
auth: { auth: {
@ -221,102 +221,120 @@ const createWhatsApp = async phone => {
store?.bind(waSocket.ev); store?.bind(waSocket.ev);
const sendTextMessage = async (number, content, externalId) => { const sendTextMessage = async (number, content, externalId) => {
const jid = formatPhoneNumber(number); const jid = formatPhoneNumber(number);
waSocket.sendMessage(jid, { text: content })
return new Promise(() => { .then(msg => {
waSocket.sendMessage(jid, { text: content }) msgIdMap.set(msg.key.id, externalId);
.then(msg => { })
msgIdMap.set(msg.key.id, externalId); .catch(ex => {
}) console.error('sendTextMessage.error: ', ex)
.catch(ex => { waEmitter.emit('message:updated', {
waEmitter.emit('message:updated', { id: generateId(),
id: generateId(), externalId,
externalId, status: 'failed',
status: 'failed', direction: 'outbound',
direction: 'outbound',
from: whatsAppNo,
to: number,
errro: `发送文本消息出错 ` + ex,
eventSource: serverConfig.name + '.sendMessage.promise.catch',
updateTime: formatTimestamp(new Date().getTime() / 1000),
});
});
});
};
const sendImageMessage = async (number, imageUrl) => {
const jid = formatPhoneNumber(number);
try {
const msgInfo = await waSocket.sendMessage(jid, {
image: { url: imageUrl },
});
return {
messageId: msgInfo?.key?.id ?? generateId()
};
} catch (ex) {
waEmitter.emit('message.error', {
messge: `[${whatsAppNo}->${number}]发送图片消息出错`,
from: whatsAppNo, from: whatsAppNo,
to: number, to: number,
error: ex error: `发送文本消息出错 ` + ex,
}) eventSource: serverConfig.name + '.sendMessage.promise.catch',
console.error(`[${whatsAppNo}->${number}]发送图片消息出错: `, ex); updateTime: formatTimestamp(new Date().getTime() / 1000),
} });
}; });
};
const getProfilePicture = async (whatsAppNo) => {
const number = formatPhoneNumber(whatsAppNo); const sendImageMessage = async (number, imageUrl) => {
try { const jid = formatPhoneNumber(number);
const ppUrl = await waSocket.profilePictureUrl(number); try {
console.log('头像: ' + ppUrl); const msgInfo = await waSocket.sendMessage(jid, {
} catch (ex) { image: { url: imageUrl },
console.error('头像出错: ', ex); });
} return {
messageId: msgInfo?.key?.id ?? generateId()
};
} catch (ex) {
waEmitter.emit('message.error', {
messge: `[${whatsAppNo}->${number}]发送图片消息出错`,
from: whatsAppNo,
to: number,
error: ex
})
console.error(`[${whatsAppNo}->${number}]发送图片消息出错: `, ex);
}
};
const getProfilePicture = async (whatsAppNo) => {
const number = formatPhoneNumber(whatsAppNo);
try {
const ppUrl = await waSocket.profilePictureUrl(number);
console.log('头像: ' + ppUrl);
} catch (ex) {
console.error('头像出错: ', ex);
} }
waSocket.ev.on('connection.update', async update => { }
console.log('connection update: ', update); waSocket.ev.on('connection.update', async update => {
const { connection, lastDisconnect, qr } = update; console.log('connection update: ', update);
const { connection, lastDisconnect, qr } = update;
if (connection === 'close') { if (connection === 'close') {
if((lastDisconnect?.error)?.output?.statusCode !== DisconnectReason.loggedOut) { if((lastDisconnect?.error)?.output?.statusCode !== DisconnectReason.loggedOut) {
start(); start();
} else { } else {
waEmitter.emit('connection:close', { waEmitter.emit('connection:close', {
whatsAppNo, channelId, whatsAppNo, channelId,
eventSource: serverConfig.name + '.connection.update.close', eventSource: serverConfig.name + '.connection.update.close',
status: 'offline', status: 'offline',
});
}
} else if (connection === 'open') {
connectionStatus = 'open';
waEmitter.emit('connection:open', {
status: 'open', whatsAppNo, channelId,
eventSource: serverConfig.name + '.connection.update.open',
}); });
waEmitter.on('request.' + whatsAppNo + '.send.message', event => { }
// const jid = formatPhoneNumber(event.to); } else if (connection === 'open') {
const externalId = event.externalId; connectionStatus = 'open';
waSocket.sendMessage(event.to + '@s.whatsapp.net', { text: serverConfig.name + '.request.send.message: ' + event.content + new Date().toString()}) waEmitter.emit('connection:open', {
status: 'open', whatsAppNo, channelId,
eventSource: serverConfig.name + '.connection.update.open',
});
waEmitter.on('request.' + whatsAppNo + '.send.message', event => {
// const jid = formatPhoneNumber(event.to);
const {to: number, externalId, content} = event;
console.info('request.' + whatsAppNo + '.send.message:', event)
waSocket.sendMessage(
number + '@s.whatsapp.net',
{ text: content}
).then(msg => {
msgIdMap.set(msg.key.id, externalId);
}).catch(ex => {
console.error('sendTextMessage.error: ', ex)
waEmitter.emit('message:updated', {
id: generateId(),
externalId,
status: 'failed',
direction: 'outbound',
from: whatsAppNo,
to: number,
error: `发送文本消息出错 ` + ex,
eventSource: serverConfig.name + '.sendMessage.promise.catch',
updateTime: formatTimestamp(new Date().getTime() / 1000),
});
}); });
} else if (qr !== undefined) { //sendTextMessage(number, content, externalId);
// WebSocket 创建成功等待扫码，如果没有扫码会更新 qr });
// 第一次一分钟，后面是 20 秒更新一次 } else if (qr !== undefined) {
if (qrCode === null) { // WebSocket 创建成功等待扫码，如果没有扫码会更新 qr
qrCode = qr; // 第一次一分钟，后面是 20 秒更新一次
console.info('qr: ', qr); if (qrCode === null) {
} else { qrCode = qr;
// 第一次二维码时效后退出，不需要等待更新二维码 console.info('qr: ', qr);
waSocket.logout(() => '二维码已过期'); } else {
} // 第一次二维码时效后退出，不需要等待更新二维码
waSocket.logout(() => '二维码已过期');
} }
});
waSocket.ev.on('creds.update', handleCredsUpdate); }
waSocket.ev.on('messages.upsert', handleMessagesUpsert); });
waSocket.ev.on('messages.update', handleMessagesUpdate);
waSocket.ev.on('creds.update', handleCredsUpdate);
waSocket.ev.on('messages.upsert', handleMessagesUpsert);
waSocket.ev.on('messages.update', handleMessagesUpdate);
}; };
return { return {

Write Preview
Loading…
Cancel
Save