Namma Yatri v3.3.7 - C0257y.java 源代码

package D9;

import E9.AbstractC0260b;
import E9.C0265g;
import com.google.android.gms.tasks.OnCompleteListener;
import com.google.android.gms.tasks.OnSuccessListener;
import com.google.android.gms.tasks.Task;
import com.google.android.gms.tasks.TaskCompletionSource;
import com.google.firebase.firestore.P;
import io.grpc.Z;
import io.grpc.g;
import io.grpc.p0;
import w9.AbstractC1264a;

public class C0257y {
    private static final Z.g g;
    private static final Z.g h;
    private static final Z.g i;
    private static volatile String j;
    private final C0265g a;
    private final AbstractC1264a b;
    private final AbstractC1264a c;
    private final H d;
    private final String e;
    private final I f;

    class b extends io.grpc.A {
        final io.grpc.g[] a;
        final Task b;

        b(io.grpc.g[] gVarArr, Task task) {
            this.a = gVarArr;
            this.b = task;
        }

        protected io.grpc.g delegate() {
            AbstractC0260b.d(this.a[0] != null, "ClientCall used before onOpen() callback", new Object[0]);
            return this.a[0];
        }

        public void halfClose() {
            if (this.a[0] == null) {
                this.b.addOnSuccessListener(C0257y.this.a.o(), new OnSuccessListener() {
                    @Override
                    public final void onSuccess(Object obj) {
                        ((io.grpc.g) obj).halfClose();
                    }
                });
            } else {
                super.halfClose();
            }
        }
    }

    class c extends g.a {
        final e a;
        final io.grpc.g b;

        c(e eVar, io.grpc.g gVar) {
            this.a = eVar;
            this.b = gVar;
        }

        public void a(p0 p0Var, io.grpc.Z z) {
            this.a.a(p0Var);
        }

        public void c(Object obj) {
            this.a.b(obj);
            this.b.request(1);
        }
    }

    class d extends g.a {
        final TaskCompletionSource a;

        d(TaskCompletionSource taskCompletionSource) {
            this.a = taskCompletionSource;
        }

        public void a(p0 p0Var, io.grpc.Z z) {
            if (!p0Var.p()) {
                this.a.setException(C0257y.this.f(p0Var));
            } else {
                if (this.a.getTask().isComplete()) {
                    return;
                }
                this.a.setException(new com.google.firebase.firestore.P("Received onClose with status OK, but no message.", P.a.INTERNAL));
            }
        }

        public void c(Object obj) {
            this.a.setResult(obj);
        }
    }

    public static abstract class e {
        public abstract void a(p0 p0Var);

        public abstract void b(Object obj);
    }

    static {
        Z.d dVar = io.grpc.Z.e;
        g = Z.g.e("x-goog-api-client", dVar);
        h = Z.g.e("google-cloud-resource-prefix", dVar);
        i = Z.g.e("x-goog-request-params", dVar);
        j = "gl-java/";
    }

    C0257y(C0265g c0265g, AbstractC1264a abstractC1264a, AbstractC1264a abstractC1264a2, B9.f fVar, I i2, H h2) {
        this.a = c0265g;
        this.f = i2;
        this.b = abstractC1264a;
        this.c = abstractC1264a2;
        this.d = h2;
        this.e = String.format("projects/%s/databases/%s", fVar.i(), fVar.g());
    }

    public com.google.firebase.firestore.P f(p0 p0Var) {
        return C0250q.g(p0Var) ? new com.google.firebase.firestore.P("The Cloud Firestore client failed to establish a secure connection. This is likely a problem with your app, rather than with Cloud Firestore itself. See https://bit.ly/2XFpdma for instructions on how to enable TLS on Android 4.x devices.", P.a.d(p0Var.n().d()), p0Var.m()) : E9.I.t(p0Var);
    }

    private String g() {
        return String.format("%s fire/%s grpc/", j, "25.1.4");
    }

    public void i(io.grpc.g[] gVarArr, J j2, Task task) {
        io.grpc.g gVar = (io.grpc.g) task.getResult();
        gVarArr[0] = gVar;
        gVar.start(new a(j2, gVarArr), l());
        j2.b();
        gVarArr[0].request(1);
    }

    public void j(TaskCompletionSource taskCompletionSource, Object obj, Task task) {
        io.grpc.g gVar = (io.grpc.g) task.getResult();
        gVar.start(new d(taskCompletionSource), l());
        gVar.request(2);
        gVar.sendMessage(obj);
        gVar.halfClose();
    }

    public void k(e eVar, Object obj, Task task) {
        io.grpc.g gVar = (io.grpc.g) task.getResult();
        gVar.start(new c(eVar, gVar), l());
        gVar.request(1);
        gVar.sendMessage(obj);
        gVar.halfClose();
    }

    private io.grpc.Z l() {
        io.grpc.Z z = new io.grpc.Z();
        z.p(g, g());
        z.p(h, this.e);
        z.p(i, this.e);
        I i2 = this.f;
        if (i2 != null) {
            i2.a(z);
        }
        return z;
    }

    public static void p(String str) {
        j = str;
    }

    public void h() {
        this.b.b();
        this.c.b();
    }

    io.grpc.g m(io.grpc.a0 a0Var, final J j2) {
        final io.grpc.g[] gVarArr = {null};
        Task i2 = this.d.i(a0Var);
        i2.addOnCompleteListener(this.a.o(), new OnCompleteListener() {
            @Override
            public final void onComplete(Task task) {
                C0257y.this.i(gVarArr, j2, task);
            }
        });
        return new b(gVarArr, i2);
    }

    Task n(io.grpc.a0 a0Var, final Object obj) {
        final TaskCompletionSource taskCompletionSource = new TaskCompletionSource();
        this.d.i(a0Var).addOnCompleteListener(this.a.o(), new OnCompleteListener() {
            @Override
            public final void onComplete(Task task) {
                C0257y.this.j(taskCompletionSource, obj, task);
            }
        });
        return taskCompletionSource.getTask();
    }

    void o(io.grpc.a0 a0Var, final Object obj, final e eVar) {
        this.d.i(a0Var).addOnCompleteListener(this.a.o(), new OnCompleteListener() {
            @Override
            public final void onComplete(Task task) {
                C0257y.this.k(eVar, obj, task);
            }
        });
    }

    public void q() {
        this.d.u();
    }

    class a extends g.a {
        final J a;
        final io.grpc.g[] b;

        a(J j, io.grpc.g[] gVarArr) {
            this.a = j;
            this.b = gVarArr;
        }

        public void a(p0 p0Var, io.grpc.Z z) {
            try {
                this.a.a(p0Var);
            } catch (Throwable th) {
                C0257y.this.a.u(th);
            }
        }

        public void b(io.grpc.Z z) {
            try {
                this.a.c(z);
            } catch (Throwable th) {
                C0257y.this.a.u(th);
            }
        }

        public void c(Object obj) {
            try {
                this.a.onNext(obj);
                this.b[0].request(1);
            } catch (Throwable th) {
                C0257y.this.a.u(th);
            }
        }

        public void d() {
        }
    }
}