import { AxiosResponse, AxiosStatic } from 'axios'
import * as E from 'fp-ts/Either'
import { pipe } from 'fp-ts/function'
import * as RR from 'fp-ts/ReadonlyRecord'
import * as t from 'io-ts'
import * as $E from '../Error'
import * as $H from '../Http'
import * as $S from '../string'
import * as $TE from '../TaskEither'

const response =
  (url: string) =>
  (response: AxiosResponse): $H.HttpResponse => ({
    url: response.config.url || url,
    status: response.status,
    headers: pipe(
      response.headers,
      t.readonly(t.record(t.string, t.unknown)).decode,
      E.map(RR.filter(t.union([t.string, t.readonlyArray(t.string)]).is)),
      E.getOrElse(() => ({})),
    ),
    body: response.data,
  })

const request = (
  axios: AxiosStatic,
  method: $H.HttpMethod,
  url: string,
  options: $H.HttpOptions = {},
) =>
  $TE.tryCatch(
    () =>
      axios
        .request({
          data: options.body,
          headers: {
            ...options.headers,
            ...(options.json ? { 'Content-Type': 'application/json' } : null),
          },
          method,
          params: options.query,
          // eslint-disable-next-line no-nested-ternary
          ...(options.json
            ? { responseType: 'json' }
            : options.buffer
            ? { responseType: 'arraybuffer' }
            : null),
          url,
        })
        .then(response(url))
        .catch((error) => {
          if (!axios.isAxiosError(error) || undefined === error.response) {
            throw error
          }

          throw $E.wrap(
            new $H.HttpError(
              response(url)(error.response),
              `Cannot make HTTP request "${$S.uppercase(method)} ${url}": ${
                error.message
              }`,
            ),
          )(error)
        }),
    $E.fromUnknown(
      Error(`Cannot make HTTP request "${$S.uppercase(method)} ${url}"`),
    ),
  )

export const $axios = (_axios: AxiosStatic): $H.Http => ({
  delete: (url, options) => request(_axios, 'delete', url, options),
  get: (url, options) => request(_axios, 'get', url, options),
  patch: (url, options) => request(_axios, 'patch', url, options),
  post: (url, options) => request(_axios, 'post', url, options),
  put: (url, options) => request(_axios, 'put', url, options),
  head: (url, options) => request(_axios, 'head', url, options),
  options: (url, options) => request(_axios, 'options', url, options),
})