package defpackage;

import android.content.Context;
import android.content.pm.PackageManager;
import android.os.Build;
import com.google.firebase.remoteconfig.FirebaseRemoteConfigClientException;
import java.io.BufferedOutputStream;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.util.Date;
import java.util.HashMap;
import java.util.Iterator;
import java.util.LinkedHashSet;
import java.util.Random;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
import org.json.JSONObject;

/* JADX INFO: renamed from: ᵰᵛᵝˏ, reason: contains not printable characters */
/* JADX INFO: loaded from: classes3.dex */
public final class C4379 {

    /* JADX INFO: renamed from: ˊᵫᵗ, reason: contains not printable characters */
    public final C4107 f16619;

    /* JADX INFO: renamed from: ːˏᵟᵯ, reason: contains not printable characters */
    public int f16621;

    /* JADX INFO: renamed from: ᵟᵹᵙ, reason: contains not printable characters */
    public final C4331 f16623;

    /* JADX INFO: renamed from: ᵮᵣᵗˈ, reason: contains not printable characters */
    public final Context f16626;

    /* JADX INFO: renamed from: ᵱᵽʡᵚ, reason: contains not printable characters */
    public final InterfaceC4093 f16628;

    /* JADX INFO: renamed from: ᵲᵶᵳˈ, reason: contains not printable characters */
    public final LinkedHashSet f16629;

    /* JADX INFO: renamed from: ᵵᵽ, reason: contains not printable characters */
    public final ScheduledExecutorService f16630;

    /* JADX INFO: renamed from: ᵶᵥᵝ, reason: contains not printable characters */
    public final C0708 f16631;

    /* JADX INFO: renamed from: ᵻʽᵯ, reason: contains not printable characters */
    public final C1191 f16633;

    /* JADX INFO: renamed from: ᵻˈᵦʼ, reason: contains not printable characters */
    public HttpURLConnection f16634;

    /* JADX INFO: renamed from: ˊᵙᵾᵲ, reason: contains not printable characters */
    public static final int[] f16617 = {2, 4, 8, 16, 32, 64, 128, 256};

    /* JADX INFO: renamed from: ˉᵲ, reason: contains not printable characters */
    public static final Pattern f16616 = Pattern.compile("^[^:]+:([0-9]+):(android|ios|web):([0-9a-f]+)");

    /* JADX INFO: renamed from: ʽˈˋ, reason: contains not printable characters */
    public boolean f16618 = false;

    /* JADX INFO: renamed from: ˋˈ, reason: contains not printable characters */
    public final Random f16620 = new Random();

    /* JADX INFO: renamed from: ᵪᵹᵥᵻ, reason: contains not printable characters */
    public final ᵠʽᵲ f16625 = ᵠʽᵲ.ᵯᵷʽ;

    /* JADX INFO: renamed from: ᵝᵶ, reason: contains not printable characters */
    public final String f16622 = "firebase";

    /* JADX INFO: renamed from: ᵷᵺʾᵖ, reason: contains not printable characters */
    public boolean f16632 = false;

    /* JADX INFO: renamed from: ᵨᵣ, reason: contains not printable characters */
    public boolean f16624 = false;

    /* JADX INFO: renamed from: ᵱʡˏ, reason: contains not printable characters */
    public final Object f16627 = new Object();

    public C4379(C1191 c1191, InterfaceC4093 interfaceC4093, C4107 c4107, C0708 c0708, Context context, LinkedHashSet linkedHashSet, C4331 c4331, ScheduledExecutorService scheduledExecutorService) {
        this.f16629 = linkedHashSet;
        this.f16630 = scheduledExecutorService;
        this.f16621 = Math.max(8 - c4331.m9312().f5712, 1);
        this.f16633 = c1191;
        this.f16619 = c4107;
        this.f16628 = interfaceC4093;
        this.f16631 = c0708;
        this.f16626 = context;
        this.f16623 = c4331;
    }

    /* JADX INFO: renamed from: ᵷᵺʾᵖ, reason: contains not printable characters */
    public static boolean m9385(int i) {
        return i == 408 || i == 429 || i == 502 || i == 503 || i == 504;
    }

