messages-recv, decode-wa-message: handle storing new pairs better + lint
This commit is contained in:
@@ -1128,15 +1128,13 @@ export const makeMessagesRecvSocket = (config: SocketConfig) => {
|
|||||||
const altServer = jidDecode(alt)?.server
|
const altServer = jidDecode(alt)?.server
|
||||||
const primaryJid = msg.key.participant || msg.key.remoteJid!
|
const primaryJid = msg.key.participant || msg.key.remoteJid!
|
||||||
if (altServer === 'lid') {
|
if (altServer === 'lid') {
|
||||||
if (typeof (await signalRepository.lidMapping.getPNForLID(alt)) === 'string') {
|
if (!(await signalRepository.lidMapping.getPNForLID(alt))) {
|
||||||
await signalRepository.lidMapping.storeLIDPNMappings([{ lid: alt, pn: primaryJid }])
|
await signalRepository.lidMapping.storeLIDPNMappings([{ lid: alt, pn: primaryJid }])
|
||||||
await signalRepository.migrateSession(primaryJid, alt)
|
await signalRepository.migrateSession(primaryJid, alt)
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
if (typeof (await signalRepository.lidMapping.getLIDForPN(alt)) === 'string') {
|
await signalRepository.lidMapping.storeLIDPNMappings([{ lid: primaryJid, pn: alt }])
|
||||||
await signalRepository.lidMapping.storeLIDPNMappings([{ lid: primaryJid, pn: alt }])
|
await signalRepository.migrateSession(alt, primaryJid)
|
||||||
await signalRepository.migrateSession(alt, primaryJid)
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -13,15 +13,15 @@ import {
|
|||||||
isJidNewsletter,
|
isJidNewsletter,
|
||||||
isJidStatusBroadcast,
|
isJidStatusBroadcast,
|
||||||
isLidUser,
|
isLidUser,
|
||||||
isPnUser,
|
isPnUser
|
||||||
// transferDevice
|
// transferDevice
|
||||||
} from '../WABinary'
|
} from '../WABinary'
|
||||||
import { unpadRandomMax16 } from './generics'
|
import { unpadRandomMax16 } from './generics'
|
||||||
import type { ILogger } from './logger'
|
import type { ILogger } from './logger'
|
||||||
import { decodeAndHydrate } from './proto-utils'
|
import { decodeAndHydrate } from './proto-utils'
|
||||||
|
|
||||||
const getDecryptionJid = async (sender: string, repository: SignalRepositoryWithLIDStore): Promise<string> => {
|
const getDecryptionJid = async (sender: string, repository: SignalRepositoryWithLIDStore): Promise<string> => {
|
||||||
if (!sender.includes('@s.whatsapp.net')) {
|
if (sender.includes('@lid')) {
|
||||||
return sender
|
return sender
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user