Function writeMessages

packages/node-runtime/src/services/push-importer.ts:143–221

(
  db: DatabaseAdapter,
  messages: PushImportMessage[],
  existingPmids: Set<string>,
  existingKeys: Set<string>
)

}

function writeMessages(
  db: DatabaseAdapter,
  messages: PushImportMessage[],
  existingPmids: Set<string>,
  existingKeys: Set<string>
): {
  writtenCount: number
  duplicateCount: number
  minWrittenTs: number
  ftsEntries: Array<{ id: number; content: string | null }>
} {
  const insertMsg = db.prepare(
    `INSERT INTO message (sender_id, sender_account_name, sender_group_nickname, ts, type, content, reply_to_message_id, platform_message_id)
     VALUES (?, ?, ?, ?, ?, ?, ?, ?)`
  )
  const getMemberId = db.prepare('SELECT id FROM member WHERE platform_id = ?')
  const insertMinimalMember = db.prepare('INSERT OR IGNORE INTO member (platform_id, account_name) VALUES (?, ?)')

  const memberIdCache = new Map<string, number>()
  let writtenCount = 0
  let duplicateCount = 0
  let minWrittenTs = Infinity
  const ftsEntries: Array<{ id: number; content: string | null }> = []

  const sorted = [...messages].sort((a, b) => a.timestamp - b.timestamp)

  db.transaction(() => {
    for (const msg of sorted) {
      const key = generateMessageKey(msg.timestamp, msg.sender, msg.content ?? null)
      if (msg.platformMessageId) {
        if (existingPmids.has(msg.platformMessageId)) {
          duplicateCount++
          continue
        }
        if (existingKeys.has(key)) {
          duplicateCount++
          continue
        }
        existingPmids.add(msg.platformMessageId)
        // Also register the content hash so a same-content no-pmid copy later
        // in this batch is caught by the fallback dedup path.
        existingKeys.add(key)
      } else {
        if (existingKeys.has(key)) {
          duplicateCount++
          continue
        }
        existingKeys.add(key)
      }

      let memberId = memberIdCache.get(msg.sender)
      if (!memberId) {
        insertMinimalMember.run(msg.sender, normalizeSenderAccountName(msg.sender, msg.accountName) || null)
        const row = getMemberId.get(msg.sender) as { id: number } | undefined
        if (row) {
          memberId = row.id
          memberIdCache.set(msg.sender, memberId)
        }