package o;

import android.text.InputFilter;
import android.text.Layout;
import android.text.SpannableString;
import android.text.style.AlignmentSpan;
import android.text.style.StyleSpan;
import java.util.List;
import o.C0690Mh;
import o.C1171Xc;
import o.C2585ahQ;
import o.CYx;
import o.ZI;
import o.cXH;
import o.wRi;

/* renamed from: o.ahQ, reason: case insensitive filesystem */
/* loaded from: classes3.dex */
public class C2585ahQ extends ZI<InterfaceC8981dbB> {
    public final QAJ a;
    public final DeS b;
    public FI c;
    public final C17603yF d;
    public List<C1003Tl> e;
    public cXH.IeS.EnumC0105IeS g;
    public int h;
    private final hda i;
    private final JaU k;
    private final C11045eWp n;

    /* renamed from: o, reason: collision with root package name */
    private final C16265mo f8519o;

    @InterfaceC13391fZD
    public C2585ahQ(C16903sI c16903sI, DeS deS, C16265mo c16265mo, C11045eWp c11045eWp, hda hdaVar, QAJ qaj, C17603yF c17603yF, JaU jaU) {
        super(c16903sI);
        this.b = deS;
        this.f8519o = c16265mo;
        this.n = c11045eWp;
        this.i = hdaVar;
        this.a = qaj;
        this.d = c17603yF;
        this.k = jaU;
    }

    /* renamed from: o.ahQ$5, reason: invalid class name */
    /* loaded from: classes3.dex */
    public class AnonymousClass5 extends wRi.LWm<C2414aeE> {
        private C2585ahQ b;

