package com.runt.open.mvi.retrofit.converter;

import android.util.Log;

import com.google.gson.Gson;
import com.google.gson.JsonIOException;
import com.google.gson.JsonSyntaxException;
import com.google.gson.TypeAdapter;
import com.google.gson.stream.JsonReader;
import com.google.gson.stream.JsonToken;
import com.runt.open.mvi.data.HttpApiResult;
import com.runt.open.mvi.utils.GsonUtils;

import org.json.JSONException;

import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.nio.charset.Charset;

import okhttp3.ResponseBody;
import retrofit2.Converter;

/**
 * My father is Object, ites purpose of     解密gson转换器
 *
 * @purpose Created by Runt (qingingrunt2010@qq.com) on 2021-7-22.
 */

public class GsonResponseBodyConverter<T extends HttpApiResult> implements Converter<ResponseBody, T> {
    private final Gson gson;
    private final TypeAdapter<T> adapter;
    private final Charset UTF_8 = Charset.forName("UTF-8");
    private final boolean transHump;//驼峰转换

    public GsonResponseBodyConverter(Gson gson, TypeAdapter<T> adapter, boolean transHump) {
        this.gson = gson;
        this.adapter = adapter;
        this.transHump = transHump;
    }

    @Override
    public T convert(ResponseBody value) throws IOException {
        T result = null;
        String response = null;
        try {
            String val = new String(value.bytes(),UTF_8);
            Log.e("Converter","val body:"+val);
            response = transHump? GsonUtils.toHumpJson(val):val;
            result = readString(response);
        } catch (Throwable e) {
            e.printStackTrace();
            Log.e("Converter","Throwable 数据类型转换错误 "+e);
            HttpApiResult apiResult = new HttpApiResult<>();
            apiResult.data = response;
            if(e instanceof JSONException){
                Log.e("Converter","Throwable 非标准json "+e);
                apiResult.code = 1014;
                apiResult.msg = "非标准json";
            }else if(e instanceof JsonSyntaxException){
                Log.e("Converter","Throwable 数据类型转换错误 "+e);
                apiResult.code = 1015;
                apiResult.msg = "数据类型转换错误";
            }else {
                apiResult.code = 1016;
                apiResult.msg = "类型转换错误"+e.getMessage();
                Log.e("Converter","Throwable "+e);
            }
            response = new Gson().toJson(apiResult);
            result = readString(response);
        } finally {
            value.close();
            return result;
        }
    }

    private T readString(String str) throws IOException {
        InputStream inputStream = new ByteArrayInputStream(str.getBytes());
        JsonReader jsonReader = gson.newJsonReader(new InputStreamReader(inputStream, UTF_8));
        T result = adapter.read(jsonReader);
        if (jsonReader.peek() != JsonToken.END_DOCUMENT) {
            throw new JsonIOException("JSON document was not fully consumed.");
        }
        return result;
    }

}