Pesohere v1.0.5 - h.java 源代码

package f.e.c.x;

import android.annotation.SuppressLint;
import android.text.TextUtils;
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 f.e.c.o.z;
import f.e.c.x.j;
import f.e.c.x.s.d;
import f.e.c.x.s.f;
import java.io.IOException;
import java.util.ArrayList;
import java.util.HashSet;
import java.util.Iterator;
import java.util.List;
import java.util.Set;
import java.util.concurrent.Executor;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.atomic.AtomicInteger;

public class h implements i {
    public static final Object m = new Object();
    public final f.e.c.i a;
    public final f.e.c.x.s.c b;

    public final f.e.c.x.r.c f3453c;

    public final p f3454d;

    public final z<f.e.c.x.r.b> f3455e;

    public final n f3456f;

    public final Object f3457g;

    public final ExecutorService f3458h;

    public final Executor f3459i;

    public String f3460j;

    public Set<f.e.c.x.q.a> f3461k;

    public final List<o> f3462l;

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

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

    public static class b {
        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) {
            }
        }
    }

    static {
        new a();
    }

    @SuppressLint({"ThreadPoolCreation"})
    public h(final f.e.c.i iVar, f.e.c.w.b<f.e.c.u.i> bVar, ExecutorService executorService, Executor executor) {
        this(executorService, executor, iVar, new f.e.c.x.s.c(iVar.h(), bVar), new f.e.c.x.r.c(iVar), p.c(), new z(new f.e.c.w.b() {
            @Override
            public final Object get() {
                return h.u(f.e.c.i.this);
            }
        }), new n());
    }

    public static h l() {
        return m(f.e.c.i.i());
    }

    public static h m(f.e.c.i iVar) {
        Preconditions.checkArgument(iVar != null, "Null is not a valid value of FirebaseApp.");
        return (h) iVar.g(i.class);
    }

    public static f.e.c.x.r.b u(f.e.c.i iVar) {
        return new f.e.c.x.r.b(iVar);
    }

    public final synchronized void A(String str) {
        this.f3460j = str;
    }

    public final synchronized void B(f.e.c.x.r.d dVar, f.e.c.x.r.d dVar2) {
        if (this.f3461k.size() != 0 && !TextUtils.equals(dVar.d(), dVar2.d())) {
            Iterator<f.e.c.x.q.a> it = this.f3461k.iterator();
            while (it.hasNext()) {
                it.next().a(dVar2.d());
            }
        }
    }

    @Override
    public Task<m> a(final boolean z) {
        v();
        Task<m> b2 = b();
        this.f3458h.execute(new Runnable() {
            @Override
            public final void run() {
                h.this.t(z);
            }
        });
        return b2;
    }

    public final Task<m> b() {
        TaskCompletionSource taskCompletionSource = new TaskCompletionSource();
        d(new k(this.f3454d, taskCompletionSource));
        return taskCompletionSource.getTask();
    }

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

    public final void d(o oVar) {
        synchronized (this.f3457g) {
            this.f3462l.add(oVar);
        }
    }

    public final void r(boolean z) {
        f.e.c.x.r.d x;
        f.e.c.x.r.d n = n();
        try {
            if (!n.i() && !n.l()) {
                if (!z && !this.f3454d.f(n)) {
                    return;
                }
                x = g(n);
                q(x);
                B(n, x);
                if (x.k()) {
                    A(x.d());
                }
                if (!x.i()) {
                    y(new j(j.a.BAD_CONFIG));
                    return;
                } else if (x.j()) {
                    y(new IOException("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."));
                    return;
                } else {
                    z(x);
                    return;
                }
            }
            x = x(n);
            q(x);
            B(n, x);
            if (x.k()) {
            }
            if (!x.i()) {
            }
        } catch (j e2) {
            y(e2);
        }
    }

    public final void t(final boolean z) {
        f.e.c.x.r.d o = o();
        if (z) {
            o = o.p();
        }
        z(o);
        this.f3459i.execute(new Runnable() {
            @Override
            public final void run() {
                h.this.r(z);
            }
        });
    }

    public final f.e.c.x.r.d g(f.e.c.x.r.d dVar) {
        f.e.c.x.s.f e2 = this.b.e(h(), dVar.d(), p(), dVar.f());
        int i2 = b.b[e2.b().ordinal()];
        if (i2 == 1) {
            return dVar.o(e2.c(), e2.d(), this.f3454d.b());
        }
        if (i2 == 2) {
            return dVar.q("BAD CONFIG");
        }
        if (i2 != 3) {
            throw new j("Firebase Installations Service is unavailable. Please try again later.", j.a.UNAVAILABLE);
        }
        A(null);
        return dVar.r();
    }

    @Override
    public Task<String> getId() {
        v();
        String j2 = j();
        if (j2 != null) {
            return Tasks.forResult(j2);
        }
        Task<String> c2 = c();
        this.f3458h.execute(new Runnable() {
            @Override
            public final void run() {
                h.this.s();
            }
        });
        return c2;
    }

    public String h() {
        return this.a.k().b();
    }

    public String i() {
        return this.a.k().c();
    }

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

    public final f.e.c.x.r.b k() {
        return this.f3455e.get();
    }

    public final f.e.c.x.r.d n() {
        f.e.c.x.r.d d2;
        synchronized (m) {
            g a2 = g.a(this.a.h(), "generatefid.lock");
            try {
                d2 = this.f3453c.d();
            } finally {
                if (a2 != null) {
                    a2.b();
                }
            }
        }
        return d2;
    }

    public final f.e.c.x.r.d o() {
        f.e.c.x.r.d d2;
        synchronized (m) {
            g a2 = g.a(this.a.h(), "generatefid.lock");
            try {
                d2 = this.f3453c.d();
                if (d2.j()) {
                    String w = w(d2);
                    f.e.c.x.r.c cVar = this.f3453c;
                    d2 = d2.t(w);
                    cVar.b(d2);
                }
            } finally {
                if (a2 != null) {
                    a2.b();
                }
            }
        }
        return d2;
    }

    public String p() {
        return this.a.k().e();
    }

    public final void q(f.e.c.x.r.d dVar) {
        synchronized (m) {
            g a2 = g.a(this.a.h(), "generatefid.lock");
            try {
                this.f3453c.b(dVar);
            } finally {
                if (a2 != null) {
                    a2.b();
                }
            }
        }
    }

    public void s() {
        t(false);
    }

    public final void v() {
        Preconditions.checkNotEmpty(i(), "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.");
        Preconditions.checkNotEmpty(p(), "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.");
        Preconditions.checkNotEmpty(h(), "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.");
        Preconditions.checkArgument(p.h(i()), "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.");
        Preconditions.checkArgument(p.g(h()), "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 final String w(f.e.c.x.r.d dVar) {
        if ((!this.a.j().equals("CHIME_ANDROID_SDK") && !this.a.r()) || !dVar.m()) {
            return this.f3456f.a();
        }
        String f2 = k().f();
        return TextUtils.isEmpty(f2) ? this.f3456f.a() : f2;
    }

    public final f.e.c.x.r.d x(f.e.c.x.r.d dVar) {
        f.e.c.x.s.d d2 = this.b.d(h(), dVar.d(), p(), i(), (dVar.d() == null || dVar.d().length() != 11) ? null : k().i());
        int i2 = b.a[d2.e().ordinal()];
        if (i2 == 1) {
            return dVar.s(d2.c(), d2.d(), this.f3454d.b(), d2.b().c(), d2.b().d());
        }
        if (i2 == 2) {
            return dVar.q("BAD CONFIG");
        }
        throw new j("Firebase Installations Service is unavailable. Please try again later.", j.a.UNAVAILABLE);
    }

    public final void y(Exception exc) {
        synchronized (this.f3457g) {
            Iterator<o> it = this.f3462l.iterator();
            while (it.hasNext()) {
                if (it.next().a(exc)) {
                    it.remove();
                }
            }
        }
    }

    public final void z(f.e.c.x.r.d dVar) {
        synchronized (this.f3457g) {
            Iterator<o> it = this.f3462l.iterator();
            while (it.hasNext()) {
                if (it.next().b(dVar)) {
                    it.remove();
                }
            }
        }
    }

    @SuppressLint({"ThreadPoolCreation"})
    public h(ExecutorService executorService, Executor executor, f.e.c.i iVar, f.e.c.x.s.c cVar, f.e.c.x.r.c cVar2, p pVar, z<f.e.c.x.r.b> zVar, n nVar) {
        this.f3457g = new Object();
        this.f3461k = new HashSet();
        this.f3462l = new ArrayList();
        this.a = iVar;
        this.b = cVar;
        this.f3453c = cVar2;
        this.f3454d = pVar;
        this.f3455e = zVar;
        this.f3456f = nVar;
        this.f3458h = executorService;
        this.f3459i = executor;
    }
}