/**
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at
 *
 *   http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing,
 * software distributed under the License is distributed on an
 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
 * KIND, either express or implied.  See the License for the
 * specific language governing permissions and limitations
 * under the License.
 */
package com.taobao.weex;

import android.net.Uri;
import android.text.TextUtils;

import com.taobao.weex.adapter.IWXHttpAdapter;
import com.taobao.weex.adapter.IWXUserTrackAdapter;
import com.taobao.weex.common.WXErrorCode;
import com.taobao.weex.common.WXPerformance;
import com.taobao.weex.common.WXRenderStrategy;
import com.taobao.weex.common.WXResponse;
import com.taobao.weex.performance.WXInstanceApm;
import com.taobao.weex.tracing.WXTracing;
import com.taobao.weex.utils.WXLogUtils;
import com.taobao.weex.utils.tools.LogDetail;

import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * load bundle js listener
 */
public class WXHttpListener implements IWXHttpAdapter.OnHttpListener {

    private String pageName;
    private Map<String, Object> options;
    private String jsonInitData;
    private WXRenderStrategy flag;
    private WXSDKInstance instance;
    private long startRequestTime;
    private int traceId;
    private WXPerformance mWXPerformance;
    private WXInstanceApm mApmForInstance;
    private IWXUserTrackAdapter mUserTrackAdapter;
    public boolean isPreDownLoadMode = false;
    private boolean isInstanceReady =false;
    private boolean isResponseHasWait = false;
    private WXResponse mResponse;
    private LogDetail mLogDetail;

    private String mBundleUrl;

    public WXHttpListener(WXSDKInstance instance) {
        if(instance != null) {
            mLogDetail = instance.mTimeCalculator.createLogDetail("downloadBundleJS");
        }
        this.instance = instance;
        this.traceId = WXTracing.nextId();
        this.mWXPerformance = instance.getWXPerformance();
        this.mApmForInstance = instance.getApmForInstance();
        this.mUserTrackAdapter = WXSDKManager.getInstance().getIWXUserTrackAdapter();
        if (WXTracing.isAvailable()) {
            WXTracing.TraceEvent event = WXTracing.newEvent("downloadBundleJS", instance.getInstanceId(), -1);
            event.iid = instance.getInstanceId();
            event.tname = "Network";
            event.ph = "B";
            event.traceId = traceId;
            event.submit();
        }
    }

    public WXHttpListener(WXSDKInstance instance, String bundleUrl) {
        this(instance);
        this.startRequestTime = System.currentTimeMillis();
        this.mBundleUrl = bundleUrl;
    }

    public WXHttpListener(WXSDKInstance instance, String pageName, Map<String, Object> options, String jsonInitData, WXRenderStrategy flag, long startRequestTime) {
        this(instance);
        this.pageName = pageName;
        this.options = options;
        this.jsonInitData = jsonInitData;
        this.flag = flag;
        this.startRequestTime = startRequestTime;
        this.mBundleUrl = instance.getBundleUrl();
    }

    public void setSDKInstance(WXSDKInstance instance) {
        this.instance = instance;
    }

    protected WXSDKInstance getInstance() {
        return instance;
    }

    @Override
    public void onHttpStart() {
        if (this.instance != null
                && this.instance.getWXStatisticsListener() != null) {
            this.instance.getWXStatisticsListener().onHttpStart();
            if(mLogDetail != null) {
                mLogDetail.taskStart();
            }
        }
    }

    @Override
    public void onHeadersReceived(int statusCode, Map<String,List<String>> headers) {
        if (this.instance != null
                && this.instance.getWXStatisticsListener() != null) {
            this.instance.getWXStatisticsListener().onHeadersReceived();
            this.instance.onHttpStart();
        }
        if(this.instance != null
                && this.instance.responseHeaders != null
                && headers != null){
            this.instance.responseHeaders.putAll(headers);
        }
    }

    @Override
    public void onHttpUploadProgress(int uploadProgress) {

    }

