All File Recovery v1.0.2 - j.java 源代码

package A9;

import A9.l;
import F9.d;
import F9.f;
import W8.w;
import android.annotation.SuppressLint;
import android.text.TextUtils;
import androidx.annotation.NonNull;
import androidx.annotation.Nullable;
import com.google.android.gms.common.internal.Preconditions;
import com.google.android.gms.tasks.Task;
import com.google.android.gms.tasks.TaskCompletionSource;
import com.google.android.gms.tasks.Tasks;
import java.util.ArrayList;
import java.util.HashSet;
import java.util.Iterator;
import java.util.List;
import java.util.Set;
import java.util.concurrent.Callable;
import java.util.concurrent.Executor;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.atomic.AtomicInteger;
import l.A;
import l.i0;
import z9.InterfaceC1110b;

public class j implements k {
    public static final String n = "generatefid.lock";
    public static final String o = "CHIME_ANDROID_SDK";
    public static final int p = 0;
    public static final int q = 1;
    public static final long r = 30;
    public static final String t = "Please set a valid API key. A Firebase API key is required to communicate with Firebase server APIs: It authenticates your project with Google.Please refer to https://firebase.google.com/support/privacy/init-options.";
    public static final String u = "Please set your Application ID. A valid Firebase App ID is required to communicate with Firebase server APIs: It identifies your application with Firebase.Please refer to https://firebase.google.com/support/privacy/init-options.";
    public static final String v = "Please set your Project ID. A valid Firebase Project ID is required to communicate with Firebase server APIs: It identifies your application with Firebase.Please refer to https://firebase.google.com/support/privacy/init-options.";
    public static final String w = "Installation ID could not be validated with the Firebase servers (maybe it was deleted). Firebase Installations will need to create a new Installation ID and auth token. Please retry your last request.";
    public final L8.h a;
    public final F9.c b;
    public final E9.c c;
    public final u d;
    public final w<E9.b> e;
    public final s f;
    public final Object g;
    public final ExecutorService h;
    public final Executor i;

    @A("this")
    public String j;

    @A("FirebaseInstallations.this")
    public Set<B9.a> k;

    @A("lock")
    public final List<t> l;
    public static final Object m = new Object();
    public static final ThreadFactory s = new a();

    public class a implements ThreadFactory {
        public final AtomicInteger a = new AtomicInteger(1);

        @Override
        @SuppressLint({"ThreadPoolCreation"})
        public Thread newThread(Runnable runnable) {
            return new Thread(runnable, String.format("firebase-installations-executor-%d", Integer.valueOf(this.a.getAndIncrement())));
        }
    }

    public class b implements B9.b {
        public final B9.a a;

        public b(B9.a aVar) {
            this.a = aVar;
        }

        @Override
        public void a() {
            synchronized (j.this) {
                j.this.k.remove(this.a);
            }
        }
    }

    public static class c {
        public static final int[] a;
        public static final int[] b;

        static {
            int[] iArr = new int[f.b.values().length];
            b = iArr;
            try {
                iArr[f.b.OK.ordinal()] = 1;
            } catch (NoSuchFieldError unused) {
            }
            try {
                b[f.b.BAD_CONFIG.ordinal()] = 2;
            } catch (NoSuchFieldError unused2) {
            }
            try {
                b[f.b.AUTH_ERROR.ordinal()] = 3;
            } catch (NoSuchFieldError unused3) {
            }
            int[] iArr2 = new int[d.b.values().length];
            a = iArr2;
            try {
                iArr2[d.b.OK.ordinal()] = 1;
            } catch (NoSuchFieldError unused4) {
            }
            try {
                a[d.b.BAD_CONFIG.ordinal()] = 2;
            } catch (NoSuchFieldError unused5) {
            }
        }
    }