        public AnonymousClass5(C2585ahQ c2585ahQ) {
            this.b = c2585ahQ;
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final /* synthetic */ void onNext(Object obj) {
            C2414aeE c2414aeE = (C2414aeE) obj;
            C2585ahQ.h(this.b);
            if (!c2414aeE.d.isEmpty() && c2414aeE.d != null) {
                C2585ahQ.c(this.b, c2414aeE.d);
                C2585ahQ c2585ahQ = this.b;
                c2585ahQ.h = c2585ahQ.e.size() - 1;
                this.b.c.i = (C1003Tl) this.b.e.get(this.b.h);
                this.b.c.g = true;
                C2585ahQ c2585ahQ2 = this.b;
                ZI.IeS ieS = new ZI.IeS(this) { // from class: o.aih
                    private C2585ahQ.AnonymousClass5 e;

                    @Override // o.ZI.IeS
                    public final void e(Object obj2) {
                        C2585ahQ.AnonymousClass5.c(this.e, (InterfaceC8981dbB) obj2);
                    }

                    {
                        this.e = this;
                    }
                };
                if (c2585ahQ2.f != 0) {
                    ieS.e(c2585ahQ2.f);
                    return;
                }
                return;
            }
            C2585ahQ c2585ahQ3 = this.b;
            ZI.IeS ieS2 = new ZI.IeS() { // from class: o.aie
                @Override // o.ZI.IeS
                public final void e(Object obj2) {
                    C2585ahQ.AnonymousClass5.e((InterfaceC8981dbB) obj2);
                }
            };
            if (c2585ahQ3.f != 0) {
                ieS2.e(c2585ahQ3.f);
            }
        }

        /* JADX INFO: Access modifiers changed from: package-private */
        public static /* synthetic */ void e(InterfaceC8981dbB interfaceC8981dbB) {
            interfaceC8981dbB.b();
            interfaceC8981dbB.c();
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final void onError(Throwable th) {
            C2585ahQ.j(this.b);
            C2585ahQ c2585ahQ = this.b;
            ZI.IeS ieS = new ZI.IeS() { // from class: o.aid
                @Override // o.ZI.IeS
                public final void e(Object obj) {
                    C2585ahQ.AnonymousClass5.d((InterfaceC8981dbB) obj);
                }
            };
            if (c2585ahQ.f != 0) {
                ieS.e(c2585ahQ.f);
            }
        }

        /* JADX INFO: Access modifiers changed from: package-private */
        public static /* synthetic */ void d(InterfaceC8981dbB interfaceC8981dbB) {
            interfaceC8981dbB.b();
            interfaceC8981dbB.c();
        }

        public static /* synthetic */ void c(AnonymousClass5 anonymousClass5, InterfaceC8981dbB interfaceC8981dbB) {
            interfaceC8981dbB.b();
            interfaceC8981dbB.e(((C1003Tl) anonymousClass5.b.e.get(anonymousClass5.b.h)).d);
        }
    }

    /* renamed from: o.ahQ$4, reason: invalid class name */
    /* loaded from: classes3.dex */
    public class AnonymousClass4 extends wRi.LWm<wNS> {
        private C2585ahQ d;

        public AnonymousClass4(C2585ahQ c2585ahQ) {
            this.d = c2585ahQ;
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final /* synthetic */ void onNext(Object obj) {
            final wNS wns = (wNS) obj;
            C2585ahQ.g(this.d);
            C2585ahQ c2585ahQ = this.d;
            ZI.IeS ieS = new ZI.IeS(this, wns) { // from class: o.aii
                private wNS a;
                private C2585ahQ.AnonymousClass4 e;

                @Override // o.ZI.IeS
                public final void e(Object obj2) {
                    C2585ahQ.AnonymousClass4.e(this.e, this.a, (InterfaceC8981dbB) obj2);
                }

                {
                    this.e = this;
                    this.a = wns;
                }
            };
            if (c2585ahQ.f != 0) {
                ieS.e(c2585ahQ.f);
            }
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final void onError(Throwable th) {
            C2585ahQ.a(this.d, th, C0690Mh.IeS.JUST_DISMISS);
        }

        public static /* synthetic */ void e(AnonymousClass4 anonymousClass4, wNS wns, InterfaceC8981dbB interfaceC8981dbB) {
            if (wns.a.isEmpty()) {
                interfaceC8981dbB.h(wns.d);
                return;
            }
            FJ fj = anonymousClass4.d.c.l;
            if (fj != null) {
                interfaceC8981dbB.b(anonymousClass4.d.f8519o.a(wns), fj);
            } else {
                interfaceC8981dbB.b(anonymousClass4.d.f8519o.a(wns));
            }
        }
    }

    public static SpannableString Vb_(String str, String str2) {
        String format = String.format("%s%n%s", str, str2);
        int length = str.length();
        SpannableString spannableString = new SpannableString(format);
        spannableString.setSpan(new StyleSpan(1), length + 1, format.length(), 0);
        spannableString.setSpan(new AlignmentSpan.Standard(Layout.Alignment.ALIGN_CENTER), 0, format.length(), 33);
        return spannableString;
    }

    public static InputFilter[] Va_(int i) {
        return new InputFilter[]{new InputFilter.LengthFilter(i)};
    }

    public final void a(String str) {
        final String v = C6583cXR.v(str);
        if (v.length() >= 10) {
            JaU jaU = this.k;
            if (!gjJ.b((CharSequence) v) && jaU.c.matcher(v).matches()) {
                this.c.i = C17603yF.a(v, true);
                ZI.IeS ieS = new ZI.IeS(this, v) { // from class: o.ahR
                    private String a;
                    private C2585ahQ b;

                    @Override // o.ZI.IeS
                    public final void e(Object obj) {
                        C2585ahQ.d(this.b, this.a, (InterfaceC8981dbB) obj);
                    }

                    {
                        this.b = this;
                        this.a = v;
                    }
                };
                if (this.f != 0) {
                    ieS.e(this.f);
                    return;
                }
                return;
            }
            this.c.i = null;
            this.c.g = false;
            ZI.IeS ieS2 = new ZI.IeS(this) { // from class: o.ahM
                private C2585ahQ c;

                @Override // o.ZI.IeS
                public final void e(Object obj) {
                    C2585ahQ.e(this.c, (InterfaceC8981dbB) obj);
                }

                {
                    this.c = this;
                }
            };
            if (this.f != 0) {
                ieS2.e(this.f);
                return;
            }
            return;
        }
        this.c.i = null;
        this.c.g = false;
        ZI.IeS ieS3 = new ZI.IeS(this) { // from class: o.aif
            private C2585ahQ c;

            @Override // o.ZI.IeS
            public final void e(Object obj) {
                C2585ahQ.d(this.c, (InterfaceC8981dbB) obj);
            }

            {
                this.c = this;
            }
        };
        if (this.f != 0) {
            ieS3.e(this.f);
        }
    }

    @Override // o.ZI
    public final void w_() {
        super.w_();
        this.c.l = null;
        C11045eWp c11045eWp = this.n;
        if (!c11045eWp.h.isDisposed()) {
            c11045eWp.h.dispose();
        }
        QAJ qaj = this.a;
        if (qaj.h.isDisposed()) {
            return;
        }
        qaj.h.dispose();
    }

    /* JADX INFO: Access modifiers changed from: package-private */
    /* renamed from: o.ahQ$LWm */
    /* loaded from: classes3.dex */
    public class LWm extends wRi.LWm<krp> {
        private C2585ahQ a;

        private LWm(C2585ahQ c2585ahQ) {
            this.a = c2585ahQ;
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final /* synthetic */ void onNext(Object obj) {
            C2585ahQ.f(this.a);
            this.a.i.e.a((krp) obj);
            C2585ahQ c2585ahQ = this.a;
            ZI.IeS ieS = new ZI.IeS(this) { // from class: o.aik
                private C2585ahQ.LWm e;

                @Override // o.ZI.IeS
                public final void e(Object obj2) {
                    ((InterfaceC8981dbB) obj2).b(r0.a.c, this.e.a.g);
                }

                {
                    this.e = this;
                }
            };
            if (c2585ahQ.f != 0) {
                ieS.e(c2585ahQ.f);
            }
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final void onError(final Throwable th) {
            C2585ahQ c2585ahQ = this.a;
            ZI.IeS ieS = new ZI.IeS(this, th) { // from class: o.ail
                private C2585ahQ.LWm c;
                private Throwable d;

                @Override // o.ZI.IeS
                public final void e(Object obj) {
                    C2585ahQ.c(this.c.a, this.d);
                }

                {
                    this.c = this;
                    this.d = th;
                }
            };
            if (c2585ahQ.f != 0) {
                ieS.e(c2585ahQ.f);
            }
        }

        /* synthetic */ LWm(C2585ahQ c2585ahQ, byte b) {
            this(c2585ahQ);
        }
    }

    public static /* synthetic */ void e(C2585ahQ c2585ahQ, String str, InterfaceC8981dbB interfaceC8981dbB) {
        interfaceC8981dbB.b(c2585ahQ.b());
        List<C1003Tl> list = c2585ahQ.e;
        interfaceC8981dbB.d(10, (list == null || !str.equals(list.get(c2585ahQ.h).d)) ? C6583cXR.v(str) : "");
    }

    public static /* synthetic */ void c(C2585ahQ c2585ahQ, InterfaceC8981dbB interfaceC8981dbB) {
        interfaceC8981dbB.m(String.valueOf(c2585ahQ.c.n));
        interfaceC8981dbB.c((String) C6583cXR.c(new Object[]{Double.valueOf(c2585ahQ.c.b)}, -150997759, 150997764, (int) System.currentTimeMillis()));
        interfaceC8981dbB.b(c2585ahQ.b());
    }

    public static /* synthetic */ void d(C2585ahQ c2585ahQ, int i, InterfaceC8981dbB interfaceC8981dbB) {
        interfaceC8981dbB.b(c2585ahQ.b());
        interfaceC8981dbB.f((String) C6583cXR.c(new Object[]{true, true, c2585ahQ.e.get(i).b}, -1092823629, 1092823630, (int) System.currentTimeMillis()));
    }

    public static /* synthetic */ void d(C2585ahQ c2585ahQ, InterfaceC8981dbB interfaceC8981dbB) {
        interfaceC8981dbB.b(c2585ahQ.b());
        interfaceC8981dbB.d();
    }

    public static /* synthetic */ void d(C2585ahQ c2585ahQ, String str, InterfaceC8981dbB interfaceC8981dbB) {
        interfaceC8981dbB.b(c2585ahQ.b());
        interfaceC8981dbB.e();
        interfaceC8981dbB.d(12, (String) C6583cXR.c(new Object[]{false, true, str}, -1092823629, 1092823630, (int) System.currentTimeMillis()));
    }

    public static /* synthetic */ void d(C2585ahQ c2585ahQ, WW ww, InterfaceC8981dbB interfaceC8981dbB) {
        interfaceC8981dbB.c(ww.d.doubleValue());
        interfaceC8981dbB.b(c2585ahQ.b());
    }

    public static /* synthetic */ void e(C2585ahQ c2585ahQ, FJ fj, double d, InterfaceC8981dbB interfaceC8981dbB) {
        interfaceC8981dbB.d(fj);
        interfaceC8981dbB.g(fj.k);
        interfaceC8981dbB.b_(true);
        interfaceC8981dbB.a(c2585ahQ.c.f8156o != null ? c2585ahQ.c.f8156o.d.doubleValue() : Double.MAX_VALUE, d);
    }

    public static /* synthetic */ void e(C2585ahQ c2585ahQ, InterfaceC8981dbB interfaceC8981dbB) {
        interfaceC8981dbB.b(c2585ahQ.b());
        interfaceC8981dbB.h();
    }

    static /* synthetic */ void c(C2585ahQ c2585ahQ, List list) {
        c2585ahQ.e = (List) C16157lj.c(new Object[]{list, new C16164ln(c2585ahQ.d, true)}, -1846295624, 1846295631, (int) System.currentTimeMillis());
    }

    static /* synthetic */ void h(C2585ahQ c2585ahQ) {
        if (c2585ahQ.f != 0) {
            c2585ahQ.f.ar_();
        }
    }

    static /* synthetic */ void j(C2585ahQ c2585ahQ) {
        if (c2585ahQ.f != 0) {
            c2585ahQ.f.ar_();
        }
    }

    static /* synthetic */ void a(C2585ahQ c2585ahQ, Throwable th, C0690Mh.IeS ieS) {
        if (c2585ahQ.b(th)) {
            c2585ahQ.d(c2585ahQ.j.d(th, ieS));
        }
    }

    static /* synthetic */ void g(C2585ahQ c2585ahQ) {
        if (c2585ahQ.f != 0) {
            c2585ahQ.f.ar_();
        }
    }

    static /* synthetic */ void f(C2585ahQ c2585ahQ) {
        if (c2585ahQ.f != 0) {
            c2585ahQ.f.ar_();
        }
    }

    /* JADX INFO: Access modifiers changed from: package-private */
    public static /* synthetic */ void c(C2585ahQ c2585ahQ, Throwable th) {
        if (c2585ahQ.b(th)) {
            c2585ahQ.d(c2585ahQ.j.e(th));
        }
    }

    /* JADX INFO: Access modifiers changed from: package-private */
    public static /* synthetic */ void c(FI fi, InterfaceC8981dbB interfaceC8981dbB) {
        interfaceC8981dbB.d(fi.h);
        C1171Xc.IeS ieS = new C1171Xc.IeS(YE.BOND_FUNCTION);
        C1171Xc c1171Xc = ieS.c;
        c1171Xc.a = false;
        c1171Xc.b = true;
        c1171Xc.j = true;
        c1171Xc.g = true;
        ieS.c.g = false;
        ieS.c.j = false;
        ieS.c.b = false;
        interfaceC8981dbB.c(ieS.c);
        interfaceC8981dbB.b_(false);
        interfaceC8981dbB.m("0");
        interfaceC8981dbB.c((String) C6583cXR.c(new Object[]{Double.valueOf(0.0d)}, -150997759, 150997764, (int) System.currentTimeMillis()));
        interfaceC8981dbB.d(fi.f);
        interfaceC8981dbB.b(fi.d);
        interfaceC8981dbB.b(false);
    }

    private boolean b() {
        boolean z = this.c.b > 0.0d && this.c.b >= this.c.j && this.c.f8156o != null && this.c.f8156o.d.doubleValue() >= this.c.b;
        return this.g == cXH.IeS.EnumC0105IeS.DLT ? z && this.c.i != null : z;
    }

    public final void a() {
        if (this.c.l != null) {
            if (this.f != 0) {
                this.f.y();
            }
            byte b = 0;
            if (cXH.IeS.EnumC0105IeS.SCB == this.g) {
                C11045eWp c11045eWp = this.n;
                CYx.Sts b2 = CYx.b();
                b2.e = this.c.f8156o.s;
                b2.d = String.valueOf(this.c.b);
                b2.c = this.c.l.j;
                b2.b = this.c.a.s;
                c11045eWp.b(new CYx(b2, (byte) 0));
            } else {
                C11045eWp c11045eWp2 = this.n;
                CYx.Sts b3 = CYx.b();
                b3.e = this.c.f8156o.s;
                b3.d = C6583cXR.c(this.c.b);
                b3.c = this.c.l.j;
                b3.b = this.c.a.s;
                b3.a = this.c.i.b;
                c11045eWp2.d(new CYx(b3, (byte) 0));
            }
            C11045eWp c11045eWp3 = this.n;
            c11045eWp3.d(c11045eWp3.i, new LWm(this, b));
        }
    }
}