Function registerImportRoutes

apps/cli/src/http/routes/web/import.ts:47–485

(
  server: FastifyInstance,
  dbManager: DatabaseManager,
  options: ImportRouteOptions = {}
)

}

export function registerImportRoutes(
  server: FastifyInstance,
  dbManager: DatabaseManager,
  options: ImportRouteOptions = {}
): void {
  const sourceManager =
    options.sourceManager ??
    new ArchiveImportSourceManager({
      tempRoot: fs.mkdtempSync(path.join(os.tmpdir(), 'chatlab-import-sources-')),
    })
  const runPreparedImport =
    options.runPreparedImport ??
    (async (manifestPath: string, onProgress: (progress: unknown) => void) => {
      const result = await streamImport(dbManager, manifestPath, {
        formatId: 'google-chat-takeout',
        nativeBinding: resolveNativeBinding(),
        onProgress: onProgress as any,
      })
      return {
        success: result.success,
        sessionId: result.sessionId,
        error: result.error,
        messageCount: result.diagnostics?.messagesWritten ?? 0,
        memberCount: 0,
      }
    })

  server.addHook('onClose', async () => {
    await sourceManager.close()
  })

  server.post('/_web/import-sources', async (request, reply) => {
    const data = await (request as any).file({
      limits: { fileSize: ARCHIVE_UPLOAD_LIMIT },
    })
    if (!data) return reply.code(400).send({ success: false, error: 'error.no_file_selected' })

    const uploadPath = path.join(os.tmpdir(), `chatlab-archive-${randomUUID()}.zip`)
    try {
      await pipeline(data.file, fs.createWriteStream(uploadPath, { flags: 'wx' }))
      if (data.file.truncated) {
        cleanupTemp(uploadPath)
        return reply.code(413).send({ success: false, error: 'error.archive_limit_exceeded' })
      }

      const source = await sourceManager.prepareOwnedArchive(uploadPath)
      return { success: true, source }
    } catch (error) {
      cleanupTemp(uploadPath)
      if (error instanceof ArchiveImportError) {
        return reply.code(400).send({ success: false, error: error.code })
      }
      return reply.code(400).send({
        success: false,
        error: error instanceof Error ? error.message : String(error),
      })
    }
  })