電視直播.apk(点击下载) / rb.java

package com.ss.android.downloadlib.addownload.compliance;

import android.text.TextUtils;
import androidx.annotation.NonNull;
import com.mbridge.msdk.foundation.download.database.DownloadModel;
import com.ss.android.download.api.config.yi;
import com.ss.android.downloadlib.addownload.ao;
import com.ss.android.downloadlib.addownload.tf.kd;
import com.ss.android.downloadlib.kd.ry;
import com.ss.android.downloadlib.t;
import com.ss.android.downloadlib.w;
import java.util.concurrent.atomic.AtomicInteger;
import org.json.JSONObject;

public class rb {
    private final AtomicInteger pf;

    /* access modifiers changed from: private */
    public static class pf {
        private static rb pf = new rb();
    }

    private rb() {
        this.pf = new AtomicInteger(0);
    }

    /* access modifiers changed from: private */
    /* access modifiers changed from: public */
    private String tf() {
        StringBuilder sb = new StringBuilder();
        sb.append(this.pf.get() < 3 ? "https://apps.bytesfield.com" : "https://apps.bytesfield-b.com");
        sb.append("/customer/api/app/deep_link");
        return sb.toString();
    }

    /* access modifiers changed from: private */
    /* access modifiers changed from: public */
    private void tf(@NonNull final kd kdVar, final String str, final byte[] bArr, final nl nlVar) {
        ao.w().pf(str, bArr, "application/json; charset=utf-8", 0, new yi() {
            /* class com.ss.android.downloadlib.addownload.compliance.rb.AnonymousClass2 */

            @Override // com.ss.android.download.api.config.yi
            public void pf(String str) {
                rb.this.pf((rb) kdVar, (kd) str, (String) nlVar);
            }

            @Override // com.ss.android.download.api.config.yi
            public void pf(Throwable th) {
                rb.this.pf((rb) kdVar, (kd) str, (String) bArr, (byte[]) nlVar);
            }
        });
    }

    public static rb pf() {
        return pf.pf;
    }

    public void pf(final kd kdVar, final nl nlVar) {
        if (ao.w() == null) {
            ry.pf().pf("getDownloadNetworkFactory == NULL");
            pf(401, kdVar);
            return;
        }
        w.pf().pf(new Runnable() {
            /* class com.ss.android.downloadlib.addownload.compliance.rb.AnonymousClass1 */

            public void run() {
                rb rbVar = rb.this;
                rbVar.tf(kdVar, rbVar.tf(), rb.this.pf((rb) kdVar, (kd) true, true), nlVar);
            }
        });
    }

    /* access modifiers changed from: private */
    /* access modifiers changed from: public */
    private void pf(kd kdVar, String str, byte[] bArr, nl nlVar) {
        if (this.pf.get() < 6) {
            this.pf.incrementAndGet();
            tf(kdVar, str, bArr, nlVar);
            return;
        }
        pf("当前网络不佳，请稍后再试");
        this.pf.set(0);
        pf(402, kdVar);
    }

    private void pf(final String str) {
        t.pf().tf().post(new Runnable() {
            /* class com.ss.android.downloadlib.addownload.compliance.rb.AnonymousClass3 */

            public void run() {
                ao.ry().pf(6, ao.getContext(), null, str, null, 0);
            }
        });
    }

    /* access modifiers changed from: private */
    /* access modifiers changed from: public */
    private byte[] pf(kd kdVar, boolean z, int i2) {
        JSONObject jSONObject = new JSONObject();
        try {
            jSONObject.put(DownloadModel.DOWNLOAD_URL, kdVar.pf());
            jSONObject.put("package_name", kdVar.kd());
            jSONObject.put("call_scene", 50);
            if (z) {
                jSONObject.put("sender_package_name", ao.getContext().getPackageName());
                jSONObject.put("sender_version", ao.h().kd);
                if (i2 > 0) {
                    jSONObject.put("store", i2);
                }
            } else {
                jSONObject.put("id", String.valueOf(kdVar.tf()));
                if (kdVar.y().getDeepLink() != null) {
                    if (TextUtils.isEmpty(kdVar.y().getDeepLink().getWebUrl())) {
                        ry.pf().pf("web_url is null");
                    }
                    jSONObject.put("web_url", kdVar.y().getDeepLink().getWebUrl());
                } else {
                    ry.pf().pf("deeplink is null");
                }
            }
        } catch (Exception unused) {
            ry.pf().pf("param build error");
        }
        return jSONObject.toString().getBytes();
    }

    /* access modifiers changed from: private */
    /* access modifiers changed from: public */
    private void pf(@NonNull kd kdVar, String str, nl nlVar) {
        try {
            if (TextUtils.isEmpty(str)) {
                ry.pf().pf("response content is null");
                pf(404, kdVar);
                nlVar.pf();
                return;
            }
            this.pf.set(0);
            kd t = kd.t(str);
            if (t.pf() != 0) {
                pf(403, kdVar);
                nlVar.pf();
            } else if (TextUtils.isEmpty(t.tf())) {
                pf(405, kdVar);
                nlVar.pf();
            } else {
                nlVar.pf(t.tf());
            }
        } catch (Exception e2) {
            ry.pf().pf(e2, "DownloadMiuiMarketHelper parseResponse");
        }
    }

    public void pf(int i2, kd kdVar) {
        JSONObject jSONObject = new JSONObject();
        try {
            jSONObject.putOpt("download_miui_market_fail_code", Integer.valueOf(i2));
        } catch (Exception e2) {
            e2.printStackTrace();
        }
        com.ss.android.downloadlib.w.pf.pf().pf("get_miui_market_compliance_error", jSONObject, kdVar);
    }

    public void pf(int i2, kd kdVar, JSONObject jSONObject) {
        try {
            jSONObject.putOpt("download_miui_market_success_result", Integer.valueOf(i2));
        } catch (Exception e2) {
            e2.printStackTrace();
        }
        com.ss.android.downloadlib.w.pf.pf().pf("get_miui_market_compliance_success", jSONObject, kdVar);
    }
}