    @SuppressLint({"ThreadPoolCreation"})
    public j(final L8.h hVar, @NonNull InterfaceC1110b<x9.j> interfaceC1110b, @NonNull ExecutorService executorService, @NonNull Executor executor) {
        this(executorService, executor, hVar, new F9.c(hVar.n(), interfaceC1110b), new E9.c(hVar), u.c(), new w(new InterfaceC1110b() {
            @Override
            public final Object get() {
                return j.h(L8.h.this);
            }
        }), new s());
    }

    public static Void d(j jVar) {
        jVar.m();
        return null;
    }

    public static E9.b h(L8.h hVar) {
        return new E9.b(hVar);
    }

    @NonNull
    public static j u() {
        return v(L8.h.p());
    }

    @NonNull
    public static j v(@NonNull L8.h hVar) {
        Preconditions.checkArgument(hVar != null, "Null is not a valid value of FirebaseApp.");
        return (j) hVar.l(k.class);
    }

    public final void A(E9.d dVar) {
        synchronized (m) {
            try {
                d a2 = d.a(this.a.n(), n);
                try {
                    this.c.c(dVar);
                    if (a2 != null) {
                        a2.b();
                    }
                } catch (Throwable th) {
                    if (a2 != null) {
                        a2.b();
                    }
                    throw th;
                }
            } catch (Throwable th2) {
                throw th2;
            }
        }
    }

    public final void B() {
        Preconditions.checkNotEmpty(r(), u);
        Preconditions.checkNotEmpty(z(), v);
        Preconditions.checkNotEmpty(q(), t);
        Preconditions.checkArgument(u.h(r()), u);
        Preconditions.checkArgument(u.g(q()), t);
    }

    public final String C(E9.d dVar) {
        if ((!this.a.r().equals(o) && !this.a.B()) || !dVar.m()) {
            return this.f.a();
        }
        String f = t().f();
        return TextUtils.isEmpty(f) ? this.f.a() : f;
    }

    public final E9.d D(E9.d dVar) throws l {
        F9.d d = this.b.d(q(), dVar.d(), z(), r(), (dVar.d() == null || dVar.d().length() != 11) ? null : t().i());
        int i = c.a[d.e().ordinal()];
        if (i == 1) {
            return dVar.s(d.c(), d.d(), this.d.b(), d.b().c(), d.b().d());
        }
        if (i == 2) {
            return dVar.q("BAD CONFIG");
        }
        throw new l("Firebase Installations Service is unavailable. Please try again later.", l.a.UNAVAILABLE);
    }

    public final void E(Exception exc) {
        synchronized (this.g) {
            try {
                Iterator<t> it = this.l.iterator();
                while (it.hasNext()) {
                    if (it.next().a(exc)) {
                        it.remove();
                    }
                }
            } catch (Throwable th) {
                throw th;
            }
        }
    }

    public final void F(E9.d dVar) {
        synchronized (this.g) {
            try {
                Iterator<t> it = this.l.iterator();
                while (it.hasNext()) {
                    if (it.next().b(dVar)) {
                        it.remove();
                    }
                }
            } catch (Throwable th) {
                throw th;
            }
        }
    }

    public final synchronized void G(String str) {
        this.j = str;
    }

    public final synchronized void H(E9.d dVar, E9.d dVar2) {
        if (this.k.size() != 0 && !TextUtils.equals(dVar.d(), dVar2.d())) {
            Iterator<B9.a> it = this.k.iterator();
            while (it.hasNext()) {
                it.next().a(dVar2.d());
            }
        }
    }

    @Override
    @NonNull
    public Task<Void> a() {
        return Tasks.call(this.h, new Callable() {
            @Override
            public final Object call() {
                j.d(j.this);
                return null;
            }
        });
    }

    @Override
    @NonNull
    public synchronized B9.b b(@NonNull B9.a aVar) {
        this.k.add(aVar);
        return new b(aVar);
    }

    @Override
    @NonNull
    public Task<p> c(final boolean z) {
        B();
        Task<p> j = j();
        this.h.execute(new Runnable() {
            @Override
            public final void run() {
                j.this.o(z);
            }
        });
        return j;
    }

