/**
 * CSVファイルからユーザーを取り込む。
 * 1行でもエラーがあれば、何も保存せずにエラーの一覧を返す。
 */
const importUsers = async (file: File): Promise<ImportResult> => {
  const lines = (await file.text()).split("\n").slice(1)
  const seen = new Set<string>()
  const errors: ImportError[] = []
  const users: NewUser[] = []

  for (const [i, line] of lines.entries()) {
    const [name, email] = line.split(",")
    const row = i + 2

    if (!name || !email) errors.push({ row, reason: "必須項目がありません" })
    else if (!EMAIL_RE.test(email)) errors.push({ row, reason: "形式が不正です" })
    else if (seen.has(email)) errors.push({ row, reason: "CSV内で重複しています" })
    else if (await db.user.exists({ email })) errors.push({ row, reason: "登録済みです" })
    else users.push({ name, email })

    seen.add(email)
  }

  if (errors.length > 0) return { ok: false, errors }

  await db.transaction((tx) => tx.user.createMany(users))
  return { ok: true, importedCount: users.length }
}

/**
 * CSVファイルからユーザーを取り込む。
 * 1行でもエラーがあれば、何も保存せずにエラーの一覧を返す。
 */
const importUsers = async (file: File): Promise<ImportResult> => {
  const rows = await readUserCsv(file)
  const registeredEmails = await findRegisteredEmails(rows)
  const validation = validateUsers(rows, registeredEmails)

  if (!validation.ok) {
    return { ok: false, errors: validation.errors }
  }

  await saveUsers(validation.users)

  return { ok: true, importedCount: validation.users.length }
}

/**
 * CSVファイルを読み込み、行番号付きのデータに変換する。
 * 行番号はヘッダーを1行目として数える。
 */
const readUserCsv = async (file: File): Promise<CsvRow[]> => {
  const [, ...lines] = (await file.text()).split("\n")

  return lines.map((line, i) => {
    const [name, email] = line.split(",")
    return { row: i + 2, name, email }
  })
}

/**
 * CSVに含まれるメールアドレスのうち、登録済みのものを返す。
 */
const findRegisteredEmails = async (rows: CsvRow[]): Promise<Set<string>> => {
  const emails = rows.map(({ email }) => email).filter(Boolean)
  const users = await db.user.findMany({ email: { in: emails } })

  return new Set(users.map(({ email }) => email))
}

/**
 * 各行を検証し、エラーがなければ保存するユーザーデータを返す。
 * 1行につき、最初に見つかったエラーのみを返す。
 */
const validateUsers = (
  rows: CsvRow[],
  registeredEmails: Set<string>,
): ValidationResult => {
  const errors: ImportError[] = []
  const seen = new Set<string>()

  for (const { row, name, email } of rows) {
    if (!name || !email) {
      errors.push({ row, reason: "必須項目がありません" })
      continue
    }
    if (!EMAIL_RE.test(email)) {
      errors.push({ row, reason: "形式が不正です" })
      continue
    }
    if (seen.has(email)) {
      errors.push({ row, reason: "CSV内で重複しています" })
      continue
    }
    seen.add(email)

    if (registeredEmails.has(email)) {
      errors.push({ row, reason: "登録済みです" })
    }
  }

  if (errors.length > 0) {
    return { ok: false, errors }
  }

  return { ok: true, users: rows.map(({ name, email }) => ({ name, email })) }
}

/**
 * トランザクション内でユーザーをまとめて保存する。
 */
const saveUsers = async (users: NewUser[]): Promise<void> => {
  await db.transaction((tx) => tx.user.createMany(users))
}