import type { Task } from '@vitest/runner'
import type { Writable } from 'node:stream'
import type { TypeCheckError } from '../typecheck/typechecker'
import type { Vitest } from './core'
import type { TestProject } from './project'
import { Console } from 'node:console'
import { toArray } from '@vitest/utils/helpers'
import c from 'tinyrainbow'
import { highlightCode } from '../utils/colors'
import { printError } from './printError'
import { divider, errorBanner, formatProjectName, withLabel } from './reporters/renderers/utils'
import { RandomSequencer } from './sequencers/RandomSequencer'

export interface ErrorOptions {
  type?: string
  fullStack?: boolean
  project?: TestProject
  verbose?: boolean
  screenshotPaths?: string[]
  task?: Task
  showCodeFrame?: boolean
}

type Listener = () => void

const PAD = '      '

const ESC = '\x1B['
const ERASE_DOWN = `${ESC}J`
const ERASE_SCROLLBACK = `${ESC}3J`
const CURSOR_TO_START = `${ESC}1;1H`
const HIDE_CURSOR = `${ESC}?25l`
const SHOW_CURSOR = `${ESC}?25h`
const CLEAR_SCREEN = '\x1Bc'

export class Logger {
  private _clearScreenPending: string | undefined
  private _highlights = new Map<string, string>()
  private cleanupListeners: Listener[] = []
  public console: Console

  constructor(
    public ctx: Vitest,
    public outputStream: NodeJS.WriteStream | Writable = process.stdout,
    public errorStream: NodeJS.WriteStream | Writable = process.stderr,
  ) {
    this.console = new Console({ stdout: outputStream, stderr: errorStream })
    this._highlights.clear()
    this.addCleanupListeners()
    this.registerUnhandledRejection()

    if ((this.outputStream as typeof process.stdout).isTTY) {
      (this.outputStream as Writable).write(HIDE_CURSOR)
    }
  }

  log(...args: any[]): void {
    this._clearScreen()
    this.console.log(...args)
  }

  error(...args: any[]): void {
    this._clearScreen()
    this.console.error(...args)
  }

  warn(...args: any[]): void {
    this._clearScreen()
    this.console.warn(...args)
  }

  clearFullScreen(message = ''): void {
    if (!this.ctx.config.clearScreen) {
      this.console.log(message)
      return
    }

    if (message) {
      this.console.log(`${CLEAR_SCREEN}${ERASE_SCROLLBACK}${message}`)
    }
    else {
      (this.outputStream as Writable).write(`${CLEAR_SCREEN}${ERASE_SCROLLBACK}`)
    }
  }

  clearScreen(message: string, force = false): void {
    if (!this.ctx.config.clearScreen) {
      this.console.log(message)
      return
    }

    this._clearScreenPending = message
    if (force) {
      this._clearScreen()
    }
  }

  private _clearScreen() {
    if (this._clearScreenPending == null) {
      return
    }

    const log = this._clearScreenPending
    this._clearScreenPending = undefined
    this.console.log(`${CURSOR_TO_START}${ERASE_DOWN}${log}`)
  }

  printError(err: unknown, options: ErrorOptions = {}): void {
    printError(err, this.ctx, this, options)
  }

  deprecate(message: string): void {
    this.error(c.bold(c.bgYellow(' DEPRECATED ')), c.yellow(message))
  }

  clearHighlightCache(filename?: string): void {
    if (filename) {
      this._highlights.delete(filename)
    }
    else {
      this._highlights.clear()
    }
  }

  highlight(filename: string, source: string): string {
    if (this._highlights.has(filename)) {
      return this._highlights.get(filename)!
    }
    const code = highlightCode(filename, source)
    this._highlights.set(filename, code)
    return code
  }

  printNoTestTagsFound(): void {
    this.error(c.bgRed(' ERROR '), c.red('No test tags found in any project. Exiting with code 1.'))
  }

