258 lines
8.3 KiB
Java
258 lines
8.3 KiB
Java
package o;
|
|
|
|
import java.util.Collections;
|
|
import java.util.Iterator;
|
|
import java.util.List;
|
|
|
|
/* loaded from: classes3.dex */
|
|
public final class CBe extends wRi {
|
|
public String a;
|
|
public final AAN b;
|
|
private final InterfaceC3521azC c;
|
|
uoJ d;
|
|
private final String e;
|
|
private final String g;
|
|
|
|
/* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
|
|
@InterfaceC13391fZD
|
|
public CBe(yRw yrw, yRw yrw2, String str, String str2, InterfaceC3521azC interfaceC3521azC, AAN aan) {
|
|
super(yrw, yrw2);
|
|
C14957gcv.e(yrw, "");
|
|
C14957gcv.e(yrw2, "");
|
|
C14957gcv.e(str, "");
|
|
C14957gcv.e(str2, "");
|
|
C14957gcv.e(interfaceC3521azC, "");
|
|
C14957gcv.e(aan, "");
|
|
this.e = str;
|
|
this.g = str2;
|
|
this.c = interfaceC3521azC;
|
|
this.b = aan;
|
|
}
|
|
|
|
/* loaded from: classes3.dex */
|
|
public static final class IeS {
|
|
private IeS() {
|
|
}
|
|
|
|
public /* synthetic */ IeS(byte b) {
|
|
this();
|
|
}
|
|
}
|
|
|
|
/* JADX WARN: Removed duplicated region for block: B:40:0x00c3 */
|
|
/* JADX WARN: Removed duplicated region for block: B:42:0x00c8 */
|
|
/* JADX WARN: Removed duplicated region for block: B:44:? A[RETURN, SYNTHETIC] */
|
|
/*
|
|
Code decompiled incorrectly, please refer to instructions dump.
|
|
To view partially-correct add '--show-bad-code' argument
|
|
*/
|
|
public final java.lang.String a(java.lang.String r7, java.lang.String r8) {
|
|
/*
|
|
Method dump skipped, instructions count: 786
|
|
To view this dump add '--comments-level debug' option
|
|
*/
|
|
throw new UnsupportedOperationException("Method not decompiled: o.CBe.a(java.lang.String, java.lang.String):java.lang.String");
|
|
}
|
|
|
|
public final AbstractC13163fSk<uoJ> b() {
|
|
AAN aan = this.b;
|
|
List singletonList = Collections.singletonList("all");
|
|
C14957gcv.c(singletonList, "");
|
|
AbstractC13163fSk<uoJ> c = aan.c(new C14007fl(singletonList));
|
|
final LWm lWm = new LWm(this);
|
|
AbstractC13163fSk<uoJ> doOnNext = c.doOnNext(new fSQ(lWm) { // from class: o.Umc
|
|
private InterfaceC14894gbR c;
|
|
|
|
@Override // o.fSQ
|
|
public final void c(Object obj) {
|
|
InterfaceC14894gbR interfaceC14894gbR = this.c;
|
|
C14957gcv.e(interfaceC14894gbR, "");
|
|
interfaceC14894gbR.invoke(obj);
|
|
}
|
|
|
|
{
|
|
this.c = lWm;
|
|
}
|
|
});
|
|
final Sts sts = new Sts(this);
|
|
AbstractC13163fSk<uoJ> doOnError = doOnNext.doOnError(new fSQ(sts) { // from class: o.KyA
|
|
private InterfaceC14894gbR e;
|
|
|
|
@Override // o.fSQ
|
|
public final void c(Object obj) {
|
|
InterfaceC14894gbR interfaceC14894gbR = this.e;
|
|
C14957gcv.e(interfaceC14894gbR, "");
|
|
interfaceC14894gbR.invoke(obj);
|
|
}
|
|
|
|
{
|
|
this.e = sts;
|
|
}
|
|
});
|
|
C14957gcv.c(doOnError, "");
|
|
return doOnError;
|
|
}
|
|
|
|
/* JADX INFO: Access modifiers changed from: package-private */
|
|
/* loaded from: classes3.dex */
|
|
public static final class LWm extends AbstractC14961gcz implements InterfaceC14894gbR<uoJ, C14866gag> {
|
|
private CBe a;
|
|
|
|
@Override // o.InterfaceC14894gbR
|
|
public final /* bridge */ /* synthetic */ C14866gag invoke(uoJ uoj) {
|
|
this.a.d = uoj;
|
|
return C14866gag.c;
|
|
}
|
|
|
|
/* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
|
|
LWm(CBe cBe) {
|
|
super(1);
|
|
this.a = cBe;
|
|
}
|
|
}
|
|
|
|
/* JADX INFO: Access modifiers changed from: package-private */
|
|
/* loaded from: classes3.dex */
|
|
public static final class Sts extends AbstractC14961gcz implements InterfaceC14894gbR<Throwable, C14866gag> {
|
|
private CBe a;
|
|
|
|
@Override // o.InterfaceC14894gbR
|
|
public final /* bridge */ /* synthetic */ C14866gag invoke(Throwable th) {
|
|
this.a.d = null;
|
|
return C14866gag.c;
|
|
}
|
|
|
|
/* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
|
|
Sts(CBe cBe) {
|
|
super(1);
|
|
this.a = cBe;
|
|
}
|
|
}
|
|
|
|
/* JADX WARN: Removed duplicated region for block: B:23:0x005a */
|
|
/* JADX WARN: Removed duplicated region for block: B:25:0x005e A[ORIG_RETURN, RETURN] */
|
|
/* JADX WARN: Removed duplicated region for block: B:27:? A[RETURN, SYNTHETIC] */
|
|
/*
|
|
Code decompiled incorrectly, please refer to instructions dump.
|
|
To view partially-correct add '--show-bad-code' argument
|
|
*/
|
|
private final java.lang.String e(java.lang.String r7) {
|
|
/*
|
|
r6 = this;
|
|
o.uoJ r0 = r6.d
|
|
r1 = 0
|
|
if (r0 == 0) goto L57
|
|
java.util.List<o.TAm> r0 = r0.c
|
|
if (r0 == 0) goto L57
|
|
java.lang.Iterable r0 = (java.lang.Iterable) r0
|
|
java.util.Iterator r0 = r0.iterator()
|
|
Lf:
|
|
boolean r2 = r0.hasNext()
|
|
if (r2 == 0) goto L2b
|
|
java.lang.Object r2 = r0.next()
|
|
r3 = r2
|
|
o.TAm r3 = (o.TAm) r3
|
|
java.lang.String r3 = r3.b
|
|
java.lang.CharSequence r3 = (java.lang.CharSequence) r3
|
|
r4 = r7
|
|
java.lang.CharSequence r4 = (java.lang.CharSequence) r4
|
|
r5 = 0
|
|
boolean r3 = o.gdZ.d(r3, r4, r5)
|
|
if (r3 == 0) goto Lf
|
|
goto L2c
|
|
L2b:
|
|
r2 = r1
|
|
L2c:
|
|
o.TAm r2 = (o.TAm) r2
|
|
if (r2 == 0) goto L57
|
|
java.util.List<o.drv> r7 = r2.d
|
|
if (r7 == 0) goto L57
|
|
java.lang.Iterable r7 = (java.lang.Iterable) r7
|
|
java.util.Iterator r7 = r7.iterator()
|
|
L3a:
|
|
boolean r0 = r7.hasNext()
|
|
if (r0 == 0) goto L53
|
|
java.lang.Object r0 = r7.next()
|
|
r2 = r0
|
|
o.drv r2 = (o.C9866drv) r2
|
|
java.lang.String r3 = r6.e
|
|
java.lang.String r2 = r2.e
|
|
r4 = 1
|
|
boolean r2 = o.gdZ.a(r3, r2, r4)
|
|
if (r2 == 0) goto L3a
|
|
goto L54
|
|
L53:
|
|
r0 = r1
|
|
L54:
|
|
o.drv r0 = (o.C9866drv) r0
|
|
goto L58
|
|
L57:
|
|
r0 = r1
|
|
L58:
|
|
if (r0 == 0) goto L5c
|
|
java.lang.String r1 = r0.d
|
|
L5c:
|
|
if (r1 != 0) goto L60
|
|
java.lang.String r1 = ""
|
|
L60:
|
|
return r1
|
|
*/
|
|
throw new UnsupportedOperationException("Method not decompiled: o.CBe.e(java.lang.String):java.lang.String");
|
|
}
|
|
|
|
public final String c(String str) {
|
|
String str2;
|
|
List<TAm> list;
|
|
List<TAm> list2;
|
|
C14957gcv.e(str, "");
|
|
uoJ uoj = this.d;
|
|
Object obj = null;
|
|
if (uoj == null || (list = uoj.c) == null || !(!list.isEmpty())) {
|
|
List<TAm> list3 = b().onErrorReturnItem(new uoJ(C14851gaI.c)).blockingFirst().c;
|
|
if (list3 == null) {
|
|
return "";
|
|
}
|
|
Iterator<T> it = list3.iterator();
|
|
while (true) {
|
|
if (!it.hasNext()) {
|
|
break;
|
|
}
|
|
Object next = it.next();
|
|
if (gdZ.d((CharSequence) ((TAm) next).b, (CharSequence) str, false)) {
|
|
obj = next;
|
|
break;
|
|
}
|
|
}
|
|
TAm tAm = (TAm) obj;
|
|
if (tAm == null || (str2 = tAm.e) == null) {
|
|
return "";
|
|
}
|
|
} else {
|
|
uoJ uoj2 = this.d;
|
|
if (uoj2 == null || (list2 = uoj2.c) == null) {
|
|
return "";
|
|
}
|
|
Iterator<T> it2 = list2.iterator();
|
|
while (true) {
|
|
if (!it2.hasNext()) {
|
|
break;
|
|
}
|
|
Object next2 = it2.next();
|
|
if (gdZ.d((CharSequence) ((TAm) next2).b, (CharSequence) str, false)) {
|
|
obj = next2;
|
|
break;
|
|
}
|
|
}
|
|
TAm tAm2 = (TAm) obj;
|
|
if (tAm2 == null || (str2 = tAm2.e) == null) {
|
|
return "";
|
|
}
|
|
}
|
|
return str2;
|
|
}
|
|
|
|
static {
|
|
new IeS((byte) 0);
|
|
}
|
|
}
|