Function detectConflictsInMessages

packages/core/src/merger/algorithms.ts:118–186

(
  allMessages: Array<{ msg: MergerMessage; source: string; platform: string }>
)

// ==================== Conflict detection ====================

export function detectConflictsInMessages(
  allMessages: Array<{ msg: MergerMessage; source: string; platform: string }>
): ConflictCheckResult {
  const collidingIds = getCollidingPlatformIdsFromMessages(allMessages)
  const conflicts: MergeConflict[] = []

  const timeGroups = new Map<number, Array<{ msg: MergerMessage; source: string; platform: string }>>()
  for (const item of allMessages) {
    const ts = item.msg.timestamp
    if (!timeGroups.has(ts)) timeGroups.set(ts, [])
    timeGroups.get(ts)!.push(item)
  }

  for (const [ts, items] of timeGroups) {
    if (items.length < 2) continue

    const senderGroups = new Map<string, typeof items>()
    for (const item of items) {
      const sender = normalizePlatformId(item.msg.senderPlatformId, item.platform || 'unknown', collidingIds)
      if (!senderGroups.has(sender)) senderGroups.set(sender, [])
      senderGroups.get(sender)!.push(item)
    }

    for (const [sender, senderItems] of senderGroups) {
      if (senderItems.length < 2) continue
      const sources = new Set(senderItems.map((it) => it.source))
      if (sources.size < 2) continue

      const contentGroups = new Map<string, typeof senderItems>()
      for (const item of senderItems) {
        const c = item.msg.content || ''
        if (!contentGroups.has(c)) contentGroups.set(c, [])
        contentGroups.get(c)!.push(item)
      }

      if (contentGroups.size > 1) {
        const entries = Array.from(contentGroups.entries())
        for (let i = 0; i < entries.length - 1; i++) {
          for (let j = i + 1; j < entries.length; j++) {
            const [c1, items1] = entries[i]
            const [c2, items2] = entries[j]
            const item1 = items1[0]
            const item2 = items2.find((it) => it.source !== item1.source)
            if (!item2) continue
            if (isImageOnlyMessage(c1) && isImageOnlyMessage(c2)) continue

            conflicts.push({
              id: `conflict_${ts}_${sender}_${conflicts.length}`,
              timestamp: ts,
              sender: getDisplayName(item1.msg) || sender,
              contentLength1: c1.length,
              contentLength2: c2.length,
              content1: c1,
              content2: c2,
            })
          }
        }
      }