    @Override
    public void onHttpResponseProgress(int loadedLength) {
        instance.getApmForInstance().extInfo.put(WXInstanceApm.VALUE_BUNDLE_LOAD_LENGTH,loadedLength);
    }

    @Override
    public void onHttpFinish(WXResponse response) {
        if(mLogDetail != null) {
            mLogDetail.taskEnd();
        }
        if (this.instance != null
                && this.instance.getWXStatisticsListener() != null) {
            this.instance.getWXStatisticsListener().onHttpFinish();
        }

        if (WXTracing.isAvailable()) {
            WXTracing.TraceEvent event = WXTracing.newEvent("downloadBundleJS", instance.getInstanceId(), -1);
            event.traceId = traceId;
            event.tname = "Network";
            event.ph = "E";
            event.extParams = new HashMap<>();
            if (response != null && response.originalData != null) {
                event.extParams.put("BundleSize", response.originalData.length);
            }
            event.submit();
        }

        mWXPerformance.networkTime = System.currentTimeMillis() - startRequestTime;
        if(null!= response && response.extendParams!=null){
            mApmForInstance.updateRecordInfo(response.extendParams);
            Object actualNetworkTime=response.extendParams.get("actualNetworkTime");
            mWXPerformance.actualNetworkTime=actualNetworkTime instanceof Long?(long)actualNetworkTime:0;

            Object pureNetworkTime=response.extendParams.get("pureNetworkTime");
            mWXPerformance.pureNetworkTime=pureNetworkTime instanceof Long?(long)pureNetworkTime:0;

            Object connectionType=response.extendParams.get("connectionType");
            mWXPerformance.connectionType=connectionType instanceof String?(String)connectionType:"";

            Object packageSpendTime=response.extendParams.get("packageSpendTime");
            mWXPerformance.packageSpendTime=packageSpendTime instanceof Long ?(long)packageSpendTime:0;

            Object syncTaskTime=response.extendParams.get("syncTaskTime");
            mWXPerformance.syncTaskTime=syncTaskTime instanceof Long ?(long)syncTaskTime:0;

            Object requestType=response.extendParams.get("requestType");
            mWXPerformance.requestType=requestType instanceof String?(String)requestType:"none";

            Object cacheType = response.extendParams.get(WXPerformance.Dimension.cacheType.toString());
            if(cacheType instanceof String){
                mWXPerformance.cacheType = (String) cacheType;
            }

            Object zCacheInfo = response.extendParams.get("zCacheInfo");
            mWXPerformance.zCacheInfo = zCacheInfo instanceof String?(String)zCacheInfo:"";

            if(isNet(mWXPerformance.requestType) && mUserTrackAdapter!=null){
                WXPerformance performance=new WXPerformance(instance.getInstanceId());
                if(!TextUtils.isEmpty(mBundleUrl)){
                    try {
                        performance.args= Uri.parse(mBundleUrl).buildUpon().clearQuery().toString();
                    } catch (Exception e) {
                        performance.args=pageName;
                    }
                }
                if(!"200".equals(response.statusCode)){
                    performance.errCode= WXErrorCode.WX_ERR_JSBUNDLE_DOWNLOAD.getErrorCode();
                    performance.appendErrMsg(response.errorCode);
                    performance.appendErrMsg("|");
                    performance.appendErrMsg(response.errorMsg);

                }else if("200".equals(response.statusCode) && (response.originalData==null || response.originalData.length<=0)){
                    performance.errCode=WXErrorCode.WX_ERR_JSBUNDLE_DOWNLOAD.getErrorCode();
                    performance.appendErrMsg(response.statusCode);
                    performance.appendErrMsg("|template is null!");
                }else {
                    performance.errCode=WXErrorCode.WX_SUCCESS.getErrorCode();
                }

                if (mUserTrackAdapter != null) {
                    mUserTrackAdapter.commit(instance.getContext(), null, IWXUserTrackAdapter.JS_DOWNLOAD, performance, null);
                }
            }
        }

        if (isPreDownLoadMode){
            if (isInstanceReady){
                WXLogUtils.d("test->", "DownLoad didHttpFinish on http" );
                didHttpFinish(response);
            }else {
                WXLogUtils.d("test->", "DownLoad end before activity created" );
                mResponse = response;
                isResponseHasWait = true;
            }
        }else {
            didHttpFinish(response);
        }

    }

