Function mergeMembers

packages/core/src/query/member-ops.ts:48–108

(db: DatabaseAdapter, memberId1: number, memberId2: number)

 * with more messages (or the lower id on tie). The secondary member is deleted.
 */
export function mergeMembers(db: DatabaseAdapter, memberId1: number, memberId2: number): boolean {
  if (memberId1 === memberId2) return false

  try {
    const rows = db
      .prepare(
        `
        SELECT
          m.id,
          m.platform_id as platformId,
          m.account_name as accountName,
          m.group_nickname as groupNickname,
          m.aliases,
          m.avatar,
          COUNT(msg.id) as messageCount
        FROM member m
        LEFT JOIN message msg ON m.id = msg.sender_id
        WHERE m.id IN (?, ?)
        GROUP BY m.id
      `
      )
      .all(memberId1, memberId2) as unknown as MemberMergeRow[]

    if (rows.length !== 2) return false

    const [memberA, memberB] = rows
    let primary = memberA
    let secondary = memberB

    if (
      memberB.messageCount > memberA.messageCount ||
      (memberB.messageCount === memberA.messageCount && memberB.id < memberA.id)
    ) {
      primary = memberB
      secondary = memberA
    }

    const mergedAliases = Array.from(new Set([...parseAliases(primary.aliases), ...parseAliases(secondary.aliases)]))
    const mergedAccountName = primary.accountName || secondary.accountName
    const mergedGroupNickname = primary.groupNickname || secondary.groupNickname
    const mergedAvatar = primary.avatar || secondary.avatar

    db.transaction(() => {
      db.prepare('UPDATE message SET sender_id = ? WHERE sender_id = ?').run(primary.id, secondary.id)
      db.prepare('UPDATE member_name_history SET member_id = ? WHERE member_id = ?').run(primary.id, secondary.id)
      db.prepare('UPDATE meta SET owner_id = ? WHERE owner_id = ?').run(primary.platformId, secondary.platformId)
      db.prepare(`UPDATE member SET account_name = ?, group_nickname = ?, avatar = ?, aliases = ? WHERE id = ?`).run(
        mergedAccountName,
        mergedGroupNickname,
        mergedAvatar,
        JSON.stringify(mergedAliases),
        primary.id
      )
      db.prepare('DELETE FROM member WHERE id = ?').run(secondary.id)
    })

    return true
  } catch {