// ets_tracing: off

import * as C from "../Cause/index.js"
import { identity, pipe } from "../Function/index.js"
import * as O from "../Option/core.js"
import { catchAllCause_ } from "./catchAllCause.js"
import { halt } from "./core.js"
import type { Effect } from "./effect.js"
import { fail } from "./fail.js"

/**
 * Takes some fiber failures and converts them into errors.
 *
 * @ets_data_first unrefine_
 */
export function unrefine<E1>(pf: (u: unknown) => O.Option<E1>, __trace?: string) {
  return <R, E, A>(fa: Effect<R, E, A>) => unrefine_(fa, pf, __trace)
}

/**
 * Takes some fiber failures and converts them into errors.
 */
export function unrefine_<R, E, A, E1>(
  fa: Effect<R, E, A>,
  pf: (u: unknown) => O.Option<E1>,
  __trace?: string
) {
  return unrefineWith_(fa, pf, identity, __trace)
}

/**
 * Takes some fiber failures and converts them into errors, using the
 * specified function to convert the `E` into an `E1 | E2`.
 *
 * @ets_data_first unrefineWith_
 */
export function unrefineWith<E1, E, E2>(
  pf: (u: unknown) => O.Option<E1>,
  f: (e: E) => E2,
  __trace?: string
) {
  return <R, A>(fa: Effect<R, E, A>) => unrefineWith_(fa, pf, f, __trace)
}

/**
 * Takes some fiber failures and converts them into errors, using the
 * specified function to convert the `E` into an `E1 | E2`.
 */
export function unrefineWith_<R, E, E1, E2, A>(
  fa: Effect<R, E, A>,
  pf: (u: unknown) => O.Option<E1>,
  f: (e: E) => E2,
  __trace?: string
) {
  return catchAllCause_(
    fa,
    (cause): Effect<R, E1 | E2, A> =>
      pipe(
        cause,
        C.find((c) => (c._tag === "Die" ? pf(c.value) : O.none)),
        O.fold(() => pipe(cause, C.map(f), halt), fail)
      ),
    __trace
  )
}