  printTags(): void {
    const vitest = this.ctx
    const rootProject = vitest.getRootProject()
    const projects = [
      rootProject,
      ...vitest.projects.filter(p => p !== rootProject),
    ]

    const hasTags = projects.some(p => p.config.tags && p.config.tags.length > 0)

    if (!hasTags) {
      process.exitCode = 1
      return this.printNoTestTagsFound()
    }

    for (const project of projects) {
      const name = project.name
      if (name) {
        this.log(formatProjectName(project, ''))
      }
      project.config.tags.forEach((tag) => {
        const tagLog = `${tag.name}${tag.description ? `: ${tag.description}` : ''}`
        this.log(`  ${tagLog}`)
      })
    }
  }

  printNoTestFound(filters?: string[]): void {
    const config = this.ctx.config

    if (config.watch && (config.changed || config.related?.length)) {
      this.log(`No affected ${config.mode} files found\n`)
    }
    else if (config.watch) {
      this.log(
        c.red(`No ${config.mode} files found. You can change the file name pattern by pressing "p"\n`),
      )
    }
    else {
      if (config.passWithNoTests) {
        this.log(`No ${config.mode} files found, exiting with code 0\n`)
      }
      else {
        this.error(
          c.red(`No ${config.mode} files found, exiting with code 1\n`),
        )
      }
    }

    const comma = c.dim(', ')
    if (filters?.length) {
      this.console.error(c.dim('filter: ') + c.yellow(filters.join(comma)))
    }
    const projectsFilter = toArray(config.project)
    if (projectsFilter.length) {
      this.console.error(
        c.dim('projects: ') + c.yellow(projectsFilter.join(comma)),
      )
    }
    this.ctx.projects.forEach((project) => {
      const config = project.config
      const printConfig = !project.isRootProject() && project.name
      if (printConfig) {
        this.console.error(`\n${formatProjectName(project)}\n`)
      }
      if (config.include) {
        this.console.error(
          c.dim('include: ') + c.yellow(config.include.join(comma)),
        )
      }
      if (config.exclude) {
        this.console.error(
          c.dim('exclude:  ') + c.yellow(config.exclude.join(comma)),
        )
      }
      if (config.typecheck.enabled) {
        this.console.error(
          c.dim('typecheck include: ')
          + c.yellow(config.typecheck.include.join(comma)),
        )
        this.console.error(
          c.dim('typecheck exclude: ')
          + c.yellow(config.typecheck.exclude.join(comma)),
        )
      }
    })
    this.console.error()
  }

  printBanner(): void {
    this.log()

    const color = this.ctx.config.watch ? 'blue' : 'cyan'
    const mode = this.ctx.config.watch ? 'DEV' : 'RUN'

    this.log(withLabel(color, mode, `v${this.ctx.version} `) + c.gray(this.ctx.config.root))

    // Log seed if either files (RandomSequencer) or tests are shuffled
    if (this.ctx.config.sequence.sequencer === RandomSequencer || this.ctx.config.sequence.shuffle) {
      this.log(PAD + c.gray(`Running tests with seed "${this.ctx.config.sequence.seed}"`))
    }

    if (this.ctx.config.ui) {
      const host = this.ctx.config.api?.host || 'localhost'
      const port = this.ctx.vite.config.server.port
      const base = this.ctx.config.uiBase

      this.log(PAD + c.dim(c.green(`UI started at http://${host}:${c.bold(port)}${base}`)))
    }
    else if (this.ctx.config.api?.port) {
      const resolvedUrls = this.ctx.vite.resolvedUrls
      // workaround for https://github.com/vitejs/vite/issues/15438, it was fixed in vite 5.1
      const fallbackUrl = `http://${this.ctx.config.api.host || 'localhost'}:${this.ctx.config.api.port}`
      const origin = resolvedUrls?.local[0] ?? resolvedUrls?.network[0] ?? fallbackUrl

      this.log(PAD + c.dim(c.green(`API started at ${new URL('/', origin)}`)))
    }

    if (this.ctx.coverageProvider) {
      this.log(PAD + c.dim('Coverage enabled with ') + c.yellow(this.ctx.coverageProvider.name))
    }

    if (this.ctx.config.standalone) {
      this.log(c.yellow(`\nVitest is running in standalone mode. Edit a test file to rerun tests.\n`))
    }
    else {
      this.log()
    }
  }

