050 IP Phone v2.3.0 - g.java 源代码

package l1;

import android.annotation.SuppressLint;
import android.content.Context;
import android.content.SharedPreferences;
import androidx.annotation.NonNull;
import androidx.annotation.Nullable;
import com.google.android.gms.tasks.SuccessContinuation;
import com.google.android.gms.tasks.Task;
import com.google.android.gms.tasks.TaskCompletionSource;
import com.google.android.gms.tasks.Tasks;
import d1.b0;
import d1.c0;
import d1.d0;
import d1.h0;
import d1.y0;
import java.util.Locale;
import java.util.concurrent.Callable;
import java.util.concurrent.atomic.AtomicReference;
import l1.g;
import org.json.JSONObject;

public class g implements j {
    private final Context a;
    private final k b;
    private final h c;
    private final b0 d;
    private final l1.a e;
    private final l f;
    private final c0 g;
    private final AtomicReference<d> h;
    private final AtomicReference<TaskCompletionSource<d>> i;

    class a implements SuccessContinuation<Void, Void> {
        final e1.f a;

        a(e1.f fVar) {
            this.a = fVar;
        }

        public JSONObject b() {
            return g.this.f.a(g.this.b, true);
        }

        @NonNull
        public Task<Void> then(@Nullable Void r52) {
            JSONObject jSONObject = (JSONObject) this.a.d.c().submit(new Callable() {
                @Override
                public final Object call() {
                    JSONObject b;
                    b = g.a.this.b();
                    return b;
                }
            }).get();
            if (jSONObject != null) {
                d b = g.this.c.b(jSONObject);
                g.this.e.c(b.c, jSONObject);
                g.this.q(jSONObject, "Loaded settings: ");
                g gVar = g.this;
                gVar.r(gVar.b.f);
                g.this.h.set(b);
                ((TaskCompletionSource) g.this.i.get()).trySetResult(b);
            }
            return Tasks.forResult((Object) null);
        }
    }

    g(Context context, k kVar, b0 b0Var, h hVar, l1.a aVar, l lVar, c0 c0Var) {
        AtomicReference<d> atomicReference = new AtomicReference<>();
        this.h = atomicReference;
        this.i = new AtomicReference<>(new TaskCompletionSource());
        this.a = context;
        this.b = kVar;
        this.d = b0Var;
        this.c = hVar;
        this.e = aVar;
        this.f = lVar;
        this.g = c0Var;
        atomicReference.set(b.b(b0Var));
    }

    public static g l(Context context, String str, h0 h0Var, i1.b bVar, String str2, String str3, j1.g gVar, c0 c0Var) {
        String g = h0Var.g();
        y0 y0Var = new y0();
        return new g(context, new k(str, h0Var.h(), h0Var.i(), h0Var.j(), h0Var, d1.i.h(d1.i.m(context), str, str3, str2), str3, str2, d0.c(g).d()), y0Var, new h(y0Var), new l1.a(gVar), new c(String.format(Locale.US, "https://firebase-settings.crashlytics.com/spi/v2/platforms/android/gmp/%s/settings", str), bVar), c0Var);
    }

    private d m(e eVar) {
        d dVar = null;
        try {
            if (!e.SKIP_CACHE_LOOKUP.equals(eVar)) {
                JSONObject b = this.e.b();
                if (b != null) {
                    d b8 = this.c.b(b);
                    if (b8 != null) {
                        q(b, "Loaded cached settings: ");
                        long a8 = this.d.a();
                        if (!e.IGNORE_CACHE_EXPIRATION.equals(eVar) && b8.a(a8)) {
                            a1.g.f().i("Cached settings have expired.");
                        }
                        try {
                            a1.g.f().i("Returning cached settings.");
                            dVar = b8;
                        } catch (Exception e) {
                            e = e;
                            dVar = b8;
                            a1.g.f().e("Failed to get cached settings", e);
                            return dVar;
                        }
                    } else {
                        a1.g.f().e("Failed to parse cached settings data.", null);
                    }
                } else {
                    a1.g.f().b("No cached settings data found.");
                }
            }
        } catch (Exception e8) {
            e = e8;
        }
        return dVar;
    }

    private String n() {
        return d1.i.q(this.a).getString("existing_instance_identifier", "");
    }

    public void q(JSONObject jSONObject, String str) {
        a1.g.f().b(str + jSONObject.toString());
    }

    @SuppressLint({"CommitPrefEdits"})
    public boolean r(String str) {
        SharedPreferences.Editor edit = d1.i.q(this.a).edit();
        edit.putString("existing_instance_identifier", str);
        edit.apply();
        return true;
    }

    @Override
    public Task<d> a() {
        return this.i.get().getTask();
    }

    @Override
    public d b() {
        return this.h.get();
    }

    boolean k() {
        return !n().equals(this.b.f);
    }

    public Task<Void> o(e1.f fVar) {
        return p(e.USE_CACHE, fVar);
    }

    public Task<Void> p(e eVar, e1.f fVar) {
        d m;
        if (!k() && (m = m(eVar)) != null) {
            this.h.set(m);
            this.i.get().trySetResult(m);
            return Tasks.forResult((Object) null);
        }
        d m8 = m(e.IGNORE_CACHE_EXPIRATION);
        if (m8 != null) {
            this.h.set(m8);
            this.i.get().trySetResult(m8);
        }
        return this.g.k().onSuccessTask(fVar.a, new a(fVar));
    }
}