package com.bytedance.sdk.component.wsy.ro;

import android.text.TextUtils;
import androidx.media3.exoplayer.rtsp.RtspHeaders;
import com.bytedance.sdk.component.ro.fm.ajl;
import com.bytedance.sdk.component.ro.fm.duv;
import com.bytedance.sdk.component.ro.fm.ku;
import com.bytedance.sdk.component.ro.fm.onz;
import com.google.android.gms.measurement.internal.u1;
import defpackage.e;
import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.io.RandomAccessFile;
import java.util.HashMap;
import java.util.Map;
import java.util.Objects;
import java.util.zip.GZIPInputStream;

/* JADX INFO: loaded from: classes.dex */
public class fm extends lb {
    public File fm;
    private volatile boolean ku;
    public File ro;

    public fm(ku kuVar) {
        super(kuVar);
    }

    /* JADX INFO: Access modifiers changed from: private */
    public static long ajl(Map<String, String> map) {
        String str = map.containsKey("content-length") ? map.get("content-length") : map.containsKey(RtspHeaders.CONTENT_LENGTH) ? map.get(RtspHeaders.CONTENT_LENGTH) : null;
        if (TextUtils.isEmpty(str) || str == null) {
            return 0L;
        }
        try {
            return Long.valueOf(str).longValue();
        } catch (Throwable unused) {
            return 0L;
        }
    }