  printBrowserBanner(project: TestProject): void {
    if (!project.browser) {
      return
    }

    const resolvedUrls = project.browser.vite.resolvedUrls
    const origin = resolvedUrls?.local[0] ?? resolvedUrls?.network[0]
    if (!origin) {
      return
    }

    const output = project.isRootProject()
      ? ''
      : formatProjectName(project)
    const provider = project.browser.provider?.name
    const providerString = provider === 'preview' ? '' : ` by ${c.reset(c.bold(provider))}`
    this.log(
      c.dim(
        `${output}Browser runner started${providerString} ${c.dim('at')} ${c.blue(new URL('/__vitest_test__/', origin))}\n`,
      ),
    )
  }

  printUnhandledErrors(errors: ReadonlyArray<unknown>): void {
    const errorMessage = c.red(
      c.bold(
        `\nVitest caught ${errors.length} unhandled error${
          errors.length > 1 ? 's' : ''
        } during the test run.`
        + '\nThis might cause false positive tests. Resolve unhandled errors to make sure your tests are not affected.',
      ),
    )
    this.error(errorBanner('Unhandled Errors'))
    this.error(errorMessage)
    errors.forEach((err) => {
      this.printError(err, {
        fullStack: (err as any).name !== 'EnvironmentTeardownError',
        type: (err as any).type || 'Unhandled Error',
      })
    })
    this.error(c.red(divider()))
  }

  printSourceTypeErrors(errors: TypeCheckError[]): void {
    const errorMessage = c.red(
      c.bold(
        `\nVitest found ${errors.length} error${
          errors.length > 1 ? 's' : ''
        } not related to your test files.`,
      ),
    )
    this.log(errorBanner('Source Errors'))
    this.log(errorMessage)
    errors.forEach((err) => {
      this.printError(err, { fullStack: true })
    })
    this.log(c.red(divider()))
  }

  getColumns(): number {
    return 'columns' in this.outputStream ? this.outputStream.columns : 80
  }

  onTerminalCleanup(listener: Listener): void {
    this.cleanupListeners.push(listener)
  }

  private addCleanupListeners() {
    const cleanup = () => {
      this.cleanupListeners.forEach(fn => fn())

      if ((this.outputStream as typeof process.stdout).isTTY) {
        (this.outputStream as Writable).write(SHOW_CURSOR)
      }
    }

    const onExit = (signal?: string | number, exitCode?: number) => {
      cleanup()

      // Interrupted signals don't set exit code automatically.
      // Use same exit code as node: https://nodejs.org/api/process.html#signal-events
      if (process.exitCode === undefined) {
        process.exitCode = exitCode !== undefined ? (128 + exitCode) : Number(signal)
      }

      // Timeout to flush stderr
      setTimeout(() => process.exit(), 1)
    }

    process.once('SIGINT', onExit)
    process.once('SIGTERM', onExit)
    process.once('exit', onExit)

    this.ctx.onClose(() => {
      process.off('SIGINT', onExit)
      process.off('SIGTERM', onExit)
      process.off('exit', onExit)
      cleanup()
    })
  }

  private registerUnhandledRejection() {
    const onUnhandledRejection = (err: unknown) => {
      process.exitCode = 1

      this.printError(err, {
        fullStack: true,
        type: 'Unhandled Rejection',
      })

      this.error('\n\n')
      process.exit()
    }

    process.on('unhandledRejection', onUnhandledRejection)

    this.ctx.onClose(() => {
      process.off('unhandledRejection', onUnhandledRejection)
    })
  }
}
