weRequest/src/module/responseHandler.ts

import config from '../store/config'
import requestHandler from './requestHandler'
import errorHandler from './errorHandler'
import cacheManager from './cacheManager'
import durationReporter from './durationReporter'
import sessionManager from './sessionManager'
import { IRequestOption, IUploadFileOption } from "../interface";
import jsonSuperset from '../util/jsonSuperset'

function responseForRequest(
    res: wx.RequestSuccessCallbackResult,
    obj: IRequestOption
): any {
    if (res.statusCode === 200) {

        durationReporter.end(obj);
        
        // 请求格式为json，但返回了string，说明内容中可能存在导致使得JavaScript异常的字符
        if (obj.dataType === 'json' && typeof res.data === 'string') {
            res.data = jsonSuperset(res.data);
            try {
                res.data = JSON.parse(res.data);
            } catch (e) {
                if(obj.catchError) {
                    throw new Error(e);
                } else {
                    errorHandler.logicError(obj, res);
                    return;
                }
            }
        }

        if (config.loginTrigger!(res.data) && obj.reLoginCount !== undefined && obj.reLoginCount < config.reLoginLimit!) {
            // 登录态失效，且重试次数不超过配置
            sessionManager.delSession();
            return requestHandler.request(obj);
        } else if (config.successTrigger(res.data)) {
            // 接口返回成功码
            let realData: string | IAnyObject | ArrayBuffer = "";
            try {
                if (typeof config.successData === 'function') {
                    realData = config.successData(res.data);
                } else {
                    realData = res.data;
                }
            } catch (e) {}
            if (!obj.noCacheFlash) {
                // 如果为了保证页面不闪烁，则不回调，只是缓存最新数据，待下次进入再用
                if (typeof obj.success === "function") {
                    obj.success(realData);
                } else {
                    return realData;
                }
            }
            // 缓存存储
            cacheManager.set(obj, realData);
        } else {
            // 接口返回失败码
            throw { type: 'logic-error', res }
        }
    } else {
        // https返回状态码非200
        throw { type: 'http-error', res }
    }
}

function responseForUploadFile(
    res: wx.UploadFileSuccessCallbackResult,
    obj: IUploadFileOption
): any {
    if (res.statusCode === 200) {

        durationReporter.end(obj);

        // 内容中可能存在导致使得JavaScript异常的字符
        if (typeof res.data === 'string') {
            res.data = jsonSuperset(res.data);
            try {
                res.data = JSON.parse(res.data);
            } catch (e) {
                if(obj.catchError) {
                    throw new Error(e);
                } else {
                    errorHandler.logicError(obj, res);
                    return;
                }
            }
        }

        if (config.loginTrigger!(res.data) && obj.reLoginCount !== undefined && obj.reLoginCount < config.reLoginLimit!) {
            // 登录态失效，且重试次数不超过配置
            sessionManager.delSession();
            return requestHandler.uploadFile(obj);
        } else if (config.successTrigger(res.data)) {
            // 接口返回成功码
            let realData: string | IAnyObject | ArrayBuffer = "";
            try {
                if (typeof config.successData === 'function') {
                    realData = config.successData(res.data);
                } else {
                    realData = res.data;
                }
            } catch (e) {}

            if (typeof obj.success === "function") {
                obj.success(realData);
            } else {
                return realData;
            }
        } else {
            // 接口返回失败码
            throw { type: 'logic-error', res }
        }
    } else {
        // https返回状态码非200
        throw { type: 'http-error', res }
    }
}

export default {
    responseForRequest,
    responseForUploadFile
};