    /* JADX INFO: Access modifiers changed from: private */
    public static boolean jnr(Map<String, String> map) {
        if (TextUtils.equals(map.get("Accept-Ranges"), "bytes") || TextUtils.equals(map.get("accept-ranges"), "bytes")) {
            return true;
        }
        String str = map.get("Content-Range");
        if (TextUtils.isEmpty(str)) {
            str = map.get("content-range");
        }
        return str != null && str.startsWith("bytes");
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void vt() {
        try {
            this.fm.delete();
        } catch (Throwable unused) {
        }
        try {
            this.ro.delete();
        } catch (Throwable unused2) {
        }
    }

    /* JADX INFO: Access modifiers changed from: private */
    public static boolean wsy(Map<String, String> map) {
        return TextUtils.equals(map.get(RtspHeaders.CONTENT_ENCODING), "gzip");
    }

    public void fm(String str, String str2) {
        File file = new File(str);
        if (file.isFile()) {
            file.delete();
        }
        if (!file.exists()) {
            file.mkdirs();
        }
        this.fm = new File(str, str2);
        this.ro = new File(str, u1.j(str2, ".temp"));
    }

    @Override // com.bytedance.sdk.component.wsy.ro.lb
    public void ro() {
        this.ku = true;
        super.ro();
    }

    @Override // com.bytedance.sdk.component.wsy.ro.lb
    public void fm(final com.bytedance.sdk.component.wsy.fm.fm fmVar) {
        File file = this.fm;
        if (file == null || this.ro == null) {
            if (fmVar != null) {
                fmVar.fm(this, new IOException("File info is null, please exec setFileInfo(String dir, String fileName)"));
                return;
            }
            return;
        }
        if (file.exists() && this.fm.length() != 0 && fmVar != null) {
            long jCurrentTimeMillis = System.currentTimeMillis();
            com.bytedance.sdk.component.wsy.ro roVar = new com.bytedance.sdk.component.wsy.ro(true, 200, "Success", null, null, jCurrentTimeMillis, jCurrentTimeMillis);
            roVar.fm(this.fm);
            fmVar.fm(this, roVar);
            return;
        }
        long length = this.ro.length();
        final long j10 = length >= 0 ? length : 0L;
        duv.fm fmVar2 = new duv.fm();
        fmVar2.fm((Object) yz());
        fm(fmVar2);
        ro(RtspHeaders.RANGE, e.m(new StringBuilder("bytes="), j10, "-"));
        if (TextUtils.isEmpty(this.wu)) {
            fmVar.fm(this, new IOException("Url is Empty"));
            return;
        }
        try {
            fmVar2.ro(this.wu);
            if (!TextUtils.isEmpty(this.jnr)) {
                fmVar2.fm(this.jnr);
            }
            int i10 = this.ajl;
            if (i10 > 0) {
                fmVar2.fm(i10);
            }
            ro(fmVar2);
            com.bytedance.sdk.component.ro.fm.ro roVarFm = this.f6701lb.fm(fmVar2.fm().ro());
            if (roVarFm == null) {
                fmVar.fm(this, new IOException("new call error"));
            } else {
                roVarFm.fm(new com.bytedance.sdk.component.ro.fm.lb() { // from class: com.bytedance.sdk.component.wsy.ro.fm.1
                    @Override // com.bytedance.sdk.component.ro.fm.lb
                    public void fm(com.bytedance.sdk.component.ro.fm.ro roVar2, IOException iOException) {
                        com.bytedance.sdk.component.wsy.fm.fm fmVar3 = fmVar;
                        if (fmVar3 != null) {
                            fmVar3.fm(fm.this, iOException);
                        }
                        fm.this.vt();
                    }

                    /* JADX WARN: Removed duplicated region for block: B:143:0x0191 A[SYNTHETIC] */
                    /* JADX WARN: Removed duplicated region for block: B:56:0x0157  */
                    @Override // com.bytedance.sdk.component.ro.fm.lb
                    /*
                        Code decompiled incorrectly, please refer to instructions dump.
                    */
                    public void fm(com.bytedance.sdk.component.ro.fm.ro roVar2, onz onzVar) throws IOException {
                        RandomAccessFile randomAccessFile;
                        long j11;
                        byte[] bArr;
                        int i11;
                        int i12;
                        boolean z10;
                        InputStream inputStream;
                        if (fmVar == null) {
                            return;
                        }
                        HashMap map = new HashMap();
                        if (onzVar == null) {
                            return;
                        }
                        fm.this.fm(onzVar.ef());
                        ajl ajlVarWsy = onzVar.wsy();
                        if (ajlVarWsy != null) {
                            for (int i13 = 0; i13 < ajlVarWsy.fm(); i13++) {
                                map.put(ajlVarWsy.fm(i13), ajlVarWsy.ro(i13));
                            }
                        }
                        com.bytedance.sdk.component.wsy.ro roVar3 = new com.bytedance.sdk.component.wsy.ro(onzVar.yz(), onzVar.lb(), onzVar.jnr(), map, null, onzVar.ro(), onzVar.fm());
                        if (onzVar.yz()) {
                            long jFm = onzVar.ajl().fm();
                            if (jFm <= 0) {
                                jFm = fm.ajl(map);
                            }
                            boolean zJnr = fm.jnr(map);
                            int i14 = -1;
                            if (zJnr) {
                                jFm += j10;
                                String str = (String) map.get("Content-Range");
                                if (!TextUtils.isEmpty(str)) {
                                    String str2 = "bytes " + j10 + "-" + (jFm - 1);
                                    if (TextUtils.indexOf(str, str2) == -1) {
                                        fm.this.vt();
                                        com.bytedance.sdk.component.wsy.fm.fm fmVar3 = fmVar;
                                        fm fmVar4 = fm.this;
                                        StringBuilder sbT = e.t("The Content-Range Header is invalid Assume[", str2, "] vs Real[", str, "], please remove the temporary file [");
                                        sbT.append(fm.this.ro);
                                        sbT.append("].");
                                        fmVar3.fm(fmVar4, new IOException(sbT.toString()));
                                        return;
                                    }
                                }
                            }
                            if (jFm > 0 && fm.this.ro.exists() && fm.this.ro.length() == jFm) {
                                fm fmVar5 = fm.this;
                                if (fmVar5.ro.renameTo(fmVar5.fm)) {
                                    roVar3.fm(fm.this.fm);
                                    fmVar.fm(fm.this, roVar3);
                                    return;
                                } else {
                                    fmVar.fm(fm.this, new IOException("Rename fail"));
                                    return;
                                }
                            }
                            InputStream inputStreamLb = null;
                            try {
                                randomAccessFile = new RandomAccessFile(fm.this.ro, "rw");
                            } catch (Throwable unused) {
                                randomAccessFile = null;
                            }
                            if (zJnr) {
                                randomAccessFile.seek(j10);
                                j11 = j10;
                                try {
                                    inputStreamLb = onzVar.ajl().lb();
                                    if (fm.wsy(map) && !(inputStreamLb instanceof GZIPInputStream)) {
                                        inputStreamLb = new GZIPInputStream(inputStreamLb);
                                    }
                                    try {
                                        bArr = new byte[16384];
                                        long j12 = 0;
                                        i11 = 0;
                                        while (true) {
                                            i12 = inputStreamLb.read(bArr, i11, 16384 - i11);
                                            if (i12 == i14) {
                                                i11 += i12;
                                                inputStream = inputStreamLb;
                                                j12 += (long) i12;
                                                try {
                                                    if (j12 % 16384 == 0 || j12 == jFm - j10) {
                                                        randomAccessFile.seek(j11);
                                                        randomAccessFile.write(bArr, 0, i11);
                                                        j11 += (long) i11;
                                                        i11 = 0;
                                                    }
                                                    if (fm.this.ku) {
                                                        throw new IOException("net is cancel");
                                                    }
                                                    inputStreamLb = inputStream;
                                                    i14 = -1;
                                                } catch (Throwable th) {
                                                    th = th;
                                                    inputStreamLb = inputStream;
                                                    try {
                                                        fmVar.fm(fm.this, new IOException(th.getMessage()));
                                                        if (!zJnr) {
                                                            fm.this.vt();
                                                        }
                                                        if (inputStreamLb != null) {
                                                            try {
                                                                inputStreamLb.close();
                                                            } catch (Throwable unused2) {
                                                            }
                                                        }
                                                        try {
                                                            randomAccessFile.close();
                                                            return;
                                                        } catch (Throwable unused3) {
                                                            return;
                                                        }
                                                    } finally {
                                                    }
                                                }
                                            } else {
                                                InputStream inputStream2 = inputStreamLb;
                                                if (i11 != 0) {
                                                    randomAccessFile.seek(j11);
                                                    z10 = false;
                                                    randomAccessFile.write(bArr, 0, i11);
                                                } else {
                                                    z10 = false;
                                                }
                                                if (!zJnr) {
                                                    jFm = fm.this.ro.length();
                                                }
                                                if (jFm > 0 && fm.this.ro.exists() && fm.this.ro.length() == jFm) {
                                                    fm fmVar6 = fm.this;
                                                    if (fmVar6.ro.renameTo(fmVar6.fm)) {
                                                        roVar3.fm(fm.this.fm);
                                                        fmVar.fm(fm.this, roVar3);
                                                    } else {
                                                        fmVar.fm(fm.this, new IOException("Rename fail"));
                                                    }
                                                } else {
                                                    com.bytedance.sdk.component.wsy.fm.fm fmVar7 = fmVar;
                                                    fm fmVar8 = fm.this;
                                                    StringBuilder sb = new StringBuilder(" tempFile.length() == fileSize is");
                                                    sb.append(fm.this.ro.length() == jFm ? true : z10);
                                                    fmVar7.fm(fmVar8, new IOException(sb.toString()));
                                                }
                                                try {
                                                    inputStream2.close();
                                                } catch (Throwable unused4) {
                                                }
                                                try {
                                                    randomAccessFile.close();
                                                    return;
                                                } catch (Throwable unused5) {
                                                    return;
                                                }
                                            }
                                        }
                                    } catch (Throwable th2) {
                                        th = th2;
                                    }
                                } catch (Throwable th3) {
                                    th = th3;
                                }
                            } else {
                                randomAccessFile.setLength(0L);
                                j11 = 0;
                                inputStreamLb = onzVar.ajl().lb();
                                if (fm.wsy(map)) {
                                    inputStreamLb = new GZIPInputStream(inputStreamLb);
                                }
                                bArr = new byte[16384];
                                long j122 = 0;
                                i11 = 0;
                                while (true) {
                                    i12 = inputStreamLb.read(bArr, i11, 16384 - i11);
                                    if (i12 == i14) {
                                    }
                                    inputStreamLb = inputStream;
                                    i14 = -1;
                                }
                            }
                        } else {
                            fmVar.fm(fm.this, roVar3);
                        }
                    }
                });
            }
        } catch (IllegalArgumentException unused) {
            fmVar.fm(this, new IOException("Url is not a valid HTTP or HTTPS URL"));
        }
    }

    /* JADX WARN: Removed duplicated region for block: B:180:0x01d5 A[SYNTHETIC] */
    /* JADX WARN: Removed duplicated region for block: B:75:0x01a1 A[Catch: all -> 0x0231, TryCatch #9 {all -> 0x0231, blocks: (B:67:0x0182, B:69:0x0188, B:71:0x018c, B:72:0x0192, B:73:0x0199, B:75:0x01a1, B:77:0x01b1, B:82:0x01c4, B:85:0x01cd, B:86:0x01d4, B:81:0x01ba, B:89:0x01da, B:97:0x01f2, B:99:0x01fa, B:101:0x0204, B:103:0x020e, B:111:0x0224, B:94:0x01e8), top: B:164:0x0182 }] */
    @Override // com.bytedance.sdk.component.wsy.ro.lb
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public com.bytedance.sdk.component.wsy.ro fm() {
        RandomAccessFile randomAccessFile;
        long j10;
        InputStream inputStream;
        InputStream inputStreamLb;
        byte[] bArr;
        int i10;
        int i11;
        com.bytedance.sdk.component.wsy.ro roVar;
        File file = this.fm;
        if (file == null || this.ro == null) {
            return null;
        }
        long j11 = 0;
        if (file.exists() && this.fm.length() != 0) {
            long jCurrentTimeMillis = System.currentTimeMillis();
            com.bytedance.sdk.component.wsy.ro roVar2 = new com.bytedance.sdk.component.wsy.ro(true, 200, "Success", null, null, jCurrentTimeMillis, jCurrentTimeMillis);
            roVar2.fm(this.fm);
            return roVar2;
        }
        long length = this.ro.length();
        if (length < 0) {
            length = 0;
        }
        duv.fm fmVar = new duv.fm();
        fmVar.fm((Object) yz());
        fm(fmVar);
        ro(RtspHeaders.RANGE, e.m(new StringBuilder("bytes="), length, "-"));
        if (TextUtils.isEmpty(this.wu)) {
            return null;
        }
        try {
            fmVar.ro(this.wu);
            ro(fmVar);
            try {
                com.bytedance.sdk.component.ro.fm.ro roVarFm = this.f6701lb.fm(fmVar.fm().ro());
                if (roVarFm == null) {
                    return null;
                }
                onz onzVarRo = roVarFm.ro();
                if (onzVarRo != null) {
                    fm(onzVarRo.ef());
                }
                if (onzVarRo != null && onzVarRo.yz()) {
                    HashMap map = new HashMap();
                    ajl ajlVarWsy = onzVarRo.wsy();
                    if (ajlVarWsy != null) {
                        for (int i12 = 0; i12 < ajlVarWsy.fm(); i12++) {
                            map.put(ajlVarWsy.fm(i12), ajlVarWsy.ro(i12));
                        }
                    }
                    com.bytedance.sdk.component.wsy.ro roVar3 = new com.bytedance.sdk.component.wsy.ro(onzVarRo.yz(), onzVarRo.lb(), onzVarRo.jnr(), map, null, onzVarRo.ro(), onzVarRo.fm());
                    long jFm = onzVarRo.ajl().fm();
                    if (jFm <= 0) {
                        jFm = ajl(map);
                    }
                    long length2 = this.ro.length();
                    boolean zJnr = jnr(map);
                    int i13 = -1;
                    if (zJnr) {
                        jFm += length2;
                        String str = (String) map.get("Content-Range");
                        if (!TextUtils.isEmpty(str)) {
                            if (TextUtils.indexOf(str, "bytes " + length2 + "-" + (jFm - 1)) == -1) {
                                Objects.toString(this.ro);
                                vt();
                                return null;
                            }
                        }
                        j11 = 0;
                    }
                    if (jFm > j11 && this.ro.exists() && this.ro.length() == jFm) {
                        if (!this.ro.renameTo(this.fm)) {
                            return null;
                        }
                        roVar3.fm(this.fm);
                        return roVar3;
                    }
                    com.bytedance.sdk.component.wsy.ro roVar4 = roVar3;
                    try {
                        randomAccessFile = new RandomAccessFile(this.ro, "rw");
                    } catch (Throwable unused) {
                        randomAccessFile = null;
                    }
                    if (zJnr) {
                        randomAccessFile.seek(length);
                        j10 = length;
                        try {
                            inputStreamLb = onzVarRo.ajl().lb();
                            try {
                                if (wsy(map) && !(inputStreamLb instanceof GZIPInputStream)) {
                                    inputStreamLb = new GZIPInputStream(inputStreamLb);
                                }
                                bArr = new byte[16384];
                                i10 = 0;
                                long j12 = 0;
                                while (true) {
                                    i11 = inputStreamLb.read(bArr, i10, 16384 - i10);
                                    if (i11 != i13) {
                                        com.bytedance.sdk.component.wsy.ro roVar5 = roVar4;
                                        if (i11 != 0) {
                                            randomAccessFile.seek(j10);
                                            randomAccessFile.write(bArr, 0, i10);
                                        }
                                        if (!zJnr || length == 0) {
                                            jFm = this.ro.length();
                                        }
                                        if (jFm > 0 && this.ro.exists() && this.ro.length() == jFm) {
                                            if (this.ro.renameTo(this.fm)) {
                                                roVar5.fm(this.fm);
                                                try {
                                                    inputStreamLb.close();
                                                } catch (Throwable unused2) {
                                                }
                                                try {
                                                    randomAccessFile.close();
                                                } catch (Throwable unused3) {
                                                }
                                                return roVar5;
                                            }
                                            try {
                                                inputStreamLb.close();
                                            } catch (Throwable unused4) {
                                            }
                                            try {
                                                randomAccessFile.close();
                                                return null;
                                            } catch (Throwable unused5) {
                                                return null;
                                            }
                                        }
                                        this.ro.length();
                                        try {
                                            inputStreamLb.close();
                                        } catch (Throwable unused6) {
                                        }
                                        try {
                                            randomAccessFile.close();
                                            return null;
                                        } catch (Throwable unused7) {
                                            return null;
                                        }
                                    }
                                    i10 += i11;
                                    roVar = roVar4;
                                    j12 += (long) i11;
                                    if (j12 % 16384 == 0 || j12 == jFm - length) {
                                        randomAccessFile.seek(j10);
                                        randomAccessFile.write(bArr, 0, i10);
                                        j10 += (long) i10;
                                        i10 = 0;
                                    }
                                    if (this.ku) {
                                        throw new IOException("net is cancel");
                                    }
                                    roVar4 = roVar;
                                    i13 = -1;
                                }
                            } catch (Throwable unused8) {
                                inputStream = inputStreamLb;
                                if (!zJnr) {
                                    try {
                                        vt();
                                    } finally {
                                    }
                                }
                                if (inputStream != null) {
                                    try {
                                        inputStream.close();
                                    } catch (Throwable unused9) {
                                    }
                                }
                                try {
                                    randomAccessFile.close();
                                    return null;
                                } catch (Throwable unused10) {
                                    return null;
                                }
                            }
                        } catch (Throwable unused11) {
                            inputStream = null;
                        }
                    } else {
                        randomAccessFile.setLength(0L);
                        j10 = 0;
                        inputStreamLb = onzVarRo.ajl().lb();
                        if (wsy(map)) {
                            inputStreamLb = new GZIPInputStream(inputStreamLb);
                        }
                        bArr = new byte[16384];
                        i10 = 0;
                        long j122 = 0;
                        while (true) {
                            i11 = inputStreamLb.read(bArr, i10, 16384 - i10);
                            if (i11 != i13) {
                            }
                            roVar4 = roVar;
                            i13 = -1;
                        }
                    }
                }
            } catch (IOException unused12) {
                vt();
            }
            return null;
        } catch (IllegalArgumentException unused13) {
            return null;
        }
    }
}