Function fullImport

packages/node-runtime/src/services/push-importer.ts:223–306

(
  db: DatabaseAdapter,
  meta: PushImportMeta,
  members: PushImportMember[],
  messages: PushImportMessage[]
)

}

function fullImport(
  db: DatabaseAdapter,
  meta: PushImportMeta,
  members: PushImportMember[],
  messages: PushImportMessage[]
): { writtenCount: number; duplicateCount: number; membersAdded: number } {
  db.exec(CHAT_DB_SCHEMA)

  // Auto-create minimal member entries for senders not listed in members,
  // preserving the protocol promise that unknown senders are auto-created.
  const knownIds = new Set(members.map((m) => m.platformId))
  const extraMembers: PushImportMember[] = []
  for (const msg of messages) {
    if (!knownIds.has(msg.sender)) {
      extraMembers.push({
        platformId: msg.sender,
        accountName: normalizeSenderAccountName(msg.sender, msg.accountName),
        groupNickname: normalizeSenderGroupNickname(msg.sender, msg.groupNickname),
      })
      knownIds.add(msg.sender)
    }
  }
  const allMembers = extraMembers.length > 0 ? [...members, ...extraMembers] : members

  // Deduplicate within the batch using the same pmid/hash logic as incremental imports.
  const pmids = new Set<string>()
  const hashKeys = new Set<string>()
  let duplicateCount = 0
  const dedupedMessages: PushImportMessage[] = []
  for (const msg of messages) {
    const key = generateMessageKey(msg.timestamp, msg.sender, msg.content ?? null)
    if (msg.platformMessageId) {
      if (pmids.has(msg.platformMessageId)) {
        duplicateCount++
        continue
      }
      if (hashKeys.has(key)) {
        duplicateCount++
        continue
      }
      pmids.add(msg.platformMessageId)
      hashKeys.add(key)
    } else {
      if (hashKeys.has(key)) {
        duplicateCount++
        continue
      }
      hashKeys.add(key)
    }
    dedupedMessages.push(msg)
  }

  // Delegate to the shared writer so member_name_history is tracked correctly,
  // matching the behaviour of file-based full imports.
  const stats = writeParseResultToDb(
    db,
    meta,
    allMembers.map((m) => ({