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

package D9;

import E9.AbstractC0843b;
import E9.C0848g;
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.AbstractC3281g;
import io.grpc.Z;
import io.grpc.p0;
import w9.AbstractC4563a;

public class C0823y {

    private static final Z.g f2122g;

    private static final Z.g f2123h;

    private static final Z.g f2124i;

    private static volatile String f2125j;

    private final C0848g f2126a;

    private final AbstractC4563a f2127b;

    private final AbstractC4563a f2128c;

    private final H f2129d;

    private final String f2130e;

    private final I f2131f;

    class b extends io.grpc.A {

        final AbstractC3281g[] f2135a;

        final Task f2136b;

        b(AbstractC3281g[] abstractC3281gArr, Task task) {
            this.f2135a = abstractC3281gArr;
            this.f2136b = task;
        }

        @Override
        protected AbstractC3281g delegate() {
            AbstractC0843b.d(this.f2135a[0] != null, "ClientCall used before onOpen() callback", new Object[0]);
            return this.f2135a[0];
        }

        @Override
        public void halfClose() {
            if (this.f2135a[0] == null) {
                this.f2136b.addOnSuccessListener(C0823y.this.f2126a.o(), new OnSuccessListener() {
                    @Override
                    public final void onSuccess(Object obj) {
                        ((AbstractC3281g) obj).halfClose();
                    }
                });
            } else {
                super.halfClose();
            }
        }
    }

    class c extends AbstractC3281g.a {

        final e f2138a;

        final AbstractC3281g f2139b;

        c(e eVar, AbstractC3281g abstractC3281g) {
            this.f2138a = eVar;
            this.f2139b = abstractC3281g;
        }

        @Override
        public void a(p0 p0Var, io.grpc.Z z10) {
            this.f2138a.a(p0Var);
        }

        @Override
        public void c(Object obj) {
            this.f2138a.b(obj);
            this.f2139b.request(1);
        }
    }

    class d extends AbstractC3281g.a {

        final TaskCompletionSource f2141a;

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

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

        @Override
        public void c(Object obj) {
            this.f2141a.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.f44141e;
        f2122g = Z.g.e("x-goog-api-client", dVar);
        f2123h = Z.g.e("google-cloud-resource-prefix", dVar);
        f2124i = Z.g.e("x-goog-request-params", dVar);
        f2125j = "gl-java/";
    }

    C0823y(C0848g c0848g, AbstractC4563a abstractC4563a, AbstractC4563a abstractC4563a2, B9.f fVar, I i10, H h10) {
        this.f2126a = c0848g;
        this.f2131f = i10;
        this.f2127b = abstractC4563a;
        this.f2128c = abstractC4563a2;
        this.f2129d = h10;
        this.f2130e = String.format("projects/%s/databases/%s", fVar.i(), fVar.g());
    }

    public com.google.firebase.firestore.P f(p0 p0Var) {
        return C0816q.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/", f2125j, "25.1.4");
    }

    public void i(AbstractC3281g[] abstractC3281gArr, J j10, Task task) {
        AbstractC3281g abstractC3281g = (AbstractC3281g) task.getResult();
        abstractC3281gArr[0] = abstractC3281g;
        abstractC3281g.start(new a(j10, abstractC3281gArr), l());
        j10.b();
        abstractC3281gArr[0].request(1);
    }

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

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

    private io.grpc.Z l() {
        io.grpc.Z z10 = new io.grpc.Z();
        z10.p(f2122g, g());
        z10.p(f2123h, this.f2130e);
        z10.p(f2124i, this.f2130e);
        I i10 = this.f2131f;
        if (i10 != null) {
            i10.a(z10);
        }
        return z10;
    }

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

    public void h() {
        this.f2127b.b();
        this.f2128c.b();
    }

    AbstractC3281g m(io.grpc.a0 a0Var, final J j10) {
        final AbstractC3281g[] abstractC3281gArr = {null};
        Task i10 = this.f2129d.i(a0Var);
        i10.addOnCompleteListener(this.f2126a.o(), new OnCompleteListener() {
            @Override
            public final void onComplete(Task task) {
                C0823y.this.i(abstractC3281gArr, j10, task);
            }
        });
        return new b(abstractC3281gArr, i10);
    }

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

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

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

    class a extends AbstractC3281g.a {

        final J f2132a;

        final AbstractC3281g[] f2133b;

        a(J j10, AbstractC3281g[] abstractC3281gArr) {
            this.f2132a = j10;
            this.f2133b = abstractC3281gArr;
        }

        @Override
        public void a(p0 p0Var, io.grpc.Z z10) {
            try {
                this.f2132a.a(p0Var);
            } catch (Throwable th) {
                C0823y.this.f2126a.u(th);
            }
        }

        @Override
        public void b(io.grpc.Z z10) {
            try {
                this.f2132a.c(z10);
            } catch (Throwable th) {
                C0823y.this.f2126a.u(th);
            }
        }

        @Override
        public void c(Object obj) {
            try {
                this.f2132a.onNext(obj);
                this.f2133b[0].request(1);
            } catch (Throwable th) {
                C0823y.this.f2126a.u(th);
            }
        }

        @Override
        public void d() {
        }
    }
}