import { logError } from './utils/log'

type XhrBody = Document | XMLHttpRequestBodyInit
type XhrConfig = (xhr: XMLHttpRequest) => { isText?: boolean; body?: XhrBody }
const send = <T = any>(config: XhrConfig) => {
  const xhr = new XMLHttpRequest()
  const { isText = true, body } = config(xhr)
  return new Promise<T>((resolve, reject) => {
    xhr.addEventListener('load', () => resolve(isText ? xhr.responseText : xhr.response))
    xhr.addEventListener('error', () => reject(xhr.status))
    xhr.send(body)
  })
}
const withCredentials = (config: XhrConfig) => (xhr: XMLHttpRequest) => {
  xhr.withCredentials = true
  return config(xhr)
}

// GET
const blobRequest =
  (url: string): XhrConfig =>
  (xhr: XMLHttpRequest) => {
    xhr.responseType = 'blob'
    xhr.open('GET', url)
    return {
      isText: false,
    }
  }
/**
 * 获取二进制`Blob`对象
 * @param url 链接
 */
export const getBlob = (url: string) => send<Blob>(blobRequest(url))
/**
 * 获取二进制`Blob`对象(带身份验证)
 * @param url 链接
 */
export const getBlobWithCredentials = (url: string) => send<Blob>(withCredentials(blobRequest(url)))

const textRequest =
  (url: string): XhrConfig =>
  (xhr: XMLHttpRequest) => {
    xhr.responseType = 'text'
    xhr.open('GET', url)
    return {
      isText: true,
    }
  }
/**
 * 获取文本
 * @param url 链接
 */
export const getText = (url: string) => send<string>(textRequest(url))

/**
 * 获取文本(带身份验证)
 * @param url 链接
 */
export const getTextWithCredentials = (url: string) =>
  send<string>(withCredentials(textRequest(url)))

const jsonRequest =
  (url: string): XhrConfig =>
  (xhr: XMLHttpRequest) => {
    xhr.responseType = 'json'
    xhr.open('GET', url)
    return {
      isText: false,
    }
  }
const convertToJson = <T = any>(response: any) => {
  if (typeof response === 'string') {
    return JSON.parse(response) as T
  }
  return response as T
}
/**
 * 获取 JSON 对象
 * @param url 链接
 */
export const getJson = async <T = any>(url: string) => {
  const response = await send(jsonRequest(url))
  return convertToJson<T>(response)
}
/**
 * 获取 JSON 对象(带身份验证)
 * @param url 链接
 */
export const getJsonWithCredentials = async <T = any>(url: string) => {
  const response = await send(withCredentials(jsonRequest(url)))
  return convertToJson<T>(response)
}

// POST
/**
 * 发送文本 (`application/x-www-form-urlencoded`)
 * @param url 链接
 * @param text 文本
 */
export const postText = (url: string, text: XhrBody) =>
  send<string>(xhr => {
    xhr.open('POST', url)
    xhr.setRequestHeader('Content-Type', 'application/x-www-form-urlencoded')
    return {
      isText: false,
      body: text,
    }
  })
/**
 * 发送文本 (`application/x-www-form-urlencoded`)(带身份验证)
 * @param url 链接
 * @param text 文本
 */
export const postTextWithCredentials = (url: string, text: XhrBody) =>
  send<string>(xhr => {
    xhr.open('POST', url)
    xhr.withCredentials = true
    xhr.setRequestHeader('Content-Type', 'application/x-www-form-urlencoded')
    return {
      isText: false,
      body: text,
    }
  })
/**
 * 发送 JSON 数据 (`application/json`)
 * @param url 链接
 * @param json JSON 对象
 */
export const postJson = (url: string, json: any) =>
  send<string>(xhr => {
    xhr.open('POST', url)
    xhr.setRequestHeader('Content-Type', 'application/json')
    return {
      isText: false,
      body: JSON.stringify(json),
    }
  })
/**
 * 发送 JSON 数据 (`application/json`)(带身份验证)
 * @param url 链接
 * @param json JSON 对象
 */
export const postJsonWithCredentials = (url: string, json: any) =>
  send<string>(xhr => {
    xhr.open('POST', url)
    xhr.withCredentials = true
    xhr.setRequestHeader('Content-Type', 'application/json')
    return {
      isText: false,
      body: JSON.stringify(json),
    }
  })

