package com.bytedance.sdk.openadsdk.wsy;

import android.util.Pair;
import com.bykv.vk.openvk.preload.geckox.buffer.stream.BufferOutputStream;
import com.bykv.vk.openvk.preload.geckox.net.INetWork;
import com.bykv.vk.openvk.preload.geckox.net.Response;
import com.bykv.vk.openvk.preload.geckox.utils.CloseableUtils;
import com.bytedance.sdk.component.ro.fm.ajl;
import com.bytedance.sdk.component.ro.fm.dsz;
import com.bytedance.sdk.component.ro.fm.duv;
import com.bytedance.sdk.component.ro.fm.ef;
import com.bytedance.sdk.component.ro.fm.jnr;
import com.bytedance.sdk.component.ro.fm.ku;
import com.bytedance.sdk.component.ro.fm.lb;
import com.bytedance.sdk.component.ro.fm.onz;
import java.io.BufferedInputStream;
import java.io.Closeable;
import java.io.IOException;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.TimeUnit;

/* JADX INFO: loaded from: classes2.dex */
public class fm implements INetWork {
    protected ku fm;
    protected ku ro;

    public fm() {
        ku.fm fmVar = new ku.fm();
        TimeUnit timeUnit = TimeUnit.SECONDS;
        this.fm = fmVar.fm(10L, timeUnit).ro(10L, timeUnit).lb(10L, timeUnit).fm();
        this.ro = new ku.fm().fm(10L, timeUnit).ro(30L, timeUnit).lb(30L, timeUnit).fm();
    }

    private Map<String, String> fm(ajl ajlVar) {
        if (ajlVar == null) {
            return null;
        }
        HashMap map = new HashMap();
        for (int i10 = 0; i10 < ajlVar.fm(); i10++) {
            map.put(ajlVar.fm(i10), ajlVar.ro(i10));
        }
        return map;
    }

    @Override // com.bykv.vk.openvk.preload.geckox.net.INetWork
    public Response doGet(String str) throws Exception {
        onz onzVarRo = this.fm.fm(new duv.fm().fm().ro(str).fm("gecko").ro()).ro();
        return new Response(fm(onzVarRo.wsy()), onzVarRo.lb() == 200 ? onzVarRo.ajl().ro() : null, onzVarRo.lb(), onzVarRo.jnr());
    }

    @Override // com.bykv.vk.openvk.preload.geckox.net.INetWork
    public Response doPost(String str, List<Pair<String, String>> list) throws Exception {
        jnr.fm fmVar = new jnr.fm();
        if (list != null) {
            for (Pair<String, String> pair : list) {
                fmVar.fm((String) pair.first, (String) pair.second);
            }
        }
        onz onzVarRo = this.fm.fm(new duv.fm().ro(str).fm((dsz) fmVar.fm()).fm("gecko").ro()).ro();
        return new Response(fm(onzVarRo.wsy()), onzVarRo.lb() == 200 ? onzVarRo.ajl().ro() : null, onzVarRo.lb(), onzVarRo.jnr());
    }

    /* JADX WARN: Not initialized variable reg: 2, insn: 0x0044: MOVE (r7 I:??[OBJECT, ARRAY]) = (r2 I:??[OBJECT, ARRAY]) (LINE:69), block:B:12:0x0044 */
    @Override // com.bykv.vk.openvk.preload.geckox.net.INetWork
    public void downloadFile(String str, long j10, BufferOutputStream bufferOutputStream) throws Exception {
        Exception e10;
        Closeable closeable;
        BufferedInputStream bufferedInputStream;
        Closeable closeable2 = null;
        int i10 = 0;
        try {
            try {
                try {
                    onz onzVarRo = this.ro.fm(new duv.fm().fm().fm("gecko").ro(str).ro()).ro();
                    int iLb = onzVarRo.lb();
                    try {
                        bufferedInputStream = new BufferedInputStream(onzVarRo.ajl().lb());
                    } catch (Exception e11) {
                        e10 = e11;
                    }
                    try {
                        byte[] bArr = new byte[2048];
                        while (true) {
                            int i11 = bufferedInputStream.read(bArr, 0, 2048);
                            if (i11 == -1) {
                                CloseableUtils.close(bufferedInputStream);
                                return;
                            }
                            bufferOutputStream.write(bArr, 0, i11);
                        }
                    } catch (Exception e12) {
                        e10 = e12;
                        i10 = iLb;
                        throw new RuntimeException("downloadFile failed, code: " + i10 + ", url:" + str + ", caused by:" + e10.getMessage(), e10);
                    }
                } catch (Throwable th) {
                    th = th;
                    closeable2 = closeable;
                    CloseableUtils.close(closeable2);
                    throw th;
                }
            } catch (Exception e13) {
                e10 = e13;
            }
        } catch (Throwable th2) {
            th = th2;
            CloseableUtils.close(closeable2);
            throw th;
        }
    }

    @Override // com.bykv.vk.openvk.preload.geckox.net.INetWork
    public void syncDoGet(final String str) {
        this.fm.fm(new duv.fm().fm().ro(str).fm("gecko").ro()).fm(new lb() { // from class: com.bytedance.sdk.openadsdk.wsy.fm.1
            @Override // com.bytedance.sdk.component.ro.fm.lb
            public void fm(com.bytedance.sdk.component.ro.fm.ro roVar, onz onzVar) throws IOException {
            }

            @Override // com.bytedance.sdk.component.ro.fm.lb
            public void fm(com.bytedance.sdk.component.ro.fm.ro roVar, IOException iOException) {
            }
        });
    }

    @Override // com.bykv.vk.openvk.preload.geckox.net.INetWork
    public Response doPost(String str, String str2) throws Exception {
        onz onzVarRo = this.fm.fm(new duv.fm().ro(str).fm(dsz.fm(ef.fm("application/json; charset=utf-8"), str2)).fm("gecko").ro()).ro();
        return new Response(fm(onzVarRo.wsy()), onzVarRo.lb() == 200 ? onzVarRo.ajl().ro() : null, onzVarRo.lb(), onzVarRo.jnr());
    }
}