    @Override
    @NonNull
    public Task<String> getId() {
        B();
        String s2 = s();
        if (s2 != null) {
            return Tasks.forResult(s2);
        }
        Task<String> k = k();
        this.h.execute(new Runnable() {
            @Override
            public final void run() {
                j.this.o(false);
            }
        });
        return k;
    }

    public final Task<p> j() {
        TaskCompletionSource taskCompletionSource = new TaskCompletionSource();
        l(new n(this.d, taskCompletionSource));
        return taskCompletionSource.getTask();
    }

    public final Task<String> k() {
        TaskCompletionSource taskCompletionSource = new TaskCompletionSource();
        l(new o(taskCompletionSource));
        return taskCompletionSource.getTask();
    }

    public final void l(t tVar) {
        synchronized (this.g) {
            this.l.add(tVar);
        }
    }

    public final Void m() throws l {
        G(null);
        E9.d w2 = w();
        if (w2.k()) {
            this.b.e(q(), w2.d(), z(), w2.f());
        }
        A(w2.r());
        return null;
    }

    public final void n(boolean r3) {
        throw new UnsupportedOperationException("Method not decompiled: A9.j.n(boolean):void");
    }

    public final void o(final boolean z) {
        E9.d y = y();
        if (z) {
            y = y.p();
        }
        F(y);
        this.i.execute(new Runnable() {
            @Override
            public final void run() {
                j.this.n(z);
            }
        });
    }

    public final E9.d p(@NonNull E9.d dVar) throws l {
        F9.f f = this.b.f(q(), dVar.d(), z(), dVar.f());
        int i = c.b[f.b().ordinal()];
        if (i == 1) {
            return dVar.o(f.c(), f.d(), this.d.b());
        }
        if (i == 2) {
            return dVar.q("BAD CONFIG");
        }
        if (i != 3) {
            throw new l("Firebase Installations Service is unavailable. Please try again later.", l.a.UNAVAILABLE);
        }
        G(null);
        return dVar.r();
    }

    @Nullable
    public String q() {
        return this.a.s().a;
    }

    @i0
    public String r() {
        return this.a.s().b;
    }

    public final synchronized String s() {
        return this.j;
    }

    public final E9.b t() {
        return this.e.get();
    }

    public final E9.d w() {
        E9.d e;
        synchronized (m) {
            try {
                d a2 = d.a(this.a.n(), n);
                try {
                    e = this.c.e();
                    if (a2 != null) {
                        a2.b();
                    }
                } catch (Throwable th) {
                    if (a2 != null) {
                        a2.b();
                    }
                    throw th;
                }
            } catch (Throwable th2) {
                throw th2;
            }
        }
        return e;
    }

    @i0
    public String x() {
        return this.a.r();
    }

    public final E9.d y() {
        E9.d e;
        synchronized (m) {
            try {
                d a2 = d.a(this.a.n(), n);
                try {
                    e = this.c.e();
                    if (e.j()) {
                        e = this.c.c(e.t(C(e)));
                    }
                    if (a2 != null) {
                        a2.b();
                    }
                } catch (Throwable th) {
                    if (a2 != null) {
                        a2.b();
                    }
                    throw th;
                }
            } catch (Throwable th2) {
                throw th2;
            }
        }
        return e;
    }

    @Nullable
    public String z() {
        return this.a.s().g;
    }

    @SuppressLint({"ThreadPoolCreation"})
    public j(ExecutorService executorService, Executor executor, L8.h hVar, F9.c cVar, E9.c cVar2, u uVar, w<E9.b> wVar, s sVar) {
        this.g = new Object();
        this.k = new HashSet();
        this.l = new ArrayList();
        this.a = hVar;
        this.b = cVar;
        this.c = cVar2;
        this.d = uVar;
        this.e = wVar;
        this.f = sVar;
        this.h = executorService;
        this.i = executor;
    }
}