/**
 * 调用 Tampermonkey API 进行请求 (`GM_xmlhttpRequest`)
 * @param details 参数
 */
export const monkey = <T = any>(details: MonkeyXhrBasicDetails) =>
  new Promise<T>((resolve, reject) => {
    const fullDetails: MonkeyXhrDetails = {
      nocache: true,
      ...details,
      onload: (r: MonkeyXhrResponse) => resolve(r.response),
      onerror: (r: MonkeyXhrResponse) => {
        // 重新序列化一下取出对象字段, 油猴给的是一个函数对象混合体
        const realObject = {
          ...JSON.parse(JSON.stringify(r)),
          toString() {
            return JSON.stringify(this)
          },
        }
        reject(realObject)
      },
    }
    if (!('method' in fullDetails)) {
      fullDetails.method = 'GET'
    }
    GM_xmlhttpRequest(fullDetails)
  })
/**
 * 获取全部的分页数据, 返回一个会随翻页变化的数组, 可用于响应式数据
 * @param config 配置参数
 */
export const responsiveGetPages = <T = any>(config: {
  /** API 地址, 可接受`page`参数表示页码 */
  api: (page: number) => Promise<any>
  /** 从返回的对象中获取本页的数据 */
  getList: (json: any) => T[]
  /** 从返回的对象中获取数据总数 */
  getTotal: (json: any) => number
}): [Promise<T[]>, Promise<T[]>] => {
  let responsivePromise: Promise<T[]>
  const totalPromise = new Promise<T[]>(resolveTotal => {
    responsivePromise = new Promise(resolveResponsive => {
      ;(async () => {
        const { api, getList, getTotal } = config
        let total = Infinity
        const result: T[] = []

        const fetchPage = async (p: number): Promise<T[]> => {
          const json = await api(p)
          if (json.code !== 0) {
            console.warn(
              `api failed in ajax.getPages. message = ${json.message}, page = ${p}, total = ${total}, api = `,
              api,
            )
            return []
          }
          return getList(json)
        }

        // 请求第一次获得 total
        const firstReq = await api(1)
        result.push(...getList(firstReq))

        total = getTotal(firstReq)
        const pageSize = getList(firstReq).length || 1 // 防止为 0
        const totalPages = Math.ceil(total / pageSize)
        resolveResponsive(result) // 第一页
        if (totalPages === 1) {
          resolveTotal(result)
          return
        }
        // 收集 Promise，每 5 个为一个 batch 运行
        const batchSize = 5
        let batch: Promise<T[]>[] = []
        for (let i = 2; i <= totalPages; i++) {
          batch.push(fetchPage(i))
          if (batch.length === batchSize || i === totalPages) {
            const lists = await Promise.all(batch)
            result.push(...lists.flat())
            batch = []
          }
        }
        // 等所有并发完成
        resolveTotal(result)
      })()
    })
  })
  return [responsivePromise, totalPromise]
}
/**
 * 获取全部的分页数据
 * @param config 配置参数
 */
export const getPages = async <T = any>(config: {
  /** API 地址, 可接受`page`参数表示页码 */
  api: (page: number) => Promise<any>
  /** 从返回的对象中获取本页的数据 */
  getList: (json: any) => T[]
  /** 从返回的对象中获取数据总数 */
  getTotal: (json: any) => number
}) => {
  const [, total] = responsiveGetPages(config)
  const result = await total
  return result
}

/** bilibili API 标准响应 */
export interface BilibiliApiResponse {
  code: number
  message: string
  msg?: string
  ttl: number
  data: any
  result?: any
}

/**
 * 进行 bilibili API 标准响应处理
 * @param apiPromise 运行中的 API Promise
 * @param errorMessage 出错时的提示信息
 */
export const bilibiliApi = async <T = any>(
  apiPromise: Promise<BilibiliApiResponse>,
  errorMessage?: string,
) => {
  const json = await apiPromise
  if (json.code !== 0) {
    const error = new Error(
      `${errorMessage}: code = ${json.code}, message = ${json.message || json.msg}`,
    )
    logError(error)
    throw error
  }
  return (json.data || json.result || {}) as T
}