    public void onInstanceReady(){
        if (!isPreDownLoadMode){
            return;
        }
        this.isInstanceReady = true;
        if (isResponseHasWait){
            WXLogUtils.d("test->", "preDownLoad didHttpFinish on ready" );
            this.didHttpFinish(mResponse);
        }

    }

    private void didHttpFinish(WXResponse response){
        String wxErrorCode = WXInstanceApm.VALUE_ERROR_CODE_DEFAULT;
        if (response!=null && response.originalData!=null && TextUtils.equals("200", response.statusCode)) {
            mApmForInstance.onStage(WXInstanceApm.KEY_PAGE_STAGES_DOWN_BUNDLE_END);
            onSuccess(response);

            // check content-type
        } else if (TextUtils.equals(WXErrorCode.WX_DEGRAD_ERR_BUNDLE_CONTENTTYPE_ERROR.getErrorCode(),
                response.statusCode)) {
            WXLogUtils.e("user intercept: WX_DEGRAD_ERR_BUNDLE_CONTENTTYPE_ERROR");
            wxErrorCode = WXErrorCode.WX_DEGRAD_ERR_BUNDLE_CONTENTTYPE_ERROR.getErrorCode();
            instance.onRenderError(wxErrorCode,
                    "|response.errorMsg==" + response.errorMsg +
                            "|instance bundleUrl = \n" + instance.getBundleUrl() +
                            "|instance requestUrl = \n" + Uri.decode(WXSDKInstance.requestUrl)
            );
            onFail(response);

            // check content-length
        } else if (response!=null && response.originalData!=null && TextUtils.equals("-206", response.statusCode)) {
            WXLogUtils.e("user intercept: WX_DEGRAD_ERR_NETWORK_CHECK_CONTENT_LENGTH_FAILED");
            wxErrorCode =  WXErrorCode.WX_DEGRAD_ERR_NETWORK_CHECK_CONTENT_LENGTH_FAILED.getErrorCode();
            instance.onRenderError(wxErrorCode ,
                    WXErrorCode.WX_DEGRAD_ERR_NETWORK_CHECK_CONTENT_LENGTH_FAILED.getErrorCode() +
                            "|response.errorMsg==" + response.errorMsg
            );
            onFail(response);
        }
        else {
            wxErrorCode = WXErrorCode.WX_DEGRAD_ERR_NETWORK_BUNDLE_DOWNLOAD_FAILED.getErrorCode();
            instance.onRenderError(wxErrorCode,
                    response.errorMsg);
            onFail(response);
        }
        if (!WXInstanceApm.VALUE_ERROR_CODE_DEFAULT.equals(wxErrorCode)){
            mApmForInstance.addProperty(WXInstanceApm.KEY_PROPERTIES_ERROR_CODE,wxErrorCode);
        }
    }

    private boolean isNet(String requestType){

        return "network".equals(requestType) || "2g".equals(requestType) || "3g".equals(requestType)
                || "4g".equals(requestType) || "wifi".equals(requestType) || "other".equals(requestType)
                || "unknown".equals(requestType);
    }

    public void onSuccess(WXResponse response) {
        if (flag==WXRenderStrategy.DATA_RENDER_BINARY){
            instance.render(pageName, response.originalData, options, jsonInitData);
        }else {
            String template = new String(response.originalData);
            instance.render(pageName, template, options, jsonInitData, flag);
        }
    }

    public void onFail(WXResponse response) {

    }
}