import { CauseException } from "../../errors.js"
import { logError, reportError } from "../../lib/errorReporter.js"
import { RequestContext } from "../../lib/RequestContext.js"

export class RequestException<E> extends CauseException<E> {
  constructor(cause: Cause<E>) {
    super(cause, "Request")
  }
}
export const reportRequestError_ = reportError(cause => new RequestException(cause))

export const reportRequestError = (cause: Cause<unknown>, context?: Record<string, unknown> | undefined) =>
  RequestContext.Tag.accessWithEffect(requestContext => reportRequestError_(cause, { requestContext, ...context }))

export const logRequestError_ = logError(cause => new RequestException(cause))

export const logRequestError = (cause: Cause<unknown>, context?: Record<string, unknown> | undefined) =>
  RequestContext.Tag.accessWithEffect(requestContext => logRequestError_(cause, { requestContext, ...context }))

/**
 * Forks the effect into a new fiber attached to the global scope. Because the
 * new fiber is attached to the global scope, when the fiber executing the
 * returned effect terminates, the forked fiber will continue running.
 *
 * Reports errors.
 *
 * @tsplus getter effect/io/Effect forkDaemonReportRequest
 */
export function forkDaemonReportRequest<R, E, A>(self: Effect<R, E, A>) {
  return self.tapErrorCause(reportRequestError)
    .fork.daemonChildren
}

/**
 * Forks the effect into a new fiber attached to the global scope. Because the
 * new fiber is attached to the global scope, when the fiber executing the
 * returned effect terminates, the forked fiber will continue running.
 *
 * Reports errors.
 *
 * @tsplus getter effect/io/Effect forkDaemonReportRequestUnexpected
 */
export function forkDaemonReportRequestUnexpected<R, E, A>(self: Effect<R, E, A>) {
  return self.tapErrorCause(cause =>
    cause.isInterruptedOnly() || cause.isDie()
      ? reportRequestError(cause)
      : logRequestError(cause)
  )
    .fork.daemonChildren
}