Compare commits
20 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 871ad3711e | |||
| 3d8778561a | |||
| 9d6ada6514 | |||
| 5e7c53eff7 | |||
| 0640de9a38 | |||
| 847e213443 | |||
| 7a66f8b3d6 | |||
| 5b42aaa642 | |||
| 5c6f38d885 | |||
| a790bf616d | |||
| 259f9e3b68 | |||
| 2ff8f6edba | |||
| 0655d79e8b | |||
| 2363944bb3 | |||
| 7f1e9e67f7 | |||
| acb8457ebc | |||
| 39d167168c | |||
| 8340803377 | |||
| aa37c8c19e | |||
| d075195cda |
+1
-14
@@ -1,7 +1,7 @@
|
|||||||
syntax = "proto3";
|
syntax = "proto3";
|
||||||
package proto;
|
package proto;
|
||||||
|
|
||||||
/// WhatsApp Version: 2.3000.1035484955
|
/// WhatsApp Version: 2.3000.1035302375
|
||||||
|
|
||||||
message ADVDeviceIdentity {
|
message ADVDeviceIdentity {
|
||||||
optional uint32 rawId = 1;
|
optional uint32 rawId = 1;
|
||||||
@@ -417,7 +417,6 @@ message BotCapabilityMetadata {
|
|||||||
JSON_PATCH_STREAMING = 58;
|
JSON_PATCH_STREAMING = 58;
|
||||||
AI_TAB_FORCE_CLIPPY = 59;
|
AI_TAB_FORCE_CLIPPY = 59;
|
||||||
UNIFIED_RESPONSE_EMBEDDED_SCREENS = 60;
|
UNIFIED_RESPONSE_EMBEDDED_SCREENS = 60;
|
||||||
AI_SUBSCRIPTION_ENABLED = 61;
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -1934,20 +1933,8 @@ message HandshakeMessage {
|
|||||||
optional bytes paddedBytes = 6;
|
optional bytes paddedBytes = 6;
|
||||||
optional bool sendServerHelloPaddedBytes = 7;
|
optional bool sendServerHelloPaddedBytes = 7;
|
||||||
optional bool simulateXxkemFs = 8;
|
optional bool simulateXxkemFs = 8;
|
||||||
optional HandshakeMessage.HandshakePqMode pqMode = 9;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
enum HandshakePqMode {
|
|
||||||
HANDSHAKE_PQ_MODE_UNKNOWN = 0;
|
|
||||||
XXKEM = 1;
|
|
||||||
XXKEM_FS = 2;
|
|
||||||
WA_CLASSICAL = 3;
|
|
||||||
WA_PQ = 4;
|
|
||||||
IKKEM = 5;
|
|
||||||
IKKEM_FS = 6;
|
|
||||||
XXKEM_2 = 7;
|
|
||||||
IKKEM_2 = 8;
|
|
||||||
}
|
|
||||||
message ServerHello {
|
message ServerHello {
|
||||||
optional bytes ephemeral = 1;
|
optional bytes ephemeral = 1;
|
||||||
optional bytes static = 2;
|
optional bytes static = 2;
|
||||||
|
|||||||
Vendored
+1
-16
@@ -1092,8 +1092,7 @@ export namespace proto {
|
|||||||
RICH_RESPONSE_UR_IMAGINE_VIDEO = 57,
|
RICH_RESPONSE_UR_IMAGINE_VIDEO = 57,
|
||||||
JSON_PATCH_STREAMING = 58,
|
JSON_PATCH_STREAMING = 58,
|
||||||
AI_TAB_FORCE_CLIPPY = 59,
|
AI_TAB_FORCE_CLIPPY = 59,
|
||||||
UNIFIED_RESPONSE_EMBEDDED_SCREENS = 60,
|
UNIFIED_RESPONSE_EMBEDDED_SCREENS = 60
|
||||||
AI_SUBSCRIPTION_ENABLED = 61
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -4760,7 +4759,6 @@ export namespace proto {
|
|||||||
paddedBytes?: (Uint8Array|null);
|
paddedBytes?: (Uint8Array|null);
|
||||||
sendServerHelloPaddedBytes?: (boolean|null);
|
sendServerHelloPaddedBytes?: (boolean|null);
|
||||||
simulateXxkemFs?: (boolean|null);
|
simulateXxkemFs?: (boolean|null);
|
||||||
pqMode?: (proto.HandshakeMessage.HandshakePqMode|null);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
class ClientHello implements IClientHello {
|
class ClientHello implements IClientHello {
|
||||||
@@ -4773,7 +4771,6 @@ export namespace proto {
|
|||||||
public paddedBytes?: (Uint8Array|null);
|
public paddedBytes?: (Uint8Array|null);
|
||||||
public sendServerHelloPaddedBytes?: (boolean|null);
|
public sendServerHelloPaddedBytes?: (boolean|null);
|
||||||
public simulateXxkemFs?: (boolean|null);
|
public simulateXxkemFs?: (boolean|null);
|
||||||
public pqMode?: (proto.HandshakeMessage.HandshakePqMode|null);
|
|
||||||
public static create(properties?: proto.HandshakeMessage.IClientHello): proto.HandshakeMessage.ClientHello;
|
public static create(properties?: proto.HandshakeMessage.IClientHello): proto.HandshakeMessage.ClientHello;
|
||||||
public static encode(m: proto.HandshakeMessage.IClientHello, w?: $protobuf.Writer): $protobuf.Writer;
|
public static encode(m: proto.HandshakeMessage.IClientHello, w?: $protobuf.Writer): $protobuf.Writer;
|
||||||
public static decode(r: ($protobuf.Reader|Uint8Array), l?: number): proto.HandshakeMessage.ClientHello;
|
public static decode(r: ($protobuf.Reader|Uint8Array), l?: number): proto.HandshakeMessage.ClientHello;
|
||||||
@@ -4783,18 +4780,6 @@ export namespace proto {
|
|||||||
public static getTypeUrl(typeUrlPrefix?: string): string;
|
public static getTypeUrl(typeUrlPrefix?: string): string;
|
||||||
}
|
}
|
||||||
|
|
||||||
enum HandshakePqMode {
|
|
||||||
HANDSHAKE_PQ_MODE_UNKNOWN = 0,
|
|
||||||
XXKEM = 1,
|
|
||||||
XXKEM_FS = 2,
|
|
||||||
WA_CLASSICAL = 3,
|
|
||||||
WA_PQ = 4,
|
|
||||||
IKKEM = 5,
|
|
||||||
IKKEM_FS = 6,
|
|
||||||
XXKEM_2 = 7,
|
|
||||||
IKKEM_2 = 8
|
|
||||||
}
|
|
||||||
|
|
||||||
interface IServerHello {
|
interface IServerHello {
|
||||||
ephemeral?: (Uint8Array|null);
|
ephemeral?: (Uint8Array|null);
|
||||||
"static"?: (Uint8Array|null);
|
"static"?: (Uint8Array|null);
|
||||||
|
|||||||
@@ -6897,10 +6897,6 @@ export const proto = $root.proto = (() => {
|
|||||||
case 60:
|
case 60:
|
||||||
m.capabilities[i] = 60;
|
m.capabilities[i] = 60;
|
||||||
break;
|
break;
|
||||||
case "AI_SUBSCRIPTION_ENABLED":
|
|
||||||
case 61:
|
|
||||||
m.capabilities[i] = 61;
|
|
||||||
break;
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -6997,7 +6993,6 @@ export const proto = $root.proto = (() => {
|
|||||||
values[valuesById[58] = "JSON_PATCH_STREAMING"] = 58;
|
values[valuesById[58] = "JSON_PATCH_STREAMING"] = 58;
|
||||||
values[valuesById[59] = "AI_TAB_FORCE_CLIPPY"] = 59;
|
values[valuesById[59] = "AI_TAB_FORCE_CLIPPY"] = 59;
|
||||||
values[valuesById[60] = "UNIFIED_RESPONSE_EMBEDDED_SCREENS"] = 60;
|
values[valuesById[60] = "UNIFIED_RESPONSE_EMBEDDED_SCREENS"] = 60;
|
||||||
values[valuesById[61] = "AI_SUBSCRIPTION_ENABLED"] = 61;
|
|
||||||
return values;
|
return values;
|
||||||
})();
|
})();
|
||||||
|
|
||||||
@@ -32590,7 +32585,6 @@ export const proto = $root.proto = (() => {
|
|||||||
ClientHello.prototype.paddedBytes = null;
|
ClientHello.prototype.paddedBytes = null;
|
||||||
ClientHello.prototype.sendServerHelloPaddedBytes = null;
|
ClientHello.prototype.sendServerHelloPaddedBytes = null;
|
||||||
ClientHello.prototype.simulateXxkemFs = null;
|
ClientHello.prototype.simulateXxkemFs = null;
|
||||||
ClientHello.prototype.pqMode = null;
|
|
||||||
|
|
||||||
let $oneOfFields;
|
let $oneOfFields;
|
||||||
|
|
||||||
@@ -32642,12 +32636,6 @@ export const proto = $root.proto = (() => {
|
|||||||
set: $util.oneOfSetter($oneOfFields)
|
set: $util.oneOfSetter($oneOfFields)
|
||||||
});
|
});
|
||||||
|
|
||||||
// Virtual OneOf for proto3 optional field
|
|
||||||
Object.defineProperty(ClientHello.prototype, "_pqMode", {
|
|
||||||
get: $util.oneOfGetter($oneOfFields = ["pqMode"]),
|
|
||||||
set: $util.oneOfSetter($oneOfFields)
|
|
||||||
});
|
|
||||||
|
|
||||||
ClientHello.create = function create(properties) {
|
ClientHello.create = function create(properties) {
|
||||||
return new ClientHello(properties);
|
return new ClientHello(properties);
|
||||||
};
|
};
|
||||||
@@ -32671,8 +32659,6 @@ export const proto = $root.proto = (() => {
|
|||||||
w.uint32(56).bool(m.sendServerHelloPaddedBytes);
|
w.uint32(56).bool(m.sendServerHelloPaddedBytes);
|
||||||
if (m.simulateXxkemFs != null && Object.hasOwnProperty.call(m, "simulateXxkemFs"))
|
if (m.simulateXxkemFs != null && Object.hasOwnProperty.call(m, "simulateXxkemFs"))
|
||||||
w.uint32(64).bool(m.simulateXxkemFs);
|
w.uint32(64).bool(m.simulateXxkemFs);
|
||||||
if (m.pqMode != null && Object.hasOwnProperty.call(m, "pqMode"))
|
|
||||||
w.uint32(72).int32(m.pqMode);
|
|
||||||
return w;
|
return w;
|
||||||
};
|
};
|
||||||
|
|
||||||
@@ -32717,10 +32703,6 @@ export const proto = $root.proto = (() => {
|
|||||||
m.simulateXxkemFs = r.bool();
|
m.simulateXxkemFs = r.bool();
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
case 9: {
|
|
||||||
m.pqMode = r.int32();
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
default:
|
default:
|
||||||
r.skipType(t & 7);
|
r.skipType(t & 7);
|
||||||
break;
|
break;
|
||||||
@@ -32772,50 +32754,6 @@ export const proto = $root.proto = (() => {
|
|||||||
if (d.simulateXxkemFs != null) {
|
if (d.simulateXxkemFs != null) {
|
||||||
m.simulateXxkemFs = Boolean(d.simulateXxkemFs);
|
m.simulateXxkemFs = Boolean(d.simulateXxkemFs);
|
||||||
}
|
}
|
||||||
switch (d.pqMode) {
|
|
||||||
default:
|
|
||||||
if (typeof d.pqMode === "number") {
|
|
||||||
m.pqMode = d.pqMode;
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
break;
|
|
||||||
case "HANDSHAKE_PQ_MODE_UNKNOWN":
|
|
||||||
case 0:
|
|
||||||
m.pqMode = 0;
|
|
||||||
break;
|
|
||||||
case "XXKEM":
|
|
||||||
case 1:
|
|
||||||
m.pqMode = 1;
|
|
||||||
break;
|
|
||||||
case "XXKEM_FS":
|
|
||||||
case 2:
|
|
||||||
m.pqMode = 2;
|
|
||||||
break;
|
|
||||||
case "WA_CLASSICAL":
|
|
||||||
case 3:
|
|
||||||
m.pqMode = 3;
|
|
||||||
break;
|
|
||||||
case "WA_PQ":
|
|
||||||
case 4:
|
|
||||||
m.pqMode = 4;
|
|
||||||
break;
|
|
||||||
case "IKKEM":
|
|
||||||
case 5:
|
|
||||||
m.pqMode = 5;
|
|
||||||
break;
|
|
||||||
case "IKKEM_FS":
|
|
||||||
case 6:
|
|
||||||
m.pqMode = 6;
|
|
||||||
break;
|
|
||||||
case "XXKEM_2":
|
|
||||||
case 7:
|
|
||||||
m.pqMode = 7;
|
|
||||||
break;
|
|
||||||
case "IKKEM_2":
|
|
||||||
case 8:
|
|
||||||
m.pqMode = 8;
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
return m;
|
return m;
|
||||||
};
|
};
|
||||||
|
|
||||||
@@ -32863,11 +32801,6 @@ export const proto = $root.proto = (() => {
|
|||||||
if (o.oneofs)
|
if (o.oneofs)
|
||||||
d._simulateXxkemFs = "simulateXxkemFs";
|
d._simulateXxkemFs = "simulateXxkemFs";
|
||||||
}
|
}
|
||||||
if (m.pqMode != null && m.hasOwnProperty("pqMode")) {
|
|
||||||
d.pqMode = o.enums === String ? $root.proto.HandshakeMessage.HandshakePqMode[m.pqMode] === undefined ? m.pqMode : $root.proto.HandshakeMessage.HandshakePqMode[m.pqMode] : m.pqMode;
|
|
||||||
if (o.oneofs)
|
|
||||||
d._pqMode = "pqMode";
|
|
||||||
}
|
|
||||||
return d;
|
return d;
|
||||||
};
|
};
|
||||||
|
|
||||||
@@ -32885,20 +32818,6 @@ export const proto = $root.proto = (() => {
|
|||||||
return ClientHello;
|
return ClientHello;
|
||||||
})();
|
})();
|
||||||
|
|
||||||
HandshakeMessage.HandshakePqMode = (function() {
|
|
||||||
const valuesById = {}, values = Object.create(valuesById);
|
|
||||||
values[valuesById[0] = "HANDSHAKE_PQ_MODE_UNKNOWN"] = 0;
|
|
||||||
values[valuesById[1] = "XXKEM"] = 1;
|
|
||||||
values[valuesById[2] = "XXKEM_FS"] = 2;
|
|
||||||
values[valuesById[3] = "WA_CLASSICAL"] = 3;
|
|
||||||
values[valuesById[4] = "WA_PQ"] = 4;
|
|
||||||
values[valuesById[5] = "IKKEM"] = 5;
|
|
||||||
values[valuesById[6] = "IKKEM_FS"] = 6;
|
|
||||||
values[valuesById[7] = "XXKEM_2"] = 7;
|
|
||||||
values[valuesById[8] = "IKKEM_2"] = 8;
|
|
||||||
return values;
|
|
||||||
})();
|
|
||||||
|
|
||||||
HandshakeMessage.ServerHello = (function() {
|
HandshakeMessage.ServerHello = (function() {
|
||||||
|
|
||||||
function ServerHello(p) {
|
function ServerHello(p) {
|
||||||
|
|||||||
@@ -1 +1 @@
|
|||||||
{"version":[2,3000,1035504971]}
|
{"version":[2,3000,1035317910]}
|
||||||
|
|||||||
@@ -123,11 +123,11 @@ export const makeNewsletterSocket = (config: SocketConfig) => {
|
|||||||
},
|
},
|
||||||
|
|
||||||
newsletterMute: (jid: string) => {
|
newsletterMute: (jid: string) => {
|
||||||
return executeWMexQuery({ input: { newsletter_id: jid, type: 'MUTE_ADMIN_ACTIVITY', value: 'OFF' } }, QueryIds.MUTE, XWAPaths.xwa2_newsletter_mute_v2)
|
return executeWMexQuery({ newsletter_id: jid }, QueryIds.MUTE, XWAPaths.xwa2_newsletter_mute_v2)
|
||||||
},
|
},
|
||||||
|
|
||||||
newsletterUnmute: (jid: string) => {
|
newsletterUnmute: (jid: string) => {
|
||||||
return executeWMexQuery({ input: { newsletter_id: jid, type: 'MUTE_ADMIN_ACTIVITY', value: 'ON' } }, QueryIds.UNMUTE, XWAPaths.xwa2_newsletter_unmute_v2)
|
return executeWMexQuery({ newsletter_id: jid }, QueryIds.UNMUTE, XWAPaths.xwa2_newsletter_unmute_v2)
|
||||||
},
|
},
|
||||||
|
|
||||||
newsletterUpdateName: async (jid: string, name: string) => {
|
newsletterUpdateName: async (jid: string, name: string) => {
|
||||||
|
|||||||
@@ -27,8 +27,6 @@ export type BaileysEventMap = {
|
|||||||
chats: Chat[]
|
chats: Chat[]
|
||||||
contacts: Contact[]
|
contacts: Contact[]
|
||||||
messages: WAMessage[]
|
messages: WAMessage[]
|
||||||
/** Past participants for group chats (people who left/were removed). userJid is always a phone number (PN), never a LID. */
|
|
||||||
pastParticipants?: proto.IPastParticipants[] | null
|
|
||||||
isLatest?: boolean
|
isLatest?: boolean
|
||||||
progress?: number | null
|
progress?: number | null
|
||||||
syncType?: proto.HistorySync.HistorySyncType | null
|
syncType?: proto.HistorySync.HistorySyncType | null
|
||||||
@@ -187,8 +185,6 @@ export type BufferedEventData = {
|
|||||||
chats: { [jid: string]: Chat }
|
chats: { [jid: string]: Chat }
|
||||||
contacts: { [jid: string]: Contact }
|
contacts: { [jid: string]: Contact }
|
||||||
messages: { [uqId: string]: WAMessage }
|
messages: { [uqId: string]: WAMessage }
|
||||||
/** Keyed by groupJid for O(1) deduplication across chunks */
|
|
||||||
pastParticipants: { [groupJid: string]: proto.IPastParticipant[] }
|
|
||||||
empty: boolean
|
empty: boolean
|
||||||
isLatest: boolean
|
isLatest: boolean
|
||||||
progress?: number | null
|
progress?: number | null
|
||||||
|
|||||||
@@ -4,10 +4,10 @@ export enum XWAPaths {
|
|||||||
xwa2_newsletter_view = 'xwa2_newsletter_view',
|
xwa2_newsletter_view = 'xwa2_newsletter_view',
|
||||||
xwa2_newsletter_metadata = 'xwa2_newsletter',
|
xwa2_newsletter_metadata = 'xwa2_newsletter',
|
||||||
xwa2_newsletter_admin_count = 'xwa2_newsletter_admin',
|
xwa2_newsletter_admin_count = 'xwa2_newsletter_admin',
|
||||||
xwa2_newsletter_mute_v2 = 'xwa2_newsletter_update_user_setting',
|
xwa2_newsletter_mute_v2 = 'xwa2_newsletter_mute_v2',
|
||||||
xwa2_newsletter_unmute_v2 = 'xwa2_newsletter_update_user_setting',
|
xwa2_newsletter_unmute_v2 = 'xwa2_newsletter_unmute_v2',
|
||||||
xwa2_newsletter_follow = 'xwa2_newsletter_join_v2',
|
xwa2_newsletter_follow = 'xwa2_newsletter_follow',
|
||||||
xwa2_newsletter_unfollow = 'xwa2_newsletter_leave_v2',
|
xwa2_newsletter_unfollow = 'xwa2_newsletter_unfollow',
|
||||||
xwa2_newsletter_change_owner = 'xwa2_newsletter_change_owner',
|
xwa2_newsletter_change_owner = 'xwa2_newsletter_change_owner',
|
||||||
xwa2_newsletter_demote = 'xwa2_newsletter_demote',
|
xwa2_newsletter_demote = 'xwa2_newsletter_demote',
|
||||||
xwa2_newsletter_delete_v2 = 'xwa2_newsletter_delete_v2'
|
xwa2_newsletter_delete_v2 = 'xwa2_newsletter_delete_v2'
|
||||||
@@ -17,10 +17,10 @@ export enum QueryIds {
|
|||||||
UPDATE_METADATA = '24250201037901610',
|
UPDATE_METADATA = '24250201037901610',
|
||||||
METADATA = '6563316087068696',
|
METADATA = '6563316087068696',
|
||||||
SUBSCRIBERS = '9783111038412085',
|
SUBSCRIBERS = '9783111038412085',
|
||||||
FOLLOW = '24404358912487870',
|
FOLLOW = '7871414976211147',
|
||||||
UNFOLLOW = '9767147403369991',
|
UNFOLLOW = '7238632346214362',
|
||||||
MUTE = '31938993655691868',
|
MUTE = '29766401636284406',
|
||||||
UNMUTE = '31938993655691868',
|
UNMUTE = '9864994326891137',
|
||||||
ADMIN_COUNT = '7130823597031706',
|
ADMIN_COUNT = '7130823597031706',
|
||||||
CHANGE_OWNER = '7341777602580933',
|
CHANGE_OWNER = '7341777602580933',
|
||||||
DEMOTE = '6551828931592903',
|
DEMOTE = '6551828931592903',
|
||||||
|
|||||||
@@ -1,5 +1,4 @@
|
|||||||
import EventEmitter from 'events'
|
import EventEmitter from 'events'
|
||||||
import { proto } from '../../WAProto/index.js'
|
|
||||||
import type {
|
import type {
|
||||||
BaileysEvent,
|
BaileysEvent,
|
||||||
BaileysEventEmitter,
|
BaileysEventEmitter,
|
||||||
@@ -891,7 +890,6 @@ const makeBufferData = (): BufferedEventData => {
|
|||||||
chats: {},
|
chats: {},
|
||||||
messages: {},
|
messages: {},
|
||||||
contacts: {},
|
contacts: {},
|
||||||
pastParticipants: {},
|
|
||||||
isLatest: false,
|
isLatest: false,
|
||||||
empty: true
|
empty: true
|
||||||
},
|
},
|
||||||
@@ -969,28 +967,6 @@ function append<E extends BufferableEvent>(
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// Merge pastParticipants with deduplication by groupJid and by userJid within each group.
|
|
||||||
// Multiple HistorySync chunks can carry the same group -- we merge rather than concatenate
|
|
||||||
// to avoid duplicate entries in the final event delivered to the consumer.
|
|
||||||
for (const group of (eventData.pastParticipants ?? []) as proto.IPastParticipants[]) {
|
|
||||||
const groupJid = group.groupJid
|
|
||||||
if (!groupJid) continue
|
|
||||||
|
|
||||||
if (!data.historySets.pastParticipants[groupJid]) {
|
|
||||||
data.historySets.pastParticipants[groupJid] = []
|
|
||||||
}
|
|
||||||
|
|
||||||
const existing = data.historySets.pastParticipants[groupJid]
|
|
||||||
const seenJids = new Set(existing.map(p => p.userJid).filter(Boolean))
|
|
||||||
|
|
||||||
for (const participant of (group.pastParticipants ?? []) as proto.IPastParticipant[]) {
|
|
||||||
if (participant.userJid && !seenJids.has(participant.userJid)) {
|
|
||||||
existing.push(participant)
|
|
||||||
seenJids.add(participant.userJid)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
data.historySets.empty = false
|
data.historySets.empty = false
|
||||||
data.historySets.syncType = eventData.syncType
|
data.historySets.syncType = eventData.syncType
|
||||||
data.historySets.progress = eventData.progress
|
data.historySets.progress = eventData.progress
|
||||||
@@ -1316,10 +1292,6 @@ function consolidateEvents(data: BufferedEventData) {
|
|||||||
chats: Object.values(data.historySets.chats),
|
chats: Object.values(data.historySets.chats),
|
||||||
messages: Object.values(data.historySets.messages),
|
messages: Object.values(data.historySets.messages),
|
||||||
contacts: Object.values(data.historySets.contacts),
|
contacts: Object.values(data.historySets.contacts),
|
||||||
// Convert dedup map back to array. Each entry has groupJid + participants (all unique userJids).
|
|
||||||
pastParticipants: Object.entries(data.historySets.pastParticipants).map(
|
|
||||||
([groupJid, participants]) => ({ groupJid, pastParticipants: participants })
|
|
||||||
),
|
|
||||||
syncType: data.historySets.syncType,
|
syncType: data.historySets.syncType,
|
||||||
progress: data.historySets.progress,
|
progress: data.historySets.progress,
|
||||||
isLatest: data.historySets.isLatest,
|
isLatest: data.historySets.isLatest,
|
||||||
|
|||||||
@@ -374,25 +374,10 @@ export const processHistoryMessage = (item: proto.IHistorySync, logger?: ILogger
|
|||||||
// Convert Map back to array for return
|
// Convert Map back to array for return
|
||||||
const lidPnMappings = Array.from(lidPnMap.values())
|
const lidPnMappings = Array.from(lidPnMap.values())
|
||||||
|
|
||||||
// Normalize pastParticipants: resolve LID userJids → PN so the consumer always
|
|
||||||
// receives a phone number, never an opaque LID identifier.
|
|
||||||
// Uses the lidPnMap built above (populated from phoneNumberToLidMappings + conversations).
|
|
||||||
// If a LID cannot be resolved, the original value is kept rather than dropping the participant.
|
|
||||||
const pastParticipants: proto.IPastParticipants[] = (item.pastParticipants ?? []).map(group => ({
|
|
||||||
groupJid: group.groupJid,
|
|
||||||
pastParticipants: (group.pastParticipants ?? []).map(participant => {
|
|
||||||
const userJid = participant.userJid
|
|
||||||
if (!userJid || !isAnyLidUser(userJid)) return participant
|
|
||||||
const mapping = lidPnMap.get(jidNormalizedUser(userJid))
|
|
||||||
return mapping?.pn ? { ...participant, userJid: mapping.pn } : participant
|
|
||||||
})
|
|
||||||
}))
|
|
||||||
|
|
||||||
return {
|
return {
|
||||||
chats,
|
chats,
|
||||||
contacts,
|
contacts,
|
||||||
messages,
|
messages,
|
||||||
pastParticipants,
|
|
||||||
lidPnMappings,
|
lidPnMappings,
|
||||||
syncType: item.syncType,
|
syncType: item.syncType,
|
||||||
progress: item.progress
|
progress: item.progress
|
||||||
|
|||||||
Reference in New Issue
Block a user