Hamza/nabeh
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Phase 4: Support LID identity scheme and fix incoming message parsing

Browse Source
This commit is contained in:
Hamza-Ayed
2026-05-21 22:55:06 +03:00
parent d4a7a3e829
commit 0a1752ce44
2 changed files with 24 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
.gitignore vendored
View File

@@ -95,3 +95,8 @@ mobile/ios/DerivedData/
*.mode2v3
*.storyboardc
*.nib
# ==========================================
# 💬 WhatsApp Gateway
# ==========================================
whatsapp-gateway/sessions/

23
whatsapp-gateway/baileys-client.js
View File

@@ -90,8 +90,12 @@ async function startSession(session_key, webhook_url) {
if (msg.key.fromMe) continue;
const remoteJid = msg.key.remoteJid;
// Only process direct messages from individuals (ignore groups/broadcasts)
if (!remoteJid || !remoteJid.endsWith('@s.whatsapp.net')) continue;
if (!remoteJid) continue;
// Only process individual chats (ignore groups and broadcasts)
const isGroup = remoteJid.endsWith('@g.us');
const isBroadcast = remoteJid.endsWith('@broadcast');
if (isGroup || isBroadcast) continue;
// Extract text body
const body = msg.message?.conversation ||
@@ -102,10 +106,21 @@ async function startSession(session_key, webhook_url) {
// For now, only process messages that have text content
if (!body) continue;
const senderPhone = remoteJid.split('@')[0];
// Extract sender phone number (handle LID privacy scheme)
let senderPhone = '';
if (msg.key.senderPn && msg.key.senderPn.endsWith('@s.whatsapp.net')) {
senderPhone = msg.key.senderPn.split('@')[0];
} else if (remoteJid.endsWith('@s.whatsapp.net')) {
senderPhone = remoteJid.split('@')[0];
} else if (remoteJid.endsWith('@lid')) {
senderPhone = remoteJid.split('@')[0];
}
if (!senderPhone) continue;
const senderName = msg.pushName || '';
console.log(`[Message] Received from ${senderPhone}: ${body}`);
console.log(`[Message] Received from ${senderPhone} (JID: ${remoteJid}): ${body}`);
await sendWebhook(webhook_url, {
session_key,