import httpEnv from "./auth/env"
import { getToken, removeToken } from "./auth/manageToken"
const baseApi = {
	//开发版
	develop: "https://kairos-wx.test.tuzuu.com/api",
	// 体验版
	trial: "https://kairos-wx.test.tuzuu.com/api",
	// 正式版
	release: "https://kairos-wx.test.tuzuu.com/api",
}
//获取当前环境的接口前缀
export const baseUrl = baseApi[httpEnv]

function request(options) {
	return new Promise((resolve, reject) => {
		const token = getToken()
		let header = {}
		if (token) {
			header.Authorization = 'Bearer ' + token;
		}
		wx.request({
			url: baseUrl + options.url,
			method: options.method || 'GET',
			data: options.data || {},
			header,
			timeout: 10000,
			success(res) {
				if (res.statusCode == 404) {
					wx.showToast({
						title: '接口404',
						icon: 'none'
					})
					return
				}
				const { code, data, message } = res.data
				if (code == 1) {
					resolve(data)
				} else if (code == 401) {
					//重新登录
					wx.showToast({
						title: message,
						icon: 'none'
					})
					removeToken()
					setTimeout(() => {
						wx.redirectTo({
							url: '/pages/system/login/index',
						})
					}, 1000);
				}
				else {
					wx.showToast({
						title: message,
						icon: 'none'
					})
				}
			},
			fail(err) {
				wx.showToast({
					title: "网络错误，请检查网络",
					icon: 'none'
				})
				reject(err)
			},
		})
	})
}

request.get = function (url, options) {
	return request({
		url: url,
		data: options,
		method: "GET",
	})
}

request.post = function (url, options) {
	return request({
		url: url,
		data: options,
		method: "POST",
	})
}

//流式
let lastChunk = '' //流可能会被截断，需要补充
export function streamRequest(url, data, onChunkReceived) {
	return new Promise((resolve, reject) => {
		const token = getToken()
		let header = {}
		if (token) {
			header.Authorization = 'Bearer ' + token;
		}
		let requestTask = wx.request({
			url: baseUrl + url,
			data: data || {},
			method: 'POST',
			header,
			timeout: 100000,
			responseType: "arraybuffer",
			enableChunked: true, //关键！开启流式传输模式
			success: () => {
				resolve()
			},
			fail: (e) => {
				console.log(e);
				reject()
			}
		})
		//处理流
		if (onChunkReceived) {
			lastChunk = ''
			requestTask.onChunkReceived((response) => {
				let data = response.data;
				// console.log(decodeStream(data));
				onChunkReceived(decodeStream(data))
			})
		}
	})
}
//流素具解码
function decodeStream(data) {
	let uint8Array = new Uint8Array(data);  // 将 ArrayBuffer 转换为 Uint8Array
	let responseText = decodeURIComponent(escape(String.fromCharCode.apply(null, uint8Array)));  // 使用 apply 扩展字节
	// 处理数据，移除前缀等操作
	if (lastChunk) {
		responseText = "data: " + lastChunk + responseText
		lastChunk = ""
	}
	// 处理数据，移除前缀等操作
	responseText = responseText.replaceAll("data: ", '');
	let jsonStrings = responseText.trim().split(/\n+/);
	// 过滤掉解析失败的部分
	let jsonArray = jsonStrings.map(jsonStr => {
		try {
			return JSON.parse(jsonStr);
		} catch (e) {
			lastChunk = jsonStr
			console.error('JSON格式不正确(已做兼容处理):');
			return null; // 如果解析失败，返回null
		}
	}).filter(item => item !== null);
	return jsonArray
}

export default request