Function deduplicateAndSortMessages

packages/core/src/merger/algorithms.ts:219–246

(
  sources: Array<{ platform: string; messages: MergerMessage[] }>,
  collidingIds: Set<string>
)

// ==================== Message dedup + sort ====================

export function deduplicateAndSortMessages(
  sources: Array<{ platform: string; messages: MergerMessage[] }>,
  collidingIds: Set<string>
): MergedMessage[] {
  const seen = new Set<string>()
  const merged: MergedMessage[] = []

  for (const { platform, messages } of sources) {
    const p = platform || 'unknown'
    for (const msg of messages) {
      const nid = normalizePlatformId(msg.senderPlatformId, p, collidingIds)
      const key = getMessageKey(msg, nid)
      if (seen.has(key)) continue
      seen.add(key)
      merged.push({
        sender: nid,
        accountName: msg.senderAccountName,
        groupNickname: msg.senderGroupNickname,
        timestamp: msg.timestamp,
        type: msg.type,
        content: msg.content,
      })
    }
  }

  merged.sort((a, b) => a.timestamp - b.timestamp)
  return merged
}