import { anySignal } from 'any-signal'
import { setMaxListeners } from 'main-event'
import { debounce } from './debounce.ts'
import type { AbortOptions } from '@libp2p/interface'

export interface RepeatingTask {
  /**
   * Update the interval after which the next iteration of the task will run.
   *
   * This is useful if, for example, you want to retry a task with a short rest
   * duration until it succeeds, then periodically after that.
   *
   * This only affects the next iteration of the task, if it is currently
   * running, that run will not be interrupted.
   *
   * Setting the interval to the current value has no effect.
   */
  setInterval(ms: number): void

  /**
   * Update the amount of time a task will run before the passed abort signal
   * will fire.
   *
   * This only affects the next iteration of the task, if it is currently
   * running, that run will not be interrupted.
   */
  setTimeout(ms: number): void

  /**
   * Schedule the task to be run immediately - if the task is not running it
   * will run after a short delay in order to debounce multiple `.run()`
   * invocations.
   */
  run(): void

  /**
   * Start the task running
   */
  start(): void

  /**
   * Stop the task running
   */
  stop(): void
}

export interface RepeatingTaskOptions {
  /**
   * How long the task is allowed to run before the passed AbortSignal fires an
   * abort event
   */
  timeout?: number

  /**
   * Whether to schedule the task to run immediately
   *
   * @default false
   */
  runImmediately?: boolean

  /**
   * When `.run()` is called to run the task outside of the current interval,
   * debounce repeated calls to `.run()` by this amount.
   *
   * @default 100
   */
  debounce?: number
}

export function repeatingTask (fn: (options?: AbortOptions) => void | Promise<void>, interval: number, options?: RepeatingTaskOptions): RepeatingTask {
  let timeout: ReturnType<typeof setTimeout>
  let shutdownController: AbortController
  let running = false

  function runTask (): void {
    const opts: AbortOptions = {
      signal: shutdownController.signal
    }

    let signal: ReturnType<typeof anySignal> | undefined

    if (options?.timeout != null) {
      signal = anySignal([shutdownController.signal, AbortSignal.timeout(options.timeout)])
      setMaxListeners(Infinity, signal)

      opts.signal = signal
    }

    running = true

    Promise.resolve().then(async () => {
      await fn(opts)
    })
      .catch(() => {})
      .finally(() => {
        if (signal != null) {
          if (signal.aborted) {
            signal.clear()
          } else {
            // Clear listeners once this per-run signal eventually aborts
            signal.addEventListener('abort', () => {
              signal.clear()
            }, { once: true })
          }
        }

        running = false

        if (shutdownController.signal.aborted) {
          // task has been cancelled, bail
          return
        }

        // reschedule
        timeout = setTimeout(runTask, interval)
      })
  }

  const runTaskDebounced = debounce(runTask, options?.debounce ?? 100)

  let started = false

  return {
    setInterval: (ms): void => {
      if (interval === ms) {
        // already running at this interval, nothing to do
        return
      }

      interval = ms

      // maybe reschedule
      if (timeout != null) {
        clearTimeout(timeout)
        timeout = setTimeout(runTask, interval)
      }
    },
    setTimeout: (ms): void => {
      options ??= {}
      options.timeout = ms
    },
    run: (): void => {
      if (running) {
        return
      }

      clearTimeout(timeout)
      runTaskDebounced()
    },
    start: (): void => {
      if (started) {
        return
      }

      started = true
      shutdownController = new AbortController()
      setMaxListeners(Infinity, shutdownController.signal)

      // run now
      if (options?.runImmediately === true) {
        queueMicrotask(() => {
          runTask()
        })
      } else {
        // run later
        timeout = setTimeout(runTask, interval)
      }
    },
    stop: (): void => {
      clearTimeout(timeout)
      shutdownController?.abort()
      started = false
    }
  }
}