package cc.mrbird.febs.unisoftiot.config;

import cc.mrbird.febs.common.exception.FebsException;
import cc.mrbird.febs.unisoftiot.enums.ResponseCodeEnum;
import cc.mrbird.febs.unisoftiot.utils.OkHttpUtils;
import cn.hutool.core.util.StrUtil;
import cn.hutool.json.JSONObject;
import okhttp3.Request;
import okhttp3.Response;
import okhttp3.ResponseBody;
import org.json.JSONException;

import java.io.IOException;

/**
 * 响应处理器类，用于处理OKHTTP请求的响应
 */
public final class ResponseHandler {

    // 错误信息前缀
    private static final String ERROR_PREFIX = "[ResponseHandler] OKHTTP Error: ";

    // 私有构造方法，防止实例化
    private ResponseHandler() {
    }

    /**
     * 处理HTTP响应
     * @param request 请求对象
     * @return 响应体字符串
     * @throws FebsException 当响应处理失败时抛出
     */
    public static String handleResponse(Request request) {
        try (
                // 执行HTTP请求并获取响应
                Response response = OkHttpUtils.builder().okHttpClient.newCall(request).execute()
        ) {
            // 获取响应体内容
            String responseBodyStr = getResponseBodyAsString(response.body());
            if (ResponseCodeEnum.isFail(response.code())) {
                throw new FebsException(ERROR_PREFIX + responseBodyStr);
            }
            // 如果响应内容为空，则抛出异常
            if(StrUtil.isEmpty(responseBodyStr)){
                throw new FebsException(ERROR_PREFIX + "请求返回参数为空");
            }
            // 解析响应内容为JSON对象
            JSONObject jsonObject = new JSONObject(responseBodyStr);
            // 获取响应码
            int code = jsonObject.getInt("code");
            // 如果响应码表示失败，则处理错误响应
            if(ResponseCodeEnum.isFail(code)){
                throw handleErrorResponse(code, responseBodyStr);
            }
            // 获取响应消息
            String msg = jsonObject.getStr("msg");
            // 如果响应消息不正确，则抛出异常
            if(!ResponseCodeEnum.SUCCESS.getMsg().equals(msg)){
                throw new FebsException(ERROR_PREFIX + "请求返回参数msg不正确");
            }
            // 返回响应内容
            return responseBodyStr;
        } catch (IOException | IllegalStateException | JSONException e) {
            // 捕获异常并抛出自定义异常
            throw new FebsException(ERROR_PREFIX + e.getMessage());
        }
    }

    /**
     * 处理错误响应
     * @param code 响应码
     * @param responseBodyStr 响应体字符串
     * @return 自定义异常
     * @throws JSONException 当JSON解析失败时抛出
     */
    private static FebsException handleErrorResponse(int code, String responseBodyStr) {
        try {
            // 获取错误描述和消息
            String desc = ResponseCodeEnum.getDesc(code);
            String msg = ResponseCodeEnum.getMsg(code);
            // 构造并返回自定义异常
            return new FebsException(ERROR_PREFIX + "{" + msg + "},{" + desc + "}");
        } catch (JSONException e) {
            // 如果JSON解析失败，构造并返回自定义异常
            throw new FebsException(ERROR_PREFIX + "{" + responseBodyStr + "}");
        }
    }

    /**
     * 获取响应体内容作为字符串
     * @param body 响应体
     * @return 响应体字符串
     * @throws IOException 当读取响应体失败时抛出
     */
    private static String getResponseBodyAsString(ResponseBody body) throws IOException {
        if (body != null) {
            // 如果响应体不为空，读取并返回内容
            return body.string();
        } else {
            // 如果响应体为空，返回空字符串
            return "";
        }
    }
}