Function analyzeNewImport

packages/node-runtime/src/import/streaming-importer.ts:631–663

(
  filePath: string,
  onProgress: ImportProgressCallback
)

}

export async function analyzeNewImport(
  filePath: string,
  onProgress: ImportProgressCallback
): Promise<AnalyzeNewImportResult> {
  const formatFeature = detectFormat(filePath)
  if (!formatFeature) {
    return { totalMessages: 0, totalMembers: 0, meta: null, error: 'error.unrecognized_format' }
  }

  let meta: { name: string; platform: string; type: string } | null = null
  const memberSet = new Set<string>()
  let totalMessages = 0

  await streamParseFile(filePath, {
    onMeta: (parsedMeta: ParsedMeta) => {
      meta = { name: parsedMeta.name, platform: parsedMeta.platform, type: parsedMeta.type }
    },
    onMembers: (members: ParsedMember[]) => {
      for (const m of members) memberSet.add(m.platformId)
    },
    onProgress: (progress: ParseProgress) => {
      onProgress(progress)
    },
    onMessageBatch: (batch: ParsedMessage[]) => {
      for (const msg of batch) {
        totalMessages++
        if (!memberSet.has(msg.senderPlatformId)) memberSet.add(msg.senderPlatformId)
      }
    },
  })

  return { totalMessages, totalMembers: memberSet.size, meta }
}

// ==================== Temp DB for merge preview ====================