    /* JADX INFO: renamed from: ᵻˈᵦʼ, reason: contains not printable characters */
    public static String m9386(InputStream inputStream) {
        StringBuilder sb = new StringBuilder();
        try {
            BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(inputStream));
            while (true) {
                String line = bufferedReader.readLine();
                if (line == null) {
                    break;
                }
                sb.append(line);
            }
        } catch (IOException unused) {
            if (sb.length() == 0) {
                return "Unable to connect to the server, access is forbidden. HTTP status code: 403";
            }
        }
        return sb.toString();
    }

    /* JADX INFO: renamed from: ʽˈˋ, reason: contains not printable characters */
    public final void m9387(InputStream inputStream, InputStream inputStream2) {
        HttpURLConnection httpURLConnection = this.f16634;
        if (httpURLConnection != null && !this.f16624) {
            httpURLConnection.disconnect();
        }
        if (inputStream != null) {
            try {
                inputStream.close();
            } catch (IOException unused) {
            }
        }
        if (inputStream2 != null) {
            try {
                inputStream2.close();
            } catch (IOException unused2) {
            }
        }
    }

    /* JADX INFO: renamed from: ˊᵫᵗ, reason: contains not printable characters */
    public final synchronized void m9388() {
        this.f16621 = 8;
    }

    /* JADX INFO: renamed from: ˋˈ, reason: contains not printable characters */
    public final void m9389(Date date) {
        C4331 c4331 = this.f16623;
        int i = c4331.m9312().f5712 + 1;
        long millis = TimeUnit.MINUTES.toMillis(f16617[(i < 8 ? i : 8) - 1]);
        c4331.m9315(i, new Date(date.getTime() + (millis / 2) + ((long) this.f16620.nextInt((int) millis))));
    }

    /* JADX INFO: renamed from: ːˏᵟᵯ, reason: contains not printable characters */
    public final String m9390(String str) {
        C1191 c1191 = this.f16633;
        c1191.m3677();
        Matcher matcher = f16616.matcher(c1191.f5073.f16223);
        return AbstractC3653.m8234("https://firebaseremoteconfigrealtime.googleapis.com/v1/projects/", matcher.matches() ? matcher.group(1) : null, "/namespaces/", str, ":streamFetchInvalidations");
    }

    /* JADX INFO: renamed from: ᵝᵶ, reason: contains not printable characters */
    public final synchronized C3420 m9391(HttpURLConnection httpURLConnection) {
        C3420 c3420;
        C5146 c5146 = new C5146(this);
        C4107 c4107 = this.f16619;
        C0708 c0708 = this.f16631;
        LinkedHashSet linkedHashSet = this.f16629;
        ScheduledExecutorService scheduledExecutorService = this.f16630;
        C4331 c4331 = this.f16623;
        c3420 = new C3420();
        c3420.f13165 = httpURLConnection;
        c3420.f13167 = c4107;
        c3420.f13171 = c0708;
        c3420.f13169 = linkedHashSet;
        c3420.f13168 = c5146;
        c3420.f13173 = scheduledExecutorService;
        c3420.f13170 = new Random();
        c3420.f13172 = c4331;
        c3420.f13166 = ᵠʽᵲ.ᵯᵷʽ;
        return c3420;
    }

    /* JADX INFO: renamed from: ᵨᵣ, reason: contains not printable characters */
    public final synchronized void m9392(long j) {
        try {
            if (m9395()) {
                int i = this.f16621;
                if (i > 0) {
                    this.f16621 = i - 1;
                    this.f16630.schedule(new RunnableC1500(4, this), j, TimeUnit.MILLISECONDS);
                } else if (!this.f16624) {
                    new FirebaseRemoteConfigClientException("Unable to connect to the server. Check your connection and try again.");
                    m9396();
                }
            }
        } catch (Throwable th) {
            throw th;
        }
    }

    /* JADX WARN: Removed duplicated region for block: B:12:0x0071  */
    /* JADX INFO: renamed from: ᵮᵣᵗˈ, reason: contains not printable characters */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final void m9393(HttpURLConnection httpURLConnection, String str, String str2) {
        String strM7946;
        byte[] bArr;
        httpURLConnection.setRequestMethod("POST");
        httpURLConnection.setRequestProperty("X-Goog-Firebase-Installations-Auth", str2);
        C1191 c1191 = this.f16633;
        c1191.m3677();
        C4250 c4250 = c1191.f5073;
        httpURLConnection.setRequestProperty("X-Goog-Api-Key", c4250.f16226);
        Context context = this.f16626;
        httpURLConnection.setRequestProperty("X-Android-Package", context.getPackageName());
        try {
            bArr = ˀᵳˎᵹ.ᵝᵶ(context, context.getPackageName());
        } catch (PackageManager.NameNotFoundException unused) {
            context.getPackageName();
        }
        if (bArr != null) {
            strM7946 = AbstractC3481.m7946(bArr);
            httpURLConnection.setRequestProperty("X-Android-Cert", strM7946);
            httpURLConnection.setRequestProperty("X-Google-GFE-Can-Retry", "yes");
            httpURLConnection.setRequestProperty("X-Accept-Response-Streaming", "true");
            httpURLConnection.setRequestProperty("Content-Type", "application/json");
            httpURLConnection.setRequestProperty("Accept", "application/json");
            HashMap map = new HashMap();
            c1191.m3677();
            Matcher matcher = f16616.matcher(c4250.f16223);
            map.put("project", matcher.matches() ? matcher.group(1) : null);
            map.put("namespace", this.f16622);
            map.put("lastKnownVersionNumber", Long.toString(this.f16619.f15732.f16493.getLong("last_template_version", 0L)));
            c1191.m3677();
            map.put("appId", c4250.f16223);
            map.put("sdkVersion", "23.1.0");
            map.put("appInstanceId", str);
            byte[] bytes = new JSONObject(map).toString().getBytes("utf-8");
            BufferedOutputStream bufferedOutputStream = new BufferedOutputStream(httpURLConnection.getOutputStream());
            bufferedOutputStream.write(bytes);
            bufferedOutputStream.flush();
            bufferedOutputStream.close();
        }
        context.getPackageName();
        strM7946 = null;
        httpURLConnection.setRequestProperty("X-Android-Cert", strM7946);
        httpURLConnection.setRequestProperty("X-Google-GFE-Can-Retry", "yes");
        httpURLConnection.setRequestProperty("X-Accept-Response-Streaming", "true");
        httpURLConnection.setRequestProperty("Content-Type", "application/json");
        httpURLConnection.setRequestProperty("Accept", "application/json");
        HashMap map2 = new HashMap();
        c1191.m3677();
        Matcher matcher2 = f16616.matcher(c4250.f16223);
        map2.put("project", matcher2.matches() ? matcher2.group(1) : null);
        map2.put("namespace", this.f16622);
        map2.put("lastKnownVersionNumber", Long.toString(this.f16619.f15732.f16493.getLong("last_template_version", 0L)));
        c1191.m3677();
        map2.put("appId", c4250.f16223);
        map2.put("sdkVersion", "23.1.0");
        map2.put("appInstanceId", str);
        byte[] bytes2 = new JSONObject(map2).toString().getBytes("utf-8");
        BufferedOutputStream bufferedOutputStream2 = new BufferedOutputStream(httpURLConnection.getOutputStream());
        bufferedOutputStream2.write(bytes2);
        bufferedOutputStream2.flush();
        bufferedOutputStream2.close();
    }

    /* JADX INFO: renamed from: ᵱᵽʡᵚ, reason: contains not printable characters */
    public final synchronized void m9394(boolean z) {
        this.f16618 = z;
    }

    /* JADX WARN: Removed duplicated region for block: B:14:0x0019  */
    /* JADX INFO: renamed from: ᵲᵶᵳˈ, reason: contains not printable characters */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final synchronized boolean m9395() {
        boolean z;
        if (this.f16629.isEmpty() || this.f16618 || this.f16632) {
            z = false;
        } else if (!this.f16624) {
            z = true;
        }
        return z;
    }

    /* JADX INFO: renamed from: ᵵᵽ, reason: contains not printable characters */
    public final synchronized void m9396() {
        Iterator it = this.f16629.iterator();
        while (it.hasNext()) {
            ((C5146) it.next()).m10655();
        }
    }

    /* JADX INFO: renamed from: ᵶᵥᵝ, reason: contains not printable characters */
    public final void m9397(boolean z) {
        HttpURLConnection httpURLConnection;
        synchronized (this.f16627) {
            try {
                this.f16624 = z;
                if (Build.VERSION.SDK_INT >= 26 && z && (httpURLConnection = this.f16634) != null) {
                    httpURLConnection.disconnect();
                }
            } catch (Throwable th) {
                throw th;
            }
        }
    }

    /* JADX INFO: renamed from: ᵻʽᵯ, reason: contains not printable characters */
    public final synchronized void m9398() {
        this.f16625.getClass();
        m9392(Math.max(0L, this.f16623.m9312().f5711.getTime() - new Date(System.currentTimeMillis()).getTime()));
    }
}